kubernetes

Documentation

Index

• func DrainNode(ctx context.Context, clientset kubernetes.Interface, node *corev1.Node) error
• func NewListerWatcher(ctx context.Context, kubeClient client.WithWatch, objectList client.ObjectList, ...) cache.ListerWatcher
• func NewScheme() (*runtime.Scheme, error)
• func NewWatcher(ctx context.Context, kubeClient client.WithWatch, objectList client.ObjectList, ...) cache.Watcher
• func ParseWatchEventObject[T runtime.Object](event watch.Event) (T, error)
• func SelectorMatchesLabels(labelSelector *metav1.LabelSelector, resourceLabels map[string]string) (bool, error)
• func WaitForNodeToBeDeleted(ctx context.Context, clientset kubernetes.Interface, nodeName string) error
• func WaitUntilDeploymentAvailable(ctx context.Context, kubeClient client.WithWatch, ...) error
• func WaitUntilDeploymentUnavailable(ctx context.Context, kubeClient client.WithWatch, ...) error

Functions

func DrainNode

func DrainNode(ctx context.Context, clientset kubernetes.Interface, node *corev1.Node) error

We use the default drain implementation: https://github.com/kubernetes/kubectl/blob/3ec401449e5821ad954942c7ecec9d2c90ecaaa1/pkg/drain/default.go

func NewListerWatcher

func NewListerWatcher(ctx context.Context, kubeClient client.WithWatch, objectList client.ObjectList, opts ...client.ListOption) cache.ListerWatcher

func NewScheme

func NewScheme() (*runtime.Scheme, error)

NewScheme creates a new scheme: https://book.kubebuilder.io/cronjob-tutorial/gvks.html#err-but-whats-that-scheme-thing

func NewWatcher

func NewWatcher(ctx context.Context, kubeClient client.WithWatch, objectList client.ObjectList, opts ...client.ListOption) cache.Watcher

func ParseWatchEventObject

func ParseWatchEventObject[T runtime.Object](event watch.Event) (T, error)

ParseWatchEventObject determines if the specified watch event is an error and if so returns an error and otherwise asserts and returns an object of the expected type

func SelectorMatchesLabels

func SelectorMatchesLabels(labelSelector *metav1.LabelSelector, resourceLabels map[string]string) (bool, error)

func WaitForNodeToBeDeleted

func WaitForNodeToBeDeleted(ctx context.Context, clientset kubernetes.Interface, nodeName string) error

func WaitUntilDeploymentAvailable

func WaitUntilDeploymentAvailable(ctx context.Context, kubeClient client.WithWatch, deploymentNamespace, deploymentName string) error

func WaitUntilDeploymentUnavailable

func WaitUntilDeploymentUnavailable(ctx context.Context, kubeClient client.WithWatch, deploymentNamespace, deploymentName string) error