utils

package

v1.19.1 Latest Latest Go to latest Published: Mar 28, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/k8ssandra/cass-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddHashAnnotation(r Annotated)
func AppendValuesToStringArrayIfNotPresent(a []string, values ...string) []string
func DeepHashObject(hasher hash.Hash, objectToWrite interface{})
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 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
type RunModeType
type StringSet
- 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

Constants ¶

View Source

const ResourceHashAnnotationKey = "cassandra.datastax.com/resource-hash"

View Source

const (
	// WatchNamespaceEnvVar is the constant for env variable WATCH_NAMESPACE
	// which is the namespace where the watch activity happens.
	// this value is empty if the operator is running with clusterScope.
	WatchNamespaceEnvVar = "WATCH_NAMESPACE"
)

Variables ¶

View Source

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

ErrNoNamespace indicates that a namespace could not be found for the current environment

View Source

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

ErrRunLocal indicates that the operator is set to run in local mode (this error is returned by functions that only work on operators running in cluster mode)

View Source

var ForceRunModeEnv = "OSDK_FORCE_RUN_MODE"

ForceRunModeEnv indicates if the operator should be forced to run in either local or cluster mode (currently only used for local mode)

Functions ¶

func AddHashAnnotation ¶

func AddHashAnnotation(r Annotated)

func AppendValuesToStringArrayIfNotPresent ¶

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

func DeepHashObject ¶ added in v1.13.0

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

DeepHashObject writes specified object to hash using the spew library which follows pointers and prints actual values of the nested objects ensuring the hash does not change when a pointer changes.

func ElementsMatch ¶

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

func FilterNodesWithFn ¶

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

func FilterNodesWithTaintKeyValueEffect ¶

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

func FilterPodsWithAnnotationKey ¶

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

func FilterPodsWithFn ¶

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

func FilterPodsWithLabel ¶

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

func FilterPodsWithNodeInNameSet ¶

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

func GenerateJKS ¶

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

func GetGVKsFromAddToScheme ¶

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

GetGVKsFromAddToScheme takes in the runtime scheme and filters out all generic apimachinery meta types. It returns just the GVK specific to this scheme.

func GetNewCAandKey ¶

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

func GetOperatorNamespace ¶

func GetOperatorNamespace() (string, error)

GetOperatorNamespace returns the namespace the operator should be running in.

func GetPVCSelectedNodeName ¶

func GetPVCSelectedNodeName(pvc *corev1.PersistentVolumeClaim) string

func GetWatchNamespace ¶

func GetWatchNamespace() (string, error)

GetWatchNamespace returns the namespace the operator should be watching for changes

func IndexOfString ¶

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

func MergeMap ¶

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

MergeMap will take two maps, merging the entries of the source map into destination map. If both maps share the same key then destination's value for that key will be overwritten with what's in source.

func RangeInt ¶

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

func RemoveValueFromStringArray ¶

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

func ResourcesHaveSameHash ¶

func ResourcesHaveSameHash(r1, r2 Annotated) bool

func SearchMap ¶

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

SearchMap will recursively search a map looking for a key with a value of another map

Types ¶

type Annotated ¶

type Annotated interface {
	GetAnnotations() map[string]string
	SetAnnotations(annotations map[string]string)
}

type RunModeType ¶

type RunModeType string

const (
	LocalRunMode   RunModeType = "local"
	ClusterRunMode RunModeType = "cluster"
)

type StringSet ¶

type StringSet map[string]bool

StringSet helper functions

func GetNodeNameSet ¶

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

k8s Node helper functions

func GetPodNameSet ¶

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

func GetPodNodeNameSet ¶

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

func IntersectionStringSet ¶

func IntersectionStringSet(a, b StringSet) StringSet

func SubtractStringSet ¶

func SubtractStringSet(a, b StringSet) StringSet

func UnionStringSet ¶

func UnionStringSet(a, b StringSet) StringSet

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func AddHashAnnotation ¶

func AppendValuesToStringArrayIfNotPresent ¶

func DeepHashObject ¶ added in v1.13.0

func ElementsMatch ¶

func FilterNodesWithFn ¶

func FilterNodesWithTaintKeyValueEffect ¶

func FilterPVCsWithFn ¶

func FilterPodsWithAnnotationKey ¶

func FilterPodsWithFn ¶

func FilterPodsWithLabel ¶

func FilterPodsWithNodeInNameSet ¶

func GenerateJKS ¶

func GetGVKsFromAddToScheme ¶

func GetNewCAandKey ¶

func GetOperatorNamespace ¶

func GetPVCSelectedNodeName ¶

func GetWatchNamespace ¶

func IndexOfString ¶

func IsPodUnschedulable ¶

func MergeMap ¶

func RangeInt ¶

func RemoveValueFromStringArray ¶

func ResourcesHaveSameHash ¶

func SearchMap ¶

Types ¶

type Annotated ¶

type RunModeType ¶

type StringSet ¶

func GetNodeNameSet ¶

func GetPodNameSet ¶

func GetPodNodeNameSet ¶

func IntersectionStringSet ¶

func SubtractStringSet ¶

func UnionStringSet ¶

Source Files ¶