Struct ColdIndexPageCache 

pub struct ColdIndexPageCache<S: ColdIndexPageStore + ?Sized> { /* private fields */ }

Implementations

impl<S: ColdIndexPageStore + ?Sized> ColdIndexPageCache<S>

pub fn new(store: Arc<S>, capacity_pages: usize) -> Self

pub async fn put_page( &self, key: &ColdIndexPageKey, page: &ColdIndexPage, ) -> Result<()>

pub async fn get_page( &self, key: &ColdIndexPageKey, ) -> Result<Option<Arc<ColdIndexPage>>>

pub fn invalidate_stream(&self, stream_id: &BucketStreamId)

Drops every cached generation/page for one stream. Compaction invokes this on every replica when the replicated replacement command applies.

pub async fn object_segments_for_read( &self, stream_id: &BucketStreamId, segment: &StreamReadColdIndexSegment, ) -> Result<Vec<ObjectPayloadRef>>

pub fn cached_page_count(&self) -> usize

Trait Implementations

impl<S: Debug + ColdIndexPageStore + ?Sized> Debug for ColdIndexPageCache<S>

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

Formats the value using the given formatter.