link-common 0.5.2-rc.2

Shared Rust implementation for KalamDB link crates
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30

//! WebSocket subscription management for real-time updates.
//!
//! `models` (subscription models) is always available — no `tokio-runtime` needed.
//! The WebSocket manager requires the `tokio-runtime` feature.

mod checkpoint;
mod live_rows_config;
mod live_rows_event;
mod live_rows_materializer;
pub mod models;

pub use live_rows_config::LiveRowsConfig;
pub use live_rows_event::LiveRowsEvent;
pub use live_rows_materializer::LiveRowsMaterializer;
pub use models::{SubscriptionConfig, SubscriptionInfo, SubscriptionOptions, SubscriptionRequest};

#[cfg(feature = "tokio-runtime")]
mod live_rows_subscription;
#[cfg(feature = "tokio-runtime")]
mod manager;
#[cfg(any(feature = "tokio-runtime", feature = "wasm", test))]
pub(crate) use checkpoint::filter_replayed_event;
#[cfg(feature = "tokio-runtime")]
pub(crate) use checkpoint::{
    batch_envelope, buffer_event, event_progress, final_resume_seq, subscription_start_ready,
};
#[cfg(feature = "tokio-runtime")]
pub use live_rows_subscription::LiveRowsSubscription;
#[cfg(feature = "tokio-runtime")]
pub use manager::SubscriptionManager;