pipelines

package

v0.6.0 Latest Latest Go to latest Published: May 20, 2024 License: BSD-3-Clause Imports: 5 Imported by: 2

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

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

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

func FlatMapErr ¶ added in v0.4.1

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

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

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

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