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

update log messages

This commit is contained in:
Felix Kunde 2021-08-10 11:56:15 +02:00
parent eb7050571d
commit 14e989ac83
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/cluster/streams.go
View File

@ -236,7 +236,7 @@ func (c *Cluster) syncStreams() error {
err := c.syncPostgresConfig()
if err != nil {
return fmt.Errorf("logical decoding setup incomplete: %v", err)
return fmt.Errorf("could not update Postgres config for event streaming: %v", err)
}
effectiveStreams, err := c.KubeClient.FabricEventStreamsGetter.FabricEventStreams(c.Namespace).Get(context.TODO(), c.Name+constants.FESsuffix, metav1.GetOptions{})
@ -253,7 +253,7 @@ func (c *Cluster) syncStreams() error {
} else {
err := c.syncStreamDbResources()
if err != nil {
return fmt.Warnf("database setup incomplete: %v", err)
c.logger.Warnf("database setup might be incomplete : %v", err)
}
desiredStreams := c.generateFabricEventStream()
if reflect.DeepEqual(effectiveStreams.Spec, desiredStreams.Spec) {