Struct PipelineRuntime 

pub struct PipelineRuntime { /* private fields */ }

Implementations

impl PipelineRuntime

pub fn new( pipeline: Pipeline, source: Arc<dyn Source>, transform: Arc<dyn Transform>, sink: Arc<dyn Sink>, checkpoint_store: Arc<dyn CheckpointStore>, dead_letter_store: Arc<dyn DeadLetterStore>, event_store: Arc<dyn PipelineEventStore>, ) -> Self

pub fn execute_manual( &self, context: QueryContext, control: PipelineControl, requested_by: Option<String>, ) -> DataResult<PipelineRun>

pub fn execute_scheduled( &self, context: QueryContext, control: PipelineControl, schedule_id: impl Into<String>, ) -> DataResult<PipelineRun>

pub fn execute_event( &self, context: QueryContext, control: PipelineControl, event: impl Into<String>, payload: Value, ) -> DataResult<PipelineRun>

pub fn execute( &self, command: PipelineRunCommand, context: QueryContext, control: PipelineControl, ) -> DataResult<PipelineRun>

pub fn operation_snapshot( &self, run: &PipelineRun, ) -> DataResult<PipelineOperationSnapshot>