Struct HookRunner 

pub struct HookRunner { /* private fields */ }

Dispatcher that manages registered hook handlers.

Void hooks are dispatched in parallel via join_all. Modifying hooks run sequentially by priority (higher first), piping output and short-circuiting on Cancel.

Implementations

impl HookRunner

pub fn new() -> Self

Create an empty runner with no handlers.

pub fn register(&mut self, handler: Box<dyn HookHandler>)

Register a handler and re-sort by descending priority.

pub async fn fire_gateway_start(&self, host: &str, port: u16)

pub async fn fire_gateway_stop(&self)

pub async fn fire_session_start(&self, session_id: &str, channel: &str)

pub async fn fire_session_end(&self, session_id: &str, channel: &str)

pub async fn fire_llm_input(&self, messages: &[ChatMessage], model: &str)

pub async fn fire_llm_output(&self, response: &ChatResponse)

pub async fn fire_after_tool_call( &self, tool: &str, result: &ToolResult, duration: Duration, )

pub async fn fire_message_sent( &self, channel: &str, recipient: &str, content: &str, )

pub async fn fire_heartbeat_tick(&self)

pub async fn run_before_model_resolve( &self, provider: String, model: String, ) -> HookResult<(String, String)>

pub async fn run_before_prompt_build( &self, prompt: String, ) -> HookResult<String>

pub async fn run_before_llm_call( &self, messages: Vec<ChatMessage>, model: String, ) -> HookResult<(Vec<ChatMessage>, String)>

pub async fn run_before_tool_call( &self, name: String, args: Value, ) -> HookResult<(String, Value)>

pub async fn run_on_message_received( &self, message: ChannelMessage, ) -> HookResult<ChannelMessage>

pub async fn run_on_message_sending( &self, channel: String, recipient: String, content: String, ) -> HookResult<(String, String, String)>