[−][src]Trait nakadion::consumer::AggregatesProcessors
Implementors can group everything that can process
TelemetryMessage
s.
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,
[src]
P: ProcessesTelemetryMessages,
Add a processor.
pub fn add_snapshooter<S>(&mut self, snapshooter: S) where
S: PutsSnapshot,
[src]
S: PutsSnapshot,
Add a snapshooter.
Provided methods
pub fn attached_mount(&mut self, mount: ProcessorMount) -> AttachedMount
[src]
Implementations on Foreign Types
impl AggregatesProcessors for AttachedMount
[src]
pub fn add_processor<P>(&mut self, processor: P) where
P: ProcessesTelemetryMessages,
[src]
P: ProcessesTelemetryMessages,
pub fn add_snapshooter<S>(&mut self, snapshooter: S) where
S: PutsSnapshot,
[src]
S: PutsSnapshot,
Implementors
impl AggregatesProcessors for ProcessorMount
[src]
pub fn add_processor<P>(&mut self, processor: P) where
P: ProcessesTelemetryMessages,
[src]
P: ProcessesTelemetryMessages,
pub fn add_snapshooter<S>(&mut self, snapshooter: S) where
S: PutsSnapshot,
[src]
S: PutsSnapshot,
impl AggregatesProcessors for TelemetryDriver
[src]
pub fn add_processor<P>(&mut self, processor: P) where
P: ProcessesTelemetryMessages,
[src]
P: ProcessesTelemetryMessages,
pub fn add_snapshooter<S>(&mut self, snapshooter: S) where
S: PutsSnapshot,
[src]
S: PutsSnapshot,