List of all items

Structs

• GhostStub
• GhostTable
• MigrationExecutor
• MigrationRequest
• MigrationResult
• MigrationSnapshot
• MigrationTracker
• applied_watcher::registry::GroupAppliedWatchers
• applied_watcher::watcher::AppliedIndexWatcher
• auth::audit::AuditEvent
• auth::audit::NoopAuditWriter
• auth::audit::VecAuditWriter
• auth::bundle::AuthenticatedJoinBundle
• auth::raft_backed_store::RaftBackedTokenStore
• auth::token_state::InMemoryTokenStore
• auth::token_state::JoinTokenState
• bootstrap::config::ClusterConfig
• bootstrap::config::ClusterState
• bootstrap::config::JoinRetryPolicy
• catalog::cluster_settings::ClusterSettings
• catalog::core::ClusterCatalog
• closed_timestamp::ClosedTimestampTracker
• cluster_info::ClusterInfoSnapshot
• cluster_info::ClusterObserver
• cluster_info::GroupSnapshot
• cluster_info::PeerSnapshot
• conf_change::ConfChange
• cross_shard_txn::EdgeValidationRequest
• cross_shard_txn::GsiForwardEntry
• decommission::coordinator::DecommissionCoordinator
• decommission::coordinator::DecommissionRunResult
• decommission::flow::DecommissionPlan
• decommission::observer::DecommissionObserver
• distributed_array::coordinator::read::ArrayCoordParams
• distributed_array::coordinator::read::ArrayCoordinator
• distributed_array::coordinator::read::CoordSliceResult
• distributed_array::coordinator::write::ArrayWriteCoordParams
• distributed_array::merge::ArrayAggPartial
• distributed_array::partition::DeleteBucket
• distributed_array::partition::PutBucket
• distributed_array::scatter::FanOutParams
• distributed_array::scatter::FanOutPartitionedParams
• distributed_array::wire::ArrayShardAggReq
• distributed_array::wire::ArrayShardAggResp
• distributed_array::wire::ArrayShardDeleteReq
• distributed_array::wire::ArrayShardDeleteResp
• distributed_array::wire::ArrayShardPutReq
• distributed_array::wire::ArrayShardPutResp
• distributed_array::wire::ArrayShardSliceReq
• distributed_array::wire::ArrayShardSliceResp
• distributed_array::wire::ArrayShardSurrogateBitmapReq
• distributed_array::wire::ArrayShardSurrogateBitmapResp
• 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
• distributed_vector::seam::MemoryRegion
• distributed_vector::seam::ShardMessage
• distributed_vector::seam::ShardMessageReply
• distributed_vector::seam::ShardRef
• follower_read::FollowerReadGate
• forward::NoopPlanExecutor
• health::HealthConfig
• health::HealthMonitor
• install_snapshot::sender::SendChunkedParams
• install_snapshot::state::PartialSnapshotState
• 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
• metadata_group::migration_state::MigrationStateTable
• metadata_group::migration_state::PersistedMigrationCheckpoint
• migration::MigrationState
• mirror::bootstrap::CrossClusterSnapshotEnvelope
• mirror::bootstrap::MirrorBootstrapReceiver
• mirror::handshake::MirrorHello
• mirror::handshake::MirrorHelloAck
• mirror::link::CrossClusterLink
• mirror::source_handler::HandshakeOutcome
• mirror::source_handler::SourceHandlerParams
• mirror::throttle::SendThrottle
• multi_raft::core::GroupStatus
• multi_raft::core::LogEntry
• 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::data_propose::ArchivedDataProposeRequest
• rpc_codec::data_propose::ArchivedDataProposeResponse
• rpc_codec::data_propose::DataProposeRequest
• rpc_codec::data_propose::DataProposeRequestResolver
• rpc_codec::data_propose::DataProposeResponse
• rpc_codec::data_propose::DataProposeResponseResolver
• 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
• subsystem::context::BootstrapCtx
• subsystem::health::ClusterHealth
• subsystem::impls::adapters::migration_dispatcher::ExecutorDispatcher
• subsystem::impls::adapters::multiraft_election_gate::MultiRaftElectionGate
• subsystem::impls::adapters::transport_metrics_provider::NexarTransportMetricsProvider
• subsystem::impls::decommission_subsystem::DecommissionSubsystem
• subsystem::impls::reachability_subsystem::ReachabilitySubsystem
• subsystem::impls::rebalancer_subsystem::RebalancerSubsystem
• subsystem::impls::swim_subsystem::SwimSubsystem
• subsystem::impls::swim_subsystem::SwimSubsystemConfig
• subsystem::registry::RunningCluster
• subsystem::registry::SubsystemRegistry
• subsystem::trait::SubsystemHandle
• 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::pinned_verifier::PinnedClientVerifier
• transport::pinned_verifier::PinnedServerVerifier
• transport::pki_types::CertificateDer
• transport::pki_types::CertificateRevocationListDer
• transport::pki_types::PrivatePkcs8KeyDer
• transport::pki_types::UnixTime
• transport::server::NoopIdentityStore
• wire::VShardEnvelope
• wire_version::envelope::Versioned
• wire_version::metrics::WireVersionCounter
• wire_version::metrics::WireVersionMetrics
• wire_version::negotiation::VersionHandshake
• wire_version::negotiation::VersionHandshakeAck
• wire_version::negotiation::VersionRange
• wire_version::types::WireVersion

