util

package
v3.0.0-...-d6c4d9c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 14, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BackupResources

func BackupResources(ctx context.Context, kubeClient ctrlruntimeclient.Client, gvk schema.GroupVersionKind, filename string) error

BackupResources takes a GroupVersionKind and dumps all resources of that type (across all namespaces) as YAML into the given filename (the file will be truncated first).

func CheckHelmRelease

func CheckHelmRelease(ctx context.Context, log logrus.FieldLogger, helmClient helm.Client, namespace string, releaseName string) (*helm.Release, error)

CheckHelmRelease tries to find an existing Helm release in the cluster and returns it. If the release is still in a pending state, the function will wait a bit for it to settle down. If the release status is failed for whatever reason, the release is purged to allow clean re-installs.

func DeployCRD

func DeployCRD(ctx context.Context, kubeClient ctrlruntimeclient.Client, crd ctrlruntimeclient.Object) error

func DeployCRDs

func DeployCRDs(ctx context.Context, kubeClient ctrlruntimeclient.Client, log logrus.FieldLogger, directory string, versions *kubermaticversion.Versions, kind crd.ClusterKind) error

func DeployHelmChart

func DeployHelmChart(
	ctx context.Context,
	log logrus.FieldLogger,
	helmClient helm.Client,
	chart *helm.Chart,
	namespace string,
	releaseName string,
	values *yamled.Document,
	atomic bool,
	force bool,
	skipDeps bool,
	release *helm.Release,
) error

func DumpResources

func DumpResources(ctx context.Context, filename string, objects []unstructured.Unstructured) error

func EnsureNamespace

func EnsureNamespace(ctx context.Context, log logrus.FieldLogger, kubeClient ctrlruntimeclient.Client, namespace string) error

func HasAllReadyCRDs

func HasAllReadyCRDs(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdNames []string) (bool, error)

func HasReadyCRD

func HasReadyCRD(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdName string) (bool, error)

func RemoveMutatingWebhook

func RemoveMutatingWebhook(ctx context.Context, logger logrus.FieldLogger, client ctrlruntimeclient.Client, webhookName string) error

func RemoveValidatingWebhook

func RemoveValidatingWebhook(ctx context.Context, logger logrus.FieldLogger, client ctrlruntimeclient.Client, webhookName string) error

func ShutdownDeployment

func ShutdownDeployment(ctx context.Context, logger logrus.FieldLogger, client ctrlruntimeclient.Client, namespace string, name string) error

ShutdownDeployment takes the name and namespace of a deployment and will scale that Deployment to 0 replicas.

func WaitForAllPodsToBeGone

func WaitForAllPodsToBeGone(ctx context.Context, logger logrus.FieldLogger, client ctrlruntimeclient.Client, namespace string, name string, timeout time.Duration) error

WaitForAllPodsToBeGone takes the name of a Deployment and will wait until all Pods for that Deployment have been shut down.

func WaitForCRDGone

func WaitForCRDGone(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdName string, timeout time.Duration) error

func WaitForReadyCRD

func WaitForReadyCRD(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdName string, timeout time.Duration) error

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL