Struct HttpInspectionLayer 

pub struct HttpInspectionLayer { /* private fields */ }

A Layer that observes HTTP responses and invokes registered callbacks based on their status code.

Inspectors are registered against a specific StatusCode via with_inspector. Whenever the wrapped service produces a successful (Ok) response whose status matches, the corresponding callback is invoked. Multiple inspectors may be registered, including more than one for the same status, in which case all matching callbacks are invoked. The response itself is always passed through unchanged, and service errors never trigger callbacks.

This layer is purely observational: it does not modify requests or responses, retry, or short-circuit. Because it sees the raw response from the inner service, placing it below a layer that transforms responses into errors (such as a retry circuit breaker) allows callbacks to observe responses that would otherwise never surface to the caller.

Callbacks are invoked from within the response future, which may be polled concurrently, so they must be Send and Sync. Any throttling or deduplication of callback invocations is the caller’s responsibility.

Implementations

impl HttpInspectionLayer

pub fn new() -> Self

Creates a new HttpInspectionLayer with no registered inspectors.

Without any inspectors, the layer passes every response through unchanged and invokes nothing.

pub fn with_inspector<F>(self, status: StatusCode, callback: F) -> Self

where F: Fn() + Send + Sync + 'static,

Registers a callback to be invoked whenever a response with the given status code is observed.

The callback is invoked once per matching response, including responses produced by retried requests when this layer sits below a retrying layer.

Trait Implementations

impl Clone for HttpInspectionLayer

fn clone(&self) -> HttpInspectionLayer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for HttpInspectionLayer

fn default() -> HttpInspectionLayer

Returns the “default value” for a type.

impl<S> Layer<S> for HttpInspectionLayer

type Service = HttpInspection<S>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.