Struct Committed Source Handoff &nbsp; Copy item path

impl CommittedSourceHandoff

pub const fn attempt(&self) -> CheckpointAttempt

Exact committed checkpoint attempt supplying this handoff.

pub const fn checkpoint_assignment_version(&self) -> u64

Assignment version sealed by the committed checkpoint.

pub const fn cluster_watermark(&self) -> CheckpointWatermark

Explicit cluster event-time status at the committed cut.

pub const fn recovery_watermark_frontier(&self) -> Option<i64>

Durable numeric event-time frontier restored with the committed cut.

An idle cut can retain the last active frontier even though it has no currently active input. An uninitialized cut has no recovery frontier.

pub fn source(&self, source: &str) -> Option<&SourceHandoffState>

State for source, or None when the committed cut did not contain it.

pub fn sources( &self, ) -> impl ExactSizeIterator<Item = (&str, &SourceHandoffState)> + DoubleEndedIterator

Iterate the complete source cut in canonical source-name order.

pub fn source_count(&self) -> usize

Number of sources captured in the committed cut.

pub fn is_empty(&self) -> bool

Whether the committed cut contains no sources.

Trait Implementations§

impl Debug for CommittedSourceHandoff

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

Formats the value using the given formatter. Read more

impl Eq for CommittedSourceHandoff

impl PartialEq for CommittedSourceHandoff

fn eq(&self, other: &CommittedSourceHandoff) -> bool

Equality operator ==. Read more

1.0.0 (const: unstable) · Source§

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=. Read more

impl StructuralPartialEq for CommittedSourceHandoff

impl TryFrom<&ClusterRecoveryCapsule> for CommittedSourceHandoff

type Error = String

The type returned in the event of a conversion error.

fn try_from(capsule: &ClusterRecoveryCapsule) -> Result<Self, Self::Error>

Performs the conversion.

Auto Trait Implementations§

impl UnwindSafe for CommittedSourceHandoff

Blanket Implementations§

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

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

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

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

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

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> IntoEither for T

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 more

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

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