Module subscription 

Durable identities and canonical metadata for committed subscription output. Versioned, feature-neutral contract for durable subscription output.

Structs

MergedSubscriptionCheckpoint

Whole-cluster stream cut reconstructed from exact participant manifests.

NodePartitionRange

One participant-owned output interval in a checkpoint attempt.

NodeSubscriptionManifest

Participant-local subscription output bound into its checkpoint manifest.

NodeSubscriptionStreamManifest

One stream’s participant-local portion of a checkpointed output cut.

OutputDistributionCertificate

Planner proof that a final operator has a stable, recoverable output distribution.

OutputFrameId

Globally unambiguous identity of one partition-local output frame.

OutputPartitionId

Logical output partition. Keyed aggregate partitions are stable vnodes.

OutputSegmentRef

Exact immutable object containing a contiguous partition-frame range.

PartitionFrontier

First partition sequence not covered by a committed checkpoint.

PartitionSequence

Monotonic frame position within one stream generation and output partition.

StreamGeneration

Durable identity of one catalog stream incarnation.

SubscriptionCheckpointManifest

Canonical subscription output bound into one whole-cluster checkpoint.

SubscriptionDigest

Fixed-size SHA-256 used by subscription metadata.

SubscriptionProtocolVersion

Version of the durable subscription metadata and segment envelope.

Enums

ChangelogMode

Changelog representation bound into an output-distribution certificate.

OutputDistribution

Recoverable mapping from final operator output to subscription partitions.

SubscriptionContractError

Structured validation failure for durable subscription contracts.

Constants

MAX_OUTPUT_FRAMES_PER_SEGMENT

Hard frame-count bound for one immutable Arrow output segment.

MAX_OUTPUT_SEGMENTS_PER_MANIFEST

Hard segment-reference count bound for one stream checkpoint manifest.

MAX_OUTPUT_SEGMENT_BYTES

Hard encoded-object bound for one immutable Arrow output segment.

MAX_SUBSCRIPTION_MANIFEST_BYTES

Hard canonical encoded size bound for one stream checkpoint manifest.

OUTPUT_DISTRIBUTION_CERTIFICATE_VERSION

Current canonical output-distribution certificate format.

SUBSCRIPTION_PROTOCOL_VERSION

Current committed-subscription protocol version.

Functions

merge_node_subscription_manifests

Merge one complete participant roster into canonical whole-cluster subscription cuts. Each manifest is paired with the exact owned-vnode roster from its enclosing checkpoint.