1pub mod blocks;
14pub mod events;
15pub mod integrations;
16pub mod manager;
17pub mod metrics;
18pub mod pools;
19pub mod pubsub;
20pub mod registry;
21pub mod sequence;
22pub mod tinylfu;
23
24#[cfg(any(test, feature = "testing"))]
25pub mod testing;
26
27use bincode::{Decode, Encode};
28use serde::{Deserialize, Serialize};
29
30pub use blocks::{
32 BlockError, BlockMetadata, CompleteBlock, ImmutableBlock, MutableBlock, WeakBlock,
33};
34pub use integrations::{
35 ApplyError, DecodeOutcome, NoopDelegate, RequestSequence, SchedulableSequence,
36 SchedulableSequenceBuilder, ScheduleError, SequenceDelegate, SequenceEvent, SequenceState,
37};
38pub use manager::BlockManager;
39pub use registry::BlockRegistry;
40pub use sequence::{
41 BlockSequence, BlockSequenceError, ExternalBlockAssignments, LogicalBlockAssignmentError,
42 LogicalBlockAssignments, zip_assigned, zip_assigned_pending,
43};
44
45pub type BlockId = usize;
46pub type SequenceHash = dynamo_tokens::PositionalLineageHash;
47
48pub trait KvbmSequenceHashProvider {
49 fn kvbm_sequence_hash(&self) -> SequenceHash;
50}
51
52impl KvbmSequenceHashProvider for dynamo_tokens::TokenBlock {
53 fn kvbm_sequence_hash(&self) -> SequenceHash {
54 self.positional_lineage_hash()
55 }
56}
57
58#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Encode, Decode, Serialize, Deserialize)]
62pub enum LogicalLayoutHandle {
63 G1,
65 G2,
67 G3,
69 G4,
72}