k8sutil

May 15, 2019

Changes in this version

+ func FilterPodCount(pods []*v1.Pod, phase v1.PodPhase) int32

Mar 26, 2019

Changes in this version

+ func FilterActivePods(pods []*v1.Pod) []*v1.Pod

+ func FilterPods(pods []*v1.Pod, phase v1.PodPhase) int

+ func IsPodActive(p *v1.Pod) bool

Feb 13, 2019

Changes in this version

type CRDRestClient

+ func (c *CRDRestClient) UpdateStatus(obj *metav1unstructured.Unstructured, plural string) error

Sep 22, 2018

Changes in this version

+ type CRDClient interface

+ Update func(obj *metav1unstructured.Unstructured) error

+ type CRDRestClient struct

+ func NewCRDRestClient(version *schema.GroupVersion) (*CRDRestClient, error)

+ func (c *CRDRestClient) Client() *http.Client

+ func (c *CRDRestClient) Update(obj *metav1unstructured.Unstructured, plural string) error

Mar 29, 2018

Changes in this version

+ const RecommendedConfigPathEnvVar

+ func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions

+ func GetClusterConfig() (*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 MustNewKubeClient() kubernetes.Interface