List of all items

Structs

• bootstrap::ClusterConfig
• bootstrap::ClusterState
• catalog::ClusterCatalog
• circuit_breaker::CircuitBreaker
• circuit_breaker::CircuitBreakerConfig
• circuit_breaker::RetryPolicy
• conf_change::ConfChange
• cross_shard_txn::CrossShardTransaction
• cross_shard_txn::EdgeValidationRequest
• cross_shard_txn::ForwardEntry
• cross_shard_txn::GsiForwardEntry
• cross_shard_txn::TransactionCoordinator
• distributed_document::bm25_global::GlobalIdf
• distributed_document::bm25_global::GlobalIdfCoordinator
• distributed_document::bm25_global::ScoredHit
• distributed_document::bm25_global::ShardDfReport
• distributed_document::merge_sort::OrderByMerger
• distributed_document::merge_sort::ShardRow
• distributed_document::partial_group::PartialColumnAgg
• distributed_document::partial_group::PartialGroup
• distributed_document::partial_group::PartialGroupByMerger
• distributed_graph::coordinator::BspCoordinator
• distributed_graph::pagerank::ShardPageRankState
• distributed_graph::pattern_match::DistributedMatchCoordinator
• distributed_graph::pattern_match::PatternContinuation
• distributed_graph::pattern_match::ShardMatchResult
• distributed_graph::types::AlgoComplete
• distributed_graph::types::BoundaryContributions
• distributed_graph::types::SuperstepAck
• distributed_graph::types::SuperstepBarrier
• distributed_graph::wcc::ComponentMergeRequest
• distributed_graph::wcc::ShardWccState
• distributed_graph::wcc::WccRoundAck
• distributed_join::BroadcastJoinRequest
• distributed_join::ShufflePartition
• distributed_spatial::coordinator::SpatialScatterGather
• distributed_spatial::coordinator::SpatialScatterPayload
• distributed_spatial::geofence::Geofence
• distributed_spatial::geofence::GeofenceEvent
• distributed_spatial::geofence::GeofenceRegistry
• distributed_spatial::merge::ShardSpatialResult
• distributed_spatial::merge::SpatialHit
• distributed_spatial::merge::SpatialResultMerger
• distributed_spatial::shard_routing::ShardSpatialExtent
• distributed_spatial::shard_routing::SpatialRoutingTable
• distributed_timeseries::coordinator::TsArchivePayload
• distributed_timeseries::coordinator::TsCoordinator
• distributed_timeseries::coordinator::TsScatterPayload
• distributed_timeseries::merge::PartialAgg
• distributed_timeseries::merge::PartialAggMerger
• distributed_timeseries::retention::CoordinatedRetention
• distributed_timeseries::retention::RetentionCommand
• distributed_timeseries::retention::RetentionVerification
• distributed_timeseries::retention::ShardRetentionResult
• distributed_timeseries::s3_shard::ArchivePlan
• distributed_timeseries::s3_shard::ArchivedPartition
• distributed_timeseries::s3_shard::ShardedS3Config
• distributed_timeseries::scatter_gather::ScatterGatherPlan
• distributed_timeseries::scatter_gather::ShardResult
• distributed_timeseries::sketch_merge::SketchMerger
• distributed_vector::coordinator::VectorScatterGather
• distributed_vector::coordinator::VectorScatterPayload
• distributed_vector::merge::ShardSearchResult
• distributed_vector::merge::VectorHit
• distributed_vector::merge::VectorMerger
• forward::NoopForwarder
• ghost::GhostStub
• ghost::GhostTable
• ghost::SweepReport
• ghost_sweeper::GhostSweeperConfig
• health::HealthConfig
• health::HealthMonitor
• lifecycle::DecommissionResult
• metadata_group::MetadataCache
• migration::MigrationState
• migration_executor::MigrationExecutor
• migration_executor::MigrationRequest
• migration_executor::MigrationResult
• migration_executor::MigrationSnapshot
• migration_executor::MigrationTracker
• multi_raft::GroupStatus
• multi_raft::MultiRaft
• multi_raft::MultiRaftReady
• quic_transport::QuicTransport
• quic_transport::QuicTransportConfig
• raft_loop::RaftLoop
• raft_storage::RedbLogStorage
• rdma_transport::RdmaConfig
• rdma_transport::RdmaTransport
• rebalance::PlannedMove
• rebalance::RebalancePlan
• rebalance_scheduler::NodeMetrics
• rebalance_scheduler::RebalanceScheduler
• rebalance_scheduler::SchedulerConfig
• routing::GroupInfo
• routing::RoutingTable
• rpc_codec::ArchivedForwardRequest
• rpc_codec::ArchivedForwardResponse
• rpc_codec::ArchivedJoinGroupInfo
• rpc_codec::ArchivedJoinNodeInfo
• rpc_codec::ArchivedJoinRequest
• rpc_codec::ArchivedJoinResponse
• rpc_codec::ArchivedPingRequest
• rpc_codec::ArchivedPongResponse
• rpc_codec::ArchivedTopologyAck
• rpc_codec::ArchivedTopologyUpdate
• rpc_codec::ForwardRequest
• rpc_codec::ForwardRequestResolver
• rpc_codec::ForwardResponse
• rpc_codec::ForwardResponseResolver
• rpc_codec::JoinGroupInfo
• rpc_codec::JoinGroupInfoResolver
• rpc_codec::JoinNodeInfo
• rpc_codec::JoinNodeInfoResolver
• rpc_codec::JoinRequest
• rpc_codec::JoinRequestResolver
• rpc_codec::JoinResponse
• rpc_codec::JoinResponseResolver
• rpc_codec::PingRequest
• rpc_codec::PingRequestResolver
• rpc_codec::PongResponse
• rpc_codec::PongResponseResolver
• rpc_codec::TopologyAck
• rpc_codec::TopologyAckResolver
• rpc_codec::TopologyUpdate
• rpc_codec::TopologyUpdateResolver
• shard_split::SplitPlan
• topology::ClusterTopology
• topology::NodeInfo
• transport::client::NexarTransport
• transport::config::TlsCredentials
• wire::VShardEnvelope

