risingwave_storage::store_impl::boxed_state_store

Trait DynamicDispatchedLocalStateStore

source 
pub trait DynamicDispatchedLocalStateStore: StaticSendSync {

Show 13 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<BoxLocalStateStoreIterStream<'_>>> + 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<BoxLocalStateStoreIterStream<'_>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    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(&mut self, vnodes: Arc<Bitmap>) -> Arc<Bitmap>;
    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<BoxLocalStateStoreIterStream<'_>>> + 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<BoxLocalStateStoreIterStream<'_>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

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(&mut self, vnodes: Arc<Bitmap>) -> Arc<Bitmap>

source

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

Implementors§