Struct RangeKvStateStoreReadSnapshot

pub struct RangeKvStateStoreReadSnapshot<R: RangeKv> {
    inner: RangeKvStateStore<R>,
    epoch: u64,
    table_id: TableId,
}

Fields

inner: RangeKvStateStore<R>

epoch: u64

table_id: TableId

Trait Implementations

impl<R: Clone + RangeKv> Clone for RangeKvStateStoreReadSnapshot<R>

fn clone(&self) -> RangeKvStateStoreReadSnapshot<R>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<R: RangeKv> StateStoreRead for RangeKvStateStoreReadSnapshot<R>

type Iter = RangeKvStateStoreIter<R>

type RevIter = RangeKvStateStoreRevIter<R>

async fn get_keyed_row( &self, key: TableKey<Bytes>, _read_options: ReadOptions, ) -> StorageResult<Option<StateStoreKeyedRow>>

Point gets a value from the state store. The result is based on a snapshot corresponding to the given epoch. Both full key and the value are returned.

async fn iter( &self, key_range: TableKeyRange, _read_options: ReadOptions, ) -> StorageResult<Self::Iter>

Opens and returns an iterator for given prefix_hint and full_key_range Internally, prefix_hint will be used to for checking bloom_filter and full_key_range used for iter. (if the prefix_hint not None, it should be be included in key_range) The returned iterator will iterate data based on a snapshot corresponding to the given epoch.

async fn rev_iter( &self, key_range: TableKeyRange, _read_options: ReadOptions, ) -> StorageResult<Self::RevIter>

fn get( &self, key: TableKey<Bytes>, read_options: ReadOptions, ) -> impl StorageFuture<'_, Option<Bytes>>

Point gets a value from the state store. The result is based on a snapshot corresponding to the given epoch. Only the value is returned.