Trait ipfs_sqlite_block_store::cache::CacheTracker

pub trait CacheTracker: Debug + Send {
    pub fn blocks_accessed(&self, blocks: Vec<BlockInfo>) { ... }
    pub fn blocks_written(&self, blocks: Vec<WriteInfo>) { ... }
    pub fn blocks_deleted(&self, blocks: Vec<BlockInfo>) { ... }
    pub fn sort_ids(&self, ids: &mut [i64]) { ... }
    pub fn retain_ids(&self, ids: &[i64]) { ... }
}

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

Provided methods

pub 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.

pub 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.

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

called whenever blocks have been deleted by gc.

pub 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

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

notification that only these ids should be retained

this will be called once during startup

Loading content...

Implementations on Foreign Types

impl CacheTracker for Box<dyn CacheTracker>

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

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

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

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

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

Loading content...

Implementors

impl CacheTracker for NoopCacheTracker

impl CacheTracker for SortByIdCacheTracker

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

impl<F> CacheTracker for SqliteCacheTracker<F> where
    F: Fn(i64, BlockInfo) -> Option<i64> + Send, 

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

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

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

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

impl<S, T> CacheTracker for AsyncCacheTracker<S, T> where
    S: Spawner,
    T: CacheTracker + Send + 'static, 

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

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

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

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

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

impl<T, F> CacheTracker for InMemCacheTracker<T, F> where
    T: Ord + Clone + Debug + Send,
    F: Fn(Duration, BlockInfo) -> Option<T> + Send, 

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

called whenever blocks were accessed

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

notification that these ids no longer have to be tracked

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

notification that only these ids should be retained

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

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

Loading content...