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

Cause function returns cause value.

func (BindingDataCollectionValidationError) Error

Error satisfies the builtin error interface

func (BindingDataCollectionValidationError) ErrorName

ErrorName returns error name.

func (BindingDataCollectionValidationError) Field

Field function returns field value.

func (BindingDataCollectionValidationError) Key

Key function returns key value.

func (BindingDataCollectionValidationError) Reason

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

Cause function returns cause value.

func (BindingDataMapValidationError) Error

Error satisfies the builtin error interface

func (BindingDataMapValidationError) ErrorName

func (e BindingDataMapValidationError) ErrorName() string

ErrorName returns error name.

func (BindingDataMapValidationError) Field

Field function returns field value.

func (BindingDataMapValidationError) Key

Key function returns key value.

func (BindingDataMapValidationError) Reason

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

Cause function returns cause value.

func (BindingDataValidationError) Error

Error satisfies the builtin error interface

func (BindingDataValidationError) ErrorName

func (e BindingDataValidationError) ErrorName() string

ErrorName returns error name.

func (BindingDataValidationError) Field

Field function returns field value.

func (BindingDataValidationError) Key

Key function returns key value.

func (BindingDataValidationError) Reason

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

Cause function returns cause value.

func (BlobMetadataValidationError) Error

Error satisfies the builtin error interface

func (BlobMetadataValidationError) ErrorName

func (e BlobMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (BlobMetadataValidationError) Field

Field function returns field value.

func (BlobMetadataValidationError) Key

Key function returns key value.

func (BlobMetadataValidationError) Reason

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

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

Cause function returns cause value.

func (BooleanExpressionValidationError) Error

Error satisfies the builtin error interface

func (BooleanExpressionValidationError) ErrorName

ErrorName returns error name.

func (BooleanExpressionValidationError) Field

Field function returns field value.

func (BooleanExpressionValidationError) Key

Key function returns key value.

func (BooleanExpressionValidationError) Reason

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

Error satisfies the builtin error interface

func (BranchNodeValidationError) ErrorName

func (e BranchNodeValidationError) ErrorName() string

ErrorName returns error name.

func (BranchNodeValidationError) Field

Field function returns field value.

func (BranchNodeValidationError) Key

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

Cause function returns cause value.

func (CatalogArtifactTagValidationError) Error added in v0.17.38

Error satisfies the builtin error interface

func (CatalogArtifactTagValidationError) ErrorName added in v0.17.38

ErrorName returns error name.

func (CatalogArtifactTagValidationError) Field added in v0.17.38

Field function returns field value.

func (CatalogArtifactTagValidationError) Key added in v0.17.38

Key function returns key value.

func (CatalogArtifactTagValidationError) Reason added in v0.17.38

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

Cause function returns cause value.

func (CatalogMetadataValidationError) Error added in v0.17.38

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

Field function returns field value.

func (CatalogMetadataValidationError) Key added in v0.17.38

Key function returns key value.

func (CatalogMetadataValidationError) Reason added in v0.17.38

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

Cause function returns cause value.

func (ComparisonExpressionValidationError) Error

Error satisfies the builtin error interface

func (ComparisonExpressionValidationError) ErrorName

ErrorName returns error name.

func (ComparisonExpressionValidationError) Field

Field function returns field value.

func (ComparisonExpressionValidationError) Key

Key function returns key value.

func (ComparisonExpressionValidationError) Reason

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

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

Cause function returns cause value.

func (CompiledTaskValidationError) Error

Error satisfies the builtin error interface

func (CompiledTaskValidationError) ErrorName

func (e CompiledTaskValidationError) ErrorName() string

ErrorName returns error name.

func (CompiledTaskValidationError) Field

Field function returns field value.

func (CompiledTaskValidationError) Key

Key function returns key value.

func (CompiledTaskValidationError) Reason

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

Cause function returns cause value.

func (CompiledWorkflowClosureValidationError) Error

Error satisfies the builtin error interface

func (CompiledWorkflowClosureValidationError) ErrorName

ErrorName returns error name.

func (CompiledWorkflowClosureValidationError) Field

Field function returns field value.

func (CompiledWorkflowClosureValidationError) Key

Key function returns key value.

func (CompiledWorkflowClosureValidationError) Reason

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

Cause function returns cause value.

func (CompiledWorkflowValidationError) Error

Error satisfies the builtin error interface

func (CompiledWorkflowValidationError) ErrorName

ErrorName returns error name.

func (CompiledWorkflowValidationError) Field

Field function returns field value.

func (CompiledWorkflowValidationError) Key

Key function returns key value.

func (CompiledWorkflowValidationError) Reason

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

Cause function returns cause value.

func (ConjunctionExpressionValidationError) Error

Error satisfies the builtin error interface

func (ConjunctionExpressionValidationError) ErrorName

ErrorName returns error name.

func (ConjunctionExpressionValidationError) Field

Field function returns field value.

func (ConjunctionExpressionValidationError) Key

Key function returns key value.

func (ConjunctionExpressionValidationError) Reason

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

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

Cause function returns cause value.

func (ConnectionSetValidationError) Error

Error satisfies the builtin error interface

func (ConnectionSetValidationError) ErrorName

func (e ConnectionSetValidationError) ErrorName() string

ErrorName returns error name.

func (ConnectionSetValidationError) Field

Field function returns field value.

func (ConnectionSetValidationError) Key

Key function returns key value.

func (ConnectionSetValidationError) Reason

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

Cause function returns cause value.

func (ConnectionSet_IdListValidationError) Error

Error satisfies the builtin error interface

func (ConnectionSet_IdListValidationError) ErrorName

ErrorName returns error name.

func (ConnectionSet_IdListValidationError) Field

Field function returns field value.

func (ConnectionSet_IdListValidationError) Key

Key function returns key value.

func (ConnectionSet_IdListValidationError) Reason

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