List of all items

Structs

• bootstrap::MetasrvInstance
• cache_invalidator::MetasrvCacheInvalidator
• cluster::Context
• cluster::MetaPeerClient
• cluster::MetaPeerClientBuilder
• election::etcd::EtcdElection
• error::BatchGetSnafu
• error::BuildPartitionClientSnafu
• error::BuildWalOptionsAllocatorSnafu
• error::ChooseItemsSnafu
• error::ConnectEtcdSnafu
• error::ConvertProtoDataSnafu
• error::CreateChannelSnafu
• error::DatanodeTableNotFoundSnafu
• error::DeleteRecordSnafu
• error::DeserializeFromJsonSnafu
• error::EmptyKeySnafu
• error::EtcdFailedSnafu
• error::ExceededDeadlineSnafu
• error::ExceededRetryLimitSnafu
• error::FlowStateHandlerSnafu
• error::HandlerNotFoundSnafu
• error::InitDdlManagerSnafu
• error::InitExportMetricsTaskSnafu
• error::InitMetadataSnafu
• error::InvalidArgumentsSnafu
• error::InvalidClusterInfoFormatSnafu
• error::InvalidDatanodeStatFormatSnafu
• error::InvalidHttpBodySnafu
• error::InvalidInactiveRegionKeySnafu
• error::InvalidLeaseKeySnafu
• error::InvalidRegionKeyFromUtf8Snafu
• error::InvalidStatKeySnafu
• error::InvalidUtf8ValueSnafu
• error::InvalidateTableCacheSnafu
• error::IsNotLeaderSnafu
• error::JoinSnafu
• error::KvBackendSnafu
• error::LeaseKeyFromUtf8Snafu
• error::LeaseValueFromUtf8Snafu
• error::ListCatalogsSnafu
• error::ListSchemasSnafu
• error::ListTablesSnafu
• error::LookupPeerSnafu
• error::MailboxClosedSnafu
• error::MailboxReceiverSnafu
• error::MailboxTimeoutSnafu
• error::MaintenanceModeManagerSnafu
• error::MigrationAbortSnafu
• error::MigrationRunningSnafu
• error::MissingRequestHeaderSnafu
• error::MissingRequiredParameterSnafu
• error::NextSequenceSnafu
• error::NoEnoughAvailableNodeSnafu
• error::NoLeaderSnafu
• error::OtherSnafu
• error::ParseAddrSnafu
• error::ParseBoolSnafu
• error::ParseNumSnafu
• error::PeerUnavailableSnafu
• error::ProcedureNotFoundSnafu
• error::PublishMessageSnafu
• error::PushMessageSnafu
• error::PusherNotFoundSnafu
• error::QueryProcedureSnafu
• error::RangeSnafu
• error::RegionOpeningRaceSnafu
• error::RegionRouteNotFoundSnafu
• error::RegisterProcedureLoaderSnafu
• error::ResponseHeaderNotFoundSnafu
• error::RetryLaterSnafu
• error::RetryLaterWithSourceSnafu
• error::SaveClusterInfoSnafu
• error::SchemaAlreadyExistsSnafu
• error::SendShutdownSignalSnafu
• error::SerializeToJsonSnafu
• error::ShutdownServerSnafu
• error::StartGrpcSnafu
• error::StartHttpSnafu
• error::StartProcedureManagerSnafu
• error::StartTelemetryTaskSnafu
• error::StopProcedureManagerSnafu
• error::SubmitDdlTaskSnafu
• error::SubmitProcedureSnafu
• error::TableAlreadyExistsSnafu
• error::TableInfoNotFoundSnafu
• error::TableMetadataManagerSnafu
• error::TableNotFoundSnafu
• error::TableRouteNotFoundSnafu
• error::TcpBindSnafu
• error::TcpIncomingSnafu
• error::TomlFormatSnafu
• error::TooManyPartitionsSnafu
• error::UnexpectedInstructionReplySnafu
• error::UnexpectedLogicalRouteTableSnafu
• error::UnexpectedSnafu
• error::UnsupportedSelectorTypeSnafu
• error::UnsupportedSnafu
• error::WaitProcedureSnafu
• failure_detector::HeartbeatHistory
• failure_detector::PhiAccrualFailureDetector
• failure_detector::PhiAccrualFailureDetectorOptions
• flow_meta_alloc::FlowPeerAllocator
• greptimedb_telemetry::DistributedGreptimeDBTelemetryCollector
• handler::DefaultHeartbeatHandlerGroupBuilderCustomizer
• handler::HeartbeatAccumulator
• handler::HeartbeatHandlerGroup
• handler::HeartbeatHandlerGroupBuilder
• handler::HeartbeatMailbox
• handler::NameCachedHandler
• handler::Pusher
• handler::PusherId
• handler::Pushers
• handler::check_leader_handler::CheckLeaderHandler
• handler::collect_cluster_info_handler::CollectDatanodeClusterInfoHandler
• handler::collect_cluster_info_handler::CollectFlownodeClusterInfoHandler
• handler::collect_cluster_info_handler::CollectFrontendClusterInfoHandler
• handler::collect_leader_region_handler::CollectLeaderRegionHandler
• handler::collect_stats_handler::CollectStatsHandler
• handler::collect_stats_handler::EpochStats
• handler::extract_stat_handler::ExtractStatHandler
• handler::failure_handler::RegionFailureHandler
• handler::filter_inactive_region_stats::FilterInactiveRegionStatsHandler
• handler::flow_state_handler::FlowStateHandler
• handler::keep_lease_handler::DatanodeKeepLeaseHandler
• handler::keep_lease_handler::FlownodeKeepLeaseHandler
• handler::mailbox_handler::MailboxHandler
• handler::on_leader_start_handler::OnLeaderStartHandler
• handler::publish_heartbeat_handler::PublishHeartbeatHandler
• handler::region_lease_handler::RegionLeaseHandler
• handler::remap_flow_peer_handler::RemapFlowPeerHandler
• handler::response_header_handler::ResponseHeaderHandler
• key::DatanodeLeaseKey
• key::FlownodeLeaseKey
• key::InactiveRegionKey
• key::LeaseValue
• key::datanode::DATANODE_LEASE_KEY_PATTERN
• key::datanode::DATANODE_STAT_KEY_PATTERN
• key::datanode::DatanodeLeaseKey
• key::datanode::INACTIVE_REGION_KEY_PATTERN
• key::datanode::InactiveRegionKey
• key::flownode::FLOWNODE_LEASE_KEY_PATTERN
• key::flownode::FlownodeLeaseKey
• lease::MetaPeerLookupService
• metasrv::Context
• metasrv::LeaderValue
• metasrv::MetaStateHandler
• metasrv::Metasrv
• metasrv::MetasrvInfo
• metasrv::MetasrvNodeInfo
• metasrv::MetasrvOptions
• metasrv::SelectorContext
• metasrv::builder::MetasrvBuilder
• metrics::METRIC_META_ADD_REGION_FOLLOWER_EXECUTE
• metrics::METRIC_META_HANDLER_EXECUTE
• metrics::METRIC_META_HEARTBEAT_CONNECTION_NUM
• metrics::METRIC_META_HEARTBEAT_RECV
• metrics::METRIC_META_INACTIVE_REGIONS
• metrics::METRIC_META_KV_CACHE_HIT
• metrics::METRIC_META_KV_CACHE_MISS
• metrics::METRIC_META_KV_REQUEST_ELAPSED
• metrics::METRIC_META_LEADER_CACHED_KV_LOAD_ELAPSED
• metrics::METRIC_META_REGION_MIGRATION_DATANODES
• metrics::METRIC_META_REGION_MIGRATION_ERROR
• metrics::METRIC_META_REGION_MIGRATION_EXECUTE
• metrics::METRIC_META_REGION_MIGRATION_FAIL
• metrics::METRIC_META_REMOVE_REGION_FOLLOWER_EXECUTE
• mocks::MockInfo
• procedure::ProcedureManagerListenerAdapter
• procedure::region_migration::Context
• procedure::region_migration::DefaultContextFactory
• procedure::region_migration::PersistentContext
• procedure::region_migration::RegionMigrationData
• procedure::region_migration::RegionMigrationDataOwned
• procedure::region_migration::RegionMigrationProcedure
• procedure::region_migration::RegionMigrationProcedureTask
• procedure::region_migration::RegionMigrationProcedureTracker
• procedure::region_migration::VolatileContext
• procedure::region_migration::close_downgraded_region::CloseDowngradedRegion
• procedure::region_migration::downgrade_leader_region::DowngradeLeaderRegion
• procedure::region_migration::manager::RegionMigrationManager
• procedure::region_migration::manager::RegionMigrationProcedureGuard
• procedure::region_migration::manager::RegionMigrationProcedureTask
• procedure::region_migration::manager::RegionMigrationProcedureTracker
• procedure::region_migration::migration_abort::RegionMigrationAbort
• procedure::region_migration::migration_end::RegionMigrationEnd
• procedure::region_migration::migration_start::RegionMigrationStart
• procedure::region_migration::open_candidate_region::OpenCandidateRegion
• procedure::region_migration::upgrade_candidate_region::UpgradeCandidateRegion
• procedure::utils::mock::EchoRegionServer
• procedure::wal_prune::Context
• procedure::wal_prune::WalPruneData
• procedure::wal_prune::WalPruneProcedure
• pubsub::DefaultPublisher
• pubsub::DefaultSubscribeManager
• pubsub::SubscribeRequest
• pubsub::Subscriber
• pubsub::UnsubscribeRequest
• pubsub::publish::DefaultPublisher
• pubsub::subscribe_manager::DefaultSubscribeManager
• pubsub::subscribe_manager::SubscribeRequest
• pubsub::subscribe_manager::UnsubscribeRequest
• pubsub::subscriber::Subscriber
• region::failure_detector::FailureDetectorEntry
• region::failure_detector::RegionFailureDetector
• region::lease_keeper::RegionLeaseKeeper
• region::lease_keeper::RenewRegionLeasesResponse
• region::supervisor::DatanodeHeartbeat
• region::supervisor::HeartbeatAcceptor
• region::supervisor::RegionFailureDetectorControl
• region::supervisor::RegionSupervisor
• region::supervisor::RegionSupervisorTicker
• selector::SelectorOptions
• selector::lease_based::LeaseBasedSelector
• selector::load_based::LoadBasedSelector
• selector::round_robin::RoundRobinSelector
• selector::weight_compute::RegionNumsBasedWeightCompute
• selector::weighted_choose::RandomWeightedChoose
• selector::weighted_choose::WeightedItem
• service::admin::Admin
• service::admin::Router
• service::admin::health::HealthHandler
• service::admin::heartbeat::HeartBeatHandler
• service::admin::heartbeat::StatValues
• service::admin::leader::LeaderHandler
• service::admin::maintenance::MaintenanceHandler
• service::admin::node_lease::HumanLease
• service::admin::node_lease::LeaseValues
• service::admin::node_lease::NodeLeaseHandler
• service::mailbox::MailboxReceiver
• service::store::cached_kv::AlwaysLeader
• service::store::cached_kv::LeaderCachedKvBackend
• state::FollowerState
• state::LeaderState
• table_meta_alloc::MetasrvPeerAllocator

