Struct StreamCompressionLayer
pub struct StreamCompressionLayer<P = DefaultStreamPredicate> { /* private fields */ }compression and http only.Expand description
Compress response bodies of the underlying service.
This uses the Accept-Encoding header to pick an appropriate encoding and adds the
Content-Encoding header to responses.
See the module docs for more details.
Implementations§
§impl StreamCompressionLayer
impl StreamCompressionLayer
pub fn new() -> StreamCompressionLayer
pub fn new() -> StreamCompressionLayer
Creates a new StreamCompressionLayer.
pub fn with_compress_predicate<C>(
self,
predicate: C,
) -> StreamCompressionLayer<C>where
C: Predicate,
pub fn with_compress_predicate<C>(
self,
predicate: C,
) -> StreamCompressionLayer<C>where
C: Predicate,
Replace the current compression predicate.
§impl<P> StreamCompressionLayer<P>
impl<P> StreamCompressionLayer<P>
pub fn with_gzip(self, enable: bool) -> StreamCompressionLayer<P>
pub fn with_gzip(self, enable: bool) -> StreamCompressionLayer<P>
Sets whether to enable the gzip encoding.
pub fn set_gzip(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
pub fn set_gzip(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
Sets whether to enable the gzip encoding.
pub fn with_deflate(self, enable: bool) -> StreamCompressionLayer<P>
pub fn with_deflate(self, enable: bool) -> StreamCompressionLayer<P>
Sets whether to enable the Deflate encoding.
pub fn set_deflate(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
pub fn set_deflate(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
Sets whether to enable the Deflate encoding.
pub fn with_br(self, enable: bool) -> StreamCompressionLayer<P>
pub fn with_br(self, enable: bool) -> StreamCompressionLayer<P>
Sets whether to enable the Brotli encoding.
pub fn set_br(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
pub fn set_br(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
Sets whether to enable the Brotli encoding.
pub fn with_zstd(self, enable: bool) -> StreamCompressionLayer<P>
pub fn with_zstd(self, enable: bool) -> StreamCompressionLayer<P>
Sets whether to enable the Zstd encoding.
pub fn set_zstd(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
pub fn set_zstd(&mut self, enable: bool) -> &mut StreamCompressionLayer<P>
Sets whether to enable the Zstd encoding.
pub fn with_quality(
self,
quality: CompressionLevel,
) -> StreamCompressionLayer<P>
pub fn with_quality( self, quality: CompressionLevel, ) -> StreamCompressionLayer<P>
Sets the compression quality.
pub fn set_quality(
&mut self,
quality: CompressionLevel,
) -> &mut StreamCompressionLayer<P>
pub fn set_quality( &mut self, quality: CompressionLevel, ) -> &mut StreamCompressionLayer<P>
Sets the compression quality.
pub fn with_enforce_not_acceptable(
self,
enable: bool,
) -> StreamCompressionLayer<P>
pub fn with_enforce_not_acceptable( self, enable: bool, ) -> StreamCompressionLayer<P>
Sets whether to respond with 406 Not Acceptable when the client’s
Accept-Encoding header rejects every available representation
(e.g. *;q=0 or a lone identity;q=0), as recommended by RFC 9110 §12.5.3.
Enabled by default. Disable to opt out and instead fall back to sending an uncompressed (identity) response regardless of the client’s stated preference.
pub fn set_enforce_not_acceptable(
&mut self,
enable: bool,
) -> &mut StreamCompressionLayer<P>
pub fn set_enforce_not_acceptable( &mut self, enable: bool, ) -> &mut StreamCompressionLayer<P>
Sets whether to respond with 406 Not Acceptable when the client’s
Accept-Encoding header rejects every available representation
(e.g. *;q=0 or a lone identity;q=0), as recommended by RFC 9110 §12.5.3.
Enabled by default. Disable to opt out and instead fall back to sending an uncompressed (identity) response regardless of the client’s stated preference.
Trait Implementations§
§impl<P> Clone for StreamCompressionLayer<P>where
P: Clone,
impl<P> Clone for StreamCompressionLayer<P>where
P: Clone,
§fn clone(&self) -> StreamCompressionLayer<P>
fn clone(&self) -> StreamCompressionLayer<P>
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more§impl<P> Debug for StreamCompressionLayer<P>where
P: Debug,
impl<P> Debug for StreamCompressionLayer<P>where
P: Debug,
§impl<P> Default for StreamCompressionLayer<P>where
P: Default,
impl<P> Default for StreamCompressionLayer<P>where
P: Default,
§fn default() -> StreamCompressionLayer<P>
fn default() -> StreamCompressionLayer<P>
§impl<S, P> Layer<S> for StreamCompressionLayer<P>where
P: Predicate,
impl<S, P> Layer<S> for StreamCompressionLayer<P>where
P: Predicate,
§type Service = StreamCompression<S, P>
type Service = StreamCompression<S, P>
§fn layer(&self, inner: S) -> <StreamCompressionLayer<P> as Layer<S>>::Service
fn layer(&self, inner: S) -> <StreamCompressionLayer<P> as Layer<S>>::Service
§fn into_layer(
self,
inner: S,
) -> <StreamCompressionLayer<P> as Layer<S>>::Service
fn into_layer( self, inner: S, ) -> <StreamCompressionLayer<P> as Layer<S>>::Service
layer but consuming self after the service was created. Read moreAuto Trait Implementations§
impl<P> Freeze for StreamCompressionLayer<P>where
P: Freeze,
impl<P> RefUnwindSafe for StreamCompressionLayer<P>where
P: RefUnwindSafe,
impl<P> Send for StreamCompressionLayer<P>where
P: Send,
impl<P> Sync for StreamCompressionLayer<P>where
P: Sync,
impl<P> Unpin for StreamCompressionLayer<P>where
P: Unpin,
impl<P> UnsafeUnpin for StreamCompressionLayer<P>where
P: UnsafeUnpin,
impl<P> UnwindSafe for StreamCompressionLayer<P>where
P: UnwindSafe,
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a rama_grpc::Request§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Policy that returns Action::Follow only if self and other return
Action::Follow. Read more§impl<T, U> RamaTryFrom<T> for Uwhere
U: TryFrom<T>,
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>,
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>
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
§impl<V, F> ValueFormatter<&V> for F
impl<V, F> ValueFormatter<&V> for F
§fn format_value(writer: impl ValueWriter, value: &&V)
fn format_value(writer: impl ValueWriter, value: &&V)
value to writer§impl<V, F> ValueFormatter<Arc<V>> for F
impl<V, F> ValueFormatter<Arc<V>> for F
§fn format_value(writer: impl ValueWriter, value: &Arc<V>)
fn format_value(writer: impl ValueWriter, value: &Arc<V>)
value to writer§impl<V, F> ValueFormatter<Box<V>> for F
impl<V, F> ValueFormatter<Box<V>> for F
§fn format_value(writer: impl ValueWriter, value: &Box<V>)
fn format_value(writer: impl ValueWriter, value: &Box<V>)
value to writer§impl<V, F> ValueFormatter<Cow<'_, V>> for F
impl<V, F> ValueFormatter<Cow<'_, V>> for F
§fn format_value(writer: impl ValueWriter, value: &Cow<'_, V>)
fn format_value(writer: impl ValueWriter, value: &Cow<'_, V>)
value to writer§impl<V, F> ValueFormatter<Option<V>> for Fwhere
F: ValueFormatter<V> + ?Sized,
impl<V, F> ValueFormatter<Option<V>> for Fwhere
F: ValueFormatter<V> + ?Sized,
§fn format_value(writer: impl ValueWriter, value: &Option<V>)
fn format_value(writer: impl ValueWriter, value: &Option<V>)
value to writer