righvalor 0.1.0

RighValor: AI Infrastructure and Applications Framework for the Far Edge
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

use ractor_cluster::RactorClusterMessage;

use crate::{
    common::task::ValorMasterTask,
    master::{ValorMasterRejectedReason, ValorMasterServiceManagement},
};
/// Messages that Worker can receive from Valor Master and external systems.
///
/// These messages implement the northbound communication protocol where the
/// Valor Master sends task assignments, service management commands, and
/// registration responses to Valor Workers.
///
/// ## Communication Flow
///
/// - **Registration Flow**: Master confirms or rejects worker registration
/// - **Task Assignment**: Master distributes computational tasks to workers
/// - **Service Management**: Master sends service lifecycle commands
/// - **Operational Control**: Master sends operational commands like shutdown
#[derive(Debug, Clone, RactorClusterMessage)]
pub enum ValorWorkerMessage {
    /// Shutdown the worker gracefully
    Shutdown,

    /// Northbound: Master has confirmed worker registration
    ///
    /// Sent by Valor Master to acknowledge successful worker registration
    /// and indicate the worker is now part of the distributed compute cluster.
    NorthboundRegisterMasterConfirmed,

    /// Northbound: Master has rejected worker registration
    ///
    /// Sent by Valor Master when worker registration fails, including
    /// the specific reason for rejection to enable corrective action.
    NorthboundRegisterMasterRejected(ValorMasterRejectedReason),

    /// Northbound: Master task assignment
    ///
    /// Sent by Valor Master to assign a computational task to this worker.
    /// Contains the task to be executed based on worker capabilities.
    NorthboundMasterTask(Box<ValorMasterTask>),

    /// Northbound: Master service management commands
    ///
    /// Sent by Valor Master to manage the lifecycle of services on this worker.
    /// Includes installation, updates, configuration, and removal commands.
    NorthboundMasterServiceManagements(Vec<ValorMasterServiceManagement>),

    /// Northbound: Master confirmed worker unregistration
    NorthboundUnregisterConfirmed,
}