risingwave_pb/

hummock.rs

// This file is @generated by prost-build.
/// Key range for a single vnode within an SST.
/// Keys are always represented as closed intervals: \[min_key, max_key\].
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct VnodeUserKeyRange {
    #[prost(bytes = "vec", tag = "1")]
    pub min_key: ::prost::alloc::vec::Vec<u8>,
    #[prost(bytes = "vec", tag = "2")]
    pub max_key: ::prost::alloc::vec::Vec<u8>,
}
/// Optional per-vnode statistics for SSTs with few vnodes.
/// Enables more precise query pruning by providing vnode-level key ranges.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VnodeStatistics {
    #[prost(map = "uint32, message", tag = "1")]
    pub vnode_user_key_ranges: ::std::collections::HashMap<u32, VnodeUserKeyRange>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SstableInfo {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockSstableObjectId")]
    pub object_id: crate::id::HummockSstableObjectId,
    #[prost(uint64, tag = "2", wrapper = "crate::id::HummockSstableId")]
    pub sst_id: crate::id::HummockSstableId,
    #[prost(message, optional, tag = "3")]
    pub key_range: ::core::option::Option<KeyRange>,
    /// represents the physical object size, which is usually used in the builder.
    #[prost(uint64, tag = "4")]
    pub file_size: u64,
    #[prost(uint32, repeated, tag = "5", wrapper = "crate::id::TableId")]
    pub table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
    #[prost(uint64, tag = "6")]
    pub meta_offset: u64,
    #[prost(uint64, tag = "7")]
    pub stale_key_count: u64,
    #[prost(uint64, tag = "8")]
    pub total_key_count: u64,
    #[prost(uint64, tag = "9")]
    pub min_epoch: u64,
    #[prost(uint64, tag = "10")]
    pub max_epoch: u64,
    #[prost(uint64, tag = "11")]
    pub uncompressed_file_size: u64,
    #[prost(uint64, tag = "12")]
    pub range_tombstone_count: u64,
    #[prost(enumeration = "BloomFilterType", tag = "13")]
    pub bloom_filter_kind: i32,
    /// In order to calculate more finely in the compaction strategy, we need to re-calculate the sst_size after split sst
    /// `sst_size` represents the size of the sst instead of the object size(usually used in the meta).
    #[prost(uint64, tag = "14")]
    pub sst_size: u64,
    /// Optional per-vnode statistics for query pruning when the SST spans only a small set of vnodes.
    /// Only emitted when SST contains multiple vnodes to avoid redundancy with key_range.
    #[prost(message, optional, tag = "15")]
    pub vnode_statistics: ::core::option::Option<VnodeStatistics>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct OverlappingLevel {
    #[prost(message, repeated, tag = "1")]
    pub sub_levels: ::prost::alloc::vec::Vec<Level>,
    #[prost(uint64, tag = "2")]
    pub total_file_size: u64,
    #[prost(uint64, tag = "3")]
    pub uncompressed_file_size: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Level {
    #[prost(uint32, tag = "1")]
    pub level_idx: u32,
    #[prost(enumeration = "LevelType", tag = "2")]
    pub level_type: i32,
    #[prost(message, repeated, tag = "3")]
    pub table_infos: ::prost::alloc::vec::Vec<SstableInfo>,
    #[prost(uint64, tag = "4")]
    pub total_file_size: u64,
    #[prost(uint64, tag = "5")]
    pub sub_level_id: u64,
    #[prost(uint64, tag = "6")]
    pub uncompressed_file_size: u64,
    #[prost(uint32, tag = "7")]
    pub vnode_partition_count: u32,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InputLevel {
    #[prost(uint32, tag = "1")]
    pub level_idx: u32,
    #[prost(enumeration = "LevelType", tag = "2")]
    pub level_type: i32,
    #[prost(message, repeated, tag = "3")]
    pub table_infos: ::prost::alloc::vec::Vec<SstableInfo>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct NewL0SubLevel {
    #[prost(message, repeated, tag = "1")]
    pub inserted_table_infos: ::prost::alloc::vec::Vec<SstableInfo>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct IntraLevelDelta {
    #[prost(uint32, tag = "1")]
    pub level_idx: u32,
    #[prost(uint64, tag = "2")]
    pub l0_sub_level_id: u64,
    #[prost(uint64, repeated, tag = "3", wrapper = "crate::id::HummockSstableId")]
    pub removed_table_ids: ::prost::alloc::vec::Vec<crate::id::HummockSstableId>,
    #[prost(message, repeated, tag = "4")]
    pub inserted_table_infos: ::prost::alloc::vec::Vec<SstableInfo>,
    #[prost(uint32, tag = "5")]
    pub vnode_partition_count: u32,
    #[prost(uint64, tag = "6")]
    pub compaction_group_version_id: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GroupConstruct {
    #[prost(message, optional, tag = "1")]
    pub group_config: ::core::option::Option<CompactionConfig>,
    /// If parent_group_id is not 0, it means parent_group_id splits into parent_group_id and this group, so this group is not empty initially.
    #[prost(uint64, tag = "2", wrapper = "crate::id::CompactionGroupId")]
    pub parent_group_id: crate::id::CompactionGroupId,
    #[deprecated]
    #[prost(uint32, repeated, packed = "false", tag = "3")]
    pub table_ids: ::prost::alloc::vec::Vec<u32>,
    #[prost(uint64, tag = "4", wrapper = "crate::id::CompactionGroupId")]
    pub group_id: crate::id::CompactionGroupId,
    #[prost(uint64, tag = "5", wrapper = "crate::id::HummockSstableId")]
    pub new_sst_start_id: crate::id::HummockSstableId,
    #[prost(enumeration = "CompatibilityVersion", tag = "6")]
    pub version: i32,
    /// The split_key is the key that the group is split by.
    /// When GroupConstruct with commit_epoch, split_key will be empty
    /// When split_key is not None, GroupConstruct tells to use split_key to check each level and split the sstable_info in the level into two groups (bounded by split_key).
    /// For the left sstable_info, split_key (right_exclusive=true) will be used as key_range_right.
    /// In the current implementation split_key always contains a table_id, vnode = 0, epoch = MAX
    #[prost(bytes = "vec", optional, tag = "7")]
    pub split_key: ::core::option::Option<::prost::alloc::vec::Vec<u8>>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GroupDestroy {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GroupMerge {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub left_group_id: crate::id::CompactionGroupId,
    #[prost(uint64, tag = "2", wrapper = "crate::id::CompactionGroupId")]
    pub right_group_id: crate::id::CompactionGroupId,
}
/// TruncateTables is used to truncate multiple tables from sstables.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TruncateTables {
    #[prost(uint32, repeated, tag = "1", wrapper = "crate::id::TableId")]
    pub table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GroupDelta {
    #[prost(oneof = "group_delta::DeltaType", tags = "1, 2, 3, 6, 7, 8")]
    pub delta_type: ::core::option::Option<group_delta::DeltaType>,
}
/// Nested message and enum types in `GroupDelta`.
pub mod group_delta {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum DeltaType {
        #[prost(message, tag = "1")]
        IntraLevel(super::IntraLevelDelta),
        #[prost(message, tag = "2")]
        GroupConstruct(super::GroupConstruct),
        #[prost(message, tag = "3")]
        GroupDestroy(super::GroupDestroy),
        #[prost(message, tag = "6")]
        GroupMerge(super::GroupMerge),
        #[prost(message, tag = "7")]
        NewL0SubLevel(super::NewL0SubLevel),
        #[prost(message, tag = "8")]
        TruncateTables(super::TruncateTables),
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct VnodeWatermark {
    /// The watermark shared by multiple vnodes
    #[prost(bytes = "vec", tag = "1")]
    pub watermark: ::prost::alloc::vec::Vec<u8>,
    /// The set of vnodes that share the same watermark
    #[prost(message, optional, tag = "2")]
    pub vnode_bitmap: ::core::option::Option<super::common::Buffer>,
}
/// Table watermark is a lighter weight range delete introduced in
/// <https://github.com/risingwavelabs/risingwave/issues/13148>
/// It means the lowest (or highest when `is_ascending` is false) visible
/// keys in the table within a vnode. Keys lower (or higher) than the
/// table watermark is invisible and will be cleaned in later compaction.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableWatermarks {
    /// Table watermarks of a state table from all vnodes written in multiple epochs.
    /// Epochs should be sorted in ascending order, which means earlier epoch at the front
    #[prost(message, repeated, tag = "1")]
    pub epoch_watermarks: ::prost::alloc::vec::Vec<table_watermarks::EpochNewWatermarks>,
    /// The direction of the table watermark.
    #[prost(bool, tag = "2")]
    pub is_ascending: bool,
    /// The table watermark is non-pk prefix table watermark.
    /// Deprecated. use WatermarkSerdeType instead;
    #[deprecated]
    #[prost(bool, tag = "3")]
    pub is_non_pk_prefix: bool,
    #[prost(enumeration = "WatermarkSerdeType", tag = "4")]
    pub raw_watermark_serde_type: i32,
}
/// Nested message and enum types in `TableWatermarks`.
pub mod table_watermarks {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct EpochNewWatermarks {
        #[prost(message, repeated, tag = "1")]
        pub watermarks: ::prost::alloc::vec::Vec<super::VnodeWatermark>,
        #[prost(uint64, tag = "2")]
        pub epoch: u64,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct EpochNewChangeLog {
    #[prost(message, repeated, tag = "1")]
    pub old_value: ::prost::alloc::vec::Vec<SstableInfo>,
    #[prost(message, repeated, tag = "2")]
    pub new_value: ::prost::alloc::vec::Vec<SstableInfo>,
    /// Epochs should be sorted in ascending order, which means earlier epoch at the front
    #[prost(uint64, repeated, tag = "3")]
    pub epochs: ::prost::alloc::vec::Vec<u64>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct TableChangeLog {
    /// Epochs should be sorted in ascending order, which means earlier epoch at the front.
    #[prost(message, repeated, tag = "1")]
    pub change_logs: ::prost::alloc::vec::Vec<EpochNewChangeLog>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct StateTableInfo {
    #[prost(uint64, tag = "1")]
    pub committed_epoch: u64,
    #[prost(uint64, tag = "3", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct StateTableInfoDelta {
    #[prost(uint64, tag = "1")]
    pub committed_epoch: u64,
    #[prost(uint64, tag = "3", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct VectorIndexObject {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockRawObjectId")]
    pub id: crate::id::HummockRawObjectId,
    #[prost(enumeration = "VectorIndexObjectType", tag = "2")]
    pub object_type: i32,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct VectorFileInfo {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockVectorFileId")]
    pub object_id: crate::id::HummockVectorFileId,
    #[prost(uint64, tag = "2")]
    pub file_size: u64,
    #[prost(uint64, tag = "3")]
    pub start_vector_id: u64,
    #[prost(uint32, tag = "4")]
    pub vector_count: u32,
    #[prost(uint64, tag = "5")]
    pub meta_offset: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FlatIndex {
    #[prost(message, optional, tag = "1")]
    pub config: ::core::option::Option<super::catalog::FlatIndexConfig>,
    #[prost(message, repeated, tag = "2")]
    pub vector_files: ::prost::alloc::vec::Vec<VectorFileInfo>,
    #[prost(uint64, tag = "3")]
    pub next_vector_id: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct FlatIndexAdd {
    #[prost(message, repeated, tag = "1")]
    pub added_vector_files: ::prost::alloc::vec::Vec<VectorFileInfo>,
    #[prost(uint64, tag = "2")]
    pub next_vector_id: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HnswGraph {
    #[prost(message, repeated, tag = "1")]
    pub nodes: ::prost::alloc::vec::Vec<hnsw_graph::HnswNode>,
    #[prost(uint64, tag = "2")]
    pub entrypoint_id: u64,
}
/// Nested message and enum types in `HnswGraph`.
pub mod hnsw_graph {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, Copy, PartialEq, ::prost::Message)]
    pub struct HnswNeighbor {
        #[prost(uint64, tag = "1")]
        pub vector_id: u64,
        #[prost(double, tag = "2")]
        pub distance: f64,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct HnswLevel {
        #[prost(message, repeated, tag = "1")]
        pub neighbors: ::prost::alloc::vec::Vec<HnswNeighbor>,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct HnswNode {
        #[prost(message, repeated, tag = "1")]
        pub levels: ::prost::alloc::vec::Vec<HnswLevel>,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HnswGraphFileInfo {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockHnswGraphFileId")]
    pub object_id: crate::id::HummockHnswGraphFileId,
    #[prost(uint64, tag = "2")]
    pub file_size: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HnswFlatIndex {
    #[prost(message, optional, tag = "1")]
    pub config: ::core::option::Option<super::catalog::HnswFlatIndexConfig>,
    #[prost(message, repeated, tag = "2")]
    pub vector_files: ::prost::alloc::vec::Vec<VectorFileInfo>,
    #[prost(uint64, tag = "3")]
    pub next_vector_id: u64,
    #[prost(message, optional, tag = "4")]
    pub graph_file: ::core::option::Option<HnswGraphFileInfo>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HnswFlatIndexAdd {
    #[prost(message, repeated, tag = "1")]
    pub added_vector_files: ::prost::alloc::vec::Vec<VectorFileInfo>,
    #[prost(uint64, tag = "2")]
    pub next_vector_id: u64,
    #[prost(message, optional, tag = "3")]
    pub graph_file: ::core::option::Option<HnswGraphFileInfo>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VectorIndex {
    #[prost(uint32, tag = "1")]
    pub dimension: u32,
    #[prost(enumeration = "super::common::DistanceType", tag = "2")]
    pub distance_type: i32,
    #[prost(oneof = "vector_index::Variant", tags = "65, 66")]
    pub variant: ::core::option::Option<vector_index::Variant>,
}
/// Nested message and enum types in `VectorIndex`.
pub mod vector_index {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Variant {
        /// reserve 64 general configs
        #[prost(message, tag = "65")]
        Flat(super::FlatIndex),
        #[prost(message, tag = "66")]
        HnswFlat(super::HnswFlatIndex),
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VectorIndexDelta {
    #[prost(oneof = "vector_index_delta::Delta", tags = "1, 2")]
    pub delta: ::core::option::Option<vector_index_delta::Delta>,
}
/// Nested message and enum types in `VectorIndexDelta`.
pub mod vector_index_delta {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct VectorIndexInit {
        #[prost(message, optional, tag = "1")]
        pub info: ::core::option::Option<super::super::catalog::VectorIndexInfo>,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct VectorIndexAdd {
        #[prost(oneof = "vector_index_add::Add", tags = "65, 66")]
        pub add: ::core::option::Option<vector_index_add::Add>,
    }
    /// Nested message and enum types in `VectorIndexAdd`.
    pub mod vector_index_add {
        #[derive(prost_helpers::AnyPB)]
        #[derive(Clone, PartialEq, ::prost::Oneof)]
        pub enum Add {
            /// reserve 64 general configs
            #[prost(message, tag = "65")]
            Flat(super::super::FlatIndexAdd),
            #[prost(message, tag = "66")]
            HnswFlat(super::super::HnswFlatIndexAdd),
        }
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct VectorIndexAdds {
        #[prost(message, repeated, tag = "1")]
        pub adds: ::prost::alloc::vec::Vec<VectorIndexAdd>,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Delta {
        #[prost(message, tag = "1")]
        Init(VectorIndexInit),
        #[prost(message, tag = "2")]
        Adds(VectorIndexAdds),
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HummockVersion {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockVersionId")]
    pub id: crate::id::HummockVersionId,
    /// Levels of each compaction group
    #[prost(
        map = "uint64, message",
        tag = "2",
        wrapper = "crate::id::CompactionGroupId"
    )]
    pub levels: ::std::collections::HashMap<
        crate::id::CompactionGroupId,
        hummock_version::Levels,
    >,
    #[deprecated]
    #[prost(uint64, tag = "3")]
    pub max_committed_epoch: u64,
    #[prost(map = "uint32, message", tag = "5", wrapper = "crate::id::TableId")]
    pub table_watermarks: ::std::collections::HashMap<
        crate::id::TableId,
        TableWatermarks,
    >,
    #[prost(map = "uint32, message", tag = "6", wrapper = "crate::id::TableId")]
    pub table_change_logs: ::std::collections::HashMap<
        crate::id::TableId,
        TableChangeLog,
    >,
    #[prost(map = "uint32, message", tag = "7", wrapper = "crate::id::TableId")]
    pub state_table_info: ::std::collections::HashMap<
        crate::id::TableId,
        StateTableInfo,
    >,
    #[prost(map = "uint32, message", tag = "8", wrapper = "crate::id::TableId")]
    pub vector_indexes: ::std::collections::HashMap<crate::id::TableId, VectorIndex>,
}
/// Nested message and enum types in `HummockVersion`.
pub mod hummock_version {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct Levels {
        #[prost(message, repeated, tag = "1")]
        pub levels: ::prost::alloc::vec::Vec<super::Level>,
        #[prost(message, optional, tag = "2")]
        pub l0: ::core::option::Option<super::OverlappingLevel>,
        #[prost(uint64, tag = "3", wrapper = "crate::id::CompactionGroupId")]
        pub group_id: crate::id::CompactionGroupId,
        #[prost(uint64, tag = "4", wrapper = "crate::id::CompactionGroupId")]
        pub parent_group_id: crate::id::CompactionGroupId,
        #[deprecated]
        #[prost(uint32, repeated, packed = "false", tag = "5")]
        pub member_table_ids: ::prost::alloc::vec::Vec<u32>,
        #[prost(uint64, tag = "6")]
        pub compaction_group_version_id: u64,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HummockVersionDelta {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockVersionId")]
    pub id: crate::id::HummockVersionId,
    #[prost(uint64, tag = "2", wrapper = "crate::id::HummockVersionId")]
    pub prev_id: crate::id::HummockVersionId,
    /// Levels of each compaction group
    #[prost(
        map = "uint64, message",
        tag = "3",
        wrapper = "crate::id::CompactionGroupId"
    )]
    pub group_deltas: ::std::collections::HashMap<
        crate::id::CompactionGroupId,
        hummock_version_delta::GroupDeltas,
    >,
    #[deprecated]
    #[prost(uint64, tag = "4")]
    pub max_committed_epoch: u64,
    #[prost(bool, tag = "6")]
    pub trivial_move: bool,
    #[prost(map = "uint32, message", tag = "8", wrapper = "crate::id::TableId")]
    pub new_table_watermarks: ::std::collections::HashMap<
        crate::id::TableId,
        TableWatermarks,
    >,
    #[prost(uint32, repeated, tag = "9", wrapper = "crate::id::TableId")]
    pub removed_table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
    #[prost(map = "uint32, message", tag = "10", wrapper = "crate::id::TableId")]
    pub change_log_delta: ::std::collections::HashMap<
        crate::id::TableId,
        hummock_version_delta::ChangeLogDelta,
    >,
    #[prost(map = "uint32, message", tag = "11", wrapper = "crate::id::TableId")]
    pub state_table_info_delta: ::std::collections::HashMap<
        crate::id::TableId,
        StateTableInfoDelta,
    >,
    #[prost(map = "uint32, message", tag = "12", wrapper = "crate::id::TableId")]
    pub vector_index_delta: ::std::collections::HashMap<
        crate::id::TableId,
        VectorIndexDelta,
    >,
}
/// Nested message and enum types in `HummockVersionDelta`.
pub mod hummock_version_delta {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct GroupDeltas {
        #[prost(message, repeated, tag = "1")]
        pub group_deltas: ::prost::alloc::vec::Vec<super::GroupDelta>,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ChangeLogDelta {
        #[prost(message, optional, tag = "1")]
        pub new_log: ::core::option::Option<super::EpochNewChangeLog>,
        /// only logs in epoch later than truncate_epoch will be preserved
        #[prost(uint64, tag = "2")]
        pub truncate_epoch: u64,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HummockVersionDeltas {
    #[prost(message, repeated, tag = "1")]
    pub version_deltas: ::prost::alloc::vec::Vec<HummockVersionDelta>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HummockVersionCheckpoint {
    #[prost(message, optional, tag = "1")]
    pub version: ::core::option::Option<HummockVersion>,
    #[prost(map = "uint64, message", tag = "2", wrapper = "crate::id::HummockVersionId")]
    pub stale_objects: ::std::collections::HashMap<
        crate::id::HummockVersionId,
        hummock_version_checkpoint::StaleObjects,
    >,
}
/// Nested message and enum types in `HummockVersionCheckpoint`.
pub mod hummock_version_checkpoint {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct StaleObjects {
        #[prost(
            uint64,
            repeated,
            tag = "1",
            wrapper = "crate::id::HummockSstableObjectId"
        )]
        pub id: ::prost::alloc::vec::Vec<crate::id::HummockSstableObjectId>,
        #[prost(uint64, tag = "2")]
        pub total_file_size: u64,
        #[prost(message, repeated, tag = "3")]
        pub vector_files: ::prost::alloc::vec::Vec<super::VectorIndexObject>,
    }
}
/// Envelope message wrapping a compressed or uncompressed HummockVersionCheckpoint.
/// When compression_algorithm is NONE (or UNSPECIFIED), payload contains raw PbHummockVersionCheckpoint bytes.
/// Otherwise, payload contains the compressed PbHummockVersionCheckpoint bytes.
///
/// Backward compatibility:
///
/// * Old code (unaware of this message) writes raw PbHummockVersionCheckpoint directly.
/// * New code tries to decode as HummockVersionCheckpointEnvelope first.
///   If it fails (old format), it falls back to decoding as PbHummockVersionCheckpoint.
/// * Legacy bytes may occasionally decode as an envelope due to protobuf's unknown-field
///   skipping, so readers treat `checksum` as the discriminator: all new envelopes set it,
///   while old raw checkpoints do not have field 3.
///
/// Format detection logic:
///
/// 1. Try to decode bytes as HummockVersionCheckpointEnvelope
/// 1. If checksum.is_some(), treat as new envelope format:
///    a. Verify checksum against payload
///    b. Decompress payload according to compression_algorithm
///    c. Decode decompressed bytes as PbHummockVersionCheckpoint
/// 1. If checksum.is_none() or decode fails, treat as legacy format:
///    * Decode bytes directly as PbHummockVersionCheckpoint
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HummockVersionCheckpointEnvelope {
    #[prost(enumeration = "CheckpointCompressionAlgorithm", tag = "1")]
    pub compression_algorithm: i32,
    /// Compressed (or uncompressed if algorithm is NONE) PbHummockVersionCheckpoint bytes.
    #[prost(bytes = "vec", tag = "2")]
    pub payload: ::prost::alloc::vec::Vec<u8>,
    /// xxhash64 checksum of the payload bytes (compressed data) for integrity verification.
    /// Presence of this field distinguishes new envelope format from legacy raw checkpoints.
    #[prost(uint64, optional, tag = "3")]
    pub checksum: ::core::option::Option<u64>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HummockVersionArchive {
    #[prost(message, optional, tag = "1")]
    pub version: ::core::option::Option<HummockVersion>,
    /// some version_deltas since version
    #[prost(message, repeated, tag = "2")]
    pub version_deltas: ::prost::alloc::vec::Vec<HummockVersionDelta>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct VersionUpdatePayload {
    #[prost(oneof = "version_update_payload::Payload", tags = "1, 2")]
    pub payload: ::core::option::Option<version_update_payload::Payload>,
}
/// Nested message and enum types in `VersionUpdatePayload`.
pub mod version_update_payload {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Payload {
        #[prost(message, tag = "1")]
        VersionDeltas(super::HummockVersionDeltas),
        #[prost(message, tag = "2")]
        PinnedVersion(super::HummockVersion),
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct UnpinVersionBeforeRequest {
    #[prost(uint32, tag = "1", wrapper = "crate::id::WorkerId")]
    pub context_id: crate::id::WorkerId,
    #[prost(uint64, tag = "2", wrapper = "crate::id::HummockVersionId")]
    pub unpin_version_before: crate::id::HummockVersionId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct UnpinVersionBeforeResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetCurrentVersionRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCurrentVersionResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
    #[prost(message, optional, tag = "2")]
    pub current_version: ::core::option::Option<HummockVersion>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetTableChangeLogsRequest {
    /// If true, returns only the epoch without the full log bodies.
    #[prost(bool, tag = "1")]
    pub epoch_only: bool,
    #[prost(bool, tag = "2")]
    pub exclude_empty: bool,
    /// Defines the epoch range to fetch.
    #[prost(uint64, optional, tag = "3")]
    pub start_epoch_inclusive: ::core::option::Option<u64>,
    #[prost(uint64, optional, tag = "4")]
    pub end_epoch_inclusive: ::core::option::Option<u64>,
    /// Defines the tables to fetch.
    #[prost(message, optional, tag = "5")]
    pub table_ids: ::core::option::Option<get_table_change_logs_request::TableFilter>,
    /// Limit the number of `EpochNewChangeLog` returned for each table.
    #[prost(uint32, optional, tag = "6")]
    pub limit: ::core::option::Option<u32>,
}
/// Nested message and enum types in `GetTableChangeLogsRequest`.
pub mod get_table_change_logs_request {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct TableFilter {
        #[prost(uint32, repeated, tag = "1", wrapper = "crate::id::TableId")]
        pub table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetTableChangeLogsResponse {
    #[prost(map = "uint32, message", tag = "1")]
    pub table_change_logs: ::std::collections::HashMap<u32, TableChangeLog>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct UnpinVersionRequest {
    #[prost(uint32, tag = "1", wrapper = "crate::id::WorkerId")]
    pub context_id: crate::id::WorkerId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct UnpinVersionResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetAssignedCompactTaskNumRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetAssignedCompactTaskNumResponse {
    #[prost(uint32, tag = "1")]
    pub num_tasks: u32,
}
/// When right_exclusive=false, it represents \[left, right\], of which both boundary are open. When right_exclusive=true,
/// it represents \[left, right), of which right is exclusive.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct KeyRange {
    #[prost(bytes = "vec", tag = "1")]
    pub left: ::prost::alloc::vec::Vec<u8>,
    #[prost(bytes = "vec", tag = "2")]
    pub right: ::prost::alloc::vec::Vec<u8>,
    #[prost(bool, tag = "3")]
    pub right_exclusive: bool,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TableOption {
    #[prost(uint32, optional, tag = "2")]
    pub retention_seconds: ::core::option::Option<u32>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TableSchema {
    #[prost(int32, repeated, tag = "1")]
    pub column_ids: ::prost::alloc::vec::Vec<i32>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CompactTask {
    /// SSTs to be compacted, which will be removed from LSM after compaction
    #[prost(message, repeated, tag = "1")]
    pub input_ssts: ::prost::alloc::vec::Vec<InputLevel>,
    /// In ideal case, the compaction will generate splits.len() tables which have key range
    /// corresponding to that in \[splits\], respectively
    #[prost(message, repeated, tag = "2")]
    pub splits: ::prost::alloc::vec::Vec<KeyRange>,
    /// compaction output, which will be added to \[target_level\] of LSM after compaction
    #[prost(message, repeated, tag = "4")]
    pub sorted_output_ssts: ::prost::alloc::vec::Vec<SstableInfo>,
    /// task id assigned by hummock storage service
    #[prost(uint64, tag = "5")]
    pub task_id: u64,
    /// compaction output will be added to \[target_level\] of LSM after compaction
    #[prost(uint32, tag = "6")]
    pub target_level: u32,
    #[prost(bool, tag = "7")]
    pub gc_delete_keys: bool,
    /// Lbase in LSM
    #[prost(uint32, tag = "8")]
    pub base_level: u32,
    #[prost(enumeration = "compact_task::TaskStatus", tag = "9")]
    pub task_status: i32,
    /// compaction group the task belongs to
    #[prost(uint64, tag = "12", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
    /// existing_table_ids for compaction drop key
    #[prost(uint32, repeated, tag = "13", wrapper = "crate::id::TableId")]
    pub existing_table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
    #[prost(uint32, tag = "14")]
    pub compression_algorithm: u32,
    #[prost(uint64, tag = "15")]
    pub target_file_size: u64,
    #[prost(uint32, tag = "16")]
    pub compaction_filter_mask: u32,
    #[prost(btree_map = "uint32, message", tag = "17", wrapper = "crate::id::TableId")]
    pub table_options: ::prost::alloc::collections::BTreeMap<
        crate::id::TableId,
        TableOption,
    >,
    #[prost(uint64, tag = "18")]
    pub current_epoch_time: u64,
    #[prost(uint64, tag = "19")]
    pub target_sub_level_id: u64,
    /// Identifies whether the task is space_reclaim, if the compact_task_type increases, it will be refactored to enum
    #[prost(enumeration = "compact_task::TaskType", tag = "20")]
    pub task_type: i32,
    /// Deprecated. use table_vnode_partition instead;
    #[deprecated]
    #[prost(bool, tag = "21")]
    pub split_by_state_table: bool,
    /// Compaction needs to cut the state table every time 1/weight of vnodes in the table have been processed.
    /// Deprecated. use table_vnode_partition instead;
    #[prost(uint32, tag = "22")]
    pub split_weight_by_vnode: u32,
    #[prost(btree_map = "uint32, uint32", tag = "23", wrapper = "crate::id::TableId")]
    pub table_vnode_partition: ::prost::alloc::collections::BTreeMap<
        crate::id::TableId,
        u32,
    >,
    /// The table watermark of any table id. In compaction we only use the table watermarks on safe epoch,
    /// so we only need to include the table watermarks on safe epoch to reduce the size of metadata.
    #[prost(btree_map = "uint32, message", tag = "24", wrapper = "crate::id::TableId")]
    pub table_watermarks: ::prost::alloc::collections::BTreeMap<
        crate::id::TableId,
        TableWatermarks,
    >,
    /// The table schemas that are at least as new as the one used to create `input_ssts`.
    #[prost(btree_map = "uint32, message", tag = "25", wrapper = "crate::id::TableId")]
    pub table_schemas: ::prost::alloc::collections::BTreeMap<
        crate::id::TableId,
        TableSchema,
    >,
    /// Max sub compaction task numbers
    #[prost(uint32, tag = "26")]
    pub max_sub_compaction: u32,
    /// The compaction group id when the compaction task is created.
    #[prost(uint64, tag = "27")]
    pub compaction_group_version_id: u64,
    /// The maximum key-value count threshold for using Xor16 filter.
    /// When the number of keys exceeds this threshold, a BlockedXor16 filter will be used.
    #[prost(uint64, optional, tag = "28")]
    pub max_kv_count_for_xor16: ::core::option::Option<u64>,
    /// Max bytes for vnode-level key range hints to embed into output SSTs.
    #[prost(uint64, optional, tag = "29")]
    pub max_vnode_key_range_bytes: ::core::option::Option<u64>,
}
/// Nested message and enum types in `CompactTask`.
pub mod compact_task {
    #[derive(prost_helpers::AnyPB)]
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum TaskStatus {
        Unspecified = 0,
        Pending = 1,
        Success = 2,
        HeartbeatCanceled = 3,
        NoAvailMemoryResourceCanceled = 4,
        AssignFailCanceled = 5,
        SendFailCanceled = 6,
        ManualCanceled = 7,
        InvalidGroupCanceled = 8,
        InputOutdatedCanceled = 9,
        ExecuteFailed = 10,
        JoinHandleFailed = 11,
        TrackSstObjectIdFailed = 12,
        NoAvailCpuResourceCanceled = 13,
        HeartbeatProgressCanceled = 14,
        RetentionTimeRejected = 17,
        /// for serverless compaction
        ServerlessSendFailCanceled = 15,
        ServerlessTableNotFoundCanceled = 16,
    }
    impl TaskStatus {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                Self::Unspecified => "UNSPECIFIED",
                Self::Pending => "PENDING",
                Self::Success => "SUCCESS",
                Self::HeartbeatCanceled => "HEARTBEAT_CANCELED",
                Self::NoAvailMemoryResourceCanceled => {
                    "NO_AVAIL_MEMORY_RESOURCE_CANCELED"
                }
                Self::AssignFailCanceled => "ASSIGN_FAIL_CANCELED",
                Self::SendFailCanceled => "SEND_FAIL_CANCELED",
                Self::ManualCanceled => "MANUAL_CANCELED",
                Self::InvalidGroupCanceled => "INVALID_GROUP_CANCELED",
                Self::InputOutdatedCanceled => "INPUT_OUTDATED_CANCELED",
                Self::ExecuteFailed => "EXECUTE_FAILED",
                Self::JoinHandleFailed => "JOIN_HANDLE_FAILED",
                Self::TrackSstObjectIdFailed => "TRACK_SST_OBJECT_ID_FAILED",
                Self::NoAvailCpuResourceCanceled => "NO_AVAIL_CPU_RESOURCE_CANCELED",
                Self::HeartbeatProgressCanceled => "HEARTBEAT_PROGRESS_CANCELED",
                Self::RetentionTimeRejected => "RETENTION_TIME_REJECTED",
                Self::ServerlessSendFailCanceled => "SERVERLESS_SEND_FAIL_CANCELED",
                Self::ServerlessTableNotFoundCanceled => {
                    "SERVERLESS_TABLE_NOT_FOUND_CANCELED"
                }
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNSPECIFIED" => Some(Self::Unspecified),
                "PENDING" => Some(Self::Pending),
                "SUCCESS" => Some(Self::Success),
                "HEARTBEAT_CANCELED" => Some(Self::HeartbeatCanceled),
                "NO_AVAIL_MEMORY_RESOURCE_CANCELED" => {
                    Some(Self::NoAvailMemoryResourceCanceled)
                }
                "ASSIGN_FAIL_CANCELED" => Some(Self::AssignFailCanceled),
                "SEND_FAIL_CANCELED" => Some(Self::SendFailCanceled),
                "MANUAL_CANCELED" => Some(Self::ManualCanceled),
                "INVALID_GROUP_CANCELED" => Some(Self::InvalidGroupCanceled),
                "INPUT_OUTDATED_CANCELED" => Some(Self::InputOutdatedCanceled),
                "EXECUTE_FAILED" => Some(Self::ExecuteFailed),
                "JOIN_HANDLE_FAILED" => Some(Self::JoinHandleFailed),
                "TRACK_SST_OBJECT_ID_FAILED" => Some(Self::TrackSstObjectIdFailed),
                "NO_AVAIL_CPU_RESOURCE_CANCELED" => {
                    Some(Self::NoAvailCpuResourceCanceled)
                }
                "HEARTBEAT_PROGRESS_CANCELED" => Some(Self::HeartbeatProgressCanceled),
                "RETENTION_TIME_REJECTED" => Some(Self::RetentionTimeRejected),
                "SERVERLESS_SEND_FAIL_CANCELED" => Some(Self::ServerlessSendFailCanceled),
                "SERVERLESS_TABLE_NOT_FOUND_CANCELED" => {
                    Some(Self::ServerlessTableNotFoundCanceled)
                }
                _ => None,
            }
        }
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum TaskType {
        TypeUnspecified = 0,
        Dynamic = 1,
        SpaceReclaim = 2,
        Manual = 3,
        SharedBuffer = 4,
        Ttl = 5,
        Tombstone = 6,
        Emergency = 7,
        VnodeWatermark = 8,
    }
    impl TaskType {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                Self::TypeUnspecified => "TYPE_UNSPECIFIED",
                Self::Dynamic => "DYNAMIC",
                Self::SpaceReclaim => "SPACE_RECLAIM",
                Self::Manual => "MANUAL",
                Self::SharedBuffer => "SHARED_BUFFER",
                Self::Ttl => "TTL",
                Self::Tombstone => "TOMBSTONE",
                Self::Emergency => "EMERGENCY",
                Self::VnodeWatermark => "VNODE_WATERMARK",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "TYPE_UNSPECIFIED" => Some(Self::TypeUnspecified),
                "DYNAMIC" => Some(Self::Dynamic),
                "SPACE_RECLAIM" => Some(Self::SpaceReclaim),
                "MANUAL" => Some(Self::Manual),
                "SHARED_BUFFER" => Some(Self::SharedBuffer),
                "TTL" => Some(Self::Ttl),
                "TOMBSTONE" => Some(Self::Tombstone),
                "EMERGENCY" => Some(Self::Emergency),
                "VNODE_WATERMARK" => Some(Self::VnodeWatermark),
                _ => None,
            }
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LevelHandler {
    #[prost(uint32, tag = "1")]
    pub level: u32,
    #[prost(message, repeated, tag = "3")]
    pub tasks: ::prost::alloc::vec::Vec<level_handler::RunningCompactTask>,
}
/// Nested message and enum types in `LevelHandler`.
pub mod level_handler {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct RunningCompactTask {
        #[prost(uint64, tag = "1")]
        pub task_id: u64,
        #[prost(uint64, repeated, tag = "2", wrapper = "crate::id::HummockSstableId")]
        pub ssts: ::prost::alloc::vec::Vec<crate::id::HummockSstableId>,
        #[prost(uint64, tag = "3")]
        pub total_file_size: u64,
        #[prost(uint32, tag = "4")]
        pub target_level: u32,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CompactStatus {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
    #[prost(message, repeated, tag = "2")]
    pub level_handlers: ::prost::alloc::vec::Vec<LevelHandler>,
}
/// Config info of compaction group.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CompactionGroup {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub id: crate::id::CompactionGroupId,
    #[prost(message, optional, tag = "4")]
    pub compaction_config: ::core::option::Option<CompactionConfig>,
}
/// Complete info of compaction group.
/// The info is the aggregate of HummockVersion and CompactionGroupConfig
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CompactionGroupInfo {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub id: crate::id::CompactionGroupId,
    #[prost(uint64, tag = "2", wrapper = "crate::id::CompactionGroupId")]
    pub parent_id: crate::id::CompactionGroupId,
    #[prost(uint32, repeated, tag = "3", wrapper = "crate::id::TableId")]
    pub member_table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
    #[prost(message, optional, tag = "4")]
    pub compaction_config: ::core::option::Option<CompactionConfig>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CompactTaskAssignment {
    #[prost(message, optional, tag = "1")]
    pub compact_task: ::core::option::Option<CompactTask>,
    #[prost(uint32, tag = "2", wrapper = "crate::id::WorkerId")]
    pub context_id: crate::id::WorkerId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HummockPinnedVersion {
    #[prost(uint32, tag = "1", wrapper = "crate::id::WorkerId")]
    pub context_id: crate::id::WorkerId,
    #[prost(uint64, tag = "2", wrapper = "crate::id::HummockVersionId")]
    pub min_pinned_id: crate::id::HummockVersionId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct HummockPinnedSnapshot {
    #[prost(uint32, tag = "1", wrapper = "crate::id::WorkerId")]
    pub context_id: crate::id::WorkerId,
    #[prost(uint64, tag = "2")]
    pub minimal_pinned_snapshot: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetNewObjectIdsRequest {
    #[prost(uint32, tag = "1")]
    pub number: u32,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetNewObjectIdsResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
    /// inclusive
    #[prost(uint64, tag = "2", wrapper = "crate::id::HummockRawObjectId")]
    pub start_id: crate::id::HummockRawObjectId,
    /// exclusive
    #[prost(uint64, tag = "3", wrapper = "crate::id::HummockRawObjectId")]
    pub end_id: crate::id::HummockRawObjectId,
}
/// This is a heartbeat message. Task will be considered dead if
/// CompactTaskProgress is not received for a timeout
/// or num_ssts_sealed/num_ssts_uploaded do not increase for a timeout.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CompactTaskProgress {
    #[prost(uint64, tag = "1")]
    pub task_id: u64,
    #[prost(uint32, tag = "2")]
    pub num_ssts_sealed: u32,
    #[prost(uint32, tag = "3")]
    pub num_ssts_uploaded: u32,
    #[prost(uint64, tag = "4")]
    pub num_progress_key: u64,
    #[prost(uint64, tag = "5")]
    pub num_pending_read_io: u64,
    #[prost(uint64, tag = "6")]
    pub num_pending_write_io: u64,
    #[prost(uint64, optional, tag = "7", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: ::core::option::Option<crate::id::CompactionGroupId>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SubscribeCompactionEventRequest {
    #[prost(uint64, tag = "7")]
    pub create_at: u64,
    #[prost(oneof = "subscribe_compaction_event_request::Event", tags = "1, 2, 3, 4")]
    pub event: ::core::option::Option<subscribe_compaction_event_request::Event>,
}
/// Nested message and enum types in `SubscribeCompactionEventRequest`.
pub mod subscribe_compaction_event_request {
    /// Register provides the context_id of the corresponding Compactor.
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct Register {
        #[prost(uint32, tag = "1", wrapper = "crate::id::WorkerId")]
        pub context_id: crate::id::WorkerId,
    }
    /// PullTask provides the number of tasks needed for the Compactor.
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct PullTask {
        #[prost(uint32, tag = "4")]
        pub pull_task_count: u32,
    }
    /// ReportTask provides the compact task to report to the meta.
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ReportTask {
        #[prost(map = "uint32, message", tag = "3", wrapper = "crate::id::TableId")]
        pub table_stats_change: ::std::collections::HashMap<
            crate::id::TableId,
            super::TableStats,
        >,
        #[prost(uint64, tag = "4")]
        pub task_id: u64,
        #[prost(enumeration = "super::compact_task::TaskStatus", tag = "5")]
        pub task_status: i32,
        #[prost(message, repeated, tag = "6")]
        pub sorted_output_ssts: ::prost::alloc::vec::Vec<super::SstableInfo>,
        #[prost(
            map = "uint64, uint64",
            tag = "7",
            wrapper = "crate::id::HummockSstableObjectId"
        )]
        pub object_timestamps: ::std::collections::HashMap<
            crate::id::HummockSstableObjectId,
            u64,
        >,
    }
    /// HeartBeat provides the progress status of all tasks on the Compactor.
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct HeartBeat {
        #[prost(message, repeated, tag = "2")]
        pub progress: ::prost::alloc::vec::Vec<super::CompactTaskProgress>,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Event {
        /// Compactor will register its own context_id with Meta via Register and establish a bi-directional streaming rpc.
        #[prost(message, tag = "1")]
        Register(Register),
        /// Compactor will recalculate the number of tasks needed locally after receiving the PullTaskAck and get the next batch of tasks from Meta via PullTask.
        #[prost(message, tag = "2")]
        PullTask(PullTask),
        /// When the execution of each task completes/fails, Compactor returns the task to the meta via ReportTask.
        #[prost(message, tag = "3")]
        ReportTask(ReportTask),
        /// Periodically, HeartBeat carries the progress of all tasks on the Compactor, and the meta will cancel the task when it expires.
        #[prost(message, tag = "4")]
        HeartBeat(HeartBeat),
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SubscribeCompactionEventResponse {
    #[prost(uint64, tag = "7")]
    pub create_at: u64,
    #[prost(
        oneof = "subscribe_compaction_event_response::Event",
        tags = "1, 2, 3, 4, 5, 6"
    )]
    pub event: ::core::option::Option<subscribe_compaction_event_response::Event>,
}
/// Nested message and enum types in `SubscribeCompactionEventResponse`.
pub mod subscribe_compaction_event_response {
    /// PullTaskAck is a response, the meta will return a PullTaskAck after distributing the task requested by the PullTask.
    /// The Compactor receives the PullTaskAck and remakes its state and tries to initiate the next PullTask.
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct PullTaskAck {}
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Event {
        #[prost(message, tag = "1")]
        CompactTask(super::CompactTask),
        #[deprecated]
        #[prost(message, tag = "2")]
        VacuumTask(super::VacuumTask),
        #[deprecated]
        #[prost(message, tag = "3")]
        FullScanTask(super::FullScanTask),
        #[deprecated]
        #[prost(message, tag = "4")]
        ValidationTask(super::ValidationTask),
        #[prost(message, tag = "5")]
        CancelCompactTask(super::CancelCompactTask),
        #[prost(message, tag = "6")]
        PullTaskAck(PullTaskAck),
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReportCompactionTaskRequest {
    #[prost(oneof = "report_compaction_task_request::Event", tags = "1, 2")]
    pub event: ::core::option::Option<report_compaction_task_request::Event>,
}
/// Nested message and enum types in `ReportCompactionTaskRequest`.
pub mod report_compaction_task_request {
    /// ReportTask provides the compact task to report to the meta.
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct ReportTask {
        #[prost(message, optional, tag = "2")]
        pub compact_task: ::core::option::Option<super::CompactTask>,
        #[prost(map = "uint32, message", tag = "3", wrapper = "crate::id::TableId")]
        pub table_stats_change: ::std::collections::HashMap<
            crate::id::TableId,
            super::TableStats,
        >,
        #[prost(
            map = "uint64, uint64",
            tag = "4",
            wrapper = "crate::id::HummockSstableObjectId"
        )]
        pub object_timestamps: ::std::collections::HashMap<
            crate::id::HummockSstableObjectId,
            u64,
        >,
    }
    /// HeartBeat provides the progress status of all tasks on the Compactor.
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Message)]
    pub struct HeartBeat {
        #[prost(message, repeated, tag = "2")]
        pub progress: ::prost::alloc::vec::Vec<super::CompactTaskProgress>,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, ::prost::Oneof)]
    pub enum Event {
        #[prost(message, tag = "1")]
        ReportTask(ReportTask),
        #[prost(message, tag = "2")]
        HeartBeat(HeartBeat),
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ReportCompactionTaskResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ValidationTask {
    #[prost(message, repeated, tag = "1")]
    pub sst_infos: ::prost::alloc::vec::Vec<SstableInfo>,
    #[prost(
        map = "uint64, uint32",
        tag = "2",
        wrapper = "crate::id::HummockSstableObjectId ->crate::id:: WorkerId"
    )]
    pub sst_id_to_worker_id: ::std::collections::HashMap<
        crate::id::HummockSstableObjectId,
        crate::id::WorkerId,
    >,
}
/// Delete SSTs in object store
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct VacuumTask {
    #[prost(uint64, repeated, tag = "1", wrapper = "crate::id::HummockSstableObjectId")]
    pub sstable_object_ids: ::prost::alloc::vec::Vec<crate::id::HummockSstableObjectId>,
}
/// Scan object store to get candidate orphan SSTs.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct FullScanTask {
    #[prost(uint64, tag = "1")]
    pub sst_retention_watermark: u64,
    #[prost(string, optional, tag = "2")]
    pub prefix: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(string, optional, tag = "3")]
    pub start_after: ::core::option::Option<::prost::alloc::string::String>,
    #[prost(uint64, optional, tag = "4")]
    pub limit: ::core::option::Option<u64>,
}
/// Cancel compact task
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CancelCompactTask {
    #[prost(uint32, tag = "1", wrapper = "crate::id::WorkerId")]
    pub context_id: crate::id::WorkerId,
    #[prost(uint64, tag = "2")]
    pub task_id: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TriggerManualCompactionRequest {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
    #[prost(message, optional, tag = "2")]
    pub key_range: ::core::option::Option<KeyRange>,
    #[prost(uint32, tag = "3", wrapper = "crate::id::JobId")]
    pub table_id: crate::id::JobId,
    #[prost(uint32, tag = "4")]
    pub level: u32,
    #[prost(uint64, repeated, tag = "5", wrapper = "crate::id::HummockSstableId")]
    pub sst_ids: ::prost::alloc::vec::Vec<crate::id::HummockSstableId>,
    #[prost(bool, optional, tag = "6")]
    pub exclusive: ::core::option::Option<bool>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TriggerManualCompactionResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
    #[prost(bool, optional, tag = "2")]
    pub should_retry: ::core::option::Option<bool>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TriggerFullGcRequest {
    #[prost(uint64, tag = "1")]
    pub sst_retention_time_sec: u64,
    #[prost(string, optional, tag = "2")]
    pub prefix: ::core::option::Option<::prost::alloc::string::String>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TriggerFullGcResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ListVersionDeltasRequest {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockVersionId")]
    pub start_id: crate::id::HummockVersionId,
    #[prost(uint32, tag = "2")]
    pub num_limit: u32,
    #[prost(uint64, tag = "3")]
    pub committed_epoch_limit: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListVersionDeltasResponse {
    #[prost(message, optional, tag = "1")]
    pub version_deltas: ::core::option::Option<HummockVersionDeltas>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PinnedVersionsSummary {
    #[prost(message, repeated, tag = "1")]
    pub pinned_versions: ::prost::alloc::vec::Vec<HummockPinnedVersion>,
    #[prost(map = "uint32, message", tag = "2", wrapper = "crate::id::WorkerId")]
    pub workers: ::std::collections::HashMap<
        crate::id::WorkerId,
        super::common::WorkerNode,
    >,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlGetPinnedVersionsSummaryRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RiseCtlGetPinnedVersionsSummaryResponse {
    #[prost(message, optional, tag = "1")]
    pub summary: ::core::option::Option<PinnedVersionsSummary>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct InitMetadataForReplayRequest {
    #[prost(message, repeated, tag = "1")]
    pub tables: ::prost::alloc::vec::Vec<super::catalog::Table>,
    #[prost(message, repeated, tag = "2")]
    pub compaction_groups: ::prost::alloc::vec::Vec<CompactionGroupInfo>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct InitMetadataForReplayResponse {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReplayVersionDeltaRequest {
    #[prost(message, optional, tag = "1")]
    pub version_delta: ::core::option::Option<HummockVersionDelta>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ReplayVersionDeltaResponse {
    #[prost(message, optional, tag = "1")]
    pub version: ::core::option::Option<HummockVersion>,
    #[prost(uint64, repeated, tag = "2", wrapper = "crate::id::CompactionGroupId")]
    pub modified_compaction_groups: ::prost::alloc::vec::Vec<
        crate::id::CompactionGroupId,
    >,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TriggerCompactionDeterministicRequest {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockVersionId")]
    pub version_id: crate::id::HummockVersionId,
    #[prost(uint64, repeated, tag = "2", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_groups: ::prost::alloc::vec::Vec<crate::id::CompactionGroupId>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TriggerCompactionDeterministicResponse {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct DisableCommitEpochRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DisableCommitEpochResponse {
    #[prost(message, optional, tag = "1")]
    pub current_version: ::core::option::Option<HummockVersion>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlListCompactionGroupRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RiseCtlListCompactionGroupResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
    #[prost(message, repeated, tag = "2")]
    pub compaction_groups: ::prost::alloc::vec::Vec<CompactionGroupInfo>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RiseCtlUpdateCompactionConfigRequest {
    #[prost(uint64, repeated, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_ids: ::prost::alloc::vec::Vec<crate::id::CompactionGroupId>,
    #[prost(message, repeated, tag = "2")]
    pub configs: ::prost::alloc::vec::Vec<
        rise_ctl_update_compaction_config_request::MutableConfig,
    >,
}
/// Nested message and enum types in `RiseCtlUpdateCompactionConfigRequest`.
pub mod rise_ctl_update_compaction_config_request {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct CompressionAlgorithm {
        #[prost(uint32, tag = "1")]
        pub level: u32,
        #[prost(string, tag = "2")]
        pub compression_algorithm: ::prost::alloc::string::String,
    }
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct MutableConfig {
        #[prost(
            oneof = "mutable_config::MutableConfig",
            tags = "1, 2, 3, 4, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 25, 26, 27, 28, 29, 30, 31, 32, 33"
        )]
        pub mutable_config: ::core::option::Option<mutable_config::MutableConfig>,
    }
    /// Nested message and enum types in `MutableConfig`.
    pub mod mutable_config {
        #[derive(prost_helpers::AnyPB)]
        #[derive(Clone, PartialEq, Eq, Hash, ::prost::Oneof)]
        pub enum MutableConfig {
            #[prost(uint64, tag = "1")]
            MaxBytesForLevelBase(u64),
            #[prost(uint64, tag = "2")]
            MaxBytesForLevelMultiplier(u64),
            #[prost(uint64, tag = "3")]
            MaxCompactionBytes(u64),
            #[prost(uint64, tag = "4")]
            SubLevelMaxCompactionBytes(u64),
            #[prost(uint64, tag = "6")]
            Level0TierCompactFileNumber(u64),
            #[prost(uint64, tag = "7")]
            TargetFileSizeBase(u64),
            #[prost(uint32, tag = "8")]
            CompactionFilterMask(u32),
            #[prost(uint32, tag = "9")]
            MaxSubCompaction(u32),
            #[prost(uint64, tag = "10")]
            Level0StopWriteThresholdSubLevelNumber(u64),
            #[prost(uint32, tag = "11")]
            Level0SubLevelCompactLevelCount(u32),
            #[prost(uint32, tag = "12")]
            Level0OverlappingSubLevelCompactLevelCount(u32),
            #[prost(uint64, tag = "13")]
            MaxSpaceReclaimBytes(u64),
            #[prost(uint64, tag = "14")]
            Level0MaxCompactFileNumber(u64),
            #[prost(bool, tag = "15")]
            EnableEmergencyPicker(bool),
            #[prost(uint32, tag = "16")]
            TombstoneReclaimRatio(u32),
            #[prost(message, tag = "17")]
            CompressionAlgorithm(super::CompressionAlgorithm),
            #[prost(uint32, tag = "18")]
            MaxL0CompactLevelCount(u32),
            #[prost(uint64, tag = "19")]
            SstAllowedTrivialMoveMinSize(u64),
            #[prost(uint32, tag = "20")]
            SplitWeightByVnode(u32),
            #[prost(bool, tag = "21")]
            DisableAutoGroupScheduling(bool),
            #[prost(uint64, tag = "22")]
            MaxOverlappingLevelSize(u64),
            /// The emergency compaction limitations for the level0 sstables file count
            #[prost(uint32, tag = "25")]
            EmergencyLevel0SstFileCount(u32),
            /// The emergency compaction limitations for the level0 sub level partition
            #[prost(uint32, tag = "26")]
            EmergencyLevel0SubLevelPartition(u32),
            /// The limitation of the max sst size of the level0 to trigger the write stop
            #[prost(uint32, tag = "27")]
            Level0StopWriteThresholdMaxSstCount(u32),
            /// The limitation of the max sst size of the level0 to trigger the write stop
            #[prost(uint64, tag = "28")]
            Level0StopWriteThresholdMaxSize(u64),
            /// The limitation of the max sst count of the trivial move task
            #[prost(uint32, tag = "29")]
            SstAllowedTrivialMoveMaxCount(u32),
            /// Enable the optimization of the interval selection for the level0 compaction
            #[prost(bool, tag = "30")]
            EnableOptimizeL0IntervalSelection(bool),
            /// Deprecated. Kept for backward compatibility and ignored by meta.
            #[deprecated]
            #[prost(uint64, tag = "31")]
            VnodeAlignedLevelSizeThreshold(u64),
            /// The maximum key-value count threshold for using Xor16 filter
            #[prost(uint64, tag = "32")]
            MaxKvCountForXor16(u64),
            /// Max bytes for vnode key-range hints recorded into each SST.
            #[prost(uint64, tag = "33")]
            MaxVnodeKeyRangeBytes(u64),
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlUpdateCompactionConfigResponse {
    #[prost(message, optional, tag = "1")]
    pub status: ::core::option::Option<super::common::Status>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct PinVersionRequest {
    #[prost(uint32, tag = "1", wrapper = "crate::id::WorkerId")]
    pub context_id: crate::id::WorkerId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct PinVersionResponse {
    #[prost(message, optional, tag = "1")]
    pub pinned_version: ::core::option::Option<HummockVersion>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct SplitCompactionGroupRequest {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub group_id: crate::id::CompactionGroupId,
    #[prost(uint32, repeated, tag = "2", wrapper = "crate::id::TableId")]
    pub table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
    #[prost(uint32, tag = "3")]
    pub partition_vnode_count: u32,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct SplitCompactionGroupResponse {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub new_group_id: crate::id::CompactionGroupId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlPauseVersionCheckpointRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlPauseVersionCheckpointResponse {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlResumeVersionCheckpointRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlResumeVersionCheckpointResponse {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlGetCheckpointVersionRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RiseCtlGetCheckpointVersionResponse {
    #[prost(message, optional, tag = "1")]
    pub checkpoint_version: ::core::option::Option<HummockVersion>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlListCompactionStatusRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct RiseCtlListCompactionStatusResponse {
    #[prost(message, repeated, tag = "1")]
    pub compaction_statuses: ::prost::alloc::vec::Vec<CompactStatus>,
    #[prost(message, repeated, tag = "2")]
    pub task_assignment: ::prost::alloc::vec::Vec<CompactTaskAssignment>,
    #[prost(message, repeated, tag = "3")]
    pub task_progress: ::prost::alloc::vec::Vec<CompactTaskProgress>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ListBranchedObjectRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListBranchedObjectResponse {
    #[prost(message, repeated, tag = "1")]
    pub branched_objects: ::prost::alloc::vec::Vec<BranchedObject>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ListActiveWriteLimitRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListActiveWriteLimitResponse {
    /// \< compaction group id, write limit info >
    #[prost(
        map = "uint64, message",
        tag = "1",
        wrapper = "crate::id::CompactionGroupId"
    )]
    pub write_limits: ::std::collections::HashMap<
        crate::id::CompactionGroupId,
        write_limits::WriteLimit,
    >,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ListHummockMetaConfigRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListHummockMetaConfigResponse {
    #[prost(map = "string, string", tag = "1")]
    pub configs: ::std::collections::HashMap<
        ::prost::alloc::string::String,
        ::prost::alloc::string::String,
    >,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlRebuildTableStatsRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct RiseCtlRebuildTableStatsResponse {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetCompactionScoreRequest {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetCompactionScoreResponse {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
    #[prost(message, repeated, tag = "2")]
    pub scores: ::prost::alloc::vec::Vec<get_compaction_score_response::PickerInfo>,
}
/// Nested message and enum types in `GetCompactionScoreResponse`.
pub mod get_compaction_score_response {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct PickerInfo {
        #[prost(uint64, tag = "1")]
        pub score: u64,
        #[prost(uint64, tag = "2")]
        pub select_level: u64,
        #[prost(uint64, tag = "3")]
        pub target_level: u64,
        #[prost(string, tag = "4")]
        pub picker_type: ::prost::alloc::string::String,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ListCompactTaskAssignmentRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListCompactTaskAssignmentResponse {
    #[prost(message, repeated, tag = "1")]
    pub task_assignment: ::prost::alloc::vec::Vec<CompactTaskAssignment>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct ListCompactTaskProgressRequest {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListCompactTaskProgressResponse {
    #[prost(message, repeated, tag = "1")]
    pub task_progress: ::prost::alloc::vec::Vec<CompactTaskProgress>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CancelCompactTaskRequest {
    #[prost(uint64, tag = "1")]
    pub task_id: u64,
    #[prost(enumeration = "compact_task::TaskStatus", tag = "2")]
    pub task_status: i32,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CancelCompactTaskResponse {
    #[prost(bool, tag = "1")]
    pub ret: bool,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct GetVersionByEpochRequest {
    #[prost(uint64, tag = "1")]
    pub epoch: u64,
    #[prost(uint32, tag = "2", wrapper = "crate::id::TableId")]
    pub table_id: crate::id::TableId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetVersionByEpochResponse {
    #[prost(message, optional, tag = "1")]
    pub version: ::core::option::Option<HummockVersion>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct MergeCompactionGroupRequest {
    #[prost(uint64, tag = "1", wrapper = "crate::id::CompactionGroupId")]
    pub left_group_id: crate::id::CompactionGroupId,
    #[prost(uint64, tag = "2", wrapper = "crate::id::CompactionGroupId")]
    pub right_group_id: crate::id::CompactionGroupId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct MergeCompactionGroupResponse {}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct CompactionConfig {
    #[prost(uint64, tag = "1")]
    pub max_bytes_for_level_base: u64,
    #[prost(uint64, tag = "2")]
    pub max_level: u64,
    #[prost(uint64, tag = "3")]
    pub max_bytes_for_level_multiplier: u64,
    #[prost(uint64, tag = "4")]
    pub max_compaction_bytes: u64,
    #[prost(uint64, tag = "5")]
    pub sub_level_max_compaction_bytes: u64,
    #[prost(uint64, tag = "7")]
    pub level0_tier_compact_file_number: u64,
    #[prost(enumeration = "compaction_config::CompactionMode", tag = "8")]
    pub compaction_mode: i32,
    #[prost(string, repeated, tag = "9")]
    pub compression_algorithm: ::prost::alloc::vec::Vec<::prost::alloc::string::String>,
    #[prost(uint64, tag = "10")]
    pub target_file_size_base: u64,
    #[prost(uint32, tag = "11")]
    pub compaction_filter_mask: u32,
    #[prost(uint32, tag = "12")]
    pub max_sub_compaction: u32,
    #[prost(uint64, tag = "13")]
    pub max_space_reclaim_bytes: u64,
    #[prost(bool, tag = "14")]
    pub split_by_state_table: bool,
    /// Compaction needs to cut the state table every time 1/weight of vnodes in the table have been processed.
    #[prost(uint32, tag = "6")]
    pub split_weight_by_vnode: u32,
    /// soft limit for max number of sub level number
    #[prost(uint64, tag = "15")]
    pub level0_stop_write_threshold_sub_level_number: u64,
    #[prost(uint64, tag = "16")]
    pub level0_max_compact_file_number: u64,
    #[prost(uint32, tag = "17")]
    pub level0_sub_level_compact_level_count: u32,
    /// for tier compaction pick overlapping level
    #[prost(uint32, tag = "18")]
    pub level0_overlapping_sub_level_compact_level_count: u32,
    #[prost(uint32, tag = "19")]
    pub tombstone_reclaim_ratio: u32,
    #[prost(bool, tag = "20")]
    pub enable_emergency_picker: bool,
    /// The limitation of the level count of l0 compaction
    #[prost(uint32, optional, tag = "21")]
    pub max_l0_compact_level_count: ::core::option::Option<u32>,
    /// The limitation of base level trivial move sst size
    #[prost(uint64, optional, tag = "22")]
    pub sst_allowed_trivial_move_min_size: ::core::option::Option<u64>,
    /// The limitation of auto group scheduling
    #[prost(bool, optional, tag = "23")]
    pub disable_auto_group_scheduling: ::core::option::Option<bool>,
    /// The limitation of the max size of the overlapping-level for the compaction
    /// hummock will reorg the commit-sstables to the multi overlapping-level if the size of the commit-sstables is larger than `max_overlapping_level_size`
    #[prost(uint64, optional, tag = "24")]
    pub max_overlapping_level_size: ::core::option::Option<u64>,
    /// The emergency compaction limitations for the level0 sstables file count
    #[prost(uint32, optional, tag = "25")]
    pub emergency_level0_sst_file_count: ::core::option::Option<u32>,
    /// The emergency compaction limitations for the level0 sub level partition
    #[prost(uint32, optional, tag = "26")]
    pub emergency_level0_sub_level_partition: ::core::option::Option<u32>,
    /// The limitation of the max sst count of the level0 to trigger the write stop
    #[prost(uint32, optional, tag = "27")]
    pub level0_stop_write_threshold_max_sst_count: ::core::option::Option<u32>,
    /// The limitation of the max sst size of the level0 to trigger the write stop
    #[prost(uint64, optional, tag = "28")]
    pub level0_stop_write_threshold_max_size: ::core::option::Option<u64>,
    /// The limitation of the max sst count of the trivial move task
    #[prost(uint32, optional, tag = "29")]
    pub sst_allowed_trivial_move_max_count: ::core::option::Option<u32>,
    /// Enable the optimization of the interval selection for the level0 compaction
    #[prost(bool, optional, tag = "30")]
    pub enable_optimize_l0_interval_selection: ::core::option::Option<bool>,
    /// Deprecated. Kept for backward compatibility and ignored by meta.
    #[deprecated]
    #[prost(uint64, optional, tag = "31")]
    pub vnode_aligned_level_size_threshold: ::core::option::Option<u64>,
    /// The maximum key-value count threshold for using Xor16 filter instead of BlockedXor16 filter.
    /// When the number of keys in a compaction task or SST exceeds this threshold,
    /// a BlockedXor16 filter will be used instead of a single Xor16 filter.
    ///
    /// Typical value: 256 * 1024 (256K keys).
    #[prost(uint64, optional, tag = "32")]
    pub max_kv_count_for_xor16: ::core::option::Option<u64>,
    /// Max bytes for vnode key-range hints recorded into each SST.
    #[prost(uint64, optional, tag = "33")]
    pub max_vnode_key_range_bytes: ::core::option::Option<u64>,
}
/// Nested message and enum types in `CompactionConfig`.
pub mod compaction_config {
    #[derive(prost_helpers::AnyPB)]
    #[derive(
        Clone,
        Copy,
        Debug,
        PartialEq,
        Eq,
        Hash,
        PartialOrd,
        Ord,
        ::prost::Enumeration
    )]
    #[repr(i32)]
    pub enum CompactionMode {
        Unspecified = 0,
        Range = 1,
    }
    impl CompactionMode {
        /// String value of the enum field names used in the ProtoBuf definition.
        ///
        /// The values are not transformed in any way and thus are considered stable
        /// (if the ProtoBuf definition does not change) and safe for programmatic use.
        pub fn as_str_name(&self) -> &'static str {
            match self {
                Self::Unspecified => "UNSPECIFIED",
                Self::Range => "RANGE",
            }
        }
        /// Creates an enum from field names used in the ProtoBuf definition.
        pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
            match value {
                "UNSPECIFIED" => Some(Self::Unspecified),
                "RANGE" => Some(Self::Range),
                _ => None,
            }
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, PartialEq, Eq, Hash, ::prost::Message)]
pub struct TableStats {
    #[prost(int64, tag = "1")]
    pub total_key_size: i64,
    #[prost(int64, tag = "2")]
    pub total_value_size: i64,
    #[prost(int64, tag = "3")]
    pub total_key_count: i64,
    /// \`total_compressed_size\`` represents the size that the table takes up in the output sst
    /// and this field is only filled and used by CN flushes, not compactor compaction
    #[prost(uint64, tag = "4")]
    pub total_compressed_size: u64,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct HummockVersionStats {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockVersionId")]
    pub hummock_version_id: crate::id::HummockVersionId,
    #[prost(map = "uint32, message", tag = "2", wrapper = "crate::id::TableId")]
    pub table_stats: ::std::collections::HashMap<crate::id::TableId, TableStats>,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct WriteLimits {
    /// \< compaction group id, write limit info >
    #[prost(
        map = "uint64, message",
        tag = "1",
        wrapper = "crate::id::CompactionGroupId"
    )]
    pub write_limits: ::std::collections::HashMap<
        crate::id::CompactionGroupId,
        write_limits::WriteLimit,
    >,
}
/// Nested message and enum types in `WriteLimits`.
pub mod write_limits {
    #[derive(prost_helpers::AnyPB)]
    #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
    pub struct WriteLimit {
        #[prost(uint32, repeated, tag = "1", wrapper = "crate::id::TableId")]
        pub table_ids: ::prost::alloc::vec::Vec<crate::id::TableId>,
        #[prost(string, tag = "2")]
        pub reason: ::prost::alloc::string::String,
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
pub struct BranchedObject {
    #[prost(uint64, tag = "1", wrapper = "crate::id::HummockSstableObjectId")]
    pub object_id: crate::id::HummockSstableObjectId,
    #[prost(uint64, repeated, tag = "2", wrapper = "crate::id::HummockSstableId")]
    pub sst_id: ::prost::alloc::vec::Vec<crate::id::HummockSstableId>,
    /// Compaction group id the SST belongs to.
    #[prost(uint64, tag = "3", wrapper = "crate::id::CompactionGroupId")]
    pub compaction_group_id: crate::id::CompactionGroupId,
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum BloomFilterType {
    BloomFilterUnspecified = 0,
    Sstable = 1,
    Blocked = 2,
}
impl BloomFilterType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::BloomFilterUnspecified => "BLOOM_FILTER_UNSPECIFIED",
            Self::Sstable => "SSTABLE",
            Self::Blocked => "BLOCKED",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "BLOOM_FILTER_UNSPECIFIED" => Some(Self::BloomFilterUnspecified),
            "SSTABLE" => Some(Self::Sstable),
            "BLOCKED" => Some(Self::Blocked),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum LevelType {
    Unspecified = 0,
    Nonoverlapping = 1,
    Overlapping = 2,
}
impl LevelType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::Unspecified => "LEVEL_TYPE_UNSPECIFIED",
            Self::Nonoverlapping => "LEVEL_TYPE_NONOVERLAPPING",
            Self::Overlapping => "LEVEL_TYPE_OVERLAPPING",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "LEVEL_TYPE_UNSPECIFIED" => Some(Self::Unspecified),
            "LEVEL_TYPE_NONOVERLAPPING" => Some(Self::Nonoverlapping),
            "LEVEL_TYPE_OVERLAPPING" => Some(Self::Overlapping),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(prost_helpers::Version)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum CompatibilityVersion {
    VersionUnspecified = 0,
    NoTrivialSplit = 1,
    NoMemberTableIds = 2,
    SplitGroupByTableId = 3,
}
impl CompatibilityVersion {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::VersionUnspecified => "VERSION_UNSPECIFIED",
            Self::NoTrivialSplit => "NO_TRIVIAL_SPLIT",
            Self::NoMemberTableIds => "NO_MEMBER_TABLE_IDS",
            Self::SplitGroupByTableId => "SPLIT_GROUP_BY_TABLE_ID",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "VERSION_UNSPECIFIED" => Some(Self::VersionUnspecified),
            "NO_TRIVIAL_SPLIT" => Some(Self::NoTrivialSplit),
            "NO_MEMBER_TABLE_IDS" => Some(Self::NoMemberTableIds),
            "SPLIT_GROUP_BY_TABLE_ID" => Some(Self::SplitGroupByTableId),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum WatermarkSerdeType {
    TypeUnspecified = 0,
    PkPrefix = 1,
    NonPkPrefix = 2,
    Value = 3,
}
impl WatermarkSerdeType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::TypeUnspecified => "TYPE_UNSPECIFIED",
            Self::PkPrefix => "PK_PREFIX",
            Self::NonPkPrefix => "NON_PK_PREFIX",
            Self::Value => "VALUE",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "TYPE_UNSPECIFIED" => Some(Self::TypeUnspecified),
            "PK_PREFIX" => Some(Self::PkPrefix),
            "NON_PK_PREFIX" => Some(Self::NonPkPrefix),
            "VALUE" => Some(Self::Value),
            _ => None,
        }
    }
}
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum VectorIndexObjectType {
    VectorIndexObjectUnspecified = 0,
    VectorIndexObjectVector = 1,
    VectorIndexObjectHnswGraph = 2,
}
impl VectorIndexObjectType {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::VectorIndexObjectUnspecified => "VECTOR_INDEX_OBJECT_UNSPECIFIED",
            Self::VectorIndexObjectVector => "VECTOR_INDEX_OBJECT_VECTOR",
            Self::VectorIndexObjectHnswGraph => "VECTOR_INDEX_OBJECT_HNSW_GRAPH",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "VECTOR_INDEX_OBJECT_UNSPECIFIED" => Some(Self::VectorIndexObjectUnspecified),
            "VECTOR_INDEX_OBJECT_VECTOR" => Some(Self::VectorIndexObjectVector),
            "VECTOR_INDEX_OBJECT_HNSW_GRAPH" => Some(Self::VectorIndexObjectHnswGraph),
            _ => None,
        }
    }
}
/// Compression algorithm used for checkpoint data serialization.
#[derive(prost_helpers::AnyPB)]
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum CheckpointCompressionAlgorithm {
    /// No compression (uncompressed).
    CheckpointCompressionUnspecified = 0,
    /// Zstd compression (default, good balance between ratio and speed).
    CheckpointCompressionZstd = 1,
    /// Lz4 compression (faster but lower compression ratio).
    CheckpointCompressionLz4 = 2,
}
impl CheckpointCompressionAlgorithm {
    /// String value of the enum field names used in the ProtoBuf definition.
    ///
    /// The values are not transformed in any way and thus are considered stable
    /// (if the ProtoBuf definition does not change) and safe for programmatic use.
    pub fn as_str_name(&self) -> &'static str {
        match self {
            Self::CheckpointCompressionUnspecified => {
                "CHECKPOINT_COMPRESSION_UNSPECIFIED"
            }
            Self::CheckpointCompressionZstd => "CHECKPOINT_COMPRESSION_ZSTD",
            Self::CheckpointCompressionLz4 => "CHECKPOINT_COMPRESSION_LZ4",
        }
    }
    /// Creates an enum from field names used in the ProtoBuf definition.
    pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
        match value {
            "CHECKPOINT_COMPRESSION_UNSPECIFIED" => {
                Some(Self::CheckpointCompressionUnspecified)
            }
            "CHECKPOINT_COMPRESSION_ZSTD" => Some(Self::CheckpointCompressionZstd),
            "CHECKPOINT_COMPRESSION_LZ4" => Some(Self::CheckpointCompressionLz4),
            _ => None,
        }
    }
}
/// Generated client implementations.
pub mod hummock_manager_service_client {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    use tonic::codegen::http::Uri;
    #[derive(Debug, Clone)]
    pub struct HummockManagerServiceClient<T> {
        inner: tonic::client::Grpc<T>,
    }
    impl HummockManagerServiceClient<tonic::transport::Channel> {
        /// Attempt to create a new client by connecting to a given endpoint.
        pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
        where
            D: TryInto<tonic::transport::Endpoint>,
            D::Error: Into<StdError>,
        {
            let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
            Ok(Self::new(conn))
        }
    }
    impl<T> HummockManagerServiceClient<T>
    where
        T: tonic::client::GrpcService<tonic::body::Body>,
        T::Error: Into<StdError>,
        T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
        <T::ResponseBody as Body>::Error: Into<StdError> + std::marker::Send,
    {
        pub fn new(inner: T) -> Self {
            let inner = tonic::client::Grpc::new(inner);
            Self { inner }
        }
        pub fn with_origin(inner: T, origin: Uri) -> Self {
            let inner = tonic::client::Grpc::with_origin(inner, origin);
            Self { inner }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> HummockManagerServiceClient<InterceptedService<T, F>>
        where
            F: tonic::service::Interceptor,
            T::ResponseBody: Default,
            T: tonic::codegen::Service<
                http::Request<tonic::body::Body>,
                Response = http::Response<
                    <T as tonic::client::GrpcService<tonic::body::Body>>::ResponseBody,
                >,
            >,
            <T as tonic::codegen::Service<
                http::Request<tonic::body::Body>,
            >>::Error: Into<StdError> + std::marker::Send + std::marker::Sync,
        {
            HummockManagerServiceClient::new(InterceptedService::new(inner, interceptor))
        }
        /// Compress requests with the given encoding.
        ///
        /// This requires the server to support it otherwise it might respond with an
        /// error.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.send_compressed(encoding);
            self
        }
        /// Enable decompressing responses.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.inner = self.inner.accept_compressed(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_decoding_message_size(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.inner = self.inner.max_encoding_message_size(limit);
            self
        }
        pub async fn unpin_version_before(
            &mut self,
            request: impl tonic::IntoRequest<super::UnpinVersionBeforeRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UnpinVersionBeforeResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/UnpinVersionBefore",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "UnpinVersionBefore",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_current_version(
            &mut self,
            request: impl tonic::IntoRequest<super::GetCurrentVersionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetCurrentVersionResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/GetCurrentVersion",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("hummock.HummockManagerService", "GetCurrentVersion"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_version_deltas(
            &mut self,
            request: impl tonic::IntoRequest<super::ListVersionDeltasRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListVersionDeltasResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ListVersionDeltas",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("hummock.HummockManagerService", "ListVersionDeltas"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn replay_version_delta(
            &mut self,
            request: impl tonic::IntoRequest<super::ReplayVersionDeltaRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ReplayVersionDeltaResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ReplayVersionDelta",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "ReplayVersionDelta",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_assigned_compact_task_num(
            &mut self,
            request: impl tonic::IntoRequest<super::GetAssignedCompactTaskNumRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetAssignedCompactTaskNumResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/GetAssignedCompactTaskNum",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "GetAssignedCompactTaskNum",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn trigger_compaction_deterministic(
            &mut self,
            request: impl tonic::IntoRequest<
                super::TriggerCompactionDeterministicRequest,
            >,
        ) -> std::result::Result<
            tonic::Response<super::TriggerCompactionDeterministicResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/TriggerCompactionDeterministic",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "TriggerCompactionDeterministic",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn disable_commit_epoch(
            &mut self,
            request: impl tonic::IntoRequest<super::DisableCommitEpochRequest>,
        ) -> std::result::Result<
            tonic::Response<super::DisableCommitEpochResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/DisableCommitEpoch",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "DisableCommitEpoch",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_new_object_ids(
            &mut self,
            request: impl tonic::IntoRequest<super::GetNewObjectIdsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetNewObjectIdsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/GetNewObjectIds",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("hummock.HummockManagerService", "GetNewObjectIds"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn trigger_manual_compaction(
            &mut self,
            request: impl tonic::IntoRequest<super::TriggerManualCompactionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::TriggerManualCompactionResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/TriggerManualCompaction",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "TriggerManualCompaction",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn trigger_full_gc(
            &mut self,
            request: impl tonic::IntoRequest<super::TriggerFullGcRequest>,
        ) -> std::result::Result<
            tonic::Response<super::TriggerFullGcResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/TriggerFullGC",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("hummock.HummockManagerService", "TriggerFullGC"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_get_pinned_versions_summary(
            &mut self,
            request: impl tonic::IntoRequest<
                super::RiseCtlGetPinnedVersionsSummaryRequest,
            >,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlGetPinnedVersionsSummaryResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlGetPinnedVersionsSummary",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlGetPinnedVersionsSummary",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_list_compaction_group(
            &mut self,
            request: impl tonic::IntoRequest<super::RiseCtlListCompactionGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlListCompactionGroupResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlListCompactionGroup",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlListCompactionGroup",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_update_compaction_config(
            &mut self,
            request: impl tonic::IntoRequest<super::RiseCtlUpdateCompactionConfigRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlUpdateCompactionConfigResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlUpdateCompactionConfig",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlUpdateCompactionConfig",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_pause_version_checkpoint(
            &mut self,
            request: impl tonic::IntoRequest<super::RiseCtlPauseVersionCheckpointRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlPauseVersionCheckpointResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlPauseVersionCheckpoint",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlPauseVersionCheckpoint",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_resume_version_checkpoint(
            &mut self,
            request: impl tonic::IntoRequest<
                super::RiseCtlResumeVersionCheckpointRequest,
            >,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlResumeVersionCheckpointResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlResumeVersionCheckpoint",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlResumeVersionCheckpoint",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_get_checkpoint_version(
            &mut self,
            request: impl tonic::IntoRequest<super::RiseCtlGetCheckpointVersionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlGetCheckpointVersionResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlGetCheckpointVersion",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlGetCheckpointVersion",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_rebuild_table_stats(
            &mut self,
            request: impl tonic::IntoRequest<super::RiseCtlRebuildTableStatsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlRebuildTableStatsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlRebuildTableStats",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlRebuildTableStats",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn init_metadata_for_replay(
            &mut self,
            request: impl tonic::IntoRequest<super::InitMetadataForReplayRequest>,
        ) -> std::result::Result<
            tonic::Response<super::InitMetadataForReplayResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/InitMetadataForReplay",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "InitMetadataForReplay",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn pin_version(
            &mut self,
            request: impl tonic::IntoRequest<super::PinVersionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::PinVersionResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/PinVersion",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(GrpcMethod::new("hummock.HummockManagerService", "PinVersion"));
            self.inner.unary(req, path, codec).await
        }
        pub async fn split_compaction_group(
            &mut self,
            request: impl tonic::IntoRequest<super::SplitCompactionGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::SplitCompactionGroupResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/SplitCompactionGroup",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "SplitCompactionGroup",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn rise_ctl_list_compaction_status(
            &mut self,
            request: impl tonic::IntoRequest<super::RiseCtlListCompactionStatusRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlListCompactionStatusResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/RiseCtlListCompactionStatus",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "RiseCtlListCompactionStatus",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn subscribe_compaction_event(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::SubscribeCompactionEventRequest,
            >,
        ) -> std::result::Result<
            tonic::Response<
                tonic::codec::Streaming<super::SubscribeCompactionEventResponse>,
            >,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/SubscribeCompactionEvent",
            );
            let mut req = request.into_streaming_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "SubscribeCompactionEvent",
                    ),
                );
            self.inner.streaming(req, path, codec).await
        }
        pub async fn report_compaction_task(
            &mut self,
            request: impl tonic::IntoRequest<super::ReportCompactionTaskRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ReportCompactionTaskResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ReportCompactionTask",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "ReportCompactionTask",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_branched_object(
            &mut self,
            request: impl tonic::IntoRequest<super::ListBranchedObjectRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListBranchedObjectResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ListBranchedObject",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "ListBranchedObject",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_active_write_limit(
            &mut self,
            request: impl tonic::IntoRequest<super::ListActiveWriteLimitRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListActiveWriteLimitResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ListActiveWriteLimit",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "ListActiveWriteLimit",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_hummock_meta_config(
            &mut self,
            request: impl tonic::IntoRequest<super::ListHummockMetaConfigRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListHummockMetaConfigResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ListHummockMetaConfig",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "ListHummockMetaConfig",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_compaction_score(
            &mut self,
            request: impl tonic::IntoRequest<super::GetCompactionScoreRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetCompactionScoreResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/GetCompactionScore",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "GetCompactionScore",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_compact_task_assignment(
            &mut self,
            request: impl tonic::IntoRequest<super::ListCompactTaskAssignmentRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListCompactTaskAssignmentResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ListCompactTaskAssignment",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "ListCompactTaskAssignment",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn list_compact_task_progress(
            &mut self,
            request: impl tonic::IntoRequest<super::ListCompactTaskProgressRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListCompactTaskProgressResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/ListCompactTaskProgress",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "ListCompactTaskProgress",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn cancel_compact_task(
            &mut self,
            request: impl tonic::IntoRequest<super::CancelCompactTaskRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CancelCompactTaskResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/CancelCompactTask",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("hummock.HummockManagerService", "CancelCompactTask"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_version_by_epoch(
            &mut self,
            request: impl tonic::IntoRequest<super::GetVersionByEpochRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetVersionByEpochResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/GetVersionByEpoch",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new("hummock.HummockManagerService", "GetVersionByEpoch"),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn merge_compaction_group(
            &mut self,
            request: impl tonic::IntoRequest<super::MergeCompactionGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::MergeCompactionGroupResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/MergeCompactionGroup",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "MergeCompactionGroup",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        pub async fn get_table_change_logs(
            &mut self,
            request: impl tonic::IntoRequest<super::GetTableChangeLogsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetTableChangeLogsResponse>,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/GetTableChangeLogs",
            );
            let mut req = request.into_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "GetTableChangeLogs",
                    ),
                );
            self.inner.unary(req, path, codec).await
        }
        /// iceberg
        pub async fn subscribe_iceberg_compaction_event(
            &mut self,
            request: impl tonic::IntoStreamingRequest<
                Message = super::super::iceberg_compaction::SubscribeIcebergCompactionEventRequest,
            >,
        ) -> std::result::Result<
            tonic::Response<
                tonic::codec::Streaming<
                    super::super::iceberg_compaction::SubscribeIcebergCompactionEventResponse,
                >,
            >,
            tonic::Status,
        > {
            self.inner
                .ready()
                .await
                .map_err(|e| {
                    tonic::Status::unknown(
                        format!("Service was not ready: {}", e.into()),
                    )
                })?;
            let codec = tonic_prost::ProstCodec::default();
            let path = http::uri::PathAndQuery::from_static(
                "/hummock.HummockManagerService/SubscribeIcebergCompactionEvent",
            );
            let mut req = request.into_streaming_request();
            req.extensions_mut()
                .insert(
                    GrpcMethod::new(
                        "hummock.HummockManagerService",
                        "SubscribeIcebergCompactionEvent",
                    ),
                );
            self.inner.streaming(req, path, codec).await
        }
    }
}
/// Generated server implementations.
pub mod hummock_manager_service_server {
    #![allow(
        unused_variables,
        dead_code,
        missing_docs,
        clippy::wildcard_imports,
        clippy::let_unit_value,
    )]
    use tonic::codegen::*;
    /// Generated trait containing gRPC methods that should be implemented for use with HummockManagerServiceServer.
    #[async_trait]
    pub trait HummockManagerService: std::marker::Send + std::marker::Sync + 'static {
        async fn unpin_version_before(
            &self,
            request: tonic::Request<super::UnpinVersionBeforeRequest>,
        ) -> std::result::Result<
            tonic::Response<super::UnpinVersionBeforeResponse>,
            tonic::Status,
        >;
        async fn get_current_version(
            &self,
            request: tonic::Request<super::GetCurrentVersionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetCurrentVersionResponse>,
            tonic::Status,
        >;
        async fn list_version_deltas(
            &self,
            request: tonic::Request<super::ListVersionDeltasRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListVersionDeltasResponse>,
            tonic::Status,
        >;
        async fn replay_version_delta(
            &self,
            request: tonic::Request<super::ReplayVersionDeltaRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ReplayVersionDeltaResponse>,
            tonic::Status,
        >;
        async fn get_assigned_compact_task_num(
            &self,
            request: tonic::Request<super::GetAssignedCompactTaskNumRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetAssignedCompactTaskNumResponse>,
            tonic::Status,
        >;
        async fn trigger_compaction_deterministic(
            &self,
            request: tonic::Request<super::TriggerCompactionDeterministicRequest>,
        ) -> std::result::Result<
            tonic::Response<super::TriggerCompactionDeterministicResponse>,
            tonic::Status,
        >;
        async fn disable_commit_epoch(
            &self,
            request: tonic::Request<super::DisableCommitEpochRequest>,
        ) -> std::result::Result<
            tonic::Response<super::DisableCommitEpochResponse>,
            tonic::Status,
        >;
        async fn get_new_object_ids(
            &self,
            request: tonic::Request<super::GetNewObjectIdsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetNewObjectIdsResponse>,
            tonic::Status,
        >;
        async fn trigger_manual_compaction(
            &self,
            request: tonic::Request<super::TriggerManualCompactionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::TriggerManualCompactionResponse>,
            tonic::Status,
        >;
        async fn trigger_full_gc(
            &self,
            request: tonic::Request<super::TriggerFullGcRequest>,
        ) -> std::result::Result<
            tonic::Response<super::TriggerFullGcResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_get_pinned_versions_summary(
            &self,
            request: tonic::Request<super::RiseCtlGetPinnedVersionsSummaryRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlGetPinnedVersionsSummaryResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_list_compaction_group(
            &self,
            request: tonic::Request<super::RiseCtlListCompactionGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlListCompactionGroupResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_update_compaction_config(
            &self,
            request: tonic::Request<super::RiseCtlUpdateCompactionConfigRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlUpdateCompactionConfigResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_pause_version_checkpoint(
            &self,
            request: tonic::Request<super::RiseCtlPauseVersionCheckpointRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlPauseVersionCheckpointResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_resume_version_checkpoint(
            &self,
            request: tonic::Request<super::RiseCtlResumeVersionCheckpointRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlResumeVersionCheckpointResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_get_checkpoint_version(
            &self,
            request: tonic::Request<super::RiseCtlGetCheckpointVersionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlGetCheckpointVersionResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_rebuild_table_stats(
            &self,
            request: tonic::Request<super::RiseCtlRebuildTableStatsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlRebuildTableStatsResponse>,
            tonic::Status,
        >;
        async fn init_metadata_for_replay(
            &self,
            request: tonic::Request<super::InitMetadataForReplayRequest>,
        ) -> std::result::Result<
            tonic::Response<super::InitMetadataForReplayResponse>,
            tonic::Status,
        >;
        async fn pin_version(
            &self,
            request: tonic::Request<super::PinVersionRequest>,
        ) -> std::result::Result<
            tonic::Response<super::PinVersionResponse>,
            tonic::Status,
        >;
        async fn split_compaction_group(
            &self,
            request: tonic::Request<super::SplitCompactionGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::SplitCompactionGroupResponse>,
            tonic::Status,
        >;
        async fn rise_ctl_list_compaction_status(
            &self,
            request: tonic::Request<super::RiseCtlListCompactionStatusRequest>,
        ) -> std::result::Result<
            tonic::Response<super::RiseCtlListCompactionStatusResponse>,
            tonic::Status,
        >;
        /// Server streaming response type for the SubscribeCompactionEvent method.
        type SubscribeCompactionEventStream: tonic::codegen::tokio_stream::Stream<
                Item = std::result::Result<
                    super::SubscribeCompactionEventResponse,
                    tonic::Status,
                >,
            >
            + std::marker::Send
            + 'static;
        async fn subscribe_compaction_event(
            &self,
            request: tonic::Request<
                tonic::Streaming<super::SubscribeCompactionEventRequest>,
            >,
        ) -> std::result::Result<
            tonic::Response<Self::SubscribeCompactionEventStream>,
            tonic::Status,
        >;
        async fn report_compaction_task(
            &self,
            request: tonic::Request<super::ReportCompactionTaskRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ReportCompactionTaskResponse>,
            tonic::Status,
        >;
        async fn list_branched_object(
            &self,
            request: tonic::Request<super::ListBranchedObjectRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListBranchedObjectResponse>,
            tonic::Status,
        >;
        async fn list_active_write_limit(
            &self,
            request: tonic::Request<super::ListActiveWriteLimitRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListActiveWriteLimitResponse>,
            tonic::Status,
        >;
        async fn list_hummock_meta_config(
            &self,
            request: tonic::Request<super::ListHummockMetaConfigRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListHummockMetaConfigResponse>,
            tonic::Status,
        >;
        async fn get_compaction_score(
            &self,
            request: tonic::Request<super::GetCompactionScoreRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetCompactionScoreResponse>,
            tonic::Status,
        >;
        async fn list_compact_task_assignment(
            &self,
            request: tonic::Request<super::ListCompactTaskAssignmentRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListCompactTaskAssignmentResponse>,
            tonic::Status,
        >;
        async fn list_compact_task_progress(
            &self,
            request: tonic::Request<super::ListCompactTaskProgressRequest>,
        ) -> std::result::Result<
            tonic::Response<super::ListCompactTaskProgressResponse>,
            tonic::Status,
        >;
        async fn cancel_compact_task(
            &self,
            request: tonic::Request<super::CancelCompactTaskRequest>,
        ) -> std::result::Result<
            tonic::Response<super::CancelCompactTaskResponse>,
            tonic::Status,
        >;
        async fn get_version_by_epoch(
            &self,
            request: tonic::Request<super::GetVersionByEpochRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetVersionByEpochResponse>,
            tonic::Status,
        >;
        async fn merge_compaction_group(
            &self,
            request: tonic::Request<super::MergeCompactionGroupRequest>,
        ) -> std::result::Result<
            tonic::Response<super::MergeCompactionGroupResponse>,
            tonic::Status,
        >;
        async fn get_table_change_logs(
            &self,
            request: tonic::Request<super::GetTableChangeLogsRequest>,
        ) -> std::result::Result<
            tonic::Response<super::GetTableChangeLogsResponse>,
            tonic::Status,
        >;
        /// Server streaming response type for the SubscribeIcebergCompactionEvent method.
        type SubscribeIcebergCompactionEventStream: tonic::codegen::tokio_stream::Stream<
                Item = std::result::Result<
                    super::super::iceberg_compaction::SubscribeIcebergCompactionEventResponse,
                    tonic::Status,
                >,
            >
            + std::marker::Send
            + 'static;
        /// iceberg
        async fn subscribe_iceberg_compaction_event(
            &self,
            request: tonic::Request<
                tonic::Streaming<
                    super::super::iceberg_compaction::SubscribeIcebergCompactionEventRequest,
                >,
            >,
        ) -> std::result::Result<
            tonic::Response<Self::SubscribeIcebergCompactionEventStream>,
            tonic::Status,
        >;
    }
    #[derive(Debug)]
    pub struct HummockManagerServiceServer<T> {
        inner: Arc<T>,
        accept_compression_encodings: EnabledCompressionEncodings,
        send_compression_encodings: EnabledCompressionEncodings,
        max_decoding_message_size: Option<usize>,
        max_encoding_message_size: Option<usize>,
    }
    impl<T> HummockManagerServiceServer<T> {
        pub fn new(inner: T) -> Self {
            Self::from_arc(Arc::new(inner))
        }
        pub fn from_arc(inner: Arc<T>) -> Self {
            Self {
                inner,
                accept_compression_encodings: Default::default(),
                send_compression_encodings: Default::default(),
                max_decoding_message_size: None,
                max_encoding_message_size: None,
            }
        }
        pub fn with_interceptor<F>(
            inner: T,
            interceptor: F,
        ) -> InterceptedService<Self, F>
        where
            F: tonic::service::Interceptor,
        {
            InterceptedService::new(Self::new(inner), interceptor)
        }
        /// Enable decompressing requests with the given encoding.
        #[must_use]
        pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.accept_compression_encodings.enable(encoding);
            self
        }
        /// Compress responses with the given encoding, if the client supports it.
        #[must_use]
        pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
            self.send_compression_encodings.enable(encoding);
            self
        }
        /// Limits the maximum size of a decoded message.
        ///
        /// Default: `4MB`
        #[must_use]
        pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
            self.max_decoding_message_size = Some(limit);
            self
        }
        /// Limits the maximum size of an encoded message.
        ///
        /// Default: `usize::MAX`
        #[must_use]
        pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
            self.max_encoding_message_size = Some(limit);
            self
        }
    }
    impl<T, B> tonic::codegen::Service<http::Request<B>>
    for HummockManagerServiceServer<T>
    where
        T: HummockManagerService,
        B: Body + std::marker::Send + 'static,
        B::Error: Into<StdError> + std::marker::Send + 'static,
    {
        type Response = http::Response<tonic::body::Body>;
        type Error = std::convert::Infallible;
        type Future = BoxFuture<Self::Response, Self::Error>;
        fn poll_ready(
            &mut self,
            _cx: &mut Context<'_>,
        ) -> Poll<std::result::Result<(), Self::Error>> {
            Poll::Ready(Ok(()))
        }
        fn call(&mut self, req: http::Request<B>) -> Self::Future {
            match req.uri().path() {
                "/hummock.HummockManagerService/UnpinVersionBefore" => {
                    #[allow(non_camel_case_types)]
                    struct UnpinVersionBeforeSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::UnpinVersionBeforeRequest>
                    for UnpinVersionBeforeSvc<T> {
                        type Response = super::UnpinVersionBeforeResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::UnpinVersionBeforeRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::unpin_version_before(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = UnpinVersionBeforeSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/GetCurrentVersion" => {
                    #[allow(non_camel_case_types)]
                    struct GetCurrentVersionSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::GetCurrentVersionRequest>
                    for GetCurrentVersionSvc<T> {
                        type Response = super::GetCurrentVersionResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::GetCurrentVersionRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::get_current_version(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = GetCurrentVersionSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ListVersionDeltas" => {
                    #[allow(non_camel_case_types)]
                    struct ListVersionDeltasSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::ListVersionDeltasRequest>
                    for ListVersionDeltasSvc<T> {
                        type Response = super::ListVersionDeltasResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ListVersionDeltasRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::list_version_deltas(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ListVersionDeltasSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ReplayVersionDelta" => {
                    #[allow(non_camel_case_types)]
                    struct ReplayVersionDeltaSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::ReplayVersionDeltaRequest>
                    for ReplayVersionDeltaSvc<T> {
                        type Response = super::ReplayVersionDeltaResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ReplayVersionDeltaRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::replay_version_delta(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ReplayVersionDeltaSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/GetAssignedCompactTaskNum" => {
                    #[allow(non_camel_case_types)]
                    struct GetAssignedCompactTaskNumSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::GetAssignedCompactTaskNumRequest,
                    > for GetAssignedCompactTaskNumSvc<T> {
                        type Response = super::GetAssignedCompactTaskNumResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::GetAssignedCompactTaskNumRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::get_assigned_compact_task_num(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = GetAssignedCompactTaskNumSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/TriggerCompactionDeterministic" => {
                    #[allow(non_camel_case_types)]
                    struct TriggerCompactionDeterministicSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::TriggerCompactionDeterministicRequest,
                    > for TriggerCompactionDeterministicSvc<T> {
                        type Response = super::TriggerCompactionDeterministicResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::TriggerCompactionDeterministicRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::trigger_compaction_deterministic(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = TriggerCompactionDeterministicSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/DisableCommitEpoch" => {
                    #[allow(non_camel_case_types)]
                    struct DisableCommitEpochSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::DisableCommitEpochRequest>
                    for DisableCommitEpochSvc<T> {
                        type Response = super::DisableCommitEpochResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::DisableCommitEpochRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::disable_commit_epoch(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = DisableCommitEpochSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/GetNewObjectIds" => {
                    #[allow(non_camel_case_types)]
                    struct GetNewObjectIdsSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::GetNewObjectIdsRequest>
                    for GetNewObjectIdsSvc<T> {
                        type Response = super::GetNewObjectIdsResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::GetNewObjectIdsRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::get_new_object_ids(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = GetNewObjectIdsSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/TriggerManualCompaction" => {
                    #[allow(non_camel_case_types)]
                    struct TriggerManualCompactionSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::TriggerManualCompactionRequest>
                    for TriggerManualCompactionSvc<T> {
                        type Response = super::TriggerManualCompactionResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::TriggerManualCompactionRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::trigger_manual_compaction(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = TriggerManualCompactionSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/TriggerFullGC" => {
                    #[allow(non_camel_case_types)]
                    struct TriggerFullGCSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::TriggerFullGcRequest>
                    for TriggerFullGCSvc<T> {
                        type Response = super::TriggerFullGcResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::TriggerFullGcRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::trigger_full_gc(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = TriggerFullGCSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlGetPinnedVersionsSummary" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlGetPinnedVersionsSummarySvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::RiseCtlGetPinnedVersionsSummaryRequest,
                    > for RiseCtlGetPinnedVersionsSummarySvc<T> {
                        type Response = super::RiseCtlGetPinnedVersionsSummaryResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlGetPinnedVersionsSummaryRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_get_pinned_versions_summary(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlGetPinnedVersionsSummarySvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlListCompactionGroup" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlListCompactionGroupSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::RiseCtlListCompactionGroupRequest,
                    > for RiseCtlListCompactionGroupSvc<T> {
                        type Response = super::RiseCtlListCompactionGroupResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlListCompactionGroupRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_list_compaction_group(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlListCompactionGroupSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlUpdateCompactionConfig" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlUpdateCompactionConfigSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::RiseCtlUpdateCompactionConfigRequest,
                    > for RiseCtlUpdateCompactionConfigSvc<T> {
                        type Response = super::RiseCtlUpdateCompactionConfigResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlUpdateCompactionConfigRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_update_compaction_config(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlUpdateCompactionConfigSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlPauseVersionCheckpoint" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlPauseVersionCheckpointSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::RiseCtlPauseVersionCheckpointRequest,
                    > for RiseCtlPauseVersionCheckpointSvc<T> {
                        type Response = super::RiseCtlPauseVersionCheckpointResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlPauseVersionCheckpointRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_pause_version_checkpoint(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlPauseVersionCheckpointSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlResumeVersionCheckpoint" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlResumeVersionCheckpointSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::RiseCtlResumeVersionCheckpointRequest,
                    > for RiseCtlResumeVersionCheckpointSvc<T> {
                        type Response = super::RiseCtlResumeVersionCheckpointResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlResumeVersionCheckpointRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_resume_version_checkpoint(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlResumeVersionCheckpointSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlGetCheckpointVersion" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlGetCheckpointVersionSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::RiseCtlGetCheckpointVersionRequest,
                    > for RiseCtlGetCheckpointVersionSvc<T> {
                        type Response = super::RiseCtlGetCheckpointVersionResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlGetCheckpointVersionRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_get_checkpoint_version(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlGetCheckpointVersionSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlRebuildTableStats" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlRebuildTableStatsSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::RiseCtlRebuildTableStatsRequest>
                    for RiseCtlRebuildTableStatsSvc<T> {
                        type Response = super::RiseCtlRebuildTableStatsResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlRebuildTableStatsRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_rebuild_table_stats(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlRebuildTableStatsSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/InitMetadataForReplay" => {
                    #[allow(non_camel_case_types)]
                    struct InitMetadataForReplaySvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::InitMetadataForReplayRequest>
                    for InitMetadataForReplaySvc<T> {
                        type Response = super::InitMetadataForReplayResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::InitMetadataForReplayRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::init_metadata_for_replay(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = InitMetadataForReplaySvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/PinVersion" => {
                    #[allow(non_camel_case_types)]
                    struct PinVersionSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::PinVersionRequest>
                    for PinVersionSvc<T> {
                        type Response = super::PinVersionResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::PinVersionRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::pin_version(&inner, request)
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = PinVersionSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/SplitCompactionGroup" => {
                    #[allow(non_camel_case_types)]
                    struct SplitCompactionGroupSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::SplitCompactionGroupRequest>
                    for SplitCompactionGroupSvc<T> {
                        type Response = super::SplitCompactionGroupResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::SplitCompactionGroupRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::split_compaction_group(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = SplitCompactionGroupSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/RiseCtlListCompactionStatus" => {
                    #[allow(non_camel_case_types)]
                    struct RiseCtlListCompactionStatusSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::RiseCtlListCompactionStatusRequest,
                    > for RiseCtlListCompactionStatusSvc<T> {
                        type Response = super::RiseCtlListCompactionStatusResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::RiseCtlListCompactionStatusRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::rise_ctl_list_compaction_status(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = RiseCtlListCompactionStatusSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/SubscribeCompactionEvent" => {
                    #[allow(non_camel_case_types)]
                    struct SubscribeCompactionEventSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::StreamingService<
                        super::SubscribeCompactionEventRequest,
                    > for SubscribeCompactionEventSvc<T> {
                        type Response = super::SubscribeCompactionEventResponse;
                        type ResponseStream = T::SubscribeCompactionEventStream;
                        type Future = BoxFuture<
                            tonic::Response<Self::ResponseStream>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                tonic::Streaming<super::SubscribeCompactionEventRequest>,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::subscribe_compaction_event(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = SubscribeCompactionEventSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.streaming(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ReportCompactionTask" => {
                    #[allow(non_camel_case_types)]
                    struct ReportCompactionTaskSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::ReportCompactionTaskRequest>
                    for ReportCompactionTaskSvc<T> {
                        type Response = super::ReportCompactionTaskResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ReportCompactionTaskRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::report_compaction_task(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ReportCompactionTaskSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ListBranchedObject" => {
                    #[allow(non_camel_case_types)]
                    struct ListBranchedObjectSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::ListBranchedObjectRequest>
                    for ListBranchedObjectSvc<T> {
                        type Response = super::ListBranchedObjectResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ListBranchedObjectRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::list_branched_object(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ListBranchedObjectSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ListActiveWriteLimit" => {
                    #[allow(non_camel_case_types)]
                    struct ListActiveWriteLimitSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::ListActiveWriteLimitRequest>
                    for ListActiveWriteLimitSvc<T> {
                        type Response = super::ListActiveWriteLimitResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ListActiveWriteLimitRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::list_active_write_limit(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ListActiveWriteLimitSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ListHummockMetaConfig" => {
                    #[allow(non_camel_case_types)]
                    struct ListHummockMetaConfigSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::ListHummockMetaConfigRequest>
                    for ListHummockMetaConfigSvc<T> {
                        type Response = super::ListHummockMetaConfigResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::ListHummockMetaConfigRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::list_hummock_meta_config(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ListHummockMetaConfigSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/GetCompactionScore" => {
                    #[allow(non_camel_case_types)]
                    struct GetCompactionScoreSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::GetCompactionScoreRequest>
                    for GetCompactionScoreSvc<T> {
                        type Response = super::GetCompactionScoreResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::GetCompactionScoreRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::get_compaction_score(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = GetCompactionScoreSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ListCompactTaskAssignment" => {
                    #[allow(non_camel_case_types)]
                    struct ListCompactTaskAssignmentSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<
                        super::ListCompactTaskAssignmentRequest,
                    > for ListCompactTaskAssignmentSvc<T> {
                        type Response = super::ListCompactTaskAssignmentResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::ListCompactTaskAssignmentRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::list_compact_task_assignment(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ListCompactTaskAssignmentSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/ListCompactTaskProgress" => {
                    #[allow(non_camel_case_types)]
                    struct ListCompactTaskProgressSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::ListCompactTaskProgressRequest>
                    for ListCompactTaskProgressSvc<T> {
                        type Response = super::ListCompactTaskProgressResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                super::ListCompactTaskProgressRequest,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::list_compact_task_progress(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = ListCompactTaskProgressSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/CancelCompactTask" => {
                    #[allow(non_camel_case_types)]
                    struct CancelCompactTaskSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::CancelCompactTaskRequest>
                    for CancelCompactTaskSvc<T> {
                        type Response = super::CancelCompactTaskResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::CancelCompactTaskRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::cancel_compact_task(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = CancelCompactTaskSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/GetVersionByEpoch" => {
                    #[allow(non_camel_case_types)]
                    struct GetVersionByEpochSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::GetVersionByEpochRequest>
                    for GetVersionByEpochSvc<T> {
                        type Response = super::GetVersionByEpochResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::GetVersionByEpochRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::get_version_by_epoch(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = GetVersionByEpochSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/MergeCompactionGroup" => {
                    #[allow(non_camel_case_types)]
                    struct MergeCompactionGroupSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::MergeCompactionGroupRequest>
                    for MergeCompactionGroupSvc<T> {
                        type Response = super::MergeCompactionGroupResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::MergeCompactionGroupRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::merge_compaction_group(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = MergeCompactionGroupSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/GetTableChangeLogs" => {
                    #[allow(non_camel_case_types)]
                    struct GetTableChangeLogsSvc<T: HummockManagerService>(pub Arc<T>);
                    impl<
                        T: HummockManagerService,
                    > tonic::server::UnaryService<super::GetTableChangeLogsRequest>
                    for GetTableChangeLogsSvc<T> {
                        type Response = super::GetTableChangeLogsResponse;
                        type Future = BoxFuture<
                            tonic::Response<Self::Response>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<super::GetTableChangeLogsRequest>,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::get_table_change_logs(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = GetTableChangeLogsSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.unary(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                "/hummock.HummockManagerService/SubscribeIcebergCompactionEvent" => {
                    #[allow(non_camel_case_types)]
                    struct SubscribeIcebergCompactionEventSvc<T: HummockManagerService>(
                        pub Arc<T>,
                    );
                    impl<
                        T: HummockManagerService,
                    > tonic::server::StreamingService<
                        super::super::iceberg_compaction::SubscribeIcebergCompactionEventRequest,
                    > for SubscribeIcebergCompactionEventSvc<T> {
                        type Response = super::super::iceberg_compaction::SubscribeIcebergCompactionEventResponse;
                        type ResponseStream = T::SubscribeIcebergCompactionEventStream;
                        type Future = BoxFuture<
                            tonic::Response<Self::ResponseStream>,
                            tonic::Status,
                        >;
                        fn call(
                            &mut self,
                            request: tonic::Request<
                                tonic::Streaming<
                                    super::super::iceberg_compaction::SubscribeIcebergCompactionEventRequest,
                                >,
                            >,
                        ) -> Self::Future {
                            let inner = Arc::clone(&self.0);
                            let fut = async move {
                                <T as HummockManagerService>::subscribe_iceberg_compaction_event(
                                        &inner,
                                        request,
                                    )
                                    .await
                            };
                            Box::pin(fut)
                        }
                    }
                    let accept_compression_encodings = self.accept_compression_encodings;
                    let send_compression_encodings = self.send_compression_encodings;
                    let max_decoding_message_size = self.max_decoding_message_size;
                    let max_encoding_message_size = self.max_encoding_message_size;
                    let inner = self.inner.clone();
                    let fut = async move {
                        let method = SubscribeIcebergCompactionEventSvc(inner);
                        let codec = tonic_prost::ProstCodec::default();
                        let mut grpc = tonic::server::Grpc::new(codec)
                            .apply_compression_config(
                                accept_compression_encodings,
                                send_compression_encodings,
                            )
                            .apply_max_message_size_config(
                                max_decoding_message_size,
                                max_encoding_message_size,
                            );
                        let res = grpc.streaming(method, req).await;
                        Ok(res)
                    };
                    Box::pin(fut)
                }
                _ => {
                    Box::pin(async move {
                        let mut response = http::Response::new(
                            tonic::body::Body::default(),
                        );
                        let headers = response.headers_mut();
                        headers
                            .insert(
                                tonic::Status::GRPC_STATUS,
                                (tonic::Code::Unimplemented as i32).into(),
                            );
                        headers
                            .insert(
                                http::header::CONTENT_TYPE,
                                tonic::metadata::GRPC_CONTENT_TYPE,
                            );
                        Ok(response)
                    })
                }
            }
        }
    }
    impl<T> Clone for HummockManagerServiceServer<T> {
        fn clone(&self) -> Self {
            let inner = self.inner.clone();
            Self {
                inner,
                accept_compression_encodings: self.accept_compression_encodings,
                send_compression_encodings: self.send_compression_encodings,
                max_decoding_message_size: self.max_decoding_message_size,
                max_encoding_message_size: self.max_encoding_message_size,
            }
        }
    }
    /// Generated gRPC service name
    pub const SERVICE_NAME: &str = "hummock.HummockManagerService";
    impl<T> tonic::server::NamedService for HummockManagerServiceServer<T> {
        const NAME: &'static str = SERVICE_NAME;
    }
}