public_git/postgres-operator
1
0
Fork 0
mirror of https://github.com/zalando/postgres-operator.git synced 2026-10-19 09:24:46 +02:00
Code Issues Projects Releases Wiki Activity

create key in the cluster map on cluster creation failure

Browse Source
This commit is contained in:
Murat Kabilov
2017-05-12 11:41:32 +02:00
parent 3b99ce3d2e
commit ce90a54cf9
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/controller/postgresql.go
+3 -2
View File
@@ -96,6 +96,9 @@ func (c *Controller) postgresqlAdd(obj interface{}) {
c.logger.Infof("Creation of a new Postgresql cluster '%s' started", clusterName) c.logger.Infof("Creation of a new Postgresql cluster '%s' started", clusterName)
cl := cluster.New(c.makeClusterConfig(), *pg, c.logger.Logger) cl := cluster.New(c.makeClusterConfig(), *pg, c.logger.Logger)
c.clusters[clusterName] = cl
cl.SetStatus(spec.ClusterStatusCreating) cl.SetStatus(spec.ClusterStatusCreating)
if err := cl.Create(); err != nil { if err := cl.Create(); err != nil {
c.logger.Errorf("Can't create cluster: %s", err) c.logger.Errorf("Can't create cluster: %s", err)
@@ -103,10 +106,8 @@ func (c *Controller) postgresqlAdd(obj interface{}) {
return return
} }
cl.SetStatus(spec.ClusterStatusRunning) //TODO: are you sure it's running? cl.SetStatus(spec.ClusterStatusRunning) //TODO: are you sure it's running?
stopCh := make(chan struct{}) stopCh := make(chan struct{})
c.stopChMap[clusterName] = stopCh c.stopChMap[clusterName] = stopCh
c.clusters[clusterName] = cl
go cl.Run(stopCh) go cl.Run(stopCh)
c.logger.Infof("Postgresql cluster '%s' has been created", clusterName) c.logger.Infof("Postgresql cluster '%s' has been created", clusterName)