Module subscription_runtime 

Store-backed subscription runtime (Packet C).

syncbat owns replay, live wake, cursor resume, ACK/backpressure, and delivery envelopes. Wire framing lives in netbat.

Structs

CompositeSubscriptionRuntime

Store-backed composite subscription runtime dispatching event and projection routes.

EntityStreamCursorV1

Versioned opaque entity-stream cursor owned by syncbat.

EntityStreamEnvelopeV1

Canonical entity-stream payload envelope encoded with batpak::canonical::to_bytes.

EntityStreamRouteBinding

Binding fields needed to open an entity-stream subscription session.

EntityStreamSession

Store-backed entity-stream subscription session.

EventStreamCursorV1

Versioned opaque event-stream cursor owned by syncbat.

EventStreamEnvelopeV1

Canonical event-stream payload envelope encoded with batpak::canonical::to_bytes.

EventStreamSession

Store-backed event-category subscription session.

EventSubscriptionRuntime

Store-backed event-subscription runtime.

OperationStatusRouteBinding

Binding fields needed to open an operation-status subscription session.

OperationStatusStreamCursorV1

Versioned opaque operation-status-stream cursor owned by syncbat.

OperationStatusStreamEnvelopeV1

Canonical operation-status-stream payload envelope encoded with batpak::canonical::to_bytes.

OperationStatusStreamSession

Store-backed operation-status subscription session.

ProjectionRouteBinding

Route binding passed to projection projectors at session open.

ProjectionStreamCursorV1

Versioned opaque projection-stream cursor owned by syncbat.

ProjectionStreamEnvelopeV1

Canonical projection-stream payload envelope encoded with batpak::canonical::to_bytes.

ProjectionStreamSession

Store-backed projection subscription session.

ReceiptStreamCursorV1

Versioned opaque receipt-stream cursor owned by syncbat.

ReceiptStreamEnvelopeV1

Canonical receipt-stream payload envelope encoded with batpak::canonical::to_bytes.

ReceiptStreamRouteBinding

Binding fields needed to open a receipt-stream subscription session.

ReceiptStreamSession

Store-backed receipt-stream subscription session.

RuntimeCursor

Opaque runtime cursor bytes passed between syncbat sessions and netbat transport.

SessionEnd

Terminal stream end delivery.

SessionError

Terminal stream error delivery.

SessionEventDelivery

One delivered event or projection update with cursor and envelope bytes.

SessionWatermarkDelivery

Coalesced watermark delivery.

SubscriptionId

Globally unique subscription id (orders.open.v1 grammar).

SubscriptionRegistry

Typed subscription route table for the runtime engine.

SubscriptionRuntimeConfig

Runtime limits for subscription delivery sessions.

SubscriptionStore

Cloneable syncbat-owned store handle for subscription runtime sessions.

TypedProjectionProjector

Typed projector backed by Store::watch_projection_with_cursor.

Enums

OperationStatusPositionKind

Resume position encoded inside OperationStatusStreamCursorV1.

PositionKind

Resume position encoded inside EventStreamCursorV1.

ProjectionPositionKind

Resume position encoded inside ProjectionStreamCursorV1.

SessionControl

Client control input accepted after subscribe.

SessionDelivery

One server-side delivery frame produced by the runtime engine.

SessionPoll

Result of one runtime poll step.

SubscriptionRoute

Declared route for one subscription id.

SubscriptionRuntimeError

Error returned by the subscription runtime engine.

Constants

CURSOR_V1_LEN

Fixed on-wire event cursor byte length.

ENTITY_STREAM_CURSOR_V1_LEN

Fixed on-wire entity-stream cursor byte length.

MAX_SUBSCRIPTION_ID_BYTES

Maximum bytes accepted for a subscription id under the subscription-id grammar. This is the single source the boundary crates (hostbat, netbat) share so their id caps can never disagree with the runtime registry’s.

OPERATION_STATUS_CURSOR_V1_LEN

Fixed on-wire operation-status cursor byte length.

PROJECTION_CURSOR_V1_LEN

Fixed on-wire projection cursor byte length.

RECEIPT_STREAM_CURSOR_V1_LEN

Fixed on-wire receipt-stream cursor byte length.

SOURCE_KIND_ENTITY_STREAM

Entity stream source kind.

SOURCE_KIND_EVENT_CATEGORY

Event-category stream source kind.

SOURCE_KIND_OPERATION_STATUS

Operation-status stream source kind.

SOURCE_KIND_PROJECTION

Projection stream source kind.

SOURCE_KIND_RECEIPT_STREAM

Receipt stream source kind.

Traits

ProjectionProjector

syncbat-owned projector that opens typed projection subscription sessions.

SubscriptionSession

Runtime session polled by transport adapters.

SubscriptionSessionFactory

Factory that opens subscription sessions from wire SUBSCRIBE inputs.

Functions

cursor_invalid_error

Cursor invalid terminal error before session open.

cursor_mismatch_error

Cursor mismatch terminal error before session open.

unknown_subscription_error

Unknown subscription terminal error before session open.