Struct DistributorPact

pub struct DistributorPact<B>(pub B);

Intended to wrap a function from a usize to an impl Distributor.

For a D: Distributor<C> and an appropriate builder D::new(peers: usize), a DistributorPact(|peers| D::new(peers)) acts as a pact that will use D and distribute containers of type C.

Tuple Fields

0: B

Implementations

impl<CB, F> DistributorPact<Box<dyn FnOnce(usize) -> DrainContainerDistributor<CB, F>>>

where CB: LengthPreservingContainerBuilder, CB::Container: DrainContainer, for<'a> F: FnMut(&<CB::Container as DrainContainer>::Item<'a>) -> u64 + 'static,

pub fn new_core(func: F) -> ExchangeCore<CB, F>

Allocates a new Exchange pact from a distribution function.

impl<C, F> DistributorPact<Box<dyn FnOnce(usize) -> DrainContainerDistributor<CapacityContainerBuilder<C>, F>>>

where C: Container + SizableContainer + DrainContainer, for<'a> F: FnMut(&C::Item<'a>) -> u64 + 'static,

pub fn new(func: F) -> ExchangeCore<CapacityContainerBuilder<C>, F>

Allocates a new Exchange pact from a distribution function.

Trait Implementations

impl<T, B, C, D> ParallelizationContract<T, C> for DistributorPact<B>

where T: Timestamp, B: FnOnce(usize) -> D, C: Accountable + ContainerBytes + Send + 'static, D: Distributor<C> + 'static,

type Pusher = Exchange<T, LogPusher<Box<dyn Push<Message<T, C>>>>, D>

Type implementing Push produced by this pact.

type Puller = LogPuller<Box<dyn Pull<Message<T, C>>>>

Type implementing Pull produced by this pact.

fn connect<A: AsWorker>( self, allocator: &mut A, identifier: usize, address: Rc<[usize]>, logging: Option<TimelyLogger>, ) -> (Self::Pusher, Self::Puller)

Allocates a matched pair of push and pull endpoints implementing the pact.