core

package
v0.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 4, 2019 License: Apache-2.0 Imports: 16 Imported by: 131

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BlobType_BlobDimensionality_name = map[int32]string{
	0: "SINGLE",
	1: "MULTIPART",
}
View Source 
var BlobType_BlobDimensionality_value = map[string]int32{
	"SINGLE":    0,
	"MULTIPART": 1,
}
View Source 
var ComparisonExpression_Operator_name = map[int32]string{
	0: "EQ",
	1: "NEQ",
	2: "GT",
	3: "GTE",
	4: "LT",
	5: "LTE",
}
View Source 
var ComparisonExpression_Operator_value = map[string]int32{
	"EQ":  0,
	"NEQ": 1,
	"GT":  2,
	"GTE": 3,
	"LT":  4,
	"LTE": 5,
}
View Source 
var ConjunctionExpression_LogicalOperator_name = map[int32]string{
	0: "AND",
	1: "OR",
}
View Source 
var ConjunctionExpression_LogicalOperator_value = map[string]int32{
	"AND": 0,
	"OR":  1,
}
View Source 
var ContainerError_Kind_name = map[int32]string{
	0: "NON_RECOVERABLE",
	1: "RECOVERABLE",
}
View Source 
var ContainerError_Kind_value = map[string]int32{
	"NON_RECOVERABLE": 0,
	"RECOVERABLE":     1,
}
View Source 
var NodeExecution_Phase_name = map[int32]string{
	0: "UNDEFINED",
	1: "QUEUED",
	2: "RUNNING",
	3: "SUCCEEDED",
	4: "FAILING",
	5: "FAILED",
	6: "ABORTED",
	7: "SKIPPED",
	8: "TIMED_OUT",
}
View Source 
var NodeExecution_Phase_value = map[string]int32{
	"UNDEFINED": 0,
	"QUEUED":    1,
	"RUNNING":   2,
	"SUCCEEDED": 3,
	"FAILING":   4,
	"FAILED":    5,
	"ABORTED":   6,
	"SKIPPED":   7,
	"TIMED_OUT": 8,
}
View Source 
var ResourceType_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "TASK",
	2: "WORKFLOW",
	3: "LAUNCH_PLAN",
}
View Source 
var ResourceType_value = map[string]int32{
	"UNSPECIFIED": 0,
	"TASK":        1,
	"WORKFLOW":    2,
	"LAUNCH_PLAN": 3,
}
View Source 
var Resources_ResourceName_name = map[int32]string{
	0: "UNKNOWN",
	1: "CPU",
	2: "GPU",
	3: "MEMORY",
	4: "STORAGE",
}
View Source 
var Resources_ResourceName_value = map[string]int32{
	"UNKNOWN": 0,
	"CPU":     1,
	"GPU":     2,
	"MEMORY":  3,
	"STORAGE": 4,
}
View Source 
var RuntimeMetadata_RuntimeType_name = map[int32]string{
	0: "OTHER",
	1: "FLYTE_SDK",
}
View Source 
var RuntimeMetadata_RuntimeType_value = map[string]int32{
	"OTHER":     0,
	"FLYTE_SDK": 1,
}
View Source 
var SchemaType_SchemaColumn_SchemaColumnType_name = map[int32]string{
	0: "INTEGER",
	1: "FLOAT",
	2: "STRING",
	3: "BOOLEAN",
	4: "DATETIME",
	5: "DURATION",
}
View Source 
var SchemaType_SchemaColumn_SchemaColumnType_value = map[string]int32{
	"INTEGER":  0,
	"FLOAT":    1,
	"STRING":   2,
	"BOOLEAN":  3,
	"DATETIME": 4,
	"DURATION": 5,
}
View Source 
var SimpleType_name = map[int32]string{
	0: "NONE",
	1: "INTEGER",
	2: "FLOAT",
	3: "STRING",
	4: "BOOLEAN",
	5: "DATETIME",
	6: "DURATION",
	7: "BINARY",
	8: "ERROR",
	9: "STRUCT",
}
View Source 
var SimpleType_value = map[string]int32{
	"NONE":     0,
	"INTEGER":  1,
	"FLOAT":    2,
	"STRING":   3,
	"BOOLEAN":  4,
	"DATETIME": 5,
	"DURATION": 6,
	"BINARY":   7,
	"ERROR":    8,
	"STRUCT":   9,
}
View Source 
var TaskExecution_Phase_name = map[int32]string{
	0: "UNDEFINED",
	1: "QUEUED",
	2: "RUNNING",
	3: "SUCCEEDED",
	4: "ABORTED",
	5: "FAILED",
}
View Source 
var TaskExecution_Phase_value = map[string]int32{
	"UNDEFINED": 0,
	"QUEUED":    1,
	"RUNNING":   2,
	"SUCCEEDED": 3,
	"ABORTED":   4,
	"FAILED":    5,
}
View Source 
var TaskLog_MessageFormat_name = map[int32]string{
	0: "UNKNOWN",
	1: "CSV",
	2: "JSON",
}
View Source 
var TaskLog_MessageFormat_value = map[string]int32{
	"UNKNOWN": 0,
	"CSV":     1,
	"JSON":    2,
}
View Source 
var WorkflowExecution_Phase_name = map[int32]string{
	0: "UNDEFINED",
	1: "QUEUED",
	2: "RUNNING",
	3: "SUCCEEDING",
	4: "SUCCEEDED",
	5: "FAILING",
	6: "FAILED",
	7: "ABORTED",
	8: "TIMED_OUT",
}
View Source 
var WorkflowExecution_Phase_value = map[string]int32{
	"UNDEFINED":  0,
	"QUEUED":     1,
	"RUNNING":    2,
	"SUCCEEDING": 3,
	"SUCCEEDED":  4,
	"FAILING":    5,
	"FAILED":     6,
	"ABORTED":    7,
	"TIMED_OUT":  8,
}

Functions

This section is empty.

Types

type Alias 

type Alias struct {
	// Must match one of the output variable names on a node.
	Var string `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	// A workflow-level unique alias that downstream nodes can refer to in their input.
	Alias                string   `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Links a variable to an alias.

func (*Alias) Descriptor 

func (*Alias) Descriptor() ([]byte, []int)

func (*Alias) GetAlias 

func (m *Alias) GetAlias() string

func (*Alias) GetVar 

func (m *Alias) GetVar() string

func (*Alias) ProtoMessage 

func (*Alias) ProtoMessage()

func (*Alias) Reset 

func (m *Alias) Reset()

func (*Alias) String 

func (m *Alias) String() string

func (*Alias) Validate 

func (m *Alias) Validate() error

Validate checks the field values on Alias with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Alias) XXX_DiscardUnknown 

func (m *Alias) XXX_DiscardUnknown()

func (*Alias) XXX_Marshal 

func (m *Alias) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Alias) XXX_Merge 

func (dst *Alias) XXX_Merge(src proto.Message)

func (*Alias) XXX_Size 

func (m *Alias) XXX_Size() int

func (*Alias) XXX_Unmarshal 

func (m *Alias) XXX_Unmarshal(b []byte) error

type AliasValidationError 

type AliasValidationError struct {
	// contains filtered or unexported fields
}

AliasValidationError is the validation error returned by Alias.Validate if the designated constraints aren't met.

func (AliasValidationError) Cause 

func (e AliasValidationError) Cause() error

Cause function returns cause value.

func (AliasValidationError) Error 

func (e AliasValidationError) Error() string

Error satisfies the builtin error interface

func (AliasValidationError) ErrorName 

func (e AliasValidationError) ErrorName() string

ErrorName returns error name.

func (AliasValidationError) Field 

func (e AliasValidationError) Field() string

Field function returns field value.

func (AliasValidationError) Key 

func (e AliasValidationError) Key() bool

Key function returns key value.

func (AliasValidationError) Reason 

func (e AliasValidationError) Reason() string

Reason function returns reason value.

type Binary 

type Binary struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Tag                  string   `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A simple byte array with a tag to help different parts of the system communicate about what is in the byte array. It's strongly advisable that consumers of this type define a unique tag and validate the tag before parsing the data.

func (*Binary) Descriptor 

func (*Binary) Descriptor() ([]byte, []int)

func (*Binary) GetTag 

func (m *Binary) GetTag() string

func (*Binary) GetValue 

func (m *Binary) GetValue() []byte

func (*Binary) ProtoMessage 

func (*Binary) ProtoMessage()

func (*Binary) Reset 

func (m *Binary) Reset()

func (*Binary) String 

func (m *Binary) String() string

func (*Binary) Validate 

func (m *Binary) Validate() error

Validate checks the field values on Binary with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Binary) XXX_DiscardUnknown 

func (m *Binary) XXX_DiscardUnknown()

func (*Binary) XXX_Marshal 

func (m *Binary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Binary) XXX_Merge 

func (dst *Binary) XXX_Merge(src proto.Message)

func (*Binary) XXX_Size 

func (m *Binary) XXX_Size() int

func (*Binary) XXX_Unmarshal 

func (m *Binary) XXX_Unmarshal(b []byte) error

type BinaryValidationError 

type BinaryValidationError struct {
	// contains filtered or unexported fields
}

BinaryValidationError is the validation error returned by Binary.Validate if the designated constraints aren't met.

func (BinaryValidationError) Cause 

func (e BinaryValidationError) Cause() error

Cause function returns cause value.

func (BinaryValidationError) Error 

func (e BinaryValidationError) Error() string

Error satisfies the builtin error interface

func (BinaryValidationError) ErrorName 

func (e BinaryValidationError) ErrorName() string

ErrorName returns error name.

func (BinaryValidationError) Field 

func (e BinaryValidationError) Field() string

Field function returns field value.

func (BinaryValidationError) Key 

func (e BinaryValidationError) Key() bool

Key function returns key value.

func (BinaryValidationError) Reason 

func (e BinaryValidationError) Reason() string

Reason function returns reason value.

type Binding 

type Binding struct {
	// Variable name must match an input/output variable of the node.
	Var string `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	// Data to use to bind this variable.
	Binding              *BindingData `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

An input/output binding of a variable to either static value or a node output.

func (*Binding) Descriptor 

func (*Binding) Descriptor() ([]byte, []int)

func (*Binding) GetBinding 

func (m *Binding) GetBinding() *BindingData

func (*Binding) GetVar 

func (m *Binding) GetVar() string

func (*Binding) ProtoMessage 

func (*Binding) ProtoMessage()

func (*Binding) Reset 

func (m *Binding) Reset()

func (*Binding) String 

func (m *Binding) String() string

func (*Binding) Validate 

func (m *Binding) Validate() error

Validate checks the field values on Binding with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Binding) XXX_DiscardUnknown 

func (m *Binding) XXX_DiscardUnknown()

func (*Binding) XXX_Marshal 

func (m *Binding) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Binding) XXX_Merge 

func (dst *Binding) XXX_Merge(src proto.Message)

func (*Binding) XXX_Size 

func (m *Binding) XXX_Size() int

func (*Binding) XXX_Unmarshal 

func (m *Binding) XXX_Unmarshal(b []byte) error

type BindingData 

type BindingData struct {
	// Types that are valid to be assigned to Value:
	//	*BindingData_Scalar
	//	*BindingData_Collection
	//	*BindingData_Promise
	//	*BindingData_Map
	Value                isBindingData_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Specifies either a simple value or a reference to another output.

func (*BindingData) Descriptor 

func (*BindingData) Descriptor() ([]byte, []int)

func (*BindingData) GetCollection 

func (m *BindingData) GetCollection() *BindingDataCollection

func (*BindingData) GetMap 

func (m *BindingData) GetMap() *BindingDataMap

func (*BindingData) GetPromise 

func (m *BindingData) GetPromise() *OutputReference

func (*BindingData) GetScalar 

func (m *BindingData) GetScalar() *Scalar

func (*BindingData) GetValue 

func (m *BindingData) GetValue() isBindingData_Value

func (*BindingData) ProtoMessage 

func (*BindingData) ProtoMessage()

func (*BindingData) Reset 

func (m *BindingData) Reset()

func (*BindingData) String 

func (m *BindingData) String() string

func (*BindingData) Validate 

func (m *BindingData) Validate() error

Validate checks the field values on BindingData with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*BindingData) XXX_DiscardUnknown 

func (m *BindingData) XXX_DiscardUnknown()

func (*BindingData) XXX_Marshal 

func (m *BindingData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BindingData) XXX_Merge 

func (dst *BindingData) XXX_Merge(src proto.Message)

func (*BindingData) XXX_OneofFuncs 

func (*BindingData) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*BindingData) XXX_Size 

func (m *BindingData) XXX_Size() int

func (*BindingData) XXX_Unmarshal 

func (m *BindingData) XXX_Unmarshal(b []byte) error

type BindingDataCollection 

type BindingDataCollection struct {
	Bindings             []*BindingData `protobuf:"bytes,1,rep,name=bindings,proto3" json:"bindings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

A collection of BindingData items.

func (*BindingDataCollection) Descriptor 

func (*BindingDataCollection) Descriptor() ([]byte, []int)

func (*BindingDataCollection) GetBindings 

func (m *BindingDataCollection) GetBindings() []*BindingData

func (*BindingDataCollection) ProtoMessage 

func (*BindingDataCollection) ProtoMessage()

func (*BindingDataCollection) Reset 

func (m *BindingDataCollection) Reset()

func (*BindingDataCollection) String 

func (m *BindingDataCollection) String() string

func (*BindingDataCollection) Validate 

func (m *BindingDataCollection) Validate() error

Validate checks the field values on BindingDataCollection with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*BindingDataCollection) XXX_DiscardUnknown 

func (m *BindingDataCollection) XXX_DiscardUnknown()

func (*BindingDataCollection) XXX_Marshal 

func (m *BindingDataCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BindingDataCollection) XXX_Merge 

func (dst *BindingDataCollection) XXX_Merge(src proto.Message)

func (*BindingDataCollection) XXX_Size 

func (m *BindingDataCollection) XXX_Size() int

func (*BindingDataCollection) XXX_Unmarshal 

func (m *BindingDataCollection) XXX_Unmarshal(b []byte) error

type BindingDataCollectionValidationError 

type BindingDataCollectionValidationError struct {
	// contains filtered or unexported fields
}

BindingDataCollectionValidationError is the validation error returned by BindingDataCollection.Validate if the designated constraints aren't met.

func (BindingDataCollectionValidationError) Cause 

func (e BindingDataCollectionValidationError) Cause() error

Cause function returns cause value.

func (BindingDataCollectionValidationError) Error 

func (e BindingDataCollectionValidationError) Error() string

Error satisfies the builtin error interface

func (BindingDataCollectionValidationError) ErrorName 

func (e BindingDataCollectionValidationError) ErrorName() string

ErrorName returns error name.

func (BindingDataCollectionValidationError) Field 

func (e BindingDataCollectionValidationError) Field() string

Field function returns field value.

func (BindingDataCollectionValidationError) Key 

func (e BindingDataCollectionValidationError) Key() bool

Key function returns key value.

func (BindingDataCollectionValidationError) Reason 

func (e BindingDataCollectionValidationError) Reason() string

Reason function returns reason value.

type BindingDataMap 

type BindingDataMap struct {
	Bindings             map[string]*BindingData `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

A map of BindingData items.

func (*BindingDataMap) Descriptor 

func (*BindingDataMap) Descriptor() ([]byte, []int)

func (*BindingDataMap) GetBindings 

func (m *BindingDataMap) GetBindings() map[string]*BindingData

func (*BindingDataMap) ProtoMessage 

func (*BindingDataMap) ProtoMessage()

func (*BindingDataMap) Reset 

func (m *BindingDataMap) Reset()

func (*BindingDataMap) String 

func (m *BindingDataMap) String() string

func (*BindingDataMap) Validate 

func (m *BindingDataMap) Validate() error

Validate checks the field values on BindingDataMap with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*BindingDataMap) XXX_DiscardUnknown 

func (m *BindingDataMap) XXX_DiscardUnknown()

func (*BindingDataMap) XXX_Marshal 

func (m *BindingDataMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BindingDataMap) XXX_Merge 

func (dst *BindingDataMap) XXX_Merge(src proto.Message)

func (*BindingDataMap) XXX_Size 

func (m *BindingDataMap) XXX_Size() int

func (*BindingDataMap) XXX_Unmarshal 

func (m *BindingDataMap) XXX_Unmarshal(b []byte) error

type BindingDataMapValidationError 

type BindingDataMapValidationError struct {
	// contains filtered or unexported fields
}

BindingDataMapValidationError is the validation error returned by BindingDataMap.Validate if the designated constraints aren't met.

func (BindingDataMapValidationError) Cause 

func (e BindingDataMapValidationError) Cause() error

Cause function returns cause value.

func (BindingDataMapValidationError) Error 

func (e BindingDataMapValidationError) Error() string

Error satisfies the builtin error interface

func (BindingDataMapValidationError) ErrorName 

func (e BindingDataMapValidationError) ErrorName() string

ErrorName returns error name.

func (BindingDataMapValidationError) Field 

func (e BindingDataMapValidationError) Field() string

Field function returns field value.

func (BindingDataMapValidationError) Key 

func (e BindingDataMapValidationError) Key() bool

Key function returns key value.

func (BindingDataMapValidationError) Reason 

func (e BindingDataMapValidationError) Reason() string

Reason function returns reason value.

type BindingDataValidationError 

type BindingDataValidationError struct {
	// contains filtered or unexported fields
}

BindingDataValidationError is the validation error returned by BindingData.Validate if the designated constraints aren't met.

func (BindingDataValidationError) Cause 

func (e BindingDataValidationError) Cause() error

Cause function returns cause value.

func (BindingDataValidationError) Error 

func (e BindingDataValidationError) Error() string

Error satisfies the builtin error interface

func (BindingDataValidationError) ErrorName 

func (e BindingDataValidationError) ErrorName() string

ErrorName returns error name.

func (BindingDataValidationError) Field 

func (e BindingDataValidationError) Field() string

Field function returns field value.

func (BindingDataValidationError) Key 

func (e BindingDataValidationError) Key() bool

Key function returns key value.

func (BindingDataValidationError) Reason 

func (e BindingDataValidationError) Reason() string

Reason function returns reason value.

type BindingData_Collection 

type BindingData_Collection struct {
	Collection *BindingDataCollection `protobuf:"bytes,2,opt,name=collection,proto3,oneof"`
}

type BindingData_Map 

type BindingData_Map struct {
	Map *BindingDataMap `protobuf:"bytes,4,opt,name=map,proto3,oneof"`
}

type BindingData_Promise 

type BindingData_Promise struct {
	Promise *OutputReference `protobuf:"bytes,3,opt,name=promise,proto3,oneof"`
}

type BindingData_Scalar 

type BindingData_Scalar struct {
	Scalar *Scalar `protobuf:"bytes,1,opt,name=scalar,proto3,oneof"`
}

type BindingValidationError 

type BindingValidationError struct {
	// contains filtered or unexported fields
}

BindingValidationError is the validation error returned by Binding.Validate if the designated constraints aren't met.

func (BindingValidationError) Cause 

func (e BindingValidationError) Cause() error

Cause function returns cause value.

func (BindingValidationError) Error 

func (e BindingValidationError) Error() string

Error satisfies the builtin error interface

func (BindingValidationError) ErrorName 

func (e BindingValidationError) ErrorName() string

ErrorName returns error name.

func (BindingValidationError) Field 

func (e BindingValidationError) Field() string

Field function returns field value.

func (BindingValidationError) Key 

func (e BindingValidationError) Key() bool

Key function returns key value.

func (BindingValidationError) Reason 

func (e BindingValidationError) Reason() string

Reason function returns reason value.

type Blob 

type Blob struct {
	Metadata             *BlobMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Uri                  string        `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Refers to an offloaded set of files. It encapsulates the type of the store and a unique uri for where the data is. There are no restrictions on how the uri is formatted since it will depend on how to interact with the store.

func (*Blob) Descriptor 

func (*Blob) Descriptor() ([]byte, []int)

func (*Blob) GetMetadata 

func (m *Blob) GetMetadata() *BlobMetadata

func (*Blob) GetUri 

func (m *Blob) GetUri() string

func (*Blob) ProtoMessage 

func (*Blob) ProtoMessage()

func (*Blob) Reset 

func (m *Blob) Reset()

func (*Blob) String 

func (m *Blob) String() string

func (*Blob) Validate 

func (m *Blob) Validate() error

Validate checks the field values on Blob with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Blob) XXX_DiscardUnknown 

func (m *Blob) XXX_DiscardUnknown()

func (*Blob) XXX_Marshal 

func (m *Blob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Blob) XXX_Merge 

func (dst *Blob) XXX_Merge(src proto.Message)

func (*Blob) XXX_Size 

func (m *Blob) XXX_Size() int

func (*Blob) XXX_Unmarshal 

func (m *Blob) XXX_Unmarshal(b []byte) error

type BlobMetadata 

type BlobMetadata struct {
	Type                 *BlobType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*BlobMetadata) Descriptor 

func (*BlobMetadata) Descriptor() ([]byte, []int)

func (*BlobMetadata) GetType 

func (m *BlobMetadata) GetType() *BlobType

func (*BlobMetadata) ProtoMessage 

func (*BlobMetadata) ProtoMessage()

func (*BlobMetadata) Reset 

func (m *BlobMetadata) Reset()

func (*BlobMetadata) String 

func (m *BlobMetadata) String() string

func (*BlobMetadata) Validate 

func (m *BlobMetadata) Validate() error

Validate checks the field values on BlobMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*BlobMetadata) XXX_DiscardUnknown 

func (m *BlobMetadata) XXX_DiscardUnknown()

func (*BlobMetadata) XXX_Marshal 

func (m *BlobMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlobMetadata) XXX_Merge 

func (dst *BlobMetadata) XXX_Merge(src proto.Message)

func (*BlobMetadata) XXX_Size 

func (m *BlobMetadata) XXX_Size() int

func (*BlobMetadata) XXX_Unmarshal 

func (m *BlobMetadata) XXX_Unmarshal(b []byte) error

type BlobMetadataValidationError 

type BlobMetadataValidationError struct {
	// contains filtered or unexported fields
}

BlobMetadataValidationError is the validation error returned by BlobMetadata.Validate if the designated constraints aren't met.

func (BlobMetadataValidationError) Cause 

func (e BlobMetadataValidationError) Cause() error

Cause function returns cause value.

func (BlobMetadataValidationError) Error 

