Function ensureWalArchiveIsWorking

pkg/management/postgres/wal.go:43–55

ensureWalArchiveIsWorking behaves slightly differently when executed on primary or a standby. On primary, it could run even before the first WAL has completed. For this reason it could require a WAL switch, to quicken the check. On standby, the mere existence of the standby guarantees that a WAL fil

(instance *Instance)

// by the pg_basebackup used to prime the standby data directory, so we check only if the WAL
// archive process is not failing.
func ensureWalArchiveIsWorking(instance *Instance) error {
	isPrimary, err := instance.IsPrimary()
	if err != nil {
		return err
	}

	if isPrimary {
		return newWalArchiveBootstrapperForPrimary().ensureFirstWalArchived(instance, retryUntilWalArchiveWorking)
	}

	return newWalArchiveAnalyzerForReplicaInstance(instance.GetPrimaryConnInfo()).
		mustHaveFirstWalArchivedWithBackoff(retryUntilWalArchiveWorking)
}

// walArchiveAnalyzer represents an object that can check for the status of
// WAL archiving, in primary or replicas