Struct PipelineStats 

pub struct PipelineStats {
    pub received: AtomicU64,
    pub processed: AtomicU64,
    pub errors: AtomicU64,
    pub dlq: AtomicU64,
    pub filtered: AtomicU64,
    pub bytes_received: AtomicU64,
    pub bytes_written: AtomicU64,
    pub batches_flushed: AtomicU64,
}

Available on crate features worker-batch or worker-pool or worker only.

Common DFE pipeline statistics with atomic counters.

Lock-free, safe to read and write from any thread. Uses Ordering::Relaxed – stats are informational, not safety-critical.

Fields

received: AtomicU64

Messages received from source (Kafka, HTTP, gRPC, etc.).

processed: AtomicU64

Messages successfully processed through the pipeline.

errors: AtomicU64

Messages that failed processing and were routed to DLQ or dropped.

dlq: AtomicU64

Messages sent to the dead letter queue (subset of errors, only if DLQ enabled).

filtered: AtomicU64

Messages filtered out (did not pass routing rules or predicates).

bytes_received: AtomicU64

Total bytes received from source.

bytes_written: AtomicU64

Total bytes written to sink.

batches_flushed: AtomicU64

Batches flushed to sink.

Implementations

impl PipelineStats

pub fn new() -> Self

Create new zeroed stats.

pub fn incr_received(&self)

pub fn incr_processed(&self)

pub fn incr_errors(&self)

pub fn incr_dlq(&self)

pub fn incr_filtered(&self)

pub fn incr_batches_flushed(&self)

pub fn add_received(&self, n: u64)

pub fn add_processed(&self, n: u64)

pub fn add_filtered(&self, n: u64)

pub fn add_bytes_received(&self, n: u64)

pub fn add_bytes_written(&self, n: u64)

pub fn snapshot(&self) -> PipelineStatsSnapshot

Take an immutable snapshot for logging, metrics, or display.

Trait Implementations

impl Debug for PipelineStats

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

Formats the value using the given formatter.

impl Default for PipelineStats

fn default() -> PipelineStats

Returns the “default value” for a type.