Trait ExecutionObserver 

pub trait ExecutionObserver: Send + Sync {
    // Provided methods
    fn on_started(&self, _spec: &ExecutionSpec) { ... }
    fn on_paused(&self, _queries: &[LlmQuery]) { ... }
    fn on_partial_feed(&self, _query_id: &QueryId, _remaining: usize) { ... }
    fn on_resumed(&self) { ... }
    fn on_completed(&self, _result: &Value) { ... }
    fn on_failed(&self, _error: &str) { ... }
    fn on_cancelled(&self) { ... }
}

Observer for execution state transitions.

Hooks cross-cutting concerns (stats, logging) without polluting the Execution core.

Provided Methods

fn on_started(&self, _spec: &ExecutionSpec)

fn on_paused(&self, _queries: &[LlmQuery])

LLM request issued (transition to Paused).

fn on_partial_feed(&self, _query_id: &QueryId, _remaining: usize)

Partial response arrived (not yet complete).

fn on_resumed(&self)

All responses arrived, Lua resuming (transition to Running).

fn on_completed(&self, _result: &Value)

fn on_failed(&self, _error: &str)

fn on_cancelled(&self)

Host-initiated cancellation.

Implementors

impl ExecutionObserver for MetricsObserver