Struct CachingFetcher 

pub struct CachingFetcher<CTXEXT, FENS> {
    pub inner: Arc<FENS>,
    /* private fields */
}

Wraps an ensemble fetcher with per-request deduplication caching.

When multiple parts of a request need the same ensemble, this fetcher ensures only one actual fetch is performed. Subsequent requests for the same ensemble ID within the same request context share the result.

Fields

inner: Arc<FENS>

The underlying fetcher to delegate to on cache miss.

Implementations

impl<CTXEXT, FENS> CachingFetcher<CTXEXT, FENS>

pub fn new(inner: Arc<FENS>) -> Self

Creates a new caching fetcher wrapping the given inner fetcher.

impl<CTXEXT, FENS> CachingFetcher<CTXEXT, FENS>

where CTXEXT: Send + Sync + 'static, FENS: Fetcher<CTXEXT> + Send + Sync + 'static,

pub async fn fetch( &self, ctx: Context<CTXEXT>, id: &str, ) -> Result<Option<(Ensemble, u64)>, ResponseError>

Fetches an ensemble, using the request-scoped cache for deduplication.

If another fetch for the same ID is already in progress within this request context, waits for and shares that result instead of fetching again.

Trait Implementations

impl<CTXEXT: Clone, FENS: Clone> Clone for CachingFetcher<CTXEXT, FENS>

fn clone(&self) -> CachingFetcher<CTXEXT, FENS>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<CTXEXT: Debug, FENS: Debug> Debug for CachingFetcher<CTXEXT, FENS>

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

Formats the value using the given formatter.