streamweave-attractor 0.3.0

Attractor pipeline as a StreamWeave graph
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Predefined StreamWeave graphs built with the `graph!` macro.
//!
//! Use these instead of building equivalent graphs manually so that fixed
//! pipeline shapes stay declarative and easy to read.

use crate::nodes::IdentityNode;
use streamweave::graph::Graph;
use tracing::instrument;

/// Trivial start→exit pipeline: one identity from input to output.
///
/// Node names are `start` and `exit` to match the Attractor convention.
/// Graph I/O: `input` → start.in, exit.out → `output`.
#[instrument(level = "trace")]
pub fn trivial_start_exit_graph() -> Graph {
  streamweave::graph! {
    start: IdentityNode::new("start"),
    exit: IdentityNode::new("exit"),
    graph.input => start.in,
    start.out => exit.in,
    exit.out => graph.output
  }
}