Struct AlignmentGroupCoordinator 

pub struct AlignmentGroupCoordinator { /* private fields */ }

Manages multiple alignment groups.

Provides a single coordination point for all alignment groups in the system. Routes watermark updates to the appropriate group based on source assignment.

Example

use laminar_core::time::{
    AlignmentGroupCoordinator, AlignmentGroupConfig, AlignmentGroupId,
    EnforcementMode, AlignmentAction,
};
use std::time::Duration;

let mut coordinator = AlignmentGroupCoordinator::new();

// Create a group for orders-payments join
let config = AlignmentGroupConfig::new("orders-payments")
    .with_max_drift(Duration::from_secs(300));
coordinator.add_group(config);

// Assign sources to the group
coordinator.assign_source_to_group(0, &AlignmentGroupId::new("orders-payments")).unwrap();
coordinator.assign_source_to_group(1, &AlignmentGroupId::new("orders-payments")).unwrap();

// Report watermarks
let action = coordinator.report_watermark(0, 10_000);
assert_eq!(action, Some(AlignmentAction::Continue));

Implementations

impl AlignmentGroupCoordinator

pub fn new() -> Self

Creates a new coordinator.

pub fn add_group(&mut self, config: AlignmentGroupConfig)

Adds an alignment group.

pub fn remove_group( &mut self, group_id: &AlignmentGroupId, ) -> Option<WatermarkAlignmentGroup>

Removes an alignment group.

pub fn assign_source_to_group( &mut self, source_id: usize, group_id: &AlignmentGroupId, ) -> Result<(), AlignmentError>

Assigns a source to a group.

Errors

Returns an error if the group doesn’t exist or the source is already assigned to another group.

pub fn unassign_source(&mut self, source_id: usize)

Removes a source from its group.

pub fn report_watermark( &mut self, source_id: usize, watermark: i64, ) -> Option<AlignmentAction>

Reports a watermark update.

Returns the action for the source, or None if source not in any group.

pub fn check_all_alignments(&mut self) -> Vec<(usize, AlignmentAction)>

Checks alignment for all groups.

Returns all resume/pause actions across all groups.

pub fn all_metrics(&self) -> FxHashMap<AlignmentGroupId, AlignmentGroupMetrics>

Returns metrics for all groups.

pub fn group( &self, group_id: &AlignmentGroupId, ) -> Option<&WatermarkAlignmentGroup>

Returns a reference to a specific group.

pub fn group_mut( &mut self, group_id: &AlignmentGroupId, ) -> Option<&mut WatermarkAlignmentGroup>

Returns a mutable reference to a specific group.

pub fn source_group(&self, source_id: usize) -> Option<&AlignmentGroupId>

Returns the group ID for a source.

pub fn group_count(&self) -> usize

Returns the number of groups.

pub fn total_source_count(&self) -> usize

Returns the total number of sources across all groups.

pub fn should_resume(&self, source_id: usize) -> bool

Checks if a source should resume.

pub fn is_paused(&self, source_id: usize) -> bool

Checks if a source is paused.

Trait Implementations

impl Debug for AlignmentGroupCoordinator

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

Formats the value using the given formatter.

impl Default for AlignmentGroupCoordinator

fn default() -> AlignmentGroupCoordinator

Returns the “default value” for a type.