Struct CallbackManager 

pub struct CallbackManager { /* private fields */ }

Callback manager that handles multiple handlers

Implementations

impl CallbackManager

pub fn new() -> Self

Create a new callback manager

pub fn add_handler(self, handler: Arc<dyn CallbackHandler>) -> Self

Add a callback handler

pub fn handlers(&self) -> &[Arc<dyn CallbackHandler>]

Get all handlers

pub fn is_empty(&self) -> bool

Check if there are any handlers

impl CallbackManager

pub async fn dispatch_chain_start(&self, run: &RunTree, inputs: &Value)

Dispatch on_chain_start to all handlers.

pub async fn dispatch_chain_end(&self, run: &RunTree, outputs: &Value)

Dispatch on_chain_end to all handlers.

pub async fn dispatch_chain_error(&self, run: &RunTree, error: &str)

Dispatch on_chain_error to all handlers.

pub async fn dispatch_llm_start(&self, run: &RunTree, messages: &[Message])

Dispatch on_llm_start to all handlers.

pub async fn dispatch_llm_end(&self, run: &RunTree, response: &str)

Dispatch on_llm_end to all handlers.

pub async fn dispatch_llm_error(&self, run: &RunTree, error: &str)

Dispatch on_llm_error to all handlers.

pub async fn dispatch_llm_new_token(&self, run: &RunTree, token: &str)

Dispatch on_llm_new_token to all handlers.

pub async fn dispatch_tool_start( &self, run: &RunTree, tool_name: &str, input: &str, )

Dispatch on_tool_start to all handlers.

pub async fn dispatch_tool_end(&self, run: &RunTree, output: &str)

Dispatch on_tool_end to all handlers.

pub async fn dispatch_tool_error(&self, run: &RunTree, error: &str)

Dispatch on_tool_error to all handlers.

pub async fn dispatch_retriever_start(&self, run: &RunTree, query: &str)

Dispatch on_retriever_start to all handlers.

pub async fn dispatch_retriever_end(&self, run: &RunTree, documents: &[Value])

Dispatch on_retriever_end to all handlers.

pub async fn dispatch_retriever_error(&self, run: &RunTree, error: &str)

Dispatch on_retriever_error to all handlers.

Trait Implementations

impl Clone for CallbackManager

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CallbackManager

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

Formats the value using the given formatter.

impl Default for CallbackManager

fn default() -> Self

Returns the “default value” for a type.