Struct RuntimeMetrics 

pub struct RuntimeMetrics {
    pub resync_count: u64,
    pub seq_gaps: u64,
    pub unknown_orders: u64,
    pub unknown_resolved_ms: u64,
    pub rate_limit_hits: u64,
    pub rate_limit_by_bucket: Vec<(String, u64)>,
    pub buffer_conflated: u64,
    pub buffer_dropped: u64,
    pub buffer_overflow: u64,
    pub egress_latency_p50_ms: Duration,
    pub egress_latency_p99_ms: Duration,
}

A plain set of counters about the connector runtime.

It is a snapshot-style struct for the owner to fill and read. The runtime does not update it by itself and there is no exporter. All counts start at zero and only grow.

Examples

use brokapi_runtime::RuntimeMetrics;

let mut m = RuntimeMetrics::new();
m.record_rate_limit("orders");
m.record_rate_limit("orders");
m.record_rate_limit("global");
assert_eq!(m.rate_limit_hits, 3);
assert_eq!(m.rate_limit_by_bucket, vec![("orders".to_string(), 2), ("global".to_string(), 1)]);

Fields

resync_count: u64

Number of resyncs recorded with record_resync.

seq_gaps: u64

Number of sequence gaps recorded with record_seq_gap.

unknown_orders: u64

Number of orders that entered the Unknown state. The owner counts them, no method here does.

unknown_resolved_ms: u64

Milliseconds spent resolving Unknown orders. The owner decides how to sum it, the runtime does not fill it.

rate_limit_hits: u64

Number of calls refused by the rate limiter.

rate_limit_by_bucket: Vec<(String, u64)>

The same refusals split by bucket name, in order of first appearance.

buffer_conflated: u64

Events replaced by newer ones in Conflate buffers, added with record_conflated.

buffer_dropped: u64

Events thrown away by DropNewest buffers, added with record_dropped.

buffer_overflow: u64

Overflows of Lossless buffers, counted with record_overflow.

egress_latency_p50_ms: Duration

Median time from parsing an event to handing it to the consumer. Not filled by the runtime.

egress_latency_p99_ms: Duration

99th percentile of the same time. Not filled by the runtime.

Implementations

impl RuntimeMetrics

pub fn new() -> Self

Creates a zeroed set. Same as Default::default.

pub fn record_resync(&mut self)

Adds one to resync_count.

pub fn record_seq_gap(&mut self)

Adds one to seq_gaps.

pub fn record_rate_limit(&mut self, bucket: &str)

Counts one rate-limit refusal, in total and for bucket.

pub fn record_conflated(&mut self, n: u64)

Adds n to buffer_conflated.

pub fn record_dropped(&mut self, n: u64)

Adds n to buffer_dropped.

pub fn record_overflow(&mut self)

Adds one to buffer_overflow.

Trait Implementations

impl Clone for RuntimeMetrics

fn clone(&self) -> RuntimeMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RuntimeMetrics

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

Formats the value using the given formatter.

impl Default for RuntimeMetrics

fn default() -> RuntimeMetrics

Returns the “default value” for a type.

impl Eq for RuntimeMetrics

impl PartialEq for RuntimeMetrics

fn eq(&self, other: &RuntimeMetrics) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RuntimeMetrics