Function metriki_warp::with_metrics[][src]

pub fn with_metrics(
    m: Arc<MetricsRegistry>
) -> impl Filter<Extract = (Arc<MetricsRegistry>,), Error = Infallible> + Clone

Inject metriki MetricRegistry into your warp handler

use std::sync::Arc;

use metriki_core::MetricsRegistry;
use metriki_warp::with_metrics;
use warp::{self, Filter};

let metrics = MetricsRegistry::arc();
let router = warp::get()
  .and(with_metrics(metrics))
  .map(|mtk: Arc<MetricsRegistry>| {
     mtk.meter("hit").mark();
     "yes"
  });