Re-exports§
pub use channel::AppendResolution;pub use channel::CausalContext;pub use channel::DurableChannel;pub use channel::EphemeralChannel;pub use channel::MessageEnvelope;pub use channel::PartitionKey;pub use channel::UnresolvedAppend;pub use config::CheckpointPolicy;pub use config::DurabilityConfig;pub use config::DurabilityMode;pub use conversation::ConversationEvent;pub use conversation::DurableConversation;pub use conversation::RedeliveryDecision;pub use counting::StoreCountObserver;pub use counting::CountingStore;pub use counting::StoreCounts;pub use counting::StoreCountsHandle;pub use counting::record_store_opened;pub use counting::stores_opened;pub use cursor::CheckpointDriver;pub use cursor::ConsumerCursor;pub use cursor::cursor_key_for;pub use dedup::ClaimEvidence;pub use dedup::DedupCache;pub use dedup::DedupDecision;pub use dedup::DedupEntry;pub use dedup::DedupHeadCounts;pub use dedup::DedupSweepReport;pub use dedup::DedupSweeper;pub use dedup::InFlightClaim;pub use dedup::dedup_head_counts;pub use error::DurabilityError;pub use head_checkpoint::HEAD_CHECKPOINT_EVERY;pub use head_checkpoint::HeadCheckpointRefusal;pub use head_checkpoint::advance_head;pub use head_checkpoint::head_checkpoint_key;pub use head_checkpoint::recover_partition_head;pub use receipt::ProcessingReceipt;pub use recovery::RecoveredCursor;pub use recovery::recover_conversation;pub use recovery::recover_cursor;pub use recovery::recover_cursor_with_replay;pub use recovery::recover_durable_channel;pub use recovery::recover_partition_sequences;pub use replay::replay_from;pub use replay::replay_range;pub use store::DurableStore;pub use store::EphemeralHaematiteStore;pub use store::HaematiteStore;pub use store::RoutedBatchEntry;pub use store::RoutedBatchItem;pub use store::ScanCursor;pub use store::ScanPage;pub use store::StoredEntry;pub use ephemeral_root::EphemeralRoot;pub use ephemeral_root::EphemeralSweepCounts;
Modules§
- bridge
- Synchronous bridge for driving durable-store futures to completion.
- channel
- config
- conversation
- counting
- A counting seam around any
DurableStore. - cursor
- dedup
- ephemeral_
root - error
- Named storage failures and uncertain channel append outcomes.
- head_
checkpoint - Recorded partition heads: where a durable channel’s restart resumes reading its log.
- head_
checkpoint_ stop - Clean-stop checkpoint ownership at the shared store’s append boundary.
- receipt
- recovery
- replay
- settle
- Writes that settle an unknown outcome by reading the position back.
- store