utils

func CleanupAndWait ¶

func CleanupAndWait(ctx context.Context, c client.Client, objs ...client.Object) error

CleanupAndWait deletes an object and waits for it to be removed before exiting.

func CleanupWithFinalizerRemovalAndWait ¶

func CleanupWithFinalizerRemovalAndWait(ctx context.Context, c client.Client, resources ...client.Object) error

CleanupWithFinalizerRemovalAndWait removes finalizers from resources then deletes them. After deletion, it waits for them to be removed Note: this should be used when such a "force" deletion is ok and leads to no side-effects. e.g. no controllers need to take action as a result of a resource removal.

func CleanupWithLabelAndWait ¶

func CleanupWithLabelAndWait(ctx context.Context, c client.Client, labelSelector labels.Selector, resources ...client.ObjectList) error

CleanupWithLabelAndWait collects all resources matching the label selector and delegates to CleanupAndWait for parallel deletion

func CreateMTLSCerts ¶

func CreateMTLSCerts(dmsIP string) (caCrtBytes, clientCrtBytes, clientKeyBytes, srvCrtBytes, srvKeyBytes []byte)

CreateMTLSCerts creates mTLS certificates for testing purposes. Returns CA certificate, client certificate, client key, server certificate, and server key as PEM-encoded bytes.

func CreateResourceIfNotExist ¶

func CreateResourceIfNotExist(ctx context.Context, c client.Client, obj client.Object) error

CreateResourceIfNotExist creates a resource if it doesn't exist

func ForceObjectReconcileWithAnnotation ¶

func ForceObjectReconcileWithAnnotation(ctx context.Context, c client.Client, obj client.Object) error

ForceObjectReconcileWithAnnotation adds patches the passed object with an annotation to force it to be reconciled.

func GenerateDPUObj ¶

func GenerateDPUObj[T client.Object](name, ns string, obj T, customLabels ...map[string]string) T

GenerateDPUObj sets the name, namespace, and labels on a given client.Object. Default is It scope cleanup labels; if customLabels provided, they replace the default.

func GetFakeKamajiClusterSecretFromEnvtest ¶

func GetFakeKamajiClusterSecretFromEnvtest(cluster provisioningv1.DPUCluster, cfg *rest.Config) (*corev1.Secret, error)

GetFakeKamajiClusterSecretFromEnvtest creates a kamaji secret using the envtest information to simulate that we have a kamaji cluster. In reality, this is the same envtest Kubernetes API.

func GetTestDPUCluster ¶

func GetTestDPUCluster(ns, name string) provisioningv1.DPUCluster

func GetTestLabels ¶

func GetTestLabels() map[string]string

func PatchStatus ¶

func PatchStatus(ctx context.Context, c client.Client, obj client.Object, mutate func())

PatchStatus re-fetches obj, calls mutate() to modify status fields, then patches the status subresource using a merge patch. Retries on conflict to avoid "object has been modified" errors from concurrent controller reconciliations.

func ResolveBFBImageURL ¶

func ResolveBFBImageURL(bfbURL string) (string, error)

ResolveBFBImageURL resolves a BFB image URL to a real file path. On our test environment, we can access NFS files via HTTP. To be able to test the latest BFB image, we need to resolve the URL to a real file path.

func ResolveHBNImageURL ¶

func ResolveHBNImageURL(hbnURL string) (string, error)

ResolveHBNImageURL processes the HBN image URL and returns it if valid.