Struct BulkExecutor 

pub struct BulkExecutor { /* private fields */ }

Executes multiple operations with optional concurrency limits and dry-run support.

Implementations

impl BulkExecutor

pub fn new(concurrency: usize, dry_run: bool) -> Self

pub fn from_config(config: BulkConfig) -> Self

pub fn with_progress(self, show_progress: bool) -> Self

pub fn with_fail_fast(self, fail_fast: bool) -> Self

pub async fn run<T, Fut, F>(&self, items: Vec<T>, job: F) -> Result<()>

where T: Send + Sync + Debug + 'static, F: Fn(T) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send,

pub async fn execute_with_results<T, R, Fut, F>( &self, items: Vec<T>, job: F, ) -> Result<BulkResult<R>>

where T: Send + Sync + Debug + 'static, R: Send + 'static, F: Fn(T) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<R>> + Send,