Struct TimeTravelGraph 

pub struct TimeTravelGraph { /* private fields */ }

Graph wrapper with time travel capabilities

Implementations

impl TimeTravelGraph

pub fn new(graph: Graph) -> Self

Create a new time travel graph with in-memory storage

pub fn with_store(graph: Graph, store: Arc<dyn HistoryStore>) -> Self

Create with custom history store

pub fn graph(&self) -> &Graph

Get the underlying graph

pub async fn execute( &self, initial_state: GraphState, ) -> Result<ExecutionHistory, CrewError>

Execute the graph and record full history

pub async fn replay_from( &self, history: &ExecutionHistory, from_step: usize, ) -> Result<ExecutionHistory, CrewError>

Replay execution from a specific step

pub async fn fork_from( &self, history: &ExecutionHistory, from_step: usize, modified_state: GraphState, ) -> Result<ExecutionHistory, CrewError>

Fork execution from a specific step with modified state

pub async fn load_history( &self, id: &str, ) -> Result<Option<ExecutionHistory>, CrewError>

Load an execution history by ID

pub async fn list_executions(&self) -> Result<Vec<String>, CrewError>

List all executions for this graph

pub async fn list_forks( &self, parent_id: &str, ) -> Result<Vec<String>, CrewError>

List all forks of an execution

pub async fn compare_executions( &self, id1: &str, id2: &str, ) -> Result<ExecutionComparison, CrewError>

Compare two executions