orca-core 0.1.0-rc.2

Core types, configuration, Runtime trait, and error types for the orca orchestrator
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

use serde::{Deserialize, Serialize};

/// Configuration for the backup system.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct BackupConfig {
    /// Cron expression for scheduled backups (e.g. "0 0 2 * * *" for 2am daily).
    #[serde(default)]
    pub schedule: Option<String>,

    /// Number of days to retain backups before pruning.
    #[serde(default = "default_retention_days")]
    pub retention_days: u32,

    /// Where to store backups.
    #[serde(default)]
    pub targets: Vec<BackupTarget>,
}

fn default_retention_days() -> u32 {
    30
}

/// A backup storage destination.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(tag = "type", rename_all = "lowercase")]
pub enum BackupTarget {
    Local {
        path: String,
    },
    S3 {
        bucket: String,
        region: String,
        #[serde(default)]
        prefix: Option<String>,
        /// Optional S3-compatible endpoint (for Minio, R2, B2, etc.).
        #[serde(default)]
        endpoint: Option<String>,
        /// AWS access key. Falls back to `AWS_ACCESS_KEY_ID` env var.
        #[serde(default)]
        access_key: Option<String>,
        /// AWS secret key. Falls back to `AWS_SECRET_ACCESS_KEY` env var.
        #[serde(default)]
        secret_key: Option<String>,
    },
}

/// Per-service backup settings.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ServiceBackupConfig {
    /// Whether backups are enabled for this service.
    #[serde(default)]
    pub enabled: bool,

    /// Command to run before backup (e.g. "pg_dump -U postgres mydb > /tmp/dump.sql").
    #[serde(default)]
    pub pre_hook: Option<String>,
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn parse_backup_config() {
        let toml = r#"
schedule = "0 0 2 * * *"
retention_days = 7

[[targets]]
type = "local"
path = "/backups"

[[targets]]
type = "s3"
bucket = "my-backups"
region = "eu-central-1"
prefix = "orca/"
"#;
        let config: BackupConfig = toml::from_str(toml).unwrap();
        assert_eq!(config.retention_days, 7);
        assert_eq!(config.targets.len(), 2);
    }
}