Struct RuntimeTurnStateHandle 

pub struct RuntimeTurnStateHandle { /* private fields */ }

Runtime-backed TurnStateHandle impl.

Implementations

impl RuntimeTurnStateHandle

pub fn new(dsl: Arc<HandleDslAuthority>) -> Self

Construct a handle backed by the session’s shared DSL authority.

pub fn ephemeral() -> Self

Construct a handle backed by an ephemeral DSL authority.

Trait Implementations

impl Debug for RuntimeTurnStateHandle

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

Formats the value using the given formatter.

impl TurnStateHandle for RuntimeTurnStateHandle

fn apply_turn_input( &self, input: TurnExecutionInput, ) -> Result<Vec<TurnExecutionEffect>, DslTransitionError>

Apply one typed turn-execution input and return the generated turn-authority effects emitted by that transition.

fn start_conversation_run( &self, run_id: RunId, primitive_kind: TurnPrimitiveKind, admitted_content_shape: ContentShape, vision_enabled: bool, image_tool_results_enabled: bool, max_extraction_retries: u64, ) -> Result<(), DslTransitionError>

fn start_immediate_append( &self, run_id: RunId, ) -> Result<(), DslTransitionError>

fn start_immediate_context( &self, run_id: RunId, ) -> Result<(), DslTransitionError>

fn primitive_applied(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn llm_returned_tool_calls( &self, run_id: RunId, tool_count: u64, ) -> Result<(), DslTransitionError>

fn llm_returned_terminal(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn register_pending_ops( &self, run_id: RunId, op_refs: BTreeSet<AsyncOpRef>, barrier_operation_ids: BTreeSet<OperationId>, ) -> Result<(), DslTransitionError>

fn tool_calls_resolved(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn ops_barrier_satisfied( &self, run_id: RunId, operation_ids: BTreeSet<OperationId>, ) -> Result<(), DslTransitionError>

fn boundary_continue(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn boundary_complete(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn enter_extraction( &self, run_id: RunId, max_retries: u32, ) -> Result<(), DslTransitionError>

fn extraction_start(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn extraction_validation_passed( &self, run_id: RunId, ) -> Result<(), DslTransitionError>

fn extraction_validation_failed( &self, run_id: RunId, error: String, ) -> Result<(), DslTransitionError>

fn extraction_failed( &self, run_id: RunId, error: String, ) -> Result<(), DslTransitionError>

fn recoverable_failure( &self, run_id: RunId, retry: LlmRetrySchedule, ) -> Result<(), DslTransitionError>

fn fatal_failure( &self, run_id: RunId, failure: TurnFailureSource, ) -> Result<(), DslTransitionError>

fn retry_requested( &self, run_id: RunId, retry_attempt: u32, ) -> Result<(), DslTransitionError>

fn cancel_now(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn request_cancel_after_boundary( &self, run_id: RunId, ) -> Result<(), DslTransitionError>

fn cancellation_observed(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn acknowledge_terminal(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn turn_limit_reached(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn budget_exhausted(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn time_budget_exceeded(&self, run_id: RunId) -> Result<(), DslTransitionError>

fn force_cancel_no_run(&self) -> Result<(), DslTransitionError>

fn run_completed(&self, _run_id: RunId) -> Result<(), DslTransitionError>

fn run_failed( &self, _run_id: RunId, _reason: TurnFailureReason, ) -> Result<(), DslTransitionError>

fn run_cancelled(&self, _run_id: RunId) -> Result<(), DslTransitionError>

fn snapshot(&self) -> TurnStateSnapshot