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>)

Collect an observation.

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

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

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

Observed count occurences at time timestamp

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

Observed one occurence at time timestamp

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

Observed one occurence with value value at time timestamp

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

Observed count occurences at now.

fn observed_one_now(&self, label: L)

Observed one occurence now

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

Observed one occurence with value value now