Struct metrix::TelemetryTransmitterSync

pub struct TelemetryTransmitterSync<L> { /* fields omitted */ }

Transmits Observations to the backend and has the Sync marker.

This is almost the same as the TelemetryTransmitter.

Since a Sender for a channel is not Sync this struct wraps the Sender in an Arc<Mutex<_>> so that it can be shared between threads.

Trait Implementations

impl<L: Clone> Clone for TelemetryTransmitterSync<L>

fn clone(&self) -> TelemetryTransmitterSync<L>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<L> TransmitsTelemetryData<L> for TelemetryTransmitterSync<L>

fn transmit(&self, observation: Observation<L>) -> &Self

Transit an observation to the backend.

fn add_handler(&self, handler: Box<HandlesObservations<Label = L>>) -> &Self

Add a handler.

fn add_cockpit(&self, cockpit: Cockpit<L>) -> &Self

Add a Copckpit

fn add_panel_to_cockpit(&self, cockpit_name: String, panel: Panel<L>) -> &Self

Add a Panel to a Cockpit if that Cockpit has the given name.

fn observed(&self, label: L, count: u64, timestamp: Instant) -> &Self

Observed count occurences at time timestamp

fn observed_one(&self, label: L, timestamp: Instant) -> &Self

Observed one occurence at time timestamp

fn observed_one_value(&self, label: L, value: u64, timestamp: Instant) -> &Self

Observed one occurence with value value at time timestamp

fn observed_duration(     &self,     label: L,     duration: Duration,     timestamp: Instant ) -> &Self

Sends a Duration as an observed value observed at timestamp. The Duration is converted to nanoseconds.

fn observed_now(&self, label: L, count: u64) -> &Self

Observed count occurences at now.

fn observed_one_now(&self, label: L) -> &Self

Observed one occurence now

fn observed_one_value_now(&self, label: L, value: u64) -> &Self

Observed one occurence with value value now

fn observed_one_duration_now(&self, label: L, duration: Duration) -> &Self

Sends a Duration as an observed value observed with the current timestamp.

fn measure_time(&self, label: L, from: Instant) -> &Self

Measures the time from from until now.