Trait nakadion::publisher::AggregatesProcessors

pub trait AggregatesProcessors {
    fn add_processor<P>(&mut self, processor: P)
    where
        P: ProcessesTelemetryMessages;
    fn add_snapshooter<S>(&mut self, snapshooter: S)
    where
        S: PutsSnapshot;
}

Implementors can group everything that can process TelemetryMessages.

Since PutsSnapshot implementors can be added almost everywhere the add_snapshooter method is placed here, too.

Required methods

fn add_processor<P>(&mut self, processor: P) where
    P: ProcessesTelemetryMessages, 

Add a processor.

fn add_snapshooter<S>(&mut self, snapshooter: S) where
    S: PutsSnapshot, 

Add a snapshooter.

Loading content...

Implementors

impl AggregatesProcessors for ProcessorMount

fn add_processor<P>(&mut self, processor: P) where
    P: ProcessesTelemetryMessages, 

fn add_snapshooter<S>(&mut self, snapshooter: S) where
    S: PutsSnapshot, 

impl AggregatesProcessors for TelemetryDriver

fn add_processor<P>(&mut self, processor: P) where
    P: ProcessesTelemetryMessages, 

fn add_snapshooter<S>(&mut self, snapshooter: S) where
    S: PutsSnapshot, 

Loading content...