make Sync take PGVERSION into account

This commit is contained in:
Sergey Dudoladov 2020-10-14 09:01:12 +02:00
parent baa244668b
commit 16c14b3098
1 changed files with 10 additions and 0 deletions

View File

@ -916,10 +916,20 @@ func (c *Cluster) getNewPgVersion(container v1.Container, newPgVersion string) (
var (
spiloConfiguration spiloConfiguration
runningPgVersion string
version string
err error
)
for _, env := range container.Env {
if env.Name == "PGVERSION" {
err = json.Unmarshal([]byte(env.Value), &version)
if err != nil {
return newPgVersion, err
}
return version, nil
}
if env.Name != "SPILO_CONFIGURATION" {
continue
}