Struct ReceivedShuffle 

pub struct ReceivedShuffle { /* private fields */ }

A received shuffle message whose decoded memory remains admitted until the envelope is dropped. Consumers retain it while processing shallow clones of the message or its batch.

Implementations

impl ReceivedShuffle

pub const fn peer(&self) -> ShufflePeerId

Peer that sent this message.

pub const fn message(&self) -> &ShuffleMessage

Borrow the message without releasing its inbound admission.

pub const fn sender_incarnation(&self) -> Uuid

Sender process incarnation bound by the stream handshake.

pub const fn receiver_incarnation(&self) -> Uuid

Receiver process incarnation bound by the stream handshake.

pub const fn stream_id(&self) -> Uuid

Connection identity bound by the stream handshake.

pub const fn assignment_version(&self) -> u64

Assignment version carried by the stream that delivered this message.

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

Exact checkpoint assignment-certificate digest carried by a barrier.

pub const fn recovery_gen(&self) -> u64

Recovery generation carried by the stream that delivered this message.

pub const fn checkpoint_sequence(&self) -> u64

Data carries its logical-frame sequence. A barrier carries the exclusive data high-water sequence it closes.

pub fn into_parts(self) -> (ShuffleMessage, ShuffleBatchAdmission)

Split the message from any decoded-data admission after its transport scope has been validated.

Trait Implementations

impl Debug for ReceivedShuffle

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

Formats the value using the given formatter.