Struct TurnOptimizationContext 

pub struct TurnOptimizationContext {
    pub turn_id: Uuid,
    pub processed_input: String,
    pub input_context: HashMap<String, Value>,
    pub staged_context_writes: HashMap<String, Value>,
    pub pre_turn_lifecycle_completed: bool,
    pub user_message_committed: bool,
    pub post_turn_lifecycle_completed: bool,
    pub redispatch_depth: u32,
    pub speculative_llm_calls_used: u32,
    pub max_speculative_llm_calls: u32,
}

Tracks lifecycle and staged writes for one optimized runtime turn.

Fields

turn_id: Uuid

Stable ID shared by branch and maintenance work for the current turn.

processed_input: String

Processed user input after the input pipeline.

input_context: HashMap<String, Value>

Context values produced by the input process pipeline.

staged_context_writes: HashMap<String, Value>

Context writes that must only commit if the selected path wins.

pre_turn_lifecycle_completed: bool

Whether actor memory and relationship loading ran for this turn.

user_message_committed: bool

Whether the user message has been written to memory.

post_turn_lifecycle_completed: bool

Whether post-turn maintenance has been scheduled or completed.

redispatch_depth: u32

Redispatch depth used to avoid repeated lifecycle work.

speculative_llm_calls_used: u32

Number of speculative LLM calls used in this turn.

max_speculative_llm_calls: u32

Maximum speculative LLM calls allowed in this turn.

Implementations

impl TurnOptimizationContext

pub fn new( processed_input: impl Into<String>, input_context: HashMap<String, Value>, max_speculative_llm_calls: u32, ) -> TurnOptimizationContext

Creates a new turn context with no staged writes.

pub fn reserve_speculative_llm_call(&mut self) -> bool

Returns true when another speculative LLM call can be scheduled.

pub fn reserve_speculative_llm_call_for( &mut self, _kind: RuntimeOptimizationKind, ) -> bool

pub fn release_or_mark_failed_reservation( &mut self, _kind: RuntimeOptimizationKind, )

pub fn can_schedule_branch( &self, active_tasks: usize, max_parallel_tasks: usize, ) -> bool

pub fn stage_context_write(&mut self, key: impl Into<String>, value: Value)

pub fn take_staged_context_writes(&mut self) -> HashMap<String, Value>

pub fn reserve_speculative_llm_calls(&mut self, count: u32) -> bool

Returns true when the turn can schedule the requested number of branch calls.

pub fn mark_user_message_committed(&mut self)

Marks the root user message as committed.

pub fn mark_post_turn_lifecycle_completed(&mut self)

Marks post-turn lifecycle work as completed.

pub fn enter_redispatch(&mut self)

Enters a redispatch scope.

pub fn exit_redispatch(&mut self)

Leaves a redispatch scope.

Trait Implementations

impl Clone for TurnOptimizationContext

fn clone(&self) -> TurnOptimizationContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TurnOptimizationContext

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

Formats the value using the given formatter.