Struct AsyncRunManager 

pub struct AsyncRunManager { /* private fields */ }

Async Run Manager.

This is the async counterpart to RunManager.

Implementations

impl AsyncRunManager

pub fn new( run_id: Uuid, handlers: Vec<Arc<dyn BaseCallbackHandler>>, inheritable_handlers: Vec<Arc<dyn BaseCallbackHandler>>, parent_run_id: Option<Uuid>, 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 run manager.

pub fn get_sync(&self) -> RunManager

Get the sync version of this run manager.

pub fn run_id(&self) -> Uuid

Get the run ID.

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

Get the parent run ID.

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

Get the handlers.

pub fn tags(&self) -> &[String]

Get the tags.

pub async fn on_text(&self, text: &str)

Run when a text is received (async).

pub async fn on_retry(&self, retry_state: &Value)

Run when a retry is received (async).

pub fn get_noop_manager() -> Self

Return a noop manager.

Trait Implementations

impl Clone for AsyncRunManager

fn clone(&self) -> AsyncRunManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AsyncRunManager

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

Formats the value using the given formatter.