Struct mz_environmentd::http::metrics::PrometheusFuture

pub struct PrometheusFuture<F> {
    source: &'static str,
    path: String,
    timer: Option<HistogramTimer>,
    metrics: Metrics,
    fut: F,
}

Fields

source: &'static str

The server source label.

path: String

The axum router path this request matched.

timer: Option<HistogramTimer>

Instant at which we started the requst.

metrics: Metrics

Metrics registry used to record events.

fut: F

Inner request future.

Implementations

impl<F> PrometheusFuture<F>

pub(crate) fn project<'pin>( self: Pin<&'pin mut Self> ) -> __PrometheusFutureProjection<'pin, F>

pub(crate) fn project_ref<'pin>( self: Pin<&'pin Self> ) -> __PrometheusFutureProjectionRef<'pin, F>

impl<F> PrometheusFuture<F>

pub fn new(source: &'static str, fut: F, path: String, metrics: Metrics) -> Self

Trait Implementations

impl<F> Drop for PrometheusFuture<F>

fn drop(&mut self)

Executes the destructor for this type.

impl<F, R, E> Future for PrometheusFuture<F>

where R: IntoResponse, E: Into<Infallible>, F: Future<Output = Result<R, E>>,

type Output = Result<Response<UnsyncBoxBody<Bytes, Error>>, E>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<'pin, F> Unpin for PrometheusFuture<F>

where __PrometheusFuture<'pin, F>: Unpin,