Module subscription 

Structs

MatchedCheckpoint

SubscriptionService

SubscriptionServiceHandle

SubscriptionSpec

What a subscriber asked for. query: None = unfiltered (stream everything).

Enums

SubscriptionKind

Which item stream a subscriber asked for.

SubscriptionMatches

Kind-specific match payload. Indices are within-checkpoint and ascending.

SubscriptionUpdate

Updates delivered to a subscriber while processing checkpoints. An initial progress frame may precede a matched frame for the entry checkpoint.

Type Aliases

IndexedCheckpointFn

Reads the highest checkpoint the index has committed (the embedded rpc-store’s live-cohort watermark), or None if it has indexed nothing yet. When supplied to SubscriptionService::build, the service holds a checkpoint back until the index has committed it, so a client that observes a checkpoint (e.g. via execute_transaction_and_wait_for_checkpoint) can immediately read that checkpoint’s indexed state.