Struct PrefixedStoreClient 

pub struct PrefixedStoreClient { /* private fields */ }

A physical StoreClient paired with a StoreKeyPrefix that namespaces every key on the wire. The prefix can be the zero-width StoreKeyPrefix::identity, representing the un-namespaced case.

Implementations

impl PrefixedStoreClient

pub fn new(client: StoreClient, prefix: StoreKeyPrefix) -> Self

Pair a physical client with an explicit namespace prefix.

pub fn empty(client: StoreClient) -> Self

Pair a physical client with the zero-width StoreKeyPrefix::identity, so keys pass through untranslated.

pub fn key_prefix(&self) -> &StoreKeyPrefix

The configured key prefix.

pub fn client(&self) -> &StoreClient

Borrow the underlying physical transport. Operations performed directly on it are not namespaced; prefer the methods on this type.

pub fn encode_store_key(&self, key: &Key) -> Result<Key, ClientError>

Encode a logical key as it will appear in the physical Store.

pub fn decode_store_key(&self, key: &Key) -> Result<Key, ClientError>

Decode a physical Store key into this client’s logical keyspace.

pub fn ingest(&self) -> Ingest<'_>

Typed access to the store.ingest.v1 service.

pub fn query(&self) -> Query<'_>

Typed access to the store.query.v1 service.

pub fn compact(&self) -> Compact<'_>

Typed access to the store.compact.v1 service.

pub fn stream(&self) -> Stream<'_>

Typed access to the store.stream.v1 service.

pub fn create_session(&self) -> SerializableReadSession

Create an unseeded serializable read session over this namespace.

pub fn create_session_with_sequence( &self, sequence: u64, ) -> SerializableReadSession

Create a serializable read session pinned to at least sequence.

Trait Implementations

impl Clone for PrefixedStoreClient

fn clone(&self) -> PrefixedStoreClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PrefixedStoreClient

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

Formats the value using the given formatter.