Skip to main content

Module introspection

Module introspection 

Source
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§

ConnectivityMetrics
Graph connectivity metrics
CriticalPath
Critical path analysis result
DependencyChain
Dependency chain from one node to another
EdgeInfo
Information about a single edge in the graph
ExecutionWave
Execution wave: a group of nodes that can run concurrently
GraphSnapshot
Complete snapshot of graph structure and analysis
ImpactAnalysis
Impact analysis when modifying a node
NodeInfo
Information about a single node in the graph
NodeQuery
Query for filtering nodes in introspection