Struct RuntimeSessionLifecycle 

pub struct RuntimeSessionLifecycle<A: RuntimeHostAdapter> { /* private fields */ }

Shared lifecycle helper for runtime-backed hosts.

Implementations

impl<A: RuntimeHostAdapter> RuntimeSessionLifecycle<A>

pub fn new(adapter: A, org_id: i64, session_id: SessionId) -> Self

pub async fn turn_started(&self, turn_id: TurnId, input_message_id: MessageId)

pub async fn emit_turn_completed( &self, input_message_id: MessageId, data: TurnCompletedData, )

pub async fn emit_session_idled( &self, turn_id: TurnId, input_message_id: MessageId, iterations: Option<u32>, usage: Option<TokenUsage>, )

pub async fn turn_completed( &self, turn_id: TurnId, input_message_id: MessageId, iterations: u32, usage: Option<TokenUsage>, input_content: Option<String>, )

pub async fn fire_turn_end_hooks( &self, harness_id: HarnessId, agent_id: Option<AgentId>, turn_id: TurnId, success: bool, )

Fire turn_end lifecycle hooks (advisory). Collects the session’s hook specs and runs every turn_end hook; failures are logged, never fatal. harness_id/agent_id are required to resolve the capability chain.

pub async fn user_prompt_blocked( &self, turn_id: TurnId, input_message_id: MessageId, reason: &str, user_message: Option<&str>, )

Abort a turn because a user_prompt_submit hook returned Block. Reuses the dependency-blocked failure shape: emit a user-facing message carrying the hook’s user_message (or reason), then mark the turn failed and idle the session.

pub async fn turn_failed( &self, turn_id: TurnId, input_message_id: MessageId, error: &str, user_error: Option<&UserFacingError>, )

pub async fn waiting_for_tool_results(&self)

pub async fn dependency_blocked( &self, turn_id: TurnId, input_message_id: MessageId, blocker: DependencyBlocker, )