Struct DagExecutorBuilder 

pub struct DagExecutorBuilder { /* private fields */ }

Fluent builder for DagExecutor.

Implementations

impl DagExecutorBuilder

pub fn config(self, config: Config) -> Self

Use a fully custom configuration.

pub fn concurrency(self, n: usize) -> Self

Set the maximum number of concurrently executing tasks.

pub fn storage(self, storage: Arc<dyn Storage>) -> Self

Provide a custom storage backend (defaults to FileStorage at the configured storage_dir, or MemoryStorage when persistence is off).

pub fn retry(self, retry: RetryPolicy) -> Self

Set the retry policy applied to every task.

pub fn circuit_breaker(self, breaker: CircuitBreaker) -> Self

Enable a shared circuit breaker guarding task execution.

pub fn persist(self, persist: bool) -> Self

Toggle state persistence.

pub fn build(self) -> DagExecutor

Finalize the executor.