Ensures that all labels in the provided map are present and returns True if an update was made.

Ensures that a given key/value label is present and returns True if an update was made.

Determine the proper affinity to apply based on the current users of a PVC.

Will append the MoverDebug Env var if the volsyncv1alpha1.EnableDebugMoverAnnotation annotation is set on the corresponding ReplicationSource or Destination.

Append k/v from the secret if they start with RCLONE_.

CleanupObjects deletes all objects that have been marked.

If an update causes an immutable error, delete the object and return an error (or potentially an error from the delete if the delete fails).

Appies lineFilter to each line.

Attempts to get the newest successful pod when jobFailed==false Attempts to get the newest failed pod (or newest running pod if no failed pods) if jobFailed==true.

GetServiceAddress Returns the address of the given service as a string.

Check if error is due to the CRD not being present (API kind/group not available) This has changed recently in controller-runtime v0.15.0, see: https://github.com/kubernetes-sigs/controller-runtime/pull/2116.

Returns True if the object contains a label indicating that it was created by VolSync.

MarkForCleanup marks the provided "obj" to be deleted at the end of the synchronization iteration.

reconcileBatch steps through a list of reconcile functions until one returns false or an error.

Removes the given key from the object's labels and returns True if an update was made.

Removes the "created by Volsync" label.

Returns true if the pvc was updated.

Returns true if the pvc was updated.

Returns true if the pvc was updated.

Returns true if the pvc was updated.

Returns true if the pvc was updated.

Sets a label on the object to indicate it was created by VolSync.

UnmarkForCleanup removes any previously applied cleanup label.

Updates mover status to failed and puts the errMessage as the logs.

Updates to set the securityContext, podLabels on mover pod in the spec and resourceRequirements on the mover containers based on what is set in the MoverConfig.

#nosec G101 - gosec thinks this is a credential.

Define the error messages to be returned by VolSync.

Env var - Set to "true" to log all lines (up to MOVER_LOG_MAX_LINES) of mover logs.

Env var - max bytes we will log into the status log.

Env var - max lines we will tail from a mover pod to process logs Set to -1 to tail all lines since the mover pod start.

SCCName is the name of the SCC to use for the mover Jobs.

CustomCAObject will generate the appropriate volumesource for attaching to a podspec from a source customca secret or configmap.

reconcileFunc is a function that partially reconciles an object.