laminar-core 0.26.0

Core streaming engine for LaminarDB - operators, checkpoint barriers, and streaming primitives
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Cross-instance shuffle over Tonic gRPC client-streaming: one
//! client-streaming call per peer pair carrying [`ShuffleMessage`](crate::shuffle::message::ShuffleMessage) frames.
//! Backpressure is the HTTP/2 flow-control window plus the bounded crossfire
//! inbound queue on the consuming side. The real transport is compiled under
//! `cluster`; the default build keeps a networking-free shim.

pub mod barrier_tracker;
pub mod message;
pub mod routing;
pub mod transport;

pub use barrier_tracker::BarrierTracker;
pub use message::ShuffleMessage;
pub use routing::{
    row_vnodes, slice_batch_by_targets, slice_batch_by_vnode, slice_batch_by_vnodes,
};
#[cfg(feature = "cluster")]
pub use transport::SHUFFLE_ADDR_KEY;
pub use transport::{ShufflePeerId, ShuffleReceiver, ShuffleSender};