Struct CoreWatermarkState 

pub struct CoreWatermarkState { /* private fields */ }

Per-core partition watermark aggregator.

Each core tracks watermarks for its assigned partitions. The global tracker aggregates across cores.

This is used in thread-per-core architectures where each core processes a subset of partitions.

Implementations

impl CoreWatermarkState

pub fn new(core_id: usize) -> Self

Creates a new per-core watermark state.

pub fn with_partitions(core_id: usize, partitions: Vec<PartitionId>) -> Self

Creates with pre-assigned partitions.

pub fn assign_partition(&mut self, partition: PartitionId)

Assigns a partition to this core.

pub fn remove_partition(&mut self, partition: PartitionId) -> bool

Removes a partition from this core.

pub fn update_partition( &mut self, partition: PartitionId, watermark: i64, ) -> Option<i64>

Updates a partition watermark on this core.

Returns

Some(i64) with the new local watermark if it advances.

pub fn mark_idle(&mut self, partition: PartitionId) -> Option<i64>

Marks a partition as idle on this core.

pub fn local_watermark(&self) -> i64

Returns the local (per-core) watermark.

pub fn core_id(&self) -> usize

Returns the core ID.

pub fn assigned_partitions(&self) -> &[PartitionId]

Returns the assigned partitions.

pub fn partition_count(&self) -> usize

Returns the number of assigned partitions.

Trait Implementations

impl Debug for CoreWatermarkState

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

Formats the value using the given formatter.