Get behaves like the original Get method, but uses a cache for secrets

Error implements the error interface

Create creates the object store resources.

Error implements the error interface

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ObjectStore.

EnsureRole ensures the RBAC Role for the given Cluster matches the desired state derived from the given ObjectStores. On creation, the Cluster is set

CollectSecretNamesFromCredentials collects the names of the secrets

ExecuteInContainer executes a command in a container. If timeout is not nil, the command will be executed with the specified timeout. The function ret

EnsureRoleBinding ensures the RoleBinding for the given Cluster is present and carries the recommended labels. This function is called from the Pre h

GetBarmanObjectKey gets the namespaced name of the barman object

ObjectStoreNamesFromRole extracts the ObjectStore names referenced by a plugin-managed Role. It finds the objectstores rule semantically (by APIGroup

+kubebuilder:rbac:groups=rbac.authorization.k8s.io,resources=rolebindings,verbs=create;patch;update;get;list;watch +kubebuilder:rbac:groups=rbac.autho

BuildRoleRules builds the RBAC PolicyRules for the given ObjectStores. nolint:goconst

GetRecoveryBarmanObjectKey gets the namespaced name of the recovery barman object

ensureVolumeMount makes sure the passed volume mounts are present in the list of volume mounts. If a volume mount is already present, it is updated.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

BuildCertificateFilePath builds the path to the barman objectStore certificate

GetRBACName returns the name of the RBAC entities for the barman cloud plugin

NewMinioObjectStore creates a new Minio object store.

NewMinioObjectStoreResources creates the resources required to create a Minio object store.

SetControllerReference sets an owner reference on controlled pointing to owner, reading the GVK from the owner object's metadata rather than from a sc

AddCNPGToScheme registers CNPG types into the given scheme using the API group configured via CUSTOM_CNPG_GROUP/CUSTOM_CNPG_VERSION environment variab

BuildLabels returns the Kubernetes recommended labels applied to every object managed by this plugin for the given Cluster. See https://github.com/clo

EnsureRoleRules updates the rules of an existing Role to match the desired state derived from the given ObjectStores. Unlike EnsureRole, this function

NewAzuriteObjectStore creates a new ObjectStore object for Azurite.

NewAzuriteObjectStoreResources creates the resources required to create an Azurite object store.

NewFromCluster extracts the configuration from the cluster

NewFromClusterJSON decodes a JSON representation of a cluster.

Patch behaves like the original Patch method, but on secrets it removes the secret from the cache

Delete behaves like the original Delete method, but on secrets it removes the secret from the cache

NewGCSObjectStore creates a new GCS object store.

NewGCSObjectStoreResources creates the resources required to create a GCS object store.

Update behaves like the original Update method, but on secrets it removes the secret from the cache

classifyWALRestoreError maps an error returned by the WAL restorer to a gRPC-coded error so the caller can tell terminal failures apart from transient

ensureVolume makes sure the passed volume is present in the list of volumes. If the volume is already present, it is updated.

ApplyKustomization builds the kustomization and creates the resources.

GetReferredBarmanObjectsKey gets the list of barman objects referred by this plugin configuration

newPatchCountingClient returns a fake client plus a pointer to a counter incremented on every Patch call. Useful for asserting that a "no-op" reconcil

removeObject ensures that a object is not present in the cache

removeVolume removes a volume with a known name from a list of volumes.

AddHealthCheck adds a health check service to the gRPC server with the tag 'plugin-barman-cloud'

BuildRole builds the Role object for this cluster

CheckBackupDestination checks if the backup destination is suitable to archive WALs

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

GenerateScheme creates a runtime.Scheme object with all the definition needed to support the sidecar. This allows the plugin to be used in every CNPG-

GetReplicaSourceBarmanObjectKey gets the namespaced name of the replica source barman object

GetRestoreCABundleEnv gets the enveronment variables to be used when custom Object Store CA is present

IsReady checks if the deployment is ready.

MergeEnv merges all the values inside incomingEnv into env.

Name gets the name of the segment.

Run runs the E2E tests on a Kubernetes cluster. It returns the output of the tests. We expect a kubeconfig file that allows access to the cluster, and

SegmentFromName retrieves the timeline, log ID and segment ID from the name of a xlog segment, and can also handle a full path or a simple file name.

Start starts the GRPC service

Status implements the WALService interface

WaitForDeploymentReady waits for the deployment to be ready. ctx should have a timeout set.

WalSegmentsPerFile is the number of WAL Segments in a WAL File.

containsSubject reports whether subjects contains an element that is semantically equal to subject.

isStreamingAvailable checks if this pod can replicate via streaming connection.

labelsNeedUpdate returns true if a Patch is required to bring existing labels into the state mergeLabels would produce, i.e. any desired key is missin

mergeLabels writes the desired labels onto existing per-key. Keys in desired overwrite the existing value; keys not in desired (any unrelated label a

patchRole patches the Role's rules and optionally its labels to match the desired state. When desiredLabels is nil, labels are not modified. Uses retr

updateRecoveryWindow updates the recovery window inside the object store status subresource

BuildRoleBinding builds the role binding object for this cluster

Check is the response handle for the healthcheck request

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ObjectStoreList.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

GetCapabilities exposes the lifecycle capabilities nolint:goconst