func (e BlobMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (BlobMetadataValidationError) ErrorName 

func (e BlobMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (BlobMetadataValidationError) Field 

func (e BlobMetadataValidationError) Field() string

Field function returns field value.

func (BlobMetadataValidationError) Key 

func (e BlobMetadataValidationError) Key() bool

Key function returns key value.

func (BlobMetadataValidationError) Reason 

func (e BlobMetadataValidationError) Reason() string

Reason function returns reason value.

type BlobType 

type BlobType struct {
	// Format can be a free form string understood by SDK/UI etc like
	// csv, parquet etc
	Format               string                      `protobuf:"bytes,1,opt,name=format,proto3" json:"format,omitempty"`
	Dimensionality       BlobType_BlobDimensionality `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Defines type behavior for blob objects

func (*BlobType) Descriptor 

func (*BlobType) Descriptor() ([]byte, []int)

func (*BlobType) GetDimensionality 

func (m *BlobType) GetDimensionality() BlobType_BlobDimensionality

func (*BlobType) GetFormat 

func (m *BlobType) GetFormat() string

func (*BlobType) ProtoMessage 

func (*BlobType) ProtoMessage()

func (*BlobType) Reset 

func (m *BlobType) Reset()

func (*BlobType) String 

func (m *BlobType) String() string

func (*BlobType) Validate 

func (m *BlobType) Validate() error

Validate checks the field values on BlobType with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*BlobType) XXX_DiscardUnknown 

func (m *BlobType) XXX_DiscardUnknown()

func (*BlobType) XXX_Marshal 

func (m *BlobType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlobType) XXX_Merge 

func (dst *BlobType) XXX_Merge(src proto.Message)

func (*BlobType) XXX_Size 

func (m *BlobType) XXX_Size() int

func (*BlobType) XXX_Unmarshal 

func (m *BlobType) XXX_Unmarshal(b []byte) error

type BlobTypeValidationError 

type BlobTypeValidationError struct {
	// contains filtered or unexported fields
}

BlobTypeValidationError is the validation error returned by BlobType.Validate if the designated constraints aren't met.

func (BlobTypeValidationError) Cause 

func (e BlobTypeValidationError) Cause() error

Cause function returns cause value.

func (BlobTypeValidationError) Error 

func (e BlobTypeValidationError) Error() string

Error satisfies the builtin error interface

func (BlobTypeValidationError) ErrorName 

func (e BlobTypeValidationError) ErrorName() string

ErrorName returns error name.

func (BlobTypeValidationError) Field 

func (e BlobTypeValidationError) Field() string

Field function returns field value.

func (BlobTypeValidationError) Key 

func (e BlobTypeValidationError) Key() bool

Key function returns key value.

func (BlobTypeValidationError) Reason 

func (e BlobTypeValidationError) Reason() string

Reason function returns reason value.

type BlobType_BlobDimensionality 

type BlobType_BlobDimensionality int32
const (
	BlobType_SINGLE    BlobType_BlobDimensionality = 0
	BlobType_MULTIPART BlobType_BlobDimensionality = 1
)

func (BlobType_BlobDimensionality) EnumDescriptor 

func (BlobType_BlobDimensionality) EnumDescriptor() ([]byte, []int)

func (BlobType_BlobDimensionality) String 

func (x BlobType_BlobDimensionality) String() string

type BlobValidationError 

type BlobValidationError struct {
	// contains filtered or unexported fields
}

BlobValidationError is the validation error returned by Blob.Validate if the designated constraints aren't met.

func (BlobValidationError) Cause 

func (e BlobValidationError) Cause() error

Cause function returns cause value.

func (BlobValidationError) Error 

func (e BlobValidationError) Error() string

Error satisfies the builtin error interface

func (BlobValidationError) ErrorName 

func (e BlobValidationError) ErrorName() string

ErrorName returns error name.

func (BlobValidationError) Field 

func (e BlobValidationError) Field() string

Field function returns field value.

func (BlobValidationError) Key 

func (e BlobValidationError) Key() bool

Key function returns key value.

func (BlobValidationError) Reason 

func (e BlobValidationError) Reason() string

Reason function returns reason value.

type BooleanExpression 

type BooleanExpression struct {
	// Types that are valid to be assigned to Expr:
	//	*BooleanExpression_Conjunction
	//	*BooleanExpression_Comparison
	Expr                 isBooleanExpression_Expr `protobuf_oneof:"expr"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Defines a boolean expression tree. It can be a simple or a conjunction expression. Multiple expressions can be combined using a conjunction or a disjunction to result in a final boolean result.

func (*BooleanExpression) Descriptor 

func (*BooleanExpression) Descriptor() ([]byte, []int)

func (*BooleanExpression) GetComparison 

func (m *BooleanExpression) GetComparison() *ComparisonExpression

func (*BooleanExpression) GetConjunction 

func (m *BooleanExpression) GetConjunction() *ConjunctionExpression

func (*BooleanExpression) GetExpr 

func (m *BooleanExpression) GetExpr() isBooleanExpression_Expr

func (*BooleanExpression) ProtoMessage 

func (*BooleanExpression) ProtoMessage()

func (*BooleanExpression) Reset 

func (m *BooleanExpression) Reset()

func (*BooleanExpression) String 

func (m *BooleanExpression) String() string

func (*BooleanExpression) Validate 

func (m *BooleanExpression) Validate() error

Validate checks the field values on BooleanExpression with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*BooleanExpression) XXX_DiscardUnknown 

func (m *BooleanExpression) XXX_DiscardUnknown()

func (*BooleanExpression) XXX_Marshal 

func (m *BooleanExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BooleanExpression) XXX_Merge 

func (dst *BooleanExpression) XXX_Merge(src proto.Message)

func (*BooleanExpression) XXX_OneofFuncs 

func (*BooleanExpression) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*BooleanExpression) XXX_Size 

func (m *BooleanExpression) XXX_Size() int

func (*BooleanExpression) XXX_Unmarshal 

func (m *BooleanExpression) XXX_Unmarshal(b []byte) error

type BooleanExpressionValidationError 

type BooleanExpressionValidationError struct {
	// contains filtered or unexported fields
}

BooleanExpressionValidationError is the validation error returned by BooleanExpression.Validate if the designated constraints aren't met.

func (BooleanExpressionValidationError) Cause 

func (e BooleanExpressionValidationError) Cause() error

Cause function returns cause value.

func (BooleanExpressionValidationError) Error 

func (e BooleanExpressionValidationError) Error() string

Error satisfies the builtin error interface

func (BooleanExpressionValidationError) ErrorName 

func (e BooleanExpressionValidationError) ErrorName() string

ErrorName returns error name.

func (BooleanExpressionValidationError) Field 

func (e BooleanExpressionValidationError) Field() string

Field function returns field value.

func (BooleanExpressionValidationError) Key 

func (e BooleanExpressionValidationError) Key() bool

Key function returns key value.

func (BooleanExpressionValidationError) Reason 

func (e BooleanExpressionValidationError) Reason() string

Reason function returns reason value.

type BooleanExpression_Comparison 

type BooleanExpression_Comparison struct {
	Comparison *ComparisonExpression `protobuf:"bytes,2,opt,name=comparison,proto3,oneof"`
}

type BooleanExpression_Conjunction 

type BooleanExpression_Conjunction struct {
	Conjunction *ConjunctionExpression `protobuf:"bytes,1,opt,name=conjunction,proto3,oneof"`
}

type BranchNode 

type BranchNode struct {
	// +required
	IfElse               *IfElseBlock `protobuf:"bytes,1,opt,name=if_else,json=ifElse,proto3" json:"if_else,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

BranchNode is a special node that alter the flow of the workflow graph. It allows the control flow to branch at runtime based on a series of conditions that get evaluated on various parameters (e.g. inputs, primtives).

func (*BranchNode) Descriptor 

func (*BranchNode) Descriptor() ([]byte, []int)

func (*BranchNode) GetIfElse 

func (m *BranchNode) GetIfElse() *IfElseBlock

func (*BranchNode) ProtoMessage 

func (*BranchNode) ProtoMessage()

func (*BranchNode) Reset 

func (m *BranchNode) Reset()

func (*BranchNode) String 

func (m *BranchNode) String() string

func (*BranchNode) Validate 

func (m *BranchNode) Validate() error

Validate checks the field values on BranchNode with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*BranchNode) XXX_DiscardUnknown 

func (m *BranchNode) XXX_DiscardUnknown()

func (*BranchNode) XXX_Marshal 

func (m *BranchNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BranchNode) XXX_Merge 

func (dst *BranchNode) XXX_Merge(src proto.Message)

func (*BranchNode) XXX_Size 

func (m *BranchNode) XXX_Size() int

func (*BranchNode) XXX_Unmarshal 

func (m *BranchNode) XXX_Unmarshal(b []byte) error

type BranchNodeValidationError 

type BranchNodeValidationError struct {
	// contains filtered or unexported fields
}

BranchNodeValidationError is the validation error returned by BranchNode.Validate if the designated constraints aren't met.

func (BranchNodeValidationError) Cause 

func (e BranchNodeValidationError) Cause() error

Cause function returns cause value.

func (BranchNodeValidationError) Error 

func (e BranchNodeValidationError) Error() string

Error satisfies the builtin error interface

func (BranchNodeValidationError) ErrorName 

func (e BranchNodeValidationError) ErrorName() string

ErrorName returns error name.

func (BranchNodeValidationError) Field 

func (e BranchNodeValidationError) Field() string

Field function returns field value.

func (BranchNodeValidationError) Key 

func (e BranchNodeValidationError) Key() bool

Key function returns key value.

func (BranchNodeValidationError) Reason 

func (e BranchNodeValidationError) Reason() string

Reason function returns reason value.

type ComparisonExpression 

type ComparisonExpression struct {
	Operator             ComparisonExpression_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=flyteidl.core.ComparisonExpression_Operator" json:"operator,omitempty"`
	LeftValue            *Operand                      `protobuf:"bytes,2,opt,name=left_value,json=leftValue,proto3" json:"left_value,omitempty"`
	RightValue           *Operand                      `protobuf:"bytes,3,opt,name=right_value,json=rightValue,proto3" json:"right_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

Defines a 2-level tree where the root is a comparison operator and Operands are primitives or known variables. Each expression results in a boolean result.

func (*ComparisonExpression) Descriptor 

func (*ComparisonExpression) Descriptor() ([]byte, []int)

func (*ComparisonExpression) GetLeftValue 

func (m *ComparisonExpression) GetLeftValue() *Operand

func (*ComparisonExpression) GetOperator 

func (m *ComparisonExpression) GetOperator() ComparisonExpression_Operator

func (*ComparisonExpression) GetRightValue 

func (m *ComparisonExpression) GetRightValue() *Operand

func (*ComparisonExpression) ProtoMessage 

func (*ComparisonExpression) ProtoMessage()

func (*ComparisonExpression) Reset 

func (m *ComparisonExpression) Reset()

func (*ComparisonExpression) String 

func (m *ComparisonExpression) String() string

func (*ComparisonExpression) Validate 

func (m *ComparisonExpression) Validate() error

Validate checks the field values on ComparisonExpression with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ComparisonExpression) XXX_DiscardUnknown 

func (m *ComparisonExpression) XXX_DiscardUnknown()

func (*ComparisonExpression) XXX_Marshal 

func (m *ComparisonExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ComparisonExpression) XXX_Merge 

func (dst *ComparisonExpression) XXX_Merge(src proto.Message)

func (*ComparisonExpression) XXX_Size 

func (m *ComparisonExpression) XXX_Size() int

func (*ComparisonExpression) XXX_Unmarshal 

func (m *ComparisonExpression) XXX_Unmarshal(b []byte) error

type ComparisonExpressionValidationError 

type ComparisonExpressionValidationError struct {
	// contains filtered or unexported fields
}

ComparisonExpressionValidationError is the validation error returned by ComparisonExpression.Validate if the designated constraints aren't met.

func (ComparisonExpressionValidationError) Cause 

func (e ComparisonExpressionValidationError) Cause() error

Cause function returns cause value.

func (ComparisonExpressionValidationError) Error 

func (e ComparisonExpressionValidationError) Error() string

Error satisfies the builtin error interface

func (ComparisonExpressionValidationError) ErrorName 

func (e ComparisonExpressionValidationError) ErrorName() string

ErrorName returns error name.

func (ComparisonExpressionValidationError) Field 

func (e ComparisonExpressionValidationError) Field() string

Field function returns field value.

func (ComparisonExpressionValidationError) Key 

func (e ComparisonExpressionValidationError) Key() bool

Key function returns key value.

func (ComparisonExpressionValidationError) Reason 

func (e ComparisonExpressionValidationError) Reason() string

Reason function returns reason value.

type ComparisonExpression_Operator 

type ComparisonExpression_Operator int32

Binary Operator for each expression 

const (
	ComparisonExpression_EQ  ComparisonExpression_Operator = 0
	ComparisonExpression_NEQ ComparisonExpression_Operator = 1
	// Greater Than
	ComparisonExpression_GT  ComparisonExpression_Operator = 2
	ComparisonExpression_GTE ComparisonExpression_Operator = 3
	// Less Than
	ComparisonExpression_LT  ComparisonExpression_Operator = 4
	ComparisonExpression_LTE ComparisonExpression_Operator = 5
)

func (ComparisonExpression_Operator) EnumDescriptor 

func (ComparisonExpression_Operator) EnumDescriptor() ([]byte, []int)

func (ComparisonExpression_Operator) String 

func (x ComparisonExpression_Operator) String() string

type CompiledTask 

type CompiledTask struct {
	// Completely contained TaskTemplate
	Template             *TaskTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Output of the Compilation step. This object represent one Task. We store more metadata at this layer

func (*CompiledTask) Descriptor 

func (*CompiledTask) Descriptor() ([]byte, []int)

func (*CompiledTask) GetTemplate 

func (m *CompiledTask) GetTemplate() *TaskTemplate

func (*CompiledTask) ProtoMessage 

func (*CompiledTask) ProtoMessage()

func (*CompiledTask) Reset 

func (m *CompiledTask) Reset()

func (*CompiledTask) String 

func (m *CompiledTask) String() string

func (*CompiledTask) Validate 

func (m *CompiledTask) Validate() error

Validate checks the field values on CompiledTask with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*CompiledTask) XXX_DiscardUnknown 

func (m *CompiledTask) XXX_DiscardUnknown()

func (*CompiledTask) XXX_Marshal 

func (m *CompiledTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompiledTask) XXX_Merge 

func (dst *CompiledTask) XXX_Merge(src proto.Message)

func (*CompiledTask) XXX_Size 

func (m *CompiledTask) XXX_Size() int

func (*CompiledTask) XXX_Unmarshal 

func (m *CompiledTask) XXX_Unmarshal(b []byte) error

type CompiledTaskValidationError 

type CompiledTaskValidationError struct {
	// contains filtered or unexported fields
}

CompiledTaskValidationError is the validation error returned by CompiledTask.Validate if the designated constraints aren't met.

func (CompiledTaskValidationError) Cause 

func (e CompiledTaskValidationError) Cause() error

Cause function returns cause value.

func (CompiledTaskValidationError) Error 

func (e CompiledTaskValidationError) Error() string

Error satisfies the builtin error interface

func (CompiledTaskValidationError) ErrorName 

func (e CompiledTaskValidationError) ErrorName() string

ErrorName returns error name.

func (CompiledTaskValidationError) Field 

func (e CompiledTaskValidationError) Field() string

Field function returns field value.

func (CompiledTaskValidationError) Key 

func (e CompiledTaskValidationError) Key() bool

Key function returns key value.

func (CompiledTaskValidationError) Reason 

func (e CompiledTaskValidationError) Reason() string

Reason function returns reason value.

type CompiledWorkflow 

type CompiledWorkflow struct {
	// Completely contained Workflow Template
	Template *WorkflowTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// For internal use only! This field is used by the system and must not be filled in. Any values set will be ignored.
	Connections          *ConnectionSet `protobuf:"bytes,2,opt,name=connections,proto3" json:"connections,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Output of the compilation Step. This object represents one workflow. We store more metadata at this layer

func (*CompiledWorkflow) Descriptor 

func (*CompiledWorkflow) Descriptor() ([]byte, []int)

func (*CompiledWorkflow) GetConnections 

func (m *CompiledWorkflow) GetConnections() *ConnectionSet

func (*CompiledWorkflow) GetTemplate 

func (m *CompiledWorkflow) GetTemplate() *WorkflowTemplate

func (*CompiledWorkflow) ProtoMessage 

func (*CompiledWorkflow) ProtoMessage()

func (*CompiledWorkflow) Reset 

func (m *CompiledWorkflow) Reset()

func (*CompiledWorkflow) String 

func (m *CompiledWorkflow) String() string

func (*CompiledWorkflow) Validate 

func (m *CompiledWorkflow) Validate() error

Validate checks the field values on CompiledWorkflow with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*CompiledWorkflow) XXX_DiscardUnknown 

func (m *CompiledWorkflow) XXX_DiscardUnknown()

func (*CompiledWorkflow) XXX_Marshal 

func (m *CompiledWorkflow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompiledWorkflow) XXX_Merge 

func (dst *CompiledWorkflow) XXX_Merge(src proto.Message)

func (*CompiledWorkflow) XXX_Size 

func (m *CompiledWorkflow) XXX_Size() int

func (*CompiledWorkflow) XXX_Unmarshal 

func (m *CompiledWorkflow) XXX_Unmarshal(b []byte) error

type CompiledWorkflowClosure 

type CompiledWorkflowClosure struct {
	// +required
	Primary *CompiledWorkflow `protobuf:"bytes,1,opt,name=primary,proto3" json:"primary,omitempty"`
	// Guaranteed that there will only exist one and only one workflow with a given id, i.e., every sub workflow has a
	// unique identifier. Also every enclosed subworkflow is used either by a primary workflow or by a subworkflow
	// as an inlined workflow
	// +optional
	SubWorkflows []*CompiledWorkflow `protobuf:"bytes,2,rep,name=sub_workflows,json=subWorkflows,proto3" json:"sub_workflows,omitempty"`
	// Guaranteed that there will only exist one and only one task with a given id, i.e., every task has a unique id
	// +required (atleast 1)
	Tasks                []*CompiledTask `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

A Compiled Workflow Closure contains all the information required to start a new execution, or to visualize a workflow and its details. The CompiledWorkflowClosure should always contain a primary workflow, that is the main workflow that will being the execution. All subworkflows are denormalized. WorkflowNodes refer to the workflow identifiers of compiled subworkflows.

func (*CompiledWorkflowClosure) Descriptor 

func (*CompiledWorkflowClosure) Descriptor() ([]byte, []int)

func (*CompiledWorkflowClosure) GetPrimary 

func (m *CompiledWorkflowClosure) GetPrimary() *CompiledWorkflow

func (*CompiledWorkflowClosure) GetSubWorkflows 

func (m *CompiledWorkflowClosure) GetSubWorkflows() []*CompiledWorkflow

func (*CompiledWorkflowClosure) GetTasks 

func (m *CompiledWorkflowClosure) GetTasks() []*CompiledTask

func (*CompiledWorkflowClosure) ProtoMessage 

func (*CompiledWorkflowClosure) ProtoMessage()

func (*CompiledWorkflowClosure) Reset 

func (m *CompiledWorkflowClosure) Reset()

func (*CompiledWorkflowClosure) String 

func (m *CompiledWorkflowClosure) String() string

func (*CompiledWorkflowClosure) Validate 

func (m *CompiledWorkflowClosure) Validate() error

Validate checks the field values on CompiledWorkflowClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*CompiledWorkflowClosure) XXX_DiscardUnknown 

func (m *CompiledWorkflowClosure) XXX_DiscardUnknown()

func (*CompiledWorkflowClosure) XXX_Marshal 

func (m *CompiledWorkflowClosure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CompiledWorkflowClosure) XXX_Merge 

func (dst *CompiledWorkflowClosure) XXX_Merge(src proto.Message)

func (*CompiledWorkflowClosure) XXX_Size 

func (m *CompiledWorkflowClosure) XXX_Size() int

func (*CompiledWorkflowClosure) XXX_Unmarshal 

func (m *CompiledWorkflowClosure) XXX_Unmarshal(b []byte) error

type CompiledWorkflowClosureValidationError 

type CompiledWorkflowClosureValidationError struct {
	// contains filtered or unexported fields
}

CompiledWorkflowClosureValidationError is the validation error returned by CompiledWorkflowClosure.Validate if the designated constraints aren't met.

func (CompiledWorkflowClosureValidationError) Cause 

func (e CompiledWorkflowClosureValidationError) Cause() error

Cause function returns cause value.

func (CompiledWorkflowClosureValidationError) Error 

func (e CompiledWorkflowClosureValidationError) Error() string

Error satisfies the builtin error interface

func (CompiledWorkflowClosureValidationError) ErrorName 

func (e CompiledWorkflowClosureValidationError) ErrorName() string

ErrorName returns error name.

func (CompiledWorkflowClosureValidationError) Field 

func (e CompiledWorkflowClosureValidationError) Field() string

Field function returns field value.

func (CompiledWorkflowClosureValidationError) Key 

func (e CompiledWorkflowClosureValidationError) Key() bool

Key function returns key value.

func (CompiledWorkflowClosureValidationError) Reason 

func (e CompiledWorkflowClosureValidationError) Reason() string

Reason function returns reason value.

type CompiledWorkflowValidationError 

type CompiledWorkflowValidationError struct {
	// contains filtered or unexported fields
}

CompiledWorkflowValidationError is the validation error returned by CompiledWorkflow.Validate if the designated constraints aren't met.

func (CompiledWorkflowValidationError) Cause 

func (e CompiledWorkflowValidationError) Cause() error

Cause function returns cause value.

func (CompiledWorkflowValidationError) Error 

func (e CompiledWorkflowValidationError) Error() string

Error satisfies the builtin error interface

func (CompiledWorkflowValidationError) ErrorName 

func (e CompiledWorkflowValidationError) ErrorName() string

ErrorName returns error name.

func (CompiledWorkflowValidationError) Field 

func (e CompiledWorkflowValidationError) Field() string

Field function returns field value.

func (CompiledWorkflowValidationError) Key 

func (e CompiledWorkflowValidationError) Key() bool

Key function returns key value.

func (CompiledWorkflowValidationError) Reason 

func (e CompiledWorkflowValidationError) Reason() string

Reason function returns reason value.

type ConjunctionExpression 

type ConjunctionExpression struct {
	Operator             ConjunctionExpression_LogicalOperator `` /* 127-byte string literal not displayed */
	LeftExpression       *BooleanExpression                    `protobuf:"bytes,2,opt,name=left_expression,json=leftExpression,proto3" json:"left_expression,omitempty"`
	RightExpression      *BooleanExpression                    `protobuf:"bytes,3,opt,name=right_expression,json=rightExpression,proto3" json:"right_expression,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

Defines a conjunction expression of two boolean expressions.

func (*ConjunctionExpression) Descriptor 

func (*ConjunctionExpression) Descriptor() ([]byte, []int)

func (*ConjunctionExpression) GetLeftExpression 

func (m *ConjunctionExpression) GetLeftExpression() *BooleanExpression

func (*ConjunctionExpression) GetOperator 

func (m *ConjunctionExpression) GetOperator() ConjunctionExpression_LogicalOperator

func (*ConjunctionExpression) GetRightExpression 

func (m *ConjunctionExpression) GetRightExpression() *BooleanExpression

func (*ConjunctionExpression) ProtoMessage 

func (*ConjunctionExpression) ProtoMessage()

func (*ConjunctionExpression) Reset 

func (m *ConjunctionExpression) Reset()

func (*ConjunctionExpression) String 

func (m *ConjunctionExpression) String() string

func (*ConjunctionExpression) Validate 

func (m *ConjunctionExpression) Validate() error

Validate checks the field values on ConjunctionExpression with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ConjunctionExpression) XXX_DiscardUnknown 

func (m *ConjunctionExpression) XXX_DiscardUnknown()

func (*ConjunctionExpression) XXX_Marshal 

func (m *ConjunctionExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConjunctionExpression) XXX_Merge 

func (dst *ConjunctionExpression) XXX_Merge(src proto.Message)

func (*ConjunctionExpression) XXX_Size 

func (m *ConjunctionExpression) XXX_Size() int

func (*ConjunctionExpression) XXX_Unmarshal 

func (m *ConjunctionExpression) XXX_Unmarshal(b []byte) error

type ConjunctionExpressionValidationError 

type ConjunctionExpressionValidationError struct {
	// contains filtered or unexported fields
}

ConjunctionExpressionValidationError is the validation error returned by ConjunctionExpression.Validate if the designated constraints aren't met.

func (ConjunctionExpressionValidationError) Cause 

func (e ConjunctionExpressionValidationError) Cause() error

Cause function returns cause value.

func (ConjunctionExpressionValidationError) Error 

func (e ConjunctionExpressionValidationError) Error() string

Error satisfies the builtin error interface

func (ConjunctionExpressionValidationError) ErrorName 

func (e ConjunctionExpressionValidationError) ErrorName() string

ErrorName returns error name.

func (ConjunctionExpressionValidationError) Field 

func (e ConjunctionExpressionValidationError) Field() string

Field function returns field value.

func (ConjunctionExpressionValidationError) Key 

func (e ConjunctionExpressionValidationError) Key() bool

Key function returns key value.

func (ConjunctionExpressionValidationError) Reason 

func (e ConjunctionExpressionValidationError) Reason() string

Reason function returns reason value.

type ConjunctionExpression_LogicalOperator 

type ConjunctionExpression_LogicalOperator int32

Nested conditions. They can be conjoined using AND / OR Order of evaluation is not important as the operators are Commutative 

const (
	// Conjunction
	ConjunctionExpression_AND ConjunctionExpression_LogicalOperator = 0
	ConjunctionExpression_OR  ConjunctionExpression_LogicalOperator = 1
)

func (ConjunctionExpression_LogicalOperator) EnumDescriptor 

func (ConjunctionExpression_LogicalOperator) EnumDescriptor() ([]byte, []int)

func (ConjunctionExpression_LogicalOperator) String 

func (x ConjunctionExpression_LogicalOperator) String() string

type ConnectionSet 

type ConnectionSet struct {
	// A list of all the node ids that are downstream from a given node id
	Downstream map[string]*ConnectionSet_IdList `` /* 161-byte string literal not displayed */
	// A list of all the node ids, that are upstream of this node id
	Upstream             map[string]*ConnectionSet_IdList `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

Adjacency list for the workflow. This is created as part of the compilation process. Every process after the compilation step uses this created ConnectionSet

func (*ConnectionSet) Descriptor 

func (*ConnectionSet) Descriptor() ([]byte, []int)

func (*ConnectionSet) GetDownstream 

func (m *ConnectionSet) GetDownstream() map[string]*ConnectionSet_IdList

func (*ConnectionSet) GetUpstream 

func (m *ConnectionSet) GetUpstream() map[string]*ConnectionSet_IdList

func (*ConnectionSet) ProtoMessage 

func (*ConnectionSet) ProtoMessage()

func (*ConnectionSet) Reset 

func (m *ConnectionSet) Reset()

func (*ConnectionSet) String 

func (m *ConnectionSet) String() string

func (*ConnectionSet) Validate 

func (m *ConnectionSet) Validate() error

Validate checks the field values on ConnectionSet with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ConnectionSet) XXX_DiscardUnknown 

func (m *ConnectionSet) XXX_DiscardUnknown()

func (*ConnectionSet) XXX_Marshal 

func (m *ConnectionSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionSet) XXX_Merge 

func (dst *ConnectionSet) XXX_Merge(src proto.Message)

func (*ConnectionSet) XXX_Size 

func (m *ConnectionSet) XXX_Size() int

func (*ConnectionSet) XXX_Unmarshal 

func (m *ConnectionSet) XXX_Unmarshal(b []byte) error

type ConnectionSetValidationError 

type ConnectionSetValidationError struct {
	// contains filtered or unexported fields
}

ConnectionSetValidationError is the validation error returned by ConnectionSet.Validate if the designated constraints aren't met.

func (ConnectionSetValidationError) Cause 

func (e ConnectionSetValidationError) Cause() error

Cause function returns cause value.

func (ConnectionSetValidationError) Error 

func (e ConnectionSetValidationError) Error() string

Error satisfies the builtin error interface

func (ConnectionSetValidationError) ErrorName 

func (e ConnectionSetValidationError) ErrorName() string

ErrorName returns error name.

func (ConnectionSetValidationError) Field 

func (e ConnectionSetValidationError) Field() string

Field function returns field value.

func (ConnectionSetValidationError) Key 

func (e ConnectionSetValidationError) Key() bool

Key function returns key value.

func (ConnectionSetValidationError) Reason 

func (e ConnectionSetValidationError) Reason() string

Reason function returns reason value.

type ConnectionSet_IdList 

type ConnectionSet_IdList struct {
	Ids                  []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConnectionSet_IdList) Descriptor 

func (*ConnectionSet_IdList) Descriptor() ([]byte, []int)

func (*ConnectionSet_IdList) GetIds 

func (m *ConnectionSet_IdList) GetIds() []string

func (*ConnectionSet_IdList) ProtoMessage 

func (*ConnectionSet_IdList) ProtoMessage()

func (*ConnectionSet_IdList) Reset 

func (m *ConnectionSet_IdList) Reset()

func (*ConnectionSet_IdList) String 

func (m *ConnectionSet_IdList) String() string

func (*ConnectionSet_IdList) Validate 

func (m *ConnectionSet_IdList) Validate() error

Validate checks the field values on ConnectionSet_IdList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ConnectionSet_IdList) XXX_DiscardUnknown 

func (m *ConnectionSet_IdList) XXX_DiscardUnknown()

func (*ConnectionSet_IdList) XXX_Marshal 

func (m *ConnectionSet_IdList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionSet_IdList) XXX_Merge 

func (dst *ConnectionSet_IdList) XXX_Merge(src proto.Message)

func (*ConnectionSet_IdList) XXX_Size 

func (m *ConnectionSet_IdList) XXX_Size() int

func (*ConnectionSet_IdList) XXX_Unmarshal 

func (m *ConnectionSet_IdList) XXX_Unmarshal(b []byte) error

type ConnectionSet_IdListValidationError 

type ConnectionSet_IdListValidationError struct {
	// contains filtered or unexported fields
}

ConnectionSet_IdListValidationError is the validation error returned by ConnectionSet_IdList.Validate if the designated constraints aren't met.

func (ConnectionSet_IdListValidationError) Cause 

func (e ConnectionSet_IdListValidationError) Cause() error

Cause function returns cause value.

func (ConnectionSet_IdListValidationError) Error 

func (e ConnectionSet_IdListValidationError) Error() string

Error satisfies the builtin error interface

func (ConnectionSet_IdListValidationError) ErrorName 

func (e ConnectionSet_IdListValidationError) ErrorName() string

ErrorName returns error name.

func (ConnectionSet_IdListValidationError) Field 

func (e ConnectionSet_IdListValidationError) Field() string

Field function returns field value.

func (ConnectionSet_IdListValidationError) Key 

func (e ConnectionSet_IdListValidationError) Key() bool

Key function returns key value.

func (ConnectionSet_IdListValidationError) Reason 

func (e ConnectionSet_IdListValidationError) Reason() string

Reason function returns reason value.

type Container 

type Container struct {
	// Container image url. Eg: docker/redis:latest
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// Command to be executed, if not provided, the default entrypoint in the container image will be used.
	Command []string `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty"`
	// These will default to Flyte given paths. If provided, the system will not append known paths. If the task still
	// needs flyte's inputs and outputs path, add $(FLYTE_INPUT_FILE), $(FLYTE_OUTPUT_FILE) wherever makes sense and the
	// system will populate these before executing the container.
	Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// Container resources requirement as specified by the container engine.
	Resources *Resources `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"`
	// Environment variables will be set as the container is starting up.
	Env []*KeyValuePair `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	// Allows extra configs to be available for the container.
	// TODO: elaborate on how configs will become available.
	Config []*KeyValuePair `protobuf:"bytes,6,rep,name=config,proto3" json:"config,omitempty"`
	// Ports to open in the container. This feature is not supported by all execution engines. (e.g. supported on K8s but
	// not supported on AWS Batch)
	Ports                []*ContainerPort `protobuf:"bytes,7,rep,name=ports,proto3" json:"ports,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Container) Descriptor 

func (*Container) Descriptor() ([]byte, []int)

func (*Container) GetArgs 

func (m *Container) GetArgs() []string

func (*Container) GetCommand 

func (m *Container) GetCommand() []string

func (*Container) GetConfig 

func (m *Container) GetConfig() []*KeyValuePair

func (*Container) GetEnv 

func (m *Container) GetEnv() []*KeyValuePair

func (*Container) GetImage 

func (m *Container) GetImage() string

func (*Container) GetPorts 

func (m *Container) GetPorts() []*ContainerPort

func (*Container) GetResources 

func (m *Container) GetResources() *Resources

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) String 

func (m *Container) String() string

func (*Container) Validate 

func (m *Container) Validate() error

Validate checks the field values on Container with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Container) XXX_DiscardUnknown 

