Skip to main content

laminar_core/checkpoint/subscription/
mod.rs

1//! Versioned, feature-neutral contract for durable subscription output.
2
3mod distribution;
4mod identity;
5mod manifest;
6mod node_manifest;
7
8pub use distribution::{
9    ChangelogMode, OutputDistribution, OutputDistributionCertificate,
10    OUTPUT_DISTRIBUTION_CERTIFICATE_VERSION,
11};
12pub use identity::{
13    OutputFrameId, OutputPartitionId, PartitionSequence, StreamGeneration, SubscriptionDigest,
14    SubscriptionProtocolVersion, SUBSCRIPTION_PROTOCOL_VERSION,
15};
16pub use manifest::{
17    OutputSegmentRef, PartitionFrontier, SubscriptionCheckpointManifest, SubscriptionContractError,
18    MAX_OUTPUT_FRAMES_PER_SEGMENT, MAX_OUTPUT_SEGMENTS_PER_MANIFEST, MAX_OUTPUT_SEGMENT_BYTES,
19    MAX_SUBSCRIPTION_MANIFEST_BYTES,
20};
21pub use node_manifest::{
22    merge_node_subscription_manifests, MergedSubscriptionCheckpoint, NodePartitionRange,
23    NodeSubscriptionManifest, NodeSubscriptionStreamManifest,
24};