microsandbox-db 0.3.14

Shared database entity definitions for the microsandbox project.
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

//! Entity definition for the `run` table.

use sea_orm::entity::prelude::*;

//--------------------------------------------------------------------------------------------------
// Types
//--------------------------------------------------------------------------------------------------

/// The status of a sandbox run.
#[derive(Debug, Clone, Copy, PartialEq, Eq, EnumIter, DeriveActiveEnum)]
#[sea_orm(rs_type = "String", db_type = "Text")]
pub enum RunStatus {
    /// The sandbox is running.
    #[sea_orm(string_value = "Running")]
    Running,

    /// The run has terminated.
    #[sea_orm(string_value = "Terminated")]
    Terminated,
}

/// The reason a sandbox run terminated.
#[derive(Debug, Clone, Copy, PartialEq, Eq, EnumIter, DeriveActiveEnum)]
#[sea_orm(rs_type = "String", db_type = "Text")]
pub enum TerminationReason {
    /// Sandbox exited cleanly (exit code 0).
    #[sea_orm(string_value = "Completed")]
    Completed,

    /// Sandbox exited with non-zero code or was killed by signal.
    #[sea_orm(string_value = "Failed")]
    Failed,

    /// Sandbox exceeded `max_duration_secs`.
    #[sea_orm(string_value = "MaxDurationExceeded")]
    MaxDurationExceeded,

    /// agentd reported no activity for `idle_timeout_secs`.
    #[sea_orm(string_value = "IdleTimeout")]
    IdleTimeout,

    /// SIGUSR1 received (explicit drain request).
    #[sea_orm(string_value = "DrainRequested")]
    DrainRequested,

    /// SIGTERM/SIGINT received from external source.
    #[sea_orm(string_value = "Signal")]
    Signal,

    /// Internal error.
    #[sea_orm(string_value = "InternalError")]
    InternalError,
}

/// A single run of a sandbox.
#[derive(Clone, Debug, PartialEq, DeriveEntityModel)]
#[sea_orm(table_name = "run")]
pub struct Model {
    #[sea_orm(primary_key)]
    pub id: i32,
    pub sandbox_id: i32,
    pub pid: Option<i32>,
    pub status: RunStatus,
    pub exit_code: Option<i32>,
    pub exit_signal: Option<i32>,
    pub termination_reason: Option<TerminationReason>,
    pub termination_detail: Option<String>,
    pub signals_sent: Option<String>,
    pub started_at: Option<DateTime>,
    pub terminated_at: Option<DateTime>,
}

//--------------------------------------------------------------------------------------------------
// Types: Relations
//--------------------------------------------------------------------------------------------------

/// Relations for the run entity.
#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
pub enum Relation {
    /// A run belongs to a sandbox.
    #[sea_orm(
        belongs_to = "super::sandbox::Entity",
        from = "Column::SandboxId",
        to = "super::sandbox::Column::Id",
        on_delete = "Cascade"
    )]
    Sandbox,
}

impl Related<super::sandbox::Entity> for Entity {
    fn to() -> RelationDef {
        Relation::Sandbox.def()
    }
}

//--------------------------------------------------------------------------------------------------
// Trait Implementations
//--------------------------------------------------------------------------------------------------

impl std::fmt::Display for TerminationReason {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::Completed => f.write_str("Completed"),
            Self::Failed => f.write_str("Failed"),
            Self::MaxDurationExceeded => f.write_str("MaxDurationExceeded"),
            Self::IdleTimeout => f.write_str("IdleTimeout"),
            Self::DrainRequested => f.write_str("DrainRequested"),
            Self::Signal => f.write_str("Signal"),
            Self::InternalError => f.write_str("InternalError"),
        }
    }
}

impl ActiveModelBehavior for ActiveModel {}