Struct BulkExecutor 

pub struct BulkExecutor { /* private fields */ }

Bulk operation executor

Orchestrates parallel execution of bulk operations with:

• Configurable concurrency using semaphores
• Retry logic with exponential backoff
• Progress tracking and callbacks

Implementations

impl BulkExecutor

pub fn new(config: BulkConfig) -> Self

Create a new executor with the given configuration

pub fn config(&self) -> &BulkConfig

Get the configuration

pub async fn execute<F, Fut, P>( &self, operation_id: Uuid, items: Vec<ProcessItem>, processor: F, on_progress: P, ) -> BulkOperationResult

where F: Fn(String) -> Fut + Send + Sync + 'static, Fut: Future<Output = ItemResult> + Send, P: Fn(ProgressUpdate) + Send + Sync + 'static,

Execute a bulk operation with progress tracking

Arguments

• operation_id - Unique identifier for this operation
• items - List of items to process
• processor - Async function to process each item
• on_progress - Callback for progress updates

Type Parameters

• F - Processor function type
• Fut - Future returned by processor