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 ParseK8sObjects(y string) ([]runtime.Object, error)

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

func IsJobCompleted

func IsJobCompleted(job *batchv1.Job) bool

func IsPodCompleted

func IsPodCompleted(pod *corev1.Pod) bool

func ParseK8sObjects

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