k8sutil

Documentation

Index

• Constants
• func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions
• func GetClusterConfig(f string) (*rest.Config, error)
• func IsKubernetesResourceAlreadyExistError(err error) bool
• func IsKubernetesResourceNotFoundError(err error) bool
• func JobListOpt(clusterName string) metav1.ListOptions
• func LabelsForJob(jobName string) map[string]string
• func MustNewApiExtensionsClient() apiextensionsclient.Interface
• func MustNewKubeClient() kubernetes.Interface

Constants

const RecommendedConfigPathEnvVar = "KUBECONFIG"

Functions

func CascadeDeleteOptions

func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions

TODO(jlewi): CascadeDeletOptions are part of garbage collection policy. Do we want to use this? See https://kubernetes.io/docs/concepts/workloads/controllers/garbage-collection/

func GetClusterConfig

func GetClusterConfig(f string) (*rest.Config, error)

Obtain the config from the Kube configuration used by kubeconfig, or from k8s cluster.

func IsKubernetesResourceAlreadyExistError

func IsKubernetesResourceAlreadyExistError(err error) bool

func IsKubernetesResourceNotFoundError

func IsKubernetesResourceNotFoundError(err error) bool

func JobListOpt

func JobListOpt(clusterName string) metav1.ListOptions

We are using internal api types for cluster related.

func LabelsForJob

func LabelsForJob(jobName string) map[string]string

func MustNewApiExtensionsClient

func MustNewApiExtensionsClient() apiextensionsclient.Interface

func MustNewKubeClient

func MustNewKubeClient() kubernetes.Interface