k8s_utils

Documentation

Index

• func Create(ctx context.Context, cli client.Client, objects []runtime.Object, ...) error
• func Delete(ctx context.Context, cli client.Client, objects []runtime.Object, ...) error
• func GetPodLog(ctx context.Context, config *rest.Config, pod *corev1.Pod, ...) (string, error)
• func IsJobCompleted(job *batchv1.Job) bool
• func IsPodCompleted(pod *corev1.Pod) bool
• func IsPodRunning(pod *corev1.Pod) bool
• func ParseK8sObjects(y string) ([]runtime.Object, error)
• func PopNamespaceFromObjectList(objects []runtime.Object) (nsObject runtime.Object, otherObjects []runtime.Object)
• func RestartDeamonSet(ctx context.Context, cli client.Client, dsUpdate *appsv1.DaemonSet) error
• type KubeQuerySecretsMethod
  • func QuerySecrets(cli client.Client, opts ...client.ListOption) KubeQuerySecretsMethod
  • func QuerySecretsInNamespace(cli client.Client, namespace string) KubeQuerySecretsMethod

Functions

func Create

func Create(ctx context.Context, cli client.Client, objects []runtime.Object, logger logr.Logger) error

func Delete

func Delete(ctx context.Context, cli client.Client, objects []runtime.Object, logger logr.Logger) error

func GetPodLog

func GetPodLog(ctx context.Context, config *rest.Config, pod *corev1.Pod, containerName string) (string, error)

func IsJobCompleted

func IsJobCompleted(job *batchv1.Job) bool

func IsPodCompleted

func IsPodCompleted(pod *corev1.Pod) bool

func IsPodRunning

func IsPodRunning(pod *corev1.Pod) bool

func ParseK8sObjects

func ParseK8sObjects(y string) ([]runtime.Object, error)

func PopNamespaceFromObjectList

func PopNamespaceFromObjectList(objects []runtime.Object) (nsObject runtime.Object, otherObjects []runtime.Object)

func RestartDeamonSet

func RestartDeamonSet(ctx context.Context, cli client.Client, dsUpdate *appsv1.DaemonSet) error

RestartDeamonSet restarts all pods that belong to the daemonset

Types

type KubeQuerySecretsMethod

type KubeQuerySecretsMethod func(ctx context.Context) (*corev1.SecretList, error)

func QuerySecrets

func QuerySecrets(cli client.Client, opts ...client.ListOption) KubeQuerySecretsMethod

func QuerySecretsInNamespace

func QuerySecretsInNamespace(cli client.Client, namespace string) KubeQuerySecretsMethod