marco/plugin-barman-cloud
1
0
Fork 0
mirror of https://github.com/cloudnative-pg/plugin-barman-cloud.git synced 2026-07-08 10:42:21 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge 056426a018 into f4326b50c4

Browse Source
This commit is contained in:
Leonardo Cecchi 2026-06-17 12:25:07 +02:00 committed by GitHub
commit 42af2ce678
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 6 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
internal/cnpgi/common/wal.go
View File

@ -242,20 +242,13 @@ func (w WALServiceImplementation) Restore(
var serverName string var serverName string
var objectStoreKey types.NamespacedName var objectStoreKey types.NamespacedName
var promotionToken string
if configuration.Cluster.Spec.ReplicaCluster != nil {
promotionToken = configuration.Cluster.Spec.ReplicaCluster.PromotionToken
}
switch { switch {
case promotionToken != "" && configuration.Cluster.Status.LastPromotionToken != promotionToken: case configuration.Cluster.Status.CurrentPrimary == w.InstanceName &&
// This is a replica cluster that is being promoted to a primary cluster len(configuration.ReplicaSourceBarmanObjectName) > 0:
// Recover from the replica source object store // restore_command is only called while PostgreSQL is in recovery, so if this
serverName = configuration.ReplicaSourceServerName // instance is the current primary with a replica source configured, it must be
objectStoreKey = configuration.GetReplicaSourceBarmanObjectKey() // a designated primary that hasn't completed promotion yet. This covers both
// switchover (promotion token) and failover (no promotion token) cases.
case configuration.Cluster.IsReplica() && configuration.Cluster.Status.CurrentPrimary == w.InstanceName:
// Designated primary on replica cluster, using replica source object store
serverName = configuration.ReplicaSourceServerName serverName = configuration.ReplicaSourceServerName
objectStoreKey = configuration.GetReplicaSourceBarmanObjectKey() objectStoreKey = configuration.GetReplicaSourceBarmanObjectKey()