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
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48

//! Attractor pipeline types per [attractor-spec](https://github.com/strongdm/attractor/blob/main/attractor-spec.md).
//!
//! These types flow through the StreamWeave graph as `Arc<dyn Any>`.

use std::collections::HashMap;

mod attractor_edge;
#[cfg(test)]
mod attractor_edge_test;
mod attractor_graph;
#[cfg(test)]
mod attractor_graph_test;
mod attractor_node;
#[cfg(test)]
mod attractor_node_test;
mod attractor_result;
mod execution_log;
mod execution_state;
#[cfg(test)]
mod execution_state_test;
mod graph_payload;
#[cfg(test)]
mod graph_payload_test;
mod node_outcome;
#[cfg(test)]
mod node_outcome_test;
mod outcome_status;
#[cfg(test)]
mod outcome_status_test;
mod resume_state;
#[cfg(test)]
mod resume_state_test;
mod run_summary;

pub use attractor_edge::AttractorEdge;
pub use attractor_graph::AttractorGraph;
pub use attractor_node::AttractorNode;
pub use attractor_result::AttractorResult;
pub use execution_log::{ExecutionLog, ExecutionStepEntry};
pub use execution_state::ExecutionState;
pub use graph_payload::GraphPayload;
pub use node_outcome::NodeOutcome;
pub use outcome_status::OutcomeStatus;
pub use resume_state::ResumeState;
pub use run_summary::{RunSummary, RunSummaryOutput, run_summary_output_from_log};

/// Key-value context shared across the pipeline run.
pub type RunContext = HashMap<String, String>;