List of all items

Structs

• backup_restore::BackupManager
• backup_restore::RestoreOpts
• backup_restore::backup_manager::BackupJobHandle
• backup_restore::backup_manager::BackupManager
• backup_restore::backup_manager::BackupWorker
• backup_restore::meta_snapshot_builder::MetaSnapshotV2Builder
• backup_restore::metrics::BackupManagerMetrics
• backup_restore::restore::RestoreOpts
• backup_restore::restore_impl::v2::LoaderV2
• backup_restore::restore_impl::v2::WriterModelV2ToMetaStoreV2
• barrier::BarrierScheduler
• barrier::BarrierWorkerRuntimeInfoSnapshot
• barrier::CreateStreamingJobCommandInfo
• barrier::GlobalBarrierManager
• barrier::InflightSubscriptionInfo
• barrier::ReplaceTablePlan
• barrier::Reschedule
• barrier::Scheduled
• barrier::SnapshotBackfillInfo
• barrier::TracedEpoch
• barrier::checkpoint::control::BarrierEpochState
• barrier::checkpoint::control::CheckpointControl
• barrier::checkpoint::control::DatabaseCheckpointControl
• barrier::checkpoint::control::EpochNode
• barrier::checkpoint::creating_job::CreatingStreamingJobControl
• barrier::checkpoint::creating_job::barrier_control::CreatingStreamingJobBarrierControl
• barrier::checkpoint::creating_job::barrier_control::CreatingStreamingJobEpochState
• barrier::checkpoint::creating_job::status::CreateMviewLogStoreProgressTracker
• barrier::checkpoint::creating_job::status::CreatingJobInjectBarrierInfo
• barrier::checkpoint::state::BarrierWorkerState
• barrier::command::CommandContext
• barrier::command::CreateStreamingJobCommandInfo
• barrier::command::ReplaceTablePlan
• barrier::command::Reschedule
• barrier::command::SnapshotBackfillInfo
• barrier::complete_task::BarrierCompleteOutput
• barrier::complete_task::CompleteBarrierTask
• barrier::context::GlobalBarrierWorkerContextImpl
• barrier::info::BarrierInfo
• barrier::info::InflightDatabaseInfo
• barrier::info::InflightStreamingJobInfo
• barrier::info::InflightSubscriptionInfo
• barrier::manager::GlobalBarrierManager
• barrier::notifier::Notifier
• barrier::progress::CreateMviewProgressTracker
• barrier::progress::Progress
• barrier::progress::RecoveredTrackingJob
• barrier::progress::TrackingCommand
• barrier::rpc::ControlStreamManager
• barrier::rpc::ControlStreamNode
• barrier::schedule::BarrierScheduler
• barrier::schedule::Inner
• barrier::schedule::NewBarrier
• barrier::schedule::PeriodicBarriers
• barrier::schedule::ScheduledBarriers
• barrier::schedule::ScheduledQueue
• barrier::schedule::ScheduledQueueItem
• barrier::trace::TracedEpoch
• barrier::worker::GlobalBarrierWorker
• controller::ObjectModel
• controller::SqlMetaStore
• controller::catalog::CatalogController
• controller::catalog::CatalogControllerInner
• controller::catalog::CatalogStats
• controller::catalog::ReleaseContext
• controller::cluster::ClusterController
• controller::cluster::ClusterControllerInner
• controller::cluster::StreamingClusterInfo
• controller::cluster::WorkerExtraInfo
• controller::cluster::WorkerInfo
• controller::fragment::FragmentParallelismInfo
• controller::fragment::InflightFragmentInfo
• controller::fragment::StreamingJobInfo
• controller::id::IdGenerator
• controller::id::IdGeneratorManager
• controller::rename::QueryRewriter
• controller::rename::ReplaceTableExprRewriter
• controller::scale::RescheduleWorkingSet
• controller::session_params::SessionParamsController
• controller::system_param::SystemParamsController
• controller::utils::FragmentDesc
• controller::utils::PartialActorLocation
• controller::utils::PartialActorSplits
• controller::utils::PartialFragmentStateTables
• controller::utils::PartialObject
• controller::utils::PartialUserPrivilege
• dashboard::DashboardService
• dashboard::handlers::DashboardError
• dashboard::prometheus::ClusterMetrics
• dashboard::prometheus::FragmentBackPressure
• dashboard::prometheus::PrometheusSample
• dashboard::prometheus::PrometheusVector
• error::MetaError
• hummock::CommitEpochInfo
• hummock::HummockManager
• hummock::HummockVersionSafePoint
• hummock::NewTableFragmentInfo
• hummock::compaction::CompactStatus
• hummock::compaction::CompactionDeveloperConfig
• hummock::compaction::CompactionTask
• hummock::compaction::compaction_config::CompactionConfigBuilder
• hummock::compaction::overlap_strategy::RangeOverlapInfo
• hummock::compaction::overlap_strategy::RangeOverlapStrategy
• hummock::compaction::picker::CompactionInput
• hummock::compaction::picker::LocalPickerStatistic
• hummock::compaction::picker::base_level_compaction_picker::LevelCompactionPicker
• hummock::compaction::picker::compaction_task_validator::BaseCompactionTaskValidationRule
• hummock::compaction::picker::compaction_task_validator::CompactionTaskValidator
• hummock::compaction::picker::compaction_task_validator::IntraCompactionTaskValidationRule
• hummock::compaction::picker::compaction_task_validator::TierCompactionTaskValidationRule
• hummock::compaction::picker::emergency_compaction_picker::EmergencyCompactionPicker
• hummock::compaction::picker::intra_compaction_picker::IntraCompactionPicker
• hummock::compaction::picker::intra_compaction_picker::WholeLevelCompactionPicker
• hummock::compaction::picker::manual_compaction_picker::ManualCompactionPicker
• hummock::compaction::picker::min_overlap_compaction_picker::MinOverlappingPicker
• hummock::compaction::picker::min_overlap_compaction_picker::NonOverlapSubLevelPicker
• hummock::compaction::picker::min_overlap_compaction_picker::SubLevelSstables
• hummock::compaction::picker::space_reclaim_compaction_picker::SpaceReclaimCompactionPicker
• hummock::compaction::picker::space_reclaim_compaction_picker::SpaceReclaimPickerState
• hummock::compaction::picker::tier_compaction_picker::TierCompactionPicker
• hummock::compaction::picker::tombstone_reclaim_compaction_picker::TombstoneReclaimCompactionPicker
• hummock::compaction::picker::tombstone_reclaim_compaction_picker::TombstoneReclaimPickerState
• hummock::compaction::picker::trivial_move_compaction_picker::TrivialMovePicker
• hummock::compaction::picker::ttl_reclaim_compaction_picker::TtlPickerState
• hummock::compaction::picker::ttl_reclaim_compaction_picker::TtlReclaimCompactionPicker
• hummock::compaction::picker::vnode_watermark_picker::VnodeWatermarkCompactionPicker
• hummock::compaction::selector::CompactionSelectorContext
• hummock::compaction::selector::DynamicLevelSelector
• hummock::compaction::selector::DynamicLevelSelectorCore
• hummock::compaction::selector::EmergencySelector
• hummock::compaction::selector::LocalSelectorStatistic
• hummock::compaction::selector::ManualCompactionOption
• hummock::compaction::selector::ManualCompactionSelector
• hummock::compaction::selector::SpaceReclaimCompactionSelector
• hummock::compaction::selector::TombstoneCompactionSelector
• hummock::compaction::selector::TtlCompactionSelector
• hummock::compaction::selector::VnodeWatermarkCompactionSelector
• hummock::compaction::selector::emergency_selector::EmergencySelector
• hummock::compaction::selector::level_selector::DynamicLevelSelector
• hummock::compaction::selector::level_selector::DynamicLevelSelectorCore
• hummock::compaction::selector::level_selector::PickerInfo
• hummock::compaction::selector::level_selector::SelectContext
• hummock::compaction::selector::manual_selector::ManualCompactionOption
• hummock::compaction::selector::manual_selector::ManualCompactionSelector
• hummock::compaction::selector::space_reclaim_selector::SpaceReclaimCompactionSelector
• hummock::compaction::selector::tombstone_compaction_selector::TombstoneCompactionSelector
• hummock::compaction::selector::ttl_selector::TtlCompactionSelector
• hummock::compaction::selector::vnode_watermark_selector::VnodeWatermarkCompactionSelector
• hummock::compactor_manager::Compactor
• hummock::compactor_manager::CompactorManager
• hummock::compactor_manager::CompactorManagerInner
• hummock::compactor_manager::TaskHeartbeat
• hummock::level_handler::LevelHandler
• hummock::manager::HummockManager
• hummock::manager::checkpoint::HummockVersionCheckpoint
• hummock::manager::commit_epoch::CommitEpochInfo
• hummock::manager::commit_epoch::NewTableFragmentInfo
• hummock::manager::compaction::Compaction
• hummock::manager::compaction::CompactionGroupStatistic
• hummock::manager::compaction::CompactionState
• hummock::manager::compaction::compaction_group_manager::CompactionGroupManager
• hummock::manager::context::ContextInfo
• hummock::manager::context::HummockVersionSafePoint
• hummock::manager::gc::FullGcState
• hummock::manager::gc::GcManager
• hummock::manager::sequence::SequenceGenerator
• hummock::manager::transaction::HummockVersionStatsTransaction
• hummock::manager::transaction::HummockVersionTransaction
• hummock::manager::transaction::SingleDeltaTransaction
• hummock::manager::versioning::Versioning
• hummock::metrics_utils::LocalTableMetrics
• hummock::mock_hummock_meta_client::CompactionEventItemStream
• hummock::mock_hummock_meta_client::MockHummockMetaClient
• hummock::model::CompactionGroup
• hummock::model::compaction_group_config::CompactionGroup
• hummock::sequence::SequenceGenerator
• hummock::test_utils::CommitEpochInfo
• hummock::utils::RetryableError
• manager::ActiveStreamingWorkerNodes
• manager::IdleManager
• manager::MetaOpts
• manager::MetaSrvEnv
• manager::MetadataManager
• manager::NotificationManager
• manager::WorkerKey
• manager::diagnose::DiagnoseCommand
• manager::env::MetaOpts
• manager::env::MetaSrvEnv
• manager::event_log::EventLog
• manager::event_log::EventLogManger
• manager::idle::IdleManager
• manager::metadata::ActiveStreamingWorkerNodes
• manager::metadata::MetadataManager
• manager::notification::NotificationManager
• manager::notification::NotificationManagerCore
• manager::notification::Target
• manager::notification::Task
• manager::notification_version::NotificationVersionGenerator
• manager::prelude::Actor
• manager::prelude::ActorDispatcher
• manager::prelude::CatalogVersion
• manager::prelude::Cluster
• manager::prelude::CompactionConfig
• manager::prelude::CompactionStatus
• manager::prelude::CompactionTask
• manager::prelude::Connection
• manager::prelude::Database
• manager::prelude::Fragment
• manager::prelude::Function
• manager::prelude::HummockPinnedSnapshot
• manager::prelude::HummockPinnedVersion
• manager::prelude::HummockSequence
• manager::prelude::HummockVersionDelta
• manager::prelude::HummockVersionStats
• manager::prelude::Index
• manager::prelude::Object
• manager::prelude::ObjectDependency
• manager::prelude::Schema
• manager::prelude::Secret
• manager::prelude::SessionParameter
• manager::prelude::Sink
• manager::prelude::Source
• manager::prelude::StreamingJob
• manager::prelude::Subscription
• manager::prelude::SystemParameter
• manager::prelude::Table
• manager::prelude::User
• manager::prelude::UserPrivilege
• manager::prelude::View
• manager::prelude::Worker
• manager::prelude::WorkerProperty
• manager::sink_coordination::SinkCoordinatorManager
• manager::sink_coordination::coordinator_worker::CoordinationHandleManager
• manager::sink_coordination::coordinator_worker::CoordinatorWorker
• manager::sink_coordination::coordinator_worker::EpochCommitRequests
• manager::sink_coordination::handle::SinkWriterCoordinationHandle
• manager::sink_coordination::manager::CoordinatorWorkerHandle
• manager::sink_coordination::manager::ManagerWorker
• manager::sink_coordination::manager::SinkCoordinatorManager
• model::BTreeMapEntryTransaction
• model::BTreeMapTransactionInner
• model::BTreeMapTransactionValueGuard
• model::ClusterId
• model::DerefMutForward
• model::StreamContext
• model::TableFragments
• model::VarTransaction
• model::stream::StreamContext
• model::stream::TableFragments
• rpc::ddl_controller::CreatingStreamingJobPermit
• rpc::ddl_controller::DdlController
• rpc::ddl_controller::ReplaceTableInfo
• rpc::election::ElectionMember
• rpc::election::dummy::DummyElectionClient
• rpc::election::sql::ElectionRow
• rpc::election::sql::MySqlDriver
• rpc::election::sql::PostgresDriver
• rpc::election::sql::SqlBackendElectionClient
• rpc::election::sql::SqliteDriver
• rpc::intercept::MetricsMiddleware
• rpc::intercept::MetricsMiddlewareLayer
• rpc::metrics::MetaMetrics
• serving::ServingVnodeMapping
• storage::Transaction
• storage::transaction::Transaction
• stream::ActorGraphBuildResult
• stream::ActorGraphBuilder
• stream::CompleteStreamFragmentGraph
• stream::ConnectorSourceWorkerHandle
• stream::ConsistentHashRing
• stream::CreateStreamingJobContext
• stream::CreateStreamingJobOption
• stream::CustomActorInfo
• stream::CustomFragmentInfo
• stream::GlobalStreamManager
• stream::Locations
• stream::ReplaceTableContext
• stream::RescheduleContext
• stream::RescheduleOptions
• stream::ScaleController
• stream::SourceManager
• stream::SourceManagerCore
• stream::SourceManagerRunningInfo
• stream::StreamFragmentGraph
• stream::TableResizePolicy
• stream::WorkerReschedule
• stream::scale::ConsistentHashRing
• stream::scale::CustomActorInfo
• stream::scale::CustomFragmentInfo
• stream::scale::RescheduleContext
• stream::scale::RescheduleOptions
• stream::scale::ScaleController
• stream::scale::TableResizePolicy
• stream::scale::WorkerReschedule
• stream::source_manager::ActorSplitsAssignment
• stream::source_manager::ConnectorSourceWorker
• stream::source_manager::ConnectorSourceWorkerHandle
• stream::source_manager::SharedSplitMap
• stream::source_manager::SourceManager
• stream::source_manager::SourceManagerCore
• stream::source_manager::SourceManagerRunningInfo
• stream::source_manager::SplitDiffOptions
• stream::stream_graph::actor::ActorBuilder
• stream::stream_graph::actor::ActorGraphBuildResult
• stream::stream_graph::actor::ActorGraphBuildState
• stream::stream_graph::actor::ActorGraphBuildStateInner
• stream::stream_graph::actor::ActorGraphBuilder
• stream::stream_graph::actor::ActorUpstream
• stream::stream_graph::actor::ExternalChange
• stream::stream_graph::actor::FragmentLinkNode
• stream::stream_graph::fragment::BuildingFragment
• stream::stream_graph::fragment::CompleteStreamFragmentGraph
• stream::stream_graph::fragment::FragmentGraphDownstreamContext
• stream::stream_graph::fragment::FragmentGraphUpstreamContext
• stream::stream_graph::fragment::StreamFragmentEdge
• stream::stream_graph::fragment::StreamFragmentGraph
• stream::stream_graph::id::GlobalId
• stream::stream_graph::id::GlobalIdGen
• stream::stream_graph::schedule::Crepe
• stream::stream_graph::schedule::Edge
• stream::stream_graph::schedule::ExternalReq
• stream::stream_graph::schedule::Input
• stream::stream_graph::schedule::Locations
• stream::stream_graph::schedule::Requirement
• stream::stream_graph::schedule::Scheduler
• stream::stream_manager::CreateStreamingJobContext
• stream::stream_manager::CreateStreamingJobOption
• stream::stream_manager::CreatingStreamingJobInfo
• stream::stream_manager::GlobalStreamManager
• stream::stream_manager::ReplaceTableContext
• stream::stream_manager::StreamingJobExecution
• telemetry::MetaReportCreator
• telemetry::MetaTelemetryInfoFetcher
• telemetry::MetaTelemetryJobDesc
• telemetry::MetaTelemetryReport
• telemetry::NodeCount
• telemetry::RwVersion

