Crate streamweave_attractor 

streamweave-attractor

Attractor pipeline implementation as a graph of StreamWeave nodes. Implements StrongDM’s Attractor spec.

Architecture

All pipeline logic is implemented as StreamWeave nodes:

Pipeline logic is implemented as StreamWeave nodes (see nodes module). Supporting nodes: ApplyContextUpdatesNode, CheckGoalGatesNode, CreateCheckpointNode, FindStartNode, etc.

Re-exports

pub use compiler::compile_attractor_graph;

pub use nodes::AttractorResult;

pub use runner::RunOptions;

pub use runner::run_compiled_graph;

pub use runner::run_streamweave_graph;

pub use types::AttractorGraph;

pub use types::AttractorNode;

pub use types::ExecutionState;

pub use types::NodeOutcome;

Modules

checkpoint_io

Checkpoint save/load to run directory (JSON).

compiler

Compile AttractorGraph (AST) to StreamWeave graph.

dot_parser

Minimal DOT parser for Attractor pipeline graphs.

graphs

Predefined StreamWeave graphs built with the graph! macro.

nodes

StreamWeave nodes implementing Attractor pipeline logic.

runner

Compiled graph runner: compile AttractorGraph to StreamWeave graph and run it.

types

Attractor pipeline types per attractor-spec.

Constants

DEFAULT_STAGE_DIR

Default directory for outcome.json, checkpoint, and staging when not overridden.