zebflow 0.11.14

Reactive web automation platform — pipelines, templates, and real-time collaboration in a single binary.
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
143
144
145
146
147
148

//! Portable project runtime profile.
//!
//! This model captures repo-owned runtime intent that should survive movement between standalone,
//! shared-worker, pinned-worker, dedicated-runtime, and future independent-platform deployments.
//!
//! It intentionally does not include concrete worker ids or cluster-local addresses. Those are
//! environment-owned placement details.

use std::fmt;

use serde::{Deserialize, Serialize};

use crate::infra::execution::backend::ExecutionProfileKind;

/// Runtime mode chosen for one project.
#[derive(Debug, Clone, Copy, Serialize, Deserialize, PartialEq, Eq, Default)]
#[serde(rename_all = "snake_case")]
pub enum ProjectRuntimeMode {
    /// Project runs in a shared worker pool.
    #[default]
    Shared,
    /// Project is pinned to one chosen worker or worker-class.
    Pinned,
    /// Project gets its own dedicated runtime deployment or VM.
    Dedicated,
}

impl ProjectRuntimeMode {
    /// Stable string form used by UI payloads and portable config displays.
    pub const fn as_str(self) -> &'static str {
        match self {
            Self::Shared => "shared",
            Self::Pinned => "pinned",
            Self::Dedicated => "dedicated",
        }
    }
}

impl fmt::Display for ProjectRuntimeMode {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str(self.as_str())
    }
}

/// Named resource sizing profile.
#[derive(Debug, Clone, Copy, Serialize, Deserialize, PartialEq, Eq, Default)]
#[serde(rename_all = "snake_case")]
pub enum ResourceProfile {
    Tiny,
    #[default]
    Small,
    Medium,
    Large,
    /// Explicit resource numbers are supplied in `custom_resources`.
    Custom,
}

/// Explicit runtime resource overrides.
#[derive(Debug, Clone, Serialize, Deserialize, Default, PartialEq, Eq)]
#[serde(deny_unknown_fields)]
pub struct RuntimeResourceSpec {
    /// Requested CPU in millicores.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub cpu_request_millis: Option<u32>,
    /// Requested memory in megabytes.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub memory_request_mb: Option<u32>,
    /// Hard CPU limit in millicores.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub cpu_limit_millis: Option<u32>,
    /// Hard memory limit in megabytes.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub memory_limit_mb: Option<u32>,
    /// Optional ephemeral disk in megabytes.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub ephemeral_disk_mb: Option<u32>,
    /// Optional accelerator/GPU count.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub accelerator_count: Option<u16>,
}

/// Portable runtime profile stored in repo config and migration plans.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Eq)]
#[serde(deny_unknown_fields)]
pub struct ProjectRuntimeProfile {
    /// Runtime isolation mode.
    #[serde(default)]
    pub mode: ProjectRuntimeMode,
    /// Portable execution profile.
    #[serde(default)]
    pub execution: ExecutionProfileKind,
    /// Named resource sizing tier.
    #[serde(default)]
    pub resource_profile: ResourceProfile,
    /// Desired minimum number of resident replicas.
    #[serde(default = "default_min_replicas")]
    pub min_replicas: u32,
    /// Optional ceiling for autoscaling.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub max_replicas: Option<u32>,
    /// Required runner tags/capabilities for placement.
    #[serde(default, skip_serializing_if = "Vec::is_empty")]
    pub required_tags: Vec<String>,
    /// Explicit resource numbers used when `resource_profile == custom`.
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub custom_resources: Option<RuntimeResourceSpec>,
}

const fn default_min_replicas() -> u32 {
    1
}

impl Default for ProjectRuntimeProfile {
    fn default() -> Self {
        Self {
            mode: ProjectRuntimeMode::Shared,
            execution: ExecutionProfileKind::Resident,
            resource_profile: ResourceProfile::Small,
            min_replicas: default_min_replicas(),
            max_replicas: None,
            required_tags: Vec::new(),
            custom_resources: None,
        }
    }
}

impl ProjectRuntimeProfile {
    /// Whether this profile carries explicit resource overrides.
    pub fn uses_custom_resources(&self) -> bool {
        self.resource_profile == ResourceProfile::Custom && self.custom_resources.is_some()
    }
}

#[cfg(test)]
mod tests {
    use super::{ProjectRuntimeMode, ProjectRuntimeProfile, ResourceProfile};
    use crate::infra::execution::backend::ExecutionProfileKind;

    #[test]
    fn default_runtime_profile_is_portable() {
        let profile = ProjectRuntimeProfile::default();
        assert_eq!(profile.mode, ProjectRuntimeMode::Shared);
        assert_eq!(profile.execution, ExecutionProfileKind::Resident);
        assert_eq!(profile.resource_profile, ResourceProfile::Small);
        assert_eq!(profile.min_replicas, 1);
        assert!(profile.max_replicas.is_none());
    }
}