func (m *Container) XXX_DiscardUnknown()

func (*Container) XXX_Marshal 

func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Container) XXX_Merge 

func (dst *Container) XXX_Merge(src proto.Message)

func (*Container) XXX_Size 

func (m *Container) XXX_Size() int

func (*Container) XXX_Unmarshal 

func (m *Container) XXX_Unmarshal(b []byte) error

type ContainerError 

type ContainerError struct {
	// A simplified code for errors, so that we can provide a glossary of all possible errors.
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// A detailed error message.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// An abstract error kind for this error. Defaults to Non_Recoverable if not specified.
	Kind                 ContainerError_Kind `protobuf:"varint,3,opt,name=kind,proto3,enum=flyteidl.core.ContainerError_Kind" json:"kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Error message to propagate detailed errors from container executions to the execution engine.

func (*ContainerError) Descriptor 

func (*ContainerError) Descriptor() ([]byte, []int)

func (*ContainerError) GetCode 

func (m *ContainerError) GetCode() string

func (*ContainerError) GetKind 

func (m *ContainerError) GetKind() ContainerError_Kind

func (*ContainerError) GetMessage 

func (m *ContainerError) GetMessage() string

func (*ContainerError) ProtoMessage 

func (*ContainerError) ProtoMessage()

func (*ContainerError) Reset 

func (m *ContainerError) Reset()

func (*ContainerError) String 

func (m *ContainerError) String() string

func (*ContainerError) Validate 

func (m *ContainerError) Validate() error

Validate checks the field values on ContainerError with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ContainerError) XXX_DiscardUnknown 

func (m *ContainerError) XXX_DiscardUnknown()

func (*ContainerError) XXX_Marshal 

func (m *ContainerError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerError) XXX_Merge 

func (dst *ContainerError) XXX_Merge(src proto.Message)

func (*ContainerError) XXX_Size 

func (m *ContainerError) XXX_Size() int

func (*ContainerError) XXX_Unmarshal 

func (m *ContainerError) XXX_Unmarshal(b []byte) error

type ContainerErrorValidationError 

type ContainerErrorValidationError struct {
	// contains filtered or unexported fields
}

ContainerErrorValidationError is the validation error returned by ContainerError.Validate if the designated constraints aren't met.

func (ContainerErrorValidationError) Cause 

func (e ContainerErrorValidationError) Cause() error

Cause function returns cause value.

func (ContainerErrorValidationError) Error 

func (e ContainerErrorValidationError) Error() string

Error satisfies the builtin error interface

func (ContainerErrorValidationError) ErrorName 

func (e ContainerErrorValidationError) ErrorName() string

ErrorName returns error name.

func (ContainerErrorValidationError) Field 

func (e ContainerErrorValidationError) Field() string

Field function returns field value.

func (ContainerErrorValidationError) Key 

func (e ContainerErrorValidationError) Key() bool

Key function returns key value.

func (ContainerErrorValidationError) Reason 

func (e ContainerErrorValidationError) Reason() string

Reason function returns reason value.

type ContainerError_Kind 

type ContainerError_Kind int32

Defines a generic error type that dictates the behavior of the retry strategy. 

const (
	ContainerError_NON_RECOVERABLE ContainerError_Kind = 0
	ContainerError_RECOVERABLE     ContainerError_Kind = 1
)

func (ContainerError_Kind) EnumDescriptor 

func (ContainerError_Kind) EnumDescriptor() ([]byte, []int)

func (ContainerError_Kind) String 

func (x ContainerError_Kind) String() string

type ContainerPort 

type ContainerPort struct {
	// Number of port to expose on the pod's IP address.
	// This must be a valid port number, 0 < x < 65536.
	ContainerPort        uint32   `protobuf:"varint,1,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Defines port properties for a container.

func (*ContainerPort) Descriptor 

func (*ContainerPort) Descriptor() ([]byte, []int)

func (*ContainerPort) GetContainerPort 

func (m *ContainerPort) GetContainerPort() uint32

func (*ContainerPort) ProtoMessage 

func (*ContainerPort) ProtoMessage()

func (*ContainerPort) Reset 

func (m *ContainerPort) Reset()

func (*ContainerPort) String 

func (m *ContainerPort) String() string

func (*ContainerPort) Validate 

func (m *ContainerPort) Validate() error

Validate checks the field values on ContainerPort with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ContainerPort) XXX_DiscardUnknown 

func (m *ContainerPort) XXX_DiscardUnknown()

func (*ContainerPort) XXX_Marshal 

func (m *ContainerPort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerPort) XXX_Merge 

func (dst *ContainerPort) XXX_Merge(src proto.Message)

func (*ContainerPort) XXX_Size 

func (m *ContainerPort) XXX_Size() int

func (*ContainerPort) XXX_Unmarshal 

func (m *ContainerPort) XXX_Unmarshal(b []byte) error

type ContainerPortValidationError 

type ContainerPortValidationError struct {
	// contains filtered or unexported fields
}

ContainerPortValidationError is the validation error returned by ContainerPort.Validate if the designated constraints aren't met.

func (ContainerPortValidationError) Cause 

func (e ContainerPortValidationError) Cause() error

Cause function returns cause value.

func (ContainerPortValidationError) Error 

func (e ContainerPortValidationError) Error() string

Error satisfies the builtin error interface

func (ContainerPortValidationError) ErrorName 

func (e ContainerPortValidationError) ErrorName() string

ErrorName returns error name.

func (ContainerPortValidationError) Field 

func (e ContainerPortValidationError) Field() string

Field function returns field value.

func (ContainerPortValidationError) Key 

func (e ContainerPortValidationError) Key() bool

Key function returns key value.

func (ContainerPortValidationError) Reason 

func (e ContainerPortValidationError) Reason() string

Reason function returns reason value.

type ContainerValidationError 

type ContainerValidationError struct {
	// contains filtered or unexported fields
}

ContainerValidationError is the validation error returned by Container.Validate if the designated constraints aren't met.

func (ContainerValidationError) Cause 

func (e ContainerValidationError) Cause() error

Cause function returns cause value.

func (ContainerValidationError) Error 

func (e ContainerValidationError) Error() string

Error satisfies the builtin error interface

func (ContainerValidationError) ErrorName 

func (e ContainerValidationError) ErrorName() string

ErrorName returns error name.

func (ContainerValidationError) Field 

func (e ContainerValidationError) Field() string

Field function returns field value.

func (ContainerValidationError) Key 

func (e ContainerValidationError) Key() bool

Key function returns key value.

func (ContainerValidationError) Reason 

func (e ContainerValidationError) Reason() string

Reason function returns reason value.

type DynamicJobSpec 

type DynamicJobSpec struct {
	// A collection of nodes to execute.
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// An absolute number of successful completions of nodes required to mark this job as succeeded. As soon as this
	// criteria is met, the dynamic job will be marked as successful and outputs will be computed. If this number
	// becomes impossible to reach (e.g. number of currently running tasks + number of already succeeded tasks <
	// min_successes) the task will be aborted immediately and marked as failed. The default value of this field, if not
	// specified, is the count of nodes repeated field.
	MinSuccesses int64 `protobuf:"varint,2,opt,name=min_successes,json=minSuccesses,proto3" json:"min_successes,omitempty"`
	// Describes how to bind the final output of the dynamic job from the outputs of executed nodes. The referenced ids
	// in bindings should have the generated id for the subtask.
	Outputs []*Binding `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// [Optional] A complete list of task specs referenced in nodes.
	Tasks []*TaskTemplate `protobuf:"bytes,4,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// [Optional] A complete list of task specs referenced in nodes.
	Subworkflows         []*WorkflowTemplate `protobuf:"bytes,5,rep,name=subworkflows,proto3" json:"subworkflows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Describes a set of tasks to execute and how the final outputs are produced.

func (*DynamicJobSpec) Descriptor 

func (*DynamicJobSpec) Descriptor() ([]byte, []int)

func (*DynamicJobSpec) GetMinSuccesses 

func (m *DynamicJobSpec) GetMinSuccesses() int64

func (*DynamicJobSpec) GetNodes 

func (m *DynamicJobSpec) GetNodes() []*Node

func (*DynamicJobSpec) GetOutputs 

func (m *DynamicJobSpec) GetOutputs() []*Binding

func (*DynamicJobSpec) GetSubworkflows 

func (m *DynamicJobSpec) GetSubworkflows() []*WorkflowTemplate

func (*DynamicJobSpec) GetTasks 

func (m *DynamicJobSpec) GetTasks() []*TaskTemplate

func (*DynamicJobSpec) ProtoMessage 

func (*DynamicJobSpec) ProtoMessage()

func (*DynamicJobSpec) Reset 

func (m *DynamicJobSpec) Reset()

func (*DynamicJobSpec) String 

func (m *DynamicJobSpec) String() string

func (*DynamicJobSpec) Validate 

func (m *DynamicJobSpec) Validate() error

Validate checks the field values on DynamicJobSpec with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DynamicJobSpec) XXX_DiscardUnknown 

func (m *DynamicJobSpec) XXX_DiscardUnknown()

func (*DynamicJobSpec) XXX_Marshal 

func (m *DynamicJobSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DynamicJobSpec) XXX_Merge 

func (dst *DynamicJobSpec) XXX_Merge(src proto.Message)

func (*DynamicJobSpec) XXX_Size 

func (m *DynamicJobSpec) XXX_Size() int

func (*DynamicJobSpec) XXX_Unmarshal 

func (m *DynamicJobSpec) XXX_Unmarshal(b []byte) error

type DynamicJobSpecValidationError 

type DynamicJobSpecValidationError struct {
	// contains filtered or unexported fields
}

DynamicJobSpecValidationError is the validation error returned by DynamicJobSpec.Validate if the designated constraints aren't met.

func (DynamicJobSpecValidationError) Cause 

func (e DynamicJobSpecValidationError) Cause() error

Cause function returns cause value.

func (DynamicJobSpecValidationError) Error 

func (e DynamicJobSpecValidationError) Error() string

Error satisfies the builtin error interface

func (DynamicJobSpecValidationError) ErrorName 

func (e DynamicJobSpecValidationError) ErrorName() string

ErrorName returns error name.

func (DynamicJobSpecValidationError) Field 

func (e DynamicJobSpecValidationError) Field() string

Field function returns field value.

func (DynamicJobSpecValidationError) Key 

func (e DynamicJobSpecValidationError) Key() bool

Key function returns key value.

func (DynamicJobSpecValidationError) Reason 

func (e DynamicJobSpecValidationError) Reason() string

Reason function returns reason value.

type Error 

type Error struct {
	// The node id that threw the error.
	FailedNodeId string `protobuf:"bytes,1,opt,name=failed_node_id,json=failedNodeId,proto3" json:"failed_node_id,omitempty"`
	// Error message thrown.
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents an error thrown from a node.

func (*Error) Descriptor 

func (*Error) Descriptor() ([]byte, []int)

func (*Error) GetFailedNodeId 

func (m *Error) GetFailedNodeId() string

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) Validate 

func (m *Error) Validate() error

Validate checks the field values on Error with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (dst *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

type ErrorDocument 

type ErrorDocument struct {
	// The error raised during execution.
	Error                *ContainerError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Defines the errors.pb file format the container can produce to communicate failure reasons to the execution engine.

func (*ErrorDocument) Descriptor 

func (*ErrorDocument) Descriptor() ([]byte, []int)

func (*ErrorDocument) GetError 

func (m *ErrorDocument) GetError() *ContainerError

func (*ErrorDocument) ProtoMessage 

func (*ErrorDocument) ProtoMessage()

func (*ErrorDocument) Reset 

func (m *ErrorDocument) Reset()

func (*ErrorDocument) String 

func (m *ErrorDocument) String() string

func (*ErrorDocument) Validate 

func (m *ErrorDocument) Validate() error

Validate checks the field values on ErrorDocument with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ErrorDocument) XXX_DiscardUnknown 

func (m *ErrorDocument) XXX_DiscardUnknown()

func (*ErrorDocument) XXX_Marshal 

func (m *ErrorDocument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorDocument) XXX_Merge 

func (dst *ErrorDocument) XXX_Merge(src proto.Message)

func (*ErrorDocument) XXX_Size 

func (m *ErrorDocument) XXX_Size() int

func (*ErrorDocument) XXX_Unmarshal 

func (m *ErrorDocument) XXX_Unmarshal(b []byte) error

type ErrorDocumentValidationError 

type ErrorDocumentValidationError struct {
	// contains filtered or unexported fields
}

ErrorDocumentValidationError is the validation error returned by ErrorDocument.Validate if the designated constraints aren't met.

func (ErrorDocumentValidationError) Cause 

func (e ErrorDocumentValidationError) Cause() error

Cause function returns cause value.

func (ErrorDocumentValidationError) Error 

func (e ErrorDocumentValidationError) Error() string

Error satisfies the builtin error interface

func (ErrorDocumentValidationError) ErrorName 

func (e ErrorDocumentValidationError) ErrorName() string

ErrorName returns error name.

func (ErrorDocumentValidationError) Field 

func (e ErrorDocumentValidationError) Field() string

Field function returns field value.

func (ErrorDocumentValidationError) Key 

func (e ErrorDocumentValidationError) Key() bool

Key function returns key value.

func (ErrorDocumentValidationError) Reason 

func (e ErrorDocumentValidationError) Reason() string

Reason function returns reason value.

type ErrorValidationError 

type ErrorValidationError struct {
	// contains filtered or unexported fields
}

ErrorValidationError is the validation error returned by Error.Validate if the designated constraints aren't met.

func (ErrorValidationError) Cause 

func (e ErrorValidationError) Cause() error

Cause function returns cause value.

func (ErrorValidationError) Error 

func (e ErrorValidationError) Error() string

Error satisfies the builtin error interface

func (ErrorValidationError) ErrorName 

func (e ErrorValidationError) ErrorName() string

ErrorName returns error name.

func (ErrorValidationError) Field 

func (e ErrorValidationError) Field() string

Field function returns field value.

func (ErrorValidationError) Key 

func (e ErrorValidationError) Key() bool

Key function returns key value.

func (ErrorValidationError) Reason 

func (e ErrorValidationError) Reason() string

Reason function returns reason value.

type ExecutionError 

type ExecutionError struct {
	// Error code indicates a grouping of a type of error.
	// More Info: <Link>
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// Detailed description of the error - including stack trace.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Full error contents accessible via a URI
	ErrorUri             string   `protobuf:"bytes,3,opt,name=error_uri,json=errorUri,proto3" json:"error_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents the error message from the execution.

func (*ExecutionError) Descriptor 

func (*ExecutionError) Descriptor() ([]byte, []int)

func (*ExecutionError) GetCode 

func (m *ExecutionError) GetCode() string

func (*ExecutionError) GetErrorUri 

func (m *ExecutionError) GetErrorUri() string

func (*ExecutionError) GetMessage 

func (m *ExecutionError) GetMessage() string

func (*ExecutionError) ProtoMessage 

func (*ExecutionError) ProtoMessage()

func (*ExecutionError) Reset 

func (m *ExecutionError) Reset()

func (*ExecutionError) String 

func (m *ExecutionError) String() string

func (*ExecutionError) Validate 

func (m *ExecutionError) Validate() error

Validate checks the field values on ExecutionError with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionError) XXX_DiscardUnknown 

func (m *ExecutionError) XXX_DiscardUnknown()

func (*ExecutionError) XXX_Marshal 

func (m *ExecutionError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionError) XXX_Merge 

func (dst *ExecutionError) XXX_Merge(src proto.Message)

