Struct BatchProcessor 

pub struct BatchProcessor { /* private fields */ }

Batch processor for executing multiple API operations

Implementations

impl BatchProcessor

pub fn new(config: BatchConfig) -> Self

Creates a new batch processor with the given configuration

Panics

Panics if the rate limit is configured as 0 (which would be invalid)

pub async fn parse_batch_file(path: &Path) -> Result<BatchFile, Error>

Parses a batch file from the given path

Errors

Returns an error if:

• The file cannot be read
• The file is not valid JSON or YAML
• The file structure doesn’t match the expected BatchFile format

pub async fn execute_batch( &self, spec: &CachedSpec, batch_file: BatchFile, global_config: Option<&GlobalConfig>, base_url: Option<&str>, dry_run: bool, output_format: &OutputFormat, jq_filter: Option<&str>, ) -> Result<BatchResult, Error>

Executes a batch of operations.

If the batch uses dependency features (capture, capture_append, or depends_on), operations are executed sequentially in topological order with variable interpolation and atomic failure semantics.

Otherwise, operations are executed concurrently using the original parallel execution strategy.

Errors

Returns an error if:

• The dependency graph is invalid (cycles, missing refs)
• Any operation fails in dependent mode (atomic execution)
• Any operation fails and continue_on_error is false in concurrent mode

Panics

Panics if the semaphore is poisoned (should not happen in normal operation)