Crate exoware_server 

Store server for ingest/query/prune/retention/stream APIs.

Use AppState with connect_stack for an all-in-one server, or the narrower state and service constructors when capabilities are served separately.

Structs

AppState

All-in-one single-process composition for a backend that serves every store capability. Split deployments construct the narrower capability states directly.

CompiledMatchers

Validated stream matchers compiled for repeated evaluation.

CompiledSelector

One validated and compiled stream selector.

Entry

Types used by filtered-batch and matcher APIs, re-exported so backends can use the server API without a version-matched direct SDK dependency. A raw key-value pair shared by store APIs that move complete rows without additional per-entry metadata.

FilteredBatch

Filtered and fully resolved entries from a retained sequence batch.

IngestLimits

Limits enforced before ingest requests reach the backend.

IngestState

State for an ingest-only service.

InvalidFilter

A stream filter rejected during validation or compilation.

LogBatch

Pre-encoded log.stream.v1.GetResponse stored for a retained sequence batch.

PruneState

State for a prune-only service.

QueryState

State for a query-only service.

RangeScanBatch

RetentionState

State for a retention-only service.

Selector

Types used by filtered-batch and matcher APIs, re-exported so backends can use the server API without a version-matched direct SDK dependency. Identifies a subset of keys by a byte prefix + payload regex. Matches the common.kv.v1.Selector wire shape (see proto/common/v1/kv.proto). A key belongs to the selector’s family iff it starts with prefix; the payload (the key bytes after prefix) is matched against payload_regex. An empty prefix matches all keys.

StreamFilter

Types used by filtered-batch and matcher APIs, re-exported so backends can use the server API without a version-matched direct SDK dependency.

StreamHub

StreamNotification

StreamState

State for a stream-only service.

Utf8

Types used by filtered-batch and matcher APIs, re-exported so backends can use the server API without a version-matched direct SDK dependency.

Enums

Filter

Types used by filtered-batch and matcher APIs, re-exported so backends can use the server API without a version-matched direct SDK dependency. Matches a row’s raw value bytes by exact match, prefix, or regex. Wire shape mirrors common.kv.v1.Filter.

IngestError

Why an ingest write was not accepted.

RangeError

Constants

DEFAULT_MAX_VALUE_LEN

Default maximum value size accepted by ingest validation.

Traits

Ingest

Ingest write capability.

Log

Retained per-sequence batch-log access for stream replay and lookups.

Prune

Prune mutation capability.

Query

Query read capability.

RangeScan

Owned pull-based range cursor for query RPCs.

Retention

Sequence-log retention capability (log.stream.v1 SetRetention).

Sequence

Local sequence frontier visible to this process.

StoreEngine

Compatibility facade for backends that serve every store capability.

StreamNotifier

In-process notification capability for stream subscribers.

Functions

connect_stack

ingest_service

prune_service

query_service

query_stack

retention_service

stream_service

Type Aliases

QueryExtra

Backend-defined query metadata.