cruxx-core 0.2.5

Core types, traits, and runtime for the cruxx agentic DSL
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

/// Conditional tracing helpers — compile to no-ops without the `tracing` feature.
///
/// Uses `tracing::info!` events rather than spans to avoid `EnteredSpan` (not Send)
/// living across `.await` points in async methods.

/// Emit a tracing event for step execution start.
#[cfg(feature = "tracing")]
macro_rules! trace_step {
    ($name:expr, $confidence:expr) => {
        tracing::info!(name = $name, confidence = $confidence, "step.start");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_step {
    ($name:expr, $confidence:expr) => {};
}

/// Emit a tracing event for delegation start.
#[cfg(feature = "tracing")]
macro_rules! trace_delegate {
    ($name:expr, $agent:expr) => {
        tracing::info!(name = $name, agent = $agent, "delegate.start");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_delegate {
    ($name:expr, $agent:expr) => {};
}

/// Emit a tracing event for speculation start.
#[cfg(feature = "tracing")]
macro_rules! trace_speculate {
    ($name:expr, $arm_count:expr) => {
        tracing::info!(name = $name, arms = $arm_count, "speculate.start");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_speculate {
    ($name:expr, $arm_count:expr) => {};
}

/// Emit a tracing event for join_all start.
#[cfg(feature = "tracing")]
macro_rules! trace_join_all {
    ($name:expr, $arm_count:expr) => {
        tracing::info!(name = $name, arms = $arm_count, "join_all.start");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_join_all {
    ($name:expr, $arm_count:expr) => {};
}

/// Emit a tracing event for pipe start.
#[cfg(feature = "tracing")]
macro_rules! trace_pipe {
    ($name:expr, $stage_count:expr) => {
        tracing::info!(name = $name, stages = $stage_count, "pipe.start");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_pipe {
    ($name:expr, $stage_count:expr) => {};
}

/// Emit a tracing event for replay cache hit.
#[cfg(feature = "tracing")]
macro_rules! trace_replay_hit {
    ($name:expr) => {
        tracing::debug!(name = $name, "replay.hit");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_replay_hit {
    ($name:expr) => {};
}

/// Emit a tracing event for replay cache miss.
#[cfg(feature = "tracing")]
macro_rules! trace_replay_miss {
    ($name:expr) => {
        tracing::debug!(name = $name, "replay.miss");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_replay_miss {
    ($name:expr) => {};
}

/// Emit a tracing event for hook dispatch.
#[cfg(feature = "tracing")]
macro_rules! trace_hook {
    ($hook:expr, $step:expr) => {
        tracing::debug!(hook = $hook, step = $step, "hook.dispatch");
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_hook {
    ($hook:expr, $step:expr) => {};
}

/// Emit a tracing event for route_on_confidence matching.
#[cfg(feature = "tracing")]
macro_rules! trace_route {
    ($name:expr, $confidence:expr, $label:expr) => {
        tracing::info!(
            name = $name,
            confidence = $confidence,
            matched = $label,
            "route.matched"
        );
    };
}

#[cfg(not(feature = "tracing"))]
macro_rules! trace_route {
    ($name:expr, $confidence:expr, $label:expr) => {};
}