Equals fails the test if `want` and `got` are not equal.

NoError fails the test if `err` is not nil.

withPVC returns a `podModifier` that adds given `pvc` to the Pods volumes.

createPod creates a new Kubernetes Pod in the control plane with given `modifiers`.

schedule simulates `testPod` to be scheduled in given node.

createVolume creates a new pair of unbounded PV and PVC.

bind bounds PV and PVC to each other.

String returns string representation of the argument to pass Mountpoint.

defaultExpectedFields return default test expected fields for MountpointS3PodAttachmentSpec matching

expectNoS3PodAttachmentWithFields verifies that no MountpointS3PodAttachment matching specified fields exists within a time period

ParseArgs parses given list of unnormalized and returns a normalized [Args].

waitAndVerifyS3PodAttachmentAndMountpointPod waits and verifies that MountpointS3PodAttachment and Mountpoint Pod are created for given `node`, `vol`

Get returns pod from watcher's cache.

EXPECT returns an object that allows the caller to indicate expected use.

New creates a new [Provider] with given client.

waitForObjectToDisappear waits until `obj` disappears in the control plane.

OpenDevNull opens `/dev/null` and returns the file handle.

waitForObject waits until `obj` appears in the control plane.

MountpointPod returns a new Mountpoint Pod spec to schedule for given `node`, `pv` and `priorityClassKind`.

waitAndVerifyMountpointPodFromPodAttachment waits and verifies Mountpoint Pod scheduled for given `s3pa`, `pod` and `vol.`

Exit makes Wait() return with the given code and stderr.

waitForS3PodAttachmentWithFields waits until a MountpointS3PodAttachment matching specified node and pv appears in the cluster

List returns all pods from watcher's cache.

Delete deletes the environment variable with the specified key.

PathOnHost returns the full path on the host that refers to `path` inside Mountpoint Pod. This function should be used in the CSI Driver Node Pod whic

Remove removes given key, it returns the key's value and whether the key was found.

SortedList returns ordered list of normalized arguments.

withVolumeAttributes returns a `volumeModifier` that updates volume to have given volume attributes.

Has returns whether given key exists in [Args].

waitForHeadroomPodForWorkload waits and returns the Headroom Pod for the given workload.

findMountpointPodNameForWorkload tries to found Mountpoint Pod name that `workloadUID` is assigned to in given `s3pa`, it returns an empty string if n

verifyHeadroomPodFor verifies given `headroomPood` for given `pod` and `vol`.

contextWithVolumeAttributes enhances given context with given volume attributes. This value is used by `s3Volume.CreateVolume` and `s3Volume.GetPersis

succeed simulates `testPod` to be succeeded running.

withServiceAccount returns a `podModifier` that sets ServiceAccountName.

Set sets or replaces value of given key.

WorkloadHasLabelPodForHeadroomPod returns whether the `workloadPod` is labelled with [LabelHeadroomForWorkload].

withCSIDriver returns a `volumeModifier` that updates volume to use given CSI Driver.

withSchedulingGates returns a `podModifier` that sets given scheduling gates.

GetVersion returns a `VersionInfo`.

Merge adds all key-value pairs from the given environment to the current environment. If a key exists in both environments, the value from the given e

Run runs Mountpoint with given options until completion and returns its exit code and its error (if any).

Shutdown sends SIGTERM to all processes and waits for them to exit.

receiveMountOptions will receive mount options sent to the Mountpoint Pod. This operation will block in place, and ideally should be called from a sep

waitUntilSchedulingUngated waits until all scheduling gates are removed from `testPod` and its ready to be scheduled.

Create creates an AWS Profile with credentials and config files from given credentials. Created credentials and config files can be clean up with [Cle

HeadroomPod returns a new Headroom Pod spec for the given `workloadPod` and `pv`. This Headroom Pod serves as a capacity headroom to allow scheduling

Launch spawns a Mountpoint process for the given mount and waits for it asynchronously. Takes ownership of options.Fd, caller must not close it after

PathInsideMountpointPod returns the full path that refers to `path` inside Mountpoint Pod. This function should be used in the Mountpoint Pod.

Set adds or updates the environment variable with the specified key and value.

isPending checks if a resource is marked as pending based on the given field filters. Returns true if the resource is pending, false otherwise.

SetIfAbsent sets value of given key only if that key does not exist.

Value extracts value of given key, it returns extracted value and whether the key was found.

helpMessageForGettingMountpointLogs returns a help message to troubleshoot Mountpoint failures.

recoverFromDuplicateS3PodAttachments is a defense-in-depth handler for duplicate S3PAs sharing the same field-tuple. Deletes duplicates that reference

setPending marks a resource as pending based on the given field filters. This is typically used when a create operation is initiated.

terminate simulates `testPod` to be terminating.

waitAndVerifyS3PodAttachmentAndMountpointPodWithMinVersionAndExpectedField waits and verifies that MountpointS3PodAttachment with `minVersion` and Mou

CleanRegionEnv ensures that no AWS Region environment variables are set in the test case `t`. The calling process of `go test` may contain environment

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

NewCreator creates a new creator with the given `config`.

ReplaceFile safely replaces a file with a new file by copying to a temporary location first then renaming.

failedToParseQuantityError creates an error if provided quantity is not parsable.

getMPPodLock retrieves or creates a lock for the specified pod name. It increments the reference count for existing locks. The caller is responsible f

In some cases like changing Secret object, it's useful to trigger recreation of our pods.

overrideServiceAccountRole overrides and updates given Service Account's EKS Role ARN annotation. This causes pod's using this Service Account to assu