pub struct PipelineExecutor { /* private fields */ }Expand description
Pipeline executor for chained operations
Implementations§
Source§impl PipelineExecutor
impl PipelineExecutor
Sourcepub fn execute_two_stage<I, M, O, S1, S2>(
&self,
inputs: Vec<I>,
stage1: &S1,
stage2: &S2,
progress_message: &str,
) -> Result<PipelineResult<O>>where
I: Send + Sync + Clone,
M: Send + Sync,
O: Send,
S1: PipelineStage<I, M>,
S2: PipelineStage<M, O>,
pub fn execute_two_stage<I, M, O, S1, S2>(
&self,
inputs: Vec<I>,
stage1: &S1,
stage2: &S2,
progress_message: &str,
) -> Result<PipelineResult<O>>where
I: Send + Sync + Clone,
M: Send + Sync,
O: Send,
S1: PipelineStage<I, M>,
S2: PipelineStage<M, O>,
Execute a two-stage pipeline
Sourcepub fn execute_three_stage<I, M1, M2, O, S1, S2, S3>(
&self,
inputs: Vec<I>,
stage1: &S1,
stage2: &S2,
stage3: &S3,
progress_message: &str,
) -> Result<PipelineResult<O>>where
I: Send + Sync + Clone,
M1: Send + Sync,
M2: Send + Sync,
O: Send,
S1: PipelineStage<I, M1>,
S2: PipelineStage<M1, M2>,
S3: PipelineStage<M2, O>,
pub fn execute_three_stage<I, M1, M2, O, S1, S2, S3>(
&self,
inputs: Vec<I>,
stage1: &S1,
stage2: &S2,
stage3: &S3,
progress_message: &str,
) -> Result<PipelineResult<O>>where
I: Send + Sync + Clone,
M1: Send + Sync,
M2: Send + Sync,
O: Send,
S1: PipelineStage<I, M1>,
S2: PipelineStage<M1, M2>,
S3: PipelineStage<M2, O>,
Execute a three-stage pipeline
Sourcepub fn error_collector(&self) -> &ErrorCollector
pub fn error_collector(&self) -> &ErrorCollector
Get error collector
Trait Implementations§
Auto Trait Implementations§
impl Freeze for PipelineExecutor
impl RefUnwindSafe for PipelineExecutor
impl Send for PipelineExecutor
impl Sync for PipelineExecutor
impl Unpin for PipelineExecutor
impl UnsafeUnpin for PipelineExecutor
impl UnwindSafe for PipelineExecutor
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
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> Pointable for T
impl<T> Pointable for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<R, P> ReadPrimitive<R> for P
impl<R, P> ReadPrimitive<R> for P
Source§fn read_from_little_endian(read: &mut R) -> Result<Self, Error>
fn read_from_little_endian(read: &mut R) -> Result<Self, Error>
Read this value from the supplied reader. Same as
ReadEndian::read_from_little_endian().