Struct UploadGuard 

pub struct UploadGuard { /* private fields */ }

Runtime guard built from ServerLimits, shared across requests as an axum extension. Holds the concurrency semaphore (if any) and the per-upload caps.

Implementations

impl UploadGuard

pub fn new(limits: ServerLimits) -> Self

Build a guard from limits (an unbounded guard if limits.is_unlimited()).

pub fn try_acquire(&self) -> Option<UploadPermit>

Try to claim an upload slot. Some (held for the upload’s duration) when admitted — including the unlimited case; None when the concurrency cap is currently saturated.

pub fn content_length_rejected(&self, content_length: Option<u64>) -> bool

Whether content_length already exceeds the size cap (cheap early 413).

pub fn limit_body(&self, stream: ByteStream) -> ByteStream

Wrap an upload body so it is aborted if it exceeds the size cap or stalls past the idle timeout. A no-op (returns the stream unchanged) when neither applies, so the unlimited path keeps zero overhead.

Trait Implementations

impl Clone for UploadGuard

fn clone(&self) -> UploadGuard

Returns a duplicate of the value.

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

Performs copy-assignment from source.