util

Documentation

Index

• func Close(c Closer)
• func GenerateFieldSelectorFromWorkflowName(wfName string) string
• func GetDeletePropagation() *metav1.DeletionPropagation
• func GetSecrets(ctx context.Context, clientSet kubernetes.Interface, ...) ([]byte, error)
• func MergeArtifacts(artifactSlices ...[]wfv1.Artifact) []wfv1.Artifact
• func MergeParameters(params ...[]wfv1.Parameter) []wfv1.Parameter
• func RecoverIndexFromNodeName(name string) int
• func RecoverWorkflowNameFromSelectorStringIfAny(selector string) string
• func WriteTeriminateMessage(message string)
• type Closer

Functions

func Close

func Close(c Closer)

Close is a convenience function to close a object that has a Close() method, ignoring any errors Used to satisfy errcheck lint

func GenerateFieldSelectorFromWorkflowName

func GenerateFieldSelectorFromWorkflowName(wfName string) string

func GetDeletePropagation

func GetDeletePropagation() *metav1.DeletionPropagation

getDeletePropagation return the default or configured DeletePropagation policy

func GetSecrets

func GetSecrets(ctx context.Context, clientSet kubernetes.Interface, namespace, name, key string) ([]byte, error)

GetSecrets retrieves a secret value and memoizes the result

func MergeArtifacts

func MergeArtifacts(artifactSlices ...[]wfv1.Artifact) []wfv1.Artifact

MergeArtifacts merges artifact argument slices Merge the slices based on arguments order (first is high priority).

func MergeParameters

func MergeParameters(params ...[]wfv1.Parameter) []wfv1.Parameter

Merge the two parameters Slice Merge the slices based on arguments order (first is high priority).

func RecoverIndexFromNodeName

func RecoverIndexFromNodeName(name string) int

func RecoverWorkflowNameFromSelectorStringIfAny

func RecoverWorkflowNameFromSelectorStringIfAny(selector string) string

func WriteTeriminateMessage

func WriteTeriminateMessage(message string)

Write the Terminate message in pod spec

Types

type Closer

type Closer interface {
	Close() error
}