Struct RangeScanBuilder 

pub struct RangeScanBuilder { /* private fields */ }

A pending range_scan, created with OxiaClient::range_scan.

.await it for all matching records at once (bounded by the request timeout), or call stream for an incremental, ordered RangeScanStream with bounded memory and no overall deadline.

Implementations

impl RangeScanBuilder

pub fn partition_key(self, partition_key: impl Into<String>) -> Self

Restricts the scan to the shard owning partition_key.

pub fn use_index(self, index_name: impl Into<String>) -> Self

Scans the named secondary index instead of the primary key space.

pub fn include_internal_keys(self, include: bool) -> Self

Also returns Oxia’s internal keys (hidden by default).

pub async fn stream(self) -> Result<RangeScanStream, OxiaError>

Opens an incremental, ordered stream of the matching records.

Trait Implementations

impl Debug for RangeScanBuilder

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

Formats the value using the given formatter.

impl IntoFuture for RangeScanBuilder

type Output = Result<Vec<GetResult>, OxiaError>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = <RangeScanBuilder as IntoFuture>::Output> + Send>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.