helpers

Documentation

Index

• func ConvertToArray[To, From any](convert func(From) To, objs ...From) []To
• func CreateTwoWayMergePatch[T runtime.Object](original, modified T) ([]byte, error)
• func Filter[T any](array []T, filterFunc func(T) bool) []T
• func FilterOut[T any](array []T, filterOutFunc func(T) bool) []T
• func FilterOutNil[T any](array []*T) []*T
• func GetAgentAuthTokenConfig(token string) ([]byte, error)
• func GetAgentAuthTokenFromAgentConfigSecret(secret *corev1.Secret) (string, error)
• func GetAgentAuthTokenFromSecret(secret *corev1.Secret) (string, error)
• func IsStatusConditionPresentAndEqual(conditions []metav1.Condition, conditionType string, ...) bool
• func IsStatusConditionPresentAndFalse(conditions []metav1.Condition, conditionType string, generation int64) bool
• func IsStatusConditionPresentAndTrue(conditions []metav1.Condition, conditionType string, generation int64) bool
• func MergeMaps[Key comparable, Value any](maps ...map[Key]Value) map[Key]Value
• func Must[T any](r T, err error) T
• func NormalizeIPs(ips []net.IP) []net.IP
• func ParseClusterIP(s string) (net.IP, error)
• func ParseClusterIPs(ipStrings []string) ([]net.IP, error)
• func ToArray[T any](objs ...T) []T
• func UncachedListFunc(f func(options metav1.ListOptions) (runtime.Object, error)) func(options metav1.ListOptions) (runtime.Object, error)

Functions

func ConvertToArray

func ConvertToArray[To, From any](convert func(From) To, objs ...From) []To

func CreateTwoWayMergePatch

func CreateTwoWayMergePatch[T runtime.Object](original, modified T) ([]byte, error)

func Filter

func Filter[T any](array []T, filterFunc func(T) bool) []T

func FilterOut

func FilterOut[T any](array []T, filterOutFunc func(T) bool) []T

func FilterOutNil

func FilterOutNil[T any](array []*T) []*T

func GetAgentAuthTokenConfig

func GetAgentAuthTokenConfig(token string) ([]byte, error)

func GetAgentAuthTokenFromAgentConfigSecret

func GetAgentAuthTokenFromAgentConfigSecret(secret *corev1.Secret) (string, error)

func GetAgentAuthTokenFromSecret

func GetAgentAuthTokenFromSecret(secret *corev1.Secret) (string, error)

func IsStatusConditionPresentAndEqual

func IsStatusConditionPresentAndEqual(conditions []metav1.Condition, conditionType string, status metav1.ConditionStatus, generation int64) bool

func IsStatusConditionPresentAndFalse

func IsStatusConditionPresentAndFalse(conditions []metav1.Condition, conditionType string, generation int64) bool

func IsStatusConditionPresentAndTrue

func IsStatusConditionPresentAndTrue(conditions []metav1.Condition, conditionType string, generation int64) bool

func MergeMaps

func MergeMaps[Key comparable, Value any](maps ...map[Key]Value) map[Key]Value

MergeMaps merges several maps into a new map. If there are conflicting keys, the last one wins and overwrites the value.

func Must

func Must[T any](r T, err error) T

func NormalizeIPs

func NormalizeIPs(ips []net.IP) []net.IP

func ParseClusterIP

func ParseClusterIP(s string) (net.IP, error)

func ParseClusterIPs

func ParseClusterIPs(ipStrings []string) ([]net.IP, error)

func ToArray

func ToArray[T any](objs ...T) []T

func UncachedListFunc

func UncachedListFunc(f func(options metav1.ListOptions) (runtime.Object, error)) func(options metav1.ListOptions) (runtime.Object, error)

UncachedListFunc wraps a List function and makes sure initial lists avoid watch cache on the apiserver. This is important for caller that need top reason about "happened after" or similar cases.