kube

Documentation

Index

• func CheckNamespaceExists(ctx context.Context, namespace string, kubeFactory kube.Factory) (bool, error)
• func EnsureClusterRequirements(ctx context.Context, kubeFactory kube.Factory, namespace string, ...) error
• func GetClusterSecret(ctx context.Context, kubeFactory kube.Factory, namespace string, name string) (*v1.Secret, error)
• func WaitForJob(ctx context.Context, f kube.Factory, ns, jobName string) error
• type LaunchJobOptions

Functions

func CheckNamespaceExists

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

func EnsureClusterRequirements

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

func GetClusterSecret

func GetClusterSecret(ctx context.Context, kubeFactory kube.Factory, namespace string, name string) (*v1.Secret, error)

func WaitForJob

func WaitForJob(ctx context.Context, f kube.Factory, ns, jobName string) error

Types

type LaunchJobOptions

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