Struct ShuffleSender 

pub struct ShuffleSender { /* private fields */ }

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

Implementations

impl ShuffleSender

pub fn new(local_id: ShufflePeerId) -> Self

Empty sender. Peers must be added via register_peer or discovered via the KV in with_kv before any send_to.

pub fn with_kv(local_id: ShufflePeerId, kv: Arc<dyn ClusterKv>) -> Self

Construct a sender that falls back to kv when send_to is called for a peer not previously registered. The KV is read from the peer’s own state at SHUFFLE_ADDR_KEY.

pub async fn register_peer(&self, peer: ShufflePeerId, addr: SocketAddr)

Register (or update) a peer’s shuffle address. Must be called before send_to(peer, ..).

pub async fn send_to( &self, peer: ShufflePeerId, msg: &ShuffleMessage, ) -> Result<()>

Send msg to peer, opening a connection if necessary.

Errors

Returns io::Error on connect failure, peer-unregistered, or frame write failure.

pub async fn fan_out_barrier( &self, peers: &[ShufflePeerId], barrier: CheckpointBarrier, ) -> Result<()>

Ship barrier to every peer in order. Short-circuits on the first send failure; the gossip side-channel is the authoritative announcement so a partial fan-out is tolerable.

Errors

Returns the first io::Error from any peer’s send_to.

Trait Implementations

impl Debug for ShuffleSender

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

Formats the value using the given formatter.