Add observedGeneration field to status of postgresql resource

Signed-off-by: Mikkel Oscar Lyderik Larsen <mikkel.larsen@zalando.de>

Author: mikkeloscar

pkg/apis/acid.zalan.do/v1/postgresql_type.go

@@ -301,6 +301,7 @@ type UserFlags []string
 // PostgresStatus contains status of the PostgreSQL cluster (running, creation failed etc.)
 type PostgresStatus struct {
 	PostgresClusterStatus string `json:"PostgresClusterStatus"`
+	ObservedGeneration    int64  `json:"observedGeneration,omitempty"`
 }
 
 // ConnectionPooler Options for connection pooler

pkg/cluster/cluster.go

@@ -275,6 +275,7 @@ func (c *Cluster) Create() (err error) {
 		currentStatus := c.Status.DeepCopy()
 		pg := c.Postgresql.DeepCopy()
 		pg.Status.PostgresClusterStatus = acidv1.ClusterStatusRunning
+		pg.Status.ObservedGeneration = pgCreateStatus.Generation
 
 		if err != nil {
 			c.logger.Warningf("cluster created failed: %v", err)
@@ -998,6 +999,7 @@ func (c *Cluster) Update(oldSpec, newSpec *acidv1.Postgresql) error {
 	defer func() {
 		currentStatus := newSpec.Status.DeepCopy()
 		newSpec.Status.PostgresClusterStatus = acidv1.ClusterStatusRunning
+		newSpec.Status.ObservedGeneration = newSpec.Generation
 
 		if updateFailed {
 			newSpec.Status.PostgresClusterStatus = acidv1.ClusterStatusUpdateFailed

pkg/cluster/sync.go

@@ -44,6 +44,9 @@ func (c *Cluster) Sync(newSpec *acidv1.Postgresql) error {
 	c.setSpec(newSpec)
 
 	defer func() {
+		// update observedGeneration to reflect that the latest spec
+		// was processed
+		newSpec.Status.ObservedGeneration = newSpec.Generation
 		if err != nil {
 			c.logger.Warningf("error while syncing cluster state: %v", err)
 			newSpec.Status.PostgresClusterStatus = acidv1.ClusterStatusSyncFailed