cluster

Documentation

Index

• Constants
• func CleanJob(client crclient.Client, name string, namespace string) error
• func DeletePod(client crclient.Client, namespace, name string) error
• func GetOperatorNamespace() (string, error)
• func GetPodsBySelector(client crclient.Client, namespace string, selector string) (*corev1.PodList, error)
• func GetWatchNamespace() (string, error)
• func IsOpenShift() (bool, error)
• func IsWebhookConfigurationEnabled() (bool, error)
• func SyncJobToCluster(client crclient.Client, ctx context.Context, specJob *batchv1.Job) error
• func WaitForJobCompletion(client crclient.Client, name string, namespace string, timeout time.Duration) error

Constants

const (
	WatchNamespaceEnvVar = "WATCH_NAMESPACE"
)

Functions

func CleanJob

func CleanJob(client crclient.Client, name string, namespace string) error

CleanJob cleans up a job in a given namespace. If a job didn't exist then it will throw isNotFound error

func DeletePod

func DeletePod(client crclient.Client, namespace, name string) error

DeletePod removes all pods which match the specified selector

func GetOperatorNamespace

func GetOperatorNamespace() (string, error)

GetOperatorNamespace returns the namespace the operator should be running in.

This function was ported over from Operator SDK 0.17.0 and modified.

func GetPodsBySelector

func GetPodsBySelector(client crclient.Client, namespace string, selector string) (*corev1.PodList, error)

GetPodsBySelector selects all pods by a selector in a namespace

func GetWatchNamespace

func GetWatchNamespace() (string, error)

GetWatchNamespace returns the namespace the operator should be watching for changes

This function was ported over from Operator SDK 0.17.0

func IsOpenShift

func IsOpenShift() (bool, error)

func IsWebhookConfigurationEnabled

func IsWebhookConfigurationEnabled() (bool, error)

IsWebhookConfigurationEnabled returns true if both of mutating and validating webhook configurations are enabled

func SyncJobToCluster

func SyncJobToCluster(
	client crclient.Client,
	ctx context.Context,
	specJob *batchv1.Job,
) error

func WaitForJobCompletion

func WaitForJobCompletion(client crclient.Client, name string, namespace string, timeout time.Duration) error

Wait for the job to complete. Times out if the job isn't complete after $(timeout) seconds