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, FindStartNode, etc.

Re-exports

pub use compiler::compile_attractor_graph;

pub use compiler::validate_attractor_graph;

pub use runner::RunOptions;

pub use runner::run_compiled_graph;

pub use runner::run_streamweave_graph;

pub use types::AttractorResult;

pub use types::AttractorGraph;

pub use types::AttractorNode;

pub use types::ExecutionState;

pub use types::NodeOutcome;

pub use types::RunSummaryOutput;

pub use types::run_summary_output_from_log;

Modules

compiler

Compile AttractorGraph (AST) to StreamWeave graph.

dot_parser

Minimal DOT parser for Attractor pipeline graphs.

execution_log_io

Load execution.log.json and derive resume state (for –resume when log is single source).

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 staging when not overridden.