Struct metered::common::AtomicTxPerSec

pub struct AtomicTxPerSec<T: Instant = StdInstant> {
    pub inner: Mutex<TxPerSec<T>>,
}

Thread-safe implementation of super::RecordThroughput. It uses a Mutex to wrap TxPerSec.

Fields

inner: Mutex<TxPerSec<T>>

The inner mutex protecting the TxPerSec value holding the histogram

Implementations

impl<T: Instant> AtomicTxPerSec<T>

pub fn histogram(&self) -> HdrHistogram

Returns a cloned snapshot of the inner histogram.

Trait Implementations

impl<T: Instant> Clear for AtomicTxPerSec<T>

fn clear(&self)

Requests to clear self.

impl<T: Instant> Debug for AtomicTxPerSec<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Instant> Default for AtomicTxPerSec<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Instant> RecordThroughput for AtomicTxPerSec<T>

fn on_result(&self)

Called after the execution that the throughput metric is measuring.

impl<T: Instant> Serialize for AtomicTxPerSec<T>

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error> where
    S: Serializer, 

Serialize this value into the given Serde serializer.