Struct CheckpointMetrics 

pub struct CheckpointMetrics { /* private fields */ }

Checkpointer handles (spate_checkpoint_*).

Implementations

impl CheckpointMetrics

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

Resolve all checkpointer handles.

Claims the spate_checkpoint_* series for these labels; a second live handle set logs and becomes a shadow, counting commits but publishing no gauge (see “Series ownership” in docs/METRICS.md).

pub fn try_new( labels: &ComponentLabels, per_partition_detail: bool, ) -> Result<Self, MetricsError>

Resolve all checkpointer handles, failing when another live handle set already owns the series. The pipeline runtime’s path.

Errors

MetricsError::DuplicateSeries on a collision.

pub fn set_pending_max(&self, pending: usize)

Set the max pending-batch count across partitions.

pub fn set_partition_pending(&self, partition: PartitionId, pending: usize)

Set one partition’s pending count. No-op unless per_partition_detail.

pub fn retain_partitions(&self, keep: &[PartitionId])

Drop per-partition series for revoked partitions.

pub fn commit(&self, ok: bool, d: Duration)

Record one source commit call.

pub fn set_watermark_age(&self, age: Duration)

Set the age of the oldest unacknowledged batch.

Trait Implementations

impl Debug for CheckpointMetrics

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

Formats the value using the given formatter.