core

package
Version: v1.1.12 Latest Latest
Warning

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

Go to latest
Published: Aug 9, 2022 License: Apache-2.0 Imports: 16 Imported by: 104

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 CatalogReservation_Status_name = map[int32]string{
	0: "RESERVATION_DISABLED",
	1: "RESERVATION_ACQUIRED",
	2: "RESERVATION_EXISTS",
	3: "RESERVATION_RELEASED",
	4: "RESERVATION_FAILURE",
}
View Source
var CatalogReservation_Status_value = map[string]int32{
	"RESERVATION_DISABLED": 0,
	"RESERVATION_ACQUIRED": 1,
	"RESERVATION_EXISTS":   2,
	"RESERVATION_RELEASED": 3,
	"RESERVATION_FAILURE":  4,
}
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 Container_Architecture_name = map[int32]string{
	0: "UNKNOWN",
	1: "AMD64",
	2: "ARM64",
	3: "ARM_V6",
	4: "ARM_V7",
}
View Source
var Container_Architecture_value = map[string]int32{
	"UNKNOWN": 0,
	"AMD64":   1,
	"ARM64":   2,
	"ARM_V6":  3,
	"ARM_V7":  4,
}
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",
	9:  "DYNAMIC_RUNNING",
	10: "RECOVERED",
}
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,
	"DYNAMIC_RUNNING": 9,
	"RECOVERED":       10,
}
View Source
var OAuth2TokenRequest_Type_name = map[int32]string{
	0: "CLIENT_CREDENTIALS",
}
View Source
var OAuth2TokenRequest_Type_value = map[string]int32{
	"CLIENT_CREDENTIALS": 0,
}
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",
	5: "EPHEMERAL_STORAGE",
}
View Source
var Resources_ResourceName_value = map[string]int32{
	"UNKNOWN":           0,
	"CPU":               1,
	"GPU":               2,
	"MEMORY":            3,
	"STORAGE":           4,
	"EPHEMERAL_STORAGE": 5,
}
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 Secret_MountType_name = map[int32]string{
	0: "ANY",
	1: "ENV_VAR",
	2: "FILE",
}
View Source
var Secret_MountType_value = map[string]int32{
	"ANY":     0,
	"ENV_VAR": 1,
	"FILE":    2,
}
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 Sql_Dialect_name = map[int32]string{
	0: "UNDEFINED",
	1: "ANSI",
	2: "HIVE",
	3: "OTHER",
}
View Source
var Sql_Dialect_value = map[string]int32{
	"UNDEFINED": 0,
	"ANSI":      1,
	"HIVE":      2,
	"OTHER":     3,
}
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",
	9: "ABORTING",
}
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,
	"ABORTING":   9,
}
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"`
	Union                *UnionInfo          `protobuf:"bytes,5,opt,name=union,proto3" json:"union,omitempty"`
	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) GetUnion added in v0.24.0

func (m *BindingData) GetUnion() *UnionInfo

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.16.1

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.16.1

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, primitives).

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.18.15

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.18.15

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

func (*CatalogArtifactTag) GetArtifactId added in v0.18.15

func (m *CatalogArtifactTag) GetArtifactId() string

func (*CatalogArtifactTag) GetName added in v0.18.15

func (m *CatalogArtifactTag) GetName() string

func (*CatalogArtifactTag) ProtoMessage added in