risingwave_storage::store_impl::dyn_state_store

Trait DynLocalStateStore

Source 
pub trait DynLocalStateStore: StaticSendSync {

Show 14 methods    // Required methods
    fn get<'life0, 'async_trait>(
        &'life0 self,
        key: TableKey<Bytes>,
        read_options: ReadOptions,
    ) -> Pin<Box<dyn Future<Output = StorageResult<Option<Bytes>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    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 flush<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = StorageResult<usize>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn try_flush<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn epoch(&self) -> u64;
    fn is_dirty(&self) -> bool;
    fn init<'life0, 'async_trait>(
        &'life0 mut self,
        epoch: InitOptions,
    ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn seal_current_epoch(
        &mut self,
        next_epoch: u64,
        opts: SealCurrentEpochOptions,
    );
    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§

Source

fn get<'life0, 'async_trait>( &'life0 self, key: TableKey<Bytes>, read_options: ReadOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<Bytes>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

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,

Source

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,

Source

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

Source

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

Source

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

Source

fn flush<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StorageResult<usize>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn try_flush<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn epoch(&self) -> u64

Source

fn is_dirty(&self) -> bool

Source

fn init<'life0, 'async_trait>( &'life0 mut self, epoch: InitOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn seal_current_epoch(&mut self, next_epoch: u64, opts: SealCurrentEpochOptions)

Source

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,

Source

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

Implementors§