TODO: move to machinery once the logic is finalized InjectPluginVolumePodSpec injects the plugin volume into a CNPG Pod spec.

Install installs cert-manager using kubectl.

Install installs CloudNativePG using kubectl.

IsWALFile check if the passed file name is a regular WAL file. It supports either a full file path or a simple file name.

LifecycleHook is called when creating Kubernetes services

NewCmd creates the "restore" subcommand

NewCmd returns the healthcheck command

NewCmd creates a new operator command

NewCmd creates a new instance command

NewConfigurationError creates a new empty configuration error

NewExtendedClient returns an extended client capable of caching secrets on the 'Get' operation

NewPlugin creates a new Plugin instance for the given cluster and plugin name.

NextSegments generate the list of all possible segment names starting from `segment`, until the specified size is reached. This function will not ever

Post implements the reconciler interface

Restore restores the cluster from a backup

Setup sets up the test environment for the e2e tests, starting kind and installing the necessary components. nolint:ireturn

SetupWithManager sets up the controller with the Manager.

Start starts the sidecar informers and CNPG-i server

Start starts the manager

Start starts the sidecar informers and CNPG-i server

Start starts the GRPC server of the operator plugin

Start starts the GRPC service

Validate checks if the barmanObjectName is set

WithIgnoreExistingResources sets whether to ignore existing resources.

WithIgnoreExistingResources sets whether to ignore existing resources.

WithImageName sets the name for the CloudNativePG image.

WithImageTag sets the tag for the CloudNativePG image.

WithKustomizationRef sets the ref for the CloudNativePG kustomization.

WithKustomizationResourceURL sets the URL for the CloudNativePG kustomization.

WithKustomizationTimeout sets the timeout for the kustomization resources.

WithMessage adds a new error message to a potentially empty ConfigurationError

WithVersion sets the version of cert-manager to install.

checkEndOfWALStreamFlag returns ErrEndOfWALStreamReached if the flag is set in the restorer.

cycle enforces the retention policies. On success, it returns the amount of time to wait to the next check.

deleteBackupsNotInCatalog deletes all Backup objects pointing to the given cluster that are not present in the backup anymore

ensureRoleExists creates the Role if it does not exist. Returns nil on success and nil on AlreadyExists (another writer created it concurrently). The

gatherWALFilesToRestore files a list of possible WAL files to restore, always including as the first one the requested WAL file.

getCNPGJobRole gets the role associated to a CNPG job

getOrCreateRoleBinding returns the existing RoleBinding when it is already present on the API server, or nil after a successful Create when the just-c

getRecoverySourcePlugin returns the configuration of the plugin being the recovery source of the cluster. If no such plugin have been configured, nil

getRecoverySourcePlugin returns the configuration of the plugin being the recovery source of the cluster. If no such plugin have been configured, nil

getRestoreWalConfig obtains the content to append to `custom.conf` allowing PostgreSQL to complete the WAL recovery from the object storage and then s

injectPluginSidecarPodSpec injects a plugin sidecar into a CNPG Pod spec.

isEndOfWALStream returns true if one of the downloads has returned a file-not-found error.

loadBackupObjectFromExternalCluster generates an in-memory Backup structure given a reference to an external cluster, loading the required information

maintenance executes a collection of operations: - applies the retention policy to the object. - store and deletes the stale Kubernetes backup objec

mergeSubjects appends desired Subjects that are not already present in existing. This is intentionally asymmetric to mergeLabels: labels are metadata

newInternalWALRestoreError reports that downloading the WAL file failed for an unclassified reason. Emits codes.Internal: we have no positive signal t

newInvalidWALNameError reports that the requested WAL name is not a valid name. Emits codes.InvalidArgument: this is a terminal condition (the same na

newUnavailableError reports that downloading the WAL file failed for a reason expected to be transient (a barman-cloud connectivity blip, or a generic

newWALNotFoundError reports that the requested WAL file is not present in the object store. Emits codes.NotFound: this is a terminal condition (the fi

reconcileRoleBinding brings an existing RoleBinding's labels and Subjects into alignment with desired. It re-Gets the object on conflict-retry so each

reconcileRoleRules fetches the ObjectStores referenced by the Role and patches its rules to match the current specs.

restoreCustomWalDir moves the current pg_wal data to the specified custom wal dir and applies the symlink returns indicating if any changes were made

restoreDataDir restores PGDATA from an existing backup

roleBindingNeedsUpdate returns true if a Patch is required to bring existing into alignment with desired — any desired Subject missing (see mergeSubje