pingora_cache::max_file_size

Struct MaxFileSizeMissHandler

Source
pub struct MaxFileSizeMissHandler { /* private fields */ }
Expand description

MaxFileSizeMissHandler wraps a MissHandler to enforce a maximum asset size that should be written to the MissHandler.

This is used to enforce a maximum cache size for a request when the response size is not known ahead of time (no Content-Length header). When the response size is known ahead of time, it should be checked up front (when calculating cacheability) for efficiency. Note: for requests with partial read support (where downstream reads the response from cache as it is filled), this will cause the request as a whole to fail. The response will be remembered as uncacheable, though, so downstream will be able to retry the request, since the cache will be disabled for the retried request.

Implementations§

Source§

impl MaxFileSizeMissHandler

Source

pub fn new( inner: MissHandler, max_file_size_bytes: usize, ) -> MaxFileSizeMissHandler

Create a new MaxFileSizeMissHandler wrapping the given MissHandler

Trait Implementations§

Source§

impl HandleMiss for MaxFileSizeMissHandler

Source§

fn write_body<'life0, 'async_trait>( &'life0 mut self, data: Bytes, eof: bool, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Write the given body to the storage
Source§

fn finish<'async_trait>( self: Box<Self>, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>
where Self: 'async_trait,

Finish the cache admission Read more
Source§

fn streaming_write_tag(&self) -> Option<&[u8]>

Return a streaming write tag recognized by the underlying Storage. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

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

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

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

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

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

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more