Struct ChunkJob 

pub struct ChunkJob<I, O> { /* private fields */ }

A validated single-step chunk job definition.

Implementations

impl<I, O> ChunkJob<I, O>

pub fn new( name: JobName, step: ChunkStep<I, O>, revision: DefinitionRevision, components: &ChunkComponentRevisions, ) -> Result<Self, DefinitionError>

Constructs a chunk job with explicit restart-relevant revisions.

Errors

Returns DefinitionError::ManifestEncoding if the bounded canonical manifest cannot be encoded, and DefinitionError::DeliveryModeMismatch when an installed fault runtime declares a different delivery mode than the restart contract.

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

Borrows the in-memory compatibility plan this wrapper lowers into.

The plan retains the wrapper’s original manifest bytes, format, and fingerprint and records no durable flow decision.

pub const fn definition_identity(&self) -> &DefinitionIdentity

Borrows the exact restart-relevant definition identity.

pub fn with_listener(self, listener: Arc<dyn JobExecutionListener>) -> Self

Registers a job listener in deterministic before-order.

pub const fn name(&self) -> &JobName

Borrows the job name.

pub const fn step_name(&self) -> &StepName

Borrows the chunk-step name.

Trait Implementations

impl<I, O> Debug for ChunkJob<I, O>

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

Formats the value using the given formatter.