Skip to main content

liminal/durability/
mod.rs

1pub mod channel;
2pub mod config;
3pub mod conversation;
4pub mod cursor;
5pub mod dedup;
6pub mod error;
7pub mod receipt;
8pub mod recovery;
9pub mod replay;
10pub mod store;
11
12pub use channel::{CausalContext, DurableChannel, EphemeralChannel, MessageEnvelope, PartitionKey};
13
14pub use config::{CheckpointPolicy, DurabilityConfig, DurabilityMode};
15
16pub use conversation::{ConversationEvent, DurableConversation, RedeliveryDecision};
17
18pub use cursor::{CheckpointDriver, ConsumerCursor, cursor_key_for};
19
20pub use dedup::{DedupCache, DedupDecision, DedupEntry, DedupSweepReport, DedupSweeper};
21
22pub use error::DurabilityError;
23
24pub use receipt::ProcessingReceipt;
25
26pub use recovery::{
27    RecoveredCursor, recover_conversation, recover_cursor, recover_cursor_with_replay,
28    recover_durable_channel, recover_partition_sequences,
29};
30
31pub use replay::replay_from;
32
33pub use store::{DurableStore, HaematiteStore, StoredEntry};
34
35pub mod bridge;