Enums

• cluster::MetaPeerClientBuilderError
• election::LeaderChangeMessage
• error::Error
• handler::CustomizeHeartbeatGroupAction
• handler::HandleControl
• metasrv::BackendImpl
• metasrv::SelectTarget
• procedure::region_migration::update_metadata::UpdateMetadata
• procedure::wal_prune::WalPruneState
• pubsub::Message
• pubsub::Topic
• region::supervisor::Event
• selector::SelectorType
• service::mailbox::BroadcastChannel
• service::mailbox::Channel
• state::State

Traits

• election::Election
• election::LeaderKey
• handler::HeartbeatHandler
• handler::HeartbeatHandlerGroupBuilderCustomizer
• handler::region_lease_handler::CustomizedRegionLeaseRenewer
• procedure::region_migration::ContextFactory
• procedure::region_migration::State
• pubsub::Publisher
• pubsub::SubscriptionManager
• pubsub::SubscriptionQuery
• pubsub::Transport
• pubsub::publish::Publisher
• pubsub::subscribe_manager::SubscriptionManager
• pubsub::subscribe_manager::SubscriptionQuery
• pubsub::subscriber::Transport
• selector::Selector
• selector::weight_compute::WeightCompute
• selector::weighted_choose::WeightedChoose
• service::admin::HttpHandler
• service::mailbox::Mailbox
• service::store::cached_kv::CheckLeader

