kube

Documentation

Index

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

Functions

func CheckNamespaceExists

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

func EnsureClusterRequirements

func EnsureClusterRequirements(ctx context.Context, runtimeInstallOptions RuntimeInstallOptions) 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
	ContainerName string
	GenerateName  string
	Image         string
	Env           []v1.EnvVar
	RestartPolicy v1.RestartPolicy
	BackOffLimit  int32
}

type RuntimeInstallOptions

type RuntimeInstallOptions struct {
	KubeFactory        kube.Factory
	Namespace          string
	ContextUrl         string
	AccessMode         platmodel.AccessMode
	TunnelRegisterHost string
}