Struct ChunkStep 

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

A validated one-step chunk definition.

Implementations

impl<I, O> ChunkStep<I, O>

pub fn new( name: StepName, size: ChunkSize, reader: Box<dyn ItemReader<I>>, processor: Arc<dyn ItemProcessor<I, O>>, writer: Arc<dyn ItemWriter<O>>, transactions: Arc<dyn ChunkTransactionManager>, completion: Arc<dyn ChunkCompletion>, ) -> Self

Constructs a chunk step from facade-owned component and transaction ports.

pub fn with_chunk_listener(self, listener: Arc<dyn ChunkListener>) -> Self

Registers a chunk listener in deterministic before-order.

pub fn with_item_listeners(self, listeners: ItemListenerSet<I, O>) -> Self

Installs the authoritative item, retry, and skip listener families.

The set replaces any previously installed families.

pub fn with_fault_runtime(self, fault: FaultRuntime) -> Self

Installs bounded retry, backoff, skip, and rollback behavior.

Without a fault runtime every component failure fails the step after a known rollback, which is the M2 behavior.

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

Registers a step listener in deterministic before-order.

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

Borrows the step name.

pub async fn execute( &mut self, correlation: &ExecutionCorrelation, stop: &StopToken, ) -> ChunkExecutionReport

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

Executes this step deterministically on the caller’s async runtime.

The reader is stateful, so the definition is mutably borrowed for the duration of the run. Only counts returned by successful transaction commits appear in the report. correlation identifies the execution for item, retry, and skip listeners; it never reaches a component.

Trait Implementations

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

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

Formats the value using the given formatter.