utils

Documentation

Index

• Constants
• Variables
• func CopyMap(o map[string]string) (r map[string]string)
• func FixedLengthUniqueID(inputID string, maxLength int) (string, error)
• func FixedLengthUniqueIDForParts(maxLength int, parts ...string) (string, error)
• func GetProtoTime(t *metav1.Time) *timestamp.Timestamp
• func GetWorkflowIDFromObject(obj metav1.Object) (v1alpha1.WorkflowID, error)
• func GetWorkflowIDFromOwner(reference *metav1.OwnerReference, namespace string) (v1alpha1.WorkflowID, error)
• func MakeBinaryLiteral(v []byte) *core.Literal
• func MakeBinding(variable string, b *core.BindingData) *core.Binding
• func MakeBindingDataCollection(bindings ...*core.BindingData) *core.BindingData
• func MakeBindingDataMap(pairs ...Pair) *core.BindingData
• func MakeBindingDataPromise(fromNode, fromVar string) *core.BindingData
• func MakeBindingPromise(fromNode, fromVar, toVar string) *core.Binding
• func MakeDefaultLiteralForType(typ *core.LiteralType) (*core.Literal, error)
• func MakeLiteral(v interface{}) (*core.Literal, error)
• func MakeLiteralForCollection(v []interface{}) (*core.Literal, error)
• func MakeLiteralForMap(v map[string]interface{}) (*core.Literal, error)
• func MakeLiteralMap(v map[string]interface{}) (*core.LiteralMap, error)
• func MakePrimitive(v interface{}) (*core.Primitive, error)
• func MakePrimitiveBindingData(v interface{}) (*core.BindingData, error)
• func MakePrimitiveLiteral(v interface{}) (*core.Literal, error)
• func MustMakeDefaultLiteralForType(typ *core.LiteralType) *core.Literal
• func MustMakeLiteral(v interface{}) *core.Literal
• func MustMakePrimitive(v interface{}) *core.Primitive
• func MustMakePrimitiveBindingData(v interface{}) *core.BindingData
• func MustMakePrimitiveLiteral(v interface{}) *core.Literal
• func NewPluginTaskEventRecorder(taskEventRecorder events.TaskEventRecorder) events.TaskEventRecorder
• func ToK8sEnvVar(env []*core.KeyValuePair) []v1.EnvVar
• func ToK8sResourceList(resources []*core.Resources_ResourceEntry) (v1.ResourceList, error)
• func ToK8sResourceRequirements(resources *core.Resources) (*v1.ResourceRequirements, error)
• type FailingRawStore
  • func (FailingRawStore) CopyRaw(ctx context.Context, source, destination storage.DataReference, ...) error
  • func (FailingRawStore) GetBaseContainerFQN(ctx context.Context) storage.DataReference
  • func (FailingRawStore) Head(ctx context.Context, reference storage.DataReference) (storage.Metadata, error)
  • func (FailingRawStore) ReadRaw(ctx context.Context, reference storage.DataReference) (io.ReadCloser, error)
  • func (FailingRawStore) WriteRaw(ctx context.Context, reference storage.DataReference, size int64, ...) error
• type Pair
  • func NewPair(k string, v *core.BindingData) Pair

Constants

const ResourceNvidiaGPU = "nvidia.com/gpu"

ResourceNvidiaGPU is the name of the Nvidia GPU resource.

Variables

var NotTheOwnerError = errors.Errorf("FlytePropeller is not the owner")

Functions

func CopyMap

func CopyMap(o map[string]string) (r map[string]string)

func FixedLengthUniqueID

func FixedLengthUniqueID(inputID string, maxLength int) (string, error)

Creates a new UniqueID that is based on the inputID and of a specified length, if the given id is longer than the maxLength.

func FixedLengthUniqueIDForParts

func FixedLengthUniqueIDForParts(maxLength int, parts ...string) (string, error)

Creates a new uniqueID using the parts concatenated using `-` and ensures that the uniqueID is not longer than the maxLength. In case a simple concatenation yields a longer string, a new hashed ID is created which is always around 8 characters in length

func GetProtoTime

func GetProtoTime(t *metav1.Time) *timestamp.Timestamp

