Struct ShuffleReceiver 

pub struct ShuffleReceiver { /* private fields */ }

Inbound side of the shuffle fabric.

Binds a TcpListener and surfaces every frame received from any peer — prefixed with that peer’s id — on the subscribe channel.

Implementations

impl ShuffleReceiver

pub async fn bind(local_id: ShufflePeerId, addr: SocketAddr) -> Result<Self>

Bind on addr and start accepting peer connections. The bound socket address is surfaced via Self::local_addr so callers using an ephemeral port can register themselves with peers.

Errors

Returns io::Error on bind failure.

pub async fn bind_with_kv( local_id: ShufflePeerId, addr: SocketAddr, kv: Arc<dyn ClusterKv>, ) -> Result<Self>

Bind + publish the listener’s address into kv under SHUFFLE_ADDR_KEY so that peer ShuffleSenders can discover us via ShuffleSender::with_kv.

Errors

Returns io::Error on bind failure.

pub fn local_addr(&self) -> SocketAddr

Local socket address the listener is bound to.

pub async fn recv(&self) -> Option<(ShufflePeerId, ShuffleMessage)>

Await the next (peer_id, msg) from any connected peer.

pub fn drain_available(&self) -> Vec<(ShufflePeerId, ShuffleMessage)>

Drain every currently-available (peer_id, msg) without blocking. Returns immediately when the internal queue is empty.

Used by the row-shuffle aggregator path to pull remote rows into the current streaming cycle without waiting for more. Uses tokio::sync::Mutex::try_lock so a concurrent recv() doesn’t block us — we just skip this tick when contended (next tick picks up the messages).

Trait Implementations

impl Debug for ShuffleReceiver

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

Formats the value using the given formatter.

impl Drop for ShuffleReceiver

fn drop(&mut self)

Executes the destructor for this type.