List of all items

Structs

• bootstrap::config::ClusterConfig
• bootstrap::config::ClusterState
• bootstrap::config::JoinRetryPolicy
• bootstrap_listener::protocol::BootstrapCredsRequest
• bootstrap_listener::protocol::BootstrapCredsResponse
• catalog::core::ClusterCatalog
• circuit_breaker::BreakerSnapshot
• circuit_breaker::CircuitBreaker
• circuit_breaker::CircuitBreakerConfig
• circuit_breaker::RetryPolicy
• closed_timestamp::ClosedTimestampTracker
• 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
• decommission::coordinator::DecommissionCoordinator
• decommission::coordinator::DecommissionRunResult
• decommission::flow::DecommissionPlan
• decommission::observer::DecommissionObserver
• 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
• follower_read::FollowerReadGate
• forward::NoopPlanExecutor
• ghost::GhostStub
• ghost::GhostTable
• ghost::SweepReport
• ghost_sweeper::GhostSweeperConfig
• health::HealthConfig
• health::HealthMonitor
• lifecycle::DecommissionResult
• lifecycle_state::ClusterLifecycleTracker
• loop_metrics::LoopMetrics
• loop_metrics::LoopMetricsRegistry
• 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
• reachability::driver::ReachabilityDriver
• reachability::driver::ReachabilityDriverConfig
• reachability::prober::NoopProber
• reachability::prober::TransportProber
• rebalance::PlannedMove
• rebalance::RebalancePlan
• rebalance_scheduler::NodeMetrics
• rebalance_scheduler::RebalanceScheduler
• rebalance_scheduler::SchedulerConfig
• rebalancer::driver::AlwaysReadyGate
• rebalancer::driver::RebalancerLoop
• rebalancer::driver::RebalancerLoopConfig
• rebalancer::elastic::RebalancerKickHook
• rebalancer::metrics::LoadMetrics
• rebalancer::metrics::LoadWeights
• rebalancer::plan::RebalancerPlanConfig
• routing::GroupInfo
• routing::RoutingTable
• routing_liveness::RoutingLivenessHook
• rpc_codec::auth_envelope::EnvelopeFields
• 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::mac::MacKey
• rpc_codec::metadata::ArchivedMetadataProposeRequest
• rpc_codec::metadata::ArchivedMetadataProposeResponse
• rpc_codec::metadata::MetadataProposeRequest
• rpc_codec::metadata::MetadataProposeRequestResolver
• rpc_codec::metadata::MetadataProposeResponse
• rpc_codec::metadata::MetadataProposeResponseResolver
• rpc_codec::peer_seq::PeerSeqSender
• rpc_codec::peer_seq::PeerSeqWindow
• 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::authenticated::SwimAuth
• 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::auth_context::AuthContext
• transport::client::transport::NexarTransport
• transport::client::transport::TransportPeerSnapshot
• transport::config::TlsCredentials
• transport::pki_types::CertificateDer
• transport::pki_types::CertificateRevocationListDer
• transport::pki_types::PrivatePkcs8KeyDer
• transport::pki_types::UnixTime
• wire::VShardEnvelope

Enums

• bootstrap_listener::client::FetchError
• circuit_breaker::CircuitState
• conf_change::ConfChangeType
• cross_shard_txn::EdgeValidationResult
• cross_shard_txn::GsiAction
• decommission::safety::DecommissionSafetyError
• distributed_document::merge_sort::SortDirection
• distributed_join::JoinSide
• distributed_join::JoinStrategy
• distributed_spatial::geofence::GeofenceEventType
• error::ClusterError
• follower_read::ReadLevel
• 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
• transport::credentials::TransportCredentials
• transport::pki_types::PrivateKeyDer
• vshard_handler::DispatchTarget
• vshard_handler::HandleResult
• wire::VShardMessageType

Traits

• bootstrap_listener::server::BootstrapHandler
• cluster_info::GroupStatusProvider
• decommission::coordinator::MetadataProposer
• forward::PlanExecutor
• metadata_group::applier::MetadataApplier
• raft_loop::loop_core::CommitApplier
• reachability::prober::ReachabilityProber
• rebalancer::driver::ElectionGate
• rebalancer::driver::MigrationDispatcher
• rebalancer::metrics::LoadMetricsProvider
• swim::detector::transport::Transport
• swim::subscriber::MembershipSubscriber
• transport::server::RaftRpcHandler
• vshard_handler::VShardHandler

Functions

• bootstrap::handle_join::handle_join_request
• bootstrap::start::start_cluster
• bootstrap_listener::client::fetch_creds
• bootstrap_listener::server::spawn_listener
• decommission::flow::plan_full_decommission
• decommission::safety::check_can_decommission
• 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
• rebalancer::metrics::normalized_score
• rebalancer::plan::compute_load_based_plan
• routing::fnv1a_hash
• routing::vshard_for_collection
• rpc_codec::auth_envelope::parse_envelope
• rpc_codec::auth_envelope::write_envelope
• rpc_codec::header::frame_size
• rpc_codec::header::parse_frame
• rpc_codec::header::write_frame
• rpc_codec::mac::compute_hmac
• rpc_codec::mac::verify_hmac
• 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::bootstrap::spawn_with_subscribers
• swim::dissemination::apply::apply_and_disseminate
• swim::membership::merge::merge_update
• swim::wire::authenticated::addr_hash
• swim::wire::authenticated::unwrap
• swim::wire::authenticated::wrap
• swim::wire::codec::decode
• swim::wire::codec::encode
• transport::config::ca_fingerprint
• transport::config::ca_fingerprint_hex
• transport::config::generate_node_credentials
• transport::config::generate_node_credentials_multi_san
• transport::config::issue_leaf_for_sans
• transport::config::load_crls_from_pem
• transport::config::make_raft_client_config_mtls
• transport::config::make_raft_server_config_mtls
• transport::config::raft_transport_config
• transport::credentials::insecure_transport_count
• 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
• routing_liveness::NodeIdResolver

Constants

• bootstrap_listener::protocol::MAX_FRAME_BYTES
• 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::auth_envelope::ENVELOPE_OVERHEAD
• rpc_codec::auth_envelope::ENVELOPE_VERSION
• 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
• rpc_codec::mac::MAC_LEN
• rpc_codec::peer_seq::REPLAY_WINDOW
• 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