Struct FlowJob 

pub struct FlowJob { /* private fields */ }

An executable binding for one compiled format-2 or bounded split flow.

Implementations

impl FlowJob

pub fn with_chunk_step<I, O>( self, node_id: NodeId, step: ChunkStep<I, O>, revisions: &ChunkComponentRevisions, ) -> Result<Self, FlowJobError>

where I: Send + Sync + 'static, O: Send + Sync + 'static,

Binds a stateful chunk step to one compiled flow node.

The chunk’s size, component revisions, delivery mode, and fault policy must exactly match the immutable plan. The component is erased only at the existing tasklet composition boundary; item calls keep the accepted M3 boxed component contract.

Errors

Returns crate::FlowJobError::ComponentMismatch when executable and manifest declarations differ, or the ordinary binding errors for an unknown, wrong-kind, duplicate, or differently named node.

impl FlowJob

pub fn new( name: JobName, plan: CompiledExecutionPlan, ) -> Result<Self, FlowJobError>

Starts binding executable components to a compiled format-2 or format-3 plan.

Errors

Rejects a compatibility plan or a plan identified under another job.

pub fn with_tasklet_step( self, node_id: NodeId, step: TaskletStep, ) -> Result<Self, FlowJobError>

Binds one tasklet step to a compiled step node.

Errors

Rejects an unknown node, a decision node, a name mismatch, or a second binding for the same logical ID.

pub fn with_decider( self, node_id: NodeId, decider: Arc<dyn JobExecutionDecider>, ) -> Result<Self, FlowJobError>

Binds one deterministic decider to a compiled decision node.

Errors

Rejects an unknown/step node or a duplicate binding.

pub fn with_split_tasklet_factory( self, node_id: NodeId, factory: TaskletStepFactory, ) -> Result<Self, FlowJobError>

Binds a launch-scoped tasklet factory to one embedded split step.

Errors

Rejects an unknown/non-tasklet branch step, a declared-name mismatch, or a second binding for the same logical ID.

pub fn with_partitioned_tasklet( self, node_id: NodeId, partitioner: PartitionPlanFactory, worker: PartitionTaskletFactory, ) -> Result<Self, FlowJobError>

Binds a deterministic plan factory and independent tasklet factory to one compiled local partition manager.

Errors

Rejects an unknown/non-tasklet partition node, worker-name mismatch, or duplicate binding.

pub fn validate(&self) -> Result<(), FlowJobError>

Validates that every compiled node has exactly one executable binding.

Errors

Returns the first missing node in canonical identifier order.

pub const fn compiled_plan(&self) -> &CompiledExecutionPlan

Borrows the compiled plan.

Trait Implementations

impl Debug for FlowJob

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.