a3s-runtime 0.2.0

Provider-neutral execution contract and client for A3S runtimes
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

use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum IsolationLevel {
    Process,
    Container,
    Sandbox,
    Confidential,
}

#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(deny_unknown_fields)]
pub struct ResourceLimits {
    pub cpu_millis: u64,
    pub memory_bytes: u64,
    pub pids: u32,
    /// Optional writable-layer quota. Providers must advertise
    /// `ResourceControl::EphemeralStorage` before accepting this limit.
    pub ephemeral_storage_bytes: Option<u64>,
    /// Required for finite Tasks and forbidden for long-running Services.
    pub execution_timeout_ms: Option<u64>,
}

impl ResourceLimits {
    pub(crate) fn validate(&self) -> Result<(), String> {
        if self.cpu_millis == 0 || self.memory_bytes == 0 || self.pids == 0 {
            return Err("required Runtime resource limits must be positive".into());
        }
        if self.ephemeral_storage_bytes == Some(0) {
            return Err("ephemeral_storage_bytes must be positive when present".into());
        }
        if self.execution_timeout_ms == Some(0) {
            return Err("execution_timeout_ms must be positive when present".into());
        }
        Ok(())
    }
}