Versions in this module Expand all Collapse all v0 v0.1.0 Sep 6, 2019 Changes in this version + const ResourceNvidiaGPU + var NotTheOwnerError = errors.Errorf("FlytePropeller is not the owner") + 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 struct + 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 struct + K string + V *core.BindingData + func NewPair(k string, v *core.BindingData) Pair
Go to main page