Struct SimpleExecutor 

pub struct SimpleExecutor { /* private fields */ }

兼容 SimpleExecutor 的 API，供测试使用。

仅支持 Graph<State, StateMerge>（默认泛型参数）。

Implementations

impl SimpleExecutor

pub fn new(max_steps: usize) -> Self

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

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

pub fn execute_stream_with_restore( &self, graph: Arc<Graph>, state: State, restore_from: Option<Checkpoint<State>>, ) -> GraphExecution<State>

Trait Implementations

impl Default for SimpleExecutor

fn default() -> Self

Returns the “default value” for a type.