List of all items

Structs

• bootstrap::config::ClusterConfig
• bootstrap::config::ClusterState
• bootstrap::config::JoinRetryPolicy
• catalog::core::ClusterCatalog
• circuit_breaker::CircuitBreaker
• circuit_breaker::CircuitBreakerConfig
• circuit_breaker::RetryPolicy
• cluster_info::ClusterInfoSnapshot
• cluster_info::ClusterObserver
• cluster_info::GroupSnapshot
• cluster_info::PeerSnapshot
• 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::NoopPlanExecutor
• ghost::GhostStub
• ghost::GhostTable
• ghost::SweepReport
• ghost_sweeper::GhostSweeperConfig
• health::HealthConfig
• health::HealthMonitor
• lifecycle::DecommissionResult
• lifecycle_state::ClusterLifecycleTracker
• metadata_group::applier::CacheApplier
• metadata_group::applier::NoopMetadataApplier
• metadata_group::cache::MetadataCache
• metadata_group::descriptors::common::DescriptorHeader
• metadata_group::descriptors::common::DescriptorId
• metadata_group::descriptors::lease::DescriptorLease
• migration::MigrationState
• migration_executor::MigrationExecutor
• migration_executor::MigrationRequest
• migration_executor::MigrationResult
• migration_executor::MigrationSnapshot
• migration_executor::MigrationTracker
• multi_raft::core::GroupStatus
• multi_raft::core::MultiRaft
• multi_raft::core::MultiRaftReady
• quic_transport::QuicTransport
• quic_transport::QuicTransportConfig
• raft_loop::loop_core::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::cluster_mgmt::ArchivedJoinGroupInfo
• rpc_codec::cluster_mgmt::ArchivedJoinNodeInfo
• rpc_codec::cluster_mgmt::ArchivedJoinRequest
• rpc_codec::cluster_mgmt::ArchivedJoinResponse
• rpc_codec::cluster_mgmt::ArchivedPingRequest
• rpc_codec::cluster_mgmt::ArchivedPongResponse
• rpc_codec::cluster_mgmt::ArchivedTopologyAck
• rpc_codec::cluster_mgmt::ArchivedTopologyUpdate
• rpc_codec::cluster_mgmt::JoinGroupInfo
• rpc_codec::cluster_mgmt::JoinGroupInfoResolver
• rpc_codec::cluster_mgmt::JoinNodeInfo
• rpc_codec::cluster_mgmt::JoinNodeInfoResolver
• rpc_codec::cluster_mgmt::JoinRequest
• rpc_codec::cluster_mgmt::JoinRequestResolver
• rpc_codec::cluster_mgmt::JoinResponse
• rpc_codec::cluster_mgmt::JoinResponseResolver
• rpc_codec::cluster_mgmt::PingRequest
• rpc_codec::cluster_mgmt::PingRequestResolver
• rpc_codec::cluster_mgmt::PongResponse
• rpc_codec::cluster_mgmt::PongResponseResolver
• rpc_codec::cluster_mgmt::TopologyAck
• rpc_codec::cluster_mgmt::TopologyAckResolver
• rpc_codec::cluster_mgmt::TopologyUpdate
• rpc_codec::cluster_mgmt::TopologyUpdateResolver
• rpc_codec::execute::ArchivedDescriptorVersionEntry
• rpc_codec::execute::ArchivedExecuteRequest
• rpc_codec::execute::ArchivedExecuteResponse
• rpc_codec::execute::DescriptorVersionEntry
• rpc_codec::execute::DescriptorVersionEntryResolver
• rpc_codec::execute::ExecuteRequest
• rpc_codec::execute::ExecuteRequestResolver
• rpc_codec::execute::ExecuteResponse
• rpc_codec::execute::ExecuteResponseResolver
• rpc_codec::metadata::ArchivedMetadataProposeRequest
• rpc_codec::metadata::ArchivedMetadataProposeResponse
• rpc_codec::metadata::MetadataProposeRequest
• rpc_codec::metadata::MetadataProposeRequestResolver
• rpc_codec::metadata::MetadataProposeResponse
• rpc_codec::metadata::MetadataProposeResponseResolver
• shard_split::SplitPlan
• swim::bootstrap::SwimHandle
• swim::config::SwimConfig
• swim::detector::probe_round::InflightProbes
• swim::detector::probe_round::ProbeRound
• swim::detector::runner::FailureDetector
• swim::detector::scheduler::ProbeScheduler
• swim::detector::suspicion::SuspicionTimer
• swim::detector::transport::in_memory::InMemoryTransport
• swim::detector::transport::in_memory::TransportFabric
• swim::detector::transport::udp::UdpTransport
• swim::dissemination::entry::PendingUpdate
• swim::dissemination::queue::DisseminationQueue
• swim::incarnation::Incarnation
• swim::member::record::Member
• swim::member::record::MemberUpdate
• swim::membership::list::MembershipList
• swim::membership::list::MembershipSnapshot
• swim::wire::probe::Ack
• swim::wire::probe::Nack
• swim::wire::probe::Ping
• swim::wire::probe::PingReq
• swim::wire::probe::ProbeId
• 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
• lifecycle_state::ClusterLifecycleState
• metadata_group::descriptors::common::DescriptorKind
• metadata_group::entry::MetadataEntry
• metadata_group::entry::RoutingChange
• metadata_group::entry::TopologyChange
• metadata_group::state::DescriptorState
• migration::MigrationPhase
• rdma_transport::RdmaState
• rebalance_scheduler::RebalanceTrigger
• rpc_codec::execute::ArchivedTypedClusterError
• rpc_codec::execute::TypedClusterError
• rpc_codec::execute::TypedClusterErrorResolver
• rpc_codec::raft_rpc::RaftRpc
• shard_split::SplitStrategy
• swim::detector::probe_round::ProbeOutcome
• swim::error::SwimError
• swim::member::state::MemberState
• swim::membership::merge::MergeOutcome
• swim::wire::message::SwimMessage
• swim::wire::probe::NackReason
• topology::NodeState
• vshard_handler::DispatchTarget
• vshard_handler::HandleResult
• wire::VShardMessageType

