Skip to main content

Module transport

Module transport 

Source
Expand description

TCP shuffle: a per-peer connection pool for senders, an accept loop for receivers. Each frame carries a node id in its handshake so the receiver can attribute incoming traffic. See super::message for the wire format.

Structs§

ShuffleReceiver
Inbound side of the shuffle fabric.
ShuffleSender
Lazy pool of outbound connections, keyed by peer id. Addresses go in via register_peer (manual) or via the KV on first send.

Constants§

SHUFFLE_ADDR_KEY
Gossip KV key used by ShuffleReceiver::bind_with_kv to publish the listener’s socket address, and by ShuffleSender to discover peer addresses on first contact. Value: the bound socket address formatted via SocketAddr::to_string().

Type Aliases§

ShufflePeerId
Peer-local identifier on the wire. Matches cluster::discovery::NodeId’s inner type for seamless conversion.