Struct GenericRpcToolHandler 

pub struct GenericRpcToolHandler {
    pub plugin_id: String,
    pub plugin: Weak<SubprocessNexoPlugin>,
    pub rpc_method: String,
    pub tool_name: String,
    pub timeout: Duration,
}

ToolHandler impl that dispatches calls to a subprocess plugin via JSON-RPC.

Fields

plugin_id: String

Plugin id (e.g. "telegram"). Used only for diagnostics.

plugin: Weak<SubprocessNexoPlugin>

Weak back-ref to the subprocess plugin adapter. Upgrades to Arc<SubprocessNexoPlugin> on each call; returns None after the plugin’s outer Arc is dropped (e.g. hot-unload, daemon shutdown).

rpc_method: String

JSON-RPC method to invoke. Defaults to "outbound_tool.invoke" per OutboundToolSpec::default_outbound_rpc_method.

tool_name: String

Tool name forwarded as the request’s tool_name field (so the subprocess can dispatch on it without re-parsing the request’s method).

timeout: Duration

Per-call deadline. Plugin-side timeouts take effect first when the plugin imposes a stricter one; this timeout is the host’s safety net.

Implementations

impl GenericRpcToolHandler

pub fn new( plugin_id: impl Into<String>, plugin: Weak<SubprocessNexoPlugin>, rpc_method: impl Into<String>, tool_name: impl Into<String>, timeout: Duration, ) -> Self

Build a handler bound to a specific subprocess plugin adapter. The plugin weak ref MUST come from SubprocessNexoPlugin::weak_self() so respawn cycles install fresh handlers automatically.

Trait Implementations

impl ToolHandler for GenericRpcToolHandler

fn call<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 AgentContext, args: Value, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

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