Struct timely::communication::allocator::zero_copy::allocator::TcpAllocator

pub struct TcpAllocator<A>
where
    A: Allocate,
{ /* private fields */ }

A TCP-based allocator for inter-process communication.

Trait Implementations

impl<A> Allocate for TcpAllocator<A>

where A: Allocate,

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<T>>>, Box<dyn Pull<T>>)

where T: Exchangeable,

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<Vec<usize>>>

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<T, Pusher<T>>, Puller<T, Puller<T>>)

where T: 'static,

Constructs a pipeline channel from the worker to itself.