Struct StepCtx

Source

pub struct StepCtx {Show 18 fields
    pub run_id: RunId,
    pub step_id: StepId,
    pub attempt: i32,
    pub max_attempts: i32,
    pub spec: StepSpec,
    pub untrusted_inputs: Untrusted<Value>,
    pub artifacts: Arc<dyn ArtifactStore>,
    pub policy: Arc<RuntimePolicyPack>,
    pub policy_decision_id: Option<Uuid>,
    pub guardrails: PolicyBundle,
    pub trust: Option<Trust>,
    pub trust_origin: Option<TrustOrigin>,
    pub budget: BudgetCtx,
    pub trace: TraceContext,
    pub checkpoint: Option<Value>,
    pub idempotency_key: String,
    pub capability_token: Option<CapabilityToken>,
    pub slo: Option<StepSlo>,
}

Expand description

Execution context passed to every StepExecutor.

Fields§

§run_id: RunId§step_id: StepId§attempt: i32§max_attempts: i32§spec: StepSpec§untrusted_inputs: Untrusted<Value>§artifacts: Arc<dyn ArtifactStore>§policy: Arc<RuntimePolicyPack>§policy_decision_id: Option<Uuid>§guardrails: PolicyBundle§trust: Option<Trust>§trust_origin: Option<TrustOrigin>§budget: BudgetCtx§trace: TraceContext§checkpoint: Option<Value>§idempotency_key: String§capability_token: Option<CapabilityToken>§slo: Option<StepSlo>

Auto Trait Implementations§

§

StepCtx

Struct StepCtx Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for StepCtx

impl !RefUnwindSafe for StepCtx

impl Send for StepCtx

impl Sync for StepCtx

impl Unpin for StepCtx

impl !UnwindSafe for StepCtx

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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<T> From<T> for T

fn from(t: 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<T> IntoRequest<T> for T

fn into_request(self) -> Request<T>

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

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

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

impl<T> Same for T

type Output = 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

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

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

fn vzip(self) -> V

impl<T> WithSubscriber for T

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

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct StepCtx

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

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

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

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,

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

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

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

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>,