Struct ProcessExtension 

pub struct ProcessExtension { /* private fields */ }

A running extension process communicating via JSON-RPC 2.0 over stdio.

Implementations

impl ProcessExtension

pub async fn force_shutdown(&self)

Abort the child transport immediately. Cancellation uses this rather than waiting for the per-call permit; draining pending responders releases every blocked call/producer.

pub async fn spawn( id: &str, command: &str, args: &[String], ) -> Result<ProcessExtension, String>

pub async fn spawn_with_cwd( id: &str, command: &str, args: &[String], cwd: Option<PathBuf>, ) -> Result<ProcessExtension, String>

Spawn command with args and optional working directory.

Child stderr is captured and forwarded to debug tracing with the extension id so extension authors can inspect diagnostics without corrupting stdout.

pub fn with_restart_policy(self, policy: RestartPolicy) -> ProcessExtension

Override the restart policy. Intended for tests.

pub fn restart_count(&self) -> usize

pub async fn set_permissions(&self, perms: PermissionSet)

Public for tests: set the permission set used by inbound RPC handlers (e.g. memory.append). Called by the manager after manifest validation.

pub async fn initialize( &self, plugin_root: Option<PathBuf>, config: Value, ) -> Result<InitializeCapabilitiesResult, String>

Trait Implementations

impl ExtensionHandler for ProcessExtension

fn handle_no_spawn<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 HookEvent, ) -> Pin<Box<dyn Future<Output = HookResult> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ProcessExtension: 'async_trait,

The worker path: one hook.handle on the running child only. No spawn, no restart (call_no_spawn): a missing child or a dead transport is a failed call, so Continue.

fn id(&self) -> &str

Unique identifier for this extension.

fn lifecycle_snapshot(&self) -> Option<ExtensionLifecycle>

Observe the actual serving runtime without waiting for locks or RPC I/O.

fn call_tool_for<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, name: &'life1 str, input: Value, session_id: Option<&'life2 str>, cwd: Option<&'life3 Path>, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

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

Call an extension-provided tool on behalf of a conversation. The only way to call a tool: every caller says who the call is for.

fn call_tool_as<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, name: &'life1 str, input: Value, session_id: Option<&'life2 str>, cwd: Option<&'life3 Path>, caller: Option<&'life4 Author>, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, ProcessExtension: 'async_trait,

Self::call_tool_for, naming the run that calls: caller is the author of the calling run’s memory binding (None = the call’s context has no binding), sent as tool.call params.caller so an extension can tell a chat from each of its workers. What a registered extension tool calls. Default: Self::call_tool_for, for a handler that has no wire to put it on.

fn provider_complete<'life0, 'async_trait>( &'life0 self, params: ProviderCompleteParams, ) -> Pin<Box<dyn Future<Output = Result<ProviderCompleteResult, String>> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: 'async_trait,

Complete a chat request through an extension-provided model provider.

fn provider_stream<'life0, 'async_trait>( &'life0 self, params: ProviderCompleteParams, sink: Sender<ProviderStreamEvent>, ) -> Pin<Box<dyn Future<Output = Result<ProviderCompleteResult, String>> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: 'async_trait,

Stream a chat request through an extension-provided model provider.

fn invoke_command<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, command: &'life1 str, args: Vec<String>, request_id: &'life2 str, sink: InvokeEventSink, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

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

Invoke a plugin-registered interactive slash command. The handler must forward command.output notifications matching request_id and any task.* notifications to sink. Returns the final response value.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 HookEvent, ) -> Pin<Box<dyn Future<Output = HookResult> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ProcessExtension: 'async_trait,

Handle a hook event. Returns the handler’s decision.

fn get_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<PluginInfo, String>> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: 'async_trait,

Fetch optional plugin capability/build/model information.

fn settings_editor_open<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, category: &'life1 str, field: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

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

Open a plugin-owned custom settings editor and return its initial render payload.

fn settings_editor_key<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, category: &'life1 str, field: &'life2 str, key: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

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

Forward a keypress to the active plugin-owned custom settings editor.

fn settings_editor_commit<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, category: &'life1 str, field: &'life2 str, value: Value, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

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

Ask the plugin to commit a custom editor value selected by the UI.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: 'async_trait,

Gracefully shut down the extension.

fn subscribe_notifications<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = (usize, Receiver<NotificationFrame>)> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: 'async_trait,

Subscribe to raw JSON-RPC notifications from this extension. Returns a monotonic subscription id (for unsubscribing) and a receiver that yields every notification frame. The default implementation returns a channel whose sender is immediately dropped, so the receiver yields None right away — effectively a no-op for handler impls that don’t support notifications.

fn restart_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: 'async_trait,

Number of transport restarts observed by this handler.

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ExtensionHealth> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: 'async_trait,

Current health state of this handler.