Trait StateStoreIter

pub trait StateStoreIter<T: IterItem = StateStoreKeyedRow>: Send {
    // Required method
    fn try_next(&mut self) -> impl StorageFuture<'_, Option<T::ItemRef<'_>>>;
}

Required Methods

fn try_next(&mut self) -> impl StorageFuture<'_, Option<T::ItemRef<'_>>>

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl<'a, T: IterItem> StateStoreIter<T> for Box<dyn DynStateStoreIter<T> + 'a>

fn try_next( &mut self, ) -> impl Future<Output = StorageResult<Option<T::ItemRef<'_>>>> + Send + '_

Implementors

impl StateStoreIter<(TableKey<Bytes>, ChangeLogValue<Bytes>)> for ChangeLogIterator

impl<'a> StateStoreIter for HummockStorageIteratorInner<'a>

impl<'a> StateStoreIter for HummockStorageRevIteratorInner<'a>

impl<A: StateStoreIter<T>, E: StateStoreIter<T>, T: IterItem> StateStoreIter<T> for VerifyStateStore<A, E, T>

where for<'a> T::ItemRef<'a>: PartialEq + Debug,

impl<Item: IterItem, I: StateStoreIter<Item>, S: StateStoreIterStatsTrait<Item = Item>> StateStoreIter<Item> for MonitoredStateStoreIter<Item, I, S>

impl<R: RangeKv> StateStoreIter for RangeKvStateStoreIter<R>

impl<R: RangeKv> StateStoreIter for RangeKvStateStoreRevIter<R>

impl<R: RangeKv> StateStoreIter<(TableKey<Bytes>, ChangeLogValue<Bytes>)> for RangeKvStateStoreChangeLogIter<R>

impl<S: Stream<Item = StorageResult<StateStoreKeyedRow>> + Unpin + Send> StateStoreIter for FromStreamStateStoreIter<S>

impl<T: IterItem> StateStoreIter<T> for PanicStateStoreIter<T>