Macros

• add_compressed_service
• key::impl_from_str_lease_key
• key::impl_try_from_lease_key

Functions

• bootstrap::bootstrap_metasrv_with_router
• bootstrap::create_etcd_client
• bootstrap::metasrv_builder
• bootstrap::router
• cluster::check_resp_header
• cluster::need_retry
• cluster::to_stat_kv_map
• election::listen_leader_change
• error::match_for_io_error
• failure_detector::phi
• greptimedb_telemetry::get_greptimedb_telemetry_task
• handler::collect_cluster_info_handler::extract_base_info
• handler::collect_cluster_info_handler::put_into_memory_store
• handler::collect_stats_handler::rewrite_node_address
• handler::keep_lease_handler::put_into_memory_store
• handler::remap_flow_peer_handler::rewrite_node_address
• lease::alive_datanodes
• lease::alive_flownodes
• lease::build_lease_filter
• lease::filter
• lease::lookup_datanode_peer
• lease::lookup_flownode_peer
• metasrv::builder::build_default_meta_peer_client
• metasrv::builder::build_mailbox
• metasrv::builder::build_procedure_manager
• mocks::mock
• mocks::mock_with_etcdstore
• mocks::mock_with_memstore
• procedure::region_migration::default_timeout
• procedure::wal_prune::check_heartbeat_collected_region_ids
• region::lease_keeper::renew_region_lease_via_region_route
• selector::common::choose_items
• selector::load_based::filter_out_datanode_by_table
• selector::load_based::filter_out_expired_datanode
• selector::load_based::get_leader_peer_ids
• service::admin::boxed
• service::admin::check_path
• service::admin::heartbeat::filter_by_addr
• service::admin::make_admin_service
• service::admin::util::to_text_response
• service::heartbeat::get_node_id
• service::heartbeat::handle_ask_leader
• service::heartbeat::register_pusher
• state::become_follower
• state::become_leader

