laminar_core/shuffle/mod.rs
1//! Cross-instance shuffle: one persistent TCP connection per peer pair,
2//! length-prefixed frames with a 1-byte tag. Backpressure is carried
3//! by the per-partition tokio mpsc on the consuming side.
4
5pub mod barrier_tracker;
6pub mod message;
7pub mod transport;
8
9pub use barrier_tracker::BarrierTracker;
10pub use message::ShuffleMessage;
11#[cfg(feature = "cluster-unstable")]
12pub use transport::SHUFFLE_ADDR_KEY;
13pub use transport::{ShufflePeerId, ShuffleReceiver, ShuffleSender};