Struct MetadataV2

Source

pub struct MetadataV2 {Show 37 fields
    pub hummock_version: HummockVersion,
    pub seaql_migrations: Vec<Model>,
    pub version_stats: Vec<Model>,
    pub compaction_configs: Vec<Model>,
    pub clusters: Vec<Model>,
    pub fragment_relation: Vec<Model>,
    pub catalog_versions: Vec<Model>,
    pub connections: Vec<Model>,
    pub databases: Vec<Model>,
    pub fragments: Vec<Model>,
    pub functions: Vec<Model>,
    pub indexes: Vec<Model>,
    pub objects: Vec<Model>,
    pub object_dependencies: Vec<Model>,
    pub schemas: Vec<Model>,
    pub sinks: Vec<Model>,
    pub sources: Vec<Model>,
    pub streaming_jobs: Vec<Model>,
    pub subscriptions: Vec<Model>,
    pub system_parameters: Vec<Model>,
    pub tables: Vec<Model>,
    pub users: Vec<Model>,
    pub user_privileges: Vec<Model>,
    pub views: Vec<Model>,
    pub workers: Vec<Model>,
    pub worker_properties: Vec<Model>,
    pub hummock_sequences: Vec<Model>,
    pub session_parameters: Vec<Model>,
    pub secrets: Vec<Model>,
    pub exactly_once_iceberg_sinks: Vec<Model>,
    pub iceberg_tables: Vec<Model>,
    pub iceberg_namespace_properties: Vec<Model>,
    pub user_default_privilege: Vec<Model>,
    pub fragment_splits: Vec<Model>,
    pub pending_sink_state: Vec<Model>,
    pub refresh_jobs: Vec<Model>,
    pub cdc_table_snapshot_splits: Vec<Model>,
}

Fields§

§hummock_version: HummockVersion§seaql_migrations: Vec<Model>§version_stats: Vec<Model>§compaction_configs: Vec<Model>§clusters: Vec<Model>§fragment_relation: Vec<Model>§catalog_versions: Vec<Model>§connections: Vec<Model>§databases: Vec<Model>§fragments: Vec<Model>§functions: Vec<Model>§indexes: Vec<Model>§objects: Vec<Model>§object_dependencies: Vec<Model>§schemas: Vec<Model>§sinks: Vec<Model>§sources: Vec<Model>§streaming_jobs: Vec<Model>§subscriptions: Vec<Model>§system_parameters: Vec<Model>§tables: Vec<Model>§users: Vec<Model>§user_privileges: Vec<Model>§views: Vec<Model>§workers: Vec<Model>§worker_properties: Vec<Model>§hummock_sequences: Vec<Model>§session_parameters: Vec<Model>§secrets: Vec<Model>§exactly_once_iceberg_sinks: Vec<Model>§iceberg_tables: Vec<Model>§iceberg_namespace_properties: Vec<Model>§user_default_privilege: Vec<Model>§fragment_splits: Vec<Model>§pending_sink_state: Vec<Model>§refresh_jobs: Vec<Model>§cdc_table_snapshot_splits: Vec<Model>

MetadataV2

Struct MetadataV2 Copy item path

Fields§

Trait Implementations§

impl Default for MetadataV2

fn default() -> MetadataV2

impl Display for MetadataV2

fn fmt(&self, f: &mut Formatter<'_>) -> Result

impl Metadata for MetadataV2

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

fn storage_url(&self) -> BackupResult<String>

fn storage_directory(&self) -> BackupResult<String>

Auto Trait Implementations§

impl Freeze for MetadataV2

impl RefUnwindSafe for MetadataV2

impl Send for MetadataV2

impl Sync for MetadataV2

impl Unpin for MetadataV2

impl UnwindSafe for MetadataV2

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> AsAny for Twhere T: Any,

fn as_any(&self) -> &(dyn Any + 'static)

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

fn type_name(&self) -> &'static str

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> Downcast for Twhere T: AsAny + ?Sized,

fn is<T>(&self) -> boolwhere T: AsAny,

fn downcast_ref<T>(&self) -> Option<&T>where T: AsAny,

fn downcast_mut<T>(&mut self) -> Option<&mut T>where T: AsAny,

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<T> IntoResult<T> for T

type Err = Infallible

fn into_result(self) -> Result<T, <T as IntoResult<T>>::Err>

impl<Unshared, Shared> IntoShared<Shared> for Unsharedwhere Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

impl<M> MetricVecRelabelExt for M

fn relabel( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

fn relabel_n( self, metric_level: MetricLevel, relabel_threshold: MetricLevel, relabel_num: usize, ) -> RelabeledMetricVec<M>

fn relabel_debug_1( self, relabel_threshold: MetricLevel, ) -> RelabeledMetricVec<M>

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T> Scope for T

fn with<F, R>(self, f: F) -> Rwhere Self: Sized, F: FnOnce(Self) -> R,

fn with_ref<F, R>(&self, f: F) -> Rwhere F: FnOnce(&Self) -> R,

fn with_mut<F, R>(&mut self, f: F) -> Rwhere F: FnOnce(&mut Self) -> R,

Struct MetadataV2

fn decode(buf: &[u8]) -> BackupResult<Self>
where Self: Sized,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> AsAny for T
where T: Any,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> Downcast for T
where T: AsAny + ?Sized,

fn is<T>(&self) -> bool
where T: AsAny,

fn downcast_ref<T>(&self) -> Option<&T>
where T: AsAny,

fn downcast_mut<T>(&mut self) -> Option<&mut T>
where T: AsAny,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn with<F, R>(self, f: F) -> R
where Self: Sized, F: FnOnce(Self) -> R,

fn with_ref<F, R>(&self, f: F) -> R
where F: FnOnce(&Self) -> R,

fn with_mut<F, R>(&mut self, f: F) -> R
where F: FnOnce(&mut Self) -> R,

impl<T> ToRootSpan for T
where T: Display,

impl<T> ToString for T
where T: Display + ?Sized,

impl<T> ToStringFallible for T
where T: Display,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> LruValue for T
where T: Send + Sync,

impl<T> MaybeSend for T
where T: Send,

impl<T> MaybeSend for T
where T: Send,

impl<T> Value for T
where T: Send + Sync + 'static,