Struct MemoryCallbackHandler

pub struct MemoryCallbackHandler { /* private fields */ }

A callback handler that collects run information in memory

Implementations

impl MemoryCallbackHandler

pub fn new() -> Self

Create a new memory callback handler

pub async fn get_runs(&self) -> Vec<RunInfo>

Get all runs

pub async fn get_runs_by_name(&self, name: &str) -> Vec<RunInfo>

Get runs by name

pub async fn get_runs_by_type(&self, component_type: &str) -> Vec<RunInfo>

Get runs by component type

pub async fn get_successful_runs(&self) -> Vec<RunInfo>

Get successful runs

pub async fn get_failed_runs(&self) -> Vec<RunInfo>

Get failed runs

pub async fn clear(&self)

Clear all runs

pub async fn len(&self) -> usize

Get the number of runs

pub async fn is_empty(&self) -> bool

Check if there are any runs

Trait Implementations

impl CallbackHandler for MemoryCallbackHandler

fn on_run_start<'life0, 'life1, 'async_trait>( &'life0 self, run_info: &'life1 RunInfo, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a run starts

fn on_run_success<'life0, 'life1, 'async_trait>( &'life0 self, run_info: &'life1 RunInfo, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a run completes successfully

fn on_run_error<'life0, 'life1, 'async_trait>( &'life0 self, run_info: &'life1 RunInfo, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a run fails

fn on_run_stream<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run_info: &'life1 RunInfo, chunk: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a run produces streaming output

fn on_run_cancel<'life0, 'life1, 'async_trait>( &'life0 self, run_info: &'life1 RunInfo, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Called when a run is cancelled

impl Default for MemoryCallbackHandler

fn default() -> Self

Returns the “default value” for a type.