k8s_utils

Documentation

Index

• func GetPodLog(ctx context.Context, config *rest.Config, pod *corev1.Pod, ...) (string, error)
• 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 RestartDaemonSet(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 GetPodLog

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

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 RestartDaemonSet

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

RestartDaemonSet 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