Enums

• applied_watcher::watcher::WaitOutcome
• auth::audit::JoinOutcome
• auth::bundle::BundleError
• auth::join_token::TokenError
• auth::token_state::JoinTokenLifecycle
• auth::token_state::TokenStateError
• catalog::cluster_settings::PlacementHashId
• 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
• distributed_vector::seam::ShardMessageKind
• distributed_vector::seam::ShardSubset
• distributed_vector::seam::VectorSeamError
• error::CalvinError
• error::ClusterError
• error::MigrationCheckpointError
• error::MigrationRecoveryError
• follower_read::ReadLevel
• install_snapshot::receiver::ChunkOutcome
• lifecycle_state::ClusterLifecycleState
• metadata_group::compensation::Compensation
• metadata_group::descriptors::common::DescriptorKind
• metadata_group::entry::JoinTokenTransitionKind
• metadata_group::entry::MetadataEntry
• metadata_group::entry::RoutingChange
• metadata_group::entry::TopologyChange
• metadata_group::migration_recovery::RecoveryDecision
• metadata_group::migration_state::MigrationCheckpointPayload
• metadata_group::migration_state::MigrationPhaseTag
• metadata_group::state::DescriptorState
• migration::MigrationPhase
• mirror::bootstrap::BootstrapChunkOutcome
• mirror::error::MirrorError
• 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
• subsystem::errors::BootstrapError
• subsystem::errors::ShutdownError
• subsystem::errors::TopoError
• subsystem::health::SubsystemHealth
• 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::peer_identity_verifier::VerifyMethod
• transport::peer_identity_verifier::VerifyOutcome
• transport::pki_types::PrivateKeyDer
• vshard_handler::DispatchTarget
• vshard_handler::HandleResult
• wire::VShardMessageType
• wire_version::error::WireVersionError

Traits

• auth::audit::AuditWriter
• auth::token_state::TokenStateBackend
• cluster_info::GroupStatusProvider
• decommission::coordinator::MetadataProposer
• distributed_array::local_executor::ArrayLocalExecutor
• distributed_array::rpc::ShardRpcDispatch
• distributed_vector::seam::VectorShardSeam
• forward::PlanExecutor
• metadata_group::applier::MetadataApplier
• raft_loop::loop_core::CommitApplier
• raft_loop::loop_core::SnapshotQuarantineHook
• reachability::prober::ReachabilityProber
• rebalancer::driver::ElectionGate
• rebalancer::driver::MigrationDispatcher
• rebalancer::metrics::LoadMetricsProvider
• subsystem::trait::ClusterSubsystem
• swim::detector::transport::Transport
• swim::subscriber::MembershipSubscriber
• transport::server::PeerIdentityStore
• transport::server::RaftRpcHandler
• vshard_handler::VShardHandler

