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

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§

source§

impl Generic

source

pub fn index(&self) -> usize

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

source

pub fn peers(&self) -> usize

The number of workers.

source

pub fn release(&mut self)

Perform work after scheduling operators.

Trait Implementations§

source§

impl Allocate for Generic

source§

fn index(&self) -> usize

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

fn peers(&self) -> usize

The number of workers in the communication group.
source§

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

Constructs several send endpoints and one receive endpoint.
source§

fn receive(&mut self)

Ensure that received messages are surfaced in each channel. Read more
source§

fn release(&mut self)

Signal the completion of a batch of reads from channels. Read more
source§

fn events(&self) -> &Rc<RefCell<Vec<usize>>>

A shared queue of communication events with channel identifier. Read more
source§

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

Awaits communication events. Read more
source§

fn pipeline<T: 'static>( &mut self, identifier: usize ) -> (ThreadPusher<Message<T>>, ThreadPuller<Message<T>>)

Constructs a pipeline channel from the worker to itself. Read more

Auto Trait Implementations§

§

impl !RefUnwindSafe for Generic

§

impl !Send for Generic

§

impl !Sync for Generic

§

impl Unpin for Generic

§

impl !UnwindSafe for Generic

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.