func (*ExecutionError) XXX_Size 

func (m *ExecutionError) XXX_Size() int

func (*ExecutionError) XXX_Unmarshal 

func (m *ExecutionError) XXX_Unmarshal(b []byte) error

type ExecutionErrorValidationError 

type ExecutionErrorValidationError struct {
	// contains filtered or unexported fields
}

ExecutionErrorValidationError is the validation error returned by ExecutionError.Validate if the designated constraints aren't met.

func (ExecutionErrorValidationError) Cause 

func (e ExecutionErrorValidationError) Cause() error

Cause function returns cause value.

func (ExecutionErrorValidationError) Error 

func (e ExecutionErrorValidationError) Error() string

Error satisfies the builtin error interface

func (ExecutionErrorValidationError) ErrorName 

func (e ExecutionErrorValidationError) ErrorName() string

ErrorName returns error name.

func (ExecutionErrorValidationError) Field 

func (e ExecutionErrorValidationError) Field() string

Field function returns field value.

func (ExecutionErrorValidationError) Key 

func (e ExecutionErrorValidationError) Key() bool

Key function returns key value.

func (ExecutionErrorValidationError) Reason 

func (e ExecutionErrorValidationError) Reason() string

Reason function returns reason value.

type Identifier 

type Identifier struct {
	// Identifies the specific type of resource that this identifer corresponds to.
	ResourceType ResourceType `` /* 130-byte string literal not displayed */
	// Name of the project the resource belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the resource belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// User provided value for the resource.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Specific version of the resource.
	Version              string   `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Encapsulation of fields that uniquely identifies a Flyte resource.

func (*Identifier) Descriptor 

func (*Identifier) Descriptor() ([]byte, []int)

func (*Identifier) GetDomain 

func (m *Identifier) GetDomain() string

func (*Identifier) GetName 

func (m *Identifier) GetName() string

func (*Identifier) GetProject 

func (m *Identifier) GetProject() string

func (*Identifier) GetResourceType 

func (m *Identifier) GetResourceType() ResourceType

func (*Identifier) GetVersion 

func (m *Identifier) GetVersion() string

func (*Identifier) ProtoMessage 

func (*Identifier) ProtoMessage()

func (*Identifier) Reset 

func (m *Identifier) Reset()

func (*Identifier) String 

func (m *Identifier) String() string

func (*Identifier) Validate 

func (m *Identifier) Validate() error

Validate checks the field values on Identifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Identifier) XXX_DiscardUnknown 

func (m *Identifier) XXX_DiscardUnknown()

func (*Identifier) XXX_Marshal 

func (m *Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Identifier) XXX_Merge 

func (dst *Identifier) XXX_Merge(src proto.Message)

func (*Identifier) XXX_Size 

func (m *Identifier) XXX_Size() int

func (*Identifier) XXX_Unmarshal 

func (m *Identifier) XXX_Unmarshal(b []byte) error

type IdentifierValidationError 

type IdentifierValidationError struct {
	// contains filtered or unexported fields
}

IdentifierValidationError is the validation error returned by Identifier.Validate if the designated constraints aren't met.

func (IdentifierValidationError) Cause 

func (e IdentifierValidationError) Cause() error

Cause function returns cause value.

func (IdentifierValidationError) Error 

func (e IdentifierValidationError) Error() string

Error satisfies the builtin error interface

func (IdentifierValidationError) ErrorName 

func (e IdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (IdentifierValidationError) Field 

func (e IdentifierValidationError) Field() string

Field function returns field value.

func (IdentifierValidationError) Key 

func (e IdentifierValidationError) Key() bool

Key function returns key value.

func (IdentifierValidationError) Reason 

func (e IdentifierValidationError) Reason() string

Reason function returns reason value.

type IfBlock 

type IfBlock struct {
	Condition            *BooleanExpression `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
	ThenNode             *Node              `protobuf:"bytes,2,opt,name=then_node,json=thenNode,proto3" json:"then_node,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Defines a condition and the execution unit that should be executed if the condition is satisfied.

func (*IfBlock) Descriptor 

func (*IfBlock) Descriptor() ([]byte, []int)

func (*IfBlock) GetCondition 

func (m *IfBlock) GetCondition() *BooleanExpression

func (*IfBlock) GetThenNode 

func (m *IfBlock) GetThenNode() *Node

func (*IfBlock) ProtoMessage 

func (*IfBlock) ProtoMessage()

func (*IfBlock) Reset 

func (m *IfBlock) Reset()

func (*IfBlock) String 

func (m *IfBlock) String() string

func (*IfBlock) Validate 

func (m *IfBlock) Validate() error

Validate checks the field values on IfBlock with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*IfBlock) XXX_DiscardUnknown 

func (m *IfBlock) XXX_DiscardUnknown()

func (*IfBlock) XXX_Marshal 

func (m *IfBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IfBlock) XXX_Merge 

func (dst *IfBlock) XXX_Merge(src proto.Message)

func (*IfBlock) XXX_Size 

func (m *IfBlock) XXX_Size() int

func (*IfBlock) XXX_Unmarshal 

func (m *IfBlock) XXX_Unmarshal(b []byte) error

type IfBlockValidationError 

type IfBlockValidationError struct {
	// contains filtered or unexported fields
}

IfBlockValidationError is the validation error returned by IfBlock.Validate if the designated constraints aren't met.

func (IfBlockValidationError) Cause 

func (e IfBlockValidationError) Cause() error

Cause function returns cause value.

func (IfBlockValidationError) Error 

func (e IfBlockValidationError) Error() string

Error satisfies the builtin error interface

func (IfBlockValidationError) ErrorName 

func (e IfBlockValidationError) ErrorName() string

ErrorName returns error name.

func (IfBlockValidationError) Field 

func (e IfBlockValidationError) Field() string

Field function returns field value.

func (IfBlockValidationError) Key 

func (e IfBlockValidationError) Key() bool

Key function returns key value.

func (IfBlockValidationError) Reason 

func (e IfBlockValidationError) Reason() string

Reason function returns reason value.

type IfElseBlock 

type IfElseBlock struct {
	// +required. First condition to evaluate.
	Case *IfBlock `protobuf:"bytes,1,opt,name=case,proto3" json:"case,omitempty"`
	// +optional. Additional branches to evaluate.
	Other []*IfBlock `protobuf:"bytes,2,rep,name=other,proto3" json:"other,omitempty"`
	// +required.
	//
	// Types that are valid to be assigned to Default:
	//	*IfElseBlock_ElseNode
	//	*IfElseBlock_Error
	Default              isIfElseBlock_Default `protobuf_oneof:"default"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Defines a series of if/else blocks. The first branch whose condition evaluates to true is the one to execute. If no conditions were satisfied, the else_node or the error will execute.

func (*IfElseBlock) Descriptor 

func (*IfElseBlock) Descriptor() ([]byte, []int)

func (*IfElseBlock) GetCase 

func (m *IfElseBlock) GetCase() *IfBlock

func (*IfElseBlock) GetDefault 

func (m *IfElseBlock) GetDefault() isIfElseBlock_Default

func (*IfElseBlock) GetElseNode 

func (m *IfElseBlock) GetElseNode() *Node

func (*IfElseBlock) GetError 

func (m *IfElseBlock) GetError() *Error

func (*IfElseBlock) GetOther 

func (m *IfElseBlock) GetOther() []*IfBlock

func (*IfElseBlock) ProtoMessage 

func (*IfElseBlock) ProtoMessage()

func (*IfElseBlock) Reset 

func (m *IfElseBlock) Reset()

func (*IfElseBlock) String 

func (m *IfElseBlock) String() string

func (*IfElseBlock) Validate 

func (m *IfElseBlock) Validate() error

Validate checks the field values on IfElseBlock with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*IfElseBlock) XXX_DiscardUnknown 

func (m *IfElseBlock) XXX_DiscardUnknown()

func (*IfElseBlock) XXX_Marshal 

func (m *IfElseBlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IfElseBlock) XXX_Merge 

func (dst *IfElseBlock) XXX_Merge(src proto.Message)

func (*IfElseBlock) XXX_OneofFuncs 

func (*IfElseBlock) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*IfElseBlock) XXX_Size 

func (m *IfElseBlock) XXX_Size() int

func (*IfElseBlock) XXX_Unmarshal 

func (m *IfElseBlock) XXX_Unmarshal(b []byte) error

type IfElseBlockValidationError 

type IfElseBlockValidationError struct {
	// contains filtered or unexported fields
}

IfElseBlockValidationError is the validation error returned by IfElseBlock.Validate if the designated constraints aren't met.

func (IfElseBlockValidationError) Cause 

func (e IfElseBlockValidationError) Cause() error

Cause function returns cause value.

func (IfElseBlockValidationError) Error 

func (e IfElseBlockValidationError) Error() string

Error satisfies the builtin error interface

func (IfElseBlockValidationError) ErrorName 

func (e IfElseBlockValidationError) ErrorName() string

ErrorName returns error name.

func (IfElseBlockValidationError) Field 

func (e IfElseBlockValidationError) Field() string

Field function returns field value.

func (IfElseBlockValidationError) Key 

func (e IfElseBlockValidationError) Key() bool

Key function returns key value.

func (IfElseBlockValidationError) Reason 

func (e IfElseBlockValidationError) Reason() string

Reason function returns reason value.

type IfElseBlock_ElseNode 

type IfElseBlock_ElseNode struct {
	ElseNode *Node `protobuf:"bytes,3,opt,name=else_node,json=elseNode,proto3,oneof"`
}

type IfElseBlock_Error 

type IfElseBlock_Error struct {
	Error *Error `protobuf:"bytes,4,opt,name=error,proto3,oneof"`
}

type KeyValuePair 

type KeyValuePair struct {
	// required.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// +optional.
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A generic key value pair.

func (*KeyValuePair) Descriptor 

func (*KeyValuePair) Descriptor() ([]byte, []int)

func (*KeyValuePair) GetKey 

func (m *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (m *KeyValuePair) GetValue() string

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) Reset 

func (m *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (m *KeyValuePair) String() string

func (*KeyValuePair) Validate 

func (m *KeyValuePair) Validate() error

Validate checks the field values on KeyValuePair with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*KeyValuePair) XXX_DiscardUnknown 

func (m *KeyValuePair) XXX_DiscardUnknown()

func (*KeyValuePair) XXX_Marshal 

func (m *KeyValuePair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyValuePair) XXX_Merge 

func (dst *KeyValuePair) XXX_Merge(src proto.Message)

func (*KeyValuePair) XXX_Size 

func (m *KeyValuePair) XXX_Size() int

func (*KeyValuePair) XXX_Unmarshal 

func (m *KeyValuePair) XXX_Unmarshal(b []byte) error

type KeyValuePairValidationError 

type KeyValuePairValidationError struct {
	// contains filtered or unexported fields
}

KeyValuePairValidationError is the validation error returned by KeyValuePair.Validate if the designated constraints aren't met.

func (KeyValuePairValidationError) Cause 

func (e KeyValuePairValidationError) Cause() error

Cause function returns cause value.

func (KeyValuePairValidationError) Error 

func (e KeyValuePairValidationError) Error() string

Error satisfies the builtin error interface

func (KeyValuePairValidationError) ErrorName 

func (e KeyValuePairValidationError) ErrorName() string

ErrorName returns error name.

func (KeyValuePairValidationError) Field 

func (e KeyValuePairValidationError) Field() string

Field function returns field value.

func (KeyValuePairValidationError) Key 

func (e KeyValuePairValidationError) Key() bool

Key function returns key value.

func (KeyValuePairValidationError) Reason 

func (e KeyValuePairValidationError) Reason() string

Reason function returns reason value.

type Literal 

type Literal struct {
	// Types that are valid to be assigned to Value:
	//	*Literal_Scalar
	//	*Literal_Collection
	//	*Literal_Map
	Value                isLiteral_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

A simple value. This supports any level of nesting (e.g. array of array of array of Blobs) as well as simple primitives.

func (*Literal) Descriptor 

func (*Literal) Descriptor() ([]byte, []int)

func (*Literal) GetCollection 

func (m *Literal) GetCollection() *LiteralCollection

func (*Literal) GetMap 

func (m *Literal) GetMap() *LiteralMap

func (*Literal) GetScalar 

func (m *Literal) GetScalar() *Scalar

func (*Literal) GetValue 

func (m *Literal) GetValue() isLiteral_Value

func (*Literal) ProtoMessage 

func (*Literal) ProtoMessage()

func (*Literal) Reset 

func (m *Literal) Reset()

func (*Literal) String 

func (m *Literal) String() string

func (*Literal) Validate 

func (m *Literal) Validate() error

Validate checks the field values on Literal with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Literal) XXX_DiscardUnknown 

func (m *Literal) XXX_DiscardUnknown()

func (*Literal) XXX_Marshal 

func (m *Literal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Literal) XXX_Merge 

func (dst *Literal) XXX_Merge(src proto.Message)

func (*Literal) XXX_OneofFuncs 

func (*Literal) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Literal) XXX_Size 

func (m *Literal) XXX_Size() int

func (*Literal) XXX_Unmarshal 

func (m *Literal) XXX_Unmarshal(b []byte) error

type LiteralCollection 

type LiteralCollection struct {
	Literals             []*Literal `protobuf:"bytes,1,rep,name=literals,proto3" json:"literals,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

A collection of literals. This is a workaround since oneofs in proto messages cannot contain a repeated field.

func (*LiteralCollection) Descriptor 

func (*LiteralCollection) Descriptor() ([]byte, []int)

func (*LiteralCollection) GetLiterals 

func (m *LiteralCollection) GetLiterals() []*Literal

func (*LiteralCollection) ProtoMessage 

func (*LiteralCollection) ProtoMessage()

func (*LiteralCollection) Reset 

func (m *LiteralCollection) Reset()

func (*LiteralCollection) String 

func (m *LiteralCollection) String() string

func (*LiteralCollection) Validate 

func (m *LiteralCollection) Validate() error

Validate checks the field values on LiteralCollection with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LiteralCollection) XXX_DiscardUnknown 

func (m *LiteralCollection) XXX_DiscardUnknown()

func (*LiteralCollection) XXX_Marshal 

func (m *LiteralCollection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiteralCollection) XXX_Merge 

func (dst *LiteralCollection) XXX_Merge(src proto.Message)

func (*LiteralCollection) XXX_Size 

func (m *LiteralCollection) XXX_Size() int

func (*LiteralCollection) XXX_Unmarshal 

func (m *LiteralCollection) XXX_Unmarshal(b []byte) error

type LiteralCollectionValidationError 

type LiteralCollectionValidationError struct {
	// contains filtered or unexported fields
}

LiteralCollectionValidationError is the validation error returned by LiteralCollection.Validate if the designated constraints aren't met.

func (LiteralCollectionValidationError) Cause 

func (e LiteralCollectionValidationError) Cause() error

Cause function returns cause value.

func (LiteralCollectionValidationError) Error 

func (e LiteralCollectionValidationError) Error() string

Error satisfies the builtin error interface

func (LiteralCollectionValidationError) ErrorName 

func (e LiteralCollectionValidationError) ErrorName() string

ErrorName returns error name.

func (LiteralCollectionValidationError) Field 

func (e LiteralCollectionValidationError) Field() string

Field function returns field value.

func (LiteralCollectionValidationError) Key 

func (e LiteralCollectionValidationError) Key() bool

Key function returns key value.

func (LiteralCollectionValidationError) Reason 

func (e LiteralCollectionValidationError) Reason() string

Reason function returns reason value.

type LiteralMap 

type LiteralMap struct {
	Literals             map[string]*Literal `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

A map of literals. This is a workaround since oneofs in proto messages cannot contain a repeated field.

func (*LiteralMap) Descriptor 

func (*LiteralMap) Descriptor() ([]byte, []int)

func (*LiteralMap) GetLiterals 

func (m *LiteralMap) GetLiterals() map[string]*Literal

func (*LiteralMap) ProtoMessage 

func (*LiteralMap) ProtoMessage()

func (*LiteralMap) Reset 

func (m *LiteralMap) Reset()

func (*LiteralMap) String 

func (m *LiteralMap) String() string

func (*LiteralMap) Validate 

func (m *LiteralMap) Validate() error

Validate checks the field values on LiteralMap with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LiteralMap) XXX_DiscardUnknown 

func (m *LiteralMap) XXX_DiscardUnknown()

func (*LiteralMap) XXX_Marshal 

func (m *LiteralMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiteralMap) XXX_Merge 

func (dst *LiteralMap) XXX_Merge(src proto.Message)

func (*LiteralMap) XXX_Size 

func (m *LiteralMap) XXX_Size() int

func (*LiteralMap) XXX_Unmarshal 

func (m *LiteralMap) XXX_Unmarshal(b []byte) error

type LiteralMapValidationError 

type LiteralMapValidationError struct {
	// contains filtered or unexported fields
}

LiteralMapValidationError is the validation error returned by LiteralMap.Validate if the designated constraints aren't met.

func (LiteralMapValidationError) Cause 

func (e LiteralMapValidationError) Cause() error

Cause function returns cause value.

func (LiteralMapValidationError) Error 

func (e LiteralMapValidationError) Error() string

Error satisfies the builtin error interface

func (LiteralMapValidationError) ErrorName 

func (e LiteralMapValidationError) ErrorName() string

ErrorName returns error name.

func (LiteralMapValidationError) Field 

func (e LiteralMapValidationError) Field() string

Field function returns field value.

func (LiteralMapValidationError) Key 

func (e LiteralMapValidationError) Key() bool

Key function returns key value.

func (LiteralMapValidationError) Reason 

func (e LiteralMapValidationError) Reason() string

Reason function returns reason value.

type LiteralType 

