kube

Documentation

Index

• func CheckNamespaceExists(ctx context.Context, namespace string, kubeFactory apkube.Factory) (bool, error)
• func DeleteSecretWithFinalizer(ctx context.Context, kubeFactory apkube.Factory, secret *v1.Secret) error
• func EnsureClusterRequirements(ctx context.Context, opts ClusterRequirementsOptions) error
• func GetClientSet(kubeFactory apkube.Factory) (kubernetes.Interface, error)
• func GetClientSetOrDie(kubeFactory apkube.Factory) kubernetes.Interface
• func GetClusterSecret(ctx context.Context, kubeFactory apkube.Factory, namespace string, name string) (*v1.Secret, error)
• func GetDynamicClientOrDie(kubeFactory apkube.Factory) dynamic.Interface
• func GetIngressClass(ctx context.Context, kubeFactory apkube.Factory, name string) (*netv1.IngressClass, error)
• func GetSecretsWithLabel(ctx context.Context, kubeFactory apkube.Factory, namespace, label string) (*v1.SecretList, error)
• func GetValueFromSecret(ctx context.Context, kubeFactory apkube.Factory, namespace, name, key string) (string, error)
• func WaitForJob(ctx context.Context, kubeFactory apkube.Factory, ns, jobName string) error
• type ClusterRequirementsOptions
• type LaunchJobOptions

Functions

func CheckNamespaceExists

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

func DeleteSecretWithFinalizer

func DeleteSecretWithFinalizer(ctx context.Context, kubeFactory apkube.Factory, secret *v1.Secret) error

func EnsureClusterRequirements

func EnsureClusterRequirements(ctx context.Context, opts ClusterRequirementsOptions) error

func GetClientSet

func GetClientSet(kubeFactory apkube.Factory) (kubernetes.Interface, error)

func GetClientSetOrDie

func GetClientSetOrDie(kubeFactory apkube.Factory) kubernetes.Interface

func GetClusterSecret

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

func GetDynamicClientOrDie

func GetDynamicClientOrDie(kubeFactory apkube.Factory) dynamic.Interface

func GetIngressClass

func GetIngressClass(ctx context.Context, kubeFactory apkube.Factory, name string) (*netv1.IngressClass, error)

func GetSecretsWithLabel

func GetSecretsWithLabel(ctx context.Context, kubeFactory apkube.Factory, namespace, label string) (*v1.SecretList, error)

func GetValueFromSecret

func GetValueFromSecret(ctx context.Context, kubeFactory apkube.Factory, namespace, name, key string) (string, error)

func WaitForJob

func WaitForJob(ctx context.Context, kubeFactory apkube.Factory, ns, jobName string) error

Types

type ClusterRequirementsOptions

type ClusterRequirementsOptions struct {
	KubeFactory        apkube.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
}