Initial Commit

1 files changed, 44 insertions, 0 deletions

diff --git a/src/backup/deploy.rs b/src/backup/deploy.rs
new file mode 100644
index 0000000..0ab0be8
--- /dev/null
+++ b/src/backup/deploy.rs
@@ -0,0 +1,44 @@
+use kube::{Client, ResourceExt};
+use restic_crd::Backup;
+
+use super::job::BackupJob;
+use crate::{
+    deploy::{Deployable, Labels},
+    resticprofile::ResticProfile,
+    Error,
+};
+
+#[derive(Debug, Clone)]
+pub struct BackupDeployment {
+    profile: ResticProfile,
+    job: BackupJob,
+}
+
+impl BackupDeployment {
+    pub fn new(ns: String, backup: &Backup) -> Self {
+        let profile = ResticProfile::new(ns.clone(), backup.name_any(), &backup.spec);
+        let job = BackupJob::new(ns, backup, profile.name());
+        Self { profile, job }
+    }
+}
+
+impl Deployable for BackupDeployment {
+    type Error = Error;
+
+    async fn create<O>(&self, client: Client, owner: &O, labels: 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: Client) -> Result<(), Self::Error> {
+        self.profile.delete(client.clone()).await?;
+        self.job.delete(client).await?;
+        Ok(())
+    }
+}