Re-exports§
pub use bootstrap::ClusterConfig;pub use bootstrap::ClusterState;pub use bootstrap::start_cluster;pub use catalog::ClusterCatalog;pub use conf_change::ConfChange;pub use conf_change::ConfChangeType;pub use error::ClusterError;pub use error::Result;pub use forward::NoopForwarder;pub use forward::RequestForwarder;pub use ghost::GhostStub;pub use ghost::GhostTable;pub use health::HealthConfig;pub use health::HealthMonitor;pub use migration::MigrationPhase;pub use migration::MigrationState;pub use migration_executor::MigrationExecutor;pub use migration_executor::MigrationRequest;pub use migration_executor::MigrationResult;pub use migration_executor::MigrationSnapshot;pub use migration_executor::MigrationTracker;pub use multi_raft::GroupStatus;pub use multi_raft::MultiRaft;pub use raft_loop::CommitApplier;pub use raft_loop::RaftLoop;pub use raft_loop::VShardEnvelopeHandler;pub use rebalance::RebalancePlan;pub use rebalance::compute_plan;pub use rebalance::plan_to_requests;pub use routing::RoutingTable;pub use rpc_codec::RaftRpc;pub use topology::ClusterTopology;pub use topology::NodeInfo;pub use topology::NodeState;pub use transport::NexarTransport;pub use transport::RaftRpcHandler;pub use wire::VShardEnvelope;pub use cross_shard_txn::CrossShardTransaction;pub use cross_shard_txn::ForwardEntry;pub use cross_shard_txn::GsiForwardEntry;pub use cross_shard_txn::TransactionCoordinator;pub use metadata_group::METADATA_GROUP_ID;pub use metadata_group::MetadataCache;pub use metadata_group::MetadataEntry;pub use quic_transport::QuicTransport;pub use quic_transport::QuicTransportConfig;pub use distributed_join::BroadcastJoinRequest;pub use distributed_join::JoinStrategy;pub use distributed_join::ShufflePartition;pub use distributed_join::select_strategy;pub use lifecycle::DecommissionResult;pub use lifecycle::handle_learner_promotion;pub use lifecycle::handle_node_join;pub use lifecycle::plan_decommission;pub use rdma_transport::RdmaConfig;pub use rdma_transport::RdmaTransport;pub use rebalance_scheduler::NodeMetrics;pub use rebalance_scheduler::RebalanceScheduler;pub use rebalance_scheduler::RebalanceTrigger;pub use rebalance_scheduler::SchedulerConfig;pub use shard_split::SplitPlan;pub use shard_split::SplitStrategy;pub use shard_split::plan_graph_split;pub use shard_split::plan_vector_split;
Modules§
- bootstrap
- Cluster bootstrap and join protocol.
- catalog
- Cluster catalog — persistent storage for topology and routing tables.
- circuit_
breaker - Per-peer circuit breaker and retry policy for RPC resilience.
- conf_
change - Raft configuration change types.
- cross_
shard_ txn - Cross-shard write atomicity via Calvin-style deterministic transactions.
- distributed_
document - distributed_
graph - distributed_
join - Distributed join execution: broadcast and shuffle joins across cluster nodes.
- distributed_
spatial - distributed_
timeseries - distributed_
vector - error
- forward
- Query forwarding trait for leader-based request routing.
- ghost
- ghost_
sweeper - Periodic ghost edge anti-entropy sweeper.
- health
- Cluster health monitoring — periodic pings, failure detection, topology broadcast.
- lifecycle
- Node lifecycle management: join, leave, decommission.
- metadata_
group - Replicated metadata Raft group for cluster-wide state.
- migration
- migration_
executor - vShard migration executor — drives the 3-phase migration state machine.
- multi_
raft - quic_
transport - QUIC/TCP fallback transport for shard migration and cross-node communication.
- raft_
loop - Raft event loop — drives MultiRaft ticks and dispatches messages over the transport.
- raft_
storage - Persistent Raft log storage backed by redb.
- rdma_
transport - RDMA transport for high-performance shard migration base copy.
- rebalance
- Rebalancing planner — computes and executes vShard redistribution.
- rebalance_
scheduler - Rebalance scheduler: automatic trigger-based shard redistribution.
- routing
- rpc_
codec - Raft RPC binary codec.
- shard_
split - Shard splitting: vector-aware and graph-aware partitioning.
- topology
- Cluster topology — tracks which nodes exist and their state.
- transport
- vshard_
handler - Shard-side handler for incoming VShardEnvelope messages.
- wire
- Transport-agnostic vShard envelope.