Trait nakadion::publisher::AggregatesProcessors [−][src]
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 { ... }
}
Expand description
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
fn add_processor<P>(&mut self, processor: P) where
P: ProcessesTelemetryMessages,
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,
fn add_snapshooter<S>(&mut self, snapshooter: S) where
S: PutsSnapshot,
Add a snapshooter.