Struct ipfs_sqlite_block_store::cache::AsyncCacheTracker

pub struct AsyncCacheTracker<S, T> { /* private fields */ }

A wrapping cache tracker that performs write operations on another thread

Implementations

impl<S: Spawner, T: CacheTracker> AsyncCacheTracker<S, T>

pub fn new(spawner: S, inner: T) -> Self

Trait Implementations

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

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

called whenever blocks were accessed

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

called whenever blocks were written

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

called whenever blocks have been deleted by gc.

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

notification that only these ids should be retained

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

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

fn has_persistent_state(&self) -> bool

indicate whether retain_ids should be called on startup

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

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

Formats the value using the given formatter.