type LiteralType struct {
	// Types that are valid to be assigned to Type:
	//	*LiteralType_Simple
	//	*LiteralType_Schema
	//	*LiteralType_CollectionType
	//	*LiteralType_MapValueType
	//	*LiteralType_Blob
	Type isLiteralType_Type `protobuf_oneof:"type"`
	// This field contains type metadata that is descriptive of the type, but is NOT considered in type-checking.  This might be used by
	// consumers to identify special behavior or display extended information for the type.
	Metadata             *_struct.Struct `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Defines a strong type to allow type checking between interfaces.

func (*LiteralType) Descriptor 

func (*LiteralType) Descriptor() ([]byte, []int)

func (*LiteralType) GetBlob 

func (m *LiteralType) GetBlob() *BlobType

func (*LiteralType) GetCollectionType 

func (m *LiteralType) GetCollectionType() *LiteralType

func (*LiteralType) GetMapValueType 

func (m *LiteralType) GetMapValueType() *LiteralType

func (*LiteralType) GetMetadata 

func (m *LiteralType) GetMetadata() *_struct.Struct

func (*LiteralType) GetSchema 

func (m *LiteralType) GetSchema() *SchemaType

func (*LiteralType) GetSimple 

func (m *LiteralType) GetSimple() SimpleType

func (*LiteralType) GetType 

func (m *LiteralType) GetType() isLiteralType_Type

func (*LiteralType) ProtoMessage 

func (*LiteralType) ProtoMessage()

func (*LiteralType) Reset 

func (m *LiteralType) Reset()

func (*LiteralType) String 

func (m *LiteralType) String() string

func (*LiteralType) Validate 

func (m *LiteralType) Validate() error

Validate checks the field values on LiteralType with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LiteralType) XXX_DiscardUnknown 

func (m *LiteralType) XXX_DiscardUnknown()

func (*LiteralType) XXX_Marshal 

func (m *LiteralType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiteralType) XXX_Merge 

func (dst *LiteralType) XXX_Merge(src proto.Message)

func (*LiteralType) XXX_OneofFuncs 

func (*LiteralType) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*LiteralType) XXX_Size 

func (m *LiteralType) XXX_Size() int

func (*LiteralType) XXX_Unmarshal 

func (m *LiteralType) XXX_Unmarshal(b []byte) error

type LiteralTypeValidationError 

type LiteralTypeValidationError struct {
	// contains filtered or unexported fields
}

LiteralTypeValidationError is the validation error returned by LiteralType.Validate if the designated constraints aren't met.

func (LiteralTypeValidationError) Cause 

func (e LiteralTypeValidationError) Cause() error

Cause function returns cause value.

func (LiteralTypeValidationError) Error 

func (e LiteralTypeValidationError) Error() string

Error satisfies the builtin error interface

func (LiteralTypeValidationError) ErrorName 

func (e LiteralTypeValidationError) ErrorName() string

ErrorName returns error name.

func (LiteralTypeValidationError) Field 

func (e LiteralTypeValidationError) Field() string

Field function returns field value.

func (LiteralTypeValidationError) Key 

func (e LiteralTypeValidationError) Key() bool

Key function returns key value.

func (LiteralTypeValidationError) Reason 

func (e LiteralTypeValidationError) Reason() string

Reason function returns reason value.

type LiteralType_Blob 

type LiteralType_Blob struct {
	Blob *BlobType `protobuf:"bytes,5,opt,name=blob,proto3,oneof"`
}

type LiteralType_CollectionType 

type LiteralType_CollectionType struct {
	CollectionType *LiteralType `protobuf:"bytes,3,opt,name=collection_type,json=collectionType,proto3,oneof"`
}

type LiteralType_MapValueType 

type LiteralType_MapValueType struct {
	MapValueType *LiteralType `protobuf:"bytes,4,opt,name=map_value_type,json=mapValueType,proto3,oneof"`
}

type LiteralType_Schema 

type LiteralType_Schema struct {
	Schema *SchemaType `protobuf:"bytes,2,opt,name=schema,proto3,oneof"`
}

type LiteralType_Simple 

type LiteralType_Simple struct {
	Simple SimpleType `protobuf:"varint,1,opt,name=simple,proto3,enum=flyteidl.core.SimpleType,oneof"`
}

type LiteralValidationError 

type LiteralValidationError struct {
	// contains filtered or unexported fields
}

LiteralValidationError is the validation error returned by Literal.Validate if the designated constraints aren't met.

func (LiteralValidationError) Cause 

func (e LiteralValidationError) Cause() error

Cause function returns cause value.

func (LiteralValidationError) Error 

func (e LiteralValidationError) Error() string

Error satisfies the builtin error interface

func (LiteralValidationError) ErrorName 

func (e LiteralValidationError) ErrorName() string

ErrorName returns error name.

func (LiteralValidationError) Field 

func (e LiteralValidationError) Field() string

Field function returns field value.

func (LiteralValidationError) Key 

func (e LiteralValidationError) Key() bool

Key function returns key value.

func (LiteralValidationError) Reason 

func (e LiteralValidationError) Reason() string

Reason function returns reason value.

type Literal_Collection 

type Literal_Collection struct {
	Collection *LiteralCollection `protobuf:"bytes,2,opt,name=collection,proto3,oneof"`
}

type Literal_Map 

type Literal_Map struct {
	Map *LiteralMap `protobuf:"bytes,3,opt,name=map,proto3,oneof"`
}

type Literal_Scalar 

type Literal_Scalar struct {
	Scalar *Scalar `protobuf:"bytes,1,opt,name=scalar,proto3,oneof"`
}

type Node 

type Node struct {
	// A workflow-level unique identifier that identifies this node in the workflow. "inputs" and "outputs" are reserved
	// node ids that cannot be used by other nodes.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Extra metadata about the node.
	Metadata *NodeMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Specifies how to bind the underlying interface's inputs. All required inputs specified in the underlying interface
	// must be fullfilled.
	Inputs []*Binding `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// +optional Specifies execution depdendency for this node ensuring it will only get scheduled to run after all its
	// upstream nodes have completed. This node will have an implicit depdendency on any node that appears in inputs
	// field.
	UpstreamNodeIds []string `protobuf:"bytes,4,rep,name=upstream_node_ids,json=upstreamNodeIds,proto3" json:"upstream_node_ids,omitempty"`
	// +optional. A node can define aliases for a subset of its outputs. This is particularly useful if different nodes
	// need to conform to the same interface (e.g. all branches in a branch node). Downstream nodes must refer to this
	// nodes outputs using the alias if one's specified.
	OutputAliases []*Alias `protobuf:"bytes,5,rep,name=output_aliases,json=outputAliases,proto3" json:"output_aliases,omitempty"`
	// Information about the target to execute in this node.
	//
	// Types that are valid to be assigned to Target:
	//	*Node_TaskNode
	//	*Node_WorkflowNode
	//	*Node_BranchNode
	Target               isNode_Target `protobuf_oneof:"target"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

A Workflow graph Node. One unit of execution in the graph. Each node can be linked to a Task, a Workflow or a branch node.

func (*Node) Descriptor 

func (*Node) Descriptor() ([]byte, []int)

func (*Node) GetBranchNode 

func (m *Node) GetBranchNode() *BranchNode

func (*Node) GetId 

func (m *Node) GetId() string

func (*Node) GetInputs 

func (m *Node) GetInputs() []*Binding

func (*Node) GetMetadata 

func (m *Node) GetMetadata() *NodeMetadata

func (*Node) GetOutputAliases 

func (m *Node) GetOutputAliases() []*Alias

func (*Node) GetTarget 

func (m *Node) GetTarget() isNode_Target

func (*Node) GetTaskNode 

func (m *Node) GetTaskNode() *TaskNode

func (*Node) GetUpstreamNodeIds 

func (m *Node) GetUpstreamNodeIds() []string

func (*Node) GetWorkflowNode 

func (m *Node) GetWorkflowNode() *WorkflowNode

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) Validate 

func (m *Node) Validate() error

Validate checks the field values on Node with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (dst *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_OneofFuncs 

func (*Node) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) error

type NodeExecution 

type NodeExecution struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Indicates various phases of Node Execution

func (*NodeExecution) Descriptor 

func (*NodeExecution) Descriptor() ([]byte, []int)

func (*NodeExecution) ProtoMessage 

func (*NodeExecution) ProtoMessage()

func (*NodeExecution) Reset 

func (m *NodeExecution) Reset()

func (*NodeExecution) String 

func (m *NodeExecution) String() string

func (*NodeExecution) Validate 

func (m *NodeExecution) Validate() error

Validate checks the field values on NodeExecution with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecution) XXX_DiscardUnknown 

func (m *NodeExecution) XXX_DiscardUnknown()

func (*NodeExecution) XXX_Marshal 

func (m *NodeExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeExecution) XXX_Merge 

func (dst *NodeExecution) XXX_Merge(src proto.Message)

func (*NodeExecution) XXX_Size 

func (m *NodeExecution) XXX_Size() int

func (*NodeExecution) XXX_Unmarshal 

func (m *NodeExecution) XXX_Unmarshal(b []byte) error

type NodeExecutionIdentifier 

type NodeExecutionIdentifier struct {
	NodeId               string                       `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ExecutionId          *WorkflowExecutionIdentifier `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

Encapsulation of fields that identify a Flyte node execution entity.

func (*NodeExecutionIdentifier) Descriptor 

func (*NodeExecutionIdentifier) Descriptor() ([]byte, []int)

func (*NodeExecutionIdentifier) GetExecutionId 

func (m *NodeExecutionIdentifier) GetExecutionId() *WorkflowExecutionIdentifier

func (*NodeExecutionIdentifier) GetNodeId 

func (m *NodeExecutionIdentifier) GetNodeId() string

func (*NodeExecutionIdentifier) ProtoMessage 

func (*NodeExecutionIdentifier) ProtoMessage()

func (*NodeExecutionIdentifier) Reset 

func (m *NodeExecutionIdentifier) Reset()

func (*NodeExecutionIdentifier) String 

func (m *NodeExecutionIdentifier) String() string

func (*NodeExecutionIdentifier) Validate 

func (m *NodeExecutionIdentifier) Validate() error

Validate checks the field values on NodeExecutionIdentifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionIdentifier) XXX_DiscardUnknown 

func (m *NodeExecutionIdentifier) XXX_DiscardUnknown()

func (*NodeExecutionIdentifier) XXX_Marshal 

func (m *NodeExecutionIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeExecutionIdentifier) XXX_Merge 

func (dst *NodeExecutionIdentifier) XXX_Merge(src proto.Message)

func (*NodeExecutionIdentifier) XXX_Size 

func (m *NodeExecutionIdentifier) XXX_Size() int

func (*NodeExecutionIdentifier) XXX_Unmarshal 

func (m *NodeExecutionIdentifier) XXX_Unmarshal(b []byte) error

type NodeExecutionIdentifierValidationError 

type NodeExecutionIdentifierValidationError struct {
	// contains filtered or unexported fields
}

NodeExecutionIdentifierValidationError is the validation error returned by NodeExecutionIdentifier.Validate if the designated constraints aren't met.

func (NodeExecutionIdentifierValidationError) Cause 

func (e NodeExecutionIdentifierValidationError) Cause() error

Cause function returns cause value.

func (NodeExecutionIdentifierValidationError) Error 

func (e NodeExecutionIdentifierValidationError) Error() string

Error satisfies the builtin error interface

func (NodeExecutionIdentifierValidationError) ErrorName 

func (e NodeExecutionIdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (NodeExecutionIdentifierValidationError) Field 

func (e NodeExecutionIdentifierValidationError) Field() string

Field function returns field value.

func (NodeExecutionIdentifierValidationError) Key 

func (e NodeExecutionIdentifierValidationError) Key() bool

Key function returns key value.

func (NodeExecutionIdentifierValidationError) Reason 

func (e NodeExecutionIdentifierValidationError) Reason() string

Reason function returns reason value.

type NodeExecutionValidationError 

type NodeExecutionValidationError struct {
	// contains filtered or unexported fields
}

NodeExecutionValidationError is the validation error returned by NodeExecution.Validate if the designated constraints aren't met.

func (NodeExecutionValidationError) Cause 

func (e NodeExecutionValidationError) Cause() error

Cause function returns cause value.

func (NodeExecutionValidationError) Error 

func (e NodeExecutionValidationError) Error() string

Error satisfies the builtin error interface

func (NodeExecutionValidationError) ErrorName 

func (e NodeExecutionValidationError) ErrorName() string

ErrorName returns error name.

func (NodeExecutionValidationError) Field 

func (e NodeExecutionValidationError) Field() string

Field function returns field value.

func (NodeExecutionValidationError) Key 

func (e NodeExecutionValidationError) Key() bool

Key function returns key value.

func (NodeExecutionValidationError) Reason 

func (e NodeExecutionValidationError) Reason() string

Reason function returns reason value.

type NodeExecution_Phase 

type NodeExecution_Phase int32
const (
	NodeExecution_UNDEFINED NodeExecution_Phase = 0
	NodeExecution_QUEUED    NodeExecution_Phase = 1
	NodeExecution_RUNNING   NodeExecution_Phase = 2
	NodeExecution_SUCCEEDED NodeExecution_Phase = 3
	NodeExecution_FAILING   NodeExecution_Phase = 4
	NodeExecution_FAILED    NodeExecution_Phase = 5
	NodeExecution_ABORTED   NodeExecution_Phase = 6
	NodeExecution_SKIPPED   NodeExecution_Phase = 7
	NodeExecution_TIMED_OUT NodeExecution_Phase = 8
)

func (NodeExecution_Phase) EnumDescriptor 

func (NodeExecution_Phase) EnumDescriptor() ([]byte, []int)

func (NodeExecution_Phase) String 

func (x NodeExecution_Phase) String() string

type NodeMetadata 

type NodeMetadata struct {
	// A friendly name for the Node
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The overall timeout of a task.
	Timeout *duration.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of retries per task.
	Retries              *RetryStrategy `protobuf:"bytes,5,opt,name=retries,proto3" json:"retries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Defines extra information about the Node.

func (*NodeMetadata) Descriptor 

func (*NodeMetadata) Descriptor() ([]byte, []int)

func (*NodeMetadata) GetName 

func (m *NodeMetadata) GetName() string

func (*NodeMetadata) GetRetries 

func (m *NodeMetadata) GetRetries() *RetryStrategy

func (*NodeMetadata) GetTimeout 

func (m *NodeMetadata) GetTimeout() *duration.Duration

func (*NodeMetadata) ProtoMessage 

func (*NodeMetadata) ProtoMessage()

func (*NodeMetadata) Reset 

func (m *NodeMetadata) Reset()

func (*NodeMetadata) String 

func (m *NodeMetadata) String() string

func (*NodeMetadata) Validate 

func (m *NodeMetadata) Validate() error

Validate checks the field values on NodeMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeMetadata) XXX_DiscardUnknown 

func (m *NodeMetadata) XXX_DiscardUnknown()

func (*NodeMetadata) XXX_Marshal 

func (m *NodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeMetadata) XXX_Merge 

func (dst *NodeMetadata) XXX_Merge(src proto.Message)

func (*NodeMetadata) XXX_Size 

func (m *NodeMetadata) XXX_Size() int

func (*NodeMetadata) XXX_Unmarshal 

func (m *NodeMetadata) XXX_Unmarshal(b []byte) error

type NodeMetadataValidationError 

type NodeMetadataValidationError struct {
	// contains filtered or unexported fields
}

NodeMetadataValidationError is the validation error returned by NodeMetadata.Validate if the designated constraints aren't met.

func (NodeMetadataValidationError) Cause 

func (e NodeMetadataValidationError) Cause() error

Cause function returns cause value.

func (NodeMetadataValidationError) Error 

func (e NodeMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (NodeMetadataValidationError) ErrorName 

func (e NodeMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (NodeMetadataValidationError) Field 

func (e NodeMetadataValidationError) Field() string

Field function returns field value.

func (NodeMetadataValidationError) Key 

func (e NodeMetadataValidationError) Key() bool

Key function returns key value.

func (NodeMetadataValidationError) Reason 

func (e NodeMetadataValidationError) Reason() string

Reason function returns reason value.

type NodeValidationError 

type NodeValidationError struct {
	// contains filtered or unexported fields
}

NodeValidationError is the validation error returned by Node.Validate if the designated constraints aren't met.

func (NodeValidationError) Cause 

func (e NodeValidationError) Cause() error

Cause function returns cause value.

func (NodeValidationError) Error 

func (e NodeValidationError) Error() string

Error satisfies the builtin error interface

func (NodeValidationError) ErrorName 

func (e NodeValidationError) ErrorName() string

ErrorName returns error name.

func (NodeValidationError) Field 

func (e NodeValidationError) Field() string

Field function returns field value.

func (NodeValidationError) Key 

func (e NodeValidationError) Key() bool

Key function returns key value.

func (NodeValidationError) Reason 

func (e NodeValidationError) Reason() string

Reason function returns reason value.

type Node_BranchNode 

type Node_BranchNode struct {
	BranchNode *BranchNode `protobuf:"bytes,8,opt,name=branch_node,json=branchNode,proto3,oneof"`
}

type Node_TaskNode 

type Node_TaskNode struct {
	TaskNode *TaskNode `protobuf:"bytes,6,opt,name=task_node,json=taskNode,proto3,oneof"`
}

type Node_WorkflowNode 

type Node_WorkflowNode struct {
	WorkflowNode *WorkflowNode `protobuf:"bytes,7,opt,name=workflow_node,json=workflowNode,proto3,oneof"`
}

type Operand 

type Operand struct {
	// Types that are valid to be assigned to Val:
	//	*Operand_Primitive
	//	*Operand_Var
	Val                  isOperand_Val `protobuf_oneof:"val"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Defines an operand to a comparison expression.

func (*Operand) Descriptor 

func (*Operand) Descriptor() ([]byte, []int)

func (*Operand) GetPrimitive 

func (m *Operand) GetPrimitive() *Primitive

func (*Operand) GetVal 

func (m *Operand) GetVal() isOperand_Val

func (*Operand) GetVar 

func (m *Operand) GetVar() string

func (*Operand) ProtoMessage 

func (*Operand) ProtoMessage()

func (*Operand) Reset 

func (m *Operand) Reset()

func (*Operand) String 

func (m *Operand) String() string

func (*Operand) Validate 

func (m *Operand) Validate() error

Validate checks the field values on Operand with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Operand) XXX_DiscardUnknown 

func (m *Operand) XXX_DiscardUnknown()

func (*Operand) XXX_Marshal 

func (m *Operand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Operand) XXX_Merge 

func (dst *Operand) XXX_Merge(src proto.Message)

func (*Operand) XXX_OneofFuncs 

func (*Operand) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Operand) XXX_Size 

func (m *Operand) XXX_Size() int

func (*Operand) XXX_Unmarshal 

func (m *Operand) XXX_Unmarshal(b []byte) error

type OperandValidationError 

type OperandValidationError struct {
	// contains filtered or unexported fields
}

OperandValidationError is the validation error returned by Operand.Validate if the designated constraints aren't met.

func (OperandValidationError) Cause 

func (e OperandValidationError) Cause() error

Cause function returns cause value.

func (OperandValidationError) Error 

func (e OperandValidationError) Error() string

Error satisfies the builtin error interface

func (OperandValidationError) ErrorName 

func (e OperandValidationError) ErrorName() string

ErrorName returns error name.

func (OperandValidationError) Field 

func (e OperandValidationError) Field() string

Field function returns field value.

func (OperandValidationError) Key 

func (e OperandValidationError) Key() bool

Key function returns key value.

func (OperandValidationError) Reason 

func (e OperandValidationError) Reason() string

Reason function returns reason value.

type Operand_Primitive 

type Operand_Primitive struct {
	Primitive *Primitive `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}

type Operand_Var 

type Operand_Var struct {
	Var string `protobuf:"bytes,2,opt,name=var,proto3,oneof"`
}

type OutputReference 

type OutputReference struct {
	// Node id must exist at the graph layer.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Variable name must refer to an output variable for the node.
	Var                  string   `protobuf:"bytes,2,opt,name=var,proto3" json:"var,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A reference to an output produced by a node. The type can be retrieved -and validated- from the underlying interface of the node.

func (*OutputReference) Descriptor 

func (*OutputReference) Descriptor() ([]byte, []int)

func (*OutputReference) GetNodeId 

func (m *OutputReference) GetNodeId() string

func (*OutputReference) GetVar 

func (m *OutputReference) GetVar() string

func (*OutputReference) ProtoMessage 

func (*OutputReference) ProtoMessage()

func (*OutputReference) Reset 

func (m *OutputReference) Reset()

func (*OutputReference) String 

func (m *OutputReference) String() string

func (*OutputReference) Validate 

func (m *OutputReference) Validate() error

Validate checks the field values on OutputReference with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*OutputReference) XXX_DiscardUnknown 

func (m *OutputReference) XXX_DiscardUnknown()

func (*OutputReference) XXX_Marshal 

func (m *OutputReference) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OutputReference) XXX_Merge 

func (dst *OutputReference) XXX_Merge(src proto.Message)

func (*OutputReference) XXX_Size 

func (m *OutputReference) XXX_Size() int

func (*OutputReference) XXX_Unmarshal 

func (m *OutputReference) XXX_Unmarshal(b []byte) error

type OutputReferenceValidationError 

type OutputReferenceValidationError struct {
	// contains filtered or unexported fields
}

OutputReferenceValidationError is the validation error returned by OutputReference.Validate if the designated constraints aren't met.

func (OutputReferenceValidationError) Cause 

func (e OutputReferenceValidationError) Cause() error

Cause function returns cause value.

func (OutputReferenceValidationError) Error 

func (e OutputReferenceValidationError) Error() string

Error satisfies the builtin error interface

func (OutputReferenceValidationError) ErrorName 

func (e OutputReferenceValidationError) ErrorName() string

ErrorName returns error name.

func (OutputReferenceValidationError) Field 

func (e OutputReferenceValidationError) Field() string

Field function returns field value.

func (OutputReferenceValidationError) Key 

func (e OutputReferenceValidationError) Key() bool

Key function returns key value.

func (OutputReferenceValidationError) Reason 

func (e OutputReferenceValidationError) Reason() string

Reason function returns reason value.

type Parameter 

type Parameter struct {
	// +required Variable. Defines the type of the variable backing this parameter.
	Var *Variable `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	// +optional
	//
	// Types that are valid to be assigned to Behavior:
	//	*Parameter_Default
	//	*Parameter_Required
	Behavior             isParameter_Behavior `protobuf_oneof:"behavior"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A parameter is used as input to a launch plan and has the special ability to have a default value or mark itself as required.

func (*Parameter) Descriptor 

func (*Parameter) Descriptor() ([]byte, []int)

func (*Parameter) GetBehavior 

func (m *Parameter) GetBehavior() isParameter_Behavior

func (*Parameter) GetDefault 

func (m *Parameter) GetDefault() *Literal

func (*Parameter) GetRequired 

func (m *Parameter) GetRequired() bool

func (*Parameter) GetVar 

func (m *Parameter) GetVar() *Variable

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

func (*Parameter) Validate 

func (m *Parameter) Validate() error

Validate checks the field values on Parameter with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Parameter) XXX_DiscardUnknown 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal 

func (m *Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Parameter) XXX_Merge 

func (dst *Parameter) XXX_Merge(src proto.Message)

func (*Parameter) XXX_OneofFuncs 

func (*Parameter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Parameter) XXX_Size 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal 

func (m *Parameter) XXX_Unmarshal(b []byte) error

type ParameterMap 

type ParameterMap struct {
	// Defines a map of parameter names to parameters.
	Parameters           map[string]*Parameter `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

A map of Parameters.

func (*ParameterMap) Descriptor 

func (*ParameterMap) Descriptor() ([]byte, []int)

func (*ParameterMap) GetParameters 

func (m *ParameterMap) GetParameters() map[string]*Parameter

func (*ParameterMap) ProtoMessage 

func (*ParameterMap) ProtoMessage()

func (*ParameterMap) Reset 

func (m *ParameterMap) Reset()

func (*ParameterMap) String 

func (m *ParameterMap) String() string

func (*ParameterMap) Validate 

func (m *ParameterMap) Validate() error

Validate checks the field values on ParameterMap with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ParameterMap) XXX_DiscardUnknown 

func (m *ParameterMap) XXX_DiscardUnknown()

func (*ParameterMap) XXX_Marshal 

func (m *ParameterMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParameterMap) XXX_Merge 

func (dst *ParameterMap) XXX_Merge(src proto.Message)

func (*ParameterMap) XXX_Size 

func (m *ParameterMap) XXX_Size() int

func (*ParameterMap) XXX_Unmarshal 

func (m *ParameterMap) XXX_Unmarshal(b []byte) error

type ParameterMapValidationError 

type ParameterMapValidationError struct {
	// contains filtered or unexported fields
}

ParameterMapValidationError is the validation error returned by ParameterMap.Validate if the designated constraints aren't met.

func (ParameterMapValidationError) Cause 

func (e ParameterMapValidationError) Cause() error

Cause function returns cause value.

func (ParameterMapValidationError) Error 

func (e ParameterMapValidationError) Error() string

Error satisfies the builtin error interface

func (ParameterMapValidationError) ErrorName 

func (e ParameterMapValidationError) ErrorName() string

ErrorName returns error name.

func (ParameterMapValidationError) Field 

func (e ParameterMapValidationError) Field() string

Field function returns field value.

func (ParameterMapValidationError) Key 

func (e ParameterMapValidationError) Key() bool

Key function returns key value.

func (ParameterMapValidationError) Reason 

func (e ParameterMapValidationError) Reason() string

Reason function returns reason value.

type ParameterValidationError 

type ParameterValidationError struct {
	// contains filtered or unexported fields
}

ParameterValidationError is the validation error returned by Parameter.Validate if the designated constraints aren't met.

func (ParameterValidationError) Cause 

func (e ParameterValidationError) Cause() error

Cause function returns cause value.

func (ParameterValidationError) Error 

func (e ParameterValidationError) Error() string

Error satisfies the builtin error interface

func (ParameterValidationError) ErrorName 

func (e ParameterValidationError) ErrorName() string

ErrorName returns error name.

func (ParameterValidationError) Field 

func (e ParameterValidationError) Field() string

Field function returns field value.

func (ParameterValidationError) Key 

func (e ParameterValidationError) Key() bool

Key function returns key value.

func (ParameterValidationError) Reason 

func (e ParameterValidationError) Reason() string

Reason function returns reason value.

type Parameter_Default 

type Parameter_Default struct {
	Default *Literal `protobuf:"bytes,2,opt,name=default,proto3,oneof"`
}

type Parameter_Required 

type Parameter_Required struct {
	Required bool `protobuf:"varint,3,opt,name=required,proto3,oneof"`
}

type Primitive 

type Primitive struct {
	// Defines one of simple primitive types. These types will get translated into different programming languages as
	// described in https://developers.google.com/protocol-buffers/docs/proto#scalar.
	//
	// Types that are valid to be assigned to Value:
	//	*Primitive_Integer
	//	*Primitive_FloatValue
	//	*Primitive_StringValue
	//	*Primitive_Boolean
	//	*Primitive_Datetime
	//	*Primitive_Duration
	Value                isPrimitive_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Primitive Types

func (*Primitive) Descriptor 

func (*Primitive) Descriptor() ([]byte, []int)

func (*Primitive) GetBoolean 

func (m *Primitive) GetBoolean() bool

func (*Primitive) GetDatetime 

func (m *Primitive) GetDatetime() *timestamp.Timestamp

func (*Primitive) GetDuration 

func (m *Primitive) GetDuration() *duration.Duration

func (*Primitive) GetFloatValue 

func (m *Primitive) GetFloatValue() float64

func (*Primitive) GetInteger 

func (m *Primitive) GetInteger() int64

func (*Primitive) GetStringValue 

func (m *Primitive) GetStringValue() string

func (*Primitive) GetValue 

func (m *Primitive) GetValue() isPrimitive_Value

func (*Primitive) ProtoMessage 

func (*Primitive) ProtoMessage()

func (*Primitive) Reset 

func (m *Primitive) Reset()

func (*Primitive) String 

func (m *Primitive) String() string

func (*Primitive) Validate 

func (m *Primitive) Validate() error

Validate checks the field values on Primitive with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Primitive) XXX_DiscardUnknown 

func (m *Primitive) XXX_DiscardUnknown()

func (*Primitive) XXX_Marshal 

func (m *Primitive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Primitive) XXX_Merge 

func (dst *Primitive) XXX_Merge(src proto.Message)

func (*Primitive) XXX_OneofFuncs 

func (*Primitive) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Primitive) XXX_Size 

func (m *Primitive) XXX_Size() int

func (*Primitive) XXX_Unmarshal 

func (m *Primitive) XXX_Unmarshal(b []byte) error

type PrimitiveValidationError 

type PrimitiveValidationError struct {
	// contains filtered or unexported fields
}

PrimitiveValidationError is the validation error returned by Primitive.Validate if the designated constraints aren't met.

func (PrimitiveValidationError) Cause 

func (e PrimitiveValidationError) Cause() error

Cause function returns cause value.

func (PrimitiveValidationError) Error 

func (e PrimitiveValidationError) Error() string

Error satisfies the builtin error interface

func (PrimitiveValidationError) ErrorName 

func (e PrimitiveValidationError) ErrorName() string

ErrorName returns error name.

func (PrimitiveValidationError) Field 

func (e PrimitiveValidationError) Field() string

Field function returns field value.

func (PrimitiveValidationError) Key 

func (e PrimitiveValidationError) Key() bool

Key function returns key value.

func (PrimitiveValidationError) Reason 

func (e PrimitiveValidationError) Reason() string

Reason function returns reason value.

type Primitive_Boolean 

type Primitive_Boolean struct {
	Boolean bool `protobuf:"varint,4,opt,name=boolean,proto3,oneof"`
}

type Primitive_Datetime 

type Primitive_Datetime struct {
	Datetime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=datetime,proto3,oneof"`
}

type Primitive_Duration 

type Primitive_Duration struct {
	Duration *duration.Duration `protobuf:"bytes,6,opt,name=duration,proto3,oneof"`
}

type Primitive_FloatValue 

type Primitive_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,2,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type Primitive_Integer 

type Primitive_Integer struct {
	Integer int64 `protobuf:"varint,1,opt,name=integer,proto3,oneof"`
}

type Primitive_StringValue 

type Primitive_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type ResourceType 

type ResourceType int32

Indicates a resource type within Flyte. 

const (
	ResourceType_UNSPECIFIED ResourceType = 0
	ResourceType_TASK        ResourceType = 1
	ResourceType_WORKFLOW    ResourceType = 2
	ResourceType_LAUNCH_PLAN ResourceType = 3
)

func (ResourceType) EnumDescriptor 

func (ResourceType) EnumDescriptor() ([]byte, []int)

func (ResourceType) String 

func (x ResourceType) String() string

type Resources 

type Resources struct {
	// The desired set of resources requested. ResourceNames must be unique within the list.
	Requests []*Resources_ResourceEntry `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// Defines a set of bounds (e.g. min/max) within which the task can reliably run. ResourceNames must be unique
	// within the list.
	Limits               []*Resources_ResourceEntry `protobuf:"bytes,2,rep,name=limits,proto3" json:"limits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

A customizable interface to convey resources requested for a container. This can be interpretted differently for different container engines.

func (*Resources) Descriptor 

func (*Resources) Descriptor() ([]byte, []int)

func (*Resources) GetLimits 

func (m *Resources) GetLimits() []*Resources_ResourceEntry

func (*Resources) GetRequests 

func (m *Resources) GetRequests() []*Resources_ResourceEntry

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) Reset 

func (m *Resources) Reset()

func (*Resources) String 

func (m *Resources) String() string

func (*Resources) Validate 

func (m *Resources) Validate() error

Validate checks the field values on Resources with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Resources) XXX_DiscardUnknown 

