Struct SingleThreadHook 

pub struct SingleThreadHook { /* private fields */ }

Hook that limits each caller to one active agent prompt at a time.

The hook stores a per-caller lease in the context cache when an agent starts and removes it when the agent ends. The TTL prevents stale leases from blocking a caller forever after an interrupted process.

Implementations

impl SingleThreadHook

pub fn new(ttl: Duration) -> Self

Creates a single-thread hook with the lease time-to-live.

Trait Implementations

impl Hook for SingleThreadHook

fn on_agent_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 AgentCtx, _agent: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), BoxError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called before an agent is executed.

fn on_agent_end<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 AgentCtx, _agent: &'life2 str, output: AgentOutput, ) -> Pin<Box<dyn Future<Output = Result<AgentOutput, BoxError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called after an agent is executed.

fn on_tool_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 BaseCtx, _tool: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), BoxError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called before a tool is called.

fn on_tool_end<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 BaseCtx, _tool: &'life2 str, output: ToolOutput<Json>, ) -> Pin<Box<dyn Future<Output = Result<ToolOutput<Json>, BoxError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called after a tool is called.