Struct RunOptions

Source

pub struct RunOptions {Show 17 fields
    pub profile: Profile,
    pub entry_flow: Option<String>,
    pub input: Value,
    pub ctx: TenantContext,
    pub transcript: Option<Arc<dyn Fn(&Value) + Send + Sync>>,
    pub otlp: Option<OtlpHook>,
    pub mocks: MocksConfig,
    pub artifacts_dir: Option<PathBuf>,
    pub signing: SigningPolicy,
    pub components_dir: Option<PathBuf>,
    pub components_map: HashMap<String, PathBuf>,
    pub dist_offline: bool,
    pub dist_cache_dir: Option<PathBuf>,
    pub allow_missing_hash: bool,
    pub secrets_manager: Option<Arc<dyn SecretsManager>>,
    pub cross_pack_resolver: Option<Arc<dyn CrossPackResolver>>,
    pub session_state_dir: Option<PathBuf>,
}

Expand description

User supplied options for a run.

Fields§

§profile: Profile§entry_flow: Option<String>§input: Value§ctx: TenantContext§transcript: Option<Arc<dyn Fn(&Value) + Send + Sync>>§otlp: Option<OtlpHook>§mocks: MocksConfig§artifacts_dir: Option<PathBuf>§signing: SigningPolicy§components_dir: Option<PathBuf>§components_map: HashMap<String, PathBuf>§dist_offline: bool§dist_cache_dir: Option<PathBuf>§allow_missing_hash: bool§secrets_manager: Option<Arc<dyn SecretsManager>>

Optional secrets manager override used by embedded runtimes that need to share a caller-owned secrets backend with the runner.

§cross_pack_resolver: Option<Arc<dyn CrossPackResolver>>

Optional cross-pack resolver for provider.invoke nodes that reference providers in other packs (e.g., OAuth broker from a capability pack).

§session_state_dir: Option<PathBuf>

Directory where suspended FlowSnapshots are persisted between activities so a conversational flow can resume at the node the previous run paused at (instead of restarting from the entry).

Snapshots are keyed by ctx.session_id, so the caller must populate ctx.session_id with a stable per-conversation identifier (e.g. {tenant}:{flow}:{conversation_id}) for resume to engage. When either this directory or session_id is missing, the runner behaves exactly as before: a FlowExecution::waiting result is surfaced as an Err and the snapshot is dropped.

RunOptions

Struct RunOptions Copy item path

Fields§

Trait Implementations§

impl Clone for RunOptions

fn clone(&self) -> RunOptions

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

impl Debug for RunOptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

impl Default for RunOptions

fn default() -> RunOptions

Auto Trait Implementations§

impl !RefUnwindSafe for RunOptions

impl !UnwindSafe for RunOptions

impl Freeze for RunOptions

impl Send for RunOptions

impl Sync for RunOptions

impl Unpin for RunOptions

impl UnsafeUnpin for RunOptions

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere T: 'a,

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere T: 'a,

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> DynClone for Twhere T: Clone,

fn __clone_box(&self, _: Private) -> *mut ()

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FromRef<T> for Twhere T: Clone,

fn from_ref(input: &T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

impl<L> LayerExt<L> for L

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where L: Layer<S>,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Pointee for T

type Pointer = u32

fn debug( pointer: <T as Pointee>::Pointer, f: &mut Formatter<'_>, ) -> Result<(), Error>

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

Struct RunOptions

impl<T> Any for T
where T: 'static + ?Sized,

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T> DynClone for T
where T: Clone,

impl<T> FromRef<T> for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,