Struct CallbackHandlerAdapter 

pub struct CallbackHandlerAdapter { /* private fields */ }

Adapter that wraps any GraphCallbackHandler and implements juncture_core::observability::GraphLifecycleCallback.

Use CallbackHandlerAdapter::new to create an instance, then pass the resulting Arc<CallbackHandlerAdapter> to RunnableConfig::with_callback_handler.

Examples

use std::sync::Arc;
use juncture_tracing::callback::{CallbackHandlerAdapter, GraphCallbackHandler};
use juncture_core::config::RunnableConfig;

struct MyHandler;
impl GraphCallbackHandler for MyHandler {}

let handler = Arc::new(MyHandler);
let adapter = CallbackHandlerAdapter::new(handler);
let config = RunnableConfig::new()
    .with_callback_handler(adapter);

Implementations

impl CallbackHandlerAdapter

pub fn new(handler: Arc<dyn GraphCallbackHandler>) -> Self

Create a new adapter wrapping the given GraphCallbackHandler.

Trait Implementations

impl Debug for CallbackHandlerAdapter

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

Formats the value using the given formatter.

impl GraphLifecycleCallback for CallbackHandlerAdapter

fn on_node_start(&self, node: &str, task_id: &str)

Called when a node starts execution.

fn on_node_end(&self, node: &str, task_id: &str, duration_ms: u64)

Called when a node completes execution successfully.

fn on_node_error(&self, node: &str, error: &JunctureError)

Called when a node encounters an error.

fn on_graph_end(&self, result: &Result<(), JunctureError>)

Called when the graph execution completes.

fn on_checkpoint_saved(&self, checkpoint_id: &str, step: usize)

Called when a checkpoint is saved.