Struct ShuffleSender 

pub struct ShuffleSender { /* private fields */ }

Lazy pool of ordered streams per peer.

Implementations

impl ShuffleSender

pub fn new(local_id: ShufflePeerId, incarnation: Uuid) -> Self

Empty sender; peers arrive via Self::register_peer or KV discovery.

Panics

Panics when the node ID is zero or the process incarnation is nil.

pub const fn local_id(&self) -> ShufflePeerId

Node id bound into every outbound stream handshake.

pub fn install_process_lease_deadline( &self, deadline: Arc<LeaseDeadline>, ) -> Result<()>

Bind outbound admission to this process’s renewable cluster lease.

This must be installed before an assignment certificate is activated.

Errors

Returns an error for an expired lease, a different previously installed deadline, or an already-active assignment.

pub fn bind_process_lease_deadline_pair( &self, receiver: &ShuffleReceiver, deadline: Arc<LeaseDeadline>, ) -> Result<()>

Bind both directions of one local shuffle fabric to the same process lease.

Validation and installation are serialized across both handles, so an incompatible receiver cannot leave only the sender bound.

Errors

Returns an error without changing either handle when the deadline is expired, either handle is already bound to a different deadline, or an active assignment prevents a new binding.

pub fn install_assignment_fence( &self, fence: &CheckpointAssignmentFence, owners: &[ShufflePeerId], ) -> Result<bool>

Install the exact assignment certificate accepted by outbound shuffle streams. Changing scope closes all pooled streams and resets their scoped sequences.

Errors

Returns an error for a malformed certificate, a same-version certificate conflict, or a certificate that does not bind this exact sender process.

pub fn suspend_assignment_fence(&self)

Temporarily close outbound admission because the durable assignment authority could not be read. Unlike invalidation, this preserves the exact certificate and sequence counters so the same durable head can resume without manufacturing a delivery gap.

pub fn invalidate_assignment_fence(&self)

Reject every stream while a newer assignment is being adopted but has not yet earned an owner-complete process certificate. The last certificate is retained only as a monotonic conflict floor; it is inactive while Self::assignment_version is zero.

pub fn assignment_version(&self) -> u64

Assignment scope currently accepted for newly enqueued frames.

pub fn active_assignment_digest(&self) -> Option<[u8; 32]>

Digest of the exact assignment certificate currently active for outbound streams.

pub fn set_recovery_gen(&self, gen: u64)

Advance the generation stamped onto outbound data frames. Called after a coordinated rewind so peers can discard anything this node produced before it.

pub fn recovery_gen(&self) -> u64

Recovery scope currently accepted for newly enqueued frames.

pub const fn incarnation(&self) -> Uuid

Process incarnation bound into every outbound stream handshake.

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

Sender that falls back to kv discovery for peers not previously registered.

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

Register (or update) a peer’s shuffle address.

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

Send msg to peer, opening a client-streaming call if necessary.

Errors

Returns io::Error when the peer is unregistered/undiscoverable, the endpoint cannot be built, or the per-peer stream has shut down.

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

Send only while the sender remains in expected_assignment_version.

Routing paths use this to prevent data sliced with an old ownership publication from entering a stream opened under a newer assignment scope.

Errors

Returns io::Error when the expected assignment is no longer current, in addition to the errors returned by Self::send_to.

pub async fn establish_assignment_mesh( &self, assignment_fence: &CheckpointAssignmentFence, ) -> Result<()>

Establish an exact-scope stream to every remote assignment participant without sending a frame or consuming a delivery sequence.

Errors

Returns the first peer connection or handshake error after attempting the full roster.

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

Ship barrier to every required peer. All peers are attempted, but any failure rejects the cut so the coordinator can abort promptly.

Errors

Returns the first peer error after attempting the full fan-out.

Trait Implementations

impl Debug for ShuffleSender

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

Formats the value using the given formatter.