rust 42 lines · 7 steps

Prometheus request metrics in Axum

An Axum middleware times every request and records method, path, and status as Prometheus metrics.

Explained by highlit
Axum Intermediate middleware observability prometheus metrics instrumentation
1use std::time::Instant;
2 
3use axum::{
4 body::Body,
5 extract::MatchedPath,
6 http::{Request, Response},
7 middleware::Next,
8 response::IntoResponse,
9};
10use metrics::{counter, histogram};
11use metrics_exporter_prometheus::PrometheusHandle;
12 
13pub async fn track_metrics(req: Request<Body>, next: Next) -> impl IntoResponse {
14 let start = Instant::now();
15 let method = req.method().clone();
16 
17 let path = req
18 .extensions()
19 .get::<MatchedPath>()
20 .map(|p| p.as_str().to_owned())
21 .unwrap_or_else(|| "unmatched".to_owned());
22 
23 let response: Response<Body> = next.run(req).await;
24 
25 let latency = start.elapsed().as_secs_f64();
26 let status = response.status().as_u16().to_string();
27 
28 let labels = [
29 ("method", method.to_string()),
30 ("path", path),
31 ("status", status),
32 ];
33 
34 counter!("http_requests_total", &labels).increment(1);
35 histogram!("http_request_duration_seconds", &labels).record(latency);
36 
37 response
38}
39 
40pub async fn metrics_handler(handle: PrometheusHandle) -> impl IntoResponse {
41 handle.render()
42}
01 / 01
STEP 01

Walkthrough

Space play ←→ step click any line
Three takeaways
  1. 1Middleware that wraps `next.run` can measure anything that spans the whole request lifecycle.
  2. 2Using `MatchedPath` instead of the raw URI keeps metric cardinality bounded to your route patterns.
  3. 3Separating recording from exposition lets one endpoint render everything the middleware collected.

Related explainers

rust 
use std::cmp::Ordering;
 
pub struct PrefixIndex {
    entries: Vec<String>,

Prefix search with binary partitioning in Rust

binary-search sorting case-insensitive
Intermediate 7 steps
javascript 
const express = require('express');
const router = express.Router();
const { pool } = require('../db');
const redis = require('../redis');

Building a health check endpoint in Express

health-check timeouts promise-race
Intermediate 9 steps
rust 
use std::cmp::Ordering;
use std::str::FromStr;
 
#[derive(Debug, Clone, PartialEq, Eq)]

Parsing and ordering semantic versions in Rust

parsing trait-implementation ordering
Intermediate 8 steps
php 
<?php
 
namespace App\Http\Middleware;
 

Idempotent requests with Laravel middleware

idempotency middleware caching
Advanced 8 steps
javascript 
'use client';
 
import { useEffect } from 'react';
import * as Sentry from '@sentry/nextjs';

How a Next.js error boundary recovers

error-boundary error-handling observability
Intermediate 8 steps
go 
package middleware
 
import (
	"net/http"

A maintenance-mode gate in Gin

middleware atomic-flag concurrency
Intermediate 8 steps

Share this explainer

Here's the card — post it anywhere.

Prometheus request metrics in Axum — share card
Made with highlit — turn any snippet into a walkthrough like this in about a minute.
Explain your code