Struct NodeExecutor 

pub struct NodeExecutor { /* private fields */ }

Node Executor

Executes workflow node calls through the transport layer with support for timeout, retry, and callback handling.

Implementations

impl NodeExecutor

pub fn new(router: Arc<NodeRouter>, registry: Arc<RegistryService>) -> Self

Create a new node executor

pub fn with_config( router: Arc<NodeRouter>, registry: Arc<RegistryService>, config: NodeExecutionConfig, ) -> Self

Create with custom configuration

pub async fn execute( &self, node_id: &str, context: NodeContext, ) -> Result<NodeExecutionResult, NodeExecutorError>

Execute a node

Routes the execution to the appropriate service and handles callbacks.

pub async fn execute_with_capabilities( &self, node_id: &str, context: NodeContext, required_capabilities: Vec<String>, ) -> Result<NodeExecutionResult, NodeExecutorError>

Execute a node with required capabilities

pub async fn register_connection( &self, service_id: ServiceId, _transport: StdioTransport, )

Register a transport connection for a service

pub async fn remove_connection(&self, service_id: &ServiceId)

Remove a transport connection

pub async fn is_connected(&self, service_id: &ServiceId) -> bool

Check if a service is connected

pub async fn handle_callback( &self, callback_type: &str, request_id: &str, params: Value, ) -> Result<Value, NodeExecutorError>

Handle a callback request from a node

This is called when a node requests AI or tool execution.

Trait Implementations

impl Debug for NodeExecutor

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

Formats the value using the given formatter.