pipelines

package

v0.4.0 Latest Latest Go to latest Published: Sep 4, 2023 License: BSD-3-Clause Imports: 5 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sky-uk/kfp-operator

Links

Open Source Insights

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 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 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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Collect ¶ added in v0.4.0

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

func Contains ¶ added in v0.4.0

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

func Duplicates ¶ added in v0.4.0

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

func Exists ¶ added in v0.4.0

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

func Filter ¶ added in v0.4.0

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

func Flatten ¶ added in v0.4.0

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

func Forall ¶ added in v0.4.0

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

func GroupMap ¶ added in v0.4.0

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

func Map ¶ added in v0.4.0

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

func MapErr ¶ added in v0.4.0

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

func RetrieveAndUnsetConversionAnnotations ¶ added in v0.4.0

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

func SetConversionAnnotations ¶ added in v0.4.0

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

func SliceDiff ¶ added in v0.4.0

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

func ToMap ¶ added in v0.4.0

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

func Unique ¶ added in v0.4.0

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

func Values ¶ added in v0.4.0

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

func WriteKVListField ¶ added in v0.4.0

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

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

func WriteList ¶ added in v0.4.0

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 ¶ added in v0.4.0

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

+kubebuilder:object:generate=false

type KV ¶ added in v0.4.0

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 ¶ added in v0.4.0

func (oh ObjectHasher) WriteFieldSeparator()

func (ObjectHasher) WriteMapField ¶

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

func (ObjectHasher) WriteStringField ¶

func (oh ObjectHasher) WriteStringField(value string)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
v1alpha2 Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org	Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org
v1alpha3 Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org	Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org
v1alpha4 Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org	Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org
v1alpha5 Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org	Package v1 contains API Schema definitions for the pipelines.kubeflow.org v1 API group +kubebuilder:object:generate=true +groupName=pipelines.kubeflow.org

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