List of all items
Structs
- cache::CacheContainer
- cache::CacheRegistry
- cache::CacheRegistryBuilder
- cache::LayeredCacheRegistry
- cache::LayeredCacheRegistryBuilder
- cache::container::CacheContainer
- cache::registry::CacheRegistry
- cache::registry::CacheRegistryBuilder
- cache::registry::LayeredCacheRegistry
- cache::registry::LayeredCacheRegistryBuilder
- cache_invalidator::Context
- cache_invalidator::DummyCacheInvalidator
- cache_invalidator::DummyKvCacheInvalidator
- cluster::CLUSTER_NODE_INFO_PREFIX_PATTERN
- cluster::DatanodeStatus
- cluster::FlownodeStatus
- cluster::FrontendStatus
- cluster::MetasrvStatus
- cluster::NodeInfo
- cluster::NodeInfoKey
- datanode::DATANODE_LEASE_KEY_PATTERN
- datanode::DATANODE_STAT_KEY_PATTERN
- datanode::DatanodeStatKey
- datanode::DatanodeStatValue
- datanode::INACTIVE_REGION_KEY_PATTERN
- datanode::RegionStat
- datanode::Stat
- ddl::DdlContext
- ddl::ExecutorContext
- ddl::NoopRegionFailureDetectorControl
- ddl::TableMetadata
- ddl::TableMetadataAllocatorContext
- ddl::alter_logical_tables::AlterLogicalTablesProcedure
- ddl::alter_logical_tables::AlterTablesData
- ddl::alter_table::AlterTableData
- ddl::alter_table::AlterTableProcedure
- ddl::create_database::CreateDatabaseData
- ddl::create_database::CreateDatabaseProcedure
- ddl::create_flow::CreateFlowData
- ddl::create_flow::CreateFlowProcedure
- ddl::create_logical_tables::CreateLogicalTablesProcedure
- ddl::create_logical_tables::CreateTablesData
- ddl::create_table::CreateTableData
- ddl::create_table::CreateTableProcedure
- ddl::create_table::TableCreator
- ddl::create_table_template::CreateRequestBuilder
- ddl::create_view::CreateViewData
- ddl::create_view::CreateViewProcedure
- ddl::drop_database::DropDatabaseContext
- ddl::drop_database::DropDatabaseData
- ddl::drop_database::DropDatabaseOwnedData
- ddl::drop_database::DropDatabaseProcedure
- ddl::drop_database::cursor::DropDatabaseCursor
- ddl::drop_database::end::DropDatabaseEnd
- ddl::drop_database::executor::DropDatabaseExecutor
- ddl::drop_database::metadata::DropDatabaseRemoveMetadata
- ddl::drop_database::metadata::DropMetadataBroadcast
- ddl::drop_database::start::DropDatabaseStart
- ddl::drop_flow::DropFlowData
- ddl::drop_flow::DropFlowProcedure
- ddl::drop_table::DropTableData
- ddl::drop_table::DropTableProcedure
- ddl::drop_table::executor::DropTableExecutor
- ddl::drop_view::DropViewData
- ddl::drop_view::DropViewProcedure
- ddl::flow_meta::FlowMetadataAllocator
- ddl::flow_meta::NoopPartitionPeerAllocator
- ddl::table_meta::NoopPeerAllocator
- ddl::table_meta::TableMetadataAllocator
- ddl::test_util::alter_table::TestAlterTableExpr
- ddl::test_util::alter_table::TestAlterTableExprBuilder
- ddl::test_util::columns::TestColumnDef
- ddl::test_util::columns::TestColumnDefBuilder
- ddl::test_util::create_table::TestCreateTableExpr
- ddl::test_util::create_table::TestCreateTableExprBuilder
- ddl::test_util::datanode_handler::DatanodeWatcher
- ddl::test_util::datanode_handler::MockRequestOutdatedError
- ddl::test_util::datanode_handler::MockRequestOutdatedSnafu
- ddl::test_util::datanode_handler::NaiveDatanodeHandler
- ddl::test_util::datanode_handler::RequestOutdatedErrorDatanodeHandler
- ddl::test_util::datanode_handler::RetryErrorDatanodeHandler
- ddl::test_util::datanode_handler::UnexpectedErrorDatanodeHandler
- ddl::test_util::flownode_handler::NaiveFlownodeHandler
- ddl::truncate_table::TruncateTableData
- ddl::truncate_table::TruncateTableProcedure
- ddl_manager::DdlManager
- ddl_manager::DdlManagerBuilder
- error::AlterLogicalTablesInvalidArgumentsSnafu
- error::BuildKafkaClientSnafu
- error::BuildKafkaCtrlClientSnafu
- error::BuildKafkaPartitionClientSnafu
- error::BuildTableMetaSnafu
- error::CacheNotGetSnafu
- error::ConnectEtcdSnafu
- error::ConvertAlterTableRequestSnafu
- error::ConvertRawKeySnafu
- error::ConvertRawTableInfoSnafu
- error::CreateKafkaWalTopicSnafu
- error::CreateLogicalTablesInvalidArgumentsSnafu
- error::DatanodeTableInfoNotFoundSnafu
- error::DecodeJsonSnafu
- error::DecodeProtoSnafu
- error::DeserializeFromJsonSnafu
- error::EmptyDdlTasksSnafu
- error::EmptyKeySnafu
- error::EmptyTopicPoolSnafu
- error::EncodeJsonSnafu
- error::EncodeWalOptionsSnafu
- error::EtcdFailedSnafu
- error::EtcdTxnFailedSnafu
- error::EtcdTxnOpResponseSnafu
- error::ExternalSnafu
- error::FlowAlreadyExistsSnafu
- error::FlowNotFoundSnafu
- error::FlowRouteNotFoundSnafu
- error::FromUtf8Snafu
- error::GetCacheSnafu
- error::GetKvCacheSnafu
- error::IllegalServerStateSnafu
- error::InvalidHeartbeatResponseSnafu
- error::InvalidMetadataSnafu
- error::InvalidNodeInfoKeySnafu
- error::InvalidNumTopicsSnafu
- error::InvalidProtoMsgSnafu
- error::InvalidRoleSnafu
- error::InvalidStatKeySnafu
- error::InvalidViewInfoSnafu
- error::MetadataCorruptionSnafu
- error::MismatchPrefixSnafu
- error::MoveValuesSnafu
- error::NextSequenceSnafu
- error::OperateDatanodeSnafu
- error::ParseNumSnafu
- error::ParseOptionSnafu
- error::ParseProcedureIdSnafu
- error::PayloadNotExistSnafu
- error::PrimaryKeyNotFoundSnafu
- error::ProcedureNotFoundSnafu
- error::ProcedureOutputSnafu
- error::ProduceRecordSnafu
- error::QueryProcedureSnafu
- error::RegionOperatingRaceSnafu
- error::RegisterProcedureLoaderSnafu
- error::ResolveKafkaEndpointSnafu
- error::RetryLaterSnafu
- error::RouteInfoCorruptedSnafu
- error::SchemaAlreadyExistsSnafu
- error::SchemaNotFoundSnafu
- error::SendMessageSnafu
- error::SerdeJsonSnafu
- error::SerializeToJsonSnafu
- error::StartProcedureManagerSnafu
- error::StopProcedureManagerSnafu
- error::StrFromUtf8Snafu
- error::SubmitProcedureSnafu
- error::TableAlreadyExistsSnafu
- error::TableInfoNotFoundSnafu
- error::TableNotFoundSnafu
- error::TableRouteNotFoundSnafu
- error::TableSnafu
- error::TlsConfigSnafu
- error::UnexpectedLogicalRouteTableSnafu
- error::UnexpectedSequenceValueSnafu
- error::UnexpectedSnafu
- error::UnsupportedSnafu
- error::ValueNotExistSnafu
- error::ViewAlreadyExistsSnafu
- error::ViewNotFoundSnafu
- error::WaitProcedureSnafu
- flow_name::FlowName
- heartbeat::handler::HandlerGroupExecutor
- heartbeat::handler::HeartbeatResponseHandlerContext
- heartbeat::handler::parse_mailbox_message::ParseMailboxMessageHandler
- heartbeat::mailbox::HeartbeatMailbox
- heartbeat::mailbox::MessageMeta
- instruction::CreateFlow
- instruction::DowngradeRegion
- instruction::DowngradeRegionReply
- instruction::DropFlow
- instruction::OpenRegion
- instruction::RegionIdent
- instruction::SimpleReply
- instruction::UpgradeRegion
- instruction::UpgradeRegionReply
- key::BytesAdapter
- key::CATALOG_NAME_KEY_PATTERN
- key::DATANODE_TABLE_KEY_PATTERN
- key::DeserializedValueWithBytes
- key::NODE_ADDRESS_PATTERN
- key::SCHEMA_NAME_KEY_PATTERN
- key::SchemaMetadataManager
- key::TABLE_INFO_KEY_PATTERN
- key::TABLE_NAME_KEY_PATTERN
- key::TABLE_ROUTE_KEY_PATTERN
- key::TableMetadataManager
- key::VIEW_INFO_KEY_PATTERN
- key::catalog_name::CatalogManager
- key::catalog_name::CatalogNameKey
- key::catalog_name::CatalogNameValue
- key::datanode_table::DatanodeTableKey
- key::datanode_table::DatanodeTableManager
- key::datanode_table::DatanodeTableValue
- key::datanode_table::RegionInfo
- key::flow::FlowMetadataManager
- key::flow::FlowScoped
- key::flow::TableFlowManager
- key::flow::flow_info::FLOW_INFO_KEY_PATTERN
- key::flow::flow_info::FlowInfoKey
- key::flow::flow_info::FlowInfoKeyInner
- key::flow::flow_info::FlowInfoManager
- key::flow::flow_info::FlowInfoValue
- key::flow::flow_name::FLOW_NAME_KEY_PATTERN
- key::flow::flow_name::FlowNameKey
- key::flow::flow_name::FlowNameKeyInner
- key::flow::flow_name::FlowNameManager
- key::flow::flow_name::FlowNameValue
- key::flow::flow_route::FLOW_ROUTE_KEY_PATTERN
- key::flow::flow_route::FlowRouteKey
- key::flow::flow_route::FlowRouteKeyInner
- key::flow::flow_route::FlowRouteManager
- key::flow::flow_route::FlowRouteValue
- key::flow::flownode_flow::FLOWNODE_FLOW_KEY_PATTERN
- key::flow::flownode_flow::FlownodeFlowKey
- key::flow::flownode_flow::FlownodeFlowKeyInner
- key::flow::flownode_flow::FlownodeFlowManager
- key::flow::table_flow::TABLE_FLOW_KEY_PATTERN
- key::flow::table_flow::TableFlowKey
- key::flow::table_flow::TableFlowKeyInner
- key::flow::table_flow::TableFlowManager
- key::flow::table_flow::TableFlowValue
- key::node_address::NodeAddressKey
- key::node_address::NodeAddressValue
- key::schema_metadata_manager::SchemaMetadataManager
- key::schema_name::SchemaManager
- key::schema_name::SchemaName
- key::schema_name::SchemaNameKey
- key::schema_name::SchemaNameValue
- key::table_info::TableInfoKey
- key::table_info::TableInfoManager
- key::table_info::TableInfoValue
- key::table_name::TableNameKey
- key::table_name::TableNameManager
- key::table_name::TableNameValue
- key::table_route::LogicalTableRouteValue
- key::table_route::PhysicalTableRouteValue
- key::table_route::TableRouteKey
- key::table_route::TableRouteManager
- key::table_route::TableRouteStorage
- key::tombstone::TombstoneManager
- key::txn_helper::TxnOpGetResponseSet
- key::view_info::ViewInfoKey
- key::view_info::ViewInfoManager
- key::view_info::ViewInfoValue
- kv_backend::chroot::ChrootKvBackend
- kv_backend::etcd::BatchDelete
- kv_backend::etcd::BatchGet
- kv_backend::etcd::BatchPut
- kv_backend::etcd::Delete
- kv_backend::etcd::EtcdStore
- kv_backend::etcd::Get
- kv_backend::etcd::Put
- kv_backend::memory::MemoryKvBackend
- kv_backend::txn::Compare
- kv_backend::txn::Txn
- kv_backend::txn::TxnRequest
- kv_backend::txn::TxnResponse
- leadership_notifier::DefaultLeadershipChangeNotifierCustomizer
- leadership_notifier::LeadershipChangeNotifier
- metrics::CACHE_CONTAINER_CACHE_GET
- metrics::CACHE_CONTAINER_CACHE_MISS
- metrics::CACHE_CONTAINER_LOAD_CACHE
- metrics::METRIC_META_CREATE_CATALOG
- metrics::METRIC_META_CREATE_CATALOG_COUNTER
- metrics::METRIC_META_CREATE_SCHEMA
- metrics::METRIC_META_CREATE_SCHEMA_COUNTER
- metrics::METRIC_META_PROCEDURE_ALTER_TABLE
- metrics::METRIC_META_PROCEDURE_CREATE_FLOW
- metrics::METRIC_META_PROCEDURE_CREATE_TABLE
- metrics::METRIC_META_PROCEDURE_CREATE_TABLES
- metrics::METRIC_META_PROCEDURE_CREATE_VIEW
- metrics::METRIC_META_PROCEDURE_DROP_FLOW
- metrics::METRIC_META_PROCEDURE_DROP_TABLE
- metrics::METRIC_META_PROCEDURE_DROP_VIEW
- metrics::METRIC_META_PROCEDURE_TRUNCATE_TABLE
- metrics::METRIC_META_TXN_REQUEST
- peer::Peer
- range_stream::PaginationStream
- range_stream::PaginationStreamFactory
- region_keeper::MemoryRegionKeeper
- region_keeper::OperatingRegionGuard
- rpc::KeyValue
- rpc::ResponseHeader
- rpc::ddl::AlterTableTask
- rpc::ddl::CreateDatabaseTask
- rpc::ddl::CreateFlowTask
- rpc::ddl::CreateTableTask
- rpc::ddl::CreateViewTask
- rpc::ddl::DropDatabaseTask
- rpc::ddl::DropFlowTask
- rpc::ddl::DropTableTask
- rpc::ddl::DropViewTask
- rpc::ddl::QueryContext
- rpc::ddl::SubmitDdlTaskRequest
- rpc::ddl::SubmitDdlTaskResponse
- rpc::ddl::TruncateTableTask
- rpc::lock::LockRequest
- rpc::lock::LockResponse
- rpc::lock::UnlockRequest
- rpc::procedure::MigrateRegionRequest
- rpc::procedure::MigrateRegionResponse
- rpc::procedure::ProcedureStateResponse
- rpc::router::Partition
- rpc::router::Region
- rpc::router::RegionRoute
- rpc::router::RegionRouteBuilder
- rpc::router::RegionRoutes
- rpc::router::Table
- rpc::router::TableRoute
- rpc::store::BatchDeleteRequest
- rpc::store::BatchDeleteResponse
- rpc::store::BatchGetRequest
- rpc::store::BatchGetResponse
- rpc::store::BatchPutRequest
- rpc::store::BatchPutResponse
- rpc::store::CompareAndPutRequest
- rpc::store::CompareAndPutResponse
- rpc::store::DeleteRangeRequest
- rpc::store::DeleteRangeResponse
- rpc::store::PutRequest
- rpc::store::PutResponse
- rpc::store::RangeRequest
- rpc::store::RangeResponse
- sequence::Inner
- sequence::Sequence
- sequence::SequenceBuilder
- state_store::KvStateStore
- test_util::MockDatanodeManager
- test_util::MockFlownodeManager
- test_util::MockNode
- test_util::NoopPeerLookupService
- wal_options_allocator::kafka::topic_manager::TopicManager
- wal_options_allocator::kafka::topic_selector::RoundRobinTopicSelector
Enums
- cache::TableRoute
- cache::table::table_route::TableRoute
- cluster::NodeStatus
- cluster::Role
- ddl::alter_logical_tables::AlterTablesState
- ddl::alter_table::AlterTableState
- ddl::create_database::CreateDatabaseState
- ddl::create_flow::CreateFlowState
- ddl::create_logical_tables::CreateTablesState
- ddl::create_table::CreateTableState
- ddl::create_view::CreateViewState
- ddl::drop_database::DropTableTarget
- ddl::drop_flow::DropFlowState
- ddl::drop_table::DropTableState
- ddl::drop_table::executor::Control
- ddl::drop_view::DropViewState
- ddl::test_util::alter_table::TestAlterTableExprBuilderError
- ddl::test_util::columns::TestColumnDefBuilderError
- ddl::test_util::create_table::TestCreateTableExprBuilderError
- ddl::truncate_table::TruncateTableState
- ddl_manager::DdlManagerBuilderError
- error::Error
- heartbeat::handler::HandleControl
- instruction::CacheIdent
- instruction::Instruction
- instruction::InstructionReply
- key::table_route::TableRouteValue
- kv_backend::txn::CompareOp
- kv_backend::txn::TxnOp
- kv_backend::txn::TxnOpResponse
- lock_key::CatalogLock
- lock_key::FlowLock
- lock_key::FlowNameLock
- lock_key::RegionLock
- lock_key::SchemaLock
- lock_key::TableLock
- lock_key::TableNameLock
- rpc::ddl::DdlTask
- rpc::router::LeaderState
- rpc::router::RegionRouteBuilderError
- state_store::SplitValue
- wal_options_allocator::WalOptionsAllocator
Traits
- cache_invalidator::CacheInvalidator
- cache_invalidator::KvCacheInvalidator
- cluster::ClusterInfo
- ddl::ProcedureExecutor
- ddl::RegionFailureDetectorController
- ddl::drop_database::State
- ddl::flow_meta::PartitionPeerAllocator
- ddl::table_meta::PeerAllocator
- heartbeat::handler::HeartbeatResponseHandler
- heartbeat::handler::HeartbeatResponseHandlerExecutor
- key::MetadataKey
- key::MetadataKeyGetTxnOp
- key::MetadataValue
- kv_backend::KvBackend
- kv_backend::ResettableKvBackend
- kv_backend::txn::TxnService
- leadership_notifier::LeadershipChangeListener
- leadership_notifier::LeadershipChangeNotifierCustomizer
- node_manager::Datanode
- node_manager::Flownode
- node_manager::NodeManager
- peer::PeerLookupService
- test_util::MockDatanodeHandler
- test_util::MockFlownodeHandler
- wal_options_allocator::kafka::topic_selector::TopicSelector
Macros
- ddl_manager::procedure_loader
- ddl_manager::procedure_loader_entry
- ensure_values
- impl_metadata_value
- impl_optional_metadata_value
- key::impl_metadata_key_get_txn_op
Functions
- cache::flow::table_flownode::filter
- cache::flow::table_flownode::handle_create_flow
- cache::flow::table_flownode::handle_drop_flow
- cache::flow::table_flownode::init_factory
- cache::flow::table_flownode::invalidator
- cache::flow::table_flownode::new_table_flownode_set_cache
- cache::new_table_flownode_set_cache
- cache::new_table_info_cache
- cache::new_table_name_cache
- cache::new_table_route_cache
- cache::new_view_info_cache
- cache::table::table_info::filter
- cache::table::table_info::init_factory
- cache::table::table_info::invalidator
- cache::table::table_info::new_table_info_cache
- cache::table::table_name::filter
- cache::table::table_name::init_factory
- cache::table::table_name::invalidator
- cache::table::table_name::new_table_name_cache
- cache::table::table_route::filter
- cache::table::table_route::init_factory
- cache::table::table_route::invalidator
- cache::table::table_route::new_table_route_cache
- cache::table::view_info::filter
- cache::table::view_info::init_factory
- cache::table::view_info::invalidator
- cache::table::view_info::new_view_info_cache
- ddl::alter_logical_tables::metadata::extract_table_name
- ddl::alter_logical_tables::metadata::extract_table_name_key
- ddl::alter_logical_tables::region_request::to_region_add_columns
- ddl::alter_logical_tables::table_cache_keys::extract_table_name
- ddl::alter_table::region_request::create_proto_alter_kind
- ddl::create_table_template::build_template
- ddl::physical_table_metadata::build_new_physical_table_info
- ddl::test_util::create_logical_table
- ddl::test_util::create_physical_table
- ddl::test_util::create_physical_table_metadata
- ddl::test_util::create_table::build_raw_table_info_from_expr
- ddl::test_util::create_table::test_create_table_task
- ddl::test_util::test_create_logical_table_task
- ddl::test_util::test_create_physical_table_task
- ddl::utils::add_peer_context_if_needed
- ddl::utils::check_and_get_physical_table_id
- ddl::utils::convert_region_routes_to_detecting_regions
- ddl::utils::get_catalog_and_schema
- ddl::utils::get_physical_table_id
- ddl::utils::handle_retry_error
- ddl::utils::region_storage_path
- ddl_manager::handle_alter_logical_table_tasks
- ddl_manager::handle_alter_table_task
- ddl_manager::handle_create_database_task
- ddl_manager::handle_create_flow_task
- ddl_manager::handle_create_logical_table_tasks
- ddl_manager::handle_create_table_task
- ddl_manager::handle_create_view_task
- ddl_manager::handle_drop_database_task
- ddl_manager::handle_drop_flow_task
- ddl_manager::handle_drop_table_task
- ddl_manager::handle_drop_view_task
- ddl_manager::handle_truncate_table_task
- heartbeat::utils::mailbox_message_to_incoming_message
- heartbeat::utils::outgoing_message_to_mailbox_message
- key::catalog_name::catalog_decoder
- key::datanode_table::datanode_table_value_decoder
- key::flow::flow_name::flow_name_decoder
- key::flow::flow_route::flow_route_decoder
- key::flow::flownode_flow::flownode_flow_key_decoder
- key::flow::table_flow::table_flow_decoder
- key::schema_name::schema_decoder
- key::table_name::table_decoder
- key::table_route::extract_address_keys
- key::table_route::set_addresses
- key::test_utils::new_test_table_info
- key::test_utils::new_test_table_info_with_name
- key::tombstone::to_tombstone
- kv_backend::test::mock_kvs
- kv_backend::test::prepare_kv
- kv_backend::test::prepare_kv_with_prefix
- kv_backend::test::test_kv_batch_delete
- kv_backend::test::test_kv_batch_delete_with_prefix
- kv_backend::test::test_kv_batch_get
- kv_backend::test::test_kv_batch_get_with_prefix
- kv_backend::test::test_kv_compare_and_put
- kv_backend::test::test_kv_compare_and_put_with_prefix
- kv_backend::test::test_kv_delete_range
- kv_backend::test::test_kv_delete_range_with_prefix
- kv_backend::test::test_kv_put
- kv_backend::test::test_kv_put_with_prefix
- kv_backend::test::test_kv_range
- kv_backend::test::test_kv_range_2
- kv_backend::test::test_kv_range_2_with_prefix
- kv_backend::test::test_kv_range_with_prefix
- kv_backend::test::unprepare_kv
- rpc::procedure::pb_pid_to_pid
- rpc::procedure::pid_to_pb_pid
- rpc::procedure::procedure_details_to_pb_response
- rpc::procedure::procedure_state_to_pb_response
- rpc::procedure::procedure_state_to_pb_state
- rpc::router::as_utf8
- rpc::router::as_utf8_vec
- rpc::router::convert_to_region_leader_map
- rpc::router::convert_to_region_leader_state_map
- rpc::router::convert_to_region_peer_map
- rpc::router::extract_all_peers
- rpc::router::find_leader_regions
- rpc::router::find_leaders
- rpc::router::find_region_leader
- rpc::router::from_utf8
- rpc::router::from_utf8_vec
- rpc::router::operating_leader_regions
- rpc::router::region_distribution
- rpc::store::to_range
- sequence::seq_name
- state_store::decode_kv
- state_store::split_value
- state_store::strip_prefix
- state_store::with_prefix
- test_util::new_ddl_context
- test_util::new_ddl_context_with_kv_backend
- util::check_response_header
- util::get_next_prefix_key
- util::get_prefix_end_key
- wal_options_allocator::allocate_region_wal_options
- wal_options_allocator::prepare_wal_options
Type Aliases
- ClusterId
- DatanodeId
- FlownodeId
- SchemaOptions
- cache::CacheRegistryRef
- cache::Initializer
- cache::Invalidator
- cache::LayeredCacheRegistryRef
- cache::TableFlownodeSetCache
- cache::TableFlownodeSetCacheRef
- cache::TableInfoCache
- cache::TableInfoCacheRef
- cache::TableNameCache
- cache::TableNameCacheRef
- cache::TableRouteCache
- cache::TableRouteCacheRef
- cache::TokenFilter
- cache::ViewInfoCache
- cache::ViewInfoCacheRef
- cache::container::Initializer
- cache::container::Invalidator
- cache::container::TokenFilter
- cache::flow::table_flownode::FlownodeSet
- cache::flow::table_flownode::TableFlownodeSetCache
- cache::flow::table_flownode::TableFlownodeSetCacheRef
- cache::registry::CacheRegistryRef
- cache::registry::LayeredCacheRegistryRef
- cache::table::table_info::TableInfoCache
- cache::table::table_info::TableInfoCacheRef
- cache::table::table_name::TableNameCache
- cache::table::table_name::TableNameCacheRef
- cache::table::table_route::TableRouteCache
- cache::table::table_route::TableRouteCacheRef
- cache::table::view_info::ViewInfoCache
- cache::table::view_info::ViewInfoCacheRef
- cache_invalidator::CacheInvalidatorRef
- cache_invalidator::KvCacheInvalidatorRef
- ddl::DetectingRegion
- ddl::ProcedureExecutorRef
- ddl::RegionFailureDetectorControllerRef
- ddl::flow_meta::FlowMetadataAllocatorRef
- ddl::flow_meta::PartitionPeerAllocatorRef
- ddl::table_meta::PeerAllocatorRef
- ddl::table_meta::TableMetadataAllocatorRef
- ddl_manager::BoxedProcedureLoaderFactory
- ddl_manager::DdlManagerRef
- error::Result
- heartbeat::handler::HeartbeatResponseHandlerExecutorRef
- heartbeat::handler::HeartbeatResponseHandlerRef
- heartbeat::mailbox::IncomingMessage
- heartbeat::mailbox::MailboxRef
- heartbeat::mailbox::OutgoingMessage
- key::FlowId
- key::FlowPartitionId
- key::RegionDistribution
- key::SchemaMetadataManagerRef
- key::TableMetadataManagerRef
- key::flow::FlowMetadataManagerRef
- key::flow::TableFlowManagerRef
- key::flow::flow_info::FlowInfoDecodeResult
- key::flow::flow_info::FlowInfoManagerRef
- key::flow::flow_name::FlowNameDecodeResult
- key::flow::table_flow::TableFlowManagerRef
- key::schema_metadata_manager::SchemaMetadataManagerRef
- key::table_info::TableInfoDecodeResult
- key::table_info::TableInfoManagerRef
- key::table_name::TableNameManagerRef
- key::table_route::TableRouteManagerRef
- key::table_route::TableRouteValueDecodeResult
- key::view_info::RawViewLogicalPlan
- key::view_info::ViewInfoManagerRef
- key::view_info::ViewInfoValueDecodeResult
- kv_backend::KvBackendRef
- kv_backend::ResettableKvBackendRef
- leadership_notifier::LeadershipChangeNotifierCustomizerRef
- node_manager::AffectedRows
- node_manager::DatanodeRef
- node_manager::FlownodeRef
- node_manager::NodeManagerRef
- peer::PeerLookupServiceRef
- range_stream::KeyValueDecoderFn
- region_keeper::MemoryRegionKeeperRef
- sequence::SequenceRef
- test_util::AffectedRows
- wal_options_allocator::WalOptionsAllocatorRef
- wal_options_allocator::kafka::topic_selector::TopicSelectorRef
Constants
- cluster::CLUSTER_NODE_INFO_PREFIX
- datanode::DATANODE_LEASE_PREFIX
- datanode::DATANODE_STAT_PREFIX
- datanode::INACTIVE_REGION_PREFIX
- datanode::REGION_STATISTIC_KEY
- distributed_time_constants::DATANODE_LEASE_SECS
- distributed_time_constants::FLOWNODE_LEASE_SECS
- distributed_time_constants::FRONTEND_HEARTBEAT_INTERVAL_MILLIS
- distributed_time_constants::HEARTBEAT_INTERVAL_MILLIS
- distributed_time_constants::MAILBOX_RTT_SECS
- distributed_time_constants::META_KEEP_ALIVE_INTERVAL_SECS
- distributed_time_constants::META_LEASE_SECS
- distributed_time_constants::REGION_LEASE_SECS
- key::CACHE_KEY_PREFIXES
- key::CATALOG_NAME_KEY_PREFIX
- key::DATANODE_TABLE_KEY_PREFIX
- key::MAINTENANCE_KEY
- key::NAME_PATTERN
- key::NODE_ADDRESS_PREFIX
- key::SCHEMA_NAME_KEY_PREFIX
- key::TABLE_INFO_KEY_PREFIX
- key::TABLE_NAME_KEY_PREFIX
- key::TABLE_ROUTE_PREFIX
- key::VIEW_INFO_KEY_PREFIX
- key::flow::flow_info::FLOW_INFO_KEY_PREFIX
- key::flow::flow_name::FLOW_NAME_KEY_PREFIX
- key::flow::flow_route::FLOW_ROUTE_KEY_PREFIX
- key::flow::flownode_flow::FLOWNODE_FLOW_KEY_PREFIX
- key::flow::table_flow::TABLE_FLOW_KEY_PREFIX
- key::schema_name::OPT_KEY_TTL
- key::tombstone::TOMBSTONE_PREFIX
- lock_key::CATALOG_LOCK_PREFIX
- lock_key::FLOW_LOCK_PREFIX
- lock_key::FLOW_NAME_LOCK_PREFIX
- lock_key::REGION_LOCK_PREFIX
- lock_key::SCHEMA_LOCK_PREFIX
- lock_key::TABLE_LOCK_PREFIX
- lock_key::TABLE_NAME_LOCK_PREFIX
- range_stream::DEFAULT_ADAPTIVE_PAGE_SIZE
- range_stream::DEFAULT_PAGE_SIZE
- sequence::SEQ_PREFIX
- state_store::DELIMITER
- state_store::PROCEDURE_PREFIX
- wal_options_allocator::kafka::topic_manager::CREATED_TOPICS_KEY
- wal_options_allocator::kafka::topic_manager::DEFAULT_PARTITION