Struct CallbackManager 

pub struct CallbackManager { /* private fields */ }

Manages callback lifecycle including timeouts and heartbeats.

Implementations

impl CallbackManager

pub fn new(execution_id: &str) -> Self

Create a new callback manager.

pub fn register_callback( &mut self, callback_id: &str, timeout: Option<Duration>, ) -> Result<(), TestError>

Register a new callback.

pub fn send_success( &mut self, callback_id: &str, result: &str, ) -> Result<(), TestError>

Send callback success.

pub fn send_failure( &mut self, callback_id: &str, error: &ErrorObject, ) -> Result<(), TestError>

Send callback failure.

pub fn send_heartbeat(&mut self, callback_id: &str) -> Result<(), TestError>

Send callback heartbeat.

pub fn check_timeouts(&mut self) -> Vec<String>

Check for timed out callbacks and mark them as timed out. Returns the IDs of callbacks that timed out.

pub fn get_callback_status( &self, callback_id: &str, ) -> Option<CompleteCallbackStatus>

Get callback status.

pub fn get_callback_state(&self, callback_id: &str) -> Option<&CallbackState>

Get callback state.

pub fn execution_id(&self) -> &str

Get the execution ID.

Trait Implementations

impl Debug for CallbackManager

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

Formats the value using the given formatter.

impl Default for CallbackManager

fn default() -> CallbackManager

Returns the “default value” for a type.