Enum timely_util::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.

Implementations

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 release(&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 in the communication group.

fn allocate<T>(
    &mut self,
    identifier: usize
) -> (Vec<Box<dyn Push<Message<T>> + 'static, Global>, Global>, Box<dyn Pull<Message<T>> + 'static, Global>)where
    T: Data,

Constructs several send endpoints and one receive endpoint.

fn receive(&mut self)

Ensure that received messages are surfaced in each channel.

fn release(&mut self)

Signal the completion of a batch of reads from channels.

fn events(&self) -> &Rc<RefCell<VecDeque<(usize, Event), Global>>>

A shared queue of communication events with channel identifier.

fn await_events(&self, _duration: Option<Duration>)

Awaits communication events.

fn pipeline<T>(
    &mut self,
    identifier: usize
) -> (Pusher<Message<T>, Pusher<Message<T>>>, Puller<Message<T>, Puller<Message<T>>>)where
    T: 'static,

Constructs a pipeline channel from the worker to itself.