polaris_graph 0.4.4

Graph execution primitives for Polaris (Layer 2).
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

//! Middleware info structs passed to middleware handlers.
//!
//! Each target has a corresponding info type that carries metadata about the
//! execution unit being wrapped. These are passed as the first parameter to
//! middleware handlers registered via [`MiddlewareAPI::register_system`](super::MiddlewareAPI::register_system).

use crate::NodeId;
use crate::node::ContextMode;

/// Metadata passed to [`GraphExecution`](super::GraphExecution) middleware.
#[derive(Debug, Clone)]
pub struct GraphInfo {
    /// Number of nodes in the graph.
    pub node_count: usize,
}

/// Metadata passed to [`System`](super::System) middleware.
#[derive(Debug, Clone)]
pub struct SystemInfo {
    /// The node ID of the executing system.
    pub node_id: NodeId,
    /// The system's name.
    pub node_name: &'static str,
}

/// Metadata passed to [`Loop`](super::Loop) middleware.
#[derive(Debug, Clone)]
pub struct LoopInfo {
    /// The node ID of the loop node.
    pub node_id: NodeId,
    /// The loop's name.
    pub node_name: &'static str,
    /// The maximum iterations allowed.
    pub max_iterations: usize,
}

/// Metadata passed to [`Parallel`](super::Parallel) middleware.
#[derive(Debug, Clone)]
pub struct ParallelInfo {
    /// The node ID of the parallel node.
    pub node_id: NodeId,
    /// The parallel node's name.
    pub node_name: &'static str,
    /// Number of branches.
    pub branch_count: usize,
}

/// Metadata passed to [`Decision`](super::Decision) middleware.
#[derive(Debug, Clone)]
pub struct DecisionInfo {
    /// The node ID of the decision node.
    pub node_id: NodeId,
    /// The decision node's name.
    pub node_name: &'static str,
}

/// Metadata passed to [`Switch`](super::Switch) middleware.
#[derive(Debug, Clone)]
pub struct SwitchInfo {
    /// The node ID of the switch node.
    pub node_id: NodeId,
    /// The switch node's name.
    pub node_name: &'static str,
    /// Number of cases in the switch.
    pub case_count: usize,
    /// Whether a default case exists.
    pub has_default: bool,
}

/// Metadata passed to [`LoopIteration`](super::LoopIteration) middleware.
#[derive(Debug, Clone)]
pub struct LoopIterationInfo {
    /// The node ID of the loop node.
    pub node_id: NodeId,
    /// The loop's name.
    pub node_name: &'static str,
    /// Current iteration (0-indexed).
    pub iteration: usize,
    /// Maximum iterations allowed.
    pub max_iterations: usize,
}

/// Metadata passed to [`ParallelBranch`](super::ParallelBranch) middleware.
#[derive(Debug, Clone)]
pub struct ParallelBranchInfo {
    /// The node ID of the parallel node.
    pub node_id: NodeId,
    /// The parallel node's name.
    pub node_name: &'static str,
    /// Index of this branch (0-indexed).
    pub branch_index: usize,
    /// Total number of branches.
    pub branch_count: usize,
}

/// Metadata passed to [`Scope`](super::Scope) middleware.
#[derive(Debug, Clone)]
pub struct ScopeInfo {
    /// The node ID of the scope node.
    pub node_id: NodeId,
    /// The scope node's name.
    pub node_name: &'static str,
    /// High-level context-boundary classification — `Shared`, `Inherit`, or
    /// `Isolated`. See [`ContextMode`] and
    /// [`ContextPolicy::mode`](crate::node::ContextPolicy::mode).
    pub mode: ContextMode,
    /// Number of nodes in the embedded graph.
    pub inner_node_count: usize,
}