Struct timely::Message

pub struct Message<T> {
    pub payload: T,
}

A wrapper that indicates a serialization/deserialization strategy. A wrapper that indicates bincode as the serialization/deserialization strategy.

Fields

payload: T

Bincode contents.

Implementations

impl<T> Bincode<T>

pub fn from_typed(typed: T) -> Self

Wrap a typed item as a Bincode.

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> Deref for Bincode<T>

type Target = T

The resulting type after dereferencing.

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

Dereferences the value.

impl<T, C: Container, P: Pull<Bundle<T, C>>> Pull<Bincode<Message<T, C>>> for LogPuller<T, C, P>

fn pull(&mut self) -> &mut Option<Bundle<T, C>>

Pulls an element and provides the opportunity to take ownership.

fn recv(&mut self) -> Option<T>

Takes an Option<T> and leaves None behind.

impl<T: Timestamp, C: Container, P> Push<Bincode<Message<T, C>>> for Counter<T, C, P>

where P: Push<Bundle<T, C>>,

fn push(&mut self, message: &mut Option<Bundle<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.

impl<T: Eq + Data, C, P: Push<Bundle<T, C>>, H> Push<Bincode<Message<T, C>>> for Exchange<T, C, P, H>

where C: PushPartitioned + Container, for<'a> H: FnMut(&C::Item<'a>) -> u64,

fn push(&mut self, message: &mut Option<Bundle<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.

impl<T, C: Container, P: Push<Bundle<T, C>>> Push<Bincode<Message<T, C>>> for LogPusher<T, C, P>

fn push(&mut self, pair: &mut Option<Bundle<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.

impl<T: Data, C: Container> Push<Bincode<Message<T, C>>> for Tee<T, C>

fn push(&mut self, message: &mut Option<Bundle<T, C>>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.