k8sutil

Aug 1, 2019

Changes in this version

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

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

+ func IsPodActive(p *v1.Pod) bool

type CRDRestClient

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

May 21, 2019

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 MustNewKubeClient() kubernetes.Interface

+ 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