Trait metrix::processor::ProcessesTelemetryMessages

pub trait ProcessesTelemetryMessages: PutsSnapshot + Send + 'static {
    fn process(
        &mut self, 
        max: usize, 
        strategy: ProcessingStrategy
    ) -> 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,
    strategy: ProcessingStrategy
) -> ProcessingOutcome

Receive and handle pending operations

Loading content...

Implementors

impl ProcessesTelemetryMessages for TelemetryDriver

fn process(
    &mut self,
    _max: usize,
    _strategy: ProcessingStrategy
) -> ProcessingOutcome

Receive and handle pending operations

impl ProcessesTelemetryMessages for ProcessorMount

fn process(
    &mut self,
    max: usize,
    strategy: ProcessingStrategy
) -> ProcessingOutcome

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

fn process(
    &mut self,
    max: usize,
    strategy: ProcessingStrategy
) -> ProcessingOutcome

Loading content...