Struct SerializableReadSession 

pub struct SerializableReadSession { /* private fields */ }

A session that enforces monotonic read consistency via a fixed min_sequence_number floor.

The first read either inherits the parent StoreClient’s observed sequence number (if nonzero) or issues an unseeded read and seeds from the response. Every subsequent read passes that fixed floor so the server guarantees all responses reflect at least that point in the write log.

Implementations

impl SerializableReadSession

pub fn fixed_token(&self) -> Option<u64>

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

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

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

Same key-range semantics as StoreClient::range.

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

Same key-range semantics as StoreClient::range.

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

Same key-range semantics as StoreClient::range.

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

Same key-range semantics as StoreClient::range.

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

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

Trait Implementations

impl Clone for SerializableReadSession

fn clone(&self) -> SerializableReadSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SerializableReadSession

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

Formats the value using the given formatter.