Enums

• MetaStoreBackend
• backup_restore::BackupJobResult
• backup_restore::backup_manager::BackupJobResult
• barrier::BarrierKind
• barrier::BarrierManagerRequest
• barrier::BarrierManagerStatus
• barrier::Command
• barrier::CreateStreamingJobType
• barrier::RecoveryReason
• barrier::checkpoint::creating_job::CompleteJobType
• barrier::checkpoint::creating_job::status::CreatingStreamingJobStatus
• barrier::command::BarrierKind
• barrier::command::Command
• barrier::command::CreateStreamingJobType
• barrier::complete_task::CompletingTask
• barrier::info::CommandFragmentChanges
• barrier::progress::BackfillState
• barrier::progress::TrackingJob
• barrier::schedule::QueueStatus
• controller::scale::NoShuffleResolveDirection
• error::MetaErrorInner
• hummock::WriteLimitType
• hummock::compaction::picker::compaction_task_validator::ValidationRuleType
• hummock::compaction::selector::level_selector::PickerType
• hummock::error::Error
• hummock::manager::compaction::WriteLimitType
• hummock::manager::worker::HummockManagerEvent
• manager::DdlType
• manager::LocalNotification
• manager::StreamingJob
• manager::StreamingJobDiscriminants
• manager::metadata::ActiveStreamingWorkerChange
• manager::notification::LocalNotification
• manager::sink_coordination::manager::ManagerEvent
• manager::sink_coordination::manager::ManagerRequest
• manager::streaming_job::DdlType
• manager::streaming_job::StreamingJob
• manager::streaming_job::StreamingJobDiscriminants
• model::BTreeMapOp
• model::BTreeMapTransactionStagingEntry
• model::BackfillUpstreamType
• model::MetadataModelError
• model::TableParallelism
• model::error::MetadataModelError
• model::stream::BackfillUpstreamType
• model::stream::TableParallelism
• rpc::ddl_controller::DdlCommand
• rpc::ddl_controller::DropMode
• rpc::ddl_controller::StreamingJobId
• storage::MetaStoreError
• storage::Operation
• storage::Precondition
• storage::transaction::Operation
• storage::transaction::Precondition
• stream::CreatingState
• stream::stream_graph::fragment::EdgeId
• stream::stream_graph::fragment::EitherFragment
• stream::stream_graph::schedule::Distribution
• stream::stream_graph::schedule::Fact
• stream::stream_graph::schedule::Req
• stream::stream_manager::CreatingState
• telemetry::PlanOptimization

