Struct metered::InFlight

pub struct InFlight<G: Gauge = AtomicInt<u64>>(pub G);

A metric providing an in-flight gauge, showing how many calls are currently active for an expression.

This is a light-weight metric.

This makes sense mostly in a multi-threaded situation where several threads may call the same method constantly, and we want to monitor how many are active at a given time.

The Throughput metric shows an alternative view of the same picture, by reporting how many transactions per seconds are processed by an expression.

By default, InFlight uses a lock-free u64 Gauge, which makes sense in multithread scenarios. Non-threaded applications can gain performance by using a std::cell:Cell<u64> instead.

Trait Implementations

impl<G: Gauge> Clear for InFlight<G>

fn clear(&self)

Requests to clear self.

impl<G: Clone + Gauge> Clone for InFlight<G>

fn clone(&self) -> InFlight<G>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<G: Debug + Gauge> Debug for InFlight<G>

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

Formats the value using the given formatter.

impl<G: Default + Gauge> Default for InFlight<G>

fn default() -> InFlight<G>

Returns the "default value" for a type.

impl<G: Gauge> Deref for InFlight<G>

type Target = G

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<G: Gauge> Enter for InFlight<G>

type E = ()

The type returned by the enter function and carried to OnResult

fn enter(&self)

enter is called when entering in an aspect

impl<G: Gauge, R> Metric<R> for InFlight<G>

impl<G: Gauge, R> OnResult<R> for InFlight<G>

fn leave_scope(&self, _: ()) -> Advice

Called when an expression has exited, but the return value isn't known. This can happen because of a panic, or if control flow bypasses a macro. This is also called by the default implementation of on_result.

fn on_result(&self, enter: Self::E, _result: &R) -> Advice

Called when an expression has returned.

impl<G: Gauge> Serialize for InFlight<G> where
    G: Serialize, 

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

Serialize this value into the given Serde serializer.