k8s

Mar 20, 2019

Changes in this version

+ func DeleteConfigMap(k8sClient *kubernetes.Clientset, configMapName string) error

+ func DeletePods(k8sClient *kubernetes.Clientset, podList *v1.PodList) error

+ func ListPodsByLabel(k8sClient *kubernetes.Clientset, label string) (*v1.PodList, error)

+ func SetNodeAddressesAnnotations(node *v1.Node, internalAddress, externalAddress string)

+ func SyncNodeLabels(node *v1.Node, toAddLabels, toDelLabels map[string]string)

+ func SyncNodeTaints(node *v1.Node, toAddTaints, toDelTaints []string)

Aug 9, 2018

Changes in this version

+ func DeleteK8sSystemJob(jobYaml string, k8sClient *kubernetes.Clientset, timeout int) error

type JobStatus

+ func GetK8sJobStatus(k8sClient *kubernetes.Clientset, name, namespace string) (JobStatus, error)

Jul 6, 2018

Changes in this version

+ type JobStatus struct

+ Completed bool

+ Created bool

May 17, 2018

Changes in this version

+ const DefaultTimeout

Apr 4, 2018

Changes in this version

+ const AWSCloudProvider

Mar 27, 2018

Changes in this version

+ const ExternalAddressAnnotation

+ const InternalAddressAnnotation

+ const K8sWrapTransportTimeout

+ func SetAddressesAnnotations(k8sClient *kubernetes.Clientset, ...) error

Mar 24, 2018

Changes in this version

+ const HostnameLabel

Mar 6, 2018

Changes in this version

+ type WrapTransport func(rt http.RoundTripper) http.RoundTripper

Feb 7, 2018

Changes in this version

+ func SyncLabels(k8sClient *kubernetes.Clientset, nodeName string, ...) error

+ func SyncTaints(k8sClient *kubernetes.Clientset, nodeName string, ...) error

Jan 24, 2018

Changes in this version

+ const DefaultRetries

+ const DefaultSleepSeconds

+ func ApplyK8sSystemJob(jobYaml, kubeConfigPath string) error

+ func CordonUncordon(k8sClient *kubernetes.Clientset, nodeName string, cordoned bool) error

+ func DeleteNode(k8sClient *kubernetes.Clientset, nodeName string) error

+ func GetConfigMap(k8sClient *kubernetes.Clientset, configMapName string) (*v1.ConfigMap, error)

+ func GetNode(k8sClient *kubernetes.Clientset, nodeName string) (*v1.Node, error)

+ func GetNodeList(k8sClient *kubernetes.Clientset) (*v1.NodeList, error)

+ func GetSecret(k8sClient *kubernetes.Clientset, secretName string) (*v1.Secret, error)

+ func IsNodeReady(node v1.Node) bool

+ func NewClient(kubeConfigPath string) (*kubernetes.Clientset, error)

+ func RemoveTaintFromNodeByKey(k8sClient *kubernetes.Clientset, nodeName, taintKey string) error

+ func UpdateClusterRoleBindingFromYaml(k8sClient *kubernetes.Clientset, clusterRoleBindingYaml string) error

+ func UpdateClusterRoleFromYaml(k8sClient *kubernetes.Clientset, clusterRoleYaml string) error

+ func UpdateConfigMap(k8sClient *kubernetes.Clientset, configYaml []byte, configMapName string) error

+ func UpdatePodSecurityPolicyFromYaml(k8sClient *kubernetes.Clientset, pspYaml string) error

+ func UpdateRoleBindingFromYaml(k8sClient *kubernetes.Clientset, roleBindingYaml string) error

+ func UpdateRoleFromYaml(k8sClient *kubernetes.Clientset, roleYaml string) error

+ func UpdateSecret(k8sClient *kubernetes.Clientset, fieldName string, secretData []byte, ...) error

+ func UpdateServiceAccountFromYaml(k8sClient *kubernetes.Clientset, serviceAccountYaml string) error