Struct GraphExecutor 

pub struct GraphExecutor<State, Deps, End, P = NoPersistence>
where
    State: GraphState,
{ /* private fields */ }

Available on crate feature graph only.

Graph executor with optional persistence and instrumentation.

Implementations

impl<State, Deps, End> GraphExecutor<State, Deps, End>

where State: GraphState, Deps: Clone + Send + Sync + 'static, End: Clone + Send + Sync + 'static,

pub fn new(graph: Graph<State, Deps, End>) -> GraphExecutor<State, Deps, End>

Create a new executor without persistence.

impl<State, Deps, End, P> GraphExecutor<State, Deps, End, P>

where State: GraphState, Deps: Clone + Send + Sync + 'static, End: Clone + Send + Sync + 'static, P: StatePersistence<State, End> + 'static,

pub fn with_persistence( graph: Graph<State, Deps, End>, persistence: P, ) -> GraphExecutor<State, Deps, End, P>

Create an executor with persistence.

pub fn auto_save(self, enabled: bool) -> GraphExecutor<State, Deps, End, P>

Set whether to automatically save state.

pub fn max_steps(self, max: u32) -> GraphExecutor<State, Deps, End, P>

Set maximum steps.

pub fn without_instrumentation(self) -> GraphExecutor<State, Deps, End, P>

Disable instrumentation.

pub fn graph(&self) -> &Graph<State, Deps, End>

Get a reference to the graph.

pub async fn run( &self, state: State, deps: Deps, ) -> Result<GraphRunResult<State, End>, GraphError>

Run the graph.

pub async fn run_with_options( &self, state: State, deps: Deps, options: ExecutionOptions, ) -> Result<GraphRunResult<State, End>, GraphError>

Run the graph with options.

pub async fn resume( &self, run_id: &str, deps: Deps, ) -> Result<Option<GraphRunResult<State, End>>, GraphError>

Resume a previous run.

pub async fn get_result(&self, run_id: &str) -> Result<Option<End>, GraphError>

Get a saved result.

pub async fn list_runs(&self) -> Result<Vec<String>, GraphError>

List all saved runs.