Struct timely_util::Pipeline
source · pub struct Pipeline;Expand description
A direct connection
Trait Implementations§
source§impl<T, D> ParallelizationContract<T, D> for Pipelinewhere
T: 'static,
D: 'static,
impl<T, D> ParallelizationContract<T, D> for Pipelinewhere
T: 'static,
D: 'static,
§type Pusher = LogPusher<T, D, Pusher<Message<Message<T, D>>, Pusher<Message<Message<T, D>>>>>
type Pusher = LogPusher<T, D, Pusher<Message<Message<T, D>>, Pusher<Message<Message<T, D>>>>>
Type implementing
Push produced by this pact.§type Puller = LogPuller<T, D, Puller<Message<Message<T, D>>, Puller<Message<Message<T, D>>>>>
type Puller = LogPuller<T, D, Puller<Message<Message<T, D>>, Puller<Message<Message<T, D>>>>>
Type implementing
Pull produced by this pact.source§fn connect<A>(
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger<TimelyEvent, usize>>
) -> (<Pipeline as ParallelizationContract<T, D>>::Pusher, <Pipeline as ParallelizationContract<T, D>>::Puller)where
A: AsWorker,
fn connect<A>(
self,
allocator: &mut A,
identifier: usize,
address: &[usize],
logging: Option<Logger<TimelyEvent, usize>>
) -> (<Pipeline as ParallelizationContract<T, D>>::Pusher, <Pipeline as ParallelizationContract<T, D>>::Puller)where
A: AsWorker,
Allocates a matched pair of push and pull endpoints implementing the pact.