List of all items

Structs

• admin::cluster_info::ClusterInfoSnapshot
• admin::cluster_info::RecentEvent
• admin::cluster_info::RecentEvents
• admin::cluster_info::RowSection
• admin::cluster_info::Section
• cluster::admin_rpc::ClusterChange
• cluster::admin_rpc::JoinPlan
• cluster::admin_rpc::NoopClusterAdmin
• cluster::admin_rpc::PeerSnapshot
• cluster::admin_rpc::PeerSpec
• cluster::admin_rpc::PoolClusterAdmin
• cluster::apl::AnnotatedPeer
• cluster::apl::ClusterState
• cluster::apl::RingPoint
• cluster::capability::AaeTreeFormat
• cluster::capability::CapabilityAd
• cluster::capability::CapabilityAdEntry
• cluster::capability::CapabilityRegistry
• cluster::capability::CrdtObjectFormat
• cluster::capability::DnodeFramingVersion
• cluster::capability::GossipPhiNegotiable
• cluster::capability::NegotiatedCapabilities
• cluster::datacenter::Continuum
• cluster::datacenter::Datacenter
• cluster::datacenter::Rack
• cluster::dispatch::ClusterDispatcher
• cluster::dispatch::ReplicaTarget
• cluster::failure_detector::PhiAccrual
• cluster::gossip::GossipConfig
• cluster::gossip::GossipHandler
• cluster::gossip::GossipNode
• cluster::gossip::GossipState
• cluster::gossip::SeedRecord
• cluster::hints::Hint
• cluster::hints::HintStore
• cluster::hints::HintStoreStats
• cluster::peer::Peer
• cluster::peer::PeerEndpoint
• cluster::pool::BucketType
• cluster::pool::PoolConfig
• cluster::pool::ServerPool
• cluster::vnode::PeerTokens
• conf::ConfBucketType
• conf::ConfDynSeed
• conf::ConfListen
• conf::ConfPool
• conf::ConfRiak
• conf::ConfRiakWasmModule
• conf::ConfServer
• conf::ConfTlsProfile
• conf::Config
• conf::ObservabilityConfig
• conf::Servers
• conf::TokenComponent
• conf::TokenList
• core::log::LogConfig
• core::log::LogFormatParseError
• core::log::ReopenHandle
• core::ring_queue::RingChannels
• core::signal::SignalEntry
• core::task::TaskHandle
• crypto::Crypto
• embed::builder::ServerBuilder
• embed::events::EventBus
• embed::events::EventStream
• embed::hooks::LoggingMetricsSink
• embed::hooks::MemcacheDatastore
• embed::hooks::MemoryDatastore
• embed::hooks::RedisDatastore
• embed::hooks::RustCryptoProvider
• embed::hooks::SimpleSeedsProvider
• embed::server::Server
• embed::server::ServerHandle
• embed::server::ServerHooks
• embed::snapshots::DatacenterSnapshot
• embed::snapshots::PeerSnapshot
• embed::snapshots::RackSnapshot
• embed::snapshots::RingSnapshot
• entropy::EntropyConfig
• entropy::NegotiationHeader
• entropy::SnapshotHeader
• entropy::driver::EntropyDriver
• entropy::driver::ReconCycle
• entropy::receive::EntropyReceiver
• entropy::receive::MemorySink
• entropy::receive::RedisReplaySink
• entropy::send::EntropySender
• entropy::send::RedisLocalSnapshot
• entropy::send::StaticSnapshot
• entropy::util::EntropyIv
• entropy::util::EntropyKey
• entropy::util::EntropyMaterial
• events::EventManager
• events::Subscriber
• events::TokenRange
• hashkit::PseudoRng
• hashkit::ketama::Continuum
• hashkit::ketama::ContinuumPoint
• hashkit::ketama::ServerSpec
• hashkit::modula::Continuum
• hashkit::modula::ServerSpec
• hashkit::modula::Slot
• hashkit::random_slicing::RandomSlices
• hashkit::token::DynToken
• io::cbuf::CBuf
• io::mbuf::Mbuf
• io::mbuf::MbufPool
• io::mbuf::MbufQueue
• io::reactor::TcpTransport
• msg::index::MsgIndex
• msg::keypos::ArgPos
• msg::keypos::KeyPos
• msg::message::Msg
• msg::message::MsgFlags
• msg::queue::MsgQueue
• msg::response_mgr::ResponseMgr
• net::auto_eject::AutoEject
• net::client::ClientHandler
• net::conn::Conn
• net::conn::ConnHandle
• net::conn::ConnStats
• net::dispatcher::NoopDispatcher
• net::dispatcher::OutboundEnvelope
• net::dnode_proxy::DnodeProxy
• net::dnode_server::DnodeServerConn
• net::listener::BindOptions
• net::pool::ConnHandle
• net::pool::ConnPool
• net::pool::ConnPoolConfig
• net::proxy::Proxy
• net::server::OutboundRequest
• net::server::ServerConn
• net::tls::SharedTlsProfiles
• net::tls::TlsClientTransport
• net::tls::TlsProfileMap
• net::tls::TlsProfileSpec
• net::tls::TlsServerTransport
• proto::dnode::Dmsg
• proto::dnode::DnodeParser
• proto::dnode::Handshake
• proto::memcache::fragment::FragmentOutcome
• proto::memcache::parser::HashTag
• proto::redis::coalesce::CoalesceTracker
• proto::redis::commands::CommandTraits
• proto::redis::fragment::FragmentOutcome
• proto::redis::parser::HashTag
• runtime::Sidejob
• runtime::Throttle
• seeds::dns::DnsSeedsProvider
• seeds::florida::FloridaSeedsProvider
• seeds::simple::SimpleSeedsProvider
• stats::Aggregator
• stats::FailureMetrics
• stats::FailureSnapshot
• stats::Histogram
• stats::HistogramSummary
• stats::MetricSpec
• stats::NoTargetsEntry
• stats::PeerEntry
• stats::PeerStateEntry
• stats::PeerStats
• stats::PhiEntry
• stats::PoolStats
• stats::ServerStats
• stats::ServiceInfo
• stats::Snapshot
• stats::Stats
• stats::StatsServer
• stats::TimeoutEntry
• stats::TransitionEntry
• util::dict::DictMap
• util::rbtree::OrderedMap

