Struct Buffered 

pub struct Buffered<R, S> { /* private fields */ }

In-memory buffering tier: holds records and pushes them downstream when its FlushPolicy fires.

The policy is checked on each ingest (collector ticks are frequent compared to flush windows, so no extra timer task is needed); flush force-drains. On downstream failure the records are kept and retried at the next firing — a transient outage of the terminal sink does not lose data held in this tier.

Requires R: Clone so retained records survive a failed downstream ingest.

Implementations

impl<R, S> Buffered<R, S>

pub fn new(policy: FlushPolicy, inner: S) -> Self

pub fn inner(&self) -> &S

Access the wrapped sink.

Trait Implementations

impl<R, S> Sink<R> for Buffered<R, S>

where R: Clone + Send + 'static, S: Sink<R>,

type Error = <S as Sink<R>>::Error

Concrete error type (a thiserror enum, not a boxed error).

async fn ingest( &mut self, meta: &WindowMeta, records: Vec<R>, ) -> Result<(), Self::Error>

Hand records to this layer. A buffering layer may hold them; a terminal sink ships them immediately.

async fn flush(&mut self) -> Result<(), Self::Error>

Force-drain this layer and everything downstream (shutdown, final flush, startup recovery).