Versions in this module Expand all Collapse all v0 v0.1.2 Jun 10, 2021 Changes in this version + const RecommendedConfigPathEnvVar + func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions + func FilterActivePods(pods []*v1.Pod) []*v1.Pod + func FilterPodCount(pods []*v1.Pod, phase v1.PodPhase) int32 + func GetClusterConfig() (*rest.Config, error) + func GetTotalFailedReplicas(replicas map[apiv1.ReplicaType]*apiv1.ReplicaStatus) int32 + func GetTotalReplicas(replicas map[apiv1.ReplicaType]*apiv1.ReplicaSpec) int32 + func IsKubernetesResourceAlreadyExistError(err error) bool + func IsKubernetesResourceNotFoundError(err error) bool + func IsPodActive(p *v1.Pod) 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 + func (c *CRDRestClient) UpdateStatus(obj *metav1unstructured.Unstructured, plural string) error
Go to main page