pub struct TopologyCheckpointCut {
pub inventory: CheckpointArtifactInventory,
pub bound_sequence: u64,
pub committed: Option<TopologyCutCommit>,
pub completed_participants: Vec<CheckpointParticipant>,
}Expand description
Binding installed atomically with artifact admission, before any source barrier is injected.
Fields§
§inventory: CheckpointArtifactInventoryExact deployment, old pipeline ABI, attempt and owner-complete process roster.
bound_sequence: u64Shared append that bound this attempt and admitted its artifacts.
committed: Option<TopologyCutCommit>A Commit alone does not prove that the leader finished external sink settlement.
completed_participants: Vec<CheckpointParticipant>Sorted processes whose runtime-owned tails finished applying the cut. The leader reports after external sink settlement; followers finish their local checkpoint. Their intake remains held; these receipts do not prove actor retirement or target readiness.
Trait Implementations§
Source§impl Clone for TopologyCheckpointCut
impl Clone for TopologyCheckpointCut
Source§impl Debug for TopologyCheckpointCut
impl Debug for TopologyCheckpointCut
Source§impl<'de> Deserialize<'de> for TopologyCheckpointCut
impl<'de> Deserialize<'de> for TopologyCheckpointCut
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>,
Deserialize this value from the given Serde deserializer. Read more
impl Eq for TopologyCheckpointCut
Source§impl PartialEq for TopologyCheckpointCut
impl PartialEq for TopologyCheckpointCut
Source§impl Serialize for TopologyCheckpointCut
impl Serialize for TopologyCheckpointCut
impl StructuralPartialEq for TopologyCheckpointCut
Auto Trait Implementations§
impl Freeze for TopologyCheckpointCut
impl RefUnwindSafe for TopologyCheckpointCut
impl Send for TopologyCheckpointCut
impl Sync for TopologyCheckpointCut
impl Unpin for TopologyCheckpointCut
impl UnsafeUnpin for TopologyCheckpointCut
impl UnwindSafe for TopologyCheckpointCut
Blanket Implementations§
impl<T> Allocation for T
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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> 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
Compare self to
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> ⓘ
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 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>
Wrap the input message
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>,
Applies the layer to a service and wraps it in [
Layered].§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.