Skip to main content

laminar_db/subscription/
mod.rs

1//! `SUBSCRIBE` substrate: one shared byte-bounded log per object and cursor portals.
2
3#[cfg(feature = "cluster")]
4pub(crate) mod cluster;
5pub(crate) mod distribution;
6mod error;
7#[cfg(feature = "cluster")]
8mod frame;
9mod portal;
10mod registry;
11
12pub(crate) const MAX_SUBSCRIBERS_PER_MV: usize = 64;
13
14pub use error::ClusterSubscriptionError;
15#[cfg(feature = "cluster")]
16pub(crate) use frame::{
17    CertifiedSubscriptionFrontiers, PartitionedOutputBatch, PreparedSubscriptionOutput,
18};
19pub use portal::{
20    ClusterSubscriptionFrameMetadata, PortalFrame, SubscriptionEnvelope, SubscriptionFrameLease,
21    SubscriptionPortal,
22};
23pub use registry::SubscribeStart;
24pub(crate) use registry::{SubscriptionOpenError, SubscriptionRegistry};