Struct Chain

pub struct Chain { /* private fields */ }

A sequential chain is a chain where each step is executed in order, with the output of the previous step being available to the next step.

Implementations

impl Chain

pub fn new(steps: Vec<Step>) -> Chain

Creates a new Chain instance with the given sequence of steps.

Arguments

• steps - A vector of Step<E> objects that define the sequence of steps for the chain.

pub fn of_one(step: Step) -> Chain

Creates a new Chain instance with a single step.

Arguments

• step - A Step<E> object that defines the single step for the chain.

pub async fn run<E>( &self, parameters: Parameters, executor: &E, ) -> Result<Output, SequentialChainError>

where E: Executor,

Executes the chain with the given parameters and executor.

This method runs each step in the chain in sequence, passing the output of the previous step to the next step. If the chain is empty, an error is returned.

Arguments

• parameters - A Parameters object containing the input parameters for the chain.
• executor - A reference to an executor that implements the Executor trait.

Returns

• Ok(E::Output) - If the chain executes successfully, the output of the last step is returned.
• Err(SequentialChainError<E::Error>) - If an error occurs during the execution of the chain, the error is returned.

Trait Implementations

impl Clone for Chain

fn clone(&self) -> Chain

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Chain

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Chain

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Chain

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StorableEntity for Chain

fn get_metadata() -> Vec<(String, String)>

fn to_envelope(self) -> Envelope<Self>

where Self: Sized,

fn from_envelope(envelope: Envelope<Self>) -> Self

fn read_file_sync(path: &str) -> Result<Self, EnvelopeError>

fn write_file_sync(self, path: &str) -> Result<(), EnvelopeError>