Struct BatchMetricsRecorder 

pub struct BatchMetricsRecorder { /* private fields */ }

Records metrics for a single batcher instance.

Created via BatchMetrics::recorder. Implements MetricsRecorder so it can be passed to Batcher::builder().metrics_recorder(...).

Trait Implementations

impl Clone for BatchMetricsRecorder

fn clone(&self) -> BatchMetricsRecorder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchMetricsRecorder

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

Formats the value using the given formatter.

impl MetricsRecorder for BatchMetricsRecorder

fn item_received(&self, channel_duration: Duration)

An item was received by the worker.

fn item_rejected(&self)

An item was rejected because the batch queue for its key is full.

fn batch_completed(&self, metrics: &BatchStats)

A batch finished processing and results were sent back to callers.

fn resource_acquisition_completed(&self, duration: Duration, success: bool)

Resource acquisition completed.

fn active_keys_changed(&self, count: usize)

The number of active keys (keys with batch queues) changed.

fn processing_concurrency_changed(&self, total: usize, max_per_key: usize)

The total number of batches currently processing changed.

fn queue_depth_changed(&self, total: usize, max_per_key: usize)

The total number of batches queued for processing changed.