Struct MeteringMiddleware 

pub struct MeteringMiddleware<Q, U> { /* private fields */ }

Middleware that enforces quotas pre-dispatch and records usage post-dispatch.

Generic over the quota checker Q and usage recorder U, allowing integrators to bring their own storage backends.

Request flow

1. Extract Content-Length from request headers as a byte estimate.
2. Call QuotaChecker::check_quota — reject with 429 if over limit.
3. Delegate to the next middleware via Next::run.
4. In after_dispatch, call UsageRecorder::record_operation with the actual response metadata.

Implementations

impl<Q, U> MeteringMiddleware<Q, U>

pub fn new(quota_checker: Q, usage_recorder: U) -> Self

Create a new metering middleware with the given quota checker and usage recorder.

Trait Implementations

impl<Q: QuotaChecker, U: UsageRecorder> Middleware for MeteringMiddleware<Q, U>

async fn handle<'a>( &'a self, ctx: DispatchContext<'a>, next: Next<'a>, ) -> Result<HandlerAction, ProxyError>

Handle a request, optionally delegating to the next middleware via Next::run.

fn after_dispatch( &self, completed: &CompletedRequest<'_>, ) -> impl Future<Output = ()> + MaybeSend + '_

Called after the request has been fully dispatched and the response is available. Use this for logging, metering, or other post-dispatch side effects. The default implementation is a no-op.