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

Merge f25415eeb4 into 3cc6a882c8

Browse Source
This commit is contained in:
Jeremy Schneider 2026-07-06 16:15:55 +00:00 committed by GitHub
commit e0e3602672
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 16 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -21,7 +21,6 @@ package common
import ( import (
"context" "context"
"errors"
"fmt" "fmt"
"os" "os"
"path" "path"
@ -331,9 +330,14 @@ func (w WALServiceImplementation) restoreFromBarmanObjectStore(
return nil return nil
} }
// Step 2: return error if the end-of-wal-stream flag is set.
// PostgreSQL treats a restore_command failure as "WAL not available from
// archive" and can then try streaming via primary_conninfo. When prefetch has
// already observed archive exhaustion for this timeline, return one failure to
// let PostgreSQL switch sources instead of repeatedly probing the archive.
// We skip this step if streaming connection is not available // We skip this step if streaming connection is not available
if isStreamingAvailable(cluster, w.InstanceName) { if isStreamingAvailable(cluster, w.InstanceName) {
if err := checkEndOfWALStreamFlag(walRestorer); err != nil { if err := checkEndOfWALStreamFlag(walRestorer, walName); err != nil {
return err return err
} }
} }
@ -366,15 +370,15 @@ func (w WALServiceImplementation) restoreFromBarmanObjectStore(
} }
// We skip this step if streaming connection is not available // We skip this step if streaming connection is not available
endOfWALStream := isEndOfWALStream(walStatus) if isStreamingAvailable(cluster, w.InstanceName) {
if isStreamingAvailable(cluster, w.InstanceName) && endOfWALStream { endOfWALStream, err := walRestorer.SetEndOfWALStreamFromResults(walStatus)
contextLogger.Info(
"Set end-of-wal-stream flag as one of the WAL files to be prefetched was not found")
err = walRestorer.SetEndOfWALStream()
if err != nil { if err != nil {
return err return err
} }
if endOfWALStream {
contextLogger.Info(
"Set end-of-wal-stream flag as one of the WAL files to be prefetched was not found")
}
} }
successfulWalRestore := 0 successfulWalRestore := 0
@ -473,32 +477,14 @@ func gatherWALFilesToRestore(walName string, parallel int) (walList []string, er
return walList, err return walList, err
} }
// checkEndOfWALStreamFlag returns ErrEndOfWALStreamReached if the flag is set in the restorer. // checkEndOfWALStreamFlag returns ErrEndOfWALStreamReached if the flag is set for the requested WAL timeline.
func checkEndOfWALStreamFlag(walRestorer *barmanRestorer.WALRestorer) error { func checkEndOfWALStreamFlag(walRestorer *barmanRestorer.WALRestorer, walName string) error {
contain, err := walRestorer.IsEndOfWALStream() contains, err := walRestorer.ConsumeEndOfWALStreamForWAL(walName)
if err != nil { if err != nil {
return err return err
} }
if contains {
if contain {
err := walRestorer.ResetEndOfWalStream()
if err != nil {
return err
}
return ErrEndOfWALStreamReached return ErrEndOfWALStreamReached
} }
return nil return nil
} }
// isEndOfWALStream returns true if one of the downloads has returned
// a file-not-found error.
func isEndOfWALStream(results []barmanRestorer.Result) bool {
for _, result := range results {
if errors.Is(result.Err, barmanRestorer.ErrWALNotFound) {
return true
}
}
return false
}