rustic_scheduler 0.2.1

rustic scheduler - a client/server application to schedule regular backups on many clients to one identical repository controlled by a central scheduling server.
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

//! RusticScheduler Config
//!
//! See instructions in `commands.rs` to specify the path to your
//! application's configuration file and/or command-line options
//! for specifying it.

use std::collections::HashMap;

use anyhow::{bail, Result};
use cron::Schedule;
use rustic_backend::BackendOptions;
use rustic_core::{BackupOptions, RepositoryOptions, SnapshotOptions};
use serde::{Deserialize, Serialize};
use serde_with::{serde_as, DisplayFromStr};

#[serde_as]
#[derive(Clone, Debug, Deserialize, Serialize, Default)]
#[serde(deny_unknown_fields)]
pub struct RusticSchedulerConfig {
    pub global: GlobalOptions,
    pub repository: AllRepositoryOptions,
    pub clientgroup: HashMap<String, ClientGroupOptions>,
    #[serde_as(as = "HashMap<_,DisplayFromStr>")]
    pub schedules: HashMap<String, Schedule>,
    pub options: HashMap<String, AllBackupOptions>,
}

#[derive(Clone, Debug, Deserialize, Serialize, Default)]
#[serde(deny_unknown_fields)]
pub struct GlobalOptions {
    pub address: String,
}

#[derive(Clone, Debug, Deserialize, Serialize, Default)]
#[serde(deny_unknown_fields)]
pub struct ClientGroupOptions {
    pub clients: Vec<String>,
    pub sources: Vec<SourceOptions>,
}

#[derive(Clone, Debug, Deserialize, Serialize, Default)]
#[serde(deny_unknown_fields)]
pub struct SourceOptions {
    pub source: String,
    pub schedule: String,
    pub options: String,
}

#[derive(Clone, Debug, Deserialize, Serialize, Default)]
#[serde(deny_unknown_fields)]
pub struct AllBackupOptions {
    #[serde(flatten)]
    pub backup_opts: BackupOptions,
    #[serde(flatten)]
    pub snapshot_opts: SnapshotOptions,
}

#[derive(Clone, Debug, Deserialize, Serialize, Default)]
#[serde(deny_unknown_fields)]
pub struct AllRepositoryOptions {
    #[serde(flatten)]
    pub be: BackendOptions,
    #[serde(flatten)]
    pub repo: RepositoryOptions,
}

impl RusticSchedulerConfig {
    pub fn validate(&self) -> Result<()> {
        for (name, cg) in self.clientgroup.iter() {
            for source in &cg.sources {
                if !self.options.contains_key(&source.options) {
                    bail!(
                        "Clientgroup {name}, Source {}: Options {} are undefined!",
                        source.source,
                        source.options
                    );
                }
                if !self.schedules.contains_key(&source.schedule) {
                    bail!(
                        "Clientgroup {name}, Source {}: Scheduler {} is undefined!",
                        source.source,
                        source.schedule
                    );
                }
            }
        }

        Ok(())
    }
}