Struct ProtocolMetricCache 

pub struct ProtocolMetricCache {
    cid: String,
    m: Arc<ProtocolMetrics>,
    cache: HashMap<Sid, CacheLine>,
    sdata_frames_t: GenericCounter<AtomicU64>,
    sdata_frames_b: GenericCounter<AtomicU64>,
    rdata_frames_t: GenericCounter<AtomicU64>,
    rdata_frames_b: GenericCounter<AtomicU64>,
    ping: GenericGauge<AtomicI64>,
}

Cache for ProtocolMetrics, more optimized and cleared up after channel disconnect.

Fields

cid: String

m: Arc<ProtocolMetrics>

cache: HashMap<Sid, CacheLine>

sdata_frames_t: GenericCounter<AtomicU64>

sdata_frames_b: GenericCounter<AtomicU64>

rdata_frames_t: GenericCounter<AtomicU64>

rdata_frames_b: GenericCounter<AtomicU64>

ping: GenericGauge<AtomicI64>

Implementations

impl ProtocolMetricCache

pub fn new(channel_key: &str, metrics: Arc<ProtocolMetrics>) -> Self

pub(crate) fn init_sid(&mut self, sid: Sid) -> &CacheLine

pub(crate) fn smsg_ib(&mut self, sid: Sid, bytes: u64)

pub(crate) fn smsg_ob(&mut self, sid: Sid, reason: RemoveReason, bytes: u64)

pub(crate) fn sdata_frames_b(&mut self, cnt: u64, bytes: u64)

pub(crate) fn rmsg_ib(&mut self, sid: Sid, bytes: u64)

pub(crate) fn rmsg_ob(&mut self, sid: Sid, reason: RemoveReason, bytes: u64)

pub(crate) fn rdata_frames_b(&mut self, bytes: u64)

Trait Implementations

impl Clone for ProtocolMetricCache

fn clone(&self) -> ProtocolMetricCache

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProtocolMetricCache

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

Formats the value using the given formatter.

impl Drop for ProtocolMetricCache

fn drop(&mut self)

Executes the destructor for this type.