Struct SyslogFlusher 

struct SyslogFlusher {
    host: String,
    port: u16,
    sock_type: SockType,
    timeout: Duration,
}

BatchFlusher that concatenates the framed messages and sends them over TCP or UDP.

Fields

host: String

port: u16

sock_type: SockType

timeout: Duration

Implementations

impl SyslogFlusher

fn payload(entries: &[Value]) -> String

Concatenates the buffered frame strings into one payload.

async fn send(&self, payload: &[u8]) -> Result<(), String>

Trait Implementations

impl BatchFlusher for SyslogFlusher

fn flush<'life0, 'life1, 'async_trait>( &'life0 self, entries: &'life1 [Value], ) -> Pin<Box<dyn Future<Output = Result<(), FlushError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Attempts to deliver entries. On partial success, return a FlushError with first_fail set so the sink retries only the undelivered tail.