Struct Node 

pub struct Node { /* private fields */ }

A clonable handle to a workflow with lazy loading and shared reads.

Implementations

impl Node

pub fn new(inference: Arc<Inference>) -> Self

Creates a new Node in the Pending state with the given Inference.

pub fn init_new(reference: Arc<Reference>, inference: Arc<Inference>) -> Self

pub fn init_default(reference: Arc<Reference>) -> Self

pub fn parse(input: &str) -> Result<Self>

pub fn init(&self, reference: Arc<Reference>)

Initializes the Node in the Unloaded state with the given Reference.

pub fn reference(&self) -> Result<Arc<Reference>>

pub fn inference(&self) -> Arc<Inference>

Returns the inference characteristic for this workflow.

The model provides an abstraction to decouple inference from reliance on a specific underlying model. The model performance characteristic reflects one of six specializations:

• Fast - optimized for speed and low latency
• Standard - balanced performance for general use
• Thinking - optimized for complex reasoning
• Extraction - optimized for a large context window
• Instruct - optimized for closely following instructions
• Coder - optimized for programming tasks

The pattern provides an abstraction for different kinds of workflow tasks.

• Evaluate - non-agentic workflow evaluation
• Inference - general inference pattern
• Search - search extraction pattern
• Summarize - map-reduce pattern
• Compose - ReAct composer pattern for accurate annotation based document editing (Crate markdown)
• Debate - debate pattern where two agents each make an assessment; a third judge scores resolution.

pub fn get_workflow(&self) -> Result<Arc<Workflow>>

Gets the workflow for read-only access, loading it with Workflow::load_new if needed.

Uses a double-checked lock: fast RwLock read when loaded, upgrades to write lock to perform a single load on transition from Unloaded. Panics on poisoned locks.

pub fn get_workflow_like(&self) -> Result<Arc<dyn WorkflowLike>>

Returns the workflow as Arc<dyn WorkflowLike>.

pub fn get_workflow_mut(&self) -> Result<Workflow>

Returns an owned Workflow for mutation.

pub fn set_workflow(&self, workflow: Workflow)

Atomically replace the old workflow with the new workflow.

Sets state to Loaded with a new shared snapshot. Panics on poisoned lock.

pub fn compact(&self)

pub fn save_all(&self) -> Result<()>

Recursively saves all workflows and instances within this node’s workflow hierarchy.

This method saves the current workflow if it has pending changes, then recursively saves all child nodes and instances. It handles both loaded and unloaded workflows to ensure comprehensive state persistence.

Returns

Ok(()) if all save operations complete successfully, or an error if any workflow or instance fails to save.

Behavior

• Saves the current workflow if it has pending changes (is_touched())
• Recursively saves all child nodes in the workflow
• Saves all instances within the workflow
• Handles unloaded workflows by checking if they need saving
• Fails fast on any save error to maintain consistency

pub fn print(&self, writer: &mut Writer)

Trait Implementations

impl Clone for Node

fn clone(&self) -> Node

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Node

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Node

fn default() -> Self

Returns the “default value” for a type.

impl Display for Node

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for Node

fn eq(&self, other: &Self) -> bool

Equality is based on shared internal Arc identity, not workflow content.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl WriterLike for Node

fn write(&self, writer: &mut Writer)

Serialize this expression with the given Writer.

fn to_stringized(&self) -> String

Return a string representation (raw unsafe output).

fn to_sanitized(&self) -> String

Return a sanitized string representation (escaped for safe output).

fn to_expressionized(&self) -> String

Return a sanitized string representation (escaped for safe output).