risingwave_storage::store

Trait StateStoreReadLog

source 
pub trait StateStoreReadLog: StaticSendSync {
    type ChangeLogIter: StateStoreReadChangeLogIter;

    // Required methods
    fn next_epoch(
        &self,
        epoch: u64,
        options: NextEpochOptions,
    ) -> impl StorageFuture<'_, u64>;
    fn iter_log(
        &self,
        epoch_range: (u64, u64),
        key_range: TableKeyRange,
        options: ReadLogOptions,
    ) -> impl StorageFuture<'_, Self::ChangeLogIter>;
}

Required Associated Types§

source

type ChangeLogIter: StateStoreReadChangeLogIter

Required Methods§

source

fn next_epoch( &self, epoch: u64, options: NextEpochOptions, ) -> impl StorageFuture<'_, u64>

source

fn iter_log( &self, epoch_range: (u64, u64), key_range: TableKeyRange, options: ReadLogOptions, ) -> impl StorageFuture<'_, Self::ChangeLogIter>

Object Safety§

This trait is not object safe.

Implementors§