Struct GatewayApplicationPort 

pub struct GatewayApplicationPort { /* private fields */ }

soma-gateway’s GatewayProductState is Arc<GatewayManager> — this adapter takes the manager directly rather than depending on soma-runtime for the type alias, keeping this crate’s dependency shape limited to soma-application, soma-domain, and soma-gateway.

Implementations

impl GatewayApplicationPort

pub fn new(gateway: Arc<GatewayManager>) -> Self

Trait Implementations

impl GatewayPort for GatewayApplicationPort

fn status<'life0, 'life1, 'async_trait>( &'life0 self, context: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Value, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns the gateway’s current status snapshot.

fn reload<'life0, 'life1, 'async_trait>( &'life0 self, request: GatewayReloadRequest, context: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Value, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reloads the gateway configuration.

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, request: GatewayExecuteRequest, context: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Value, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes a gateway operation.

fn list_mcp_tools<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, scope: Option<&'life1 GatewayRouteScope>, context: &'life2 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<GatewayToolRoute>, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Lists MCP tool routes exposed through the gateway, optionally scoped.

fn call_mcp_tool<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, name: &'life1 str, params: Value, scope: Option<&'life2 GatewayRouteScope>, context: &'life3 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Calls an MCP tool by name through the gateway.

fn list_mcp_resources<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, scope: Option<&'life1 GatewayRouteScope>, context: &'life2 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<GatewayResourceRoute>, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Lists MCP resource routes exposed through the gateway, optionally scoped.

fn read_mcp_resource<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, uri: &'life1 str, scope: Option<&'life2 GatewayRouteScope>, context: &'life3 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Reads an MCP resource by URI through the gateway.

fn list_mcp_prompts<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, scope: Option<&'life1 GatewayRouteScope>, context: &'life2 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Vec<GatewayPromptRoute>, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Lists MCP prompt routes exposed through the gateway, optionally scoped.

fn get_mcp_prompt<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, name: &'life1 str, arguments: Option<Map<String, Value>>, scope: Option<&'life2 GatewayRouteScope>, context: &'life3 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, PortError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Gets an MCP prompt by name, with optional arguments, through the gateway.