Trait CacheTracker

pub trait CacheTracker:
    Debug
    + Send
    + Sync {
    // Required method
    fn has_persistent_state(&self) -> bool;

    // Provided methods
    fn blocks_accessed(&self, blocks: Vec<BlockInfo>) { ... }
    fn blocks_written(&self, blocks: Vec<WriteInfo>) { ... }
    fn blocks_deleted(&self, blocks: Vec<BlockInfo>) { ... }
    fn sort_ids(&self, ids: &mut [i64]) { ... }
    fn retain_ids(&self, ids: &[i64]) { ... }
}

tracks block reads and writes to provide info about which blocks to evict from the LRU cache

Required Methods

fn has_persistent_state(&self) -> bool

indicate whether retain_ids should be called on startup

Provided Methods

fn blocks_accessed(&self, blocks: Vec<BlockInfo>)

called whenever blocks were accessed

note that this method will be called very frequently, on every block access. it is fire and forget, so it is perfectly ok to offload the writing to another thread.

fn blocks_written(&self, blocks: Vec<WriteInfo>)

called whenever blocks were written

note that this method will be called frequently, on every block write. it is fire and forget, so it is perfectly ok to offload the writing to another thread.

fn blocks_deleted(&self, blocks: Vec<BlockInfo>)

called whenever blocks have been deleted by gc.

fn sort_ids(&self, ids: &mut [i64])

sort ids by importance. More important ids should go to the end.

this will be called from inside gc

fn retain_ids(&self, ids: &[i64])

notification that only these ids should be retained

this will be called once during startup

Implementations on Foreign Types

impl CacheTracker for Arc<dyn CacheTracker>

fn blocks_accessed(&self, blocks: Vec<BlockInfo>)

fn blocks_written(&self, blocks: Vec<WriteInfo>)

fn sort_ids(&self, ids: &mut [i64])

fn blocks_deleted(&self, blocks: Vec<BlockInfo>)

fn has_persistent_state(&self) -> bool

fn retain_ids(&self, ids: &[i64])

Implementors

impl CacheTracker for NoopCacheTracker

impl CacheTracker for SortByIdCacheTracker

impl<F> CacheTracker for SqliteCacheTracker<F>

where F: Fn(i64, BlockInfo) -> Option<i64> + Send + Sync,

impl<S, T> CacheTracker for AsyncCacheTracker<S, T>

where S: Spawner, T: CacheTracker + 'static,

impl<T, F> CacheTracker for InMemCacheTracker<T, F>

where T: Ord + Clone + Debug + Send + Sync, F: Fn(Duration, BlockInfo) -> Option<T> + Send + Sync,