deepstrike-core 0.2.33

Cross-language agent runtime kernel — pure computation, zero I/O
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

use crate::types::policy::{AttentionPolicy, SignalDisposition};
use crate::types::signal::{RuntimeSignal, Urgency};

/// Default attention policy based on signal urgency.
pub struct UrgencyBasedPolicy;

impl AttentionPolicy for UrgencyBasedPolicy {
    fn evaluate(&self, signal: &RuntimeSignal, is_running: bool) -> SignalDisposition {
        match signal.urgency {
            Urgency::Critical => {
                if is_running {
                    SignalDisposition::InterruptNow
                } else {
                    SignalDisposition::Run { priority: 255 }
                }
            }
            Urgency::High => {
                if is_running {
                    SignalDisposition::Interrupt
                } else {
                    SignalDisposition::Run { priority: 100 }
                }
            }
            Urgency::Normal => SignalDisposition::Queue,
            Urgency::Low => SignalDisposition::Observe,
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::types::signal::{SignalSource, SignalType};

    #[test]
    fn critical_signal_interrupts_running() {
        let policy = UrgencyBasedPolicy;
        let signal = RuntimeSignal::new(
            SignalSource::Gateway,
            SignalType::Alert,
            Urgency::Critical,
            "fire",
        );
        assert_eq!(
            policy.evaluate(&signal, true),
            SignalDisposition::InterruptNow
        );
    }

    #[test]
    fn low_signal_observed() {
        let policy = UrgencyBasedPolicy;
        let signal =
            RuntimeSignal::new(SignalSource::Cron, SignalType::Event, Urgency::Low, "tick");
        assert_eq!(policy.evaluate(&signal, false), SignalDisposition::Observe);
    }
}