Struct DrainContainerDistributor

pub struct DrainContainerDistributor<CB, H> { /* private fields */ }

A distributor creating containers from a drainable container based on a hash function of the container’s item.

Implementations

impl<CB: Default, H> DrainContainerDistributor<CB, H>

pub fn new(hash_func: H, peers: usize) -> Self

Constructs a new DrainContainerDistributor with the given hash function for a number of peers.

Trait Implementations

impl<CB, H> Distributor<<CB as ContainerBuilder>::Container> for DrainContainerDistributor<CB, H>

where CB: ContainerBuilder<Container: DrainContainer> + for<'a> PushInto<<CB::Container as DrainContainer>::Item<'a>>, for<'a> H: FnMut(&<CB::Container as DrainContainer>::Item<'a>) -> u64,

fn partition<T: Clone, P: Push<Message<T, CB::Container>>>( &mut self, container: &mut CB::Container, time: &T, pushers: &mut [P], )

Partition the contents of container at time into the pushers.

fn flush<T: Clone, P: Push<Message<T, CB::Container>>>( &mut self, time: &T, pushers: &mut [P], )

Flush any remaining contents into the pushers at time time.

fn relax(&mut self)

Optionally release resources, such as memory.