Struct nakadion::publisher::ProcessorMount

pub struct ProcessorMount { /* fields omitted */ }

A building block for grouping

Implementations

impl ProcessorMount

pub fn new<T>(name: T) -> ProcessorMount where
    T: Into<String>, 

Creates a new instance.

Even though a name is optional having one is the default since this struct is mostly used to group other components.

pub fn name(&self) -> Option<&str>

Returns the name

pub fn set_name<T>(&mut self, name: T) where
    T: Into<String>, 

Sets the name of this ProcessorMount

pub fn set_inactivity_limit(&mut self, limit: Duration)

Sets the maximum amount of time this processor may be inactive until no more snapshots are taken

pub fn processors(&self) -> Vec<&(dyn ProcessesTelemetryMessages + 'static)>

Returns the processors in this ProcessorMount

pub fn snapshooters(&self) -> Vec<&(dyn PutsSnapshot + 'static)>

Returns the snapshooters of this ProcessorMount

Trait Implementations

impl AggregatesProcessors for ProcessorMount

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.

impl Default for ProcessorMount

fn default() -> ProcessorMount

Returns the "default value" for a type.

impl Descriptive for ProcessorMount

fn title(&self) -> Option<&str>

fn description(&self) -> Option<&str>

impl ProcessesTelemetryMessages for ProcessorMount

fn process(
    &mut self,
    max: usize,
    strategy: ProcessingStrategy
) -> ProcessingOutcome

Receive and handle pending operations

impl PutsSnapshot for ProcessorMount

fn put_snapshot(&self, into: &mut Snapshot, descriptive: bool)

Puts the current snapshot values into the given Snapshot thereby following the guidelines of PutsSnapshot.