Struct StateCache 

pub struct StateCache<K, V> { /* private fields */ }

Implementations

impl<K, V> StateCache<K, V>

pub fn new() -> Self

impl<K, V> StateCache<K, V>

where K: Hash + Eq + Clone + HeapSize, for<'a> &'a K: IntoGroupStateKey, V: Clone + OperatorState + HeapSize,

pub fn get(&mut self, store: &mut dyn StateStore, key: &K) -> Result<Option<V>>

pub fn set( &mut self, store: &mut dyn StateStore, key: &K, value: &V, ) -> Result<()>

pub fn put( &mut self, store: &mut dyn StateStore, key: &K, value: V, ) -> Result<()>

pub fn modify<R>( &mut self, store: &mut dyn StateStore, key: &K, f: impl FnOnce(&mut V) -> R, ) -> Result<R>

where V: Default,

pub fn remove(&mut self, store: &mut dyn StateStore, key: &K) -> Result<()>

impl<K, V> StateCache<K, V>

where K: Hash + Eq + Clone + HeapSize, for<'a> &'a K: IntoGroupStateKey, V: Clone + Default + OperatorState + HeapSize,

pub fn get_or_default( &mut self, store: &mut dyn StateStore, key: &K, ) -> Result<V>

pub fn update<U>( &mut self, store: &mut dyn StateStore, key: &K, updater: U, ) -> Result<V>

where U: FnOnce(&mut V) -> Result<()>,

Trait Implementations

impl<K, V> Default for StateCache<K, V>

fn default() -> Self

Returns the “default value” for a type.