Trait Node 

pub trait Node: Debug {
    type Input;
    type Output;

    // Required method
    fn process<'life0, 'async_trait>(
        &'life0 self,
        input: Self::Input,
    ) -> Pin<Box<dyn Future<Output = Result<Self::Output, AnchorChainError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Represents a node that can process an input to produce an output.

The Node trait defines a generic processing operation with a specified input and output type. Implementors of this trait can be composed together to form a processing chain.

Required Associated Types

type Input

The input type for the node.

type Output

The output type for the node.

Required Methods

fn process<'life0, 'async_trait>( &'life0 self, input: Self::Input, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, AnchorChainError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Asynchronously processes the given input, returning the output. When chained together the output type of one node must match the input of the next node in the chain.

Implementors

impl Node for Claude3Bedrock

type Input = String

type Output = String

impl Node for Ollama

type Input = String

type Output = String

impl Node for OpenAIEmbeddingModel

type Input = Vec<String>

type Output = Vec<Vec<f32>>

impl Node for Prompt

Implements the Node trait for the Prompt struct.

type Input = HashMap<String, String>

type Output = String

impl<C, N> Node for Link<C, N>

where C: Node + Send + Sync + Debug, C::Output: Send + 'static, C::Input: Send, N: Node<Input = C::Output> + Send + Sync + Debug, N::Output: Send,

type Input = <C as Node>::Input

type Output = <N as Node>::Output

impl<I, O, C> Node for ParallelNode<I, O, C>

where I: Clone + Send + Sync + Debug, O: Send + Sync + Debug, C: Send + Sync + Debug,

type Input = I

type Output = C

impl<I, O, L> Node for Chain<I, O, L>

where L: Node<Input = I, Output = O> + Send + Sync + Debug, I: Debug + Send + Sync, O: Debug + Send + Sync,

type Input = I

type Output = O

impl<M: EmbeddingModel + Debug + Send + Sync> Node for OpenSearchIndexer<M>

type Input = Vec<Document>

type Output = Vec<Document>

impl<M: EmbeddingModel + Debug + Send + Sync> Node for OpenSearchRetriever<M>

type Input = String

type Output = Vec<Document>

impl<T> Node for OpenAIModel<T>

where T: Send + Sync + Debug + Into<Prompt> + Into<ChatCompletionRequestUserMessageContent>,

type Input = T

type Output = String

impl<T> Node for OpenAIChatModel<T>

where T: Into<ChatCompletionRequestUserMessageContent> + Debug + Send + Sync,

type Input = T

type Output = String

impl<T> Node for OpenAIInstructModel<T>

where T: Into<Prompt> + Debug + Send + Sync,

type Input = T

type Output = String

impl<T> Node for Logger<T>

where T: Debug + Send + Sync,

type Input = T

type Output = T

impl<T> Node for NoOpNode<T>

where T: Send + Sync + Debug,

type Input = T

type Output = T