Struct mz_storage_client::source::persist_source::PendingWork
source · struct PendingWork {
capability: Capability<(Timestamp, u64)>,
fetched_part: FetchedPart<SourceData, (), Timestamp, Diff>,
}
Expand description
Pending work to read from fetched parts
Fields§
§capability: Capability<(Timestamp, u64)>
The time at which the work should happen.
fetched_part: FetchedPart<SourceData, (), Timestamp, Diff>
Pending fetched part.
Implementations§
source§impl PendingWork
impl PendingWork
sourcefn do_work<P, YFn>(
&mut self,
work: &mut usize,
name: &str,
start_time: Instant,
yield_fn: YFn,
until: &Antichain<Timestamp>,
map_filter_project: Option<&MfpPlan>,
datum_vec: &mut DatumVec,
row_builder: &mut Row,
output: &mut ConsolidateBuffer<'_, '_, (Timestamp, u64), Result<Row, DataflowError>, Diff, P>
) -> boolwhere
P: Push<Bundle<(Timestamp, u64), (Result<Row, DataflowError>, (Timestamp, u64), Diff)>>,
YFn: Fn(Instant, usize) -> bool,
fn do_work<P, YFn>( &mut self, work: &mut usize, name: &str, start_time: Instant, yield_fn: YFn, until: &Antichain<Timestamp>, map_filter_project: Option<&MfpPlan>, datum_vec: &mut DatumVec, row_builder: &mut Row, output: &mut ConsolidateBuffer<'_, '_, (Timestamp, u64), Result<Row, DataflowError>, Diff, P> ) -> boolwhere P: Push<Bundle<(Timestamp, u64), (Result<Row, DataflowError>, (Timestamp, u64), Diff)>>, YFn: Fn(Instant, usize) -> bool,
Perform work, reading from the fetched part, decoding, and sending outputs, while checking
yield_fn
whether more fuel is available.
Auto Trait Implementations§
impl !RefUnwindSafe for PendingWork
impl !Send for PendingWork
impl !Sync for PendingWork
impl Unpin for PendingWork
impl !UnwindSafe for PendingWork
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
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
.