Struct StreamingProcessorStats 

pub struct StreamingProcessorStats {
    pub max_memory_bytes: usize,
    pub current_memory_bytes: usize,
    pub memory_utilization_percent: usize,
    pub records_processed: u64,
    pub bytes_processed: u64,
}

Statistics about streaming processor operation

Snapshot of current memory usage and processing metrics.

Fields

max_memory_bytes: usize

Maximum memory limit (bytes)

current_memory_bytes: usize

Current memory usage (bytes)

Estimated total memory across tracked buffers.

memory_utilization_percent: usize

Memory utilization percentage

Current usage as percentage of max (0-100).

records_processed: u64

Records processed

Total count of successfully processed records.

bytes_processed: u64

Bytes processed

Total input byte volume processed.

Trait Implementations

impl Clone for StreamingProcessorStats

fn clone(&self) -> StreamingProcessorStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingProcessorStats

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

Formats the value using the given formatter.