Struct MiddlewarePipeline 

pub struct MiddlewarePipeline {
    pub cors: Option<CorsConfig>,
    pub body_limit: Option<BodyLimitConfig>,
    pub rate_limiter: Option<RateLimiter>,
    pub timeout: Option<TimeoutConfig>,
    /* private fields */
}

The middleware pipeline configuration for a server.

Fields

cors: Option<CorsConfig>

CORS configuration (applied to all responses).

body_limit: Option<BodyLimitConfig>

Body size limit (checked before handler).

rate_limiter: Option<RateLimiter>

Rate limiter (checked before handler).

timeout: Option<TimeoutConfig>

Request timeout.

Implementations

impl MiddlewarePipeline

pub fn new() -> Self

Create an empty middleware pipeline.

pub fn with_cors(self, config: CorsConfig) -> Self

Add CORS middleware.

pub fn with_body_limit(self, max_bytes: u64) -> Self

Add body size limit middleware.

pub fn with_rate_limiter(self, limiter: RateLimiter) -> Self

Add rate limiting middleware.

pub fn with_timeout(self, duration: Duration) -> Self

Add request timeout middleware.

pub async fn pre_handle( &self, req: &Request<Incoming>, ) -> Option<Result<Response<Full<Bytes>>, OxiHttpError>>

Run pre-handler middleware checks.

Returns Some(response) if middleware short-circuits (e.g. CORS preflight, rate limit exceeded, body too large). Returns None if the request should proceed to the handler.

pub fn post_handle( &self, resp: &mut Response<Full<Bytes>>, origin: Option<&str>, )

Apply post-handler middleware (e.g. CORS headers) to a response.

Trait Implementations

impl Clone for MiddlewarePipeline

fn clone(&self) -> MiddlewarePipeline

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MiddlewarePipeline

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

Formats the value using the given formatter.

impl Default for MiddlewarePipeline

fn default() -> Self

Returns the “default value” for a type.