Struct AsyncCallbackManagerForChainGroup 

pub struct AsyncCallbackManagerForChainGroup {
    pub ended: bool,
    /* private fields */
}

Async callback manager for chain group.

Fields

ended: bool

Whether the chain group has ended.

Implementations

impl AsyncCallbackManagerForChainGroup

pub fn new( handlers: Vec<Arc<dyn BaseCallbackHandler>>, inheritable_handlers: Option<Vec<Arc<dyn BaseCallbackHandler>>>, parent_run_id: Option<Uuid>, parent_run_manager: AsyncCallbackManagerForChainRun, tags: Option<Vec<String>>, inheritable_tags: Option<Vec<String>>, metadata: Option<HashMap<String, Value>>, inheritable_metadata: Option<HashMap<String, Value>>, ) -> Self

Create a new async callback manager for chain group.

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 copy(&self) -> Self

Copy the callback manager.

pub fn merge(&self, other: &CallbackManager) -> Self

Merge with another callback manager.

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 async fn on_chain_end(&mut self, outputs: &HashMap<String, Value>)

Run when chain ends running (async).

pub async fn on_chain_error(&mut self, error: &dyn Error)

Run when chain errors (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).

Trait Implementations

impl Clone for AsyncCallbackManagerForChainGroup

fn clone(&self) -> AsyncCallbackManagerForChainGroup

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncCallbackManagerForChainGroup

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

Formats the value using the given formatter.