Struct ExtensionGateway 

pub struct ExtensionGateway { /* private fields */ }

Extension Gateway

Unified entry point for the MatrixRPC extension system. Coordinates all components: Registry, Lifecycle, Router, and Callback.

Implementations

impl ExtensionGateway

pub fn new() -> Self

Create a new extension gateway

pub fn with_config(config: GatewayConfig) -> Self

Create a new extension gateway with configuration

pub fn subscribe(&self) -> Receiver<GatewayEvent>

Subscribe to gateway events

pub async fn register_service( &self, request: ServiceRegistrationRequest, ) -> Result<ServiceId, GatewayError>

Register a new extension service

pub async fn unregister_service( &self, service_id: &ServiceId, ) -> Result<(), GatewayError>

Unregister a service

pub async fn execute_tool( &self, tool_name: &str, params: JsonValue, request_id: JsonRpcId, ) -> Result<ToolRouteResult, GatewayError>

Execute a tool

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

Execute a node

pub async fn handle_callback( &self, request: JsonRpcRequest, ) -> Result<CallbackResult, GatewayError>

Handle a callback request

pub async fn list_services(&self) -> Vec<ExtensionService>

List all services

pub async fn get_service( &self, service_id: &ServiceId, ) -> Option<ExtensionService>

Get service by ID

pub async fn get_service_by_name(&self, name: &str) -> Option<ExtensionService>

Get service by name

pub async fn list_tools(&self) -> Vec<ToolDefinition>

List all tools

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

List all nodes

pub async fn has_tool(&self, tool_name: &str) -> bool

Check if tool exists

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

Check if node exists

pub async fn registry_stats(&self) -> RegistryStats

Get registry statistics

pub async fn gateway_stats(&self) -> GatewayStats

Get gateway statistics

pub async fn health_check(&self) -> Vec<ServiceId>

Health check all services

pub async fn heartbeat( &self, service_id: &ServiceId, ) -> Result<(), GatewayError>

Send heartbeat for a service

pub async fn get_service_status( &self, service_id: &ServiceId, ) -> Option<ServiceStatus>

Get service status

pub async fn stop_all(&self)

Stop all services

pub fn create_error_response( &self, error: GatewayError, id: JsonRpcId, ) -> JsonRpcResponse

Create JSON-RPC error response

pub fn registry(&self) -> Arc<RegistryService>

Get the registry service

pub fn lifecycle(&self) -> Arc<LifecycleManager>

Get the lifecycle manager

pub fn tool_router(&self) -> Arc<ToolRouter>

Get the tool router

pub fn node_router(&self) -> Arc<NodeRouter>

Get the node router

pub fn callback(&self) -> Arc<CallbackHandler>

Get the callback handler

pub fn security(&self) -> Arc<SecurityValidator>

Get the security validator

Trait Implementations

impl Default for ExtensionGateway

fn default() -> Self

Returns the “default value” for a type.