func (m *Resources) XXX_DiscardUnknown()

func (*Resources) XXX_Marshal 

func (m *Resources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resources) XXX_Merge 

func (dst *Resources) XXX_Merge(src proto.Message)

func (*Resources) XXX_Size 

func (m *Resources) XXX_Size() int

func (*Resources) XXX_Unmarshal 

func (m *Resources) XXX_Unmarshal(b []byte) error

type ResourcesValidationError 

type ResourcesValidationError struct {
	// contains filtered or unexported fields
}

ResourcesValidationError is the validation error returned by Resources.Validate if the designated constraints aren't met.

func (ResourcesValidationError) Cause 

func (e ResourcesValidationError) Cause() error

Cause function returns cause value.

func (ResourcesValidationError) Error 

func (e ResourcesValidationError) Error() string

Error satisfies the builtin error interface

func (ResourcesValidationError) ErrorName 

func (e ResourcesValidationError) ErrorName() string

ErrorName returns error name.

func (ResourcesValidationError) Field 

func (e ResourcesValidationError) Field() string

Field function returns field value.

func (ResourcesValidationError) Key 

func (e ResourcesValidationError) Key() bool

Key function returns key value.

func (ResourcesValidationError) Reason 

func (e ResourcesValidationError) Reason() string

Reason function returns reason value.

type Resources_ResourceEntry 

type Resources_ResourceEntry struct {
	// Resource name.
	Name Resources_ResourceName `protobuf:"varint,1,opt,name=name,proto3,enum=flyteidl.core.Resources_ResourceName" json:"name,omitempty"`
	// Value must be a valid k8s quantity. See
	// https://github.com/kubernetes/apimachinery/blob/master/pkg/api/resource/quantity.go#L30-L80
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Encapsulates a resource name and value.

func (*Resources_ResourceEntry) Descriptor 

func (*Resources_ResourceEntry) Descriptor() ([]byte, []int)

func (*Resources_ResourceEntry) GetName 

func (m *Resources_ResourceEntry) GetName() Resources_ResourceName

func (*Resources_ResourceEntry) GetValue 

func (m *Resources_ResourceEntry) GetValue() string

func (*Resources_ResourceEntry) ProtoMessage 

func (*Resources_ResourceEntry) ProtoMessage()

func (*Resources_ResourceEntry) Reset 

func (m *Resources_ResourceEntry) Reset()

func (*Resources_ResourceEntry) String 

func (m *Resources_ResourceEntry) String() string

func (*Resources_ResourceEntry) Validate 

func (m *Resources_ResourceEntry) Validate() error

Validate checks the field values on Resources_ResourceEntry with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Resources_ResourceEntry) XXX_DiscardUnknown 

func (m *Resources_ResourceEntry) XXX_DiscardUnknown()

func (*Resources_ResourceEntry) XXX_Marshal 

func (m *Resources_ResourceEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resources_ResourceEntry) XXX_Merge 

func (dst *Resources_ResourceEntry) XXX_Merge(src proto.Message)

func (*Resources_ResourceEntry) XXX_Size 

func (m *Resources_ResourceEntry) XXX_Size() int

func (*Resources_ResourceEntry) XXX_Unmarshal 

func (m *Resources_ResourceEntry) XXX_Unmarshal(b []byte) error

type Resources_ResourceEntryValidationError 

type Resources_ResourceEntryValidationError struct {
	// contains filtered or unexported fields
}

Resources_ResourceEntryValidationError is the validation error returned by Resources_ResourceEntry.Validate if the designated constraints aren't met.

func (Resources_ResourceEntryValidationError) Cause 

func (e Resources_ResourceEntryValidationError) Cause() error

Cause function returns cause value.

func (Resources_ResourceEntryValidationError) Error 

func (e Resources_ResourceEntryValidationError) Error() string

Error satisfies the builtin error interface

func (Resources_ResourceEntryValidationError) ErrorName 

func (e Resources_ResourceEntryValidationError) ErrorName() string

ErrorName returns error name.

func (Resources_ResourceEntryValidationError) Field 

func (e Resources_ResourceEntryValidationError) Field() string

Field function returns field value.

func (Resources_ResourceEntryValidationError) Key 

func (e Resources_ResourceEntryValidationError) Key() bool

Key function returns key value.

func (Resources_ResourceEntryValidationError) Reason 

func (e Resources_ResourceEntryValidationError) Reason() string

Reason function returns reason value.

type Resources_ResourceName 

type Resources_ResourceName int32

Known resource names. 

const (
	Resources_UNKNOWN Resources_ResourceName = 0
	Resources_CPU     Resources_ResourceName = 1
	Resources_GPU     Resources_ResourceName = 2
	Resources_MEMORY  Resources_ResourceName = 3
	Resources_STORAGE Resources_ResourceName = 4
)

func (Resources_ResourceName) EnumDescriptor 

func (Resources_ResourceName) EnumDescriptor() ([]byte, []int)

func (Resources_ResourceName) String 

func (x Resources_ResourceName) String() string

type RetryStrategy 

type RetryStrategy struct {
	// Number of retries. Retries will be consumed when the job fails with a recoverable error.
	// The number of retries must be less than or equals to 10.
	Retries              uint32   `protobuf:"varint,5,opt,name=retries,proto3" json:"retries,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Retry strategy associated with an executable unit.

func (*RetryStrategy) Descriptor 

func (*RetryStrategy) Descriptor() ([]byte, []int)

func (*RetryStrategy) GetRetries 

func (m *RetryStrategy) GetRetries() uint32

func (*RetryStrategy) ProtoMessage 

func (*RetryStrategy) ProtoMessage()

func (*RetryStrategy) Reset 

func (m *RetryStrategy) Reset()

func (*RetryStrategy) String 

func (m *RetryStrategy) String() string

func (*RetryStrategy) Validate 

func (m *RetryStrategy) Validate() error

Validate checks the field values on RetryStrategy with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*RetryStrategy) XXX_DiscardUnknown 

func (m *RetryStrategy) XXX_DiscardUnknown()

func (*RetryStrategy) XXX_Marshal 

func (m *RetryStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetryStrategy) XXX_Merge 

func (dst *RetryStrategy) XXX_Merge(src proto.Message)

func (*RetryStrategy) XXX_Size 

func (m *RetryStrategy) XXX_Size() int

func (*RetryStrategy) XXX_Unmarshal 

func (m *RetryStrategy) XXX_Unmarshal(b []byte) error

type RetryStrategyValidationError 

type RetryStrategyValidationError struct {
	// contains filtered or unexported fields
}

RetryStrategyValidationError is the validation error returned by RetryStrategy.Validate if the designated constraints aren't met.

func (RetryStrategyValidationError) Cause 

func (e RetryStrategyValidationError) Cause() error

Cause function returns cause value.

func (RetryStrategyValidationError) Error 

func (e RetryStrategyValidationError) Error() string

Error satisfies the builtin error interface

func (RetryStrategyValidationError) ErrorName 

func (e RetryStrategyValidationError) ErrorName() string

ErrorName returns error name.

func (RetryStrategyValidationError) Field 

func (e RetryStrategyValidationError) Field() string

Field function returns field value.

func (RetryStrategyValidationError) Key 

func (e RetryStrategyValidationError) Key() bool

Key function returns key value.

func (RetryStrategyValidationError) Reason 

func (e RetryStrategyValidationError) Reason() string

Reason function returns reason value.

type RuntimeMetadata 

type RuntimeMetadata struct {
	// Type of runtime.
	Type RuntimeMetadata_RuntimeType `protobuf:"varint,1,opt,name=type,proto3,enum=flyteidl.core.RuntimeMetadata_RuntimeType" json:"type,omitempty"`
	// Version of the runtime. All versions should be backward compatible. However, certain cases call for version
	// checks to ensure tighter validation or setting expectations.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// +optional It can be used to provide extra information about the runtime (e.g. python, golang... etc.).
	Flavor               string   `protobuf:"bytes,3,opt,name=flavor,proto3" json:"flavor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Runtime information. This is losely defined to allow for extensibility.

func (*RuntimeMetadata) Descriptor 

func (*RuntimeMetadata) Descriptor() ([]byte, []int)

func (*RuntimeMetadata) GetFlavor 

func (m *RuntimeMetadata) GetFlavor() string

func (*RuntimeMetadata) GetType 

func (m *RuntimeMetadata) GetType() RuntimeMetadata_RuntimeType

func (*RuntimeMetadata) GetVersion 

func (m *RuntimeMetadata) GetVersion() string

func (*RuntimeMetadata) ProtoMessage 

func (*RuntimeMetadata) ProtoMessage()

func (*RuntimeMetadata) Reset 

func (m *RuntimeMetadata) Reset()

func (*RuntimeMetadata) String 

func (m *RuntimeMetadata) String() string

func (*RuntimeMetadata) Validate 

func (m *RuntimeMetadata) Validate() error

Validate checks the field values on RuntimeMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*RuntimeMetadata) XXX_DiscardUnknown 

func (m *RuntimeMetadata) XXX_DiscardUnknown()

func (*RuntimeMetadata) XXX_Marshal 

func (m *RuntimeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuntimeMetadata) XXX_Merge 

func (dst *RuntimeMetadata) XXX_Merge(src proto.Message)

func (*RuntimeMetadata) XXX_Size 

func (m *RuntimeMetadata) XXX_Size() int

func (*RuntimeMetadata) XXX_Unmarshal 

func (m *RuntimeMetadata) XXX_Unmarshal(b []byte) error

type RuntimeMetadataValidationError 

type RuntimeMetadataValidationError struct {
	// contains filtered or unexported fields
}

RuntimeMetadataValidationError is the validation error returned by RuntimeMetadata.Validate if the designated constraints aren't met.

func (RuntimeMetadataValidationError) Cause 

func (e RuntimeMetadataValidationError) Cause() error

Cause function returns cause value.

func (RuntimeMetadataValidationError) Error 

func (e RuntimeMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (RuntimeMetadataValidationError) ErrorName 

func (e RuntimeMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (RuntimeMetadataValidationError) Field 

func (e RuntimeMetadataValidationError) Field() string

Field function returns field value.

func (RuntimeMetadataValidationError) Key 

func (e RuntimeMetadataValidationError) Key() bool

Key function returns key value.

func (RuntimeMetadataValidationError) Reason 

func (e RuntimeMetadataValidationError) Reason() string

Reason function returns reason value.

type RuntimeMetadata_RuntimeType 

type RuntimeMetadata_RuntimeType int32
const (
	RuntimeMetadata_OTHER     RuntimeMetadata_RuntimeType = 0
	RuntimeMetadata_FLYTE_SDK RuntimeMetadata_RuntimeType = 1
)

func (RuntimeMetadata_RuntimeType) EnumDescriptor 

func (RuntimeMetadata_RuntimeType) EnumDescriptor() ([]byte, []int)

func (RuntimeMetadata_RuntimeType) String 

func (x RuntimeMetadata_RuntimeType) String() string

type Scalar 

type Scalar struct {
	// Types that are valid to be assigned to Value:
	//	*Scalar_Primitive
	//	*Scalar_Blob
	//	*Scalar_Binary
	//	*Scalar_Schema
	//	*Scalar_NoneType
	//	*Scalar_Error
	//	*Scalar_Generic
	Value                isScalar_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Scalar) Descriptor 

func (*Scalar) Descriptor() ([]byte, []int)

func (*Scalar) GetBinary 

func (m *Scalar) GetBinary() *Binary

func (*Scalar) GetBlob 

func (m *Scalar) GetBlob() *Blob

func (*Scalar) GetError 

func (m *Scalar) GetError() *Error

func (*Scalar) GetGeneric 

func (m *Scalar) GetGeneric() *_struct.Struct

func (*Scalar) GetNoneType 

func (m *Scalar) GetNoneType() *Void

func (*Scalar) GetPrimitive 

func (m *Scalar) GetPrimitive() *Primitive

func (*Scalar) GetSchema 

func (m *Scalar) GetSchema() *Schema

func (*Scalar) GetValue 

func (m *Scalar) GetValue() isScalar_Value

func (*Scalar) ProtoMessage 

func (*Scalar) ProtoMessage()

func (*Scalar) Reset 

func (m *Scalar) Reset()

func (*Scalar) String 

func (m *Scalar) String() string

func (*Scalar) Validate 

func (m *Scalar) Validate() error

Validate checks the field values on Scalar with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Scalar) XXX_DiscardUnknown 

func (m *Scalar) XXX_DiscardUnknown()

func (*Scalar) XXX_Marshal 

func (m *Scalar) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Scalar) XXX_Merge 

func (dst *Scalar) XXX_Merge(src proto.Message)

func (*Scalar) XXX_OneofFuncs 

func (*Scalar) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Scalar) XXX_Size 

func (m *Scalar) XXX_Size() int

func (*Scalar) XXX_Unmarshal 

func (m *Scalar) XXX_Unmarshal(b []byte) error

type ScalarValidationError 

type ScalarValidationError struct {
	// contains filtered or unexported fields
}

ScalarValidationError is the validation error returned by Scalar.Validate if the designated constraints aren't met.

func (ScalarValidationError) Cause 

func (e ScalarValidationError) Cause() error

Cause function returns cause value.

func (ScalarValidationError) Error 

func (e ScalarValidationError) Error() string

Error satisfies the builtin error interface

func (ScalarValidationError) ErrorName 

func (e ScalarValidationError) ErrorName() string

ErrorName returns error name.

func (ScalarValidationError) Field 

func (e ScalarValidationError) Field() string

Field function returns field value.

func (ScalarValidationError) Key 

func (e ScalarValidationError) Key() bool

Key function returns key value.

func (ScalarValidationError) Reason 

func (e ScalarValidationError) Reason() string

Reason function returns reason value.

type Scalar_Binary 

type Scalar_Binary struct {
	Binary *Binary `protobuf:"bytes,3,opt,name=binary,proto3,oneof"`
}

type Scalar_Blob 

type Scalar_Blob struct {
	Blob *Blob `protobuf:"bytes,2,opt,name=blob,proto3,oneof"`
}

type Scalar_Error 

