async fn build_shuffle_receiver(
discovery: &DiscoveryImpl,
node_id: NodeId,
) -> Result<Arc<ShuffleReceiver>, ClusterStartupError>Expand description
Bind the ShuffleReceiver. When gossip discovery is active, publish
the bound address under SHUFFLE_ADDR_KEY so peer senders can
discover it on first send.