Enums

• circuit_breaker::CircuitState
• conf_change::ConfChangeType
• cross_shard_txn::EdgeValidationResult
• cross_shard_txn::GsiAction
• distributed_document::merge_sort::SortDirection
• distributed_join::JoinSide
• distributed_join::JoinStrategy
• distributed_spatial::geofence::GeofenceEventType
• error::ClusterError
• ghost::SweepVerdict
• metadata_group::DdlAction
• metadata_group::MembershipAction
• metadata_group::MetadataEntry
• metadata_group::SecurityChangeType
• migration::MigrationPhase
• rdma_transport::RdmaState
• rebalance_scheduler::RebalanceTrigger
• rpc_codec::RaftRpc
• shard_split::SplitStrategy
• topology::NodeState
• vshard_handler::DispatchTarget
• vshard_handler::HandleResult
• wire::VShardMessageType

Traits

• forward::RequestForwarder
• raft_loop::CommitApplier
• transport::server::RaftRpcHandler
• vshard_handler::VShardHandler

Functions

• bootstrap::handle_join_request
• bootstrap::start_cluster
• distributed_document::merge_sort::encode_sort_key_f64
• distributed_document::merge_sort::encode_sort_key_i64
• distributed_document::merge_sort::encode_sort_key_string
• distributed_join::estimate_collection_bytes
• distributed_join::partition_for_key
• distributed_join::plan_shuffle_partitions
• distributed_join::select_strategy
• distributed_timeseries::scatter_gather::consolidate_aggregate_results
• distributed_timeseries::scatter_gather::estimate_scatter_cost
• distributed_timeseries::scatter_gather::merge_shard_results
• distributed_timeseries::scatter_gather::shards_for_collection
• distributed_timeseries::sketch_merge::merge_hll
• distributed_timeseries::sketch_merge::merge_tdigest
• distributed_timeseries::sketch_merge::merge_topk
• distributed_vector::merge::over_fetch_factor
• ghost_sweeper::run_sweep_loop
• health::handle_ping
• health::handle_topology_update
• lifecycle::handle_learner_promotion
• lifecycle::handle_node_join
• lifecycle::is_safe_to_remove
• lifecycle::plan_decommission
• rebalance::compute_plan
• rebalance::plan_to_requests
• rebalance::should_rebalance
• rebalance_scheduler::plan_hot_split
• routing::fnv1a_hash
• routing::vshard_for_collection
• rpc_codec::decode
• rpc_codec::encode
• rpc_codec::frame_size
• shard_split::plan_graph_split
• shard_split::plan_vector_split
• shard_split::speculative_prefetch_shards
• transport::config::generate_node_credentials
• transport::config::load_crls_from_pem
• transport::config::make_raft_client_config
• transport::config::make_raft_client_config_mtls
• transport::config::make_raft_server_config
• transport::config::make_raft_server_config_mtls
• transport::config::raft_transport_config
• vshard_handler::build_ts_retention_ack
• vshard_handler::build_ts_scatter_response
• vshard_handler::dispatch_by_type

Type Aliases

• error::Result
• raft_loop::VShardEnvelopeHandler

Constants

• conf_change::CONF_CHANGE_PREFIX
• distributed_join::DEFAULT_BROADCAST_THRESHOLD_BYTES
• ghost_sweeper::DEFAULT_SWEEP_INTERVAL
• health::DEFAULT_FAILURE_THRESHOLD
• health::DEFAULT_PING_INTERVAL
• metadata_group::METADATA_GROUP_ID
• rebalance::MAX_CONCURRENT_MIGRATIONS
• routing::VSHARD_COUNT
• rpc_codec::HEADER_SIZE
• transport::config::ALPN_NODEDB_RAFT
• transport::config::DEFAULT_RPC_TIMEOUT
• transport::config::SNI_HOSTNAME
• wire::WIRE_VERSION