Struct OrchaGraph 

pub struct OrchaGraph {
    pub graph_id: String,
    /* private fields */
}

A handle to a single execution graph.

Provides Orcha’s typed node-building API and graph-scoped execution control. No lattice types leak past this boundary — callers work entirely in Orcha concepts (tasks, validate steps, synthesize steps, review gates).

Fields

graph_id: String

The lattice graph ID — exposed for logging / monitoring.

Implementations

impl OrchaGraph

pub async fn add_task( &self, task: impl Into<String>, max_retries: Option<u8>, ) -> Result<String, String>

Add a task node.

pub async fn add_synthesize( &self, task: impl Into<String>, max_retries: Option<u8>, ) -> Result<String, String>

Add a synthesize node.

Like task, but graph_runner prepends resolved input tokens as <prior_work> context.

pub async fn add_validate( &self, command: impl Into<String>, cwd: Option<impl Into<String>>, max_retries: Option<u8>, ) -> Result<String, String>

Add a validate node.

Orcha runs command in a shell inside cwd (default /workspace).

pub async fn add_gather( &self, strategy: GatherStrategy, ) -> Result<String, String>

Add a gather node — engine-executed, auto-fires when all inbound tokens arrive.

pub async fn add_subgraph( &self, child_graph_id: impl Into<String>, ) -> Result<String, String>

Add a SubGraph node — when ready, runs the child graph to completion.

pub fn open_child_graph(&self, graph_id: impl Into<String>) -> OrchaGraph

Open a sibling graph by ID sharing the same LatticeStorage.

pub async fn add_plan(&self, task: impl Into<String>) -> Result<String, String>

Add a plan node.

When dispatched, runs Claude to produce a ticket file, compiles it into a child graph, and executes the child graph inline.

pub async fn add_review( &self, prompt: impl Into<String>, ) -> Result<String, String>

Add a review node.

pub async fn depends_on( &self, dependent: &str, dependency: &str, ) -> Result<(), String>

Declare that dependent waits for dependency to complete first.

graph.depends_on(&validate_node, &task_node)
// validate_node will not start until task_node is complete

pub fn watch( &self, after_seq: Option<u64>, ) -> impl Stream<Item = LatticeEventEnvelope> + Send + 'static

Watch this graph’s event stream.

pub async fn start_node(&self, node_id: &str) -> Result<(), String>

Signal that a node started executing.

pub async fn complete_node( &self, node_id: &str, output: Option<NodeOutput>, ) -> Result<(), String>

Signal that a node completed successfully, optionally carrying output.

pub async fn fail_node( &self, node_id: &str, error: String, ) -> Result<(), String>

Signal that a node failed.

pub async fn get_inbound_node_ids( &self, node_id: &str, ) -> Result<Vec<String>, String>

Get IDs of nodes that have an edge pointing into node_id.

pub async fn get_node_spec(&self, node_id: &str) -> Result<NodeSpec, String>

Get the spec of an existing node.

pub async fn get_node_output( &self, node_id: &str, ) -> Result<Option<NodeOutput>, String>

Get the stored output of a completed node.

pub async fn count_nodes(&self) -> Result<usize, String>

Count the total number of nodes in this graph.

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

Get the IDs of nodes that have already reached a terminal state (Complete or Failed). Used by run_graph_execution to pre-populate the dispatched set on reconnect.

pub async fn get_node_inputs(&self, node_id: &str) -> Result<Vec<Token>, String>

Get raw input tokens for a node (what arrived on all inbound edges).

pub async fn get_resolved_inputs( &self, node_id: &str, arbor: &ArborStorage, ) -> Result<Vec<ResolvedToken>, String>

Get input tokens with Handle payloads resolved to inline Values.

Lattice resolves handles server-side via Arbor. Returns ResolvedToken { color, data: Option }.

Trait Implementations

impl Clone for OrchaGraph

fn clone(&self) -> OrchaGraph

Returns a duplicate of the value.

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

Performs copy-assignment from source.