k8s_utils

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) (string, error)

func IsJobCompleted ¶

func IsJobCompleted(job *batchv1.Job) bool

func IsPodCompleted ¶

func IsPodCompleted(pod *corev1.Pod) bool

func IsPodRunning ¶ added in v0.4.0

func IsPodRunning(pod *corev1.Pod) bool

func ParseK8sObjects ¶

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

func RestartDeamonSet ¶ added in v0.4.0

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

RestartDeamonSet restarts all pods that belong to the daemonset