Struct PartitionWatermarkState 

pub struct PartitionWatermarkState {
    pub watermark: i64,
    pub last_event_time: i64,
    pub last_activity: Instant,
    pub is_idle: bool,
    pub assigned_core: Option<usize>,
}

Per-partition watermark state.

Tracks the watermark and activity status for a single partition.

Fields

watermark: i64

Current watermark for this partition

last_event_time: i64

Last event time seen

last_activity: Instant

Last activity timestamp (wall clock)

is_idle: bool

Whether this partition is marked idle

assigned_core: Option<usize>

Core assignment (for thread-per-core routing)

Implementations

impl PartitionWatermarkState

pub fn new() -> Self

Creates new partition state.

pub fn with_core(core_id: usize) -> Self

Creates partition state with a specific core assignment.

Trait Implementations

impl Clone for PartitionWatermarkState

fn clone(&self) -> PartitionWatermarkState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionWatermarkState

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

Formats the value using the given formatter.

impl Default for PartitionWatermarkState

fn default() -> Self

Returns the “default value” for a type.