pub struct ClusterTopologyObjectPlan {
pub name: String,
pub kind: CatalogObjectKind,
pub catalog_generation: u64,
pub transition: ClusterTopologyObjectTransition,
pub initialization: TopologyInitialization,
pub definition_sha256: String,
pub compatibility_sha256: String,
pub dependencies: Vec<String>,
pub schema_sha256: Option<String>,
pub managed_state_contract: Option<String>,
}Expand description
One catalog-bound entry of the local compatibility descriptor, sorted by canonical name.
Fields§
§name: StringStable catalog name, never an optimizer node index.
kind: CatalogObjectKindTyped catalog namespace owner.
catalog_generation: u64Incarnation retained from the parent or newly allocated for future-only activation.
transition: ClusterTopologyObjectTransitionSupported local classification.
initialization: TopologyInitializationRequired activation semantics; no scalar offset is invented during validation.
definition_sha256: StringHash of the same resolved definition used by strict pipeline identity.
compatibility_sha256: StringHash binding identity, schema, ABI, capability, connector contract and dependency closure.
dependencies: Vec<String>Sorted direct catalog dependencies, with their identities transitively bound by the hash.
schema_sha256: Option<String>Resolved Arrow schema hash, absent for sinks.
managed_state_contract: Option<String>Versioned codec name of a managed operator, absent for stateless/source/sink objects.
Implementations§
Source§impl ClusterTopologyObjectPlan
impl ClusterTopologyObjectPlan
Sourcepub fn owns_state_frame(&self, operator_id: &str) -> bool
pub fn owns_state_frame(&self, operator_id: &str) -> bool
Whether operator_id is a state frame of this object: a stream’s operator, or a
materialized view’s operator and the operator that owns its result slices, or a stage
split out of either’s query.
Trait Implementations§
Source§impl Clone for ClusterTopologyObjectPlan
impl Clone for ClusterTopologyObjectPlan
Source§impl Debug for ClusterTopologyObjectPlan
impl Debug for ClusterTopologyObjectPlan
Source§impl<'de> Deserialize<'de> for ClusterTopologyObjectPlan
impl<'de> Deserialize<'de> for ClusterTopologyObjectPlan
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
impl Eq for ClusterTopologyObjectPlan
impl StructuralPartialEq for ClusterTopologyObjectPlan
Auto Trait Implementations§
impl Freeze for ClusterTopologyObjectPlan
impl RefUnwindSafe for ClusterTopologyObjectPlan
impl Send for ClusterTopologyObjectPlan
impl Sync for ClusterTopologyObjectPlan
impl Unpin for ClusterTopologyObjectPlan
impl UnsafeUnpin for ClusterTopologyObjectPlan
impl UnwindSafe for ClusterTopologyObjectPlan
Blanket Implementations§
impl<T> Allocation for T
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> 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> ⓘ
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> ⓘ
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 more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Layered].