Functions

• array_routing::array_vshard_for_name
• array_routing::tile_id_of_coord
• array_routing::vshard_for_array_coord
• array_routing::vshard_for_array_tile
• auth::bundle::derive_mac_key
• auth::bundle::open_bundle
• auth::bundle::seal_bundle
• auth::join_token::issue_token
• auth::join_token::issue_token_bytes
• auth::join_token::token_hash
• auth::join_token::token_to_hex
• auth::join_token::verify_token
• auth::raft_backed_store::apply_token_transition_to_mirror
• auth::token_state::spawn_inflight_timeout
• bootstrap::handle_join::handle_join_request
• bootstrap::start::register_default_subsystems
• bootstrap::start::start_cluster
• bootstrap::start::start_cluster_subsystems
• catalog::cluster_settings::placement_hash
• cluster_epoch::bump_local_cluster_epoch
• cluster_epoch::current_local_cluster_epoch
• cluster_epoch::init_local_cluster_epoch_from_catalog
• cluster_epoch::observe_peer_cluster_epoch
• cluster_epoch::set_local_cluster_epoch
• decommission::flow::plan_full_decommission
• decommission::safety::check_can_decommission
• distributed_array::coordinator::write::coord_delete
• distributed_array::coordinator::write::coord_put
• distributed_array::coordinator::write::coord_put_partitioned
• distributed_array::handler::handle_array_shard_rpc
• distributed_array::merge::any_truncated_before_horizon_agg
• distributed_array::merge::any_truncated_before_horizon_slice
• distributed_array::merge::merge_slice_rows
• distributed_array::merge::reduce_agg_partials
• distributed_array::partition::partition_delete_coords
• distributed_array::partition::partition_put_cells
• distributed_array::routing::array_vshard_for_tile
• distributed_array::routing::array_vshards_for_slice
• distributed_array::scatter::fan_out
• distributed_array::scatter::fan_out_partitioned
• 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
• health::broadcast_topology
• health::handle_ping
• health::handle_topology_update
• install_snapshot::finalize::commit
• install_snapshot::gc::sweep_orphans
• install_snapshot::receiver::handle_chunk
• install_snapshot::receiver::partial_path_for
• install_snapshot::sender::send_chunked
• lifecycle::handle_learner_promotion
• lifecycle::handle_node_join
• lifecycle::is_safe_to_remove
• lifecycle::plan_decommission
• metadata_group::cache::apply_migration_abort
• metadata_group::cache::apply_migration_checkpoint
• metadata_group::codec::decode_entry
• metadata_group::codec::encode_entry
• metadata_group::migration_recovery::compensations_for_phase
• metadata_group::migration_recovery::recover_in_flight_migrations
• metadata_group::migration_state::new_shared
• mirror::handshake::recv_ack
• mirror::handshake::recv_hello
• mirror::handshake::send_ack
• mirror::handshake::send_hello
• mirror::source_handler::handle_mirror_connection
• 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
• recover_in_flight_migrations
• routing::fnv1a_hash
• routing::partition_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
• rpc_codec::raft_rpc::versioned_decode
• rpc_codec::raft_rpc::versioned_encode
• shard_split::plan_graph_split
• shard_split::plan_vector_split
• shard_split::speculative_prefetch_shards
• subsystem::topo_sort::topo_sort
• 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
• sync_frame_versioned::decode_versioned_sync_frame
• sync_frame_versioned::encode_versioned_sync_frame
• 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
• transport::peer_identity_verifier::spiffe_id_from_cert_der
• transport::peer_identity_verifier::spki_pin_from_cert_der
• transport::peer_identity_verifier::verify_peer_identity
• vshard_handler::build_ts_retention_ack
• vshard_handler::build_ts_scatter_response
• vshard_handler::dispatch_by_type
• wire_version::envelope::decode_versioned
• wire_version::envelope::encode_versioned
• wire_version::envelope::unwrap_bytes_versioned
• wire_version::envelope::wrap_bytes_versioned
• wire_version::handshake_io::close_on_version_error
• wire_version::handshake_io::local_version_range
• wire_version::handshake_io::perform_version_handshake_client
• wire_version::handshake_io::perform_version_handshake_server
• wire_version::negotiation::negotiate

