public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

add special case for Sync

This commit is contained in:
Sergey Dudoladov 2019-04-16 11:56:27 +02:00
parent d4ebd33db8
commit fe1d1b2dec
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/cluster/sync.go
View File

@ -4,7 +4,7 @@ import (
"fmt" "fmt"
batchv1beta1 "k8s.io/api/batch/v1beta1" batchv1beta1 "k8s.io/api/batch/v1beta1"
"k8s.io/api/core/v1" v1 "k8s.io/api/core/v1"
policybeta1 "k8s.io/api/policy/v1beta1" policybeta1 "k8s.io/api/policy/v1beta1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@ -539,6 +539,11 @@ func (c *Cluster) syncLogicalBackupJob() error {
) )
c.setProcessName("syncing the logical backup job") c.setProcessName("syncing the logical backup job")
// operator pod at startup syncs all clusters, logicalBackupJob will be nil at this point
if (c.Postgresql.Spec.EnableLogicalBackup == true) && (c.logicalBackupJob == nil) {
c.logicalBackupJob, err = c.generateLogicalBackupJob()
}
if job, err = c.KubeClient.CronJobsGetter.CronJobs(c.Namespace).Get(c.logicalBackupJob.Name, metav1.GetOptions{}); err == nil { if job, err = c.KubeClient.CronJobsGetter.CronJobs(c.Namespace).Get(c.logicalBackupJob.Name, metav1.GetOptions{}); err == nil {
desiredJob, err = c.generateLogicalBackupJob() desiredJob, err = c.generateLogicalBackupJob()