core

package
Version: v0.18.14 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

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 CatalogCacheStatus_name = map[int32]string{
	0: "CACHE_DISABLED",
	1: "CACHE_MISS",
	2: "CACHE_HIT",
	3: "CACHE_POPULATED",
	4: "CACHE_LOOKUP_FAILURE",
	5: "CACHE_PUT_FAILURE",
}
View Source 
var CatalogCacheStatus_value = map[string]int32{
	"CACHE_DISABLED":       0,
	"CACHE_MISS":           1,
	"CACHE_HIT":            2,
	"CACHE_POPULATED":      3,
	"CACHE_LOOKUP_FAILURE": 4,
	"CACHE_PUT_FAILURE":    5,
}
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 DataLoadingConfig_LiteralMapFormat_name = map[int32]string{
	0: "JSON",
	1: "YAML",
	2: "PROTO",
}
View Source 
var DataLoadingConfig_LiteralMapFormat_value = map[string]int32{
	"JSON":  0,
	"YAML":  1,
	"PROTO": 2,
}
View Source 
var ExecutionError_ErrorKind_name = map[int32]string{
	0: "UNKNOWN",
	1: "USER",
	2: "SYSTEM",
}
View Source 
var ExecutionError_ErrorKind_value = map[string]int32{
	"UNKNOWN": 0,
	"USER":    1,
	"SYSTEM":  2,
}
View Source 
var IOStrategy_DownloadMode_name = map[int32]string{
	0: "DOWNLOAD_EAGER",
	1: "DOWNLOAD_STREAM",
	2: "DO_NOT_DOWNLOAD",
}
View Source 
var IOStrategy_DownloadMode_value = map[string]int32{
	"DOWNLOAD_EAGER":  0,
	"DOWNLOAD_STREAM": 1,
	"DO_NOT_DOWNLOAD": 2,
}
View Source 
var IOStrategy_UploadMode_name = map[int32]string{
	0: "UPLOAD_ON_EXIT",
	1: "UPLOAD_EAGER",
	2: "DO_NOT_UPLOAD",
}
View Source 
var IOStrategy_UploadMode_value = map[string]int32{
	"UPLOAD_ON_EXIT": 0,
	"UPLOAD_EAGER":   1,
	"DO_NOT_UPLOAD":  2,
}
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 QualityOfService_Tier_name = map[int32]string{
	0: "UNDEFINED",
	1: "HIGH",
	2: "MEDIUM",
	3: "LOW",
}
View Source 
var QualityOfService_Tier_value = map[string]int32{
	"UNDEFINED": 0,
	"HIGH":      1,
	"MEDIUM":    2,
	"LOW":       3,
}
View Source 
var ResourceType_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "TASK",
	2: "WORKFLOW",
	3: "LAUNCH_PLAN",
	4: "DATASET",
}
View Source 
var ResourceType_value = map[string]int32{
	"UNSPECIFIED": 0,
	"TASK":        1,
	"WORKFLOW":    2,
	"LAUNCH_PLAN": 3,
	"DATASET":     4,
}
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",
	6: "INITIALIZING",
	7: "WAITING_FOR_RESOURCES",
}
View Source 
var TaskExecution_Phase_value = map[string]int32{
	"UNDEFINED":             0,
	"QUEUED":                1,
	"RUNNING":               2,
	"SUCCEEDED":             3,
	"ABORTED":               4,
	"FAILED":                5,
	"INITIALIZING":          6,
	"WAITING_FOR_RESOURCES": 7,
}
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,
}
View Source 
var WorkflowMetadata_OnFailurePolicy_name = map[int32]string{
	0: "FAIL_IMMEDIATELY",
	1: "FAIL_AFTER_EXECUTABLE_NODES_COMPLETE",
}
View Source 
var WorkflowMetadata_OnFailurePolicy_value = map[string]int32{
	"FAIL_IMMEDIATELY":                     0,
	"FAIL_AFTER_EXECUTABLE_NODES_COMPLETE": 1,
}

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 (m *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 (m *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 (m *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 (m *BindingData) XXX_Merge(src proto.Message)

func (*BindingData) XXX_OneofWrappers added in v0.4.20 

func (*BindingData) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *BooleanExpression) XXX_Merge(src proto.Message)

func (*BooleanExpression) XXX_OneofWrappers added in v0.4.20 

func (*BooleanExpression) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers 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 (m *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 CatalogArtifactTag added in v0.17.38 

type CatalogArtifactTag struct {
	// Artifact ID is generated name
	ArtifactId string `protobuf:"bytes,1,opt,name=artifact_id,json=artifactId,proto3" json:"artifact_id,omitempty"`
	// Flyte computes the tag automatically, as the hash of the values
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CatalogArtifactTag) Descriptor added in v0.17.38 

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

func (*CatalogArtifactTag) GetArtifactId added in v0.17.38 

func (m *CatalogArtifactTag) GetArtifactId() string

func (*CatalogArtifactTag) GetName added in v0.17.38 

func (m *CatalogArtifactTag) GetName() string

func (*CatalogArtifactTag) ProtoMessage added in v0.17.38 

func (*CatalogArtifactTag) ProtoMessage()

func (*CatalogArtifactTag) Reset added in v0.17.38 

func (m *CatalogArtifactTag) Reset()

func (*CatalogArtifactTag) String added in v0.17.38 

func (m *CatalogArtifactTag) String() string

func (*CatalogArtifactTag) Validate added in v0.17.38 

func (m *CatalogArtifactTag) Validate() error

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

func (*CatalogArtifactTag) XXX_DiscardUnknown added in v0.17.38 

func (m *CatalogArtifactTag) XXX_DiscardUnknown()

func (*CatalogArtifactTag) XXX_Marshal added in v0.17.38 

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

func (*CatalogArtifactTag) XXX_Merge added in v0.17.38 

func (m *CatalogArtifactTag) XXX_Merge(src proto.Message)

func (*CatalogArtifactTag) XXX_Size added in v0.17.38 

func (m *CatalogArtifactTag) XXX_Size() int

func (*CatalogArtifactTag) XXX_Unmarshal added in v0.17.38 

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

type CatalogArtifactTagValidationError added in v0.17.38 

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

CatalogArtifactTagValidationError is the validation error returned by CatalogArtifactTag.Validate if the designated constraints aren't met.

func (CatalogArtifactTagValidationError) Cause added in v0.17.38 

func (e CatalogArtifactTagValidationError) Cause() error

Cause function returns cause value.

func (CatalogArtifactTagValidationError) Error added in v0.17.38 

func (e CatalogArtifactTagValidationError) Error() string

Error satisfies the builtin error interface

func (CatalogArtifactTagValidationError) ErrorName added in v0.17.38 

func (e CatalogArtifactTagValidationError) ErrorName() string

ErrorName returns error name.

func (CatalogArtifactTagValidationError) Field added in v0.17.38 

func (e CatalogArtifactTagValidationError) Field() string

Field function returns field value.

func (CatalogArtifactTagValidationError) Key added in v0.17.38 

func (e CatalogArtifactTagValidationError) Key() bool

Key function returns key value.

func (CatalogArtifactTagValidationError) Reason added in v0.17.38 

func (e CatalogArtifactTagValidationError) Reason() string

Reason function returns reason value.

type CatalogCacheStatus added in v0.17.38 

type CatalogCacheStatus int32

Indicates the status of CatalogCaching. The reason why this is not embeded in TaskNodeMetadata is, that we may use for other types of nodes as well in the future 

const (
	// Used to indicate that caching was disabled
	CatalogCacheStatus_CACHE_DISABLED CatalogCacheStatus = 0
	// Used to indicate that the cache lookup resulted in no matches
	CatalogCacheStatus_CACHE_MISS CatalogCacheStatus = 1
	// used to indicate that the associated artifact was a result of a previous execution
	CatalogCacheStatus_CACHE_HIT CatalogCacheStatus = 2
	// used to indicate that the resultant artifact was added to the cache
	CatalogCacheStatus_CACHE_POPULATED CatalogCacheStatus = 3
	// Used to indicate that cache lookup failed because of an error
	CatalogCacheStatus_CACHE_LOOKUP_FAILURE CatalogCacheStatus = 4
	// Used to indicate that cache lookup failed because of an error
	CatalogCacheStatus_CACHE_PUT_FAILURE CatalogCacheStatus = 5
)

func (CatalogCacheStatus) EnumDescriptor added in v0.17.38 

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

func (CatalogCacheStatus) String added in v0.17.38 

func (x CatalogCacheStatus) String() string

type CatalogMetadata added in v0.17.38 

type CatalogMetadata struct {
	// Dataset ID in the catalog
	DatasetId *Identifier `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// Artifact tag in the catalog
	ArtifactTag *CatalogArtifactTag `protobuf:"bytes,2,opt,name=artifact_tag,json=artifactTag,proto3" json:"artifact_tag,omitempty"`
	// Optional: Source Execution identifier, if this dataset was generated by another execution in Flyte. This is a one-of field and will depend on the caching context
	//
	// Types that are valid to be assigned to SourceExecution:
	//	*CatalogMetadata_SourceTaskExecution
	SourceExecution      isCatalogMetadata_SourceExecution `protobuf_oneof:"source_execution"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

Catalog artifact information with specific metadata

func (*CatalogMetadata) Descriptor added in v0.17.38 

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

func (*CatalogMetadata) GetArtifactTag added in v0.17.38 

func (m *CatalogMetadata) GetArtifactTag() *CatalogArtifactTag

func (*CatalogMetadata) GetDatasetId added in v0.17.38 

func (m *CatalogMetadata) GetDatasetId() *Identifier

func (*CatalogMetadata) GetSourceExecution added in v0.17.38 

func (m *CatalogMetadata) GetSourceExecution() isCatalogMetadata_SourceExecution

func (*CatalogMetadata) GetSourceTaskExecution added in v0.17.38 

func (m *CatalogMetadata) GetSourceTaskExecution() *TaskExecutionIdentifier

func (*CatalogMetadata) ProtoMessage added in v0.17.38 

func (*CatalogMetadata) ProtoMessage()

func (*CatalogMetadata) Reset added in v0.17.38 

func (m *CatalogMetadata) Reset()

func (*CatalogMetadata) String added in v0.17.38 

func (m *CatalogMetadata) String() string

func (*CatalogMetadata) Validate added in v0.17.38 

func (m *CatalogMetadata) Validate() error

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

func (*CatalogMetadata) XXX_DiscardUnknown added in v0.17.38 

func (m *CatalogMetadata) XXX_DiscardUnknown()

func (*CatalogMetadata) XXX_Marshal added in v0.17.38 

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

func (*CatalogMetadata) XXX_Merge added in v0.17.38 

func (m *CatalogMetadata) XXX_Merge(src proto.Message)

func (*CatalogMetadata) XXX_OneofWrappers added in v0.17.38 

func (*CatalogMetadata) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CatalogMetadata) XXX_Size added in v0.17.38 

func (m *CatalogMetadata) XXX_Size() int

func (*CatalogMetadata) XXX_Unmarshal added in v0.17.38 

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

type CatalogMetadataValidationError added in v0.17.38 

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

CatalogMetadataValidationError is the validation error returned by CatalogMetadata.Validate if the designated constraints aren't met.

func (CatalogMetadataValidationError) Cause added in v0.17.38 

func (e CatalogMetadataValidationError) Cause() error

Cause function returns cause value.

func (CatalogMetadataValidationError) Error added in v0.17.38 

func (e CatalogMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (CatalogMetadataValidationError) ErrorName added in v0.17.38 

func (e CatalogMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (CatalogMetadataValidationError) Field added in v0.17.38 

func (e CatalogMetadataValidationError) Field() string

Field function returns field value.

func (CatalogMetadataValidationError) Key added in v0.17.38 

func (e CatalogMetadataValidationError) Key() bool

Key function returns key value.

func (CatalogMetadataValidationError) Reason added in v0.17.38 

func (e CatalogMetadataValidationError) Reason() string

Reason function returns reason value.

type CatalogMetadata_SourceTaskExecution added in v0.17.38 

type CatalogMetadata_SourceTaskExecution struct {
	SourceTaskExecution *TaskExecutionIdentifier `protobuf:"bytes,3,opt,name=source_task_execution,json=sourceTaskExecution,proto3,oneof"`
}

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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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 (m *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)
	// Only K8s
	Ports []*ContainerPort `protobuf:"bytes,7,rep,name=ports,proto3" json:"ports,omitempty"`
	// BETA: Optional configuration for DataLoading. If not specified, then default values are used.
	// This makes it possible to to run a completely portable container, that uses inputs and outputs
	// only from the local file-system and without having any reference to flyteidl. This is supported only on K8s at the moment.
	// If data loading is enabled, then data will be mounted in accompanying directories specified in the DataLoadingConfig. If the directories
	// are not specified, inputs will be mounted onto and outputs will be uploaded from a pre-determined file-system path. Refer to the documentation
	// to understand the default paths.
	// Only K8s
	DataConfig           *DataLoadingConfig `protobuf:"bytes,9,opt,name=data_config,json=dataConfig,proto3" json:"data_config,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) GetDataConfig added in v0.17.31 

func (m *Container) GetDataConfig() *DataLoadingConfig

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 (m *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