risingwave_storage::store_impl::boxed_state_storeTrait DynamicDispatchedStateStoreRead
source pub trait DynamicDispatchedStateStoreRead: StaticSendSync {
// Required methods
fn get_keyed_row<'life0, 'async_trait>(
&'life0 self,
key: TableKey<Bytes>,
epoch: u64,
read_options: ReadOptions,
) -> Pin<Box<dyn Future<Output = StorageResult<Option<StateStoreKeyedRow>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn iter<'life0, 'async_trait>(
&'life0 self,
key_range: TableKeyRange,
epoch: u64,
read_options: ReadOptions,
) -> Pin<Box<dyn Future<Output = StorageResult<BoxStateStoreReadIter>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn rev_iter<'life0, 'async_trait>(
&'life0 self,
key_range: TableKeyRange,
epoch: u64,
read_options: ReadOptions,
) -> Pin<Box<dyn Future<Output = StorageResult<BoxStateStoreReadIter>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
fn iter_log<'life0, 'async_trait>(
&'life0 self,
epoch_range: (u64, u64),
key_range: TableKeyRange,
options: ReadLogOptions,
) -> Pin<Box<dyn Future<Output = StorageResult<BoxStateStoreReadChangeLogIter>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait;
}