pipelines

Documentation

Index

• func Collect[R, S any](rs []R, mapFn func(R) (S, bool)) []S
• func Contains[T comparable](ts []T, elem T) bool
• func Duplicates[R comparable](in []R) (out []R)
• func Exists[T any](ts []T, predicate func(T) bool) bool
• func Filter[T any](ts []T, filter func(T) bool) (filtered []T)
• func FlatMap[R, S any](rs []R, mapFn func(R) []S) []S
• func FlatMapErr[R, S any](rs []R, mapFn func(R) ([]S, error)) ([]S, error)
• func Flatten[R any](rrs ...[]R) (out []R)
• func Forall[T any](ts []T, predicate func(T) bool) bool
• func GroupMap[R any, K comparable, V any](rs []R, groupFn func(R) (K, V)) map[K][]V
• func Map[R, S any](rs []R, mapFn func(R) S) []S
• func MapErr[R, S any](rs []R, mapFn func(R) (S, error)) (ss []S, err error)
• func MapValues[K comparable, V, W any](vs map[K]V, mapValueFn func(V) W) map[K]W
• func RetrieveAndUnsetConversionAnnotations(resource metav1.Object, remainders ...ConversionRemainder) error
• func SetConversionAnnotations(resource metav1.Object, remainders ...ConversionRemainder) error
• func SliceDiff[T any](as, bs []T, cmp func(T, T) bool) []T
• func ToMap[K comparable, V, W any](vs []V, mapFn func(V) (K, W)) map[K]W
• func Unique[R comparable](in []R) (out []R)
• func Values[K comparable, V any](kvs map[K]V) []V
• func WriteKVListField[T KV](oh ObjectHasher, kvs []T)
• func WriteList[T any](oh ObjectHasher, ts []T, cmp func(t1, t2 T) bool, ...)
• type ConversionRemainder
• type KV
• type ObjectHasher
  • func NewObjectHasher() ObjectHasher
  • func (oh ObjectHasher) Sum() []byte
  • func (oh ObjectHasher) WriteFieldSeparator()
  • func (oh ObjectHasher) WriteMapField(value map[string]string)
  • func (oh ObjectHasher) WriteStringField(value string)

Functions

func Collect

func Collect[R, S any](rs []R, mapFn func(R) (S, bool)) []S

func Contains

func Contains[T comparable](ts []T, elem T) bool

func Duplicates

func Duplicates[R comparable](in []R) (out []R)

func Exists

func Exists[T any](ts []T, predicate func(T) bool) bool

func Filter

func Filter[T any](ts []T, filter func(T) bool) (filtered []T)

func FlatMap

func FlatMap[R, S any](rs []R, mapFn func(R) []S) []S

func FlatMapErr

func FlatMapErr[R, S any](rs []R, mapFn func(R) ([]S, error)) ([]S, error)

func Flatten

func Flatten[R any](rrs ...[]R) (out []R)

func Forall

func Forall[T any](ts []T, predicate func(T) bool) bool

func GroupMap

func GroupMap[R any, K comparable, V any](rs []R, groupFn func(R) (K, V)) map[K][]V

func Map

func Map[R, S any](rs []R, mapFn func(R) S) []S

func MapErr

func MapErr[R, S any](rs []R, mapFn func(R) (S, error)) (ss []S, err error)

func MapValues

func MapValues[K comparable, V, W any](vs map[K]V, mapValueFn func(V) W) map[K]W

func RetrieveAndUnsetConversionAnnotations

func RetrieveAndUnsetConversionAnnotations(resource metav1.Object, remainders ...ConversionRemainder) error

func SetConversionAnnotations

func SetConversionAnnotations(resource metav1.Object, remainders ...ConversionRemainder) error

func SliceDiff

func SliceDiff[T any](as, bs []T, cmp func(T, T) bool) []T

func ToMap

func ToMap[K comparable, V, W any](vs []V, mapFn func(V) (K, W)) map[K]W

func Unique

func Unique[R comparable](in []R) (out []R)

func Values

func Values[K comparable, V any](kvs map[K]V) []V

func WriteKVListField

func WriteKVListField[T KV](oh ObjectHasher, kvs []T)

Has to be a function with parameter because Go does not support generic methods

func WriteList

func WriteList[T any](oh ObjectHasher, ts []T, cmp func(t1, t2 T) bool, write func(oh ObjectHasher, t T))

Has to be a function with parameter because Go does not support generic methods

Types

type ConversionRemainder

type ConversionRemainder interface {
	Empty() bool
	ConversionAnnotation() string
}

+kubebuilder:object:generate=false

type KV

type KV interface {
	GetKey() string
	GetValue() string
}

type ObjectHasher

type ObjectHasher struct {
	// contains filtered or unexported fields
}

func NewObjectHasher

func NewObjectHasher() ObjectHasher

func (ObjectHasher) Sum

func (oh ObjectHasher) Sum() []byte

func (ObjectHasher) WriteFieldSeparator

func (oh ObjectHasher) WriteFieldSeparator()

func (ObjectHasher) WriteMapField

func (oh ObjectHasher) WriteMapField(value map[string]string)

func (ObjectHasher) WriteStringField

func (oh ObjectHasher) WriteStringField(value string)