Struct llm_chain::chains::sequential::Chain

pub struct Chain<E: Executor> { /* 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<E: Executor> Chain<E>

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

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<E>) -> Chain<E>

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( &self, parameters: Parameters, executor: &E ) -> Result<E::Output, SequentialChainError<E::Error>>

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<E: Clone + Executor> Clone for Chain<E>

fn clone(&self) -> Chain<E>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<E: Debug + Executor> Debug for Chain<E>

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

Formats the value using the given formatter.

impl<'de, E: Executor> Deserialize<'de> for Chain<E>

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

Deserialize this value from the given Serde deserializer.

impl<E: Executor> Serialize for Chain<E>

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

Serialize this value into the given Serde serializer.

impl<E: Executor> StorableEntity for Chain<E>

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>