Traits

• cluster_info::GroupStatusProvider
• forward::PlanExecutor
• metadata_group::applier::MetadataApplier
• raft_loop::loop_core::CommitApplier
• swim::detector::transport::Transport
• transport::server::RaftRpcHandler
• vshard_handler::VShardHandler

Functions

• bootstrap::handle_join::handle_join_request
• bootstrap::start::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::broadcast_topology
• health::handle_ping
• health::handle_topology_update
• lifecycle::handle_learner_promotion
• lifecycle::handle_node_join
• lifecycle::is_safe_to_remove
• lifecycle::plan_decommission
• metadata_group::codec::decode_entry
• metadata_group::codec::encode_entry
• readiness::notify_ready
• readiness::notify_status
• readiness::notify_stopping
• rebalance::compute_plan
• rebalance::plan_to_requests
• rebalance::should_rebalance
• rebalance_scheduler::plan_hot_split
• routing::fnv1a_hash
• routing::vshard_for_collection
• rpc_codec::header::frame_size
• rpc_codec::header::parse_frame
• rpc_codec::header::write_frame
• rpc_codec::raft_rpc::decode
• rpc_codec::raft_rpc::encode
• rpc_codec::raft_rpc::frame_size
• shard_split::plan_graph_split
• shard_split::plan_vector_split
• shard_split::speculative_prefetch_shards
• swim::bootstrap::spawn
• swim::dissemination::apply::apply_and_disseminate
• swim::membership::merge::merge_update
• swim::wire::codec::decode
• swim::wire::codec::encode
• 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::loop_core::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::cluster_mgmt::LEADER_REDIRECT_PREFIX
• rpc_codec::discriminants::RPC_APPEND_ENTRIES_REQ
• rpc_codec::discriminants::RPC_APPEND_ENTRIES_RESP
• rpc_codec::discriminants::RPC_EXECUTE_REQ
• rpc_codec::discriminants::RPC_EXECUTE_RESP
• rpc_codec::discriminants::RPC_FORWARD_REQ
• rpc_codec::discriminants::RPC_FORWARD_RESP
• rpc_codec::discriminants::RPC_INSTALL_SNAPSHOT_REQ
• rpc_codec::discriminants::RPC_INSTALL_SNAPSHOT_RESP
• rpc_codec::discriminants::RPC_JOIN_REQ
• rpc_codec::discriminants::RPC_JOIN_RESP
• rpc_codec::discriminants::RPC_METADATA_PROPOSE_REQ
• rpc_codec::discriminants::RPC_METADATA_PROPOSE_RESP
• rpc_codec::discriminants::RPC_PING
• rpc_codec::discriminants::RPC_PONG
• rpc_codec::discriminants::RPC_REQUEST_VOTE_REQ
• rpc_codec::discriminants::RPC_REQUEST_VOTE_RESP
• rpc_codec::discriminants::RPC_TOPOLOGY_ACK
• rpc_codec::discriminants::RPC_TOPOLOGY_UPDATE
• rpc_codec::discriminants::RPC_VSHARD_ENVELOPE
• rpc_codec::execute::PLAN_DECODE_FAILED
• rpc_codec::header::HEADER_SIZE
• rpc_codec::header::MAX_RPC_PAYLOAD_SIZE
• swim::detector::transport::udp::RECV_BUF_BYTES
• topology::CLUSTER_WIRE_FORMAT_VERSION
• transport::config::ALPN_NODEDB_RAFT
• transport::config::DEFAULT_RPC_TIMEOUT
• transport::config::SNI_HOSTNAME
• wire::WIRE_VERSION