Struct pingora_cache::HttpCache

pub struct HttpCache { /* private fields */ }

The state machine for http caching

This object is used to handle the state and transitions for HTTP caching through the life of a request.

Implementations

impl HttpCache

pub fn new() -> Self

Create a new HttpCache.

Caching is not enabled by default.

pub fn enabled(&self) -> bool

Whether the cache is enabled

pub fn bypassing(&self) -> bool

Whether the cache is being bypassed

pub fn phase(&self) -> CachePhase

Return the CachePhase

pub fn upstream_used(&self) -> bool

Whether anything was fetched from the upstream

This essentially checks all possible CachePhase who need to contact the upstream server

pub fn storage_type_is<T: 'static>(&self) -> bool

Check whether the backend storage is the type T.

pub fn disable(&mut self, reason: NoCacheReason)

Disable caching

pub fn bypass(&mut self)

Set the cache to bypass

Panic

This call is only allowed in CachePhase::CacheKey phase (before any cache lookup is performed). Use it in any other phase will lead to panic.

pub fn enable( &mut self, storage: &'static (dyn Storage + Sync), eviction: Option<&'static (dyn EvictionManager + Sync)>, predictor: Option<&'static (dyn CacheablePredictor + Sync)>, cache_lock: Option<&'static CacheLock> )

Enable the cache

• storage: the cache storage backend that implements storage::Storage
• eviction: optionally the eviction manager, without it, nothing will be evicted from the storage
• predictor: optionally a cache predictor. The cache predictor predicts whether something is likely to be cacheable or not. This is useful because the proxy can apply different types of optimization to cacheable and uncacheable requests.
• cache_lock: optionally a cache lock which handles concurrent lookups to the same asset. Without it such lookups will all be allowed to fetch the asset independently.

pub fn enable_tracing(&mut self, parent_span: Span)

pub fn get_miss_span(&mut self) -> Option<SpanHandle>

pub fn set_cache_key(&mut self, key: CacheKey)

Set the cache key

Panic

Cache key is only allowed to be set in its own phase. Set it in other phases will cause panic.

pub fn cache_key(&self) -> &CacheKey

Return the cache key used for asset lookup

Panic

Can only be called after the cache key is set and the cache is not disabled. Panic otherwise.

pub fn max_file_size_bytes(&self) -> Option<usize>

Return the max size allowed to be cached.

pub fn set_max_file_size_bytes(&mut self, max_file_size_bytes: usize)

Set the maximum response body size in bytes that will be admitted to the cache.

Response header size does not contribute to the max file size.

pub fn cache_found( &mut self, meta: CacheMeta, hit_handler: HitHandler, hit_status: HitStatus )

Set that cache is found in cache storage.

This function is called after Self::cache_lookup() which returns the CacheMeta and HitHandler.

The hit_status enum allows the caller to force expire assets.

pub fn cache_miss(&mut self)

Mark self to be cache miss.

This function is called after Self::cache_lookup() finds nothing or the caller decides not to use the assets found.

Panic

Panic in other phases.

pub fn hit_handler(&mut self) -> &mut HitHandler

Return the HitHandler

Panic

Call this after Self::cache_found(), panic in other phases.

pub fn miss_body_reader(&mut self) -> Option<&mut HitHandler>

Return the body reader during a cache admission (miss/expired) which decouples the downstream read and upstream cache write

pub async fn finish_hit_handler(&mut self) -> Result<()>

Call this when cache hit is fully read.

This call will release resource if any and log the timing in tracing if set.

Panic

Panic in phases where there is no cache hit.

pub async fn set_miss_handler(&mut self) -> Result<()>

Set the MissHandler according to cache_key and meta, can only call once

pub fn miss_handler(&mut self) -> Option<&mut MissHandler>

Return the MissHandler to write the response body to cache.

None: the handler has not been set or already finished

pub async fn finish_miss_handler(&mut self) -> Result<()>

