Struct mz_persist_client::internal::trace::FuelingMerge
source · pub struct FuelingMerge<T> {
since: Antichain<T>,
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>, _: &SpineBatch<T>, fuel: &mut isize)
fn work(&mut self, _: &SpineBatch<T>, _: &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,
b1: SpineBatch<T>,
b2: SpineBatch<T>,
log: &mut SpineLog<'_, T>
) -> SpineBatch<T>
fn done( self, b1: SpineBatch<T>, b2: SpineBatch<T>, log: &mut SpineLog<'_, T> ) -> 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 moreAuto Trait Implementations§
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: 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> 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> 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
.