Type Aliases

• auth::token_state::SharedTokenStateMirror
• error::Result
• install_snapshot::receiver::PartialSnapshotMap
• metadata_group::migration_state::MigrationId
• metadata_group::migration_state::SharedMigrationStateTable
• mirror::bootstrap::ProgressCallback
• raft_loop::loop_core::VShardEnvelopeHandler
• routing_liveness::NodeIdResolver

Constants

• array_routing::VSHARD_COUNT
• auth::join_token::TOKEN_BYTE_LEN
• auth::join_token::TOKEN_HEADER_LEN
• auth::join_token::TOKEN_HEX_LEN
• auth::join_token::TOKEN_MAC_LEN
• conf_change::CONF_CHANGE_PREFIX
• distributed_array::opcodes::ARRAY_SHARD_AGG_REQ
• distributed_array::opcodes::ARRAY_SHARD_AGG_RESP
• distributed_array::opcodes::ARRAY_SHARD_DELETE_REQ
• distributed_array::opcodes::ARRAY_SHARD_DELETE_RESP
• distributed_array::opcodes::ARRAY_SHARD_PUT_REQ
• distributed_array::opcodes::ARRAY_SHARD_PUT_RESP
• distributed_array::opcodes::ARRAY_SHARD_SLICE_REQ
• distributed_array::opcodes::ARRAY_SHARD_SLICE_RESP
• distributed_array::opcodes::ARRAY_SHARD_SURROGATE_BITMAP_REQ
• distributed_array::opcodes::ARRAY_SHARD_SURROGATE_BITMAP_RESP
• distributed_join::DEFAULT_BROADCAST_THRESHOLD_BYTES
• health::DEFAULT_FAILURE_THRESHOLD
• health::DEFAULT_PING_INTERVAL
• metadata_group::METADATA_GROUP_ID
• metadata_group::migration_recovery::DEFAULT_ABORT_TIMEOUT
• mirror::bootstrap::PROGRESS_REPORT_CHUNK_BYTES
• mirror::handshake::MIRROR_HELLO
• mirror::handshake::MIRROR_HELLO_ACK
• mirror::handshake::MIRROR_HELLO_ERR_BAD_VERSION
• mirror::handshake::MIRROR_HELLO_ERR_CLUSTER_ID
• mirror::handshake::MIRROR_HELLO_ERR_OBSERVER_ONLY
• mirror::handshake::MIRROR_PROTOCOL_VERSION
• mirror::throttle::DEFAULT_CAP_BYTES
• 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_DATA_PROPOSE_REQ
• rpc_codec::discriminants::RPC_DATA_PROPOSE_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::discriminants::VSHARD_ARRAY_SHARD_AGG_REQ
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_AGG_RESP
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_DELETE_REQ
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_DELETE_RESP
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_PUT_REQ
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_PUT_RESP
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_SLICE_REQ
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_SLICE_RESP
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_SURROGATE_BITMAP_REQ
• rpc_codec::discriminants::VSHARD_ARRAY_SHARD_SURROGATE_BITMAP_RESP
• 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
• transport::peer_identity_verifier::IDENTITY_MISMATCH_QUIC_ERROR
• wire::WIRE_VERSION