risingwave_stream::common::state_cache

Trait StateCacheFiller

source
pub trait StateCacheFiller {
    type Key: Ord;
    type Value;

    // Required methods
    fn capacity(&self) -> Option<usize>;
    fn insert_unchecked(&mut self, key: Self::Key, value: Self::Value);
    fn finish(self);
}

Required Associated Types§

Required Methods§

source

fn capacity(&self) -> Option<usize>

Get the capacity of the cache.

source

fn insert_unchecked(&mut self, key: Self::Key, value: Self::Value)

Insert an entry into the cache without cache validity check.

source

fn finish(self)

Finish syncing the cache with the state table. This should mark the cache as synced.

Implementors§