Struct PayloadNode 

pub struct PayloadNode { /* private fields */ }

A node that wraps a Payload for execution within the graph.

input_selector extracts what to pass to the payload from graph state. output_mapper folds the payload output back into graph state.

Defaults: pass entire state as input; replace entire state with output.value.

Implementations

impl PayloadNode

pub fn new(payload: Box<dyn Payload>) -> Self

Create a new PayloadNode wrapping a payload.

pub fn with_name(self, name: impl Into<String>) -> Self

Set a name for this node (for debugging and events).

pub fn with_input_selector( self, selector: impl Fn(&Value) -> Value + Send + Sync + 'static, ) -> Self

Set the input selector function.

Receives the entire state as a JSON value and returns the value to pass to the payload’s invoke method.

pub fn with_output_mapper( self, mapper: impl Fn(&Value, &PayloadOutput) -> Value + Send + Sync + 'static, ) -> Self

Set the output mapper function.

Receives the current state and the payload output, returns the new state.

Trait Implementations

impl Debug for PayloadNode

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

Formats the value using the given formatter.

impl Node for PayloadNode

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: &'life1 AgentState, _config: &'life2 GraphConfig, ) -> Pin<Box<dyn Future<Output = Result<NodeOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Execute this node

fn name(&self) -> Option<&str>

Optional: Get a name for this node (for debugging)