Trait DynLocalStateStore

pub trait DynLocalStateStore:
    DynStateStoreGet
    + DynStateStoreWriteEpochControl
    + StaticSendSync {
    // Required methods
    fn iter<'life0, 'async_trait>(
        &'life0 self,
        key_range: TableKeyRange,
        read_options: ReadOptions,
    ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn DynStateStoreIter<StateStoreKeyedRow> + '_>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn rev_iter<'life0, 'async_trait>(
        &'life0 self,
        key_range: TableKeyRange,
        read_options: ReadOptions,
    ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn DynStateStoreIter<StateStoreKeyedRow> + '_>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn new_flushed_snapshot_reader(
        &self,
    ) -> StateStorePointer<Arc<dyn DynStateStoreRead>>;
    fn insert(
        &mut self,
        key: TableKey<Bytes>,
        new_val: Bytes,
        old_val: Option<Bytes>,
    ) -> StorageResult<()>;
    fn delete(
        &mut self,
        key: TableKey<Bytes>,
        old_val: Bytes,
    ) -> StorageResult<()>;
    fn update_vnode_bitmap<'life0, 'async_trait>(
        &'life0 mut self,
        vnodes: Arc<Bitmap>,
    ) -> Pin<Box<dyn Future<Output = StorageResult<Arc<Bitmap>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_table_watermark(&self, vnode: VirtualNode) -> Option<Bytes>;
}

Required Methods

fn iter<'life0, 'async_trait>( &'life0 self, key_range: TableKeyRange, read_options: ReadOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn DynStateStoreIter<StateStoreKeyedRow> + '_>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn rev_iter<'life0, 'async_trait>( &'life0 self, key_range: TableKeyRange, read_options: ReadOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn DynStateStoreIter<StateStoreKeyedRow> + '_>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn new_flushed_snapshot_reader( &self, ) -> StateStorePointer<Arc<dyn DynStateStoreRead>>

fn insert( &mut self, key: TableKey<Bytes>, new_val: Bytes, old_val: Option<Bytes>, ) -> StorageResult<()>

fn delete(&mut self, key: TableKey<Bytes>, old_val: Bytes) -> StorageResult<()>

fn update_vnode_bitmap<'life0, 'async_trait>( &'life0 mut self, vnodes: Arc<Bitmap>, ) -> Pin<Box<dyn Future<Output = StorageResult<Arc<Bitmap>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_table_watermark(&self, vnode: VirtualNode) -> Option<Bytes>

Implementors

impl<S: LocalStateStore> DynLocalStateStore for S