pub struct ModularPipeline {
pub id: String,
pub stages: Vec<PipelineStage>,
pub config: PipelineConfig,
pub metadata: PipelineMetadata,
pub execution_context: Arc<Mutex<ExecutionContext>>,
}Expand description
Modular pipeline for component composition
Fields§
§id: StringPipeline identifier
stages: Vec<PipelineStage>Pipeline stages
config: PipelineConfigPipeline configuration
metadata: PipelineMetadataPipeline metadata
execution_context: Arc<Mutex<ExecutionContext>>Execution context
Implementations§
Source§impl ModularPipeline
impl ModularPipeline
Sourcepub fn new(id: String, config: PipelineConfig) -> Self
pub fn new(id: String, config: PipelineConfig) -> Self
Create a new modular pipeline
Sourcepub fn add_step(&mut self, step: PipelineStep)
pub fn add_step(&mut self, step: PipelineStep)
Add a pipeline step
Sourcepub fn get_step(&self, step_id: &str) -> Option<PipelineStep>
pub fn get_step(&self, step_id: &str) -> Option<PipelineStep>
Get pipeline step by ID
Trait Implementations§
Source§impl Clone for ModularPipeline
impl Clone for ModularPipeline
Source§fn clone(&self) -> ModularPipeline
fn clone(&self) -> ModularPipeline
Returns a duplicate 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 Freeze for ModularPipeline
impl !RefUnwindSafe for ModularPipeline
impl Send for ModularPipeline
impl Sync for ModularPipeline
impl Unpin for ModularPipeline
impl !UnwindSafe for ModularPipeline
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> 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 more