From 5c7233a483160677dc8541ed4807297a5cbc3960 Mon Sep 17 00:00:00 2001 From: Sergey Dudoladov Date: Fri, 11 Jan 2019 16:03:18 +0100 Subject: [PATCH] Add a stub method for cron job creation --- pkg/cluster/cluster.go | 6 ++++++ pkg/cluster/resources.go | 6 ++++++ 2 files changed, 12 insertions(+) diff --git a/pkg/cluster/cluster.go b/pkg/cluster/cluster.go index 7eaa873fd..6ee2c80bb 100644 --- a/pkg/cluster/cluster.go +++ b/pkg/cluster/cluster.go @@ -296,6 +296,12 @@ func (c *Cluster) Create() error { c.logger.Infof("databases have been successfully created") } + if c.Postgresql.Spec.EnableLogicalBackup { + if err := c.createBackupCronJob(); err != nil { + return fmt.Errorf("could not create a k8s cron job for logical backups: %v", err) + } + } + if err := c.listResources(); err != nil { c.logger.Errorf("could not list resources: %v", err) } diff --git a/pkg/cluster/resources.go b/pkg/cluster/resources.go index 10e4201cb..5bf72abda 100644 --- a/pkg/cluster/resources.go +++ b/pkg/cluster/resources.go @@ -605,6 +605,12 @@ func (c *Cluster) createRoles() (err error) { return c.syncRoles() } +func (c *Cluster) createBackupCronJob() (err error) { + c.setProcessName("creating a k8s cron job for backups") + + return nil +} + // GetServiceMaster returns cluster's kubernetes master Service func (c *Cluster) GetServiceMaster() *v1.Service { return c.Services[Master]