Traits

• backup_restore::restore_impl::Loader
• backup_restore::restore_impl::Writer
• barrier::context::GlobalBarrierWorkerContext
• hummock::compaction::overlap_strategy::OverlapInfo
• hummock::compaction::overlap_strategy::OverlapStrategy
• hummock::compaction::picker::CompactionPicker
• hummock::compaction::picker::compaction_task_validator::CompactionTaskValidationRule
• hummock::compaction::selector::CompactionSelector
• model::InMemValTransaction
• model::Transactional
• model::ValTransaction
• rpc::election::ElectionClient
• rpc::election::sql::SqlDriver
• rpc::election::sql::SqlDriverCommon
• stream::stream_graph::id::GlobalFragmentIdsExt

Macros

• backup_restore::meta_snapshot_builder::define_set_metadata
• backup_restore::restore_impl::v2::reset_mysql_sequence
• bail_invalid_parameter
• bail_unavailable
• controller::scale::crit_check_in_loop
• controller::system_param::impl_merge_params
• controller::system_param::impl_system_params_from_db
• controller::system_param::impl_system_params_to_models
• error::bail_invalid_parameter
• error::bail_unavailable
• error::invalid_parameter
• error::unavailable
• for_all_auto_increment
• hummock::compaction::compaction_config::builder_field
• hummock::manager::start_measure_real_process_timer
• hummock::manager::utils::commit_multi_var
• hummock::manager::utils::commit_multi_var_with_provided_txn
• invalid_parameter
• manager::sink_coordination::manager::send_await_with_err_check
• manager::sink_coordination::manager::send_with_err_check
• unavailable

