pub struct ValDistributor<U: Update, H> { /* private fields */ }Expand description
Distributor that routes RecordedUpdates records to workers by hashing keys.
Trait Implementations§
Source§impl<U: Update, H: for<'a> FnMut(Ref<'a, U::Key>) -> u64> Distributor<RecordedUpdates<U>> for ValDistributor<U, H>
impl<U: Update, H: for<'a> FnMut(Ref<'a, U::Key>) -> u64> Distributor<RecordedUpdates<U>> for ValDistributor<U, H>
Source§fn partition<T: Clone, P: Push<Message<T, RecordedUpdates<U>>>>(
&mut self,
container: &mut RecordedUpdates<U>,
time: &T,
pushers: &mut [P],
)
fn partition<T: Clone, P: Push<Message<T, RecordedUpdates<U>>>>( &mut self, container: &mut RecordedUpdates<U>, time: &T, pushers: &mut [P], )
Partition the contents of
container at time into the pushers.Auto Trait Implementations§
impl<U, H> Freeze for ValDistributor<U, H>where
H: Freeze,
impl<U, H> RefUnwindSafe for ValDistributor<U, H>where
H: RefUnwindSafe,
U: RefUnwindSafe,
impl<U, H> Send for ValDistributor<U, H>
impl<U, H> Sync for ValDistributor<U, H>
impl<U, H> Unpin for ValDistributor<U, H>
impl<U, H> UnsafeUnpin for ValDistributor<U, H>where
H: UnsafeUnpin,
impl<U, H> UnwindSafe for ValDistributor<U, H>where
H: UnwindSafe,
U: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
Source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign, for types that do not implement AddAssign.