Struct ShardStats 

pub struct ShardStats {
    pub events_ingested: u64,
    pub events_dropped: u64,
    pub batches_dispatched: u64,
    pub events_unrouted: u64,
}

Statistics for a single shard (snapshot).

Fields

events_ingested: u64

Total events ingested.

events_dropped: u64

Events dropped due to backpressure.

batches_dispatched: u64

Batches dispatched to adapter.

events_unrouted: u64

Events that arrived at ingest_raw_batch but had no resolvable shard (e.g. the routing table was rebuilt mid-dispatch and the hashed shard id is no longer present). These cannot be attributed to a per-shard counter, so they are tracked at the ShardManager level and surfaced through aggregated stats().

Trait Implementations

impl Clone for ShardStats

fn clone(&self) -> ShardStats

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ShardStats

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

Formats the value using the given formatter.

impl Default for ShardStats

fn default() -> ShardStats

Returns the “default value” for a type.

impl Copy for ShardStats