type Scalar_Error struct {
	Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type Scalar_Generic 

type Scalar_Generic struct {
	Generic *_struct.Struct `protobuf:"bytes,7,opt,name=generic,proto3,oneof"`
}

type Scalar_NoneType 

type Scalar_NoneType struct {
	NoneType *Void `protobuf:"bytes,5,opt,name=none_type,json=noneType,proto3,oneof"`
}

type Scalar_Primitive 

type Scalar_Primitive struct {
	Primitive *Primitive `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}

type Scalar_Schema 

type Scalar_Schema struct {
	Schema *Schema `protobuf:"bytes,4,opt,name=schema,proto3,oneof"`
}

type Schema 

type Schema struct {
	Uri                  string      `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Type                 *SchemaType `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

A strongly typed schema that defines the interface of data retrieved from the underlying storage medium.

func (*Schema) Descriptor 

func (*Schema) Descriptor() ([]byte, []int)

func (*Schema) GetType 

func (m *Schema) GetType() *SchemaType

func (*Schema) GetUri 

func (m *Schema) GetUri() string

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) Reset 

func (m *Schema) Reset()

func (*Schema) String 

func (m *Schema) String() string

func (*Schema) Validate 

func (m *Schema) Validate() error

Validate checks the field values on Schema with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Schema) XXX_DiscardUnknown 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal 

func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schema) XXX_Merge 

func (dst *Schema) XXX_Merge(src proto.Message)

func (*Schema) XXX_Size 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal 

func (m *Schema) XXX_Unmarshal(b []byte) error

type SchemaType 

type SchemaType struct {
	// A list of ordered columns this schema comprises of.
	Columns              []*SchemaType_SchemaColumn `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Defines schema columns and types to strongly type-validate schemas interoperability.

func (*SchemaType) Descriptor 

func (*SchemaType) Descriptor() ([]byte, []int)

func (*SchemaType) GetColumns 

func (m *SchemaType) GetColumns() []*SchemaType_SchemaColumn

func (*SchemaType) ProtoMessage 

func (*SchemaType) ProtoMessage()

func (*SchemaType) Reset 

func (m *SchemaType) Reset()

func (*SchemaType) String 

func (m *SchemaType) String() string

func (*SchemaType) Validate 

func (m *SchemaType) Validate() error

Validate checks the field values on SchemaType with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SchemaType) XXX_DiscardUnknown 

func (m *SchemaType) XXX_DiscardUnknown()

func (*SchemaType) XXX_Marshal 

func (m *SchemaType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaType) XXX_Merge 

func (dst *SchemaType) XXX_Merge(src proto.Message)

func (*SchemaType) XXX_Size 

func (m *SchemaType) XXX_Size() int

func (*SchemaType) XXX_Unmarshal 

func (m *SchemaType) XXX_Unmarshal(b []byte) error

type SchemaTypeValidationError 

type SchemaTypeValidationError struct {
	// contains filtered or unexported fields
}

SchemaTypeValidationError is the validation error returned by SchemaType.Validate if the designated constraints aren't met.

func (SchemaTypeValidationError) Cause 

func (e SchemaTypeValidationError) Cause() error

Cause function returns cause value.

func (SchemaTypeValidationError) Error 

func (e SchemaTypeValidationError) Error() string

Error satisfies the builtin error interface

func (SchemaTypeValidationError) ErrorName 

func (e SchemaTypeValidationError) ErrorName() string

ErrorName returns error name.

func (SchemaTypeValidationError) Field 

func (e SchemaTypeValidationError) Field() string

Field function returns field value.

func (SchemaTypeValidationError) Key 

func (e SchemaTypeValidationError) Key() bool

Key function returns key value.

func (SchemaTypeValidationError) Reason 

func (e SchemaTypeValidationError) Reason() string

Reason function returns reason value.

type SchemaType_SchemaColumn 

type SchemaType_SchemaColumn struct {
	// A unique name -within the schema type- for the column
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The column type. This allows a limited set of types currently.
	Type                 SchemaType_SchemaColumn_SchemaColumnType `protobuf:"varint,2,opt,name=type,proto3,enum=flyteidl.core.SchemaType_SchemaColumn_SchemaColumnType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
	XXX_unrecognized     []byte                                   `json:"-"`
	XXX_sizecache        int32                                    `json:"-"`
}

func (*SchemaType_SchemaColumn) Descriptor 

func (*SchemaType_SchemaColumn) Descriptor() ([]byte, []int)

func (*SchemaType_SchemaColumn) GetName 

func (m *SchemaType_SchemaColumn) GetName() string

func (*SchemaType_SchemaColumn) GetType 

func (m *SchemaType_SchemaColumn) GetType() SchemaType_SchemaColumn_SchemaColumnType

func (*SchemaType_SchemaColumn) ProtoMessage 

func (*SchemaType_SchemaColumn) ProtoMessage()

func (*SchemaType_SchemaColumn) Reset 

func (m *SchemaType_SchemaColumn) Reset()

func (*SchemaType_SchemaColumn) String 

func (m *SchemaType_SchemaColumn) String() string

func (*SchemaType_SchemaColumn) Validate 

func (m *SchemaType_SchemaColumn) Validate() error

Validate checks the field values on SchemaType_SchemaColumn with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SchemaType_SchemaColumn) XXX_DiscardUnknown 

func (m *SchemaType_SchemaColumn) XXX_DiscardUnknown()

func (*SchemaType_SchemaColumn) XXX_Marshal 

func (m *SchemaType_SchemaColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaType_SchemaColumn) XXX_Merge 

func (dst *SchemaType_SchemaColumn) XXX_Merge(src proto.Message)

func (*SchemaType_SchemaColumn) XXX_Size 

func (m *SchemaType_SchemaColumn) XXX_Size() int

func (*SchemaType_SchemaColumn) XXX_Unmarshal 

func (m *SchemaType_SchemaColumn) XXX_Unmarshal(b []byte) error

type SchemaType_SchemaColumnValidationError 

type SchemaType_SchemaColumnValidationError struct {
	// contains filtered or unexported fields
}

SchemaType_SchemaColumnValidationError is the validation error returned by SchemaType_SchemaColumn.Validate if the designated constraints aren't met.

func (SchemaType_SchemaColumnValidationError) Cause 

func (e SchemaType_SchemaColumnValidationError) Cause() error

Cause function returns cause value.

func (SchemaType_SchemaColumnValidationError) Error 

func (e SchemaType_SchemaColumnValidationError) Error() string

Error satisfies the builtin error interface

func (SchemaType_SchemaColumnValidationError) ErrorName 

func (e SchemaType_SchemaColumnValidationError) ErrorName() string

ErrorName returns error name.

func (SchemaType_SchemaColumnValidationError) Field 

func (e SchemaType_SchemaColumnValidationError) Field() string

Field function returns field value.

func (SchemaType_SchemaColumnValidationError) Key 

func (e SchemaType_SchemaColumnValidationError) Key() bool

Key function returns key value.

func (SchemaType_SchemaColumnValidationError) Reason 

func (e SchemaType_SchemaColumnValidationError) Reason() string

Reason function returns reason value.

type SchemaType_SchemaColumn_SchemaColumnType 

type SchemaType_SchemaColumn_SchemaColumnType int32
const (
	SchemaType_SchemaColumn_INTEGER  SchemaType_SchemaColumn_SchemaColumnType = 0
	SchemaType_SchemaColumn_FLOAT    SchemaType_SchemaColumn_SchemaColumnType = 1
	SchemaType_SchemaColumn_STRING   SchemaType_SchemaColumn_SchemaColumnType = 2
	SchemaType_SchemaColumn_BOOLEAN  SchemaType_SchemaColumn_SchemaColumnType = 3
	SchemaType_SchemaColumn_DATETIME SchemaType_SchemaColumn_SchemaColumnType = 4
	SchemaType_SchemaColumn_DURATION SchemaType_SchemaColumn_SchemaColumnType = 5
)

func (SchemaType_SchemaColumn_SchemaColumnType) EnumDescriptor 

func (SchemaType_SchemaColumn_SchemaColumnType) EnumDescriptor() ([]byte, []int)

func (SchemaType_SchemaColumn_SchemaColumnType) String 

func (x SchemaType_SchemaColumn_SchemaColumnType) String() string

type SchemaValidationError 

type SchemaValidationError struct {
	// contains filtered or unexported fields
}

SchemaValidationError is the validation error returned by Schema.Validate if the designated constraints aren't met.

func (SchemaValidationError) Cause 

func (e SchemaValidationError) Cause() error

Cause function returns cause value.

func (SchemaValidationError) Error 

func (e SchemaValidationError) Error() string

Error satisfies the builtin error interface

func (SchemaValidationError) ErrorName 

func (e SchemaValidationError) ErrorName() string

ErrorName returns error name.

func (SchemaValidationError) Field 

func (e SchemaValidationError) Field() string

Field function returns field value.

func (SchemaValidationError) Key 

func (e SchemaValidationError) Key() bool

Key function returns key value.

func (SchemaValidationError) Reason 

func (e SchemaValidationError) Reason() string

Reason function returns reason value.

type SimpleType 

type SimpleType int32

Define a set of simple types. 

const (
	SimpleType_NONE     SimpleType = 0
	SimpleType_INTEGER  SimpleType = 1
	SimpleType_FLOAT    SimpleType = 2
	SimpleType_STRING   SimpleType = 3
	SimpleType_BOOLEAN  SimpleType = 4
	SimpleType_DATETIME SimpleType = 5
	SimpleType_DURATION SimpleType = 6
	SimpleType_BINARY   SimpleType = 7
	SimpleType_ERROR    SimpleType = 8
	SimpleType_STRUCT   SimpleType = 9
)

func (SimpleType) EnumDescriptor 

func (SimpleType) EnumDescriptor() ([]byte, []int)

func (SimpleType) String 

func (x SimpleType) String() string

type TaskExecution 

type TaskExecution struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Phases that task plugins can go through. Not all phases may be applicable to a specific plugin task, but this is the cumulative list that customers may want to know about for their task.

func (*TaskExecution) Descriptor 

func (*TaskExecution) Descriptor() ([]byte, []int)

func (*TaskExecution) ProtoMessage 

func (*TaskExecution) ProtoMessage()

func (*TaskExecution) Reset 

func (m *TaskExecution) Reset()

func (*TaskExecution) String 

func (m *TaskExecution) String() string

func (*TaskExecution) Validate 

func (m *TaskExecution) Validate() error

Validate checks the field values on TaskExecution with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecution) XXX_DiscardUnknown 

func (m *TaskExecution) XXX_DiscardUnknown()

func (*TaskExecution) XXX_Marshal 

func (m *TaskExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskExecution) XXX_Merge 

func (dst *TaskExecution) XXX_Merge(src proto.Message)

func (*TaskExecution) XXX_Size 

func (m *TaskExecution) XXX_Size() int

func (*TaskExecution) XXX_Unmarshal 

func (m *TaskExecution) XXX_Unmarshal(b []byte) error

type TaskExecutionIdentifier 

type TaskExecutionIdentifier struct {
	TaskId               *Identifier              `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NodeExecutionId      *NodeExecutionIdentifier `protobuf:"bytes,2,opt,name=node_execution_id,json=nodeExecutionId,proto3" json:"node_execution_id,omitempty"`
	RetryAttempt         uint32                   `protobuf:"varint,3,opt,name=retry_attempt,json=retryAttempt,proto3" json:"retry_attempt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Encapsulation of fields that identify a Flyte task execution entity.

func (*TaskExecutionIdentifier) Descriptor 

func (*TaskExecutionIdentifier) Descriptor() ([]byte, []int)

func (*TaskExecutionIdentifier) GetNodeExecutionId 

func (m *TaskExecutionIdentifier) GetNodeExecutionId() *NodeExecutionIdentifier

func (*TaskExecutionIdentifier) GetRetryAttempt 

func (m *TaskExecutionIdentifier) GetRetryAttempt() uint32

func (*TaskExecutionIdentifier) GetTaskId 

func (m *TaskExecutionIdentifier) GetTaskId() *Identifier

func (*TaskExecutionIdentifier) ProtoMessage 

func (*TaskExecutionIdentifier) ProtoMessage()

func (*TaskExecutionIdentifier) Reset 

func (m *TaskExecutionIdentifier) Reset()

func (*TaskExecutionIdentifier) String 

func (m *TaskExecutionIdentifier) String() string

func (*TaskExecutionIdentifier) Validate 

func (m *TaskExecutionIdentifier) Validate() error

Validate checks the field values on TaskExecutionIdentifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionIdentifier) XXX_DiscardUnknown 

func (m *TaskExecutionIdentifier) XXX_DiscardUnknown()

func (*TaskExecutionIdentifier) XXX_Marshal 

func (m *TaskExecutionIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskExecutionIdentifier) XXX_Merge 

func (dst *TaskExecutionIdentifier) XXX_Merge(src proto.Message)

func (*TaskExecutionIdentifier) XXX_Size 

func (m *TaskExecutionIdentifier) XXX_Size() int

func (*TaskExecutionIdentifier) XXX_Unmarshal 

func (m *TaskExecutionIdentifier) XXX_Unmarshal(b []byte) error

type TaskExecutionIdentifierValidationError 

type TaskExecutionIdentifierValidationError struct {
	// contains filtered or unexported fields
}

TaskExecutionIdentifierValidationError is the validation error returned by TaskExecutionIdentifier.Validate if the designated constraints aren't met.

func (TaskExecutionIdentifierValidationError) Cause 

func (e TaskExecutionIdentifierValidationError) Cause() error

Cause function returns cause value.

func (TaskExecutionIdentifierValidationError) Error 

func (e TaskExecutionIdentifierValidationError) Error() string

Error satisfies the builtin error interface

func (TaskExecutionIdentifierValidationError) ErrorName 

func (e TaskExecutionIdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (TaskExecutionIdentifierValidationError) Field 

func (e TaskExecutionIdentifierValidationError) Field() string

Field function returns field value.

func (TaskExecutionIdentifierValidationError) Key 

func (e TaskExecutionIdentifierValidationError) Key() bool

Key function returns key value.

func (TaskExecutionIdentifierValidationError) Reason 

func (e TaskExecutionIdentifierValidationError) Reason() string

Reason function returns reason value.

type TaskExecutionValidationError 

type TaskExecutionValidationError struct {
	// contains filtered or unexported fields
}

TaskExecutionValidationError is the validation error returned by TaskExecution.Validate if the designated constraints aren't met.

func (TaskExecutionValidationError) Cause 

func (e TaskExecutionValidationError) Cause() error

Cause function returns cause value.

func (TaskExecutionValidationError) Error 

func (e TaskExecutionValidationError) Error() string

Error satisfies the builtin error interface

func (TaskExecutionValidationError) ErrorName 

func (e TaskExecutionValidationError) ErrorName() string

ErrorName returns error name.

func (TaskExecutionValidationError) Field 

func (e TaskExecutionValidationError) Field() string

Field function returns field value.

func (TaskExecutionValidationError) Key 

func (e TaskExecutionValidationError) Key() bool

Key function returns key value.

func (TaskExecutionValidationError) Reason 

func (e TaskExecutionValidationError) Reason() string

Reason function returns reason value.

type TaskExecution_Phase 

type TaskExecution_Phase int32
const (
	TaskExecution_UNDEFINED TaskExecution_Phase = 0
	TaskExecution_QUEUED    TaskExecution_Phase = 1
	TaskExecution_RUNNING   TaskExecution_Phase = 2
	TaskExecution_SUCCEEDED TaskExecution_Phase = 3
	TaskExecution_ABORTED   TaskExecution_Phase = 4
	TaskExecution_FAILED    TaskExecution_Phase = 5
)

func (TaskExecution_Phase) EnumDescriptor 

func (TaskExecution_Phase) EnumDescriptor() ([]byte, []int)

func (TaskExecution_Phase) String 

func (x TaskExecution_Phase) String() string

type TaskLog 

type TaskLog struct {
	Uri                  string                `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Name                 string                `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	MessageFormat        TaskLog_MessageFormat `` /* 142-byte string literal not displayed */
	Ttl                  *duration.Duration    `protobuf:"bytes,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Log information for the task that is specific to a log sink When our log story is flushed out, we may have more metadata here like log link expiry

func (*TaskLog) Descriptor 

func (*TaskLog) Descriptor() ([]byte, []int)

func (*TaskLog) GetMessageFormat 

func (m *TaskLog) GetMessageFormat() TaskLog_MessageFormat

func (*TaskLog) GetName 

func (m *TaskLog) GetName() string

func (*TaskLog) GetTtl 

func (m *TaskLog) GetTtl() *duration.Duration

func (*TaskLog) GetUri 

func (m *TaskLog) GetUri() string

func (*TaskLog) ProtoMessage 

func (*TaskLog) ProtoMessage()

func (*TaskLog) Reset 

func (m *TaskLog) Reset()

func (*TaskLog) String 

func (m *TaskLog) String() string

func (*TaskLog) Validate 

func (m *TaskLog) Validate() error

Validate checks the field values on TaskLog with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskLog) XXX_DiscardUnknown 

func (m *TaskLog) XXX_DiscardUnknown()

func (*TaskLog) XXX_Marshal 

func (m *TaskLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskLog) XXX_Merge 

func (dst *TaskLog) XXX_Merge(src proto.Message)

func (*TaskLog) XXX_Size 

func (m *TaskLog) XXX_Size() int

func (*TaskLog) XXX_Unmarshal 

func (m *TaskLog) XXX_Unmarshal(b []byte) error

type TaskLogValidationError 

type TaskLogValidationError struct {
	// contains filtered or unexported fields
}

TaskLogValidationError is the validation error returned by TaskLog.Validate if the designated constraints aren't met.

func (TaskLogValidationError) Cause 

func (e TaskLogValidationError) Cause() error

Cause function returns cause value.

func (TaskLogValidationError) Error 

func (e TaskLogValidationError) Error() string

Error satisfies the builtin error interface

func (TaskLogValidationError) ErrorName 

func (e TaskLogValidationError) ErrorName() string

ErrorName returns error name.

func (TaskLogValidationError) Field 

func (e TaskLogValidationError) Field() string

Field function returns field value.

func (TaskLogValidationError) Key 

func (e TaskLogValidationError) Key() bool

Key function returns key value.

func (TaskLogValidationError) Reason 

func (e TaskLogValidationError) Reason() string

Reason function returns reason value.

type TaskLog_MessageFormat 

type TaskLog_MessageFormat int32
const (
	TaskLog_UNKNOWN TaskLog_MessageFormat = 0
	TaskLog_CSV     TaskLog_MessageFormat = 1
	TaskLog_JSON    TaskLog_MessageFormat = 2
)

func (TaskLog_MessageFormat) EnumDescriptor 

func (TaskLog_MessageFormat) EnumDescriptor() ([]byte, []int)

func (TaskLog_MessageFormat) String 

func (x TaskLog_MessageFormat) String() string

type TaskMetadata 

type TaskMetadata struct {
	// Indicates whether the system should attempt to lookup this task's output to avoid duplication of work.
	Discoverable bool `protobuf:"varint,1,opt,name=discoverable,proto3" json:"discoverable,omitempty"`
	// Runtime information about the task.
	Runtime *RuntimeMetadata `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// The overall timeout of a task including user-triggered retries.
	Timeout *duration.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of retries per task.
	Retries *RetryStrategy `protobuf:"bytes,5,opt,name=retries,proto3" json:"retries,omitempty"`
	// Indicates a logical version to apply to this task for the purpose of discovery.
	DiscoveryVersion string `protobuf:"bytes,6,opt,name=discovery_version,json=discoveryVersion,proto3" json:"discovery_version,omitempty"`
	// If set, this indicates that this task is deprecated.  This will enable owners of tasks to notify consumers
	// of the ending of support for a given task.
	DeprecatedErrorMessage string   `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

Task Metadata

func (*TaskMetadata) Descriptor 

func (*TaskMetadata) Descriptor() ([]byte, []int)

func (*TaskMetadata) GetDeprecatedErrorMessage 

func (m *TaskMetadata) GetDeprecatedErrorMessage() string

func (*TaskMetadata) GetDiscoverable 

func (m *TaskMetadata) GetDiscoverable() bool

func (*TaskMetadata) GetDiscoveryVersion 

func (m *TaskMetadata) GetDiscoveryVersion() string

func (*TaskMetadata) GetRetries 

func (m *TaskMetadata) GetRetries() *RetryStrategy

func (*TaskMetadata) GetRuntime 

func (m *TaskMetadata) GetRuntime() *RuntimeMetadata

func (*TaskMetadata) GetTimeout 

func (m *TaskMetadata) GetTimeout() *duration.Duration

func (*TaskMetadata) ProtoMessage 

func (*TaskMetadata) ProtoMessage()

func (*TaskMetadata) Reset 

func (m *TaskMetadata) Reset()

func (*TaskMetadata) String 

func (m *TaskMetadata) String() string

func (*TaskMetadata) Validate 

func (m *TaskMetadata) Validate() error

Validate checks the field values on TaskMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskMetadata) XXX_DiscardUnknown 

func (m *TaskMetadata) XXX_DiscardUnknown()

func (*TaskMetadata) XXX_Marshal 

func (m *TaskMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskMetadata) XXX_Merge 

func (dst *TaskMetadata) XXX_Merge(src proto.Message)

func (*TaskMetadata) XXX_Size 

func (m *TaskMetadata) XXX_Size() int

func (*TaskMetadata) XXX_Unmarshal 

func (m *TaskMetadata) XXX_Unmarshal(b []byte) error

type TaskMetadataValidationError 

type TaskMetadataValidationError struct {
	// contains filtered or unexported fields
}

TaskMetadataValidationError is the validation error returned by TaskMetadata.Validate if the designated constraints aren't met.

func (TaskMetadataValidationError) Cause 

func (e TaskMetadataValidationError) Cause() error

Cause function returns cause value.

func (TaskMetadataValidationError) Error 

func (e TaskMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TaskMetadataValidationError) ErrorName 

func (e TaskMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskMetadataValidationError) Field 

func (e TaskMetadataValidationError) Field() string

Field function returns field value.

func (TaskMetadataValidationError) Key 

func (e TaskMetadataValidationError) Key() bool

Key function returns key value.

func (TaskMetadataValidationError) Reason 

func (e TaskMetadataValidationError) Reason() string

Reason function returns reason value.

type TaskNode 

type TaskNode struct {
	// Types that are valid to be assigned to Reference:
	//	*TaskNode_ReferenceId
	Reference            isTaskNode_Reference `protobuf_oneof:"reference"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Refers to the task that the Node is to execute.

func (*TaskNode) Descriptor 

func (*TaskNode) Descriptor() ([]byte, []int)

func (*TaskNode) GetReference 

func (m *TaskNode) GetReference() isTaskNode_Reference

func (*TaskNode) GetReferenceId 

func (m *TaskNode) GetReferenceId() *Identifier

func (*TaskNode) ProtoMessage 

func (*TaskNode) ProtoMessage()

func (*TaskNode) Reset 

func (m *TaskNode) Reset()

func (*TaskNode) String 

func (m *TaskNode) String() string

func (*TaskNode) Validate 

func (m *TaskNode) Validate() error

Validate checks the field values on TaskNode with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskNode) XXX_DiscardUnknown 

func (m *TaskNode) XXX_DiscardUnknown()

func (*TaskNode) XXX_Marshal 

func (m *TaskNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskNode) XXX_Merge 

func (dst *TaskNode) XXX_Merge(src proto.Message)

func (*TaskNode) XXX_OneofFuncs 

func (*TaskNode) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*TaskNode) XXX_Size 

func (m *TaskNode) XXX_Size() int

func (*TaskNode) XXX_Unmarshal 

func (m *TaskNode) XXX_Unmarshal(b []byte) error

type TaskNodeValidationError 

type TaskNodeValidationError struct {
	// contains filtered or unexported fields
}

TaskNodeValidationError is the validation error returned by TaskNode.Validate if the designated constraints aren't met.

func (TaskNodeValidationError) Cause 

func (e TaskNodeValidationError) Cause() error

Cause function returns cause value.

func (TaskNodeValidationError) Error 

func (e TaskNodeValidationError) Error() string

Error satisfies the builtin error interface

func (TaskNodeValidationError) ErrorName 

func (e TaskNodeValidationError) ErrorName() string

ErrorName returns error name.

func (TaskNodeValidationError) Field 

func (e TaskNodeValidationError) Field() string

Field function returns field value.

func (TaskNodeValidationError) Key 

func (e TaskNodeValidationError) Key() bool

Key function returns key value.

func (TaskNodeValidationError) Reason 

func (e TaskNodeValidationError) Reason() string

Reason function returns reason value.

type TaskNode_ReferenceId 

type TaskNode_ReferenceId struct {
	ReferenceId *Identifier `protobuf:"bytes,1,opt,name=reference_id,json=referenceId,proto3,oneof"`
}

type TaskTemplate 

type TaskTemplate struct {
	// Auto generated taskId by the system. Task Id uniquely identifies this task globally.
	Id *Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A predefined yet extensible Task type identifier. This can be used to customize any of the components. If no
	// extensions are provided in the system, Flyte will resolve the this task to its TaskCategory and default the
	// implementation registered for the TaskCategory.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Extra metadata about the task.
	Metadata *TaskMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// A strongly typed interface for the task. This enables others to use this task within a workflow and gauarantees
	// compile-time validation of the workflow to avoid costly runtime failures.
	Interface *TypedInterface `protobuf:"bytes,4,opt,name=interface,proto3" json:"interface,omitempty"`
	// Custom data about the task. This is extensible to allow various plugins in the system.
	Custom *_struct.Struct `protobuf:"bytes,5,opt,name=custom,proto3" json:"custom,omitempty"`
	// Known target types that the system will guarantee plugins for. Custom SDK plugins are allowed to set these if needed.
	// If no corresponding execution-layer plugins are found, the system will default to handling these using built-in
	// handlers.
	//
	// Types that are valid to be assigned to Target:
	//	*TaskTemplate_Container
	Target               isTaskTemplate_Target `protobuf_oneof:"target"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

A Task structure that uniquely identifies a task in the system Tasks are registered as a first step in the system.

func (*TaskTemplate) Descriptor 

func (*TaskTemplate) Descriptor() ([]byte, []int)

func (*TaskTemplate) GetContainer 

func (m *TaskTemplate) GetContainer() *Container

func (*TaskTemplate) GetCustom 

func (m *TaskTemplate) GetCustom() *_struct.Struct

func (*TaskTemplate) GetId 

func (m *TaskTemplate) GetId() *Identifier

func (*TaskTemplate) GetInterface 

func (m *TaskTemplate) GetInterface() *TypedInterface

func (*TaskTemplate) GetMetadata 

func (m *TaskTemplate) GetMetadata() *TaskMetadata

func (*TaskTemplate) GetTarget 

func (m *TaskTemplate) GetTarget() isTaskTemplate_Target

func (*TaskTemplate) GetType 

func (m *TaskTemplate) GetType() string

func (*TaskTemplate) ProtoMessage 

func (*TaskTemplate) ProtoMessage()

func (*TaskTemplate) Reset 

func (m *TaskTemplate) Reset()

func (*TaskTemplate) String 

func (m *TaskTemplate) String() string

func (*TaskTemplate) Validate 

func (m *TaskTemplate) Validate() error

Validate checks the field values on TaskTemplate with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskTemplate) XXX_DiscardUnknown 

func (m *TaskTemplate) XXX_DiscardUnknown()

func (*TaskTemplate) XXX_Marshal 

func (m *TaskTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskTemplate) XXX_Merge 

func (dst *TaskTemplate) XXX_Merge(src proto.Message)

func (*TaskTemplate) XXX_OneofFuncs 

func (*TaskTemplate) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*TaskTemplate) XXX_Size 

func (m *TaskTemplate) XXX_Size() int

func (*TaskTemplate) XXX_Unmarshal 

func (m *TaskTemplate) XXX_Unmarshal(b []byte) error

type TaskTemplateValidationError 

type TaskTemplateValidationError struct {
	// contains filtered or unexported fields
}

TaskTemplateValidationError is the validation error returned by TaskTemplate.Validate if the designated constraints aren't met.

func (TaskTemplateValidationError) Cause 

func (e TaskTemplateValidationError) Cause() error

Cause function returns cause value.

func (TaskTemplateValidationError) Error 

func (e TaskTemplateValidationError) Error() string

Error satisfies the builtin error interface

func (TaskTemplateValidationError) ErrorName 

func (e TaskTemplateValidationError) ErrorName() string

ErrorName returns error name.

func (TaskTemplateValidationError) Field 

func (e TaskTemplateValidationError) Field() string

Field function returns field value.

func (TaskTemplateValidationError) Key 

func (e TaskTemplateValidationError) Key() bool

Key function returns key value.

func (TaskTemplateValidationError) Reason 

func (e TaskTemplateValidationError) Reason() string

Reason function returns reason value.

type TaskTemplate_Container 

type TaskTemplate_Container struct {
	Container *Container `protobuf:"bytes,6,opt,name=container,proto3,oneof"`
}

type TypedInterface 

type TypedInterface struct {
	Inputs               *VariableMap `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs              *VariableMap `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Defines strongly typed inputs and outputs.

func (*TypedInterface) Descriptor 

func (*TypedInterface) Descriptor() ([]byte, []int)

func (*TypedInterface) GetInputs 

func (m *TypedInterface) GetInputs() *VariableMap

func (*TypedInterface) GetOutputs 

func (m *TypedInterface) GetOutputs() *VariableMap

func (*TypedInterface) ProtoMessage 

func (*TypedInterface) ProtoMessage()

func (*TypedInterface) Reset 

func (m *TypedInterface) Reset()

func (*TypedInterface) String 

func (m *TypedInterface) String() string

func (*TypedInterface) Validate 

func (m *TypedInterface) Validate() error

Validate checks the field values on TypedInterface with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TypedInterface) XXX_DiscardUnknown 

func (m *TypedInterface) XXX_DiscardUnknown()

func (*TypedInterface) XXX_Marshal 

func (m *TypedInterface) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TypedInterface) XXX_Merge 

func (dst *TypedInterface) XXX_Merge(src proto.Message)

func (*TypedInterface) XXX_Size 

func (m *TypedInterface) XXX_Size() int

func (*TypedInterface) XXX_Unmarshal 

func (m *TypedInterface) XXX_Unmarshal(b []byte) error

type TypedInterfaceValidationError 

type TypedInterfaceValidationError struct {
	// contains filtered or unexported fields
}

TypedInterfaceValidationError is the validation error returned by TypedInterface.Validate if the designated constraints aren't met.

func (TypedInterfaceValidationError) Cause 

func (e TypedInterfaceValidationError) Cause() error

Cause function returns cause value.

func (TypedInterfaceValidationError) Error 

func (e TypedInterfaceValidationError) Error() string

Error satisfies the builtin error interface

func (TypedInterfaceValidationError) ErrorName 

func (e TypedInterfaceValidationError) ErrorName() string

ErrorName returns error name.

func (TypedInterfaceValidationError) Field 

func (e TypedInterfaceValidationError) Field() string

