Struct ExtensionRunner 

pub struct ExtensionRunner { /* private fields */ }

Orchestrates extension lifecycle and event dispatch.

Implementations

impl ExtensionRunner

pub fn new(cwd: PathBuf) -> Self

Create a new extension runner for the given working directory.

pub fn on_error<F>(&mut self, listener: F) -> ExtensionErrorHandle

where F: Fn(&ExtensionErrorRecord) + Send + Sync + 'static,

Register an error listener and return a handle for unregistering.

pub fn emit_error_record(&self, record: ExtensionErrorRecord)

Emit an error record to all listeners.

pub fn register(&mut self, ext: Arc<dyn Extension>, ctx: &ExtensionContext)

Register an extension into the runner.

pub fn unload_extension(&mut self, name: &str) -> bool

Unregister an extension by name.

pub fn state(&self, name: &str) -> ExtensionState

Get the state of an extension.

pub fn states(&self) -> &HashMap<String, ExtensionState>

Get all extension states.

pub fn extension_order(&self) -> &[String]

Get the extension execution order.

pub fn disable(&mut self, name: &str) -> Result<(), ExtensionError>

Disable an extension.

pub fn enable( &mut self, name: &str, ctx: &ExtensionContext, ) -> Result<(), ExtensionError>

Enable an extension.

pub fn is_enabled(&self, name: &str) -> bool

Check if an extension is enabled.

pub fn has_handlers(&self, _event_type: &str) -> bool

Whether any handlers exist for an event type.

pub fn has_enabled_extensions(&self) -> bool

Whether any extensions are enabled.

pub fn all_tools(&self) -> Vec<Arc<dyn AgentTool>>

Collect all tools from enabled extensions.

pub fn all_commands(&self) -> Vec<Command>

Collect all commands from enabled extensions.

pub fn wrap_tool(&self, tool: Arc<dyn AgentTool>) -> Arc<dyn AgentTool>

Wrap a tool with extension error handling.

pub fn wrap_tools( &self, tools: Vec<Arc<dyn AgentTool>>, ) -> Vec<Arc<dyn AgentTool>>

Wrap multiple tools with extension error handling.

pub fn emit_tool_call( &self, tool_name: &str, params: &Value, ) -> ToolCallEmitResult

Emit before_tool_call and on_tool_call events.

pub fn emit_tool_result_event( &self, tool_name: &str, tool_result: &AgentToolResult, ) -> ToolResultEmitResult

Emit after_tool_call and on_tool_result events.

pub fn emit_input_event(&self, event: &mut InputEvent) -> InputEventResult

Emit input event through extensions.

pub fn emit_context_event(&self, messages: Vec<Message>) -> ContextEmitResult

Emit context event (message modification).

pub fn emit_before_provider_request_event( &self, payload: Value, ) -> ProviderRequestEmitResult

Emit before_provider_request event.

pub fn emit_session_before_switch_event( &self, event: &SessionBeforeSwitchEvent, ) -> SessionBeforeEmitResult

Emit session_before_switch event.

pub fn emit_session_before_fork_event( &self, event: &SessionBeforeForkEvent, ) -> SessionBeforeEmitResult

Emit session_before_fork event.

pub fn emit_session_before_compact_event( &self, event: &SessionBeforeCompactEvent, ) -> SessionBeforeEmitResult

Emit session_before_compact event.

pub fn emit_session_before_tree_event( &self, event: &SessionBeforeTreeEvent, ) -> SessionBeforeEmitResult

Emit session_before_tree event.

pub fn emit_session_shutdown_event(&self, event: &SessionShutdownEvent) -> bool

Emit session_shutdown event.

pub fn emit_event(&self, event: &AgentEvent)

Emit a generic agent event.

pub fn registry(&self) -> &ExtensionRegistry

Access the underlying registry.

pub fn registry_mut(&mut self) -> &mut ExtensionRegistry

Access the underlying registry mutably.

pub fn get(&self, name: &str) -> Option<Arc<dyn Extension>>

Get an extension by name.

pub fn names(&self) -> impl Iterator<Item = &str>

Get all extension names in execution order.

pub fn len(&self) -> usize

Number of extensions.

pub fn is_empty(&self) -> bool

Whether any extensions exist.

pub fn errors(&self) -> Vec<ExtensionErrorRecord>

Get all recorded errors.

pub fn clear_errors(&self)

Clear recorded errors.

Trait Implementations

impl Debug for ExtensionRunner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ExtensionRunner

fn default() -> Self

Returns the “default value” for a type.