VesselRs 0.1.0

Shared memory primitives for multi-agent orchestration
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

//! # Domain Events
//!
//! Immutable events representing state changes.
//!
//! ## Event Sourcing Principles
//!
//! - Events are immutable facts
//! - Append-only log
//! - Reconstruct state by replaying events

use std::time::SystemTime;

/// Domain events for the SHM bounded context
#[derive(Debug, Clone)]
pub enum ShmEvent {
    /// Command lock was acquired
    CommandLockAcquired {
        cmd_hash: String,
        pid: u32,
        timestamp: SystemTime,
    },
    /// Command lock was released
    CommandLockReleased {
        cmd_hash: String,
        pid: u32,
        timestamp: SystemTime,
    },
    /// Circuit breaker opened
    CircuitBreakerOpened {
        target: String,
        failures: u32,
        timestamp: SystemTime,
    },
    /// Circuit breaker closed
    CircuitBreakerClosed {
        target: String,
        timestamp: SystemTime,
    },
    /// Circuit breaker half-opened
    CircuitBreakerHalfOpened {
        target: String,
        timestamp: SystemTime,
    },
    /// Provider metrics updated
    ProviderMetricsUpdated {
        provider: String,
        success_rate: f32,
        timestamp: SystemTime,
    },
    /// XP earned
    XpEarned {
        agent_id: String,
        amount: u64,
        new_level: u32,
        timestamp: SystemTime,
    },
}

impl ShmEvent {
    /// Get the timestamp of the event
    pub fn timestamp(&self) -> SystemTime {
        match self {
            ShmEvent::CommandLockAcquired { timestamp, .. } => *timestamp,
            ShmEvent::CommandLockReleased { timestamp, .. } => *timestamp,
            ShmEvent::CircuitBreakerOpened { timestamp, .. } => *timestamp,
            ShmEvent::CircuitBreakerClosed { timestamp, .. } => *timestamp,
            ShmEvent::CircuitBreakerHalfOpened { timestamp, .. } => *timestamp,
            ShmEvent::ProviderMetricsUpdated { timestamp, .. } => *timestamp,
            ShmEvent::XpEarned { timestamp, .. } => *timestamp,
        }
    }
}