Struct StateCache 

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

Implementations

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

where K: Hash + Eq + Clone, for<'a> &'a K: IntoEncodedKey, V: Clone + Serialize + DeserializeOwned,

pub fn new(capacity: usize) -> Self

pub fn get(&mut self, ctx: &mut OperatorContext, key: &K) -> Result<Option<V>>

pub fn set( &mut self, _ctx: &mut OperatorContext, key: &K, value: &V, ) -> Result<()>

pub fn remove(&mut self, _ctx: &mut OperatorContext, key: &K) -> Result<()>

pub fn flush(&mut self, ctx: &mut OperatorContext) -> Result<()>

Drain dirty entries and write them through to host storage.

Called once per txn at commit time, normally from the operator’s FFIOperator::flush_state impl. Repeated sets of the same key produce a single write here; coalesced set + remove produces a single remove.

pub fn clear_cache(&mut self)

pub fn invalidate(&mut self, key: &K)

pub fn is_cached(&self, key: &K) -> bool

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn capacity(&self) -> usize

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

where K: Hash + Eq + Clone, for<'a> &'a K: IntoEncodedKey, V: Clone + Default + Serialize + DeserializeOwned,

pub fn get_or_default( &mut self, ctx: &mut OperatorContext, key: &K, ) -> Result<V>

pub fn update<U>( &mut self, ctx: &mut OperatorContext, key: &K, updater: U, ) -> Result<V>

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