Skip to main content

StateCacheFiller

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§

Source

type Key: Ord

Source

type Value

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.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§