Struct OperatorMetrics 

pub struct OperatorMetrics { /* private fields */ }

Operator-stage handles (spate_operator_*).

Implementations

impl OperatorMetrics

pub fn new(labels: &ComponentLabels) -> Self

Resolve all operator handles.

pub fn batch(&self, records_in: u64, records_out: u64, d: Duration)

Record one processed batch.

pub fn filtered(&self, n: u64)

Count records removed by a predicate.

pub fn skipped(&self, n: u64)

Count records dropped by the Skip error policy.

pub fn unrouted(&self, n: u64)

Count records dropped because they matched no split-sink branch and the split’s unmatched policy is Skip.

pub fn errors(&self, class: ErrorClass, n: u64)

Count user-code errors of one taxonomy class.

Trait Implementations

impl Debug for OperatorMetrics

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

Formats the value using the given formatter.