liminal/durability/
mod.rs

1pub mod channel;
2pub mod config;
3pub mod conversation;
4pub mod counting;
5pub mod cursor;
6pub mod dedup;
7pub mod ephemeral_root;
8pub mod error;
9pub mod head_checkpoint;
10pub mod head_checkpoint_stop;
11#[cfg(test)]
12mod head_checkpoint_stop_tests;
13#[cfg(test)]
14mod outcome_unknown_tests;
15#[cfg(test)]
16mod real_store_proofs_tests;
17pub mod receipt;
18pub mod recovery;
19pub mod replay;
20#[cfg(test)]
21mod routed_batch_tests;
22pub mod settle;
23#[cfg(test)]
24mod settle_tests;
25pub mod store;
26#[cfg(test)]
27mod store_bound_tests;
28#[cfg(test)]
29mod tests_ephemeral_root;
30#[cfg(test)]
31mod tests_fixtures;
32#[cfg(test)]
33pub(crate) mod tests_memory_store;
34
35pub use channel::{
36    AppendResolution, CausalContext, DurableChannel, EphemeralChannel, MessageEnvelope,
37    PartitionKey, UnresolvedAppend,
38};
39
40pub use config::{CheckpointPolicy, DurabilityConfig, DurabilityMode};
41
42pub use conversation::{ConversationEvent, DurableConversation, RedeliveryDecision};
43
44pub use counting::StoreCountObserver;
45pub use counting::{
46    CountingStore, StoreCounts, StoreCountsHandle, record_store_opened, stores_opened,
47};
48
49pub use cursor::{CheckpointDriver, ConsumerCursor, cursor_key_for};
50
51pub use dedup::{
52    ClaimEvidence, DedupCache, DedupDecision, DedupEntry, DedupHeadCounts, DedupSweepReport,
53    DedupSweeper, InFlightClaim, dedup_head_counts,
54};
55
56pub use error::DurabilityError;
57
58pub use head_checkpoint::{
59    HEAD_CHECKPOINT_EVERY, HeadCheckpointRefusal, advance_head, head_checkpoint_key,
60    recover_partition_head,
61};
62
63pub use receipt::ProcessingReceipt;
64
65pub use recovery::{
66    RecoveredCursor, recover_conversation, recover_cursor, recover_cursor_with_replay,
67    recover_durable_channel, recover_partition_sequences,
68};
69
70pub use replay::{replay_from, replay_range};
71
72pub use store::{
73    DurableStore, EphemeralHaematiteStore, HaematiteStore, RoutedBatchEntry, RoutedBatchItem,
74    ScanCursor, ScanPage, StoredEntry,
75};
76
77#[cfg(any(test, feature = "test-support"))]
78pub use store::{open_ephemeral, open_ephemeral_rooted};
79
80pub use ephemeral_root::{EphemeralRoot, EphemeralSweepCounts};
81
82pub mod bridge;
liminal/durability/mod.rs

liminal/durability/
mod.rs
