Expand description
Graph introspection types and queries Graph introspection types and queries
Provides runtime inspection of DAG structure, execution state, and analysis.
§Example
use stygian_graph::domain::graph::{Pipeline, Node, Edge, DagExecutor};
use stygian_graph::domain::introspection::GraphSnapshot;
use serde_json::json;
let mut pipeline = Pipeline::new("example");
pipeline.add_node(Node::new("fetch", "http", json!({"url": "https://example.com"})));
pipeline.add_node(Node::new("extract", "ai", json!({})));
pipeline.add_edge(Edge::new("fetch", "extract"));
let executor = DagExecutor::from_pipeline(&pipeline).unwrap();
let snapshot = executor.snapshot();
assert_eq!(snapshot.node_count, 2);
assert_eq!(snapshot.edge_count, 1);Structs§
- Connectivity
Metrics - Graph connectivity metrics
- Critical
Path - Critical path analysis result
- Dependency
Chain - Dependency chain from one node to another
- Edge
Info - Information about a single edge in the graph
- Execution
Wave - Execution wave: a group of nodes that can run concurrently
- Graph
Snapshot - Complete snapshot of graph structure and analysis
- Impact
Analysis - Impact analysis when modifying a node
- Node
Info - Information about a single node in the graph
- Node
Query - Query for filtering nodes in introspection