Functions

• backup_restore::backup_manager::create_snapshot_store
• backup_restore::meta_snapshot_builder::map_db_err
• backup_restore::meta_snapshot_builder::set_metadata
• backup_restore::restore
• backup_restore::restore::dispatch
• backup_restore::restore::restore
• backup_restore::restore::restore_hummock_version
• backup_restore::restore::restore_impl
• backup_restore::restore_impl::v2::insert_models
• backup_restore::restore_impl::v2::map_db_err
• backup_restore::restore_impl::v2::update_auto_inc
• backup_restore::utils::get_backup_store
• backup_restore::utils::get_meta_store
• barrier::progress::calculate_total_key_count
• barrier::rpc::from_partial_graph_id
• barrier::rpc::merge_node_rpc_errors
• barrier::rpc::to_partial_graph_id
• barrier::schedule::tracing_span
• barrier::utils::collect_creating_job_commit_epoch_info
• barrier::utils::collect_resp_info
• controller::catalog::update_internal_tables
• controller::cluster::meta_node_info
• controller::cluster::timestamp_now_sec
• controller::rename::alter_relation_rename
• controller::rename::alter_relation_rename_refs
• controller::rename::replace_table_name
• controller::scale::construct_no_shuffle_downstream_traverse_query
• controller::scale::construct_no_shuffle_traverse_query_helper
• controller::scale::construct_no_shuffle_upstream_traverse_query
• controller::scale::resolve_no_shuffle_query
• controller::streaming_job::bitflag_intersects
• controller::streaming_job::fragment_type_mask_intersects
• controller::system_param::apply_hard_code_override
• controller::system_param::merge_params
• controller::system_param::system_params_from_db
• controller::system_param::system_params_to_model
• controller::utils::build_relation_group_for_delete
• controller::utils::check_connection_name_duplicate
• controller::utils::check_database_name_duplicate
• controller::utils::check_function_signature_duplicate
• controller::utils::check_relation_name_duplicate
• controller::utils::check_schema_name_duplicate
• controller::utils::check_secret_name_duplicate
• controller::utils::check_sink_into_table_cycle
• controller::utils::check_subscription_name_duplicate
• controller::utils::check_user_name_duplicate
• controller::utils::construct_obj_dependency_query
• controller::utils::construct_privilege_dependency_query
• controller::utils::construct_sink_cycle_check_query
• controller::utils::ensure_object_id
• controller::utils::ensure_object_not_refer
• controller::utils::ensure_privileges_not_referred
• controller::utils::ensure_schema_empty
• controller::utils::ensure_user_id
• controller::utils::extract_external_table_name_from_definition
• controller::utils::extract_grant_obj_id
• controller::utils::find_stream_source
• controller::utils::get_actor_dispatchers
• controller::utils::get_fragment_actor_ids
• controller::utils::get_fragment_ids_by_jobs
• controller::utils::get_fragment_mappings
• controller::utils::get_index_state_tables_by_table_id
• controller::utils::get_internal_tables_by_id
• controller::utils::get_object_owner
• controller::utils::get_referring_objects
• controller::utils::get_referring_objects_cascade
• controller::utils::get_referring_privileges_cascade
• controller::utils::get_user_privilege
• controller::utils::list_user_info_by_ids
• controller::utils::rebuild_fragment_mapping_from_actors
• controller::utils::rename_relation
• controller::utils::rename_relation_refer
• controller::utils::resolve_source_register_info_for_jobs
• dashboard::handlers::analyze_heap
• dashboard::handlers::diagnose
• dashboard::handlers::dump_await_tree
• dashboard::handlers::dump_await_tree_all
• dashboard::handlers::dump_await_tree_inner
• dashboard::handlers::err
• dashboard::handlers::get_embedded_back_pressures
• dashboard::handlers::get_fragment_vertex_to_relation_id_map
• dashboard::handlers::get_relation_id_infos
• dashboard::handlers::get_version
• dashboard::handlers::heap_profile
• dashboard::handlers::list_clusters
• dashboard::handlers::list_databases
• dashboard::handlers::list_fragments_by_job_id
• dashboard::handlers::list_heap_profile
• dashboard::handlers::list_indexes
• dashboard::handlers::list_internal_tables
• dashboard::handlers::list_materialized_views
• dashboard::handlers::list_object_dependencies
• dashboard::handlers::list_schemas
• dashboard::handlers::list_sinks
• dashboard::handlers::list_sources
• dashboard::handlers::list_streaming_jobs
• dashboard::handlers::list_subscription
• dashboard::handlers::list_table_catalogs_inner
• dashboard::handlers::list_tables
• dashboard::handlers::list_users
• dashboard::handlers::list_views
• dashboard::prometheus::list_prometheus_cluster
• dashboard::prometheus::list_prometheus_fragment_back_pressure
• hummock::check_cg_write_limit
• hummock::compaction::compaction_config::validate_compaction_config
• hummock::compaction::create_compaction_task
• hummock::compaction::create_overlap_strategy
• hummock::compaction::get_compression_algorithm
• hummock::compaction::overlap_strategy::check_table_overlap
• hummock::compaction::picker::vnode_watermark_picker::should_delete_key_by_watermark
• hummock::compaction::picker::vnode_watermark_picker::should_delete_sst_by_watermark
• hummock::compaction::selector::default_compaction_selector
• hummock::compaction::selector::vnode_watermark_selector::safe_epoch_read_table_watermarks
• hummock::manager::commit_epoch::on_handle_add_new_table
• hummock::manager::compaction::check_cg_write_limit
• hummock::manager::compaction::compaction_group_manager::update_compaction_config
• hummock::manager::compaction::compaction_group_schedule::check_is_creating_compaction_group
• hummock::manager::compaction::compaction_group_schedule::check_is_low_write_throughput_compaction_group
• hummock::manager::compaction::compaction_group_schedule::is_table_high_write_throughput
• hummock::manager::compaction::compaction_group_schedule::is_table_low_write_throughput
• hummock::manager::compaction::init_selectors
• hummock::manager::compaction::update_table_stats_for_vnode_watermark_trivial_reclaim
• hummock::manager::context::check_gc_history
• hummock::manager::context::check_sst_retention
• hummock::manager::context::trigger_safepoint_stat
• hummock::manager::gc::collect_min_uncommitted_sst_id
• hummock::manager::sequence::next_compaction_group_id
• hummock::manager::sequence::next_compaction_task_id
• hummock::manager::sequence::next_meta_backup_id
• hummock::manager::sequence::next_sstable_object_id
• hummock::manager::time_travel::find_root_group
• hummock::manager::time_travel::replay_archive
• hummock::manager::time_travel::require_sql_meta_store_err
• hummock::manager::time_travel::should_ignore_group
• hummock::manager::time_travel::should_mark_next_time_travel_version_snapshot
• hummock::manager::transaction::trigger_delta_log_stats
• hummock::manager::transaction::trigger_version_stat
• hummock::manager::versioning::calc_new_write_limits
• hummock::manager::versioning::estimate_table_stats
• hummock::manager::versioning::rebuild_table_stats
• hummock::manager::write_exclusive_cluster_id
• hummock::metrics_utils::build_compact_task_l0_stat_metrics_label
• hummock::metrics_utils::build_compact_task_level_type_metrics_label
• hummock::metrics_utils::build_compact_task_stat_metrics_label
• hummock::metrics_utils::build_level_l0_metrics_label
• hummock::metrics_utils::build_level_metrics_label
• hummock::metrics_utils::get_or_create_local_table_stat
• hummock::metrics_utils::remove_compact_task_metrics
• hummock::metrics_utils::remove_compacting_task_stat
• hummock::metrics_utils::remove_compaction_group_in_sst_stat
• hummock::metrics_utils::remove_compaction_group_stat
• hummock::metrics_utils::remove_split_stat
• hummock::metrics_utils::trigger_gc_stat
• hummock::metrics_utils::trigger_local_table_stat
• hummock::metrics_utils::trigger_lsm_stat
• hummock::metrics_utils::trigger_mv_stat
• hummock::metrics_utils::trigger_pin_unpin_version_state
• hummock::metrics_utils::trigger_split_stat
• hummock::metrics_utils::trigger_sst_stat
• hummock::metrics_utils::trigger_write_stop_stats
• hummock::mock_hummock_meta_client::mock_err
• hummock::sequence::next_compaction_group_id
• hummock::sequence::next_compaction_task_id
• hummock::sequence::next_meta_backup_id
• hummock::sequence::next_sstable_object_id
• hummock::start_checkpoint_loop
• hummock::start_hummock_workers
• hummock::start_vacuum_metadata_loop
• hummock::test_utils::add_ssts
• hummock::test_utils::add_test_tables
• hummock::test_utils::compaction_selector_context
• hummock::test_utils::generate_test_sstables_with_table_id
• hummock::test_utils::generate_test_tables
• hummock::test_utils::get_compaction_group_id_by_table_id
• hummock::test_utils::get_sorted_committed_object_ids
• hummock::test_utils::get_sorted_object_ids
• hummock::test_utils::get_sst_ids
• hummock::test_utils::iterator_test_key_of_epoch
• hummock::test_utils::register_sstable_infos_to_compaction_group
• hummock::test_utils::register_table_ids_to_compaction_group
• hummock::test_utils::setup_compute_env
• hummock::test_utils::setup_compute_env_with_config
• hummock::test_utils::setup_compute_env_with_metric
• hummock::test_utils::to_local_sstable_info
• hummock::test_utils::unregister_table_ids_from_compaction_group
• hummock::time_travel::require_sql_meta_store_err
• hummock::time_travel::should_mark_next_time_travel_version_snapshot
• manager::diagnose::merge_prometheus_selector
• manager::diagnose::redact_all_sql_options
• manager::diagnose::try_add_cell
• manager::env::is_first_launch_for_sql_backend_cluster
• manager::event_log::keep_latest_n
• manager::event_log::start_event_log_manager
• manager::get_referred_secret_ids_from_sink
• manager::get_referred_secret_ids_from_source
• manager::is_first_launch_for_sql_backend_cluster
• manager::sink_coordination::coordinator_worker::run_future_with_periodic_fn
• rpc::metrics::refresh_fragment_info_metrics
• rpc::metrics::start_fragment_info_monitor
• rpc::metrics::start_worker_info_monitor
• serving::fetch_serving_infos
• serving::on_meta_start
• serving::start_serving_vnode_mapping_worker
• serving::to_deleted_fragment_worker_slot_mapping
• serving::to_fragment_worker_slot_mapping
• stream::build_actor_connector_splits
• stream::build_actor_split_impls
• stream::create_source_worker_handle
• stream::rebalance_actor_vnode
• stream::scale::rebalance_actor_vnode
• stream::scale::schedule_units_for_slots
• stream::schedule_units_for_slots
• stream::sink::validate_sink
• stream::source_manager::align_backfill_splits
• stream::source_manager::build_actor_connector_splits
• stream::source_manager::build_actor_split_impls
• stream::source_manager::create_source_worker_handle
• stream::source_manager::extract_prop_from_existing_source
• stream::source_manager::extract_prop_from_new_source
• stream::source_manager::reassign_splits
• stream::stream_graph::fragment::mv_on_mv_dispatch_strategy
• stream::validate_sink
• telemetry::report_event

