Struct DispatchSession 

pub struct DispatchSession { /* private fields */ }

One replay pass’s sequenced bridge between a sandbox and Rust connectors.

Implementations

impl DispatchSession

pub async fn new( runtime: Arc<CodeModeRuntime>, execution_id: impl Into<String>, connectors: Vec<Arc<dyn Connector>>, ) -> Result<Self, String>

Resolves connector descriptions and creates a fresh replay cursor.

pub async fn new_with_descriptions( runtime: Arc<CodeModeRuntime>, execution_id: impl Into<String>, connectors: Vec<Arc<dyn Connector>>, snapshot: Vec<ConnectorDescription>, ) -> Result<Self, String>

Creates a replay cursor using a previously captured capability snapshot.

pub async fn new_with_descriptions_and_context( runtime: Arc<CodeModeRuntime>, context: ToolContext, connectors: Vec<Arc<dyn Connector>>, snapshot: Vec<ConnectorDescription>, ) -> Result<Self, String>

Creates a replay cursor with an execution-scoped connector context.

pub fn descriptions(&self) -> Vec<ConnectorDescription>

Returns descriptions used to generate the child Worker bindings.

pub async fn call( &self, connector: &str, method: &str, arguments: Value, now: u64, ) -> DispatchResponse

Executes or replays one connector call under the runtime policy.

pub async fn call_at( &self, seq: u64, connector: &str, method: &str, arguments: Value, now: u64, ) -> DispatchResponse

Executes or replays one connector call at an explicit sandbox sequence.

pub async fn begin_step( &self, name: &str, now: u64, ) -> Result<StepResponse, RuntimeError>

Begins a deterministic local step.

pub async fn begin_step_at( &self, seq: u64, name: &str, now: u64, ) -> Result<StepResponse, RuntimeError>

Begins a deterministic local step at an explicit sandbox sequence.

pub async fn record_step( &self, seq: u64, result: Value, now: u64, ) -> Result<(), RuntimeError>

Records a local step result for replay.

pub async fn pass_ended(&self, status: &str)

Notifies connectors that the current sandbox pass ended.

pub async fn execution_ended(&self, status: &str)

Notifies connectors that the execution reached a terminal state.