Struct OperatorMetrics 

pub struct OperatorMetrics { /* private fields */ }

Operator-stage handles (spate_operator_*).

error_type names what the stage did with an error. A stage carries no error class of its own, so the retryable class belongs to SinkShardMetrics.

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 record_errors(&self, n: u64)

Count records whose failure the Skip error policy dropped.

pub fn fatal_error(&self)

Count one failure that stopped the pipeline.

Trait Implementations

impl Debug for OperatorMetrics

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

Formats the value using the given formatter.