Crate exoware_sdk 

Store Rust SDK Client.

Provides typed access to the store put/get/query APIs plus plain 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::KeyCodec;

pub use keys::KeyCodecError;

pub use keys::KeyMut;

pub use keys::KeyValidationError;

pub use keys::Value;

pub use keys::MAX_KEY_LEN;

pub use proto::*;

Modules

keys

kv_codec

match_key

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

proto

Protobuf types and service stubs for the store API (store.*.v1).

prune_policy

stream_filter

Validated filter for store.stream.v1.Subscribe.

Structs

Compact

GetManyStream

Ingest

Query

RangeStream

Iterator-like async range stream.

RetryConfig

Retry policy for idempotent read operations.

SerializableReadSession

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

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 match_key matched — the wire frame doesn’t carry the index.

StreamSubscriptionFrame

One atomic Put batch delivered to a subscriber.

Enums

ClientBuildError

Error returned when StoreClientBuilder is missing a required endpoint URL.

ClientError

Store client error.

ConnectRequestCompression

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

RangeMode

Traversal mode for range queries.

StoreKeyPrefixError

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

Traits

StoreBatchPublication

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

StoreBatchUpload

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

StorePublicationFrontierWriter

A stateful writer that owns a durable publication frontier.