Finish cache admission

If self is dropped without calling this, the cache admission is considered incomplete and should be cleaned up.

This call will also trigger eviction if set.

pub fn set_cache_meta(&mut self, meta: CacheMeta)

Set the CacheMeta of the cache

pub async fn revalidate_cache_meta(&mut self, meta: CacheMeta) -> Result<bool>

Set the CacheMeta of the cache after revalidation.

Certain info such as the original cache admission time will be preserved. Others will be replaced by the input meta.

pub fn revalidate_merge_header(&mut self, resp: &RespHeader) -> ResponseHeader

After a successful revalidation, update certain headers for the cached asset such as Etag with the fresh response header resp.

pub fn revalidate_uncacheable( &mut self, header: ResponseHeader, reason: NoCacheReason )

Mark this asset uncacheable after revalidation

pub fn update_variance(&mut self, variance: Option<HashBinary>)

Update the variance of the CacheMeta.

Note that this process may change the lookup key, and eventually (when the asset is written to storage) invalidate other cached variants under the same primary key as the current asset.

pub fn cache_meta(&self) -> &CacheMeta

Return the CacheMeta of this asset

Panic

Panic in phases which has no cache meta.

pub fn maybe_cache_meta(&self) -> Option<&CacheMeta>

Return the CacheMeta of this asset if any

Different from Self::cache_meta(), this function is allowed to be called in CachePhase::Miss phase where the cache meta maybe set.

Panic

Panic in phases that shouldn’t have cache meta.

pub async fn cache_lookup(&mut self) -> Result<Option<(CacheMeta, HitHandler)>>

Perform the cache lookup from the given cache storage with the given cache key

A cache hit will return CacheMeta which contains the header and meta info about the cache as well as a HitHandler to read the cache hit body.

Panic

Panic in other phases.

pub fn cache_vary_lookup( &mut self, variance: HashBinary, meta: &CacheMeta ) -> bool

Update variance and see if the meta matches the current variance

cache_lookup() -> compute vary hash -> cache_vary_lookup() This function allows callers to compute vary based on the initial cache hit. meta should be the ones returned from the initial cache_lookup()

• return true if the meta is the variance.
• return false if the current meta doesn’t match the variance, need to cache_lookup() again

pub fn is_cache_locked(&self) -> bool

Whether this request is behind a cache lock in order to wait for another request to read the asset.

pub fn is_cache_lock_writer(&self) -> bool

Whether this request is the leader request to fetch the assets for itself and other requests behind the cache lock.

pub fn take_write_lock(&mut self) -> WritePermit

Take the write lock from this request to transfer it to another one.

Panic

Call is_cache_lock_writer() to check first, will panic otherwise.

pub fn set_write_lock(&mut self, write_lock: WritePermit)

Set the write lock, which is usually transferred from Self::take_write_lock()

pub fn can_serve_stale_error(&self) -> bool

Whether this asset is staled and stale if error is allowed

pub fn can_serve_stale_updating(&self) -> bool

Whether this asset is staled and stale while revalidate is allowed.

pub async fn cache_lock_wait(&mut self) -> LockStatus

Wait for the cache read lock to be unlocked

Panic

Check Self::is_cache_locked(), panic if this request doesn’t have a read lock.

pub fn lock_duration(&self) -> Option<Duration>

How long did this request wait behind the read lock

pub async fn purge(&mut self) -> Result<bool>

Delete the asset from the cache storage

Panic

Need to be called after the cache key is set. Panic otherwise.

pub fn cacheable_prediction(&self) -> bool

Check the cacheable prediction

Return true if the predictor is not set

pub fn response_became_cacheable(&self)

Tell the predictor that this response, which is previously predicted to be uncacheable, is cacheable now.

pub fn response_became_uncacheable(&self, reason: NoCacheReason)

Tell the predictor that this response is uncacheable so that it will know next time this request arrives.