Struct timely::dataflow::channels::message::Message

pub struct Message<T, D> {
    pub time: T,
    pub data: Content<D>,
    pub from: usize,
    pub seq: usize,
}

A serializable representation of timestamped data.

Fields

time: T

The timestamp associated with the message.

data: Content<D>

The data in the message.

from: usize

The source worker.

seq: usize

A sequence number for this worker-to-worker stream.

Methods

impl<T, D> Message<T, D>

fn new(time: T, data: Content<D>, from: usize, seq: usize) -> Message<T, D>

Allocates a new message from a time, content, source worker id, and sequence number.

Trait Implementations

impl<T: Clone, D: Clone> Clone for Message<T, D>

fn clone(&self) -> Message<T, D>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Abomonation + Clone, D: Abomonation> Serialize for Message<T, D>

fn into_bytes(&mut self, bytes: &mut Vec<u8>)

Append the binary representation of self to a vector of bytes. The &mut self argument may be mutated, but the second argument should only be appended to.

fn from_bytes(bytes: &mut Vec<u8>) -> Self

Recover an instance of Self from its binary representation. The &mut Vec<u8> argument may be taken with mem::replace if it is needed.