Struct SubscriptionStats

pub struct SubscriptionStats {
    pub dispatched: AtomicU64,
    pub dropped: AtomicU64,
    pub processed: Arc<AtomicU64>,
    pub actively_processing: Arc<AtomicU64>,
    pub flushed: Arc<AtomicU64>,
}

Thread-safe statistics tracker for the various stages of subscription processing. All counters use atomic operations for thread safety.

Fields

dispatched: AtomicU64

Number of messages dispatched to processing queues.

dropped: AtomicU64

Number of messages dropped due to queue overflow or errors.

processed: Arc<AtomicU64>

Number of messages that have completed processing. Wrapped in Arc for thread sharing.

actively_processing: Arc<AtomicU64>

Number of messages currently being processed. Wrapped in Arc for thread sharing.

flushed: Arc<AtomicU64>

Number of messages saved to disk (not processed). Wrapped in Arc for thread sharing.

Implementations

impl SubscriptionStats

pub fn new() -> Self

Creates a new instance with all counters initialized to zero.

pub fn snapshot(&self) -> SubscriptionStats

This creates a new SubscriptionStats instance with identical atomic counters.

pub fn get_dispatched(&self) -> u64

Returns the current number of dispatched messages.

pub fn get_dropped(&self) -> u64

Returns the current number of dropped messages.

pub fn get_processed(&self) -> u64

Returns the current number of processed messages.

pub fn get_actively_processing(&self) -> u64

Returns the current number of messages actively being processed.

pub fn get_flushed(&self) -> u64

Returns the current number of messages flushed to disk.

Trait Implementations

impl Default for SubscriptionStats

fn default() -> SubscriptionStats

Returns the “default value” for a type.

impl Display for SubscriptionStats

Prints current statistics to stdout.

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

Formats the value using the given formatter.