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

minor updates to log messages

This commit is contained in:
Felix Kunde 2021-07-30 15:58:02 +02:00
parent f5067e302c
commit d1edb11041
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/cluster/sync.go
View File

@ -411,7 +411,7 @@ func (c *Cluster) syncStatefulSet() error {
// if the config update requires a restart, call Patroni restart for replicas first, then master // if the config update requires a restart, call Patroni restart for replicas first, then master
if instanceRestartRequired { if instanceRestartRequired {
c.logger.Info("restarting Postgres server within pods") c.logger.Debug("restarting Postgres server within pods")
ttl, ok := postgresConfig["ttl"].(int32) ttl, ok := postgresConfig["ttl"].(int32)
if !ok { if !ok {
ttl = 30 ttl = 30
@ -456,7 +456,7 @@ func (c *Cluster) restartInstance(pod *v1.Pod, ttl int32) {
time.Sleep(time.Duration(ttl) * time.Second) time.Sleep(time.Duration(ttl) * time.Second)
c.logger.Debugf("Postgres server successfuly restarted in %s pod %s", role, podName) c.logger.Debugf("Postgres server successfuly restarted in %s pod %s", role, podName)
c.eventRecorder.Event(c.GetReference(), v1.EventTypeNormal, "Update", fmt.Sprintf("Postgres server restart done for pod %s pod %s", role, pod.Name)) c.eventRecorder.Event(c.GetReference(), v1.EventTypeNormal, "Update", fmt.Sprintf("Postgres server restart done for %s pod %s", role, pod.Name))
} }
// AnnotationsToPropagate get the annotations to update if required // AnnotationsToPropagate get the annotations to update if required
@ -556,7 +556,7 @@ func (c *Cluster) checkAndSetGlobalPostgreSQLConfiguration(pod *v1.Pod, patroniC
// try all pods until the first one that is successful, as it doesn't matter which pod // try all pods until the first one that is successful, as it doesn't matter which pod
// carries the request to change configuration through // carries the request to change configuration through
podName := util.NameFromMeta(pod.ObjectMeta) podName := util.NameFromMeta(pod.ObjectMeta)
c.logger.Debugf("calling Patroni API on a pod %s to set the following Postgres options: %s", c.logger.Debugf("patching Postgres config via Patroni API on pod %s with following options: %s",
podName, configToSetJson) podName, configToSetJson)
if err = c.patroni.SetConfig(pod, configToSet); err != nil { if err = c.patroni.SetConfig(pod, configToSet); err != nil {
return true, fmt.Errorf("could not patch postgres parameters with a pod %s: %v", podName, err) return true, fmt.Errorf("could not patch postgres parameters with a pod %s: %v", podName, err)