Module queries

Modules§

BackendBinding: The backend uses one scalar cursor per topic.
BidiTransport: A cloneable handle to the connection and topic ledger task.
BoxedStreamsClient
Connection: A handle to one open bidirectional subscription. Writing to the wire is the actor’s job; this only submits commands and reads events. Generic over the backend BidiBinding. The backend module supplies the concrete alias.
MessageBackendBuilder
MutateLimits: The interest-update frame shapes one deployment accepts (CFG-064). Adds and removes have separate caps because the backend enforces them separately.
OpenError: Keep the source error and its retry decision after type erasure.
TopicLease: Local topic interest. Dropping the handle removes its interest immediately.
TrackedStatsClient

BidiError
ConnectionFailure
Event: Events surfaced to the consumer, in wire order. Ping/Pong never appear — liveness lives entirely inside the actor. Generic over the backend’s group and welcome message types.
Inbound: What an inbound frame means to the control core, after the binding classifies it. Liveness (Ping/Pong) is handled by the actor and never surfaced; everything else becomes a consumer Event.
LeaseEvent: Encrypted envelopes and initial catch-up completion for one lease.
MessageBackendBuilderError
TransportError
TryMutateError: Outcome of a Connection::try_mutate that could not be accepted; both variants hand the mutate back to the caller.

DEFAULT_LEASE_DEPTH: Default event capacity for one lease. Slow consumers must recover from storage.

BidiBinding: Backend-specific wire vocabulary for a bidi subscription. The control core is generic over this: a binding names the wire request/response types and the per-backend Mutate and message types, builds outbound frames, and — via BidiBinding::handle — classifies an inbound response into an Inbound instruction.
TransportBinding: Map backend envelopes to topics and positions for the lease ledger.

chunk_mutate_adds: Split an add set into updates within the backend count and byte limits. The caller must also enforce the total topic limit for its connection.