Struct RuntimeExecutionContext 

pub struct RuntimeExecutionContext<'run> { /* private fields */ }

Implementations

impl<'run> RuntimeExecutionContext<'run>

pub fn session_id(&self) -> &str

pub fn session_scope(&self) -> SessionScope

pub fn trigger_store(&self) -> Option<Arc<dyn TriggerStore>>

pub fn trigger_registration_originator(&self) -> ProcessOriginator

pub fn trigger_registration_wake_target(&self) -> Option<SessionScope>

pub fn attachment_store(&self) -> Arc<dyn AttachmentStore>

pub fn process_env_store(&self) -> Arc<dyn ProcessExecutionEnvStore>

pub fn chronological_projection(&self) -> Arc<ChronologicalProjection>

pub fn protocol_extension<T: 'static>(&self) -> Option<&T>

pub fn turn_context(&self) -> &TurnContext

pub fn tool_catalog(&self) -> Arc<ToolCatalog>

pub async fn captured_process_execution_env_ref( &self, ) -> Result<ProcessExecutionEnvRef, PluginError>

pub fn parent_invocation(&self) -> Option<&RuntimeInvocation>

pub fn callable_tool_manifest(&self, name: &str) -> Option<ToolManifest>

pub fn callable_tool_manifest_by_id(&self, id: &ToolId) -> Option<ToolManifest>

pub fn tool_argument_projection_policy( &self, name: &str, ) -> ToolArgumentProjectionPolicy

pub async fn start_child_process( &self, registration: ProcessRegistration, kind: impl Into<String>, label: Option<String>, ) -> ToolInvocationReply

pub async fn sleep_process( &self, scope: &str, sequence: u64, duration_ms: u64, ) -> Result<(), RuntimeEffectControllerError>

pub async fn await_process_signal_event( &self, process_id: &str, signal_name: &str, event_ordinal: u64, ) -> Result<Value, RuntimeEffectControllerError>

pub async fn signal_process_by_id( &self, registry: Arc<dyn ProcessRegistry>, process_id: &str, signal_name: &str, signal_id: String, payload: Value, ) -> Result<ProcessEvent, RuntimeEffectControllerError>

pub async fn append_process_event( &self, registry: Arc<dyn ProcessRegistry>, process_id: &str, request: ProcessEventAppendRequest, ) -> Result<ProcessEvent, PluginError>

impl RuntimeExecutionContext<'_>

pub fn process_handle_json(id: &str) -> Value

impl RuntimeExecutionContext<'_>

pub async fn call_tool( &self, call_id: String, name: String, args: Value, index: usize, ) -> ToolInvocationReply

pub async fn call_tool_with_child_execution_trace_hook( &self, call_id: String, name: String, args: Value, index: usize, trace_hook: ToolChildExecutionTraceHook, ) -> ToolInvocationReply

pub async fn call_tool_batch( &self, calls: Vec<ToolInvocation>, ) -> Vec<ToolInvocationReply>

pub async fn start_tool_call( &self, call_id: String, name: String, args: Value, ) -> ToolInvocationReply

pub async fn await_tool_handle( &self, call_id: String, handle: Value, ) -> ToolInvocationReply

pub async fn cancel_tool_handle( &self, call_id: String, handle: Value, ) -> ToolInvocationReply

pub async fn signal_tool_handle( &self, call_id: String, handle: Value, signal_name: String, payload: Value, ) -> ToolInvocationReply

Trait Implementations

impl<'run> Clone for RuntimeExecutionContext<'run>

fn clone(&self) -> RuntimeExecutionContext<'run>

Returns a duplicate of the value.

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

Performs copy-assignment from source.