Versions in this module Expand all Collapse all v0 v0.1.3-alpha.0 Jan 11, 2024 v0.1.2 Dec 29, 2023 Changes in this version + const SlowStartInitialBatchSize + var EnvPodIpVal = os.Getenv("POD_IP") + var EnvPodNameVal = os.Getenv("POD_NAME") + var EnvPodNamespaceVal = os.Getenv("POD_NAMESPACE") + func CombineLabelSelectors(ls ...labels.Selector) labels.Selector + func DumpJSON(o interface{}) string + func GetCertDir() string + func GetCertWriter() string + func GetContainerEnvVar(container *v1.Container, key string) *v1.EnvVar + func GetHost() string + func GetMD5Hash(text string) string + func GetNamespace() string + func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition) + func GetPodConditionFromList(conditions []v1.PodCondition, conditionType v1.PodConditionType) (int, *v1.PodCondition) + func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition + func GetPort() int + func GetSecretName() string + func GetServiceName() string + func Init() error + func InitFlags(flagset *flag.FlagSet) + func IsHashChangedError(err error) bool + func IsPodActive(p *v1.Pod) bool + func IsPodReady(pod *v1.Pod) bool + func IsPodReadyConditionTrue(status v1.PodStatus) bool + func Key(namespace, name string) string + func KeyFunc(obj metav1.Object) string + func LastReplace(s, old, new string) string + func MergeLabelSelector(selA, selB *metav1.LabelSelector) *metav1.LabelSelector + func NegateLabelSelector(sel *metav1.LabelSelector) *metav1.LabelSelector + func NewClientFromManager(mgr manager.Manager, name string) client.Client + func NewDirectorClientFromManager(mgr manager.Manager, name string) client.Client + func SlowStartBatch(count int, initialBatchSize int, shortCircuit bool, fn func(int, error) error, ...) (int, error) + func ValidatedLabelSelectorAsSelector(ps *metav1.LabelSelector) (labels.Selector, error) + type HashChangedError struct + func (e HashChangedError) Error() string + func (e HashChangedError) String() string