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<Self, String>

pub async fn spawn_with_cwd( id: &str, command: &str, args: &[String], cwd: Option<PathBuf>, ) -> Result<Self, 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) -> Self

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, input: Value, ) -> Pin<Box<dyn Future<Output = Result<Value, String>> + Send + 'async_trait>>

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

Call an extension-provided tool.

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

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

Call an extension-provided tool on behalf of a conversation.

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

where Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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 Self: 'async_trait, 'life0: 'async_trait,

Fetch optional plugin capability/build/model information.

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

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

Ask the plugin to supply sidecar spawn arguments. Used by the modality-neutral sidecar bootstrap path (see crate::sidecar::spawn); plugins that don’t host a sidecar should leave the default Err in place. Core treats the returned [SidecarSpawnArgs::args] as opaque.

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: '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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: '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 Self: 'async_trait, 'life0: 'async_trait,

Current health state of this handler.