Struct mz_persist_client::internal::metrics::ExternalOpMetrics

pub struct ExternalOpMetrics {
    started: IntCounter,
    succeeded: IntCounter,
    failed: IntCounter,
    bytes: IntCounter,
    seconds: Counter,
    seconds_histogram: Option<Histogram>,
    alerts_metrics: Arc<AlertsMetrics>,
}

Fields

started: IntCounter

succeeded: IntCounter

failed: IntCounter

bytes: IntCounter

seconds: Counter

seconds_histogram: Option<Histogram>

alerts_metrics: Arc<AlertsMetrics>

Implementations

impl ExternalOpMetrics

async fn run_op<R, F, OpFn, ErrFn>( &self, op_fn: OpFn, on_err_fn: ErrFn, ) -> Result<R, ExternalError>

where F: Future<Output = Result<R, ExternalError>>, OpFn: FnOnce() -> F, ErrFn: FnOnce(&AlertsMetrics, &ExternalError),

fn run_stream<'a, R: 'a, S, OpFn, ErrFn>( &'a self, op_fn: OpFn, on_err_fn: ErrFn, ) -> impl Stream<Item = Result<R, ExternalError>> + 'a

where S: Stream<Item = Result<R, ExternalError>> + Unpin + 'a, OpFn: FnOnce() -> S, ErrFn: FnMut(&AlertsMetrics, &ExternalError) + 'a,

Trait Implementations

impl Debug for ExternalOpMetrics

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

Formats the value using the given formatter.