utils

Sep 29, 2022

Changes in this version

+ func DeepHashObject(hasher hash.Hash, objectToWrite interface{})

Jul 19, 2022

Changes in this version

+ const ResourceHashAnnotationKey

Oct 3, 2021

Changes in this version

+ const WatchNamespaceEnvVar

+ var ErrNoNamespace = fmt.Errorf("namespace not found for current environment")

+ var ErrRunLocal = fmt.Errorf("operator run mode forced to local")

+ var ForceRunModeEnv = "OSDK_FORCE_RUN_MODE"

+ func AddHashAnnotation(r Annotated)

+ func AppendValuesToStringArrayIfNotPresent(a []string, values ...string) []string

+ func ElementsMatch(a interface{}, b interface{}) bool

+ func FilterNodesWithFn(nodes []*corev1.Node, fn func(*corev1.Node) bool) []*corev1.Node

+ func FilterNodesWithTaintKeyValueEffect(nodes []*corev1.Node, taintKey, value string, effect corev1.TaintEffect) []*corev1.Node

+ func FilterPVCsWithFn(pvcs []*corev1.PersistentVolumeClaim, ...) []*corev1.PersistentVolumeClaim

+ func FilterPodsWithAnnotationKey(pods []*corev1.Pod, key string) []*corev1.Pod

+ func FilterPodsWithFn(pods []*corev1.Pod, fn func(*corev1.Pod) bool) []*corev1.Pod

+ func FilterPodsWithLabel(pods []*corev1.Pod, label, value string) []*corev1.Pod

+ func FilterPodsWithNodeInNameSet(pods []*corev1.Pod, nameSet StringSet) []*corev1.Pod

+ func GenerateJKS(ca *corev1.Secret, podname, dcname string) (jksblob []byte, err error)

+ func GetGVKsFromAddToScheme(addToSchemeFunc func(*runtime.Scheme) error) ([]schema.GroupVersionKind, error)

+ func GetNewCAandKey(leafdomain, namespace string) (keypem, certpem string, err error)

+ func GetOperatorNamespace() (string, error)

+ func GetPVCSelectedNodeName(pvc *corev1.PersistentVolumeClaim) string

+ func GetWatchNamespace() (string, error)

+ func IndexOfString(a []string, v string) int

+ func IsPSPEnabled() bool

+ func IsPodUnschedulable(pod *corev1.Pod) bool

+ func MergeMap(destination map[string]string, sources ...map[string]string) map[string]string

+ func RangeInt(min, max, step int) []int

+ func RemoveValueFromStringArray(a []string, v string) []string

+ func ResourcesHaveSameHash(r1, r2 Annotated) bool

+ func SearchMap(mapToSearch map[string]interface{}, key string) map[string]interface

+ type Annotated interface

+ GetAnnotations func() map[string]string

+ SetAnnotations func(annotations map[string]string)

+ type RunModeType string

+ const ClusterRunMode

+ const LocalRunMode

+ type StringSet map[string]bool

+ func GetNodeNameSet(nodes []*corev1.Node) StringSet

+ func GetPodNameSet(pods []*corev1.Pod) StringSet

+ func GetPodNodeNameSet(pods []*corev1.Pod) StringSet

+ func IntersectionStringSet(a, b StringSet) StringSet

+ func SubtractStringSet(a, b StringSet) StringSet

+ func UnionStringSet(a, b StringSet) StringSet