Struct LockFreeStatsCollector

pub struct LockFreeStatsCollector { /* private fields */ }

Lock-free statistics collector using atomic operations

Implementations

impl LockFreeStatsCollector

pub fn new() -> Self

Create a new lock-free statistics collector

pub fn record_event(&self)

Record a processed event (lock-free, relaxed ordering for maximum performance)

pub fn record_trades(&self, count: u64)

Record processed trades in batch (lock-free)

pub fn record_orderbooks(&self, count: u64)

Record processed orderbooks in batch (lock-free)

pub fn record_bytes_serialized(&self, bytes: u64)

Record serialized bytes (lock-free)

pub fn record_simd_batch(&self)

Record SIMD batch processing (lock-free)

pub fn record_buffer_reuse(&self)

Record buffer reuse (lock-free)

pub fn record_zero_copy_ops(&self, count: u64)

Record zero-copy operations (lock-free)

pub fn update_latency(&self, latency_nanos: u64)

Update average latency using exponential moving average (lock-free)

pub fn record_connection_error(&self)

Record connection error (lock-free)

pub fn record_parsing_error(&self)

Record parsing error (lock-free)

pub fn record_serialization_error(&self)

Record serialization error (lock-free)

pub fn record_exchange_message(&self, exchange: &str, bytes: u64)

Record exchange message (mostly lock-free, minimal lock contention)

pub fn record_exchange_reconnection(&self, exchange: &str)

Record exchange reconnection (mostly lock-free)

pub fn get_snapshot(&self) -> StatsSnapshot

Get a snapshot of current statistics (mostly lock-free reads)

pub fn reset(&self)

Reset all statistics (used for benchmarking)

pub fn get_events_per_second(&self) -> f64

Get current events per second rate (lock-free)

pub fn get_avg_latency_nanos(&self) -> u64

Get current average latency in nanoseconds (lock-free)

Trait Implementations

impl Debug for LockFreeStatsCollector

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

Formats the value using the given formatter.

impl Default for LockFreeStatsCollector

fn default() -> Self

Returns the “default value” for a type.

impl Send for LockFreeStatsCollector

impl Sync for LockFreeStatsCollector