Trait metrix::processor::ProcessesTelemetryMessages

pub trait ProcessesTelemetryMessages: PutsSnapshot + Send + 'static {
    fn process(
        &mut self, 
        max: usize, 
        drop_deadline: Instant
    ) -> ProcessingOutcome;
}

Can process TelemetryMessage.

This is the counterpart of TransmitsTelemetryData.

Since this mostly results in metrics this trait also requires the capability to write Snapshots.

Required Methods

fn process(&mut self, max: usize, drop_deadline: Instant) -> ProcessingOutcome

Receive and handle pending operations

Implementors

• impl ProcessesTelemetryMessages for TelemetryDriver

• impl<L> ProcessesTelemetryMessages for TelemetryProcessor<L> where     L: Clone + Eq + Send + 'static,

• impl ProcessesTelemetryMessages for ProcessorMount