Trait nakadion::instrumentation::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;

    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

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.

Provided methods

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

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, 

Implementors

impl AggregatesProcessors for ProcessorMount

impl AggregatesProcessors for TelemetryDriver