Struct NodeRouter 

pub struct NodeRouter { /* private fields */ }

Node Router

Routes workflow node execution requests to the appropriate extension service. Uses the registry service to discover which services provide each node.

Implementations

impl NodeRouter

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

Create a new node router with a registry service

pub fn with_timeout(self, timeout_ms: u64) -> Self

Set default timeout for node execution

pub fn with_callback_endpoint(self, endpoint: impl Into<String>) -> Self

Set default callback endpoint

pub async fn register_node( &self, _service_id: ServiceId, node_def: NodeDefinition, )

Register a node from a service

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

Unregister all nodes from a service

pub async fn rebuild_index(&self) -> Result<(), NodeRouterError>

Rebuild the node index from the registry

pub async fn route( &self, node_id: &str, context: NodeContext, request_id: JsonRpcId, required_capabilities: Vec<NodeCapability>, ) -> Result<NodeRouteResult, NodeRouterError>

Route a node execution request

pub async fn has_node(&self, node_id: &str) -> bool

Check if a node is available

pub async fn list_nodes(&self) -> Vec<NodeDefinition>

List all available nodes

pub async fn get_node(&self, node_id: &str) -> Option<NodeDefinition>

Get node definition

pub async fn get_nodes_by_type( &self, node_type: NodeType, ) -> Vec<NodeDefinition>

Get nodes by type

pub async fn get_nodes_by_capability( &self, capability: NodeCapability, ) -> Vec<NodeDefinition>

Get nodes by capability

pub fn create_node_request( &self, route_result: NodeRouteResult, ) -> JsonRpcRequest

Create a JSON-RPC request for node execution

pub fn create_error_response( &self, error: NodeRouterError, request_id: JsonRpcId, ) -> JsonRpcResponse

Create an error response for routing failures

pub async fn node_count(&self) -> usize

Get the count of registered nodes

Trait Implementations

impl Debug for NodeRouter

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

Formats the value using the given formatter.