Struct Orchestrator 

pub struct Orchestrator { /* private fields */ }

Implementations

impl Orchestrator

pub fn new(executor: Executor) -> Self

Create a new orchestrator with an executor

pub async fn execute(&self, graph: &mut Graph) -> Result<()>

Execute the graph using the internal executor

pub async fn execute_graph(graph: &mut Graph) -> Result<()>

Execute a graph using a default executor built from the graph definition

Examples found in repository

examples/simple_flow.rs (line 26)

async fn main() -> anyhow::Result<()> {
    // Initialize tracing
    tracing_subscriber::fmt()
        .with_max_level(tracing::Level::INFO)
        .init();

    println!("=== Rust Logic Graph - Simple Flow Example ===\n");

    // Load graph definition from JSON
    let def = GraphIO::load_from_file("examples/simple_flow.json")?;
    println!("Loaded graph with {} nodes and {} edges\n",
        def.nodes.len(),
        def.edges.len()
    );

    // Create graph
    let mut graph = Graph::new(def);

    // Execute the graph
    println!("Starting graph execution...\n");
    Orchestrator::execute_graph(&mut graph).await?;

    // Display final context
    println!("\n=== Final Context ===");
    for (key, value) in &graph.context.data {
        println!("{}: {}", key, value);
    }

    println!("\n=== Execution Complete ===");
    Ok(())
}

Trait Implementations

impl Default for Orchestrator

fn default() -> Self

Returns the “default value” for a type.