Struct Query 

pub struct Query<'a> { /* private fields */ }

Implementations

impl<'a> Query<'a>

pub async fn get(&self, key: &Key) -> Result<Option<Bytes>, ClientError>

pub async fn get_with_min_sequence_number( &self, key: &Key, min_sequence_number: u64, ) -> Result<Option<Bytes>, ClientError>

pub async fn get_many( &self, keys: &[&Key], batch_size: u32, ) -> Result<GetManyStream, ClientError>

pub async fn get_many_with_min_sequence_number( &self, keys: &[&Key], batch_size: u32, min_sequence_number: u64, ) -> Result<GetManyStream, ClientError>

pub async fn range( &self, start: &Key, end: &Key, limit: usize, ) -> Result<Vec<(Key, Bytes)>, ClientError>

Collect a Range into a Vec. Use range_stream for large scans.

pub async fn range_with_mode( &self, start: &Key, end: &Key, limit: usize, mode: RangeMode, ) -> Result<Vec<(Key, Bytes)>, ClientError>

pub async fn range_with_min_sequence_number( &self, start: &Key, end: &Key, limit: usize, min_sequence_number: u64, ) -> Result<Vec<(Key, Bytes)>, ClientError>

pub async fn range_with_mode_and_min_sequence_number( &self, start: &Key, end: &Key, limit: usize, mode: RangeMode, min_sequence_number: u64, ) -> Result<Vec<(Key, Bytes)>, ClientError>

pub async fn range_stream( &self, start: &Key, end: &Key, limit: usize, batch_size: usize, ) -> Result<RangeStream, ClientError>

pub async fn range_stream_with_mode( &self, start: &Key, end: &Key, limit: usize, batch_size: usize, mode: RangeMode, ) -> Result<RangeStream, ClientError>

pub async fn range_stream_with_min_sequence_number( &self, start: &Key, end: &Key, limit: usize, batch_size: usize, min_sequence_number: u64, ) -> Result<RangeStream, ClientError>

pub async fn range_stream_with_mode_and_min_sequence_number( &self, start: &Key, end: &Key, limit: usize, batch_size: usize, mode: RangeMode, min_sequence_number: u64, ) -> Result<RangeStream, ClientError>

pub async fn range_reduce( &self, start: &Key, end: &Key, request: &DomainRangeReduceRequest, ) -> Result<Vec<Option<KvReducedValue>>, ClientError>

pub async fn range_reduce_with_min_sequence_number( &self, start: &Key, end: &Key, request: &DomainRangeReduceRequest, min_sequence_number: u64, ) -> Result<Vec<Option<KvReducedValue>>, ClientError>

pub async fn range_reduce_response( &self, start: &Key, end: &Key, request: &DomainRangeReduceRequest, ) -> Result<ReduceResponse, ClientError>

pub async fn range_reduce_response_with_min_sequence_number( &self, start: &Key, end: &Key, request: &DomainRangeReduceRequest, min_sequence_number: u64, ) -> Result<ReduceResponse, ClientError>

Trait Implementations

impl<'a> Clone for Query<'a>

fn clone(&self) -> Query<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Query<'a>

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

Formats the value using the given formatter.

impl<'a> Copy for Query<'a>