Struct BatchSink 

pub struct BatchSink {
    tx: Sender<Value>,
    name: String,
}

Handle to a spawned batching task. Cheap to clone; the background task flushes any remaining entries and exits when the last handle is dropped.

Fields

tx: Sender<Value>

name: String

Implementations

impl BatchSink

pub fn spawn( name: &str, cfg: BatchConfig, flusher: Arc<dyn BatchFlusher>, ) -> Self

Spawns the background flush task and returns the sink handle.

name identifies the sink (typically the logger node id) in warning and error logs.

pub fn push(&self, entry: Value)

Non-blocking enqueue of one log entry.

Never blocks or awaits: when the channel is full (the background task is not keeping up, e.g. a slow or retrying downstream) the entry is dropped and a tracing::warn! is emitted. The rate of such drops is the operator’s signal to raise max_pending_entries.

Trait Implementations

impl Clone for BatchSink

fn clone(&self) -> BatchSink

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.