Struct nakadion::consumer::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), Global>

Returns the processors in this ProcessorMount

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

Returns the snapshooters of this ProcessorMount

pub fn add_processor_dyn(
    &mut self,
    processor: Box<dyn ProcessesTelemetryMessages + 'static, Global>
)

pub fn add_snapshooter_dyn(
    &mut self,
    snapshooter: Box<dyn PutsSnapshot + 'static, Global>
)

Trait Implementations

impl AggregatesProcessors for ProcessorMount

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.

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

impl Default for ProcessorMount

pub fn default() -> ProcessorMount

Returns the “default value” for a type.

impl Descriptive for ProcessorMount

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

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

impl ProcessesTelemetryMessages for ProcessorMount

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

Receive and handle pending operations

impl PutsSnapshot for ProcessorMount

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

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