Enums

• cluster::admin_rpc::ClusterChangeKind
• cluster::admin_rpc::ClusterError
• cluster::apl::NodeRole
• cluster::capability::CapabilityCodecError
• cluster::coverage::TokenCoverageError
• cluster::datacenter::RackRing
• cluster::dispatch::DispatchPlan
• cluster::gossip::GossipStep
• cluster::hints::HintStoreError
• cluster::peer::PeerState
• cluster::snitch::RackDistance
• conf::ConfError
• conf::ConsistencyLevel
• conf::DataStore
• conf::Distribution
• conf::EndpointKind
• conf::HashType
• conf::SecureServerOption
• core::log::LogFormat
• core::signal::SignalAction
• core::types::DynError
• core::types::SecureServerOption
• crypto::CryptoError
• embed::error::EmbedError
• embed::events::CloseReason
• embed::events::ConnRoleTag
• embed::events::PeerDownReason
• embed::events::ServerEvent
• embed::extension::HsetOutcome
• embed::hooks::CryptoProviderError
• embed::hooks::DatastoreError
• embed::hooks::MetricsError
• embed::hooks::Protocol
• entropy::EntropyError
• events::ClusterEvent
• events::SubscriberError
• events::TryRecvError
• hashkit::HashType
• hashkit::random_slicing::RandomSlicesError
• hashkit::token::Sign
• io::reactor::ConnRole
• msg::ConsistencyLevel
• msg::DynErrorCode
• msg::message::MsgParseResult
• msg::message::MsgRouting
• msg::msg_type::MsgType
• msg::response_mgr::QuorumOutcome
• net::NetError
• net::auto_eject::AutoEjectState
• net::client::ClientLoopOutcome
• net::dispatcher::DispatchOutcome
• net::tls::TlsError
• proto::dnode::DmsgDispatch
• proto::dnode::DmsgType
• proto::dnode::DnodeError
• proto::dnode::DynParseState
• proto::dnode::ParseStep
• proto::memcache::fragment::FragmentError
• proto::memcache::parser::ReqState
• proto::memcache::parser::RspState
• proto::memcache::repair::ReconcileOutcome
• proto::memcache::repair::RepairError
• proto::memcache::repair::RepairOutcome
• proto::memcache::verify::VerifyError
• proto::redis::coalesce::CoalesceOutcome
• proto::redis::commands::CommandClass
• proto::redis::commands::RoutingOverride
• proto::redis::fragment::FragmentError
• proto::redis::repair::RepairError
• proto::redis::repair::RepairOutcome
• proto::redis::repair::reconcile::ReconcileOutcome
• proto::redis::verify::VerifyError
• runtime::SidejobError
• runtime::ThrottleError
• seeds::SeedsError
• seeds::dns::ResolvedSeeds
• stats::Latency
• stats::PoolField
• stats::QueueGauge
• stats::QueueWait
• stats::ServerField
• stats::StatsMetricType
• util::sockinfo::SockInfo