Type Aliases

• backup_restore::BackupManagerRef
• backup_restore::backup_manager::BackupManagerRef
• backup_restore::backup_manager::StoreConfig
• barrier::BarrierManagerRef
• barrier::manager::BarrierManagerRef
• barrier::progress::ConsumedRows
• controller::catalog::Catalog
• controller::catalog::CatalogControllerRef
• controller::cluster::ClusterControllerRef
• controller::id::IdCategoryType
• controller::id::IdGeneratorManagerRef
• controller::session_params::SessionParamsControllerRef
• controller::system_param::SystemParamsControllerRef
• dashboard::Service
• dashboard::handlers::Result
• dashboard::prometheus::Result
• error::MetaResult
• hummock::HummockManagerRef
• hummock::compactor_manager::CompactorManagerRef
• hummock::error::Result
• hummock::manager::HummockManagerRef
• hummock::manager::compaction::CompactionRequestChannelItem
• hummock::manager::compaction::compaction_group_manager::CompactionGroupTransaction
• hummock::manager::worker::HummockManagerEventReceiver
• hummock::manager::worker::HummockManagerEventSender
• hummock::model::ext::Transaction
• hummock::model::ext::hummock::Transaction
• manager::IdleManagerRef
• manager::MessageStatus
• manager::Notification
• manager::NotificationManagerRef
• manager::NotificationVersion
• manager::diagnose::DiagnoseCommandRef
• manager::event_log::Channel
• manager::event_log::ChannelId
• manager::event_log::EventLogManagerRef
• manager::event_log::EventLogSender
• manager::event_log::EventStoreRef
• manager::event_log::ShutdownSender
• manager::idle::IdleManagerRef
• manager::notification::MessageStatus
• manager::notification::Notification
• manager::notification::NotificationManagerRef
• manager::notification::NotificationVersion
• manager::notification::SenderMap
• manager::sink_coordination::SinkCoordinatorResponseSender
• manager::sink_coordination::SinkWriterRequestStream
• model::ActorId
• model::BTreeMapTransaction
• model::DispatcherId
• model::FragmentId
• model::MetadataModelResult
• model::SubscriptionId
• model::error::MetadataModelResult
• rpc::ElectionClientRef
• serving::ServingVnodeMappingRef
• storage::ColumnFamily
• storage::Key
• storage::MetaStoreResult
• storage::Value
• stream::GlobalStreamManagerRef
• stream::ScaleControllerRef
• stream::SourceManagerRef
• stream::SplitAssignment
• stream::ThrottleConfig
• stream::scale::ScaleControllerRef
• stream::source_manager::SharedSplitMapRef
• stream::source_manager::SourceManagerRef
• stream::source_manager::SplitAssignment
• stream::source_manager::ThrottleConfig
• stream::stream_graph::actor::ActorLocations
• stream::stream_graph::id::GlobalActorId
• stream::stream_graph::id::GlobalActorIdGen
• stream::stream_graph::id::GlobalFragmentId
• stream::stream_graph::id::GlobalFragmentIdGen
• stream::stream_graph::id::GlobalTableIdGen
• stream::stream_graph::schedule::HashMappingId
• stream::stream_manager::CreatingStreamingJobInfoRef
• stream::stream_manager::GlobalStreamManagerRef

