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 duplicate 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,
§impl<T> Downcast for Twhere
T: AsAny + ?Sized,
impl<T> Downcast for Twhere
T: AsAny + ?Sized,
§fn downcast_ref<T>(&self) -> Option<&T>where
T: AsAny,
fn downcast_ref<T>(&self) -> Option<&T>where
T: AsAny,
Forward to the method defined on the type
Any.§fn downcast_mut<T>(&mut self) -> Option<&mut T>where
T: AsAny,
fn downcast_mut<T>(&mut self) -> Option<&mut T>where
T: AsAny,
Forward to the method defined on the type
Any.§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.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§impl<T> Scope for T
impl<T> Scope for T
§impl<T> ToRootSpan for Twhere
T: Display,
impl<T> ToRootSpan for Twhere
T: Display,
§fn to_root_span(&self) -> Span
fn to_root_span(&self) -> Span
Convert the type to a [
Span] that can be used as the root of an await-tree.§impl<T> ToStringFallible for Twhere
T: Display,
impl<T> ToStringFallible for Twhere
T: Display,
§fn try_to_string(&self) -> Result<String, TryReserveError>
fn try_to_string(&self) -> Result<String, TryReserveError>
ToString::to_string, but without panic on OOM.