Struct GatewayExecutors 

pub struct GatewayExecutors { /* private fields */ }

Shared, per-server registry of gateway-owned tool executors.

Built once at startup (GatewayExecutors::from_env) and reused across every request. Configured and request-declared MCP servers are discovered lazily unless handlers were registered with Self::insert.

Implementations

impl GatewayExecutors

pub fn from_env(client: Arc<Client>) -> Self

pub fn from_config( client: Arc<Client>, config: &ToolRuntimeConfig, ) -> Result<Self, ToolError>

Builds the shared executors without contacting configured MCP servers.

Configured allowed_tools are applied during discovery, so the stored handler set is the maximum set that a request may use.

Errors

Invalid policy configuration is returned as an error. Connection and discovery happen when a configured server is requested.

pub fn insert(&mut self, registration: impl Into<GatewayExecutorRegistration>)

pub fn web_search_handler(&self) -> Option<Arc<dyn GatewayExecutor>>

pub async fn mcp_handler( &mut self, param: &McpToolParam, ) -> Result<Vec<McpDiscoveredHandler>, ToolError>

Returns the discovered handlers for one request-declared MCP server.

Errors

Returns a configuration error for an invalid declaration or an empty allowed tool set, and an execution error when the server cannot connect.

Trait Implementations

impl Clone for GatewayExecutors

fn clone(&self) -> GatewayExecutors

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GatewayExecutors

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

Formats the value using the given formatter.

impl Default for GatewayExecutors

fn default() -> GatewayExecutors

Returns the “default value” for a type.