Struct ChainExecutor 

pub struct ChainExecutor { /* private fields */ }

High-performance executor for automation chains.

Features:

• Parallel execution of independent steps
• Response caching with TTL
• Configurable concurrency limits
• Progress tracking and cancellation

Implementations

impl ChainExecutor

pub fn new() -> Self

Create a new executor with default settings.

pub fn with_concurrency(max_concurrency: usize) -> Self

Create with custom concurrency limit.

pub fn with_timeout(self, timeout: Duration) -> Self

Set step timeout.

pub fn with_cache(self, enabled: bool) -> Self

Enable or disable caching.

pub fn max_concurrency(&self) -> usize

Get the maximum concurrency limit.

pub async fn execute<F, Fut>( &self, steps: Vec<ChainStep>, context: ChainContext, step_fn: F, ) -> ChainResult

where F: Fn(ChainStep, ChainContext) -> Fut + Clone + Send + Sync + 'static, Fut: Future<Output = ChainStepResult> + Send,

Execute a chain of steps.

Steps are analyzed for dependencies and independent steps are executed in parallel where possible.

pub async fn clear_cache(&self)

Clear the response cache.

Trait Implementations

impl Debug for ChainExecutor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ChainExecutor

fn default() -> Self

Returns the “default value” for a type.