Trait nakadion::publisher::AggregatesProcessors

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

    pub fn attached_mount(&mut self, mount: ProcessorMount) -> AttachedMount { ... }
}

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

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

Add a processor.

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

Add a snapshooter.

Loading content...

Provided methods

pub fn attached_mount(&mut self, mount: ProcessorMount) -> AttachedMount

Loading content...

Implementations on Foreign Types

impl AggregatesProcessors for AttachedMount

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

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

Loading content...

Implementors

impl AggregatesProcessors for ProcessorMount

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

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

impl AggregatesProcessors for TelemetryDriver

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

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

Loading content...