Struct metrix::processor::ProcessorMount

pub struct ProcessorMount { /* fields omitted */ }

A building block for grouping

Methods

impl ProcessorMount

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

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: Into<String>>(&mut self, name: T)

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<&ProcessesTelemetryMessages>

Returns the processors in this ProcessorMount

pub fn snapshooters(&self) -> Vec<&PutsSnapshot>

Returns the snapshooters of this ProcessorMount

Trait Implementations

impl Default for ProcessorMount

fn default() -> ProcessorMount

Returns the "default value" for a type.

impl AggregatesProcessors for ProcessorMount

fn add_processor<P: ProcessesTelemetryMessages>(&mut self, processor: P)

Add a processor.

fn add_snapshooter<S: PutsSnapshot>(&mut self, snapshooter: S)

Add a snapshooter.

impl ProcessesTelemetryMessages for ProcessorMount

fn process(&mut self, max: usize, drop_deadline: Instant) -> 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.

impl Descriptive for ProcessorMount

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

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