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 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 id(&self) -> &str

Unique identifier for this extension.

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 'life0: 'async_trait, 'life1: 'async_trait, ProcessExtension: 'async_trait,

Call an extension-provided tool.

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: UnboundedSender<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: UnboundedSender<InvokeCommandEvent>, ) -> 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 sidecar_spawn_args<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<SidecarSpawnArgs, String>> + Send + 'async_trait>>

where 'life0: 'async_trait, ProcessExtension: '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 '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, UnboundedReceiver<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.