nodedb-cluster 0.0.0-beta.5

Distributed coordination layer for NodeDB — vShards, QUIC transport, and replication
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

pub mod bootstrap;
pub mod catalog;
pub mod circuit_breaker;
pub mod conf_change;
pub mod cross_shard_txn;
pub mod distributed_document;
pub mod distributed_graph;
pub mod distributed_join;
pub mod distributed_spatial;
pub mod distributed_timeseries;
pub mod distributed_vector;
pub mod error;
pub mod forward;
pub mod ghost;
pub mod ghost_sweeper;
pub mod health;
pub mod lifecycle;
pub mod metadata_group;
pub mod migration;
pub mod migration_executor;
pub mod multi_raft;
pub mod quic_transport;
pub mod raft_loop;
pub mod raft_storage;
pub mod rdma_transport;
pub mod rebalance;
pub mod rebalance_scheduler;
pub mod routing;
pub mod rpc_codec;
pub mod shard_split;
pub mod topology;
pub mod transport;
pub mod vshard_handler;
pub mod wire;

pub use bootstrap::{ClusterConfig, ClusterState, start_cluster};
pub use catalog::ClusterCatalog;
pub use conf_change::{ConfChange, ConfChangeType};
pub use error::{ClusterError, Result};
pub use forward::{NoopForwarder, RequestForwarder};
pub use ghost::{GhostStub, GhostTable};
pub use health::{HealthConfig, HealthMonitor};
pub use migration::{MigrationPhase, MigrationState};
pub use migration_executor::{
    MigrationExecutor, MigrationRequest, MigrationResult, MigrationSnapshot, MigrationTracker,
};
pub use multi_raft::{GroupStatus, MultiRaft};
pub use raft_loop::{CommitApplier, RaftLoop, VShardEnvelopeHandler};
pub use rebalance::{RebalancePlan, compute_plan, plan_to_requests};
pub use routing::RoutingTable;
pub use rpc_codec::RaftRpc;
pub use topology::{ClusterTopology, NodeInfo, NodeState};
pub use transport::{NexarTransport, RaftRpcHandler};
pub use wire::VShardEnvelope;

pub use cross_shard_txn::{
    CrossShardTransaction, ForwardEntry, GsiForwardEntry, TransactionCoordinator,
};
pub use metadata_group::{METADATA_GROUP_ID, MetadataCache, MetadataEntry};
pub use quic_transport::{QuicTransport, QuicTransportConfig};

pub use distributed_join::{BroadcastJoinRequest, JoinStrategy, ShufflePartition, select_strategy};
pub use lifecycle::{
    DecommissionResult, handle_learner_promotion, handle_node_join, plan_decommission,
};
pub use rdma_transport::{RdmaConfig, RdmaTransport};
pub use rebalance_scheduler::{NodeMetrics, RebalanceScheduler, RebalanceTrigger, SchedulerConfig};
pub use shard_split::{SplitPlan, SplitStrategy, plan_graph_split, plan_vector_split};