Struct LogShipper 

pub struct LogShipper { /* private fields */ }

The handle the request path holds. Cloneable, cheap, and non-blocking to use.

Implementations

impl LogShipper

pub fn edge_id(&self) -> &str

This edge’s identity, stamped onto every record.

pub fn stats(&self) -> &Arc<ShipStats>

pub fn record(&self, rec: AccessRecord)

Hand a record to the shipper. Never blocks and never fails the caller.

try_send, not send().await: this is called from the response path of every request. An await here would couple request latency to collector latency, which is the precise failure this module exists to avoid — an access-log pipeline is not worth a millisecond of p99, let alone the unbounded stall a wedged collector would cause.

A full queue drops the NEWEST record rather than evicting the oldest. Both lose data; this one is O(1) with no locking, and during a collector outage the older records are the ones already batched and about to go out. Dropping is counted, never silent.

Trait Implementations

impl Clone for LogShipper

fn clone(&self) -> LogShipper

Returns a duplicate of the value.

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

Performs copy-assignment from source.