logforward.h

Go to the documentation of this file.

#pragma once
 
 
#include <cx/log/log.h>
#include <cx/log/logwire.h>
 
CX_C_BEGIN
 
typedef struct LogForwarder LogForwarder;
 
typedef struct LogForwardHandlers {
    bool (*send)(_In_opt_ void* ctx, _In_reads_bytes_(len) const uint8* buf, size_t len);
 
    void (*close)(_In_opt_ void* ctx);
} LogForwardHandlers;
 
#define LOG_FORWARD_SPOOL_DEFAULT (4 * 1024 * 1024)
 
#define LOG_FORWARD_SEGMENT_DEFAULT (256 * 1024)
 
#define LOG_FORWARD_MAXHOPS_DEFAULT 4
 
typedef struct LogForwardConfig {
    strref origin;       
    uint64 spoolbytes;   
    uint64 segbytes;     
    uint32 maxhops;      
} LogForwardConfig;
 
typedef struct LogForwardStats {
    uint64 sent;      
    uint64 spooled;   
    uint64 dropped;   
    uint64 looped;    
    uint64 failed;    
    uint64 pending;   
    bool subscribed;  
} LogForwardStats;
 
_Ret_opt_valid_ LogForwarder* logforwardRegister(int maxlevel, _In_opt_ strref chanfilter,
                                                 _In_ const LogForwardHandlers* handlers,
                                                 _In_opt_ void* ctx,
                                                 _In_opt_ const LogForwardConfig* config);
 
_Ret_valid_ LogDest* logForwardDest(_In_ LogForwarder* fwd);
 
void logforwardUnregister(_Pre_valid_ _Post_invalid_ LogForwarder* fwd);
 
void logForwardResume(_In_ LogForwarder* fwd);
 
void logForwardDisconnected(_In_ LogForwarder* fwd);
 
void logForwardConnected(_In_ LogForwarder* fwd);
 
bool logForwardTake(_In_ LogForwarder* fwd, _Inout_ Buffer* out);
 
bool logForwardRecv(_In_ LogForwarder* fwd, _In_reads_bytes_(len) const uint8* buf, size_t len);
 
bool logForwardApplySub(_In_ LogForwarder* fwd, _In_opt_ const LogSubSpec* spec);
 
bool logForwardCatalog(_In_ LogForwarder* fwd, _Inout_ Buffer* out);
 
void logForwardStats(_In_ LogForwarder* fwd, _Out_ LogForwardStats* out);
 
 
CX_C_END