Struct DapPlugin 

pub struct DapPlugin { /* private fields */ }

Plugin providing Debug Adapter Protocol integration for agents.

Manages debug adapter client lifecycles, registers DAP tools into the agent’s tool registry, and routes debug events (stopped, terminated) as signals.

Implementations

impl DapPlugin

pub fn new(config: DapPluginConfig) -> Self

Create a new DAP plugin with the given configuration.

The plugin starts with no active clients. Use start_adapter to spawn debug adapter processes.

pub fn with_registry( config: DapPluginConfig, registry: DebugAdapterRegistry, ) -> Self

Create a plugin with a custom adapter registry.

pub async fn start_adapter( &mut self, session_id: &str, adapter_config: &DapAdapterConfig, ) -> Result<Arc<DapClient>, DapError>

Start a debug adapter and register its tools.

The adapter is identified by session_id. If a session with the same ID already exists, it is disconnected first.

Errors

Returns DapError if the adapter fails to spawn or initialize.

pub async fn client(&self, session_id: &str) -> Option<Arc<DapClient>>

Get a client by session ID.

pub async fn disconnect_all(&self)

Disconnect all active sessions (called on plugin shutdown).

pub fn registry(&self) -> &DebugAdapterRegistry

Access the adapter registry.

pub const fn config(&self) -> &DapPluginConfig

Access the plugin configuration.

Trait Implementations

impl Plugin for DapPlugin

fn name(&self) -> &str

Plugin name (used for debugging and logging).

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

Tools contributed by this plugin.

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

Signal routes 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.