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

//! # Commands (CQRS)
//!
//! Operations that change state.

/// Command to acquire a command lock
#[derive(Debug, Clone)]
pub struct AcquireLockCommand {
    pub cmd_hash: String,
    pub pid: u32,
    pub output_path: Option<String>,
}

/// Command to release a command lock
#[derive(Debug, Clone)]
pub struct ReleaseLockCommand {
    pub cmd_hash: String,
    pub pid: u32,
}

/// Command to record a circuit breaker success
#[derive(Debug, Clone)]
pub struct RecordSuccessCommand {
    pub target: String,
}

/// Command to record a circuit breaker failure
#[derive(Debug, Clone)]
pub struct RecordFailureCommand {
    pub target: String,
}

/// Command to set component health
#[derive(Debug, Clone)]
pub struct SetHealthCommand {
    pub component: String,
    pub score: f32,
}

/// Command to record provider success
#[derive(Debug, Clone)]
pub struct RecordProviderSuccessCommand {
    pub provider: String,
    pub latency_ms: u32,
}

/// Command to record provider failure
#[derive(Debug, Clone)]
pub struct RecordProviderFailureCommand {
    pub provider: String,
}