util

Documentation

Index

• func BackupResources(ctx context.Context, kubeClient ctrlruntimeclient.Client, ...) error
• func CheckHelmRelease(ctx context.Context, log logrus.FieldLogger, helmClient helm.Client, ...) (*helm.Release, error)
• func DeployCRD(ctx context.Context, kubeClient ctrlruntimeclient.Client, ...) error
• func DeployCRDs(ctx context.Context, kubeClient ctrlruntimeclient.Client, ...) error
• func DeployHelmChart(ctx context.Context, log logrus.FieldLogger, helmClient helm.Client, ...) error
• func DumpResources(ctx context.Context, filename string, objects []unstructured.Unstructured) error
• func EnsureNamespace(ctx context.Context, log logrus.FieldLogger, ...) error
• func HasAllReadyCRDs(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdNames []string) (bool, error)
• func HasReadyCRD(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdName string) (bool, error)
• func ListResources(ctx context.Context, kubeClient ctrlruntimeclient.Client, ...) ([]unstructured.Unstructured, error)
• func WaitForCRDGone(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdName string, ...) error
• func WaitForReadyCRD(ctx context.Context, kubeClient ctrlruntimeclient.Client, crdName string, ...) error

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) 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, 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 ListResources

func ListResources(ctx context.Context, kubeClient ctrlruntimeclient.Client, gvk schema.GroupVersionKind) ([]unstructured.Unstructured, error)

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