pub struct ExecutionConfig {
pub thread_id: String,
pub resume_from: Option<String>,
pub recursion_limit: usize,
pub metadata: HashMap<String, Value>,
}Available on crate feature
graph only.Expand description
Configuration passed to nodes during execution
Fields§
§thread_id: StringThread identifier for checkpointing
resume_from: Option<String>Resume from a specific checkpoint
recursion_limit: usizeRecursion limit for cycles
metadata: HashMap<String, Value>Additional configuration
Implementations§
Source§impl ExecutionConfig
impl ExecutionConfig
Sourcepub fn new(thread_id: &str) -> ExecutionConfig
pub fn new(thread_id: &str) -> ExecutionConfig
Create a new config with the given thread ID
Sourcepub fn with_recursion_limit(self, limit: usize) -> ExecutionConfig
pub fn with_recursion_limit(self, limit: usize) -> ExecutionConfig
Set the recursion limit
Sourcepub fn with_resume_from(self, checkpoint_id: &str) -> ExecutionConfig
pub fn with_resume_from(self, checkpoint_id: &str) -> ExecutionConfig
Resume from a specific checkpoint
Sourcepub fn with_metadata(self, key: &str, value: Value) -> ExecutionConfig
pub fn with_metadata(self, key: &str, value: Value) -> ExecutionConfig
Add metadata
Trait Implementations§
Source§impl Clone for ExecutionConfig
impl Clone for ExecutionConfig
Source§fn clone(&self) -> ExecutionConfig
fn clone(&self) -> ExecutionConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Default for ExecutionConfig
impl Default for ExecutionConfig
Source§fn default() -> ExecutionConfig
fn default() -> ExecutionConfig
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for ExecutionConfig
impl RefUnwindSafe for ExecutionConfig
impl Send for ExecutionConfig
impl Sync for ExecutionConfig
impl Unpin for ExecutionConfig
impl UnwindSafe for ExecutionConfig
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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