Crate exoware_sdk 

Store Rust SDK Client.

Provides typed access to the store put/get/query APIs plus HTTP health/readiness probes.

Errors

RPC failures surface as ClientError::Rpc carrying a native ConnectError. Use ClientError::decoded_rpc_error or StoreClient::decode_error_details to unpack protobuf google.rpc details (and store.query.v1.Detail on query RPC errors), not string parsing. Idempotent reads honor google.rpc.RetryInfo when deciding backoff (see retry_delay_for_error).

Re-exports

pub use keys::Key;

pub use keys::KeyMut;

pub use keys::KeyValidationError;

pub use keys::Prefix;

pub use keys::PrefixError;

pub use keys::Value;

pub use keys::MAX_KEY_LEN;

pub use proto::*;

Modules

keys

kv_codec

proto

Protobuf types and service stubs.

prune_policy

retention

Sequence-log retention policy (the domain model behind log.retention.v1.SetRetention).

selector

Shared key-filter shape: (prefix, payload_regex).

stream_filter

Validated filter for log.stream.v1.Subscribe.

Structs

ConnectError

A ConnectRPC error.

GetManyChunk

GetManyStream

Ingest

PrefixedStoreClient

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.

Prune

Query

RangeChunk

RangeStream

Iterator-like async range stream.

Retention

RetryConfig

Retry policy for idempotent read operations.

SerializableReadSession

A session whose read floor advances to the highest Store sequence observed.

StoreClient

Typed Rust client for Store.

StoreClientBuilder

Configures a StoreClient with explicit bases for health probes and store services.

StoreKeyPrefix

A client-side namespace layered over raw Store keys.

StoreWriteBatch

A physical Store write batch assembled from one or more logical clients.

Stream

StreamSubscription

Async stream of StreamSubscriptionFrame. Backed by the generated connectrpc server stream.

StreamSubscriptionEntry

One delivered (key, value) row from a stream subscription. The client reapplies its own filter if it needs to know which selector matched — the wire frame doesn’t carry the index.

StreamSubscriptionFrame

One atomic Put batch delivered to a subscriber.

Enums

ClientBuildError

Error returned while building a StoreClient.

ClientError

Store client error.

ConnectRequestCompression

Codec used to compress outgoing RPC request bodies when compression applies.

ErrorCode

ConnectRPC error codes.

RangeMode

Traversal mode for range queries.

StoreKeyPrefixError

Errors returned by StoreKeyPrefix when a logical key cannot be mapped into the prefixed physical keyspace.

Constants

API_KEY_ENV

Environment variable read for the API key when none is set on the builder.

Traits

IntoStoreWriteValue

Converts caller-provided write values into the byte owner stored by StoreWriteBatch.

StoreBatchUpload

A writer that can stage an already-prepared upload into a shared Store write batch and then be notified of the batch outcome.

Functions

scalar_reduce_response

Returns the sole scalar frame after validating its shape and consuming the final status.

Type Aliases

ReduceStream

Final reduction results, delivered in bounded frames without collecting all groups.