Enum timely_communication::allocator::generic::Generic

pub enum Generic {
    Thread(Thread),
    Process(Process),
    ProcessBinary(ProcessAllocator),
    ZeroCopy(TcpAllocator<Process>),
}

Enumerates known implementors of Allocate. Passes trait method calls on to members.

Variants

Thread(Thread)

Intra-thread allocator.

Process(Process)

Inter-thread, intra-process allocator.

ProcessBinary(ProcessAllocator)

Inter-thread, intra-process serializing allocator.

ZeroCopy(TcpAllocator<Process>)

Inter-process allocator.

Methods

impl Generic

pub fn index(&self) -> usize

The index of the worker out of (0..self.peers()).

pub fn peers(&self) -> usize

The number of workers.

pub fn pre_work(&mut self)

Perform work before scheduling operators.

pub fn post_work(&mut self)

Perform work after scheduling operators.

Trait Implementations

impl Allocate for Generic

fn index(&self) -> usize

The index of the worker out of (0..self.peers()).

fn peers(&self) -> usize

The number of workers.

fn allocate<T: Data>(     &mut self,     identifier: usize ) -> (Vec<Box<Push<Message<T>>>>, Box<Pull<Message<T>>>)

Constructs several send endpoints and one receive endpoint.

fn pre_work(&mut self)

Work performed before scheduling dataflows.

fn post_work(&mut self)

Work performed after scheduling dataflows.