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
|
use kube::ResourceExt;
use restic_crd::ScheduledBackup;
use super::{cronjob::BackupCronJob, Error};
use crate::{deploy::Deployable, resticprofile::ResticProfile};
#[derive(Debug, Clone)]
pub struct ScheduledBackupDeployment {
profile: ResticProfile,
job: BackupCronJob,
}
impl ScheduledBackupDeployment {
pub fn new(ns: String, backup: &ScheduledBackup) -> Self {
let profile = ResticProfile::new(ns.clone(), backup.name_any(), &backup.spec.backup);
let job = BackupCronJob::new(ns, backup, profile.name());
Self { profile, job }
}
}
impl Deployable for ScheduledBackupDeployment {
type Error = Error;
async fn create<O>(
&self,
client: kube::Client,
owner: &O,
labels: crate::deploy::Labels,
) -> Result<(), Self::Error>
where
O: kube::Resource<DynamicType = ()> + Send + Sync,
{
self.profile
.create(client.clone(), owner, labels.clone())
.await?;
self.job.create(client, owner, labels).await?;
Ok(())
}
async fn delete(&self, client: kube::Client) -> Result<(), Self::Error> {
self.profile.delete(client.clone()).await?;
self.job.delete(client).await?;
Ok(())
}
}
|
