kube

func GetKubeClient ¶

func GetKubeClient() (kubernetes.Interface, error)

GetKubeClient returns a Kubernetes client

func GetKubeClientWithConfig ¶

func GetKubeClientWithConfig() (kubernetes.Interface, *rest.Config, error)

func GetKubeConfig ¶

func GetKubeConfig() (string, error)

func JobSucceeded ¶

func JobSucceeded(ctx context.Context, k kubernetes.Interface, name, namespace string) (bool, error)

JobSucceeded returns a bool if the given job has/hasn't succeeded. If an error is returned, this is considered unrecoverable.

func StreamJobLogs ¶

func StreamJobLogs(ctx context.Context, k kubernetes.Interface,
	log logrus.FieldLogger, name, namespace string, w io.Writer) error

StreamJobLogs streams pod logs to the provided io.Writer

func StreamPodLogs ¶

func StreamPodLogs(ctx context.Context, k kubernetes.Interface,
	log logrus.FieldLogger, name, namespace string) (io.ReadCloser, error)

StreamPodLogs streams pod logs from a given pod