lib.rs

pub mod bootstrap;
pub mod catalog;
pub mod circuit_breaker;
pub mod cluster_info;
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 lifecycle_state;
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 readiness;
pub mod rebalance;
pub mod rebalance_scheduler;
pub mod routing;
pub mod rpc_codec;
pub mod shard_split;
pub mod swim;
pub mod topology;
pub mod transport;
pub mod vshard_handler;
pub mod wire;

pub use bootstrap::{ClusterConfig, ClusterState, JoinRetryPolicy, start_cluster};
pub use catalog::ClusterCatalog;
pub use cluster_info::{
    ClusterInfoSnapshot, ClusterObserver, GroupSnapshot, GroupStatusProvider, PeerSnapshot,
};
pub use conf_change::{ConfChange, ConfChangeType};
pub use error::{ClusterError, Result};
pub use forward::{NoopPlanExecutor, PlanExecutor};
pub use ghost::{GhostStub, GhostTable};
pub use health::{HealthConfig, HealthMonitor};
pub use lifecycle_state::{ClusterLifecycleState, ClusterLifecycleTracker};
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::{
    CacheApplier, DescriptorHeader, DescriptorId, DescriptorKind, DescriptorLease, DescriptorState,
    METADATA_GROUP_ID, MetadataApplier, MetadataCache, MetadataEntry, NoopMetadataApplier,
    RoutingChange, TopologyChange, decode_entry, encode_entry,
};
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};
pub use swim::{
    Incarnation, Member, MemberState, MembershipList, SwimConfig, SwimError, SwimHandle,
    UdpTransport, spawn as spawn_swim,
};