Struct TcpFlusher 

struct TcpFlusher {
    host: String,
    port: u16,
    timeout: Duration,
}

BatchFlusher that connects to host:port and writes the batch.

Fields

host: String

port: u16

timeout: Duration

Implementations

impl TcpFlusher

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

Trait Implementations

impl BatchFlusher for TcpFlusher

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.