Type Alias ProgressMsg

pub type ProgressMsg<T> = Bincode<(usize, usize, ChangeBatch<(Location, T)>)>;

A progress update message consisting of source worker id, sequence number and lists of message and internal updates

Aliased Type

struct ProgressMsg<T> {
    pub payload: (usize, usize, ChangeBatch<(Location, T)>),
}

Fields

payload: (usize, usize, ChangeBatch<(Location, T)>)

Bincode contents.

Trait Implementations

impl<T: Data> Bytesable for Bincode<T>

fn from_bytes(bytes: Bytes) -> Self

Wrap bytes as Self.

fn length_in_bytes(&self) -> usize

The number of bytes required to serialize the data.

fn into_bytes<W: Write>(&self, writer: &mut W)

Writes the binary representation into writer.

impl<T: Clone> Clone for Bincode<T>

fn clone(&self) -> Bincode<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Deref for Bincode<T>

type Target = T

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for Bincode<T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T> From<T> for Bincode<T>

fn from(payload: T) -> Self

Converts to this type from the input type.