func GetWorkflowIDFromObject

func GetWorkflowIDFromObject(obj metav1.Object) (v1alpha1.WorkflowID, error)

func GetWorkflowIDFromOwner

func GetWorkflowIDFromOwner(reference *metav1.OwnerReference, namespace string) (v1alpha1.WorkflowID, error)

func MakeBinaryLiteral

func MakeBinaryLiteral(v []byte) *core.Literal

func MakeBinding

func MakeBinding(variable string, b *core.BindingData) *core.Binding

func MakeBindingDataCollection

func MakeBindingDataCollection(bindings ...*core.BindingData) *core.BindingData

func MakeBindingDataMap

func MakeBindingDataMap(pairs ...Pair) *core.BindingData

func MakeBindingDataPromise

func MakeBindingDataPromise(fromNode, fromVar string) *core.BindingData

func MakeBindingPromise

func MakeBindingPromise(fromNode, fromVar, toVar string) *core.Binding

func MakeDefaultLiteralForType

func MakeDefaultLiteralForType(typ *core.LiteralType) (*core.Literal, error)

func MakeLiteral

func MakeLiteral(v interface{}) (*core.Literal, error)

func MakeLiteralForCollection

func MakeLiteralForCollection(v []interface{}) (*core.Literal, error)

func MakeLiteralForMap

func MakeLiteralForMap(v map[string]interface{}) (*core.Literal, error)

func MakeLiteralMap

func MakeLiteralMap(v map[string]interface{}) (*core.LiteralMap, error)

func MakePrimitive

func MakePrimitive(v interface{}) (*core.Primitive, error)

func MakePrimitiveBindingData

func MakePrimitiveBindingData(v interface{}) (*core.BindingData, error)

func MakePrimitiveLiteral

func MakePrimitiveLiteral(v interface{}) (*core.Literal, error)

func MustMakeDefaultLiteralForType

func MustMakeDefaultLiteralForType(typ *core.LiteralType) *core.Literal

func MustMakeLiteral

func MustMakeLiteral(v interface{}) *core.Literal

func MustMakePrimitive

func MustMakePrimitive(v interface{}) *core.Primitive

func MustMakePrimitiveBindingData

func MustMakePrimitiveBindingData(v interface{}) *core.BindingData

func MustMakePrimitiveLiteral

func MustMakePrimitiveLiteral(v interface{}) *core.Literal

func NewPluginTaskEventRecorder

func NewPluginTaskEventRecorder(taskEventRecorder events.TaskEventRecorder) events.TaskEventRecorder

Construct task event recorder to pass down to plugin. This is a just a wrapper around the normal taskEventRecorder that can encapsulate logic to validate and handle errors.

func ToK8sEnvVar

func ToK8sEnvVar(env []*core.KeyValuePair) []v1.EnvVar

func ToK8sResourceList

func ToK8sResourceList(resources []*core.Resources_ResourceEntry) (v1.ResourceList, error)

TODO we should modify the container resources to contain a map of enum values? Also we should probably create tolerations / taints, but we could do that as a post process

func ToK8sResourceRequirements

func ToK8sResourceRequirements(resources *core.Resources) (*v1.ResourceRequirements, error)

Types

type FailingRawStore

type FailingRawStore struct {
}

func (FailingRawStore) CopyRaw

func (FailingRawStore) CopyRaw(ctx context.Context, source, destination storage.DataReference, opts storage.Options) error

func (FailingRawStore) GetBaseContainerFQN

func (FailingRawStore) GetBaseContainerFQN(ctx context.Context) storage.DataReference

func (FailingRawStore) Head

func (FailingRawStore) Head(ctx context.Context, reference storage.DataReference) (storage.Metadata, error)

func (FailingRawStore) ReadRaw

func (FailingRawStore) ReadRaw(ctx context.Context, reference storage.DataReference) (io.ReadCloser, error)

func (FailingRawStore) WriteRaw

func (FailingRawStore) WriteRaw(ctx context.Context, reference storage.DataReference, size int64, opts storage.Options, raw io.Reader) error

type Pair

type Pair struct {
	K string
	V *core.BindingData
}

func NewPair

func NewPair(k string, v *core.BindingData) Pair