Traits

• cluster::admin_rpc::ClusterAdmin
• cluster::capability::Capability
• embed::extension::CommandExtension
• embed::hooks::CryptoProvider
• embed::hooks::Datastore
• embed::hooks::MetricsSink
• embed::hooks::SeedsProvider
• entropy::SnapshotSink
• entropy::SnapshotSource
• io::reactor::Transport
• net::dispatcher::Dispatcher
• net::pool::ConnFactory
• proto::memcache::fragment::FragmentDispatcher
• proto::redis::fragment::FragmentDispatcher
• seeds::SeedsProvider
• seeds::dns::Resolver

Functions

• admin::cluster_info::build_git_sha
• admin::cluster_info::build_profile
• admin::cluster_info::build_section
• admin::cluster_info::build_version
• admin::cluster_info::config_section
• admin::cluster_info::fds_section
• admin::cluster_info::format_text
• admin::cluster_info::gather_from_handle
• admin::cluster_info::gossip_section
• admin::cluster_info::is_secret_config_field
• admin::cluster_info::memory_section
• admin::cluster_info::peer_row
• admin::cluster_info::queues_section
• admin::cluster_info::recent_events_section
• admin::cluster_info::render_timestamp
• admin::cluster_info::ring_section
• cluster::apl::fallbacks
• cluster::apl::get_apl_ann
• cluster::apl::primaries
• cluster::apl::walk_n_successors
• cluster::capability::default_registry
• cluster::coverage::validate_token_coverage
• cluster::dispatch::distribution_shadow_disagreement_total
• cluster::dispatch::reset_distribution_shadow_disagreement_total
• cluster::gossip::parse_seed_blob
• cluster::gossip::parse_seed_node
• cluster::snitch::broadcast_address
• cluster::snitch::is_aws_env
• cluster::snitch::pick_target_rack
• cluster::snitch::private_ip4
• cluster::snitch::process_env_lookup
• cluster::snitch::public_hostname
• cluster::snitch::public_ip4
• cluster::snitch::rack_distance
• cluster::vnode::dispatch
• cluster::vnode::rebuild_continuums
• conf::is_noxu_supported
• conf::set_noxu_supported
• core::log::build_env_filter
• core::log::build_logs_layer
• core::log::clamp_level
• core::log::current_level
• core::log::install_logs_only
• core::log::local_hostname
• core::log::log_init
• core::log::log_init_with_format
• core::log::log_level_decrement
• core::log::log_level_increment
• core::log::log_level_set
• core::log::log_loggable
• core::log::reopen_on_sighup
• core::log::tracing_level_for
• core::log::write_error_count
• core::setting::msgs_per_sec
• core::setting::set_msgs_per_sec
• core::signal::action_for
• core::signal::default_actions
• core::signal::dispatch
• core::signal::handle
• core::task::task_register
• core::task::task_schedule_once
• crypto::aes::decrypt_chain_to_chain
• crypto::aes::decrypt_to_vec
• crypto::aes::encrypt_to_chain
• crypto::aes::encrypt_to_vec
• crypto::base64::base64_decode
• crypto::base64::base64_encode
• crypto::pem::load_rsa_private_key
• crypto::pem::load_rsa_private_key_from_bytes
• crypto::rsa::decrypt
• crypto::rsa::encrypt
• entropy::boxed_sink
• entropy::boxed_source
• entropy::driver::reconcile_with_peer
• entropy::receive::decrypt_chunk
• entropy::send::encrypt_chunk
• entropy::util::load_iv_file
• entropy::util::load_key_file
• entropy::util::load_material
• hashkit::crc32_sz
• hashkit::hash
• hashkit::hash64
• hashkit::md5_signature
• hashkit::murmur3_x64_64
• hashkit::token::parse_token
• msg::is_read_repairs_enabled
• msg::request::is_done
• msg::request::is_error
• msg::request::move_completed
• msg::request::set_error
• msg::response::link
• msg::response::make_error
• msg::response::make_simple_redis
• msg::set_read_repairs_enabled
• net::client::client_loop
• net::dnode_client::dnode_client_loop
• net::listener::bind_dual_stack
• net::tls::acceptor_from
• net::tls::connector_from
• net::tls::dc_sni_hostname
• net::tls::load_client_config
• net::tls::load_server_config
• net::tls::server_name_owned
• proto::dnode::dmsg_process
• proto::dnode::dmsg_write
• proto::dnode::dmsg_write_mbuf
• proto::dnode::flatten_chain
• proto::dnode::parse_req
• proto::dnode::parse_rsp
• proto::memcache::coalesce::memcache_post_coalesce
• proto::memcache::coalesce::memcache_pre_coalesce
• proto::memcache::commands::memcache_arithmetic
• proto::memcache::commands::memcache_cas
• proto::memcache::commands::memcache_delete
• proto::memcache::commands::memcache_retrieval
• proto::memcache::commands::memcache_storage
• proto::memcache::commands::memcache_touch
• proto::memcache::fragment::memcache_fragment
• proto::memcache::multikey::memcache_is_multikey_request
• proto::memcache::parser::memcache_parse_req
• proto::memcache::parser::memcache_parse_req_tagged
• proto::memcache::parser::memcache_parse_rsp
• proto::memcache::repair::memcache_clear_repair_md_for_key
• proto::memcache::repair::memcache_make_repair_query
• proto::memcache::repair::memcache_reconcile_responses
• proto::memcache::repair::memcache_rewrite_query
• proto::memcache::repair::memcache_rewrite_query_with_timestamp_md
• proto::memcache::verify::memcache_verify_request
• proto::redis::bucket::bucket_name
• proto::redis::coalesce::accumulate_fragment_integer
• proto::redis::coalesce::redis_post_coalesce
• proto::redis::coalesce::redis_pre_coalesce
• proto::redis::commands::classify
• proto::redis::commands::error_lookup
• proto::redis::commands::is_redis_error
• proto::redis::commands::lookup
• proto::redis::fragment::redis_fragment
• proto::redis::multikey::redis_is_multikey_request
• proto::redis::parser::redis_parse_req
• proto::redis::parser::redis_parse_req_with_args
• proto::redis::parser::redis_parse_rsp
• proto::redis::repair::clear::redis_clear_repair_md_for_key
• proto::redis::repair::make::is_repairable
• proto::redis::repair::make::redis_make_repair_query
• proto::redis::repair::reconcile::is_foldable_multikey_response
• proto::redis::repair::reconcile::redis_reconcile_responses
• proto::redis::repair::rewrite::redis_rewrite_query
• proto::redis::repair::rewrite::redis_rewrite_query_with_timestamp_md
• proto::redis::verify::redis_verify_request
• stats::describe_stats
• stats::render_prometheus
• util::atoi::dn_atoi
• util::atoi::dn_atoui
• util::atoi::valid_port
• util::dyn_string::eq_ignore_ascii_case
• util::dyn_string::strchr
• util::dyn_string::string_compare
• util::dyn_string::strrchr
• util::time::count_digits
• util::time::msec_now
• util::time::usec_now

