Struct MetricEntry 

pub struct MetricEntry {
    pub total_received: u64,
    pub total_completed: u64,
    pub total_process_errors: u64,
    pub total_output_errors: u64,
    pub streams_started: u64,
    pub streams_completed: u64,
    pub duplicates_rejected: u64,
    pub stale_entries_removed: u64,
    pub in_flight: usize,
    pub throughput_per_sec: f64,
}

MetricEntry is the uniform struct utilized within metrics modules of fiddler.

let content = "This is a message being processed";
let metric = MetricEntry::default();

Fields

total_received: u64

• total_received - Total messages received from input

total_completed: u64

• total_completed - Messages successfully processed through all outputs

total_process_errors: u64

• total_process_errors - Messages that encountered processing errors

total_output_errors: u64

• total_output_errors - Messages that encountered output errors

streams_started: u64

• streams_started - Number of streams started

streams_completed: u64

• streams_completed - Number of streams completed

duplicates_rejected: u64

• duplicates_rejected - Duplicate messages rejected

stale_entries_removed: u64

• stale_entries_removed - Stale entries cleaned up

in_flight: usize

• in_flight - Current number of messages being processed

throughput_per_sec: f64

• throughput_per_sec - Current throughput in messages per second

Trait Implementations

impl Clone for MetricEntry

fn clone(&self) -> MetricEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetricEntry

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

Formats the value using the given formatter.

impl Default for MetricEntry

fn default() -> MetricEntry

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MetricEntry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for MetricEntry

fn eq(&self, other: &MetricEntry) -> 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 Serialize for MetricEntry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MetricEntry