Struct Step

Source

pub struct Step {Show 17 fields
    pub id: String,
    pub kind: String,
    pub depends_on: Vec<String>,
    pub when: Option<String>,
    pub retry: Option<Retry>,
    pub timeout_ms: Option<u64>,
    pub on_error: OnError,
    pub idempotent: bool,
    pub on_replay: OnReplay,
    pub output_schema: Option<Value>,
    pub cache: Option<Value>,
    pub budget: Option<u64>,
    pub skills: Vec<String>,
    pub description: Option<String>,
    pub spec: Map<String, Value>,
    pub body: Option<Body>,
    pub branches: BTreeMap<String, Body>,
}

Expand description

One step (the cross-cutting fields typed; kind fields in spec).

Fields§

§id: String§kind: String§depends_on: Vec<String>§when: Option<String>§retry: Option<Retry>§timeout_ms: Option<u64>§on_error: OnError§idempotent: bool§on_replay: OnReplay§output_schema: Option<Value>§cache: Option<Value>§budget: Option<u64>§skills: Vec<String>§description: Option<String>§spec: Map<String, Value>

The kind-specific fields, verbatim.

§body: Option<Body>

The parsed nested body (foreach/batch/iterate/subgraph).

§branches: BTreeMap<String, Body>

The parsed branches (parallel/race).

Struct Step Copy item path

Fields§

Implementations§

impl Step

pub fn info(&self) -> Option<&'static KindInfo>

pub fn is_start(&self) -> bool

pub fn field(&self, name: &str) -> Option<&Value>

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

Trait Implementations§

impl Clone for Step

fn clone(&self) -> Step

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

impl Debug for Step

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

impl<'de> Deserialize<'de> for Step

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where __D: Deserializer<'de>,

impl PartialEq for Step

fn eq(&self, other: &Step) -> bool

fn ne(&self, other: &Rhs) -> bool

impl Serialize for Step

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>where __S: Serializer,

impl StructuralPartialEq for Step

Auto Trait Implementations§

impl Freeze for Step

impl RefUnwindSafe for Step

impl Send for Step

impl Sync for Step

impl Unpin for Step

impl UnsafeUnpin for Step

impl UnwindSafe for Step

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> CloneToUninit for Twhere T: Clone,

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

impl<T> DeserializeOwned for Twhere T: for<'de> Deserialize<'de>,

impl<T> From<T> for T

fn from(t: T) -> T

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> 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 = !

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

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
where __D: Deserializer<'de>,

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
where S: Serializer,

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> CloneToUninit for T
where T: Clone,

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

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

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

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