clientutil

Documentation

Index

• Constants
• func AddLabels(labels map[string]string, objects ...runtime.Object) []runtime.Object
• func CRDsReadyCondition(ctx context.Context, client dynclient.Client, names []string) wait.ConditionFunc
• func CreateOrReplace(ctx context.Context, c client.Client, obj client.Object, updaters ...Updater) error
• func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object, updaters ...Updater) error
• func DeleteIfExists(ctx context.Context, c client.Client, obj client.Object) error
• func LabelComponent(component string, objects ...runtime.Object) []runtime.Object
• func PodsReadyCondition(ctx context.Context, c dynclient.Client, listOpts dynclient.ListOptions) wait.ConditionFunc
• type Updater
  • func WithComponentLabel(componentname string) Updater

Constants

const (
	KubeoneComponentLabel = "kubeone.io/component"
)

Functions

func AddLabels

func AddLabels(labels map[string]string, objects ...runtime.Object) []runtime.Object

func CRDsReadyCondition

func CRDsReadyCondition(ctx context.Context, client dynclient.Client, names []string) wait.ConditionFunc

CRDsReadyCondition generate a k8s.io/apimachinery/pkg/util/wait.ConditionFunc function to be used in k8s.io/apimachinery/pkg/util/wait.Poll* family of functions. It will check all provided GKs (GroupKinds) to exists and have Established status

func CreateOrReplace

func CreateOrReplace(ctx context.Context, c client.Client, obj client.Object, updaters ...Updater) error

CreateOrReplace makes it easy to "replace" objects

func CreateOrUpdate

func CreateOrUpdate(ctx context.Context, c client.Client, obj client.Object, updaters ...Updater) error

CreateOrUpdate makes it easy to "apply" objects to kubernetes API server

func DeleteIfExists

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

DeleteIfExists makes it easy to "delete" Kubernetes objects if they exist

func LabelComponent

func LabelComponent(component string, objects ...runtime.Object) []runtime.Object

func PodsReadyCondition

func PodsReadyCondition(ctx context.Context, c dynclient.Client, listOpts dynclient.ListOptions) wait.ConditionFunc

PodsReadyCondition generate a k8s.io/apimachinery/pkg/util/wait.ConditionFunc function to be used in k8s.io/apimachinery/pkg/util/wait.Poll* family of functions. It will check all selected pods to have PodReady condition and phase PodRunning.

Types

type Updater

type Updater func(client.Client, client.Object)

func WithComponentLabel

func WithComponentLabel(componentname string) Updater