Struct HttpStreamingCache 

pub struct HttpStreamingCache<T: StreamingCacheManager> {
    pub mode: CacheMode,
    pub manager: T,
    pub options: HttpCacheOptions,
}

Streaming version of HTTP cache that supports streaming request/response bodies without buffering them in memory.

Fields

mode: CacheMode

Determines the manager behavior.

manager: T

Manager instance that implements the StreamingCacheManager trait.

options: HttpCacheOptions

Override the default cache options.

Trait Implementations

impl<T: Clone + StreamingCacheManager> Clone for HttpStreamingCache<T>

fn clone(&self) -> HttpStreamingCache<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + StreamingCacheManager> Debug for HttpStreamingCache<T>

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

Formats the value using the given formatter.

impl<T: StreamingCacheManager> HttpCacheStreamInterface for HttpStreamingCache<T>

where <T::Body as Body>::Data: Send, <T::Body as Body>::Error: Into<StreamingError> + Send + Sync + 'static,

type Body = <T as StreamingCacheManager>::Body

The body type used by this cache implementation

fn analyze_request( &self, parts: &Parts, mode_override: Option<CacheMode>, ) -> Result<CacheAnalysis>

Analyze a request to determine cache behavior

async fn lookup_cached_response( &self, key: &str, ) -> Result<Option<(Response<Self::Body>, CachePolicy)>>

Look up a cached response for the given cache key, returning a streaming body

async fn process_response<B>( &self, analysis: CacheAnalysis, response: Response<B>, ) -> Result<Response<Self::Body>>

where B: Body + Send + 'static, B::Data: Send, B::Error: Into<StreamingError>, <T::Body as Body>::Data: Send, <T::Body as Body>::Error: Into<StreamingError> + Send + Sync + 'static,

Process a fresh response from upstream and potentially cache it with streaming support

fn prepare_conditional_request( &self, parts: &mut Parts, _cached_response: &Response<Self::Body>, policy: &CachePolicy, ) -> Result<()>

Update request headers for conditional requests (e.g., If-None-Match)

async fn handle_not_modified( &self, cached_response: Response<Self::Body>, fresh_parts: &Parts, ) -> Result<Response<Self::Body>>

Handle a 304 Not Modified response by returning the cached response