Type Aliases

• cluster::apl::VnodeId
• core::log::LogsLayer
• core::types::Msec
• core::types::MsgId
• core::types::Sec
• core::types::Status
• core::types::Usec
• embed::events::ConnId
• embed::events::PeerId
• embed::hooks::BoxFuture
• embed::hooks::DatastoreByteStream
• embed::hooks::DnsSeedsProvider
• embed::hooks::FloridaSeedsProvider
• entropy::BoxedSnapshotSink
• entropy::BoxedSnapshotSource
• entropy::EntropyResult
• events::PeerId
• io::mbuf::OwnerId
• msg::message::ConnId
• net::dispatcher::ServerSink
• net::dnode_client::DnodeClientHandler
• net::pool::ConnFuture
• stats::ClusterInfoProvider
• util::dict::MsgIndex

Constants

• admin::cluster_info::MAX_RECENT_EVENTS
• cluster::capability::CAP_AAE_TREE_FORMAT
• cluster::capability::CAP_CRDT_OBJECT_FORMAT
• cluster::capability::CAP_DNODE_FRAMING_VERSION
• cluster::capability::CAP_GOSSIP_PHI_NEGOTIABLE
• cluster::failure_detector::DEFAULT_MIN_MEAN_MS
• cluster::failure_detector::DEFAULT_THRESHOLD
• cluster::failure_detector::DEFAULT_WINDOW_SIZE
• cluster::gossip::DEFAULT_GOSSIP_INTERVAL_MS
• cluster::gossip::DEFAULT_SEEDS_CHECK_INTERVAL_MS
• cluster::snitch::DEFAULT_ENV
• core::log::LOG_ALERT
• core::log::LOG_CRIT
• core::log::LOG_DEBUG
• core::log::LOG_EMERG
• core::log::LOG_ERR
• core::log::LOG_INFO
• core::log::LOG_LEVEL_MAX
• core::log::LOG_NOTICE
• core::log::LOG_PVERB
• core::log::LOG_VERB
• core::log::LOG_VVERB
• core::log::LOG_VVVERB
• core::log::LOG_WARN
• core::ring_queue::C2G_IN_CAPACITY
• core::ring_queue::C2G_OUT_CAPACITY
• core::setting::DEFAULT_MSGS_PER_SEC
• crypto::aes::AES_128_KEY_LEN
• crypto::aes::AES_BLOCK_SIZE
• crypto::aes::AES_KEYLEN
• entropy::DEFAULT_BUFFER_SIZE
• entropy::DEFAULT_CIPHER_SIZE
• entropy::DEFAULT_HEADER_SIZE
• entropy::ENTROPY_COMMAND_SEND
• entropy::ENTROPY_MAGIC
• entropy::MAX_BUFFER_SIZE
• entropy::MAX_CIPHER_SIZE
• entropy::MAX_HEADER_SIZE
• entropy::MAX_SNAPSHOT_SIZE
• entropy::SAFE_PREALLOC
• entropy::driver::DEFAULT_ENTROPY_PORT
• entropy::driver::DEFAULT_RECON_INTERVAL
• entropy::util::ENTROPY_IV_LEN
• entropy::util::ENTROPY_KEY_LEN
• hashkit::ketama::MAX_HOSTLEN
• hashkit::ketama::POINTS_PER_HASH
• hashkit::ketama::POINTS_PER_SERVER
• hashkit::token::TOKEN_WORD_CAPACITY
• io::mbuf::MBUF_ESIZE
• io::mbuf::MBUF_FLAG_JUST_DECRYPTED
• io::mbuf::MBUF_FLAG_READ_FLIP
• io::mbuf::MBUF_MAX_SIZE
• io::mbuf::MBUF_MIN_SIZE
• io::mbuf::MBUF_POOL_MAX_FREE
• io::mbuf::MBUF_SIZE
• msg::response_mgr::MAX_REPLICAS_PER_DC
• net::conn::MAX_CONN_QUEUE_SIZE
• proto::dnode::CRLF
• proto::dnode::DMSG_FLAG_COMPRESSED
• proto::dnode::DMSG_FLAG_ENCRYPTED
• proto::dnode::GOSSIP_PLACEHOLDER_DATA
• proto::dnode::HANDSHAKE_PLACEHOLDER_DATA
• proto::dnode::MAGIC
• proto::dnode::VERSION_10
• proto::memcache::parser::MEMCACHE_MAX_KEY_LENGTH
• proto::redis::repair::scripts::ADD_SET_STR
• proto::redis::repair::scripts::CLEANUP_DEL_SCRIPT
• proto::redis::repair::scripts::CLEANUP_HDEL_SCRIPT
• proto::redis::repair::scripts::DEL_SCRIPT
• proto::redis::repair::scripts::GET_SCRIPT
• proto::redis::repair::scripts::HDEL_SCRIPT
• proto::redis::repair::scripts::HGET_SCRIPT
• proto::redis::repair::scripts::HSET_SCRIPT
• proto::redis::repair::scripts::REM_SET_STR
• proto::redis::repair::scripts::SADD_SCRIPT
• proto::redis::repair::scripts::SET_SCRIPT
• proto::redis::repair::scripts::ZADD_SCRIPT
• proto::redis::verify::ADD_SET_STR
• proto::redis::verify::REM_SET_STR
• stats::BUCKET_COUNT
• stats::MAX_HEADERS
• stats::MAX_REQUEST_BYTES
• stats::POOL_CODEC
• stats::SERVER_CODEC