Type Aliases

• cluster::MetaPeerClientRef
• error::Result
• handler::HeartbeatHandlerGroupBuilderCustomizerRef
• handler::HeartbeatHandlerGroupRef
• handler::region_lease_handler::CustomizedRegionLeaseRenewerRef
• metasrv::ElectionRef
• metasrv::SelectorRef
• procedure::region_migration::RegionMigrationManagerRef
• procedure::region_migration::manager::RegionMigrationManagerRef
• procedure::wal_prune::KafkaClientRef
• pubsub::PublisherRef
• pubsub::SubscriberRef
• pubsub::SubscriptionManagerRef
• pubsub::publish::PublisherRef
• pubsub::subscribe_manager::SubscriptionManagerRef
• pubsub::subscriber::SubscriberRef
• region::lease_keeper::RegionLeaseKeeperRef
• region::supervisor::RegionSupervisorRef
• region::supervisor::RegionSupervisorTickerRef
• service::GrpcResult
• service::GrpcStream
• service::mailbox::MailboxRef
• service::mailbox::MessageId
• service::store::cached_kv::CheckLeaderRef
• state::StateRef

Constants

• cache_invalidator::DEFAULT_SUBJECT
• election::CANDIDATES_ROOT
• election::CANDIDATE_LEASE_SECS
• election::ELECTION_KEY
• election::KEEP_ALIVE_INTERVAL_SECS
• handler::collect_stats_handler::DEFAULT_FLUSH_STATS_FACTOR
• handler::filter_inactive_region_stats::NAME
• key::datanode::DATANODE_LEASE_PREFIX
• key::datanode::DATANODE_STAT_PREFIX
• key::datanode::INACTIVE_REGION_PREFIX
• key::flownode::FLOWNODE_LEASE_PREFIX
• metasrv::DEFAULT_METASRV_ADDR_PORT
• metasrv::FLOW_ID_SEQ
• metasrv::METASRV_HOME
• metasrv::TABLE_ID_SEQ
• procedure::region_migration::close_downgraded_region::CLOSE_DOWNGRADED_REGION_TIMEOUT
• procedure::region_migration::open_candidate_region::OPEN_CANDIDATE_REGION_TIMEOUT
• procedure::wal_prune::TIMEOUT
• region::supervisor::DEFAULT_TICK_INTERVAL
• service::admin::health::HTTP_OK