Struct RuntimeHookChain 

pub struct RuntimeHookChain { /* private fields */ }

Ordered runtime hook composition.

Lifecycle, progress, telemetry, and log events are sent to every hook. Transform hooks are applied in order, with each hook receiving the payload returned by the previous hook.

Implementations

impl RuntimeHookChain

pub fn new(hooks: Vec<Arc<dyn RuntimeHooks>>) -> Self

Creates a chain from hooks in invocation order.

pub fn empty() -> Self

Creates an empty chain with the same behavior as NoopRuntimeHooks.

pub fn len(&self) -> usize

Returns the number of hooks in the chain.

pub fn is_empty(&self) -> bool

Returns true when the chain contains no hooks.

Trait Implementations

impl Default for RuntimeHookChain

fn default() -> RuntimeHookChain

Returns the “default value” for a type.

impl RuntimeHooks for RuntimeHookChain

fn env_connected<'life0, 'async_trait>( &'life0 self, event: EnvConnectedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn model_connected<'life0, 'async_trait>( &'life0 self, event: ModelConnectedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn session_started<'life0, 'async_trait>( &'life0 self, event: SessionStartedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn episode_started<'life0, 'async_trait>( &'life0 self, event: EpisodeStartedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn episode_completed<'life0, 'async_trait>( &'life0 self, event: EpisodeCompletedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn action_received<'life0, 'async_trait>( &'life0 self, event: ActionReceivedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn transform_action<'life0, 'async_trait>( &'life0 self, event: ActionReceivedEvent, ) -> Pin<Box<dyn Future<Output = Result<Option<MessageBytes>, HookError>> + Send + 'async_trait>>

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

fn step_completed<'life0, 'async_trait>( &'life0 self, event: StepCompletedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn observation_emitted<'life0, 'async_trait>( &'life0 self, event: ObservationEmittedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn transform_observation<'life0, 'async_trait>( &'life0 self, event: ObservationEmittedEvent, ) -> Pin<Box<dyn Future<Output = Result<Option<MessageBytes>, HookError>> + Send + 'async_trait>>

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

fn telemetry_window<'life0, 'async_trait>( &'life0 self, event: TelemetryWindowEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn telemetry_summary<'life0, 'async_trait>( &'life0 self, event: TelemetrySummaryEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn session_ended<'life0, 'async_trait>( &'life0 self, event: SessionEndedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn session_failed<'life0, 'async_trait>( &'life0 self, event: SessionFailedEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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

fn log<'life0, 'async_trait>( &'life0 self, event: LogEvent, ) -> Pin<Box<dyn Future<Output = Result<(), HookError>> + Send + 'async_trait>>

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