pub struct FuelingMerge<T> {
pub(crate) since: Antichain<T>,
pub(crate) remaining_work: usize,
}
Fields§
§since: Antichain<T>
§remaining_work: usize
Implementations§
Source§impl<T: Timestamp + Lattice> FuelingMerge<T>
impl<T: Timestamp + Lattice> FuelingMerge<T>
Sourcefn work(&mut self, _: &[SpineBatch<T>], fuel: &mut isize)
fn work(&mut self, _: &[SpineBatch<T>], fuel: &mut isize)
Perform some amount of work, decrementing fuel
.
If fuel
is non-zero after the call, the merging is complete and one
should call done
to extract the merged results.
Sourcefn done(
self,
bs: ArrayVec<SpineBatch<T>, BATCHES_PER_LEVEL>,
log: &mut SpineLog<'_, T>,
) -> Option<SpineBatch<T>>
fn done( self, bs: ArrayVec<SpineBatch<T>, BATCHES_PER_LEVEL>, log: &mut SpineLog<'_, T>, ) -> Option<SpineBatch<T>>
Extracts merged results.
This method should only be called after work
has been called and has
not brought fuel
to zero. Otherwise, the merge is still in progress.
Trait Implementations§
Source§impl<T: Clone> Clone for FuelingMerge<T>
impl<T: Clone> Clone for FuelingMerge<T>
Source§fn clone(&self) -> FuelingMerge<T>
fn clone(&self) -> FuelingMerge<T>
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl<T: Debug> Debug for FuelingMerge<T>
impl<T: Debug> Debug for FuelingMerge<T>
Source§impl<T: PartialEq> PartialEq for FuelingMerge<T>
impl<T: PartialEq> PartialEq for FuelingMerge<T>
Source§impl<T> Serialize for FuelingMerge<T>where
T: Serialize,
impl<T> Serialize for FuelingMerge<T>where
T: Serialize,
impl<T> StructuralPartialEq for FuelingMerge<T>
Auto Trait Implementations§
impl<T> Freeze for FuelingMerge<T>where
T: Freeze,
impl<T> RefUnwindSafe for FuelingMerge<T>where
T: RefUnwindSafe,
impl<T> Send for FuelingMerge<T>where
T: Send,
impl<T> Sync for FuelingMerge<T>where
T: Sync,
impl<T> Unpin for FuelingMerge<T>where
T: Unpin,
impl<T> UnwindSafe for FuelingMerge<T>where
T: RefUnwindSafe + 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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
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<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
Source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.Source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.Source§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
.