Struct AsyncCallbackManager 

pub struct AsyncCallbackManager { /* private fields */ }

Async callback manager for LangChain.

Implementations

impl AsyncCallbackManager

pub fn new() -> Self

Create a new async callback manager.

pub fn from_callback_manager(manager: CallbackManager) -> Self

Create from a callback manager.

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

Get the handlers.

pub fn parent_run_id(&self) -> Option<Uuid>

Get the parent run ID.

pub fn set_handlers( &mut self, handlers: Vec<Arc<dyn BaseCallbackHandler>>, inherit: bool, )

Set handlers.

pub fn add_handler( &mut self, handler: Arc<dyn BaseCallbackHandler>, inherit: bool, )

Add handler.

pub fn add_tags(&mut self, tags: Vec<String>, inherit: bool)

Add tags.

pub fn add_metadata(&mut self, metadata: HashMap<String, Value>, inherit: bool)

Add metadata.

pub fn is_async(&self) -> bool

Whether this is async.

pub async fn on_llm_start( &self, serialized: &HashMap<String, Value>, prompts: &[String], run_id: Option<Uuid>, ) -> Vec<AsyncCallbackManagerForLLMRun>

Run when LLM starts running (async).

pub async fn on_chat_model_start( &self, serialized: &HashMap<String, Value>, messages: &[Vec<BaseMessage>], run_id: Option<Uuid>, ) -> Vec<AsyncCallbackManagerForLLMRun>

Run when chat model starts running (async).

pub async fn on_chain_start( &self, serialized: &HashMap<String, Value>, inputs: &HashMap<String, Value>, run_id: Option<Uuid>, ) -> AsyncCallbackManagerForChainRun

Run when chain starts running (async).

pub async fn on_tool_start( &self, serialized: &HashMap<String, Value>, input_str: &str, run_id: Option<Uuid>, inputs: Option<&HashMap<String, Value>>, ) -> AsyncCallbackManagerForToolRun

Run when tool starts running (async).

pub async fn on_retriever_start( &self, serialized: &HashMap<String, Value>, query: &str, run_id: Option<Uuid>, ) -> AsyncCallbackManagerForRetrieverRun

Run when retriever starts running (async).

pub async fn on_custom_event( &self, name: &str, data: &Value, run_id: Option<Uuid>, )

Dispatch a custom event (async).

pub fn configure( inheritable_callbacks: Option<Callbacks>, local_callbacks: Option<Callbacks>, inheritable_tags: Option<Vec<String>>, local_tags: Option<Vec<String>>, inheritable_metadata: Option<HashMap<String, Value>>, local_metadata: Option<HashMap<String, Value>>, verbose: bool, ) -> Self

Configure the async callback manager.

Trait Implementations

impl Clone for AsyncCallbackManager

fn clone(&self) -> AsyncCallbackManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncCallbackManager

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

Formats the value using the given formatter.

impl Default for AsyncCallbackManager

fn default() -> AsyncCallbackManager

Returns the “default value” for a type.