rama::http::body

Struct BodyLimit

pub struct BodyLimit { /* private fields */ }

Available on crate features http and std only.

Expand description

Communicates a hard streaming limit for server-side HTTP request and/or response bodies.

A crate::BodyLimitLayer stores this value on a transport’s extensions. Rama’s HTTP server copies those extensions into each request and applies the configured limits while the L7 bodies are polled. A value of zero disables the corresponding limit.

Crossing a limit does not synthesize an HTTP status. Frames that fit are forwarded unchanged; the first data frame that would exceed the remaining budget is discarded and the body yields a crate::body::util::LengthLimitError. For a response, headers and earlier frames may already have been sent, so the HTTP transport terminates or resets that response according to its protocol.

Implementations§

§

impl BodyLimit

pub fn request_only(limit: usize) -> BodyLimit

Create a new BodyLimit, with the given limit to be applied to the request only.

pub fn response_only(limit: usize) -> BodyLimit

Create a new BodyLimit, with the given limit to be applied to the response only.

pub fn symmetric(limit: usize) -> BodyLimit

Create a new BodyLimit, with the given limit to be applied to both the request and response bodies.

pub fn asymmetric(request: usize, response: usize) -> BodyLimit

Create a new BodyLimit, with the given limits respectively to be applied to the request and response bodies.

pub fn request(&self) -> Option<usize>

Get the limit for the request body, if any.

pub fn response(&self) -> Option<usize>

Get the limit for the response body, if any.

Trait Implementations§

§

impl Clone for BodyLimit

§

fn clone(&self) -> BodyLimit

Returns a duplicate of the value. Read more

1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more

§

impl Copy for BodyLimit

§

impl Debug for BodyLimit

§

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

Formats the value using the given formatter. Read more

§

impl Extension for BodyLimit

§

impl HttpExtension for BodyLimit

Auto Trait Implementations§

§

Struct BodyLimit Copy item path

Implementations§

impl BodyLimit

pub fn request_only(limit: usize) -> BodyLimit

pub fn response_only(limit: usize) -> BodyLimit

pub fn symmetric(limit: usize) -> BodyLimit

pub fn asymmetric(request: usize, response: usize) -> BodyLimit

pub fn request(&self) -> Option<usize>

pub fn response(&self) -> Option<usize>

Trait Implementations§

impl Clone for BodyLimit

fn clone(&self) -> BodyLimit

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

impl Copy for BodyLimit

impl Debug for BodyLimit

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

impl Extension for BodyLimit

impl HttpExtension for BodyLimit

Auto Trait Implementations§

impl Freeze for BodyLimit

impl RefUnwindSafe for BodyLimit

impl Send for BodyLimit

impl Sync for BodyLimit

impl Unpin for BodyLimit

impl UnsafeUnpin for BodyLimit

impl UnwindSafe for BodyLimit

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ

fn with_current_context(self) -> WithContext<Self> ⓘ

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘwhere F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T, U> RamaFrom<T> for Uwhere U: From<T>,

fn rama_from(value: T) -> U

impl<T, U, CrateMarker> RamaInto<U, CrateMarker> for Twhere U: RamaFrom<T, CrateMarker>,

fn rama_into(self) -> U

impl<T, U> RamaTryFrom<T> for Uwhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn rama_try_from(value: T) -> Result<U, <U as RamaTryFrom<T>>::Error>

impl<T, U, CrateMarker> RamaTryInto<U, CrateMarker> for Twhere U: RamaTryFrom<T, CrateMarker>,

type Error = <U as RamaTryFrom<T, CrateMarker>>::Error

fn rama_try_into(self) -> Result<U, <U as RamaTryFrom<T, CrateMarker>>::Error>

Struct BodyLimit

impl<T> Any for T
where T: 'static + ?Sized,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T, U> RamaFrom<T> for U
where U: From<T>,

impl<T, U, CrateMarker> RamaInto<U, CrateMarker> for T
where U: RamaFrom<T, CrateMarker>,

impl<T, U> RamaTryFrom<T> for U
where U: TryFrom<T>,

impl<T, U, CrateMarker> RamaTryInto<U, CrateMarker> for T
where U: RamaTryFrom<T, CrateMarker>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

impl<V, F> ValueFormatter<&V> for F
where F: ValueFormatter<V> + ?Sized, V: ?Sized,

impl<V, F> ValueFormatter<Arc<V>> for F
where F: ValueFormatter<V> + ?Sized, V: ?Sized,

impl<V, F> ValueFormatter<Box<V>> for F
where F: ValueFormatter<V> + ?Sized, V: ?Sized,

impl<V, F> ValueFormatter<Cow<'_, V>> for F
where V: ToOwned + ?Sized, F: ValueFormatter<V> + ?Sized,

impl<V, F> ValueFormatter<Option<V>> for F
where F: ValueFormatter<V> + ?Sized,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,