pub struct ScopedState { /* private fields */ }Expand description
Hierarchical scoped runtime state with capability-checked access.
Implementations§
Source§impl ScopedState
impl ScopedState
pub fn new(workflow_input: Value) -> Self
pub fn enter_child_scope(&mut self)
pub fn exit_to_parent_scope(&mut self) -> Result<(), ScopeAccessError>
pub fn scoped_input( &self, token: &CapabilityToken, ) -> Result<Value, ScopeAccessError>
pub fn record_llm_output( &mut self, node_id: &str, output: String, token: &CapabilityToken, ) -> Result<(), ScopeAccessError>
pub fn record_tool_output( &mut self, node_id: &str, output: Value, token: &CapabilityToken, ) -> Result<(), ScopeAccessError>
pub fn record_condition_output( &mut self, node_id: &str, evaluated: bool, token: &CapabilityToken, ) -> Result<(), ScopeAccessError>
pub fn record_subgraph_output( &mut self, node_id: &str, output: Value, token: &CapabilityToken, ) -> Result<(), ScopeAccessError>
pub fn record_batch_output( &mut self, node_id: &str, output: Value, token: &CapabilityToken, ) -> Result<(), ScopeAccessError>
pub fn record_filter_output( &mut self, node_id: &str, output: Value, token: &CapabilityToken, ) -> Result<(), ScopeAccessError>
pub fn loop_iteration(&self, node_id: &str) -> u32
pub fn set_loop_iteration(&mut self, node_id: &str, iteration: u32)
pub fn clear_loop_iteration(&mut self, node_id: &str)
pub fn current_scope_node_outputs(&self) -> Value
pub fn visible_node_outputs(&self) -> BTreeMap<String, Value>
Trait Implementations§
Auto Trait Implementations§
impl Freeze for ScopedState
impl RefUnwindSafe for ScopedState
impl Send for ScopedState
impl Sync for ScopedState
impl Unpin for ScopedState
impl UnsafeUnpin for ScopedState
impl UnwindSafe for ScopedState
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request