Struct GraphExecutor 

pub struct GraphExecutor {
    pub max_steps: usize,
    /* private fields */
}

Graph 执行器 — v04: BranchState + NodeContext。

Fields

max_steps: usize

Implementations

impl GraphExecutor

pub fn new(max_steps: usize) -> Self

pub fn with_checkpoint( max_steps: usize, store: Arc<dyn CheckpointStore>, policy: CheckpointPolicy, graph: &Graph, ) -> Self

pub fn register_reducer(&mut self, key: &str, reducer: Reducer)

pub fn set_graph(&mut self, graph: &Graph)

pub async fn execute( &self, graph: Arc<Graph>, initial_state: State, ) -> Result<GraphResult, GraphError>

pub fn execute_stream( &self, graph: Arc<Graph>, initial_state: State, ) -> GraphExecution

pub async fn resume_from( &self, store: &dyn CheckpointStore, trace_id: &TraceId, graph: &Arc<Graph>, ) -> Result<GraphExecution, GraphError>

Trait Implementations

impl Clone for GraphExecutor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GraphExecutor

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

Formats the value using the given formatter.

impl Default for GraphExecutor

fn default() -> Self

Returns the “default value” for a type.