Struct AlignmentGroupConfig 

pub struct AlignmentGroupConfig {
    pub group_id: AlignmentGroupId,
    pub max_drift: Duration,
    pub update_interval: Duration,
    pub enforcement_mode: EnforcementMode,
}

Configuration for a watermark alignment group.

Fields

group_id: AlignmentGroupId

Group identifier.

max_drift: Duration

Maximum allowed drift between fastest and slowest source.

update_interval: Duration

How often to check alignment (wall clock).

enforcement_mode: EnforcementMode

Whether to pause sources or just emit warnings.

Implementations

impl AlignmentGroupConfig

pub fn new(group_id: impl Into<String>) -> Self

Creates a new configuration with defaults.

pub fn with_max_drift(self, max_drift: Duration) -> Self

Sets the maximum allowed drift.

pub fn with_update_interval(self, interval: Duration) -> Self

Sets the update interval.

pub fn with_enforcement_mode(self, mode: EnforcementMode) -> Self

Sets the enforcement mode.

Trait Implementations

impl Clone for AlignmentGroupConfig

fn clone(&self) -> AlignmentGroupConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AlignmentGroupConfig

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

Formats the value using the given formatter.