Struct BufferedWriterSnapshot 

pub struct BufferedWriterSnapshot<E> {
    pub state: BufferedWriterState,
    pub queued: usize,
    pub direct_pending: usize,
    pub persisted: u64,
    pub direct_persisted: u64,
    pub observer_events_dropped: u64,
    pub batch_failure: Option<WriteFailure<E>>,
    pub batch_failure_records: usize,
    pub direct_failure: Option<WriteFailure<E>>,
}

Observable per-instance state. Counts include in-flight, unacknowledged records.

Fields

state: BufferedWriterState

Current admission/worker lifecycle.

queued: usize

Unacknowledged batch records, including any in-flight chunk.

direct_pending: usize

Unacknowledged overflow records (zero or one).

persisted: u64

Total acknowledged records across both lanes.

direct_persisted: u64

Acknowledged overflow records only; does not imply batch durability.

observer_events_dropped: u64

Events dropped because the bounded observer channel was full or closed.

batch_failure: Option<WriteFailure<E>>

Failure blocking the front chunk; originals remain in queue order.

batch_failure_records: usize

Front records affected by batch_failure; later queued records were not attempted.

direct_failure: Option<WriteFailure<E>>

Failure blocking the retained overflow record.

Trait Implementations

impl<E: Debug> Debug for BufferedWriterSnapshot<E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.