Struct fdb_rl::cursor::key_value_cursor::KeyValueCursor

pub struct KeyValueCursor {
    subspace_length: usize,
    fdb_stream_keyvalue: FdbStreamKeyValue,
    limit_manager: LimitManager,
    values_limit: i32,
    continuation: KeyValueContinuationInternal,
    values_seen: i32,
    error: Option<CursorError>,
}

The basic cursor for scanning ranges of the FDB database.

Fields

subspace_length: usize

fdb_stream_keyvalue: FdbStreamKeyValue

limit_manager: LimitManager

values_limit: i32

continuation: KeyValueContinuationInternal

values_seen: i32

error: Option<CursorError>

Implementations

impl KeyValueCursor

fn new( subspace_length: usize, fdb_stream_keyvalue: FdbStreamKeyValue, limit_manager: LimitManager, values_limit: i32, continuation: KeyValueContinuationInternal ) -> KeyValueCursor

Create a new KeyValueCursor.

pub async fn into_btreemap(self) -> (BTreeMap<Key, Value>, CursorError)

Drain the cursor and build a BTreeMap of Key and Value.

Trait Implementations

impl Cursor<KeyValue> for KeyValueCursor

async fn next(&mut self) -> CursorResult<KeyValue>

Asynchronously return the next result from this cursor.

fn collect(self) -> impl Future<Output = (Vec<T>, CursorError)> + Sendwhere Self: Sized + Send,

Drain the cursor pushing all emitted values into a collection.

fn filter<F, Fut>( self, f: F ) -> impl Future<Output = CursorFilter<T, Self, F>> + Sendwhere Self: Sized + Send, F: FnMut(&T) -> Fut + Send, Fut: Future<Output = bool>,

Filters the values produced by this cursor according to the provided predicate.

fn map<U, F, Fut>( self, f: F ) -> impl Future<Output = CursorMap<T, Self, F>> + Sendwhere U: Send, Self: Sized + Send, F: FnMut(T) -> Fut + Send, Fut: Future<Output = U>,

Map this cursor’s items to a different type, returning a new cursor of the resulting type.

impl Debug for KeyValueCursor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Sealed for KeyValueCursor