Struct PipelineCounters 

pub struct PipelineCounters {
    pub events_ingested: AtomicU64,
    pub events_emitted: AtomicU64,
    pub events_dropped: AtomicU64,
    pub cycles: AtomicU64,
    pub last_cycle_duration_ns: AtomicU64,
    pub total_batches: AtomicU64,
    pub checkpoints_completed: AtomicU64,
    pub checkpoints_failed: AtomicU64,
    pub last_checkpoint_duration_ms: AtomicU64,
    pub checkpoint_epoch: AtomicU64,
    /* private fields */
}

Shared atomic counters incremented by the pipeline processing loop.

Counters are separated into two groups on different cache lines to prevent false sharing between Ring 0 (hot path) and Ring 2 (checkpoint):

• Ring 0 group (events_ingested … total_batches): incremented on every processing cycle from the reactor thread.
• Ring 2 group (checkpoints_completed … checkpoint_epoch): updated from the async checkpoint coordinator.

All reads and writes use Ordering::Relaxed — metrics are advisory, not transactional.

Fields

events_ingested: AtomicU64

Total events ingested from sources.

events_emitted: AtomicU64

Total events emitted to streams/sinks.

events_dropped: AtomicU64

Total events dropped (e.g. backpressure).

cycles: AtomicU64

Total processing cycles completed.

last_cycle_duration_ns: AtomicU64

Duration of the last processing cycle in nanoseconds.

total_batches: AtomicU64

Total batches processed.

checkpoints_completed: AtomicU64

Total checkpoints completed successfully.

checkpoints_failed: AtomicU64

Total checkpoints that failed.

last_checkpoint_duration_ms: AtomicU64

Duration of the last checkpoint in milliseconds.

checkpoint_epoch: AtomicU64

Current checkpoint epoch.

Implementations

impl PipelineCounters

pub fn new() -> Self

Create zeroed counters.

pub fn snapshot(&self) -> CounterSnapshot

Take a snapshot of all counters.

Trait Implementations

impl Default for PipelineCounters

fn default() -> Self

Returns the “default value” for a type.