Enum timely_communication::allocator::generic::Generic [−][src]
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
[src]
impl Generic
pub fn index(&self) -> usize
[src]
pub fn index(&self) -> usize
The index of the worker out of (0..self.peers())
.
pub fn peers(&self) -> usize
[src]
pub fn peers(&self) -> usize
The number of workers.
pub fn pre_work(&mut self)
[src]
pub fn pre_work(&mut self)
Perform work before scheduling operators.
pub fn post_work(&mut self)
[src]
pub fn post_work(&mut self)
Perform work after scheduling operators.
Trait Implementations
impl Allocate for Generic
[src]
impl Allocate for Generic
fn index(&self) -> usize
[src]
fn index(&self) -> usize
The index of the worker out of (0..self.peers())
.
fn peers(&self) -> usize
[src]
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>>>)
[src]
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)
[src]
fn pre_work(&mut self)
Work performed before scheduling dataflows.
fn post_work(&mut self)
[src]
fn post_work(&mut self)
Work performed after scheduling dataflows.