Struct ShardCounters 

pub struct ShardCounters {
    pub events_ingested: AtomicU64,
    pub events_dropped: AtomicU64,
    pub batches_dispatched: AtomicU64,
}

Atomic counters for a single shard. Kept outside Shard as Arcs so ShardManager::stats() can aggregate them without locking each shard’s mutex.

Fields

events_ingested: AtomicU64

Total events ingested into this shard.

events_dropped: AtomicU64

Events dropped due to backpressure.

batches_dispatched: AtomicU64

Batches successfully dispatched to the adapter.

Implementations

impl ShardCounters

pub fn snapshot(&self) -> ShardStats

Load a consistent snapshot of the counters.

events_unrouted is left at zero here — it is a manager-level counter, not a per-shard one. ShardManager::stats() fills it in after summing per-shard fields.

Trait Implementations

impl Debug for ShardCounters

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

Formats the value using the given formatter.

impl Default for ShardCounters

fn default() -> ShardCounters

Returns the “default value” for a type.