Struct RunContext

Source

pub struct RunContext { /* private fields */ }

Expand description

Run-scoped workspace that holds mutable state for a single agent run.

RunContext is constructed from a Thread’s persisted data at the start of a run and accumulates messages, patches, and overlay ops as the run progresses. It owns the DocCell (live document) and provides delta extraction via take_delta().

It does not hold the Thread itself — only the data needed for execution. Run identity lives in RunIdentity; this workspace only owns live execution data.

Implementations§

Source §

impl RunContext

Source

pub fn new( thread_id: impl Into<String>, state: Value, messages: Vec<Arc<Message>>, run_policy: RunPolicy, ) -> Self

Build a run workspace from thread data.

thread_id: thread identifier (owned)
state: already-rebuilt state (base + patches)
messages: initial messages (cursor set to end — no delta)
run_policy: typed per-run run policy

Source

pub fn with_registry( thread_id: impl Into<String>, state: Value, messages: Vec<Arc<Message>>, run_policy: RunPolicy, lattice_registry: Arc<LatticeRegistry>, ) -> Self

Build a run workspace with a pre-populated lattice registry.

Source

pub fn with_registry_and_identity( state: Value, messages: Vec<Arc<Message>>, run_policy: RunPolicy, run_identity: RunIdentity, lattice_registry: Arc<LatticeRegistry>, ) -> Self

Source

pub fn thread_id(&self) -> &str

Thread identifier.

Source

pub fn version(&self) -> u64

Current committed version (0 if never committed).

Source

pub fn set_version(&mut self, version: u64, timestamp: Option<u64>)

Update version after a successful state commit.

Source

pub fn version_timestamp(&self) -> Option<u64>

Timestamp of the last committed version.

Source

pub fn suspended_calls(&self) -> HashMap<String, SuspendedCall>

Read all suspended calls from durable control state.

Source

pub fn messages(&self) -> &[Arc<Message>]

All messages (initial + accumulated during run).

Source

pub fn initial_message_count(&self) -> usize

Number of messages that existed before this run started.

Source

pub fn add_message(&mut self, msg: Arc<Message>)

Add a single message to the run.

Source

pub fn add_messages(&mut self, msgs: Vec<Arc<Message>>)

Add multiple messages to the run.

Source

pub fn thread_base(&self) -> &Value

The initial rebuilt state (base + thread patches).

Source

pub fn add_thread_patch(&mut self, patch: TrackedPatch)

Add a tracked patch from this run.

Source

pub fn add_thread_patches(&mut self, patches: Vec<TrackedPatch>)

Add multiple tracked patches from this run.

Source

pub fn thread_patches(&self) -> &[TrackedPatch]

All patches accumulated during this run.

Source

pub fn add_serialized_state_actions( &mut self, state_actions: Vec<SerializedStateAction>, )

Add serialized state actions captured during tool/phase execution.

Source

pub fn snapshot(&self) -> TireaResult<Value>

Rebuild the current run-visible state (thread_base + thread_patches).

This is a pure computation that returns a new Value without touching the DocCell.

Source

pub fn snapshot_of<T: State>(&self) -> TireaResult<T>

Typed snapshot at the type’s canonical path.

Rebuilds state and deserializes the value at T::PATH.

Source

pub fn snapshot_at<T: State>(&self, path: &str) -> TireaResult<T>

Typed snapshot at an explicit path.

Rebuilds state and deserializes the value at the given path.

Source

pub fn take_delta(&mut self) -> RunDelta

Extract the incremental delta (new messages + patches + serialized state actions) since the last take_delta() call.

Source

pub fn has_delta(&self) -> bool

Whether there are un-consumed messages, patches, or serialized state actions.

Source

pub fn tool_call_context<'ctx>( &'ctx self, ops: &'ctx Mutex<Vec<Op>>, call_id: impl Into<String>, source: impl Into<String>, pending_messages: &'ctx Mutex<Vec<Arc<Message>>>, activity_manager: Arc<dyn ActivityManager>, ) -> ToolCallContext<'ctx>

Create a ToolCallContext scoped to a specific tool call.

Source §

impl RunContext

Source

pub fn from_thread( thread: &Thread, run_policy: RunPolicy, ) -> Result<Self, TireaError>

Convenience constructor from a Thread.

Rebuilds state from the thread’s base state + patches, then wraps the thread’s messages and the given run_policy into a RunContext. Version metadata is carried over from thread metadata.

Source