Struct ChainExecutionEngine 

pub struct ChainExecutionEngine { /* private fields */ }

Engine for executing request chains

Implementations

impl ChainExecutionEngine

pub fn new(registry: Arc<RequestChainRegistry>, config: ChainConfig) -> Self

Create a new chain execution engine

Panics

This method will panic if the HTTP client cannot be created, which typically indicates a system configuration issue. For better error handling, use try_new().

pub fn try_new( registry: Arc<RequestChainRegistry>, config: ChainConfig, ) -> Result<Self>

Try to create a new chain execution engine

Returns an error if the HTTP client cannot be created.

pub async fn execute_chain( &self, chain_id: &str, variables: Option<Value>, ) -> Result<ChainExecutionResult>

Execute a chain by ID

pub async fn get_chain_history(&self, chain_id: &str) -> Vec<ExecutionRecord>

Get execution history for a chain

pub async fn execute_chain_definition( &self, chain_def: &ChainDefinition, variables: Option<Value>, ) -> Result<ChainExecutionResult>

Execute a chain definition

Trait Implementations

impl Debug for ChainExecutionEngine

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

Formats the value using the given formatter.