pub struct ClusterMetadata {Show 19 fields
pub default_cf: HashMap<Vec<u8>, Vec<u8>>,
pub hummock_version: HummockVersion,
pub version_stats: HummockVersionStats,
pub compaction_groups: Vec<CompactionGroup>,
pub database: Vec<Database>,
pub schema: Vec<Schema>,
pub table: Vec<Table>,
pub index: Vec<Index>,
pub sink: Vec<Sink>,
pub source: Vec<Source>,
pub view: Vec<View>,
pub table_fragments: Vec<TableFragments>,
pub user_info: Vec<UserInfo>,
pub function: Vec<Function>,
pub connection: Vec<Connection>,
pub system_param: SystemParams,
pub cluster_id: String,
pub subscription: Vec<Subscription>,
pub secret: Vec<Secret>,
}
Expand description
For backward compatibility, never remove fields and only append new field.
Fields§
§default_cf: HashMap<Vec<u8>, Vec<u8>>
Unlike other metadata that has implemented MetadataModel
,
DEFAULT_COLUMN_FAMILY
stores various single row metadata, e.g. id offset and epoch offset.
So we use default_cf
stores raw KVs for them.
hummock_version: HummockVersion
§version_stats: HummockVersionStats
§compaction_groups: Vec<CompactionGroup>
§database: Vec<Database>
§schema: Vec<Schema>
§table: Vec<Table>
§index: Vec<Index>
§sink: Vec<Sink>
§source: Vec<Source>
§view: Vec<View>
§table_fragments: Vec<TableFragments>
§user_info: Vec<UserInfo>
§function: Vec<Function>
§connection: Vec<Connection>
§system_param: SystemParams
§cluster_id: String
§subscription: Vec<Subscription>
§secret: Vec<Secret>
Implementations§
source§impl ClusterMetadata
impl ClusterMetadata
pub fn encode_to(&self, buf: &mut Vec<u8>) -> BackupResult<()>
pub fn decode(buf: &[u8]) -> BackupResult<Self>
fn encode_prost_message(message: &impl Message, buf: &mut Vec<u8>)
fn decode_prost_message<T>(buf: &mut &[u8]) -> BackupResult<T>
fn encode_prost_message_list(messages: &[&impl Message], buf: &mut Vec<u8>)
fn decode_prost_message_list<T>(buf: &mut &[u8]) -> BackupResult<Vec<T>>
fn try_decode_prost_message_list<T>( buf: &mut &[u8], ) -> Option<BackupResult<Vec<T>>>
Trait Implementations§
source§impl Clone for ClusterMetadata
impl Clone for ClusterMetadata
source§fn clone(&self) -> ClusterMetadata
fn clone(&self) -> ClusterMetadata
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for ClusterMetadata
impl Debug for ClusterMetadata
source§impl Default for ClusterMetadata
impl Default for ClusterMetadata
source§fn default() -> ClusterMetadata
fn default() -> ClusterMetadata
Returns the “default value” for a type. Read more
source§impl Display for ClusterMetadata
impl Display for ClusterMetadata
source§impl Metadata for ClusterMetadata
impl Metadata for ClusterMetadata
fn encode_to(&self, buf: &mut Vec<u8>) -> BackupResult<()>
fn decode(buf: &[u8]) -> BackupResult<Self>where
Self: Sized,
fn hummock_version_ref(&self) -> &HummockVersion
fn hummock_version(self) -> HummockVersion
source§impl PartialEq for ClusterMetadata
impl PartialEq for ClusterMetadata
impl StructuralPartialEq for ClusterMetadata
Auto Trait Implementations§
impl Freeze for ClusterMetadata
impl RefUnwindSafe for ClusterMetadata
impl Send for ClusterMetadata
impl Sync for ClusterMetadata
impl Unpin for ClusterMetadata
impl UnwindSafe for ClusterMetadata
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
§impl<T> IntoResult<T> for T
impl<T> IntoResult<T> for T
type Err = Infallible
fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>
Creates a shared type from an unshared type.
source§impl<M> MetricVecRelabelExt for M
impl<M> MetricVecRelabelExt for M
source§fn relabel(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level
.source§fn relabel_n(
self,
metric_level: MetricLevel,
relabel_threshold: MetricLevel,
relabel_num: usize,
) -> RelabeledMetricVec<M>
fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n
.source§fn relabel_debug_1(
self,
relabel_threshold: MetricLevel,
) -> RelabeledMetricVec<M>
fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>
Equivalent to
RelabeledMetricVec::with_metric_level_relabel_n
with metric_level
set to
MetricLevel::Debug
and relabel_num
set to 1.