pelagos 0.61.1

Fast Linux container runtime — OCI-compatible, namespaces, cgroups v2, seccomp, networking, image management
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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142

//! Docker API request/response types for pelagos-dockerd.

use serde::{Deserialize, Serialize};
use std::collections::HashMap;

// ── Requests ────────────────────────────────────────────────────────────────

#[derive(Debug, Clone, Deserialize, Default)]
#[serde(rename_all = "PascalCase")]
pub struct ContainerCreateBody {
    pub image: String,
    #[serde(default)]
    pub cmd: Option<Vec<String>>,
    #[serde(default)]
    pub entrypoint: Option<Vec<String>>,
    #[serde(default)]
    pub env: Option<Vec<String>>,
    #[serde(default)]
    pub labels: Option<HashMap<String, String>>,
    #[serde(default)]
    pub working_dir: Option<String>,
    #[serde(default)]
    pub user: Option<String>,
    #[serde(default)]
    pub hostname: Option<String>,
    #[serde(default)]
    pub host_config: Option<HostConfig>,
}

#[derive(Debug, Clone, Deserialize, Default)]
#[serde(rename_all = "PascalCase")]
#[allow(dead_code)]
pub struct HostConfig {
    #[serde(default)]
    pub network_mode: Option<String>,
    #[serde(default)]
    pub binds: Option<Vec<String>>,
    #[serde(default)]
    pub memory: Option<i64>,
    #[serde(default)]
    pub cap_add: Option<Vec<String>>,
    #[serde(default)]
    pub cap_drop: Option<Vec<String>>,
    #[serde(default)]
    pub security_opt: Option<Vec<String>>,
    #[serde(default)]
    pub privileged: Option<bool>,
}

#[derive(Debug, Clone, Deserialize, Default)]
#[serde(rename_all = "PascalCase")]
#[allow(dead_code)]
pub struct ExecCreateBody {
    #[serde(default)]
    pub cmd: Vec<String>,
    #[serde(default)]
    pub attach_stdin: Option<bool>,
    #[serde(default)]
    pub attach_stdout: Option<bool>,
    #[serde(default)]
    pub attach_stderr: Option<bool>,
    #[serde(default)]
    pub tty: Option<bool>,
    #[serde(default)]
    pub env: Option<Vec<String>>,
    #[serde(default)]
    pub working_dir: Option<String>,
    #[serde(default)]
    pub user: Option<String>,
}

#[derive(Debug, Clone, Deserialize, Default)]
#[serde(rename_all = "PascalCase")]
#[allow(dead_code)]
pub struct ExecStartBody {
    #[serde(default)]
    pub detach: Option<bool>,
    #[serde(default)]
    pub tty: Option<bool>,
}

// ── Pending container (stored locally, not yet started) ─────────────────────

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct PendingContainer {
    pub name: String,
    pub image: String,
    pub cmd: Vec<String>,
    pub env: Vec<String>,
    pub labels: HashMap<String, String>,
    pub network_mode: String,
    pub binds: Vec<String>,
    pub working_dir: Option<String>,
    pub user: Option<String>,
    pub hostname: Option<String>,
    pub memory: Option<i64>,
    pub cap_add: Vec<String>,
    pub cap_drop: Vec<String>,
}

impl PendingContainer {
    pub fn from_create(name: String, body: ContainerCreateBody) -> Self {
        let hc = body.host_config.unwrap_or_default();
        let cmd = if let Some(ep) = body.entrypoint {
            let mut v = ep;
            if let Some(c) = body.cmd {
                v.extend(c);
            }
            v
        } else {
            body.cmd.unwrap_or_default()
        };

        Self {
            name,
            image: body.image,
            cmd,
            env: body.env.unwrap_or_default(),
            labels: body.labels.unwrap_or_default(),
            network_mode: hc.network_mode.unwrap_or_else(|| "bridge".to_string()),
            binds: hc.binds.unwrap_or_default(),
            working_dir: body.working_dir,
            user: body.user,
            hostname: body.hostname,
            memory: hc.memory,
            cap_add: hc.cap_add.unwrap_or_default(),
            cap_drop: hc.cap_drop.unwrap_or_default(),
        }
    }
}

// ── Exec session ────────────────────────────────────────────────────────────

#[derive(Debug, Clone)]
pub struct ExecSession {
    pub container_name: String,
    pub cmd: Vec<String>,
    pub tty: bool,
    pub env: Vec<String>,
    pub working_dir: Option<String>,
    pub user: Option<String>,
}