utils

Documentation

Index

• Constants
• func ApplyResource(ctx context.Context, clientSet *kubernetes.Clientset, recorder events.Recorder, ...) (client.Object, bool, error)
• func ApplyResources(ctx context.Context, clientSet *kubernetes.Clientset, recorder events.Recorder, ...) error
• func DeleteResource(ctx context.Context, namespacedTypedClient DeleterInterface, objName string) error
• func DeleteResources(ctx context.Context, toDeleteRefs []ToDeleteRef) error
• func ExtractAuthFromSecret(secret *v1.Secret) ([]byte, error)
• func Image() string
• func Namespace() string
• func NewPtr[T any](a T) *T
• type DeleterInterface
• type ToDeleteRef

Constants

const (
	ControllerNameKey = "controller"
	OperandLabelKey   = "multiarch.openshift.io/operand"
	OperatorName      = "multiarch-tuning-operator"
)

const (
	ArchitectureAmd64   = "amd64"
	ArchitectureArm64   = "arm64"
	ArchitecturePpc64le = "ppc64le"
	ArchitectureS390x   = "s390x"
)

const (
	ArchLabel                       = "kubernetes.io/arch"
	NodeAffinityLabel               = "multiarch.openshift.io/node-affinity"
	NodeAffinityLabelValueSet       = "set"
	NodeAffinityLabelValueNotSet    = "not-set"
	HostnameLabel                   = "kubernetes.io/hostname"
	SchedulingGateLabel             = "multiarch.openshift.io/scheduling-gate"
	SchedulingGateLabelValueGated   = "gated"
	SchedulingGateLabelValueRemoved = "removed"
)

Functions

func ApplyResource

func ApplyResource(ctx context.Context, clientSet *kubernetes.Clientset, recorder events.Recorder,
	obj client.Object) (client.Object, bool, error)

ApplyResource applies the given object to the cluster. It returns the object as it is in the cluster, a boolean indicating if the object was created or updated and an error if any. TODO[integration-tests]: integration tests for this function in a suite dedicated to this package

func ApplyResources

func ApplyResources(ctx context.Context, clientSet *kubernetes.Clientset, recorder events.Recorder,
	objs []client.Object) error

ApplyResources applies the given objects to the cluster. It returns an error if any. TODO[integration-tests]: integration tests for this function in a suite dedicated to this package

func DeleteResource

func DeleteResource(ctx context.Context, namespacedTypedClient DeleterInterface, objName string) error

DeleteResource deletes the given object from the cluster. It returns an error if any. TODO[integration-tests]: integration tests for this function in a suite dedicated to this package

func DeleteResources

func DeleteResources(ctx context.Context, toDeleteRefs []ToDeleteRef) error

DeleteResources deletes the given objects from the cluster. It returns an error if any. TODO[integration-tests]: integration tests for this function in a suite dedicated to this package

func ExtractAuthFromSecret

func ExtractAuthFromSecret(secret *v1.Secret) ([]byte, error)

func Image

func Image() string

Image returns the image used to run the operator.

func Namespace

func Namespace() string

Namespace returns the namespace where the operator's pods are running.

func NewPtr

func NewPtr[T any](a T) *T

Types

type DeleterInterface

type DeleterInterface interface {
	Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
}

DeleterInterface abstracts the Delete method of a typed and namespaced client got from a clientset

type ToDeleteRef

type ToDeleteRef struct {
	NamespacedTypedClient DeleterInterface
	ObjName               string
}