Struct MultiStreamCoordinator 

pub struct MultiStreamCoordinator<A: Float + Send + Sync> { /* private fields */ }

Multi-stream coordinator for synchronizing multiple data streams

Implementations

impl<A: Float + Send + Sync> MultiStreamCoordinator<A>

pub fn new(config: &StreamingConfig) -> Result<Self>

pub fn add_stream( &mut self, stream_id: String, config: StreamConfig<A>, priority: StreamPriority, )

Add a new stream

pub fn stream_id_of(point: &StreamingDataPoint<A>) -> &str

The logical stream a data point belongs to.

pub fn record_arrival(&mut self, point: &StreamingDataPoint<A>)

Record the arrival of one sample, registering its stream on first sight (T13: nothing ever fed sync_buffer before, so every coordination decision was made over permanently empty state).

pub fn stream_count(&self) -> usize

Number of streams seen so far.

pub fn arrival_counts(&self) -> &HashMap<String, usize>

Samples observed per stream.

pub fn synchronization_skew_ms(&self) -> Option<f64>

Measured spread between the newest arrival of the earliest stream and that of the latest one, in milliseconds. None while fewer than two streams have been seen (there is nothing to be out of sync with).

pub fn max_sync_window_ms(&self) -> u64

The configured synchronization window in milliseconds.

pub fn stream_freshness_weights(&self) -> HashMap<String, A>

Per-stream freshness weights in (0, 1], computed from how stale each stream’s newest sample is relative to the newest sample overall: 1 / (1 + lag / window). A stream that has stopped producing loses influence smoothly instead of continuing to count as an equal.

pub fn load_balancing_strategy(&self) -> LoadBalancingStrategy

The load balancing strategy in force.

pub fn set_load_balancing_strategy(&mut self, strategy: LoadBalancingStrategy)

Select the load balancing strategy.

pub fn uptime(&self) -> Duration

How long the coordinator has been running.

pub fn coordinate_streams(&mut self) -> Result<Vec<StreamingDataPoint<A>>>

Coordinate data from multiple streams