Field function returns field value.

func (TypedInterfaceValidationError) Key 

func (e TypedInterfaceValidationError) Key() bool

Key function returns key value.

func (TypedInterfaceValidationError) Reason 

func (e TypedInterfaceValidationError) Reason() string

Reason function returns reason value.

type Variable 

type Variable struct {
	// Variable literal type.
	Type *LiteralType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// +optional string describing input variable
	Description          string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Defines a strongly typed variable.

func (*Variable) Descriptor 

func (*Variable) Descriptor() ([]byte, []int)

func (*Variable) GetDescription 

func (m *Variable) GetDescription() string

func (*Variable) GetType 

func (m *Variable) GetType() *LiteralType

func (*Variable) ProtoMessage 

func (*Variable) ProtoMessage()

func (*Variable) Reset 

func (m *Variable) Reset()

func (*Variable) String 

func (m *Variable) String() string

func (*Variable) Validate 

func (m *Variable) Validate() error

Validate checks the field values on Variable with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Variable) XXX_DiscardUnknown 

func (m *Variable) XXX_DiscardUnknown()

func (*Variable) XXX_Marshal 

func (m *Variable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Variable) XXX_Merge 

func (dst *Variable) XXX_Merge(src proto.Message)

func (*Variable) XXX_Size 

func (m *Variable) XXX_Size() int

func (*Variable) XXX_Unmarshal 

func (m *Variable) XXX_Unmarshal(b []byte) error

type VariableMap 

type VariableMap struct {
	// Defines a map of variable names to variables.
	Variables            map[string]*Variable `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A map of Variables

func (*VariableMap) Descriptor 

func (*VariableMap) Descriptor() ([]byte, []int)

func (*VariableMap) GetVariables 

func (m *VariableMap) GetVariables() map[string]*Variable

func (*VariableMap) ProtoMessage 

func (*VariableMap) ProtoMessage()

func (*VariableMap) Reset 

func (m *VariableMap) Reset()

func (*VariableMap) String 

func (m *VariableMap) String() string

func (*VariableMap) Validate 

func (m *VariableMap) Validate() error

Validate checks the field values on VariableMap with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*VariableMap) XXX_DiscardUnknown 

func (m *VariableMap) XXX_DiscardUnknown()

func (*VariableMap) XXX_Marshal 

func (m *VariableMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VariableMap) XXX_Merge 

func (dst *VariableMap) XXX_Merge(src proto.Message)

func (*VariableMap) XXX_Size 

func (m *VariableMap) XXX_Size() int

func (*VariableMap) XXX_Unmarshal 

func (m *VariableMap) XXX_Unmarshal(b []byte) error

type VariableMapValidationError 

type VariableMapValidationError struct {
	// contains filtered or unexported fields
}

VariableMapValidationError is the validation error returned by VariableMap.Validate if the designated constraints aren't met.

func (VariableMapValidationError) Cause 

func (e VariableMapValidationError) Cause() error

Cause function returns cause value.

func (VariableMapValidationError) Error 

func (e VariableMapValidationError) Error() string

Error satisfies the builtin error interface

func (VariableMapValidationError) ErrorName 

func (e VariableMapValidationError) ErrorName() string

ErrorName returns error name.

func (VariableMapValidationError) Field 

func (e VariableMapValidationError) Field() string

Field function returns field value.

func (VariableMapValidationError) Key 

func (e VariableMapValidationError) Key() bool

Key function returns key value.

func (VariableMapValidationError) Reason 

func (e VariableMapValidationError) Reason() string

Reason function returns reason value.

type VariableValidationError 

type VariableValidationError struct {
	// contains filtered or unexported fields
}

VariableValidationError is the validation error returned by Variable.Validate if the designated constraints aren't met.

func (VariableValidationError) Cause 

func (e VariableValidationError) Cause() error

Cause function returns cause value.

func (VariableValidationError) Error 

func (e VariableValidationError) Error() string

Error satisfies the builtin error interface

func (VariableValidationError) ErrorName 

func (e VariableValidationError) ErrorName() string

ErrorName returns error name.

func (VariableValidationError) Field 

func (e VariableValidationError) Field() string

Field function returns field value.

func (VariableValidationError) Key 

func (e VariableValidationError) Key() bool

Key function returns key value.

func (VariableValidationError) Reason 

func (e VariableValidationError) Reason() string

Reason function returns reason value.

type Void 

type Void struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Used to denote a nil/null/None assignment to a scalar value. The underlying LiteralType for Void is intentionally undefined since it can be assigned to a scalar of any LiteralType.

func (*Void) Descriptor 

func (*Void) Descriptor() ([]byte, []int)

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) Reset 

func (m *Void) Reset()

func (*Void) String 

func (m *Void) String() string

func (*Void) Validate 

func (m *Void) Validate() error

Validate checks the field values on Void with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Void) XXX_DiscardUnknown 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal 

func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Void) XXX_Merge 

func (dst *Void) XXX_Merge(src proto.Message)

func (*Void) XXX_Size 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal 

func (m *Void) XXX_Unmarshal(b []byte) error

type VoidValidationError 

type VoidValidationError struct {
	// contains filtered or unexported fields
}

VoidValidationError is the validation error returned by Void.Validate if the designated constraints aren't met.

func (VoidValidationError) Cause 

func (e VoidValidationError) Cause() error

Cause function returns cause value.

func (VoidValidationError) Error 

func (e VoidValidationError) Error() string

Error satisfies the builtin error interface

func (VoidValidationError) ErrorName 

func (e VoidValidationError) ErrorName() string

ErrorName returns error name.

func (VoidValidationError) Field 

func (e VoidValidationError) Field() string

Field function returns field value.

func (VoidValidationError) Key 

func (e VoidValidationError) Key() bool

Key function returns key value.

func (VoidValidationError) Reason 

func (e VoidValidationError) Reason() string

Reason function returns reason value.

type WorkflowClosure 

type WorkflowClosure struct {
	// required. Workflow template.
	Workflow *WorkflowTemplate `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// optional. A collection of tasks referenced by the workflow. Only needed if the workflow
	// references tasks.
	Tasks                []*TaskTemplate `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Defines an enclosed package of workflow and tasks it references.

func (*WorkflowClosure) Descriptor 

func (*WorkflowClosure) Descriptor() ([]byte, []int)

func (*WorkflowClosure) GetTasks 

func (m *WorkflowClosure) GetTasks() []*TaskTemplate

func (*WorkflowClosure) GetWorkflow 

func (m *WorkflowClosure) GetWorkflow() *WorkflowTemplate

func (*WorkflowClosure) ProtoMessage 

func (*WorkflowClosure) ProtoMessage()

func (*WorkflowClosure) Reset 

func (m *WorkflowClosure) Reset()

func (*WorkflowClosure) String 

func (m *WorkflowClosure) String() string

func (*WorkflowClosure) Validate 

func (m *WorkflowClosure) Validate() error

Validate checks the field values on WorkflowClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowClosure) XXX_DiscardUnknown 

func (m *WorkflowClosure) XXX_DiscardUnknown()

func (*WorkflowClosure) XXX_Marshal 

func (m *WorkflowClosure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowClosure) XXX_Merge 

func (dst *WorkflowClosure) XXX_Merge(src proto.Message)

func (*WorkflowClosure) XXX_Size 

func (m *WorkflowClosure) XXX_Size() int

func (*WorkflowClosure) XXX_Unmarshal 

func (m *WorkflowClosure) XXX_Unmarshal(b []byte) error

type WorkflowClosureValidationError 

type WorkflowClosureValidationError struct {
	// contains filtered or unexported fields
}

WorkflowClosureValidationError is the validation error returned by WorkflowClosure.Validate if the designated constraints aren't met.

func (WorkflowClosureValidationError) Cause 

func (e WorkflowClosureValidationError) Cause() error

Cause function returns cause value.

func (WorkflowClosureValidationError) Error 

func (e WorkflowClosureValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowClosureValidationError) ErrorName 

func (e WorkflowClosureValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowClosureValidationError) Field 

func (e WorkflowClosureValidationError) Field() string

Field function returns field value.

func (WorkflowClosureValidationError) Key 

func (e WorkflowClosureValidationError) Key() bool

Key function returns key value.

func (WorkflowClosureValidationError) Reason 

func (e WorkflowClosureValidationError) Reason() string

Reason function returns reason value.

type WorkflowExecution 

type WorkflowExecution struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Indicates various phases of Workflow Execution

func (*WorkflowExecution) Descriptor 

func (*WorkflowExecution) Descriptor() ([]byte, []int)

func (*WorkflowExecution) ProtoMessage 

func (*WorkflowExecution) ProtoMessage()

func (*WorkflowExecution) Reset 

func (m *WorkflowExecution) Reset()

func (*WorkflowExecution) String 

func (m *WorkflowExecution) String() string

func (*WorkflowExecution) Validate 

func (m *WorkflowExecution) Validate() error

Validate checks the field values on WorkflowExecution with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecution) XXX_DiscardUnknown 

func (m *WorkflowExecution) XXX_DiscardUnknown()

func (*WorkflowExecution) XXX_Marshal 

func (m *WorkflowExecution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowExecution) XXX_Merge 

func (dst *WorkflowExecution) XXX_Merge(src proto.Message)

func (*WorkflowExecution) XXX_Size 

func (m *WorkflowExecution) XXX_Size() int

func (*WorkflowExecution) XXX_Unmarshal 

func (m *WorkflowExecution) XXX_Unmarshal(b []byte) error

type WorkflowExecutionIdentifier 

type WorkflowExecutionIdentifier struct {
	// Name of the project the resource belongs to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the resource belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// User or system provided value for the resource.
	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Encapsulation of fields that uniquely identifies a Flyte workflow execution

func (*WorkflowExecutionIdentifier) Descriptor 

func (*WorkflowExecutionIdentifier) Descriptor() ([]byte, []int)

func (*WorkflowExecutionIdentifier) GetDomain 

func (m *WorkflowExecutionIdentifier) GetDomain() string

func (*WorkflowExecutionIdentifier) GetName 

func (m *WorkflowExecutionIdentifier) GetName() string

func (*WorkflowExecutionIdentifier) GetProject 

func (m *WorkflowExecutionIdentifier) GetProject() string

func (*WorkflowExecutionIdentifier) ProtoMessage 

func (*WorkflowExecutionIdentifier) ProtoMessage()

func (*WorkflowExecutionIdentifier) Reset 

func (m *WorkflowExecutionIdentifier) Reset()

func (*WorkflowExecutionIdentifier) String 

func (m *WorkflowExecutionIdentifier) String() string

func (*WorkflowExecutionIdentifier) Validate 

func (m *WorkflowExecutionIdentifier) Validate() error

Validate checks the field values on WorkflowExecutionIdentifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecutionIdentifier) XXX_DiscardUnknown 

func (m *WorkflowExecutionIdentifier) XXX_DiscardUnknown()

func (*WorkflowExecutionIdentifier) XXX_Marshal 

func (m *WorkflowExecutionIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowExecutionIdentifier) XXX_Merge 

func (dst *WorkflowExecutionIdentifier) XXX_Merge(src proto.Message)

func (*WorkflowExecutionIdentifier) XXX_Size 

func (m *WorkflowExecutionIdentifier) XXX_Size() int

func (*WorkflowExecutionIdentifier) XXX_Unmarshal 

func (m *WorkflowExecutionIdentifier) XXX_Unmarshal(b []byte) error

type WorkflowExecutionIdentifierValidationError 

type WorkflowExecutionIdentifierValidationError struct {
	// contains filtered or unexported fields
}

WorkflowExecutionIdentifierValidationError is the validation error returned by WorkflowExecutionIdentifier.Validate if the designated constraints aren't met.

func (WorkflowExecutionIdentifierValidationError) Cause 

func (e WorkflowExecutionIdentifierValidationError) Cause() error

Cause function returns cause value.

func (WorkflowExecutionIdentifierValidationError) Error 

func (e WorkflowExecutionIdentifierValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowExecutionIdentifierValidationError) ErrorName 

func (e WorkflowExecutionIdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowExecutionIdentifierValidationError) Field 

func (e WorkflowExecutionIdentifierValidationError) Field() string

Field function returns field value.

func (WorkflowExecutionIdentifierValidationError) Key 

func (e WorkflowExecutionIdentifierValidationError) Key() bool

Key function returns key value.

func (WorkflowExecutionIdentifierValidationError) Reason 

func (e WorkflowExecutionIdentifierValidationError) Reason() string

Reason function returns reason value.

type WorkflowExecutionValidationError 

type WorkflowExecutionValidationError struct {
	// contains filtered or unexported fields
}

WorkflowExecutionValidationError is the validation error returned by WorkflowExecution.Validate if the designated constraints aren't met.

func (WorkflowExecutionValidationError) Cause 

func (e WorkflowExecutionValidationError) Cause() error

Cause function returns cause value.

func (WorkflowExecutionValidationError) Error 

func (e WorkflowExecutionValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowExecutionValidationError) ErrorName 

func (e WorkflowExecutionValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowExecutionValidationError) Field 

func (e WorkflowExecutionValidationError) Field() string

Field function returns field value.

func (WorkflowExecutionValidationError) Key 

func (e WorkflowExecutionValidationError) Key() bool

Key function returns key value.

func (WorkflowExecutionValidationError) Reason 

func (e WorkflowExecutionValidationError) Reason() string

Reason function returns reason value.

type WorkflowExecution_Phase 

type WorkflowExecution_Phase int32
const (
	WorkflowExecution_UNDEFINED  WorkflowExecution_Phase = 0
	WorkflowExecution_QUEUED     WorkflowExecution_Phase = 1
	WorkflowExecution_RUNNING    WorkflowExecution_Phase = 2
	WorkflowExecution_SUCCEEDING WorkflowExecution_Phase = 3
	WorkflowExecution_SUCCEEDED  WorkflowExecution_Phase = 4
	WorkflowExecution_FAILING    WorkflowExecution_Phase = 5
	WorkflowExecution_FAILED     WorkflowExecution_Phase = 6
	WorkflowExecution_ABORTED    WorkflowExecution_Phase = 7
	WorkflowExecution_TIMED_OUT  WorkflowExecution_Phase = 8
)

func (WorkflowExecution_Phase) EnumDescriptor 

func (WorkflowExecution_Phase) EnumDescriptor() ([]byte, []int)

func (WorkflowExecution_Phase) String 

func (x WorkflowExecution_Phase) String() string

type WorkflowMetadata 

type WorkflowMetadata struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Metadata for the entire workflow. To be used in the future.

func (*WorkflowMetadata) Descriptor 

func (*WorkflowMetadata) Descriptor() ([]byte, []int)

func (*WorkflowMetadata) ProtoMessage 

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) Reset 

func (m *WorkflowMetadata) Reset()

func (*WorkflowMetadata) String 

func (m *WorkflowMetadata) String() string

func (*WorkflowMetadata) Validate 

func (m *WorkflowMetadata) Validate() error

Validate checks the field values on WorkflowMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowMetadata) XXX_DiscardUnknown 

func (m *WorkflowMetadata) XXX_DiscardUnknown()

func (*WorkflowMetadata) XXX_Marshal 

func (m *WorkflowMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowMetadata) XXX_Merge 

func (dst *WorkflowMetadata) XXX_Merge(src proto.Message)

func (*WorkflowMetadata) XXX_Size 

func (m *WorkflowMetadata) XXX_Size() int

func (*WorkflowMetadata) XXX_Unmarshal 

func (m *WorkflowMetadata) XXX_Unmarshal(b []byte) error

type WorkflowMetadataValidationError 

type WorkflowMetadataValidationError struct {
	// contains filtered or unexported fields
}

WorkflowMetadataValidationError is the validation error returned by WorkflowMetadata.Validate if the designated constraints aren't met.

func (WorkflowMetadataValidationError) Cause 

func (e WorkflowMetadataValidationError) Cause() error

Cause function returns cause value.

func (WorkflowMetadataValidationError) Error 

func (e WorkflowMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowMetadataValidationError) ErrorName 

func (e WorkflowMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowMetadataValidationError) Field 

func (e WorkflowMetadataValidationError) Field() string

Field function returns field value.

func (WorkflowMetadataValidationError) Key 

func (e WorkflowMetadataValidationError) Key() bool

Key function returns key value.

func (WorkflowMetadataValidationError) Reason 

func (e WorkflowMetadataValidationError) Reason() string

Reason function returns reason value.

type WorkflowNode 

type WorkflowNode struct {
	// Types that are valid to be assigned to Reference:
	//	*WorkflowNode_LaunchplanRef
	//	*WorkflowNode_SubWorkflowRef
	Reference            isWorkflowNode_Reference `protobuf_oneof:"reference"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Refers to a the workflow the node is to execute.

func (*WorkflowNode) Descriptor 

func (*WorkflowNode) Descriptor() ([]byte, []int)

func (*WorkflowNode) GetLaunchplanRef 

func (m *WorkflowNode) GetLaunchplanRef() *Identifier

func (*WorkflowNode) GetReference 

func (m *WorkflowNode) GetReference() isWorkflowNode_Reference

func (*WorkflowNode) GetSubWorkflowRef 

func (m *WorkflowNode) GetSubWorkflowRef() *Identifier

func (*WorkflowNode) ProtoMessage 

func (*WorkflowNode) ProtoMessage()

func (*WorkflowNode) Reset 

func (m *WorkflowNode) Reset()

func (*WorkflowNode) String 

func (m *WorkflowNode) String() string

func (*WorkflowNode) Validate 

func (m *WorkflowNode) Validate() error

Validate checks the field values on WorkflowNode with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowNode) XXX_DiscardUnknown 

func (m *WorkflowNode) XXX_DiscardUnknown()

func (*WorkflowNode) XXX_Marshal 

func (m *WorkflowNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowNode) XXX_Merge 

func (dst *WorkflowNode) XXX_Merge(src proto.Message)

func (*WorkflowNode) XXX_OneofFuncs 

func (*WorkflowNode) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*WorkflowNode) XXX_Size 

func (m *WorkflowNode) XXX_Size() int

func (*WorkflowNode) XXX_Unmarshal 

func (m *WorkflowNode) XXX_Unmarshal(b []byte) error

type WorkflowNodeValidationError 

type WorkflowNodeValidationError struct {
	// contains filtered or unexported fields
}

WorkflowNodeValidationError is the validation error returned by WorkflowNode.Validate if the designated constraints aren't met.

func (WorkflowNodeValidationError) Cause 

func (e WorkflowNodeValidationError) Cause() error

Cause function returns cause value.

func (WorkflowNodeValidationError) Error 

func (e WorkflowNodeValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowNodeValidationError) ErrorName 

func (e WorkflowNodeValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowNodeValidationError) Field 

func (e WorkflowNodeValidationError) Field() string

Field function returns field value.

func (WorkflowNodeValidationError) Key 

func (e WorkflowNodeValidationError) Key() bool

Key function returns key value.

func (WorkflowNodeValidationError) Reason 

func (e WorkflowNodeValidationError) Reason() string

Reason function returns reason value.

type WorkflowNode_LaunchplanRef 

type WorkflowNode_LaunchplanRef struct {
	LaunchplanRef *Identifier `protobuf:"bytes,1,opt,name=launchplan_ref,json=launchplanRef,proto3,oneof"`
}

type WorkflowNode_SubWorkflowRef 

type WorkflowNode_SubWorkflowRef struct {
	SubWorkflowRef *Identifier `protobuf:"bytes,2,opt,name=sub_workflow_ref,json=subWorkflowRef,proto3,oneof"`
}

type WorkflowTemplate 

type WorkflowTemplate struct {
	// This is an autogenerated id by the system. The id is globally unique across the system.
	Id *Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Extra metadata about the workflow.
	Metadata *WorkflowMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Defines a strongly typed interface for the Workflow. This can include some optional parameters.
	Interface *TypedInterface `protobuf:"bytes,3,opt,name=interface,proto3" json:"interface,omitempty"`
	// A list of nodes. In addition, "globals" is a special reserved node id that can be used to consume workflow inputs.
	Nodes []*Node `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// A list of output bindings that specify how to construct workflow outputs. Bindings can pull node outputs or
	// specify literals. All workflow outputs specified in the interface field must be bound in order for the workflow
	// to be validated. A workflow has an implicit dependency on all of its nodes to execute successfully in order to
	// bind final outputs.
	// Most of these outputs will be Binding's with a BindingData of type OutputReference.  That is, your workflow can
	// just have an output of some constant (`Output(5)`), but usually, the workflow will be pulling
	// outputs from the output of a task.
	Outputs []*Binding `protobuf:"bytes,5,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// +optional A catch-all node. This node is executed whenever the execution engine determines the workflow has failed.
	// The interface of this node must match the Workflow interface with an additional input named "error" of type
	// pb.lyft.flyte.core.Error.
	FailureNode          *Node    `protobuf:"bytes,6,opt,name=failure_node,json=failureNode,proto3" json:"failure_node,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Flyte Workflow Structure that encapsulates task, branch and subworkflow nodes to form a statically analyzable, directed acyclic graph.

func (*WorkflowTemplate) Descriptor 

func (*WorkflowTemplate) Descriptor() ([]byte, []int)

func (*WorkflowTemplate) GetFailureNode 

func (m *WorkflowTemplate) GetFailureNode() *Node

func (*WorkflowTemplate) GetId 

func (m *WorkflowTemplate) GetId() *Identifier

func (*WorkflowTemplate) GetInterface 

func (m *WorkflowTemplate) GetInterface() *TypedInterface

func (*WorkflowTemplate) GetMetadata 

func (m *WorkflowTemplate) GetMetadata() *WorkflowMetadata

func (*WorkflowTemplate) GetNodes 

func (m *WorkflowTemplate) GetNodes() []*Node

func (*WorkflowTemplate) GetOutputs 

func (m *WorkflowTemplate) GetOutputs() []*Binding

func (*WorkflowTemplate) ProtoMessage 

func (*WorkflowTemplate) ProtoMessage()

func (*WorkflowTemplate) Reset 

func (m *WorkflowTemplate) Reset()

func (*WorkflowTemplate) String 

func (m *WorkflowTemplate) String() string

func (*WorkflowTemplate) Validate 

func (m *WorkflowTemplate) Validate() error

Validate checks the field values on WorkflowTemplate with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowTemplate) XXX_DiscardUnknown 

func (m *WorkflowTemplate) XXX_DiscardUnknown()

func (*WorkflowTemplate) XXX_Marshal 

func (m *WorkflowTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowTemplate) XXX_Merge 

func (dst *WorkflowTemplate) XXX_Merge(src proto.Message)

func (*WorkflowTemplate) XXX_Size 

func (m *WorkflowTemplate) XXX_Size() int

func (*WorkflowTemplate) XXX_Unmarshal 

func (m *WorkflowTemplate) XXX_Unmarshal(b []byte) error

type WorkflowTemplateValidationError 

type WorkflowTemplateValidationError struct {
	// contains filtered or unexported fields
}

WorkflowTemplateValidationError is the validation error returned by WorkflowTemplate.Validate if the designated constraints aren't met.

func (WorkflowTemplateValidationError) Cause 

func (e WorkflowTemplateValidationError) Cause() error

Cause function returns cause value.

func (WorkflowTemplateValidationError) Error 

func (e WorkflowTemplateValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowTemplateValidationError) ErrorName 

func (e WorkflowTemplateValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowTemplateValidationError) Field 

func (e WorkflowTemplateValidationError) Field() string

Field function returns field value.

func (WorkflowTemplateValidationError) Key 

func (e WorkflowTemplateValidationError) Key() bool

Key function returns key value.

func (WorkflowTemplateValidationError) Reason 

func (e WorkflowTemplateValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.