kube

Documentation

Index

• func DeleteJob(ctx context.Context, client kubernetes.Interface, job *batchv1.Job) error
• func EnsureClusterRequirements(ctx context.Context, kubeFactory kube.Factory, namespace string) error
• func GetPodByJob(ctx context.Context, client kubernetes.Interface, job *batchv1.Job) (*v1.Pod, error)
• func GetPodLogs(ctx context.Context, client kubernetes.Interface, namespace, name string) (string, error)
• func LaunchJob(ctx context.Context, client kubernetes.Interface, opts LaunchJobOptions) (*batchv1.Job, error)
• type LaunchJobOptions

Functions

func DeleteJob

func DeleteJob(ctx context.Context, client kubernetes.Interface, job *batchv1.Job) error

func EnsureClusterRequirements

func EnsureClusterRequirements(ctx context.Context, kubeFactory kube.Factory, namespace string) error

func GetPodByJob

func GetPodByJob(ctx context.Context, client kubernetes.Interface, job *batchv1.Job) (*v1.Pod, error)

func GetPodLogs

func GetPodLogs(ctx context.Context, client kubernetes.Interface, namespace, name string) (string, error)

func LaunchJob

func LaunchJob(ctx context.Context, client kubernetes.Interface, opts LaunchJobOptions) (*batchv1.Job, error)

Types

type LaunchJobOptions

type LaunchJobOptions struct {
	Client        kubernetes.Interface
	Namespace     string
	JobName       *string
	Image         *string
	Env           []v1.EnvVar
	RestartPolicy v1.RestartPolicy
	BackOffLimit  int32
}