kube

Documentation

Index

• func CheckNamespaceExists(ctx context.Context, namespace string, kubeFactory kube.Factory) (bool, error)
• func EnsureClusterRequirements(ctx context.Context, opts ClusterRequirementsOptions) 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 ClusterRequirementsOptions
• type LaunchJobOptions

Functions

func CheckNamespaceExists

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

func EnsureClusterRequirements

func EnsureClusterRequirements(ctx context.Context, opts ClusterRequirementsOptions) 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 ClusterRequirementsOptions

type ClusterRequirementsOptions struct {
	KubeFactory        kube.Factory
	Namespace          string
	ContextUrl         string
	AccessMode         platmodel.AccessMode
	TunnelRegisterHost string
	IsCustomInstall    bool
}

type LaunchJobOptions

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