Struct MetricEntry 

pub struct MetricEntry {

    pub total_received: u64,
    pub total_completed: u64,
    pub total_process_errors: u64,
    pub total_output_errors: u64,
    pub total_filtered: 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,
    pub cpu_usage_percent: Option<f32>,
    pub memory_used_bytes: Option<u64>,
    pub memory_total_bytes: Option<u64>,
    pub input_bytes: u64,
    pub output_bytes: u64,
    pub bytes_per_sec: f64,
    pub latency_avg_ms: f64,
    pub latency_min_ms: f64,
    pub latency_max_ms: 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

total_filtered: u64

• total_filtered - Messages intentionally filtered/dropped by processors

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

cpu_usage_percent: Option<f32>

• cpu_usage_percent - System CPU usage percentage (0-100), None if not collected

memory_used_bytes: Option<u64>

• memory_used_bytes - System memory used in bytes, None if not collected

memory_total_bytes: Option<u64>

• memory_total_bytes - System total memory in bytes, None if not collected

input_bytes: u64

• input_bytes - Total bytes received from input

output_bytes: u64

• output_bytes - Total bytes written to output

bytes_per_sec: f64

• bytes_per_sec - Current throughput in bytes per second (based on output_bytes)

latency_avg_ms: f64

• latency_avg_ms - Average message processing latency in milliseconds

latency_min_ms: f64

• latency_min_ms - Minimum message processing latency in milliseconds

latency_max_ms: f64

• latency_max_ms - Maximum message processing latency in milliseconds

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