Struct BarrierCut 

pub struct BarrierCut {
    pub group: String,
    pub epoch: i64,
    pub triggered_at: i64,
    pub completed_at: i64,
    pub status: CutStatus,
    pub offsets: Position,
    pub missing: BTreeSet<TopicPartition>,
}

One epoch’s cut across every partition of a barrier group.

A cut names an exact position in every input at once: the offset of the epoch’s marker in each partition. The marker is a Kafka control record, so no consumer receives it and the cut offset never holds a data record. The records before the cut of a partition are exactly the records with a lower offset.

CutReader decodes cuts from BARRIER_STATE_TOPIC.

Fields

group: String

The barrier group the coordinator injected markers for.

epoch: i64

The epoch that names this cut inside the group. A coordinator never reuses one.

triggered_at: i64

The time the injection started, in milliseconds since the Unix epoch.

completed_at: i64

The time the coordinator published the cut, in milliseconds since the Unix epoch.

status: CutStatus

Whether every partition received the epoch’s marker.

offsets: Position

The marker offset of every partition that received one, as topic to partition to offset.

missing: BTreeSet<TopicPartition>

The partitions that never received the epoch’s marker. It is empty for a complete cut.

Implementations

impl BarrierCut

pub fn complete(&self) -> bool

Whether every partition of the group received the epoch’s marker.

A runner aligns on a complete cut only.

pub fn offset(&self, topic: &str, partition: i32) -> Option<i64>

The marker offset of one partition, or None when the cut does not name it.

pub fn reached(&self, topic: &str, partition: i32, position: i64) -> bool

Whether a partition delivered everything below the cut.

position is the next offset the task reads. A partition the cut does not name holds nothing back, so it always reports true.

pub fn partitions(&self) -> Vec<TopicPartition>

Every partition the cut names, in topic and then partition order.

Trait Implementations

impl Clone for BarrierCut

fn clone(&self) -> BarrierCut

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BarrierCut

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

Formats the value using the given formatter.

impl Eq for BarrierCut

impl PartialEq for BarrierCut

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for BarrierCut