Trait Aliases

• manager::sink_coordination::manager::SpawnCoordinatorFn

Statics

• backup_restore::metrics::GLOBAL_BACKUP_MANAGER_METRICS
• hummock::manager::compaction::CANCEL_STATUS_SET
• hummock::manager::sequence::SEQ_INIT
• rpc::metrics::GLOBAL_META_METRICS
• stream::stream_graph::fragment::EMPTY_HASHMAP

Constants

• backup_restore::meta_snapshot_builder::VERSION
• barrier::rpc::COLLECT_ERROR_TIMEOUT
• controller::IN_MEMORY_STORE
• controller::id::IdCategory::Actor
• controller::id::IdCategory::Fragment
• controller::id::IdCategory::Table
• hummock::compaction::picker::base_level_compaction_picker::LOG_COUNTER
• hummock::compaction::picker::ttl_reclaim_compaction_picker::MIN_TTL_EXPIRE_INTERVAL_MS
• hummock::compaction::selector::level_selector::SCORE_BASE
• hummock::compactor_manager::TASK_NORMAL
• hummock::compactor_manager::TASK_NOT_FOUND
• hummock::compactor_manager::TASK_RUN_TOO_LONG
• hummock::manager::compaction::MAX_REPORT_COUNT
• hummock::manager::compaction::MAX_SKIP_TIMES
• hummock::metrics_utils::MIN_FLUSH_COUNT
• hummock::metrics_utils::MIN_FLUSH_DATA_SIZE
• manager::IGNORED_NOTIFICATION_VERSION
• manager::META_NODE_ID
• manager::notification::IGNORED_NOTIFICATION_VERSION
• manager::sink_coordination::manager::BOUNDED_CHANNEL_SIZE
• rpc::election::META_ELECTION_KEY
• stream::source_manager::DEFAULT_SOURCE_TICK_TIMEOUT
• stream::source_manager::DEFAULT_SOURCE_WORKER_TICK_INTERVAL
• stream::source_manager::MAX_FAIL_CNT
• telemetry::TELEMETRY_META_REPORT_TYPE