Struct BatchEngine 

pub struct BatchEngine { /* private fields */ }

Batch processing engine with controlled parallelism.

Implementations

impl BatchEngine

pub fn new() -> Self

pub fn create_batch( &mut self, workflow_id: &str, items: Vec<Value>, concurrency: usize, checkpoint_every: usize, ) -> WorkflowResult<String>

Create a batch job from a list of items.

pub fn get_progress(&self, batch_id: &str) -> WorkflowResult<BatchProgress>

Get batch progress.

pub fn get_report(&self, batch_id: &str) -> WorkflowResult<BatchReport>

Generate batch completion report.

pub fn get_job(&self, batch_id: &str) -> WorkflowResult<&BatchJob>

Get a batch job.

Trait Implementations

impl Default for BatchEngine

fn default() -> Self

Returns the “default value” for a type.