Struct nakadion::publisher::TelemetryDriver

pub struct TelemetryDriver { /* fields omitted */ }

Triggers registered ProcessesTelemetryMessages to poll for messages.

Runs its own background thread. The thread stops once this struct is dropped.

A TelemetryDriver can be ‘mounted’ into the hierarchy. If done so, it will still poll its children on its own thread independently.

Optional Metrics

The driver can be configured to collect metrics on its own activities.

The metrics will be added to all snapshots under a field named _metrix which contains the following fields:

• collections_per_second: The number of observation collection runs done per second

• collection_times_us: A histogram of the time each observation collection took in microseconds.

• observations_processed_per_second: The number of observations processed per second.

• observations_processed_per_collection: A histogram of the number of observations processed during each run

• observations_dropped_per_second: The number of observations dropped per second. See also max_observation_age.

• observations_dropped_per_collection: A histogram of the number of observations dropped during each run. See also max_observation_age.

• snapshots_per_second: The number of snapshots taken per second.

• snapshots_times_us: A histogram of the times it took to take a snapshot in microseconds

• dropped_observations_alarm: Will be true if observations have been dropped. Will by default stay true for 60 seconds once triggered.

• inactivity_alarm: Will be true if no observations have been made for a certain amount of time. The default is 60 seconds.

Implementations

impl TelemetryDriver

pub fn new(
    name: Option<String>,
    title: Option<String>,
    description: Option<String>,
    processing_strategy: ProcessingStrategy,
    with_driver_metrics: bool
) -> TelemetryDriver

Creates a new TelemetryDriver.

max_observation_age is the maximum age of an Observation to be taken into account. This is determined by the timestamp field of an Observation. Observations that are too old are simply dropped. The default is 60 seconds.

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

Gets the name of this driver

pub fn change_processing_stragtegy(&self, strategy: ProcessingStrategy)

Changes the ProcessingStrategy

pub fn pause(&self)

Pauses processing of observations.

pub fn resume(&self)

Resumes processing of observations

pub fn snapshot(&self, descriptive: bool) -> Result<Snapshot, GetSnapshotError>

pub fn snapshot_async(
    &self,
    descriptive: bool
) -> impl Future<Output = Result<Snapshot, GetSnapshotError>> + Send + 'static

Trait Implementations

impl AggregatesProcessors for TelemetryDriver

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 Clone for TelemetryDriver

pub fn clone(&self) -> TelemetryDriver

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TelemetryDriver

pub fn default() -> TelemetryDriver

Returns the “default value” for a type.

impl Descriptive for TelemetryDriver

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

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

impl ProcessesTelemetryMessages for TelemetryDriver

pub fn process(
    &mut self,
    _max: usize,
    _strategy: ProcessingStrategy
) -> ProcessingOutcome

Receive and handle pending operations

impl PutsSnapshot for TelemetryDriver

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.