Struct ProcessPlugin 

pub struct ProcessPlugin { /* private fields */ }

Plugin that tracks spawned processes and provides LLM tool access.

Management-only (no command execution)

let plugin = ProcessPlugin::with_scope(scope);
// Provides: list_processes, kill_process, process_stats,
//           wait_for_process, read_process_output

Full command execution

let ctx = Arc::new(SandboxContext::new(config, registry, scope, container));
let plugin = ProcessPlugin::with_context(ctx);
// Provides all management tools PLUS:
//   run_command, open_shell, shell_write, shell_read

Implementations

impl ProcessPlugin

pub fn new(registry: Arc<RwLock<ProcessRegistry>>) -> Self

Create a plugin with management tools only.

Convenience constructor that wraps the registry in a ProcessVisibilityScope with no child registries.

pub fn with_scope(scope: ProcessVisibilityScope) -> Self

Create a plugin with management tools backed by a visibility scope.

Use this when the agent has sub-agents whose process registries should be visible to read-only tools (list, stats, wait, read_output).

pub fn with_context(ctx: Arc<SandboxContext>) -> Self

Create a plugin with all tools: management + command execution.

The SandboxContext provides the OCI runtime, sandbox config, and process registry needed by run_command, open_shell, shell_write, and shell_read.

Trait Implementations

impl Plugin for ProcessPlugin

fn name(&self) -> &'static str

Plugin name (used for debugging and logging).

fn tools(&self) -> Vec<Arc<dyn Tool>>

Tools contributed by this plugin.

fn on_user_message<'a>( &'a self, _input: &'a PluginInput, _state: &'a PluginStateMap, ) -> Pin<Box<dyn Future<Output = Vec<Directive>> + Send + 'a>>

Called when a user message arrives.

fn on_event<'a>( &'a self, _event: &'a AgentEvent, _state: &'a PluginStateMap, ) -> Pin<Box<dyn Future<Output = Vec<Directive>> + Send + 'a>>

Called when an agent event is emitted.

fn before_run<'a>( &'a self, _state: &'a PluginStateMap, ) -> Pin<Box<dyn Future<Output = Vec<Directive>> + Send + 'a>>

Called before each agent run loop iteration.

fn after_run<'a>( &'a self, _state: &'a PluginStateMap, ) -> Pin<Box<dyn Future<Output = Vec<Directive>> + Send + 'a>>

Called after each agent run loop iteration.

fn signal_routes(&self) -> Vec<SignalRoute>

Signal routes contributed by this plugin.