pub struct RunHandle { /* private fields */ }Expand description
Holds run handle application-layer state or configuration. Use it with the documented coordinator methods; run, journal, event, provider, or port effects are called out on those methods rather than on construction.
Implementations§
Source§impl RunHandle
impl RunHandle
Sourcepub fn new(
run_id: RunId,
control: Arc<dyn RunControlStore>,
subscriptions: Arc<dyn RunSubscriptionSource>,
) -> Self
pub fn new( run_id: RunId, control: Arc<dyn RunControlStore>, subscriptions: Arc<dyn RunSubscriptionSource>, ) -> Self
Creates a new application::run_handle value with explicit caller-provided inputs. This constructor is data-only and performs no I/O or external side effects.
Sourcepub fn run_id(&self) -> &RunId
pub fn run_id(&self) -> &RunId
Returns run id for this application::run_handle value without performing external I/O.
Sourcepub fn wait(&self) -> Result<RunResult, AgentError>
pub fn wait(&self) -> Result<RunResult, AgentError>
Returns the terminal result once the handle store, terminal event, and journal agree. This reads run-control state and does not drive the run or start new side effects.
Sourcepub fn wait_with_timeout(
&self,
_timeout: Duration,
) -> Result<Option<RunResult>, AgentError>
pub fn wait_with_timeout( &self, _timeout: Duration, ) -> Result<Option<RunResult>, AgentError>
Returns the terminal result if it is already available before the timeout budget. This first-slice implementation is non-blocking and does not cancel or drive the run.
Sourcepub fn status(&self) -> Result<RunStatus, AgentError>
pub fn status(&self) -> Result<RunStatus, AgentError>
Returns the status currently held by this value. This reads run-control status for the handle and does not change the run.
Sourcepub fn stream_from(
&self,
cursor: Option<EventCursor>,
) -> Result<AgentEventStream, AgentError>
pub fn stream_from( &self, cursor: Option<EventCursor>, ) -> Result<AgentEventStream, AgentError>
Opens an event stream for this run from the supplied live-event cursor. This delegates to the configured subscription port to create a read-only stream; it does not drive the run, execute tools, or call the provider.
Sourcepub fn stream_from_journal(
&self,
cursor: JournalCursor,
) -> Result<AgentEventStream, AgentError>
pub fn stream_from_journal( &self, cursor: JournalCursor, ) -> Result<AgentEventStream, AgentError>
Opens a replay-derived stream for this run from a journal cursor. This delegates to the subscription port’s journal replay path and does not mutate run control or execute runtime work.
Sourcepub fn cancel(&self) -> Result<(), AgentError>
pub fn cancel(&self) -> Result<(), AgentError>
Cancel. This forwards cancellation to run control; adapter/process cleanup remains owned by the run coordinator.