Struct StreamingManager 

pub struct StreamingManager { /* private fields */ }

Available on crate feature streaming only.

File-based streaming cache manager

Implementations

impl StreamingManager

pub fn new(root_path: PathBuf) -> StreamingManager

Create a new streaming cache manager with default configuration

pub fn new_with_config( root_path: PathBuf, config: StreamingCacheConfig, ) -> StreamingManager

Create a new streaming cache manager with custom configuration

pub async fn new_with_existing_cache( root_path: PathBuf, ) -> Result<StreamingManager, Box<dyn Error + Send + Sync>>

Create a new streaming cache manager and rebuild reference counts from existing cache

pub async fn new_with_existing_cache_and_config( root_path: PathBuf, config: StreamingCacheConfig, ) -> Result<StreamingManager, Box<dyn Error + Send + Sync>>

Create a new streaming cache manager with config and rebuild reference counts from existing cache

pub async fn verify_content_integrity( &self, digest: &str, content_path: &Path, ) -> Result<bool, Box<dyn Error + Send + Sync>>

Verify content integrity by checking if file content matches its digest

pub async fn verify_cache_integrity( &self, ) -> Result<CacheIntegrityReport, Box<dyn Error + Send + Sync>>

Verify all cached content integrity and return report

pub async fn remove_corrupted_entries( &self, corrupted_digests: &[String], ) -> Result<usize, Box<dyn Error + Send + Sync>>

Remove corrupted cache entries

pub async fn cache_stats( &self, ) -> Result<CacheStats, Box<dyn Error + Send + Sync>>

Get cache statistics

Trait Implementations

impl Clone for StreamingManager

fn clone(&self) -> StreamingManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingManager

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

Formats the value using the given formatter.

impl StreamingCacheManager for StreamingManager

type Body = StreamingBody<Empty<Bytes>>

The body type used by this cache manager

fn get<'life0, 'life1, 'async_trait>( &'life0 self, cache_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<(Response<<StreamingManager as StreamingCacheManager>::Body>, CachePolicy)>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, <<StreamingManager as StreamingCacheManager>::Body as Body>::Data: Send, <<StreamingManager as StreamingCacheManager>::Body as Body>::Error: Into<StreamingError> + Send + Sync + 'static, StreamingManager: 'async_trait,

Attempts to pull a cached response and related policy from cache with streaming body.

fn put<'life0, 'async_trait, B>( &'life0 self, cache_key: String, response: Response<B>, policy: CachePolicy, _request_url: Url, metadata: Option<Vec<u8>>, ) -> Pin<Box<dyn Future<Output = Result<Response<<StreamingManager as StreamingCacheManager>::Body>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, B: Body + Send + 'static + 'async_trait, <B as Body>::Data: Send, <B as Body>::Error: Into<StreamingError>, <<StreamingManager as StreamingCacheManager>::Body as Body>::Data: Send, <<StreamingManager as StreamingCacheManager>::Body as Body>::Error: Into<StreamingError> + Send + Sync + 'static, StreamingManager: 'async_trait,

Attempts to cache a response with a streaming body and related policy.

fn convert_body<'life0, 'async_trait, B>( &'life0 self, response: Response<B>, ) -> Pin<Box<dyn Future<Output = Result<Response<<StreamingManager as StreamingCacheManager>::Body>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, B: Body + Send + 'static + 'async_trait, <B as Body>::Data: Send, <B as Body>::Error: Into<StreamingError>, <<StreamingManager as StreamingCacheManager>::Body as Body>::Data: Send, <<StreamingManager as StreamingCacheManager>::Body as Body>::Error: Into<StreamingError> + Send + Sync + 'static, StreamingManager: 'async_trait,

Converts a generic body to the manager’s body type for non-cacheable responses. This is called when a response should not be cached but still needs to be returned with the correct body type.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, cache_key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, StreamingManager: 'async_trait,

Attempts to remove a record from cache.

fn body_to_bytes_stream( body: <StreamingManager as StreamingCacheManager>::Body, ) -> impl Stream<Item = Result<Bytes, Box<dyn Error + Send + Sync>>> + Send

where <<StreamingManager as StreamingCacheManager>::Body as Body>::Data: Send, <<StreamingManager as StreamingCacheManager>::Body as Body>::Error: Send + Sync + 'static,

Available on crate feature streaming only.

Convert the manager’s body type to a reqwest-compatible bytes stream. This enables efficient streaming without collecting the entire body.