core

package
v1.10.7-b1 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2024 License: Apache-2.0 Imports: 6 Imported by: 126

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",
	6: "CACHE_SKIPPED",
	7: "CACHE_EVICTED",
}
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,
	"CACHE_SKIPPED":        6,
	"CACHE_EVICTED":        7,
}
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) 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 ApproveCondition 

type ApproveCondition struct {
	// A unique identifier for the requested boolean signal.
	SignalId             string   `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ApproveCondition represents a dependency on an external approval. During execution, this will manifest as a boolean signal with the provided signal_id.

func (*ApproveCondition) Descriptor 

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

func (*ApproveCondition) GetSignalId 

func (m *ApproveCondition) GetSignalId() string

func (*ApproveCondition) ProtoMessage 

func (*ApproveCondition) ProtoMessage()

func (*ApproveCondition) Reset 

func (m *ApproveCondition) Reset()

func (*ApproveCondition) String 

func (m *ApproveCondition) String() string

func (*ApproveCondition) XXX_DiscardUnknown 

func (m *ApproveCondition) XXX_DiscardUnknown()

func (*ApproveCondition) XXX_Marshal 

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

func (*ApproveCondition) XXX_Merge 

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

func (*ApproveCondition) XXX_Size 

func (m *ApproveCondition) XXX_Size() int

func (*ApproveCondition) XXX_Unmarshal 

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

type ArrayNode 

type ArrayNode struct {
	// node is the sub-node that will be executed for each element in the array.
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// parallelism defines the minimum number of instances to bring up concurrently at any given
	// point. Note that this is an optimistic restriction and that, due to network partitioning or
	// other failures, the actual number of currently running instances might be more. This has to
	// be a positive number if assigned. Default value is size.
	Parallelism uint32 `protobuf:"varint,2,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// Types that are valid to be assigned to SuccessCriteria:
	//	*ArrayNode_MinSuccesses
	//	*ArrayNode_MinSuccessRatio
	SuccessCriteria      isArrayNode_SuccessCriteria `protobuf_oneof:"success_criteria"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

ArrayNode is a Flyte node type that simplifies the execution of a sub-node over a list of input values. An ArrayNode can be executed with configurable parallelism (separate from the parent workflow) and can be configured to succeed when a certain number of sub-nodes succeed.

func (*ArrayNode) Descriptor 

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

func (*ArrayNode) GetMinSuccessRatio 

func (m *ArrayNode) GetMinSuccessRatio() float32

func (*ArrayNode) GetMinSuccesses 

func (m *ArrayNode) GetMinSuccesses() uint32

func (*ArrayNode) GetNode 

func (m *ArrayNode) GetNode() *Node

func (*ArrayNode) GetParallelism 

func (m *ArrayNode) GetParallelism() uint32

func (*ArrayNode) GetSuccessCriteria 

func (m *ArrayNode) GetSuccessCriteria() isArrayNode_SuccessCriteria

func (*ArrayNode) ProtoMessage 

func (*ArrayNode) ProtoMessage()

func (*ArrayNode) Reset 

func (m *ArrayNode) Reset()

func (*ArrayNode) String 

func (m *ArrayNode) String() string

func (*ArrayNode) XXX_DiscardUnknown 

func (m *ArrayNode) XXX_DiscardUnknown()

func (*ArrayNode) XXX_Marshal 

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

func (*ArrayNode) XXX_Merge 

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

func (*ArrayNode) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ArrayNode) XXX_Size 

func (m *ArrayNode) XXX_Size() int

func (*ArrayNode) XXX_Unmarshal 

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

type ArrayNode_MinSuccessRatio 

type ArrayNode_MinSuccessRatio struct {
	MinSuccessRatio float32 `protobuf:"fixed32,4,opt,name=min_success_ratio,json=minSuccessRatio,proto3,oneof"`
}

type ArrayNode_MinSuccesses 

type ArrayNode_MinSuccesses struct {
	MinSuccesses uint32 `protobuf:"varint,3,opt,name=min_successes,json=minSuccesses,proto3,oneof"`
}

type ArtifactBindingData added in v1.10.7 

type ArtifactBindingData struct {
	Index uint32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// These two fields are only relevant in the partition value case
	PartitionKey         string   `protobuf:"bytes,2,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	Transform            string   `protobuf:"bytes,3,opt,name=transform,proto3" json:"transform,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Only valid for triggers

func (*ArtifactBindingData) Descriptor added in v1.10.7 

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

func (*ArtifactBindingData) GetIndex added in v1.10.7 

func (m *ArtifactBindingData) GetIndex() uint32

func (*ArtifactBindingData) GetPartitionKey added in v1.10.7 

func (m *ArtifactBindingData) GetPartitionKey() string

func (*ArtifactBindingData) GetTransform added in v1.10.7 

func (m *ArtifactBindingData) GetTransform() string

func (*ArtifactBindingData) ProtoMessage added in v1.10.7 

func (*ArtifactBindingData) ProtoMessage()

func (*ArtifactBindingData) Reset added in v1.10.7 

func (m *ArtifactBindingData) Reset()

func (*ArtifactBindingData) String added in v1.10.7 

func (m *ArtifactBindingData) String() string

func (*ArtifactBindingData) XXX_DiscardUnknown 

func (m *ArtifactBindingData) XXX_DiscardUnknown()

func (*ArtifactBindingData) XXX_Marshal 

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

func (*ArtifactBindingData) XXX_Merge 

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

func (*ArtifactBindingData) XXX_Size 

func (m *ArtifactBindingData) XXX_Size() int

func (*ArtifactBindingData) XXX_Unmarshal 

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

type ArtifactID added in v1.10.7 

type ArtifactID struct {
	ArtifactKey *ArtifactKey `protobuf:"bytes,1,opt,name=artifact_key,json=artifactKey,proto3" json:"artifact_key,omitempty"`
	Version     string       `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Think of a partition as a tag on an Artifact, except it's a key-value pair.
	// Different partitions naturally have different versions (execution ids).
	// This is a oneof because of partition querying... we need a way to distinguish between
	// a user not-specifying partitions when searching, and specifically searching for an Artifact
	// that is not partitioned (this can happen if an Artifact goes from partitioned to non-
	// partitioned across executions).
	//
	// Types that are valid to be assigned to Dimensions:
	//	*ArtifactID_Partitions
	Dimensions           isArtifactID_Dimensions `protobuf_oneof:"dimensions"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ArtifactID) Descriptor added in v1.10.7 

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

func (*ArtifactID) GetArtifactKey added in v1.10.7 

func (m *ArtifactID) GetArtifactKey() *ArtifactKey

func (*ArtifactID) GetDimensions 

func (m *ArtifactID) GetDimensions() isArtifactID_Dimensions

func (*ArtifactID) GetPartitions added in v1.10.7 

func (m *ArtifactID) GetPartitions() *Partitions

func (*ArtifactID) GetVersion added in v1.10.7 

func (m *ArtifactID) GetVersion() string

func (*ArtifactID) ProtoMessage added in v1.10.7 

func (*ArtifactID) ProtoMessage()

func (*ArtifactID) Reset added in v1.10.7 

func (m *ArtifactID) Reset()

func (*ArtifactID) String added in v1.10.7 

func (m *ArtifactID) String() string

func (*ArtifactID) XXX_DiscardUnknown 

func (m *ArtifactID) XXX_DiscardUnknown()

func (*ArtifactID) XXX_Marshal 

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

func (*ArtifactID) XXX_Merge 

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

func (*ArtifactID) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ArtifactID) XXX_Size 

func (m *ArtifactID) XXX_Size() int

func (*ArtifactID) XXX_Unmarshal 

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

type ArtifactID_Partitions 

type ArtifactID_Partitions struct {
	Partitions *Partitions `protobuf:"bytes,3,opt,name=partitions,proto3,oneof"`
}

type ArtifactKey added in v1.10.7 

type ArtifactKey struct {
	// Project and domain and suffix needs to be unique across a given artifact store.
	Project              string   `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Domain               string   `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArtifactKey) Descriptor added in v1.10.7 

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

func (*ArtifactKey) GetDomain added in v1.10.7 

func (m *ArtifactKey) GetDomain() string

func (*ArtifactKey) GetName added in v1.10.7 

func (m *ArtifactKey) GetName() string

func (*ArtifactKey) GetProject added in v1.10.7 

func (m *ArtifactKey) GetProject() string

func (*ArtifactKey) ProtoMessage added in v1.10.7 

func (*ArtifactKey) ProtoMessage()

func (*ArtifactKey) Reset added in v1.10.7 

func (m *ArtifactKey) Reset()

func (*ArtifactKey) String added in v1.10.7 

func (m *ArtifactKey) String() string

func (*ArtifactKey) XXX_DiscardUnknown 

func (m *ArtifactKey) XXX_DiscardUnknown()

func (*ArtifactKey) XXX_Marshal 

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

func (*ArtifactKey) XXX_Merge 

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

func (*ArtifactKey) XXX_Size 

func (m *ArtifactKey) XXX_Size() int

func (*ArtifactKey) XXX_Unmarshal 

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

type ArtifactQuery added in v1.10.7 

type ArtifactQuery struct {
	// Types that are valid to be assigned to Identifier:
	//	*ArtifactQuery_ArtifactId
	//	*ArtifactQuery_ArtifactTag
	//	*ArtifactQuery_Uri
	//	*ArtifactQuery_Binding
	Identifier           isArtifactQuery_Identifier `protobuf_oneof:"identifier"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

Uniqueness constraints for Artifacts

  • project, domain, name, version, partitions

Option 2 (tags are standalone, point to an individual artifact id):

  • project, domain, name, alias (points to one partition if partitioned)
  • project, domain, name, partition key, partition value

func (*ArtifactQuery) Descriptor added in v1.10.7 

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

func (*ArtifactQuery) GetArtifactId added in v1.10.7 

func (m *ArtifactQuery) GetArtifactId() *ArtifactID

func (*ArtifactQuery) GetArtifactTag added in v1.10.7 

func (m *ArtifactQuery) GetArtifactTag() *ArtifactTag

func (*ArtifactQuery) GetBinding added in v1.10.7 

func (m *ArtifactQuery) GetBinding() *ArtifactBindingData

func (*ArtifactQuery) GetIdentifier added in v1.10.7 

func (m *ArtifactQuery) GetIdentifier() isArtifactQuery_Identifier

func (*ArtifactQuery) GetUri added in v1.10.7 

func (m *ArtifactQuery) GetUri() string

func (*ArtifactQuery) ProtoMessage added in v1.10.7 

func (*ArtifactQuery) ProtoMessage()

func (*ArtifactQuery) Reset added in v1.10.7 

func (m *ArtifactQuery) Reset()

func (*ArtifactQuery) String added in v1.10.7 

func (m *ArtifactQuery) String() string

func (*ArtifactQuery) XXX_DiscardUnknown 

func (m *ArtifactQuery) XXX_DiscardUnknown()

func (*ArtifactQuery) XXX_Marshal 

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

func (*ArtifactQuery) XXX_Merge 

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

func (*ArtifactQuery) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ArtifactQuery) XXX_Size 

func (m *ArtifactQuery) XXX_Size() int

func (*ArtifactQuery) XXX_Unmarshal 

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

type ArtifactQuery_ArtifactId added in v1.10.7 

type ArtifactQuery_ArtifactId struct {
	ArtifactId *ArtifactID `protobuf:"bytes,1,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}

type ArtifactQuery_ArtifactTag added in v1.10.7 

type ArtifactQuery_ArtifactTag struct {
	ArtifactTag *ArtifactTag `protobuf:"bytes,2,opt,name=artifact_tag,json=artifactTag,proto3,oneof"`
}

type ArtifactQuery_Binding added in v1.10.7 

type ArtifactQuery_Binding struct {
	Binding *ArtifactBindingData `protobuf:"bytes,4,opt,name=binding,proto3,oneof"`
}

type ArtifactQuery_Uri added in v1.10.7 

type ArtifactQuery_Uri struct {
	Uri string `protobuf:"bytes,3,opt,name=uri,proto3,oneof"`
}

type ArtifactTag added in v1.10.7 

type ArtifactTag struct {
	ArtifactKey          *ArtifactKey `protobuf:"bytes,1,opt,name=artifact_key,json=artifactKey,proto3" json:"artifact_key,omitempty"`
	Value                *LabelValue  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ArtifactTag) Descriptor added in v1.10.7 

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

func (*ArtifactTag) GetArtifactKey added in v1.10.7 

func (m *ArtifactTag) GetArtifactKey() *ArtifactKey

func (*ArtifactTag) GetValue added in v1.10.7 

func (m *ArtifactTag) GetValue() *LabelValue

func (*ArtifactTag) ProtoMessage added in v1.10.7 

func (*ArtifactTag) ProtoMessage()

func (*ArtifactTag) Reset added in v1.10.7 

func (m *ArtifactTag) Reset()

func (*ArtifactTag) String added in v1.10.7 

func (m *ArtifactTag) String() string

func (*ArtifactTag) XXX_DiscardUnknown 

func (m *ArtifactTag) XXX_DiscardUnknown()

func (*ArtifactTag) XXX_Marshal 

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

func (*ArtifactTag) XXX_Merge 

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

func (*ArtifactTag) XXX_Size 

func (m *ArtifactTag) XXX_Size() int

func (*ArtifactTag) XXX_Unmarshal 

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

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) 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 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) 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 

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) 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 

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) 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 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) 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 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 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) 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) 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 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) 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 BlobType_BlobDimensionality 

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

func (BlobType_BlobDimensionality) EnumDescriptor 

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

func (BlobType_BlobDimensionality) String 

func (x BlobType_BlobDimensionality) String() string

type 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) 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 

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 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) 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 CatalogArtifactTag 

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 

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

func (*CatalogArtifactTag) GetArtifactId 

func (m *CatalogArtifactTag) GetArtifactId() string

func (*CatalogArtifactTag) GetName 

func (m *CatalogArtifactTag) GetName() string

func (*CatalogArtifactTag) ProtoMessage 

func (*CatalogArtifactTag) ProtoMessage()

func (*CatalogArtifactTag) Reset 

func (m *CatalogArtifactTag) Reset()

func (*CatalogArtifactTag) String 

func (m *CatalogArtifactTag) String() string

func (*CatalogArtifactTag) XXX_DiscardUnknown 

func (m *CatalogArtifactTag) XXX_DiscardUnknown()

func (*CatalogArtifactTag) XXX_Marshal 

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

func (*CatalogArtifactTag) XXX_Merge 

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

func (*CatalogArtifactTag) XXX_Size 

func (m *CatalogArtifactTag) XXX_Size() int

func (*CatalogArtifactTag) XXX_Unmarshal 

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

type CatalogCacheStatus 

type CatalogCacheStatus int32

Indicates the status of CatalogCaching. The reason why this is not embedded 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
	// Used to indicate the cache lookup was skipped
	CatalogCacheStatus_CACHE_SKIPPED CatalogCacheStatus = 6
	// Used to indicate that the cache was evicted
	CatalogCacheStatus_CACHE_EVICTED CatalogCacheStatus = 7
)

func (CatalogCacheStatus) EnumDescriptor 

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

func (CatalogCacheStatus) String 

func (x CatalogCacheStatus) String() string

type CatalogMetadata 

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 

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

func (*CatalogMetadata) GetArtifactTag 

func (m *CatalogMetadata) GetArtifactTag() *CatalogArtifactTag

func (*CatalogMetadata) GetDatasetId 

func (m *CatalogMetadata) GetDatasetId() *Identifier

func (*CatalogMetadata) GetSourceExecution 

func (m *CatalogMetadata) GetSourceExecution() isCatalogMetadata_SourceExecution

func (*CatalogMetadata) GetSourceTaskExecution 

func (m *CatalogMetadata) GetSourceTaskExecution() *TaskExecutionIdentifier

func (*CatalogMetadata) ProtoMessage 

func (*CatalogMetadata) ProtoMessage()

func (*CatalogMetadata) Reset 

func (m *CatalogMetadata) Reset()

func (*CatalogMetadata) String 

func (m *CatalogMetadata) String() string

func (*CatalogMetadata) XXX_DiscardUnknown 

func (m *CatalogMetadata) XXX_DiscardUnknown()

func (*CatalogMetadata) XXX_Marshal 

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

func (*CatalogMetadata) XXX_Merge 

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

func (*CatalogMetadata) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*CatalogMetadata) XXX_Size 

func (m *CatalogMetadata) XXX_Size() int

func (*CatalogMetadata) XXX_Unmarshal 

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

type CatalogMetadata_SourceTaskExecution 

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

type CatalogReservation 

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

func (*CatalogReservation) Descriptor 

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

func (*CatalogReservation) ProtoMessage 

func (*CatalogReservation) ProtoMessage()

func (*CatalogReservation) Reset 

func (m *CatalogReservation) Reset()

func (*CatalogReservation) String 

func (m *CatalogReservation) String() string

func (*CatalogReservation) XXX_DiscardUnknown 

func (m *CatalogReservation) XXX_DiscardUnknown()

func (*CatalogReservation) XXX_Marshal 

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

func (*CatalogReservation) XXX_Merge 

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

func (*CatalogReservation) XXX_Size 

func (m *CatalogReservation) XXX_Size() int

func (*CatalogReservation) XXX_Unmarshal 

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

type CatalogReservation_Status 

type CatalogReservation_Status int32

Indicates the status of a catalog reservation operation. 

const (
	// Used to indicate that reservations are disabled
	CatalogReservation_RESERVATION_DISABLED CatalogReservation_Status = 0
	// Used to indicate that a reservation was successfully acquired or extended
	CatalogReservation_RESERVATION_ACQUIRED CatalogReservation_Status = 1
	// Used to indicate that an active reservation currently exists
	CatalogReservation_RESERVATION_EXISTS CatalogReservation_Status = 2
	// Used to indicate that the reservation has been successfully released
	CatalogReservation_RESERVATION_RELEASED CatalogReservation_Status = 3
	// Used to indicate that a reservation operation resulted in failure
	CatalogReservation_RESERVATION_FAILURE CatalogReservation_Status = 4
)

func (CatalogReservation_Status) EnumDescriptor 

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

func (CatalogReservation_Status) String 

func (x CatalogReservation_Status) String() string

type ComparisonExpression 

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

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

func (*ComparisonExpression) Descriptor 

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

func (*ComparisonExpression) GetLeftValue 

func (m *ComparisonExpression) GetLeftValue() *Operand

func (*ComparisonExpression) GetOperator 

func (m *ComparisonExpression) GetOperator() ComparisonExpression_Operator

func (*ComparisonExpression) GetRightValue 

func (m *ComparisonExpression) GetRightValue() *Operand

func (*ComparisonExpression) ProtoMessage 

func (*ComparisonExpression) ProtoMessage()

func (*ComparisonExpression) Reset 

func (m *ComparisonExpression) Reset()

func (*ComparisonExpression) String 

func (m *ComparisonExpression) String() string

func (*ComparisonExpression) 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 ComparisonExpression_Operator 

type ComparisonExpression_Operator int32

Binary Operator for each expression 

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

func (ComparisonExpression_Operator) EnumDescriptor 

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

func (ComparisonExpression_Operator) String 

func (x ComparisonExpression_Operator) String() string

type CompiledTask 

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

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

func (*CompiledTask) Descriptor 

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

func (*CompiledTask) GetTemplate 

func (m *CompiledTask) GetTemplate() *TaskTemplate

func (*CompiledTask) ProtoMessage 

func (*CompiledTask) ProtoMessage()

func (*CompiledTask) Reset 

func (m *CompiledTask) Reset()

func (*CompiledTask) String 

func (m *CompiledTask) String() string

func (*CompiledTask) 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 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) 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 (at least 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) 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 ConjunctionExpression 

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

Defines a conjunction expression of two boolean expressions.

func (*ConjunctionExpression) Descriptor 

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

func (*ConjunctionExpression) GetLeftExpression 

func (m *ConjunctionExpression) GetLeftExpression() *BooleanExpression

func (*ConjunctionExpression) GetOperator 

func (m *ConjunctionExpression) GetOperator() ConjunctionExpression_LogicalOperator

func (*ConjunctionExpression) GetRightExpression 

func (m *ConjunctionExpression) GetRightExpression() *BooleanExpression

func (*ConjunctionExpression) ProtoMessage 

func (*ConjunctionExpression) ProtoMessage()

func (*ConjunctionExpression) Reset 

func (m *ConjunctionExpression) Reset()

func (*ConjunctionExpression) String 

func (m *ConjunctionExpression) String() string

func (*ConjunctionExpression) 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 ConjunctionExpression_LogicalOperator 

type ConjunctionExpression_LogicalOperator int32

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

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

func (ConjunctionExpression_LogicalOperator) EnumDescriptor 

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

func (ConjunctionExpression_LogicalOperator) String 

func (x ConjunctionExpression_LogicalOperator) String() string

type ConnectionSet 

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

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

func (*ConnectionSet) Descriptor 

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

func (*ConnectionSet) GetDownstream 

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

func (*ConnectionSet) GetUpstream 

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

func (*ConnectionSet) ProtoMessage 

func (*ConnectionSet) ProtoMessage()

func (*ConnectionSet) Reset 

func (m *ConnectionSet) Reset()

func (*ConnectionSet) String 

func (m *ConnectionSet) String() string

func (*ConnectionSet) 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 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) 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 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.
	// Deprecated, please use TaskTemplate.config instead.
	Config []*KeyValuePair `protobuf:"bytes,6,rep,name=config,proto3" json:"config,omitempty"` // Deprecated: Do not use.
	// 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"`
	Architecture         Container_Architecture `protobuf:"varint,10,opt,name=architecture,proto3,enum=flyteidl.core.Container_Architecture" json:"architecture,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Container) Descriptor 

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

func (*Container) GetArchitecture 

func (m *Container) GetArchitecture() Container_Architecture

func (*Container) GetArgs 

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

func (*Container) GetCommand 

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

func (*Container) GetConfig deprecated 

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

Deprecated: Do not use.

func (*Container) GetDataConfig 

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) 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

type ContainerError 

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

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

func (*ContainerError) Descriptor 

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

func (*ContainerError) GetCode 

func (m *ContainerError) GetCode() string

func (*ContainerError) GetKind 

func (m *ContainerError) GetKind() ContainerError_Kind

func (*ContainerError) GetMessage 

func (m *ContainerError) GetMessage() string

func (*ContainerError) GetOrigin 

func (m *ContainerError) GetOrigin() ExecutionError_ErrorKind

func (*ContainerError) ProtoMessage 

func (*ContainerError) ProtoMessage()

func (*ContainerError) Reset 

func (m *ContainerError) Reset()

func (*ContainerError) String 

func (m *ContainerError) String() string

func (*ContainerError) XXX_DiscardUnknown 

func (m *ContainerError) XXX_DiscardUnknown()

func (*ContainerError) XXX_Marshal 

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

func (*ContainerError) XXX_Merge 

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

func (*ContainerError) XXX_Size 

func (m *ContainerError) XXX_Size() int

func (*ContainerError) XXX_Unmarshal 

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

type ContainerError_Kind 

type ContainerError_Kind int32

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

const (
	ContainerError_NON_RECOVERABLE ContainerError_Kind = 0
	ContainerError_RECOVERABLE     ContainerError_Kind = 1
)

func (ContainerError_Kind) EnumDescriptor 

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

func (ContainerError_Kind) String 

func (x ContainerError_Kind) String() string

type ContainerPort 

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

Defines port properties for a container.

func (*ContainerPort) Descriptor 

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

func (*ContainerPort) GetContainerPort 

func (m *ContainerPort) GetContainerPort() uint32

func (*ContainerPort) ProtoMessage 

func (*ContainerPort) ProtoMessage()

func (*ContainerPort) Reset 

func (m *ContainerPort) Reset()

func (*ContainerPort) String 

func (m *ContainerPort) String() string

func (*ContainerPort) XXX_DiscardUnknown 

func (m *ContainerPort) XXX_DiscardUnknown()

func (*ContainerPort) XXX_Marshal 

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

func (*ContainerPort) XXX_Merge 

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

func (*ContainerPort) XXX_Size 

func (m *ContainerPort) XXX_Size() int

func (*ContainerPort) XXX_Unmarshal 

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

type Container_Architecture 

type Container_Architecture int32

Architecture-type the container image supports. 

const (
	Container_UNKNOWN Container_Architecture = 0
	Container_AMD64   Container_Architecture = 1
	Container_ARM64   Container_Architecture = 2
	Container_ARM_V6  Container_Architecture = 3
	Container_ARM_V7  Container_Architecture = 4
)

func (Container_Architecture) EnumDescriptor 

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

func (Container_Architecture) String 

func (x Container_Architecture) String() string

type DataLoadingConfig 

type DataLoadingConfig struct {
	// Flag enables DataLoading Config. If this is not set, data loading will not be used!
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// File system path (start at root). This folder will contain all the inputs exploded to a separate file.
	// Example, if the input interface needs (x: int, y: blob, z: multipart_blob) and the input path is '/var/flyte/inputs', then the file system will look like
	// /var/flyte/inputs/inputs.<metadata format dependent -> .pb .json .yaml> -> Format as defined previously. The Blob and Multipart blob will reference local filesystem instead of remote locations
	// /var/flyte/inputs/x -> X is a file that contains the value of x (integer) in string format
	// /var/flyte/inputs/y -> Y is a file in Binary format
	// /var/flyte/inputs/z/... -> Note Z itself is a directory
	// More information about the protocol - refer to docs #TODO reference docs here
	InputPath string `protobuf:"bytes,2,opt,name=input_path,json=inputPath,proto3" json:"input_path,omitempty"`
	// File system path (start at root). This folder should contain all the outputs for the task as individual files and/or an error text file
	OutputPath string `protobuf:"bytes,3,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
	// In the inputs folder, there will be an additional summary/metadata file that contains references to all files or inlined primitive values.
	// This format decides the actual encoding for the data. Refer to the encoding to understand the specifics of the contents and the encoding
	Format               DataLoadingConfig_LiteralMapFormat `protobuf:"varint,4,opt,name=format,proto3,enum=flyteidl.core.DataLoadingConfig_LiteralMapFormat" json:"format,omitempty"`
	IoStrategy           *IOStrategy                        `protobuf:"bytes,5,opt,name=io_strategy,json=ioStrategy,proto3" json:"io_strategy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

This configuration allows executing raw containers in Flyte using the Flyte CoPilot system. Flyte CoPilot, eliminates the needs of flytekit or sdk inside the container. Any inputs required by the users container are side-loaded in the input_path Any outputs generated by the user container - within output_path are automatically uploaded.

func (*DataLoadingConfig) Descriptor 

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

func (*DataLoadingConfig) GetEnabled 

func (m *DataLoadingConfig) GetEnabled() bool

func (*DataLoadingConfig) GetFormat 

func (m *DataLoadingConfig) GetFormat() DataLoadingConfig_LiteralMapFormat

func (*DataLoadingConfig) GetInputPath 

func (m *DataLoadingConfig) GetInputPath() string

func (*DataLoadingConfig) GetIoStrategy 

func (m *DataLoadingConfig) GetIoStrategy() *IOStrategy

func (*DataLoadingConfig) GetOutputPath 

func (m *DataLoadingConfig) GetOutputPath() string

func (*DataLoadingConfig) ProtoMessage 

func (*DataLoadingConfig) ProtoMessage()

func (*DataLoadingConfig) Reset 

func (m *DataLoadingConfig) Reset()

func (*DataLoadingConfig) String 

func (m *DataLoadingConfig) String() string

func (*DataLoadingConfig) XXX_DiscardUnknown 

func (m *DataLoadingConfig) XXX_DiscardUnknown()

func (*DataLoadingConfig) XXX_Marshal 

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

func (*DataLoadingConfig) XXX_Merge 

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

func (*DataLoadingConfig) XXX_Size 

func (m *DataLoadingConfig) XXX_Size() int

func (*DataLoadingConfig) XXX_Unmarshal 

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

type DataLoadingConfig_LiteralMapFormat 

type DataLoadingConfig_LiteralMapFormat int32

LiteralMapFormat decides the encoding format in which the input metadata should be made available to the containers. If the user has access to the protocol buffer definitions, it is recommended to use the PROTO format. JSON and YAML do not need any protobuf definitions to read it All remote references in core.LiteralMap are replaced with local filesystem references (the data is downloaded to local filesystem) 

const (
	// JSON / YAML for the metadata (which contains inlined primitive values). The representation is inline with the standard json specification as specified - https://www.json.org/json-en.html
	DataLoadingConfig_JSON DataLoadingConfig_LiteralMapFormat = 0
	DataLoadingConfig_YAML DataLoadingConfig_LiteralMapFormat = 1
	// Proto is a serialized binary of `core.LiteralMap` defined in flyteidl/core
	DataLoadingConfig_PROTO DataLoadingConfig_LiteralMapFormat = 2
)

func (DataLoadingConfig_LiteralMapFormat) EnumDescriptor 

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

func (DataLoadingConfig_LiteralMapFormat) String 

func (x DataLoadingConfig_LiteralMapFormat) String() string

type DynamicJobSpec 

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

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

func (*DynamicJobSpec) Descriptor 

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

func (*DynamicJobSpec) GetMinSuccesses 

func (m *DynamicJobSpec) GetMinSuccesses() int64

func (*DynamicJobSpec) GetNodes 

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

func (*DynamicJobSpec) GetOutputs 

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

func (*DynamicJobSpec) GetSubworkflows 

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

func (*DynamicJobSpec) GetTasks 

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

func (*DynamicJobSpec) ProtoMessage 

func (*DynamicJobSpec) ProtoMessage()

func (*DynamicJobSpec) Reset 

func (m *DynamicJobSpec) Reset()

func (*DynamicJobSpec) String 

func (m *DynamicJobSpec) String() string

func (*DynamicJobSpec) XXX_DiscardUnknown 

func (m *DynamicJobSpec) XXX_DiscardUnknown()

func (*DynamicJobSpec) XXX_Marshal 

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

func (*DynamicJobSpec) XXX_Merge 

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

func (*DynamicJobSpec) XXX_Size 

func (m *DynamicJobSpec) XXX_Size() int

func (*DynamicJobSpec) XXX_Unmarshal 

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

type EnumType 

type EnumType struct {
	// Predefined set of enum values.
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Enables declaring enum types, with predefined string values For len(values) > 0, the first value in the ordered list is regarded as the default value. If you wish To provide no defaults, make the first value as undefined.

func (*EnumType) Descriptor 

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

func (*EnumType) GetValues 

func (m *EnumType) GetValues() []string

func (*EnumType) ProtoMessage 

func (*EnumType) ProtoMessage()

func (*EnumType) Reset 

func (m *EnumType) Reset()

func (*EnumType) String 

func (m *EnumType) String() string

func (*EnumType) XXX_DiscardUnknown 

func (m *EnumType) XXX_DiscardUnknown()

func (*EnumType) XXX_Marshal 

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

func (*EnumType) XXX_Merge 

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

func (*EnumType) XXX_Size 

func (m *EnumType) XXX_Size() int

func (*EnumType) XXX_Unmarshal 

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

type Error 

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

Represents an error thrown from a node.

func (*Error) Descriptor 

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

func (*Error) GetFailedNodeId 

func (m *Error) GetFailedNodeId() string

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type ErrorDocument 

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

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

func (*ErrorDocument) Descriptor 

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

func (*ErrorDocument) GetError 

func (m *ErrorDocument) GetError() *ContainerError

func (*ErrorDocument) ProtoMessage 

func (*ErrorDocument) ProtoMessage()

func (*ErrorDocument) Reset 

func (m *ErrorDocument) Reset()

func (*ErrorDocument) String 

func (m *ErrorDocument) String() string

func (*ErrorDocument) XXX_DiscardUnknown 

func (m *ErrorDocument) XXX_DiscardUnknown()

func (*ErrorDocument) XXX_Marshal 

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

func (*ErrorDocument) XXX_Merge 

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

func (*ErrorDocument) XXX_Size 

func (m *ErrorDocument) XXX_Size() int

func (*ErrorDocument) XXX_Unmarshal 

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

type ExecutionError 

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

Represents the error message from the execution.

func (*ExecutionError) Descriptor 

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

func (*ExecutionError) GetCode 

func (m *ExecutionError) GetCode() string

func (*ExecutionError) GetErrorUri 

func (m *ExecutionError) GetErrorUri() string

func (*ExecutionError) GetKind 

func (m *ExecutionError) GetKind() ExecutionError_ErrorKind

func (*ExecutionError) GetMessage 

func (m *ExecutionError) GetMessage() string

func (*ExecutionError) ProtoMessage 

func (*ExecutionError) ProtoMessage()

func (*ExecutionError) Reset 

func (m *ExecutionError) Reset()

func (*ExecutionError) String 

func (m *ExecutionError) String() string

func (*ExecutionError) XXX_DiscardUnknown 

func (m *ExecutionError) XXX_DiscardUnknown()

func (*ExecutionError) XXX_Marshal 

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

func (*ExecutionError) XXX_Merge 

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

func (*ExecutionError) XXX_Size 

func (m *ExecutionError) XXX_Size() int

func (*ExecutionError) XXX_Unmarshal 

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

type ExecutionError_ErrorKind 

type ExecutionError_ErrorKind int32

Error type: System or User 

const (
	ExecutionError_UNKNOWN ExecutionError_ErrorKind = 0
	ExecutionError_USER    ExecutionError_ErrorKind = 1
	ExecutionError_SYSTEM  ExecutionError_ErrorKind = 2
)

func (ExecutionError_ErrorKind) EnumDescriptor 

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

func (ExecutionError_ErrorKind) String 

func (x ExecutionError_ErrorKind) String() string

type ExecutionMetricResult added in v1.10.7 

type ExecutionMetricResult struct {
	// The metric this data represents. e.g. EXECUTION_METRIC_USED_CPU_AVG or EXECUTION_METRIC_USED_MEMORY_BYTES_AVG.
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// The result data in prometheus range query result format
	// https://prometheus.io/docs/prometheus/latest/querying/api/#expression-query-result-formats.
	// This may include multiple time series, differentiated by their metric labels.
	// Start time is greater of (execution attempt start, 48h ago)
	// End time is lesser of (execution attempt end, now)
	Data                 *_struct.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

ExecutionMetrics is a collection of metrics that are collected during the execution of a Flyte task.

func (*ExecutionMetricResult) Descriptor added in v1.10.7 

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

func (*ExecutionMetricResult) GetData added in v1.10.7 

func (m *ExecutionMetricResult) GetData() *_struct.Struct

func (*ExecutionMetricResult) GetMetric added in v1.10.7 

func (m *ExecutionMetricResult) GetMetric() string

func (*ExecutionMetricResult) ProtoMessage added in v1.10.7 

func (*ExecutionMetricResult) ProtoMessage()

func (*ExecutionMetricResult) Reset added in v1.10.7 

func (m *ExecutionMetricResult) Reset()

func (*ExecutionMetricResult) String added in v1.10.7 

func (m *ExecutionMetricResult) String() string

func (*ExecutionMetricResult) XXX_DiscardUnknown 

func (m *ExecutionMetricResult) XXX_DiscardUnknown()

func (*ExecutionMetricResult) XXX_Marshal 

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

func (*ExecutionMetricResult) XXX_Merge 

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

func (*ExecutionMetricResult) XXX_Size 

func (m *ExecutionMetricResult) XXX_Size() int

func (*ExecutionMetricResult) XXX_Unmarshal 

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

type ExtendedResources added in v1.9.20 

type ExtendedResources struct {
	// GPU accelerator to select for task. Contains information about device type, and
	// for multi-instance GPUs, the partition size to use.
	GpuAccelerator       *GPUAccelerator `protobuf:"bytes,1,opt,name=gpu_accelerator,json=gpuAccelerator,proto3" json:"gpu_accelerator,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Encapsulates all non-standard resources, not captured by v1.ResourceRequirements, to allocate to a task.

func (*ExtendedResources) Descriptor added in v1.9.20 

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

func (*ExtendedResources) GetGpuAccelerator added in v1.9.20 

func (m *ExtendedResources) GetGpuAccelerator() *GPUAccelerator

func (*ExtendedResources) ProtoMessage added in v1.9.20 

func (*ExtendedResources) ProtoMessage()

func (*ExtendedResources) Reset added in v1.9.20 

func (m *ExtendedResources) Reset()

func (*ExtendedResources) String added in v1.9.20 

func (m *ExtendedResources) String() string

func (*ExtendedResources) XXX_DiscardUnknown added in v1.9.20 

func (m *ExtendedResources) XXX_DiscardUnknown()

func (*ExtendedResources) XXX_Marshal added in v1.9.20 

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

func (*ExtendedResources) XXX_Merge added in v1.9.20 

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

func (*ExtendedResources) XXX_Size added in v1.9.20 

func (m *ExtendedResources) XXX_Size() int

func (*ExtendedResources) XXX_Unmarshal added in v1.9.20 

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

type GPUAccelerator added in v1.9.20 

type GPUAccelerator struct {
	// This can be any arbitrary string, and should be informed by the labels or taints
	// associated with the nodes in question. Default cloud provider labels typically
	// use the following values: `nvidia-tesla-t4`, `nvidia-tesla-a100`, etc.
	Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	// Types that are valid to be assigned to PartitionSizeValue:
	//	*GPUAccelerator_Unpartitioned
	//	*GPUAccelerator_PartitionSize
	PartitionSizeValue   isGPUAccelerator_PartitionSizeValue `protobuf_oneof:"partition_size_value"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

Metadata associated with the GPU accelerator to allocate to a task. Contains information about device type, and for multi-instance GPUs, the partition size to use.

func (*GPUAccelerator) Descriptor added in v1.9.20 

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

func (*GPUAccelerator) GetDevice added in v1.9.20 

func (m *GPUAccelerator) GetDevice() string

func (*GPUAccelerator) GetPartitionSize added in v1.9.20 

func (m *GPUAccelerator) GetPartitionSize() string

func (*GPUAccelerator) GetPartitionSizeValue added in v1.9.20 

func (m *GPUAccelerator) GetPartitionSizeValue() isGPUAccelerator_PartitionSizeValue

func (*GPUAccelerator) GetUnpartitioned added in v1.9.20 

func (m *GPUAccelerator) GetUnpartitioned() bool

func (*GPUAccelerator) ProtoMessage added in v1.9.20 

func (*GPUAccelerator) ProtoMessage()

func (*GPUAccelerator) Reset added in v1.9.20 

func (m *GPUAccelerator) Reset()

func (*GPUAccelerator) String added in v1.9.20 

func (m *GPUAccelerator) String() string

func (*GPUAccelerator) XXX_DiscardUnknown added in v1.9.20 

func (m *GPUAccelerator) XXX_DiscardUnknown()

func (*GPUAccelerator) XXX_Marshal added in v1.9.20 

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

func (*GPUAccelerator) XXX_Merge added in v1.9.20 

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

func (*GPUAccelerator) XXX_OneofWrappers added in v1.9.20 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GPUAccelerator) XXX_Size added in v1.9.20 

func (m *GPUAccelerator) XXX_Size() int

func (*GPUAccelerator) XXX_Unmarshal added in v1.9.20 

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

type GPUAccelerator_PartitionSize added in v1.9.20 

type GPUAccelerator_PartitionSize struct {
	PartitionSize string `protobuf:"bytes,3,opt,name=partition_size,json=partitionSize,proto3,oneof"`
}

type GPUAccelerator_Unpartitioned added in v1.9.20 

type GPUAccelerator_Unpartitioned struct {
	Unpartitioned bool `protobuf:"varint,2,opt,name=unpartitioned,proto3,oneof"`
}

type GateNode 

type GateNode struct {
	// Types that are valid to be assigned to Condition:
	//	*GateNode_Approve
	//	*GateNode_Signal
	//	*GateNode_Sleep
	Condition            isGateNode_Condition `protobuf_oneof:"condition"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

GateNode refers to the condition that is required for the gate to successfully complete.

func (*GateNode) Descriptor 

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

func (*GateNode) GetApprove 

func (m *GateNode) GetApprove() *ApproveCondition

func (*GateNode) GetCondition 

func (m *GateNode) GetCondition() isGateNode_Condition

func (*GateNode) GetSignal 

func (m *GateNode) GetSignal() *SignalCondition

func (*GateNode) GetSleep 

func (m *GateNode) GetSleep() *SleepCondition

func (*GateNode) ProtoMessage 

func (*GateNode) ProtoMessage()

func (*GateNode) Reset 

func (m *GateNode) Reset()

func (*GateNode) String 

func (m *GateNode) String() string

func (*GateNode) XXX_DiscardUnknown 

func (m *GateNode) XXX_DiscardUnknown()

func (*GateNode) XXX_Marshal 

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

func (*GateNode) XXX_Merge 

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

func (*GateNode) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*GateNode) XXX_Size 

func (m *GateNode) XXX_Size() int

func (*GateNode) XXX_Unmarshal 

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

type GateNode_Approve 

type GateNode_Approve struct {
	Approve *ApproveCondition `protobuf:"bytes,1,opt,name=approve,proto3,oneof"`
}

type GateNode_Signal 

type GateNode_Signal struct {
	Signal *SignalCondition `protobuf:"bytes,2,opt,name=signal,proto3,oneof"`
}

type GateNode_Sleep 

type GateNode_Sleep struct {
	Sleep *SleepCondition `protobuf:"bytes,3,opt,name=sleep,proto3,oneof"`
}

type IOStrategy 

type IOStrategy struct {
	// Mode to use to manage downloads
	DownloadMode IOStrategy_DownloadMode `` /* 141-byte string literal not displayed */
	// Mode to use to manage uploads
	UploadMode           IOStrategy_UploadMode `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

Strategy to use when dealing with Blob, Schema, or multipart blob data (large datasets)

func (*IOStrategy) Descriptor 

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

func (*IOStrategy) GetDownloadMode 

func (m *IOStrategy) GetDownloadMode() IOStrategy_DownloadMode

func (*IOStrategy) GetUploadMode 

func (m *IOStrategy) GetUploadMode() IOStrategy_UploadMode

func (*IOStrategy) ProtoMessage 

func (*IOStrategy) ProtoMessage()

func (*IOStrategy) Reset 

func (m *IOStrategy) Reset()

func (*IOStrategy) String 

func (m *IOStrategy) String() string

func (*IOStrategy) XXX_DiscardUnknown 

func (m *IOStrategy) XXX_DiscardUnknown()

func (*IOStrategy) XXX_Marshal 

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

func (*IOStrategy) XXX_Merge 

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

func (*IOStrategy) XXX_Size 

func (m *IOStrategy) XXX_Size() int

func (*IOStrategy) XXX_Unmarshal 

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

type IOStrategy_DownloadMode 

type IOStrategy_DownloadMode int32

Mode to use for downloading 

const (
	// All data will be downloaded before the main container is executed
	IOStrategy_DOWNLOAD_EAGER IOStrategy_DownloadMode = 0
	// Data will be downloaded as a stream and an End-Of-Stream marker will be written to indicate all data has been downloaded. Refer to protocol for details
	IOStrategy_DOWNLOAD_STREAM IOStrategy_DownloadMode = 1
	// Large objects (offloaded) will not be downloaded
	IOStrategy_DO_NOT_DOWNLOAD IOStrategy_DownloadMode = 2
)

func (IOStrategy_DownloadMode) EnumDescriptor 

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

func (IOStrategy_DownloadMode) String 

func (x IOStrategy_DownloadMode) String() string

type IOStrategy_UploadMode 

type IOStrategy_UploadMode int32

Mode to use for uploading 

const (
	// All data will be uploaded after the main container exits
	IOStrategy_UPLOAD_ON_EXIT IOStrategy_UploadMode = 0
	// Data will be uploaded as it appears. Refer to protocol specification for details
	IOStrategy_UPLOAD_EAGER IOStrategy_UploadMode = 1
	// Data will not be uploaded, only references will be written
	IOStrategy_DO_NOT_UPLOAD IOStrategy_UploadMode = 2
)

func (IOStrategy_UploadMode) EnumDescriptor 

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

func (IOStrategy_UploadMode) String 

func (x IOStrategy_UploadMode) String() string

type Identifier 

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

Encapsulation of fields that uniquely identifies a Flyte resource.

func (*Identifier) Descriptor 

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

func (*Identifier) GetDomain 

func (m *Identifier) GetDomain() string

func (*Identifier) GetName 

func (m *Identifier) GetName() string

func (*Identifier) GetOrg added in v1.10.7 

func (m *Identifier) GetOrg() string

func (*Identifier) GetProject 

func (m *Identifier) GetProject() string

func (*Identifier) GetResourceType 

func (m *Identifier) GetResourceType() ResourceType

func (*Identifier) GetVersion 

func (m *Identifier) GetVersion() string

func (*Identifier) ProtoMessage 

func (*Identifier) ProtoMessage()

func (*Identifier) Reset 

func (m *Identifier) Reset()

func (*Identifier) String 

func (m *Identifier) String() string

func (*Identifier) XXX_DiscardUnknown 

func (m *Identifier) XXX_DiscardUnknown()

func (*Identifier) XXX_Marshal 

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

func (*Identifier) XXX_Merge 

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

func (*Identifier) XXX_Size 

func (m *Identifier) XXX_Size() int

func (*Identifier) XXX_Unmarshal 

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

type Identity 

type Identity struct {
	// iam_role references the fully qualified name of Identity & Access Management role to impersonate.
	IamRole string `protobuf:"bytes,1,opt,name=iam_role,json=iamRole,proto3" json:"iam_role,omitempty"`
	// k8s_service_account references a kubernetes service account to impersonate.
	K8SServiceAccount string `protobuf:"bytes,2,opt,name=k8s_service_account,json=k8sServiceAccount,proto3" json:"k8s_service_account,omitempty"`
	// oauth2_client references an oauth2 client. Backend plugins can use this information to impersonate the client when
	// making external calls.
	Oauth2Client *OAuth2Client `protobuf:"bytes,3,opt,name=oauth2_client,json=oauth2Client,proto3" json:"oauth2_client,omitempty"`
	// execution_identity references the subject who makes the execution
	ExecutionIdentity    string   `protobuf:"bytes,4,opt,name=execution_identity,json=executionIdentity,proto3" json:"execution_identity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Identity encapsulates the various security identities a task can run as. It's up to the underlying plugin to pick the right identity for the execution environment.

func (*Identity) Descriptor 

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

func (*Identity) GetExecutionIdentity 

func (m *Identity) GetExecutionIdentity() string

func (*Identity) GetIamRole 

func (m *Identity) GetIamRole() string

func (*Identity) GetK8SServiceAccount 

func (m *Identity) GetK8SServiceAccount() string

func (*Identity) GetOauth2Client 

func (m *Identity) GetOauth2Client() *OAuth2Client

func (*Identity) ProtoMessage 

func (*Identity) ProtoMessage()

func (*Identity) Reset 

func (m *Identity) Reset()

func (*Identity) String 

func (m *Identity) String() string

func (*Identity) XXX_DiscardUnknown 

func (m *Identity) XXX_DiscardUnknown()

func (*Identity) XXX_Marshal 

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

func (*Identity) XXX_Merge 

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

func (*Identity) XXX_Size 

func (m *Identity) XXX_Size() int

func (*Identity) XXX_Unmarshal 

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

type IfBlock 

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

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

func (*IfBlock) Descriptor 

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

func (*IfBlock) GetCondition 

func (m *IfBlock) GetCondition() *BooleanExpression

func (*IfBlock) GetThenNode 

func (m *IfBlock) GetThenNode() *Node

func (*IfBlock) ProtoMessage 

func (*IfBlock) ProtoMessage()

func (*IfBlock) Reset 

func (m *IfBlock) Reset()

func (*IfBlock) String 

func (m *IfBlock) String() string

func (*IfBlock) XXX_DiscardUnknown 

func (m *IfBlock) XXX_DiscardUnknown()

func (*IfBlock) XXX_Marshal 

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

func (*IfBlock) XXX_Merge 

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

func (*IfBlock) XXX_Size 

func (m *IfBlock) XXX_Size() int

func (*IfBlock) XXX_Unmarshal 

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

type IfElseBlock 

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

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

func (*IfElseBlock) Descriptor 

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

func (*IfElseBlock) GetCase 

func (m *IfElseBlock) GetCase() *IfBlock

func (*IfElseBlock) GetDefault 

func (m *IfElseBlock) GetDefault() isIfElseBlock_Default

func (*IfElseBlock) GetElseNode 

func (m *IfElseBlock) GetElseNode() *Node

func (*IfElseBlock) GetError 

func (m *IfElseBlock) GetError() *Error

func (*IfElseBlock) GetOther 

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

func (*IfElseBlock) ProtoMessage 

func (*IfElseBlock) ProtoMessage()

func (*IfElseBlock) Reset 

func (m *IfElseBlock) Reset()

func (*IfElseBlock) String 

func (m *IfElseBlock) String() string

func (*IfElseBlock) XXX_DiscardUnknown 

func (m *IfElseBlock) XXX_DiscardUnknown()

func (*IfElseBlock) XXX_Marshal 

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

func (*IfElseBlock) XXX_Merge 

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

func (*IfElseBlock) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*IfElseBlock) XXX_Size 

func (m *IfElseBlock) XXX_Size() int

func (*IfElseBlock) XXX_Unmarshal 

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

type IfElseBlock_ElseNode 

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

type IfElseBlock_Error 

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

type InputBindingData added in v1.10.7 

type InputBindingData struct {
	Var                  string   `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InputBindingData) Descriptor added in v1.10.7 

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

func (*InputBindingData) GetVar added in v1.10.7 

func (m *InputBindingData) GetVar() string

func (*InputBindingData) ProtoMessage added in v1.10.7 

func (*InputBindingData) ProtoMessage()

func (*InputBindingData) Reset added in v1.10.7 

func (m *InputBindingData) Reset()

func (*InputBindingData) String added in v1.10.7 

func (m *InputBindingData) String() string

func (*InputBindingData) XXX_DiscardUnknown 

func (m *InputBindingData) XXX_DiscardUnknown()

func (*InputBindingData) XXX_Marshal 

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

func (*InputBindingData) XXX_Merge 

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

func (*InputBindingData) XXX_Size 

func (m *InputBindingData) XXX_Size() int

func (*InputBindingData) XXX_Unmarshal 

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

type K8SObjectMetadata 

type K8SObjectMetadata struct {
	// Optional labels to add to the pod definition.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Optional annotations to add to the pod definition.
	Annotations          map[string]string `` /* 163-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Metadata for building a kubernetes object when a task is executed.

func (*K8SObjectMetadata) Descriptor 

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

func (*K8SObjectMetadata) GetAnnotations 

func (m *K8SObjectMetadata) GetAnnotations() map[string]string

func (*K8SObjectMetadata) GetLabels 

func (m *K8SObjectMetadata) GetLabels() map[string]string

func (*K8SObjectMetadata) ProtoMessage 

func (*K8SObjectMetadata) ProtoMessage()

func (*K8SObjectMetadata) Reset 

func (m *K8SObjectMetadata) Reset()

func (*K8SObjectMetadata) String 

func (m *K8SObjectMetadata) String() string

func (*K8SObjectMetadata) XXX_DiscardUnknown 

func (m *K8SObjectMetadata) XXX_DiscardUnknown()

func (*K8SObjectMetadata) XXX_Marshal 

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

func (*K8SObjectMetadata) XXX_Merge 

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

func (*K8SObjectMetadata) XXX_Size 

func (m *K8SObjectMetadata) XXX_Size() int

func (*K8SObjectMetadata) XXX_Unmarshal 

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

type K8SPod 

type K8SPod struct {
	// Contains additional metadata for building a kubernetes pod.
	Metadata *K8SObjectMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Defines the primary pod spec created when a task is executed.
	// This should be a JSON-marshalled pod spec, which can be defined in
	// - go, using: https://github.com/kubernetes/api/blob/release-1.21/core/v1/types.go#L2936
	// - python: using https://github.com/kubernetes-client/python/blob/release-19.0/kubernetes/client/models/v1_pod_spec.py
	PodSpec *_struct.Struct `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,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 flytekit. 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,3,opt,name=data_config,json=dataConfig,proto3" json:"data_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Defines a pod spec and additional pod metadata that is created when a task is executed.

func (*K8SPod) Descriptor 

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

func (*K8SPod) GetDataConfig 

func (m *K8SPod) GetDataConfig() *DataLoadingConfig

func (*K8SPod) GetMetadata 

func (m *K8SPod) GetMetadata() *K8SObjectMetadata

func (*K8SPod) GetPodSpec 

func (m *K8SPod) GetPodSpec() *_struct.Struct

func (*K8SPod) ProtoMessage 

func (*K8SPod) ProtoMessage()

func (*K8SPod) Reset 

func (m *K8SPod) Reset()

func (*K8SPod) String 

func (m *K8SPod) String() string

func (*K8SPod) XXX_DiscardUnknown 

func (m *K8SPod) XXX_DiscardUnknown()

func (*K8SPod) XXX_Marshal 

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

func (*K8SPod) XXX_Merge 

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

func (*K8SPod) XXX_Size 

func (m *K8SPod) XXX_Size() int

func (*K8SPod) XXX_Unmarshal 

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

type KeyValuePair 

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

A generic key value pair.

func (*KeyValuePair) Descriptor 

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

func (*KeyValuePair) GetKey 

func (m *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (m *KeyValuePair) GetValue() string

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) Reset 

func (m *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (m *KeyValuePair) String() string

func (*KeyValuePair) XXX_DiscardUnknown 

func (m *KeyValuePair) XXX_DiscardUnknown()

func (*KeyValuePair) XXX_Marshal 

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

func (*KeyValuePair) XXX_Merge 

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

func (*KeyValuePair) XXX_Size 

func (m *KeyValuePair) XXX_Size() int

func (*KeyValuePair) XXX_Unmarshal 

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

type LabelValue added in v1.10.7 

type LabelValue struct {
	// Types that are valid to be assigned to Value:
	//	*LabelValue_StaticValue
	//	*LabelValue_TriggeredBinding
	//	*LabelValue_InputBinding
	Value                isLabelValue_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*LabelValue) Descriptor added in v1.10.7 

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

func (*LabelValue) GetInputBinding added in v1.10.7 

func (m *LabelValue) GetInputBinding() *InputBindingData

func (*LabelValue) GetStaticValue added in v1.10.7 

func (m *LabelValue) GetStaticValue() string

func (*LabelValue) GetTriggeredBinding added in v1.10.7 

func (m *LabelValue) GetTriggeredBinding() *ArtifactBindingData

func (*LabelValue) GetValue added in v1.10.7 

func (m *LabelValue) GetValue() isLabelValue_Value

func (*LabelValue) ProtoMessage added in v1.10.7 

func (*LabelValue) ProtoMessage()

func (*LabelValue) Reset added in v1.10.7 

func (m *LabelValue) Reset()

func (*LabelValue) String added in v1.10.7 

func (m *LabelValue) String() string

func (*LabelValue) XXX_DiscardUnknown 

func (m *LabelValue) XXX_DiscardUnknown()

func (*LabelValue) XXX_Marshal 

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

func (*LabelValue) XXX_Merge 

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

func (*LabelValue) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*LabelValue) XXX_Size 

func (m *LabelValue) XXX_Size() int

func (*LabelValue) XXX_Unmarshal 

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

type LabelValue_InputBinding added in v1.10.7 

type LabelValue_InputBinding struct {
	InputBinding *InputBindingData `protobuf:"bytes,3,opt,name=input_binding,json=inputBinding,proto3,oneof"`
}

type LabelValue_StaticValue added in v1.10.7 

type LabelValue_StaticValue struct {
	StaticValue string `protobuf:"bytes,1,opt,name=static_value,json=staticValue,proto3,oneof"`
}

type LabelValue_TriggeredBinding added in v1.10.7 

type LabelValue_TriggeredBinding struct {
	TriggeredBinding *ArtifactBindingData `protobuf:"bytes,2,opt,name=triggered_binding,json=triggeredBinding,proto3,oneof"`
}

type Literal 

type Literal struct {
	// Types that are valid to be assigned to Value:
	//	*Literal_Scalar
	//	*Literal_Collection
	//	*Literal_Map
	Value isLiteral_Value `protobuf_oneof:"value"`
	// A hash representing this literal.
	// This is used for caching purposes. For more details refer to RFC 1893
	// (https://github.com/flyteorg/flyte/blob/master/rfc/system/1893-caching-of-offloaded-objects.md)
	Hash string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	// Additional metadata for literals.
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*Literal) Descriptor 

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

func (*Literal) GetCollection 

func (m *Literal) GetCollection() *LiteralCollection

func (*Literal) GetHash 

func (m *Literal) GetHash() string

func (*Literal) GetMap 

func (m *Literal) GetMap() *LiteralMap

func (*Literal) GetMetadata added in v1.10.7 

func (m *Literal) GetMetadata() map[string]string

func (*Literal) GetScalar 

func (m *Literal) GetScalar() *Scalar

func (*Literal) GetValue 

func (m *Literal) GetValue() isLiteral_Value

func (*Literal) ProtoMessage 

func (*Literal) ProtoMessage()

func (*Literal) Reset 

func (m *Literal) Reset()

func (*Literal) String 

func (m *Literal) String() string

func (*Literal) XXX_DiscardUnknown 

func (m *Literal) XXX_DiscardUnknown()

func (*Literal) XXX_Marshal 

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

func (*Literal) XXX_Merge 

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

func (*Literal) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Literal) XXX_Size 

func (m *Literal) XXX_Size() int

func (*Literal) XXX_Unmarshal 

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

type LiteralCollection 

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

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

func (*LiteralCollection) Descriptor 

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

func (*LiteralCollection) GetLiterals 

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

func (*LiteralCollection) ProtoMessage 

func (*LiteralCollection) ProtoMessage()

func (*LiteralCollection) Reset 

func (m *LiteralCollection) Reset()

func (*LiteralCollection) String 

func (m *LiteralCollection) String() string

func (*LiteralCollection) XXX_DiscardUnknown 

func (m *LiteralCollection) XXX_DiscardUnknown()

func (*LiteralCollection) XXX_Marshal 

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

func (*LiteralCollection) XXX_Merge 

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

func (*LiteralCollection) XXX_Size 

func (m *LiteralCollection) XXX_Size() int

func (*LiteralCollection) XXX_Unmarshal 

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

type LiteralMap 

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

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

func (*LiteralMap) Descriptor 

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

func (*LiteralMap) GetLiterals 

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

func (*LiteralMap) ProtoMessage 

func (*LiteralMap) ProtoMessage()

func (*LiteralMap) Reset 

func (m *LiteralMap) Reset()

func (*LiteralMap) String 

func (m *LiteralMap) String() string

func (*LiteralMap) XXX_DiscardUnknown 

func (m *LiteralMap) XXX_DiscardUnknown()

func (*LiteralMap) XXX_Marshal 

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

func (*LiteralMap) XXX_Merge 

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

func (*LiteralMap) XXX_Size 

func (m *LiteralMap) XXX_Size() int

func (*LiteralMap) XXX_Unmarshal 

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

type LiteralType 

type LiteralType struct {
	// Types that are valid to be assigned to Type:
	//	*LiteralType_Simple
	//	*LiteralType_Schema
	//	*LiteralType_CollectionType
	//	*LiteralType_MapValueType
	//	*LiteralType_Blob
	//	*LiteralType_EnumType
	//	*LiteralType_StructuredDatasetType
	//	*LiteralType_UnionType
	Type isLiteralType_Type `protobuf_oneof:"type"`
	// This field contains type metadata that is descriptive of the type, but is NOT considered in type-checking.  This might be used by
	// consumers to identify special behavior or display extended information for the type.
	Metadata *_struct.Struct `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// This field contains arbitrary data that might have special semantic
	// meaning for the client but does not effect internal flyte behavior.
	Annotation *TypeAnnotation `protobuf:"bytes,9,opt,name=annotation,proto3" json:"annotation,omitempty"`
	// Hints to improve type matching.
	Structure            *TypeStructure `protobuf:"bytes,11,opt,name=structure,proto3" json:"structure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Defines a strong type to allow type checking between interfaces.

func (*LiteralType) Descriptor 

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

func (*LiteralType) GetAnnotation 

func (m *LiteralType) GetAnnotation() *TypeAnnotation

func (*LiteralType) GetBlob 

func (m *LiteralType) GetBlob() *BlobType

func (*LiteralType) GetCollectionType 

func (m *LiteralType) GetCollectionType() *LiteralType

func (*LiteralType) GetEnumType 

func (m *LiteralType) GetEnumType() *EnumType

func (*LiteralType) GetMapValueType 

func (m *LiteralType) GetMapValueType() *LiteralType

func (*LiteralType) GetMetadata 

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

func (*LiteralType) GetSchema 

func (m *LiteralType) GetSchema() *SchemaType

func (*LiteralType) GetSimple 

func (m *LiteralType) GetSimple() SimpleType

func (*LiteralType) GetStructure 

func (m *LiteralType) GetStructure() *TypeStructure

func (*LiteralType) GetStructuredDatasetType 

func (m *LiteralType) GetStructuredDatasetType() *StructuredDatasetType

func (*LiteralType) GetType 

func (m *LiteralType) GetType() isLiteralType_Type

func (*LiteralType) GetUnionType 

func (m *LiteralType) GetUnionType() *UnionType

func (*LiteralType) ProtoMessage 

func (*LiteralType) ProtoMessage()

func (*LiteralType) Reset 

func (m *LiteralType) Reset()

func (*LiteralType) String 

func (m *LiteralType) String() string

func (*LiteralType) XXX_DiscardUnknown 

func (m *LiteralType) XXX_DiscardUnknown()

func (*LiteralType) XXX_Marshal 

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

func (*LiteralType) XXX_Merge 

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

func (*LiteralType) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*LiteralType) XXX_Size 

func (m *LiteralType) XXX_Size() int

func (*LiteralType) XXX_Unmarshal 

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

type LiteralType_Blob 

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

type LiteralType_CollectionType 

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

type LiteralType_EnumType 

type LiteralType_EnumType struct {
	EnumType *EnumType `protobuf:"bytes,7,opt,name=enum_type,json=enumType,proto3,oneof"`
}

type LiteralType_MapValueType 

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

type LiteralType_Schema 

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

type LiteralType_Simple 

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

type LiteralType_StructuredDatasetType 

type LiteralType_StructuredDatasetType struct {
	StructuredDatasetType *StructuredDatasetType `protobuf:"bytes,8,opt,name=structured_dataset_type,json=structuredDatasetType,proto3,oneof"`
}

type LiteralType_UnionType 

type LiteralType_UnionType struct {
	UnionType *UnionType `protobuf:"bytes,10,opt,name=union_type,json=unionType,proto3,oneof"`
}

type Literal_Collection 

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

type Literal_Map 

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

type Literal_Scalar 

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

type Node 

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

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

func (*Node) Descriptor 

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

func (*Node) GetArrayNode 

func (m *Node) GetArrayNode() *ArrayNode

func (*Node) GetBranchNode 

func (m *Node) GetBranchNode() *BranchNode

func (*Node) GetGateNode 

func (m *Node) GetGateNode() *GateNode

func (*Node) GetId 

func (m *Node) GetId() string

func (*Node) GetInputs 

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

func (*Node) GetMetadata 

func (m *Node) GetMetadata() *NodeMetadata

func (*Node) GetOutputAliases 

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

func (*Node) GetTarget 

func (m *Node) GetTarget() isNode_Target

func (*Node) GetTaskNode 

func (m *Node) GetTaskNode() *TaskNode

func (*Node) GetUpstreamNodeIds 

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

func (*Node) GetWorkflowNode 

func (m *Node) GetWorkflowNode() *WorkflowNode

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeExecution 

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

Indicates various phases of Node Execution that only include the time spent to run the nodes/workflows

func (*NodeExecution) Descriptor 

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

func (*NodeExecution) ProtoMessage 

func (*NodeExecution) ProtoMessage()

func (*NodeExecution) Reset 

func (m *NodeExecution) Reset()

func (*NodeExecution) String 

func (m *NodeExecution) String() string

func (*NodeExecution) XXX_DiscardUnknown 

func (m *NodeExecution) XXX_DiscardUnknown()

func (*NodeExecution) XXX_Marshal 

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

func (*NodeExecution) XXX_Merge 

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

func (*NodeExecution) XXX_Size 

func (m *NodeExecution) XXX_Size() int

func (*NodeExecution) XXX_Unmarshal 

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

type NodeExecutionIdentifier 

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

Encapsulation of fields that identify a Flyte node execution entity.

func (*NodeExecutionIdentifier) Descriptor 

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

func (*NodeExecutionIdentifier) GetExecutionId 

func (m *NodeExecutionIdentifier) GetExecutionId() *WorkflowExecutionIdentifier

func (*NodeExecutionIdentifier) GetNodeId 

func (m *NodeExecutionIdentifier) GetNodeId() string

func (*NodeExecutionIdentifier) ProtoMessage 

func (*NodeExecutionIdentifier) ProtoMessage()

func (*NodeExecutionIdentifier) Reset 

func (m *NodeExecutionIdentifier) Reset()

func (*NodeExecutionIdentifier) String 

func (m *NodeExecutionIdentifier) String() string

func (*NodeExecutionIdentifier) XXX_DiscardUnknown 

func (m *NodeExecutionIdentifier) XXX_DiscardUnknown()

func (*NodeExecutionIdentifier) XXX_Marshal 

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

func (*NodeExecutionIdentifier) XXX_Merge 

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

func (*NodeExecutionIdentifier) XXX_Size 

func (m *NodeExecutionIdentifier) XXX_Size() int

func (*NodeExecutionIdentifier) XXX_Unmarshal 

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

type NodeExecution_Phase 

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

func (NodeExecution_Phase) EnumDescriptor 

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

func (NodeExecution_Phase) String 

func (x NodeExecution_Phase) String() string

type NodeMetadata 

type NodeMetadata struct {
	// A friendly name for the Node
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The overall timeout of a task.
	Timeout *duration.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of retries per task.
	Retries *RetryStrategy `protobuf:"bytes,5,opt,name=retries,proto3" json:"retries,omitempty"`
	// Identify whether node is interruptible
	//
	// Types that are valid to be assigned to InterruptibleValue:
	//	*NodeMetadata_Interruptible
	InterruptibleValue   isNodeMetadata_InterruptibleValue `protobuf_oneof:"interruptible_value"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

Defines extra information about the Node.

func (*NodeMetadata) Descriptor 

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

func (*NodeMetadata) GetInterruptible 

func (m *NodeMetadata) GetInterruptible() bool

func (*NodeMetadata) GetInterruptibleValue 

func (m *NodeMetadata) GetInterruptibleValue() isNodeMetadata_InterruptibleValue

func (*NodeMetadata) GetName 

func (m *NodeMetadata) GetName() string

func (*NodeMetadata) GetRetries 

func (m *NodeMetadata) GetRetries() *RetryStrategy

func (*NodeMetadata) GetTimeout 

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

func (*NodeMetadata) ProtoMessage 

func (*NodeMetadata) ProtoMessage()

func (*NodeMetadata) Reset 

func (m *NodeMetadata) Reset()

func (*NodeMetadata) String 

func (m *NodeMetadata) String() string

func (*NodeMetadata) XXX_DiscardUnknown 

func (m *NodeMetadata) XXX_DiscardUnknown()

func (*NodeMetadata) XXX_Marshal 

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

func (*NodeMetadata) XXX_Merge 

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

func (*NodeMetadata) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*NodeMetadata) XXX_Size 

func (m *NodeMetadata) XXX_Size() int

func (*NodeMetadata) XXX_Unmarshal 

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

type NodeMetadata_Interruptible 

type NodeMetadata_Interruptible struct {
	Interruptible bool `protobuf:"varint,6,opt,name=interruptible,proto3,oneof"`
}

type Node_ArrayNode 

type Node_ArrayNode struct {
	ArrayNode *ArrayNode `protobuf:"bytes,10,opt,name=array_node,json=arrayNode,proto3,oneof"`
}

type Node_BranchNode 

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

type Node_GateNode 

type Node_GateNode struct {
	GateNode *GateNode `protobuf:"bytes,9,opt,name=gate_node,json=gateNode,proto3,oneof"`
}

type Node_TaskNode 

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

type Node_WorkflowNode 

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

type OAuth2Client 

type OAuth2Client struct {
	// client_id is the public id for the client to use. The system will not perform any pre-auth validation that the
	// secret requested matches the client_id indicated here.
	// +required
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// client_secret is a reference to the secret used to authenticate the OAuth2 client.
	// +required
	ClientSecret         *Secret  `protobuf:"bytes,2,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OAuth2Client encapsulates OAuth2 Client Credentials to be used when making calls on behalf of that task.

func (*OAuth2Client) Descriptor 

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

func (*OAuth2Client) GetClientId 

func (m *OAuth2Client) GetClientId() string

func (*OAuth2Client) GetClientSecret 

func (m *OAuth2Client) GetClientSecret() *Secret

func (*OAuth2Client) ProtoMessage 

func (*OAuth2Client) ProtoMessage()

func (*OAuth2Client) Reset 

func (m *OAuth2Client) Reset()

func (*OAuth2Client) String 

func (m *OAuth2Client) String() string

func (*OAuth2Client) XXX_DiscardUnknown 

func (m *OAuth2Client) XXX_DiscardUnknown()

func (*OAuth2Client) XXX_Marshal 

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

func (*OAuth2Client) XXX_Merge 

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

func (*OAuth2Client) XXX_Size 

func (m *OAuth2Client) XXX_Size() int

func (*OAuth2Client) XXX_Unmarshal 

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

type OAuth2TokenRequest 

type OAuth2TokenRequest struct {
	// name indicates a unique id for the token request within this task token requests. It'll be used as a suffix for
	// environment variables and as a filename for mounting tokens as files.
	// +required
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// type indicates the type of the request to make. Defaults to CLIENT_CREDENTIALS.
	// +required
	Type OAuth2TokenRequest_Type `protobuf:"varint,2,opt,name=type,proto3,enum=flyteidl.core.OAuth2TokenRequest_Type" json:"type,omitempty"`
	// client references the client_id/secret to use to request the OAuth2 token.
	// +required
	Client *OAuth2Client `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	// idp_discovery_endpoint references the discovery endpoint used to retrieve token endpoint and other related
	// information.
	// +optional
	IdpDiscoveryEndpoint string `protobuf:"bytes,4,opt,name=idp_discovery_endpoint,json=idpDiscoveryEndpoint,proto3" json:"idp_discovery_endpoint,omitempty"`
	// token_endpoint references the token issuance endpoint. If idp_discovery_endpoint is not provided, this parameter is
	// mandatory.
	// +optional
	TokenEndpoint        string   `protobuf:"bytes,5,opt,name=token_endpoint,json=tokenEndpoint,proto3" json:"token_endpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

OAuth2TokenRequest encapsulates information needed to request an OAuth2 token. FLYTE_TOKENS_ENV_PREFIX will be passed to indicate the prefix of the environment variables that will be present if tokens are passed through environment variables. FLYTE_TOKENS_PATH_PREFIX will be passed to indicate the prefix of the path where secrets will be mounted if tokens are passed through file mounts.

func (*OAuth2TokenRequest) Descriptor 

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

func (*OAuth2TokenRequest) GetClient 

func (m *OAuth2TokenRequest) GetClient() *OAuth2Client

func (*OAuth2TokenRequest) GetIdpDiscoveryEndpoint 

func (m *OAuth2TokenRequest) GetIdpDiscoveryEndpoint() string

func (*OAuth2TokenRequest) GetName 

func (m *OAuth2TokenRequest) GetName() string

func (*OAuth2TokenRequest) GetTokenEndpoint 

func (m *OAuth2TokenRequest) GetTokenEndpoint() string

func (*OAuth2TokenRequest) GetType 

func (m *OAuth2TokenRequest) GetType() OAuth2TokenRequest_Type

func (*OAuth2TokenRequest) ProtoMessage 

func (*OAuth2TokenRequest) ProtoMessage()

func (*OAuth2TokenRequest) Reset 

func (m *OAuth2TokenRequest) Reset()

func (*OAuth2TokenRequest) String 

func (m *OAuth2TokenRequest) String() string

func (*OAuth2TokenRequest) XXX_DiscardUnknown 

func (m *OAuth2TokenRequest) XXX_DiscardUnknown()

func (*OAuth2TokenRequest) XXX_Marshal 

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

func (*OAuth2TokenRequest) XXX_Merge 

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

func (*OAuth2TokenRequest) XXX_Size 

func (m *OAuth2TokenRequest) XXX_Size() int

func (*OAuth2TokenRequest) XXX_Unmarshal 

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

type OAuth2TokenRequest_Type 

type OAuth2TokenRequest_Type int32

Type of the token requested. 

const (
	// CLIENT_CREDENTIALS indicates a 2-legged OAuth token requested using client credentials.
	OAuth2TokenRequest_CLIENT_CREDENTIALS OAuth2TokenRequest_Type = 0
)

func (OAuth2TokenRequest_Type) EnumDescriptor 

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

func (OAuth2TokenRequest_Type) String 

func (x OAuth2TokenRequest_Type) String() string

type Operand 

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

Defines an operand to a comparison expression.

func (*Operand) Descriptor 

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

func (*Operand) GetPrimitive deprecated 

func (m *Operand) GetPrimitive() *Primitive

Deprecated: Do not use.

func (*Operand) GetScalar 

func (m *Operand) GetScalar() *Scalar

func (*Operand) GetVal 

func (m *Operand) GetVal() isOperand_Val

func (*Operand) GetVar 

func (m *Operand) GetVar() string

func (*Operand) ProtoMessage 

func (*Operand) ProtoMessage()

func (*Operand) Reset 

func (m *Operand) Reset()

func (*Operand) String 

func (m *Operand) String() string

func (*Operand) XXX_DiscardUnknown 

func (m *Operand) XXX_DiscardUnknown()

func (*Operand) XXX_Marshal 

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

func (*Operand) XXX_Merge 

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

func (*Operand) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Operand) XXX_Size 

func (m *Operand) XXX_Size() int

func (*Operand) XXX_Unmarshal 

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

type Operand_Primitive 

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

type Operand_Scalar 

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

type Operand_Var 

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

type OutputReference 

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

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

func (*OutputReference) Descriptor 

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

func (*OutputReference) GetAttrPath 

func (m *OutputReference) GetAttrPath() []*PromiseAttribute

func (*OutputReference) GetNodeId 

func (m *OutputReference) GetNodeId() string

func (*OutputReference) GetVar 

func (m *OutputReference) GetVar() string

func (*OutputReference) ProtoMessage 

func (*OutputReference) ProtoMessage()

func (*OutputReference) Reset 

func (m *OutputReference) Reset()

func (*OutputReference) String 

func (m *OutputReference) String() string

func (*OutputReference) XXX_DiscardUnknown 

func (m *OutputReference) XXX_DiscardUnknown()

func (*OutputReference) XXX_Marshal 

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

func (*OutputReference) XXX_Merge 

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

func (*OutputReference) XXX_Size 

func (m *OutputReference) XXX_Size() int

func (*OutputReference) XXX_Unmarshal 

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

type Parameter 

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

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

func (*Parameter) Descriptor 

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

func (*Parameter) GetArtifactId added in v1.10.7 

func (m *Parameter) GetArtifactId() *ArtifactID

func (*Parameter) GetArtifactQuery added in v1.10.7 

func (m *Parameter) GetArtifactQuery() *ArtifactQuery

func (*Parameter) GetBehavior 

func (m *Parameter) GetBehavior() isParameter_Behavior

func (*Parameter) GetDefault 

func (m *Parameter) GetDefault() *Literal

func (*Parameter) GetRequired 

func (m *Parameter) GetRequired() bool

func (*Parameter) GetVar 

func (m *Parameter) GetVar() *Variable

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

func (*Parameter) XXX_DiscardUnknown 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal 

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

func (*Parameter) XXX_Merge 

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

func (*Parameter) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Parameter) XXX_Size 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal 

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

type ParameterMap 

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

A map of Parameters.

func (*ParameterMap) Descriptor 

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

func (*ParameterMap) GetParameters 

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

func (*ParameterMap) ProtoMessage 

func (*ParameterMap) ProtoMessage()

func (*ParameterMap) Reset 

func (m *ParameterMap) Reset()

func (*ParameterMap) String 

func (m *ParameterMap) String() string

func (*ParameterMap) XXX_DiscardUnknown 

func (m *ParameterMap) XXX_DiscardUnknown()

func (*ParameterMap) XXX_Marshal 

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

func (*ParameterMap) XXX_Merge 

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

func (*ParameterMap) XXX_Size 

func (m *ParameterMap) XXX_Size() int

func (*ParameterMap) XXX_Unmarshal 

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

type Parameter_ArtifactId added in v1.10.7 

type Parameter_ArtifactId struct {
	ArtifactId *ArtifactID `protobuf:"bytes,5,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}

type Parameter_ArtifactQuery added in v1.10.7 

type Parameter_ArtifactQuery struct {
	ArtifactQuery *ArtifactQuery `protobuf:"bytes,4,opt,name=artifact_query,json=artifactQuery,proto3,oneof"`
}

type Parameter_Default 

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

type Parameter_Required 

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

type Partitions added in v1.10.7 

type Partitions struct {
	Value                map[string]*LabelValue `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Partitions) Descriptor added in v1.10.7 

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

func (*Partitions) GetValue added in v1.10.7 

func (m *Partitions) GetValue() map[string]*LabelValue

func (*Partitions) ProtoMessage added in v1.10.7 

func (*Partitions) ProtoMessage()

func (*Partitions) Reset added in v1.10.7 

func (m *Partitions) Reset()

func (*Partitions) String added in v1.10.7 

func (m *Partitions) String() string

func (*Partitions) XXX_DiscardUnknown 

func (m *Partitions) XXX_DiscardUnknown()

func (*Partitions) XXX_Marshal 

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

func (*Partitions) XXX_Merge 

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

func (*Partitions) XXX_Size 

func (m *Partitions) XXX_Size() int

func (*Partitions) XXX_Unmarshal 

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

type Primitive 

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

Primitive Types

func (*Primitive) Descriptor 

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

func (*Primitive) GetBoolean 

func (m *Primitive) GetBoolean() bool

func (*Primitive) GetDatetime 

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

func (*Primitive) GetDuration 

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

func (*Primitive) GetFloatValue 

func (m *Primitive) GetFloatValue() float64

func (*Primitive) GetInteger 

func (m *Primitive) GetInteger() int64

func (*Primitive) GetStringValue 

func (m *Primitive) GetStringValue() string

func (*Primitive) GetValue 

func (m *Primitive) GetValue() isPrimitive_Value

func (*Primitive) ProtoMessage 

func (*Primitive) ProtoMessage()

func (*Primitive) Reset 

func (m *Primitive) Reset()

func (*Primitive) String 

func (m *Primitive) String() string

func (*Primitive) XXX_DiscardUnknown 

func (m *Primitive) XXX_DiscardUnknown()

func (*Primitive) XXX_Marshal 

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

func (*Primitive) XXX_Merge 

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

func (*Primitive) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Primitive) XXX_Size 

func (m *Primitive) XXX_Size() int

func (*Primitive) XXX_Unmarshal 

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

type Primitive_Boolean 

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

type Primitive_Datetime 

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

type Primitive_Duration 

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

type Primitive_FloatValue 

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

type Primitive_Integer 

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

type Primitive_StringValue 

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

type PromiseAttribute 

type PromiseAttribute struct {
	// Types that are valid to be assigned to Value:
	//	*PromiseAttribute_StringValue
	//	*PromiseAttribute_IntValue
	Value                isPromiseAttribute_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*PromiseAttribute) Descriptor 

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

func (*PromiseAttribute) GetIntValue 

func (m *PromiseAttribute) GetIntValue() int32

func (*PromiseAttribute) GetStringValue 

func (m *PromiseAttribute) GetStringValue() string

func (*PromiseAttribute) GetValue 

func (m *PromiseAttribute) GetValue() isPromiseAttribute_Value

func (*PromiseAttribute) ProtoMessage 

func (*PromiseAttribute) ProtoMessage()

func (*PromiseAttribute) Reset 

func (m *PromiseAttribute) Reset()

func (*PromiseAttribute) String 

func (m *PromiseAttribute) String() string

func (*PromiseAttribute) XXX_DiscardUnknown 

func (m *PromiseAttribute) XXX_DiscardUnknown()

func (*PromiseAttribute) XXX_Marshal 

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

func (*PromiseAttribute) XXX_Merge 

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

func (*PromiseAttribute) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PromiseAttribute) XXX_Size 

func (m *PromiseAttribute) XXX_Size() int

func (*PromiseAttribute) XXX_Unmarshal 

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

type PromiseAttribute_IntValue 

type PromiseAttribute_IntValue struct {
	IntValue int32 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type PromiseAttribute_StringValue 

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

type QualityOfService 

type QualityOfService struct {
	// Types that are valid to be assigned to Designation:
	//	*QualityOfService_Tier_
	//	*QualityOfService_Spec
	Designation          isQualityOfService_Designation `protobuf_oneof:"designation"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

Indicates the priority of an execution.

func (*QualityOfService) Descriptor 

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

func (*QualityOfService) GetDesignation 

func (m *QualityOfService) GetDesignation() isQualityOfService_Designation

func (*QualityOfService) GetSpec 

func (m *QualityOfService) GetSpec() *QualityOfServiceSpec

func (*QualityOfService) GetTier 

func (m *QualityOfService) GetTier() QualityOfService_Tier

func (*QualityOfService) ProtoMessage 

func (*QualityOfService) ProtoMessage()

func (*QualityOfService) Reset 

func (m *QualityOfService) Reset()

func (*QualityOfService) String 

func (m *QualityOfService) String() string

func (*QualityOfService) XXX_DiscardUnknown 

func (m *QualityOfService) XXX_DiscardUnknown()

func (*QualityOfService) XXX_Marshal 

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

func (*QualityOfService) XXX_Merge 

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

func (*QualityOfService) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*QualityOfService) XXX_Size 

func (m *QualityOfService) XXX_Size() int

func (*QualityOfService) XXX_Unmarshal 

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

type QualityOfServiceSpec 

type QualityOfServiceSpec struct {
	// Indicates how much queueing delay an execution can tolerate.
	QueueingBudget       *duration.Duration `protobuf:"bytes,1,opt,name=queueing_budget,json=queueingBudget,proto3" json:"queueing_budget,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Represents customized execution run-time attributes.

func (*QualityOfServiceSpec) Descriptor 

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

func (*QualityOfServiceSpec) GetQueueingBudget 

func (m *QualityOfServiceSpec) GetQueueingBudget() *duration.Duration

func (*QualityOfServiceSpec) ProtoMessage 

func (*QualityOfServiceSpec) ProtoMessage()

func (*QualityOfServiceSpec) Reset 

func (m *QualityOfServiceSpec) Reset()

func (*QualityOfServiceSpec) String 

func (m *QualityOfServiceSpec) String() string

func (*QualityOfServiceSpec) XXX_DiscardUnknown 

func (m *QualityOfServiceSpec) XXX_DiscardUnknown()

func (*QualityOfServiceSpec) XXX_Marshal 

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

func (*QualityOfServiceSpec) XXX_Merge 

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

func (*QualityOfServiceSpec) XXX_Size 

func (m *QualityOfServiceSpec) XXX_Size() int

func (*QualityOfServiceSpec) XXX_Unmarshal 

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

type QualityOfService_Spec 

type QualityOfService_Spec struct {
	Spec *QualityOfServiceSpec `protobuf:"bytes,2,opt,name=spec,proto3,oneof"`
}

type QualityOfService_Tier 

type QualityOfService_Tier int32
const (
	// Default: no quality of service specified.
	QualityOfService_UNDEFINED QualityOfService_Tier = 0
	QualityOfService_HIGH      QualityOfService_Tier = 1
	QualityOfService_MEDIUM    QualityOfService_Tier = 2
	QualityOfService_LOW       QualityOfService_Tier = 3
)

func (QualityOfService_Tier) EnumDescriptor 

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

func (QualityOfService_Tier) String 

func (x QualityOfService_Tier) String() string

type QualityOfService_Tier_ 

type QualityOfService_Tier_ struct {
	Tier QualityOfService_Tier `protobuf:"varint,1,opt,name=tier,proto3,enum=flyteidl.core.QualityOfService_Tier,oneof"`
}

type ResourceType 

type ResourceType int32

Indicates a resource type within Flyte. 

const (
	ResourceType_UNSPECIFIED ResourceType = 0
	ResourceType_TASK        ResourceType = 1
	ResourceType_WORKFLOW    ResourceType = 2
	ResourceType_LAUNCH_PLAN ResourceType = 3
	// A dataset represents an entity modeled in Flyte DataCatalog. A Dataset is also a versioned entity and can be a compilation of multiple individual objects.
	// Eventually all Catalog objects should be modeled similar to Flyte Objects. The Dataset entities makes it possible for the UI  and CLI to act on the objects
	// in a similar manner to other Flyte objects
	ResourceType_DATASET ResourceType = 4
)

func (ResourceType) EnumDescriptor 

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

func (ResourceType) String 

func (x ResourceType) String() string

type Resources 

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

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

func (*Resources) Descriptor 

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

func (*Resources) GetLimits 

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

func (*Resources) GetRequests 

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

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) Reset 

func (m *Resources) Reset()

func (*Resources) String 

func (m *Resources) String() string

func (*Resources) XXX_DiscardUnknown 

func (m *Resources) XXX_DiscardUnknown()

func (*Resources) XXX_Marshal 

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

func (*Resources) XXX_Merge 

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

func (*Resources) XXX_Size 

func (m *Resources) XXX_Size() int

func (*Resources) XXX_Unmarshal 

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

type Resources_ResourceEntry 

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

Encapsulates a resource name and value.

func (*Resources_ResourceEntry) Descriptor 

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

func (*Resources_ResourceEntry) GetName 

func (m *Resources_ResourceEntry) GetName() Resources_ResourceName

func (*Resources_ResourceEntry) GetValue 

func (m *Resources_ResourceEntry) GetValue() string

func (*Resources_ResourceEntry) ProtoMessage 

func (*Resources_ResourceEntry) ProtoMessage()

func (*Resources_ResourceEntry) Reset 

func (m *Resources_ResourceEntry) Reset()

func (*Resources_ResourceEntry) String 

func (m *Resources_ResourceEntry) String() string

func (*Resources_ResourceEntry) XXX_DiscardUnknown 

func (m *Resources_ResourceEntry) XXX_DiscardUnknown()

func (*Resources_ResourceEntry) XXX_Marshal 

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

func (*Resources_ResourceEntry) XXX_Merge 

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

func (*Resources_ResourceEntry) XXX_Size 

func (m *Resources_ResourceEntry) XXX_Size() int

func (*Resources_ResourceEntry) XXX_Unmarshal 

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

type Resources_ResourceName 

type Resources_ResourceName int32

Known resource names. 

const (
	Resources_UNKNOWN Resources_ResourceName = 0
	Resources_CPU     Resources_ResourceName = 1
	Resources_GPU     Resources_ResourceName = 2
	Resources_MEMORY  Resources_ResourceName = 3
	Resources_STORAGE Resources_ResourceName = 4
	// For Kubernetes-based deployments, pods use ephemeral local storage for scratch space, caching, and for logs.
	Resources_EPHEMERAL_STORAGE Resources_ResourceName = 5
)

func (Resources_ResourceName) EnumDescriptor 

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

func (Resources_ResourceName) String 

func (x Resources_ResourceName) String() string

type RetryStrategy 

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

Retry strategy associated with an executable unit.

func (*RetryStrategy) Descriptor 

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

func (*RetryStrategy) GetRetries 

func (m *RetryStrategy) GetRetries() uint32

func (*RetryStrategy) ProtoMessage 

func (*RetryStrategy) ProtoMessage()

func (*RetryStrategy) Reset 

func (m *RetryStrategy) Reset()

func (*RetryStrategy) String 

func (m *RetryStrategy) String() string

func (*RetryStrategy) XXX_DiscardUnknown 

func (m *RetryStrategy) XXX_DiscardUnknown()

func (*RetryStrategy) XXX_Marshal 

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

func (*RetryStrategy) XXX_Merge 

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

func (*RetryStrategy) XXX_Size 

func (m *RetryStrategy) XXX_Size() int

func (*RetryStrategy) XXX_Unmarshal 

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

type RuntimeMetadata 

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

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

func (*RuntimeMetadata) Descriptor 

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

func (*RuntimeMetadata) GetFlavor 

func (m *RuntimeMetadata) GetFlavor() string

func (*RuntimeMetadata) GetType 

func (m *RuntimeMetadata) GetType() RuntimeMetadata_RuntimeType

func (*RuntimeMetadata) GetVersion 

func (m *RuntimeMetadata) GetVersion() string

func (*RuntimeMetadata) ProtoMessage 

func (*RuntimeMetadata) ProtoMessage()

func (*RuntimeMetadata) Reset 

func (m *RuntimeMetadata) Reset()

func (*RuntimeMetadata) String 

func (m *RuntimeMetadata) String() string

func (*RuntimeMetadata) XXX_DiscardUnknown 

func (m *RuntimeMetadata) XXX_DiscardUnknown()

func (*RuntimeMetadata) XXX_Marshal 

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

func (*RuntimeMetadata) XXX_Merge 

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

func (*RuntimeMetadata) XXX_Size 

func (m *RuntimeMetadata) XXX_Size() int

func (*RuntimeMetadata) XXX_Unmarshal 

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

type RuntimeMetadata_RuntimeType 

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

func (RuntimeMetadata_RuntimeType) EnumDescriptor 

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

func (RuntimeMetadata_RuntimeType) String 

func (x RuntimeMetadata_RuntimeType) String() string

type Scalar 

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

func (*Scalar) Descriptor 

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

func (*Scalar) GetBinary 

func (m *Scalar) GetBinary() *Binary

func (*Scalar) GetBlob 

func (m *Scalar) GetBlob() *Blob

func (*Scalar) GetError 

func (m *Scalar) GetError() *Error

func (*Scalar) GetGeneric 

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

func (*Scalar) GetNoneType 

func (m *Scalar) GetNoneType() *Void

func (*Scalar) GetPrimitive 

func (m *Scalar) GetPrimitive() *Primitive

func (*Scalar) GetSchema 

func (m *Scalar) GetSchema() *Schema

func (*Scalar) GetStructuredDataset 

func (m *Scalar) GetStructuredDataset() *StructuredDataset

func (*Scalar) GetUnion 

func (m *Scalar) GetUnion() *Union

func (*Scalar) GetValue 

func (m *Scalar) GetValue() isScalar_Value

func (*Scalar) ProtoMessage 

func (*Scalar) ProtoMessage()

func (*Scalar) Reset 

func (m *Scalar) Reset()

func (*Scalar) String 

func (m *Scalar) String() string

func (*Scalar) XXX_DiscardUnknown 

func (m *Scalar) XXX_DiscardUnknown()

func (*Scalar) XXX_Marshal 

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

func (*Scalar) XXX_Merge 

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

func (*Scalar) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Scalar) XXX_Size 

func (m *Scalar) XXX_Size() int

func (*Scalar) XXX_Unmarshal 

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

type Scalar_Binary 

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

type Scalar_Blob 

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

type Scalar_Error 

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

type Scalar_Generic 

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

type Scalar_NoneType 

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

type Scalar_Primitive 

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

type Scalar_Schema 

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

type Scalar_StructuredDataset 

type Scalar_StructuredDataset struct {
	StructuredDataset *StructuredDataset `protobuf:"bytes,8,opt,name=structured_dataset,json=structuredDataset,proto3,oneof"`
}

type Scalar_Union 

type Scalar_Union struct {
	Union *Union `protobuf:"bytes,9,opt,name=union,proto3,oneof"`
}

type Schema 

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

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

func (*Schema) Descriptor 

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

func (*Schema) GetType 

func (m *Schema) GetType() *SchemaType

func (*Schema) GetUri 

func (m *Schema) GetUri() string

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) Reset 

func (m *Schema) Reset()

func (*Schema) String 

func (m *Schema) String() string

func (*Schema) XXX_DiscardUnknown 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal 

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

func (*Schema) XXX_Merge 

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

func (*Schema) XXX_Size 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal 

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

type SchemaType 

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

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

func (*SchemaType) Descriptor 

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

func (*SchemaType) GetColumns 

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

func (*SchemaType) ProtoMessage 

func (*SchemaType) ProtoMessage()

func (*SchemaType) Reset 

func (m *SchemaType) Reset()

func (*SchemaType) String 

func (m *SchemaType) String() string

func (*SchemaType) XXX_DiscardUnknown 

func (m *SchemaType) XXX_DiscardUnknown()

func (*SchemaType) XXX_Marshal 

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

func (*SchemaType) XXX_Merge 

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

func (*SchemaType) XXX_Size 

func (m *SchemaType) XXX_Size() int

func (*SchemaType) XXX_Unmarshal 

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

type SchemaType_SchemaColumn 

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

func (*SchemaType_SchemaColumn) Descriptor 

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

func (*SchemaType_SchemaColumn) GetName 

func (m *SchemaType_SchemaColumn) GetName() string

func (*SchemaType_SchemaColumn) GetType 

func (m *SchemaType_SchemaColumn) GetType() SchemaType_SchemaColumn_SchemaColumnType

func (*SchemaType_SchemaColumn) ProtoMessage 

func (*SchemaType_SchemaColumn) ProtoMessage()

func (*SchemaType_SchemaColumn) Reset 

func (m *SchemaType_SchemaColumn) Reset()

func (*SchemaType_SchemaColumn) String 

func (m *SchemaType_SchemaColumn) String() string

func (*SchemaType_SchemaColumn) XXX_DiscardUnknown 

func (m *SchemaType_SchemaColumn) XXX_DiscardUnknown()

func (*SchemaType_SchemaColumn) XXX_Marshal 

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

func (*SchemaType_SchemaColumn) XXX_Merge 

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

func (*SchemaType_SchemaColumn) XXX_Size 

func (m *SchemaType_SchemaColumn) XXX_Size() int

func (*SchemaType_SchemaColumn) XXX_Unmarshal 

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

type SchemaType_SchemaColumn_SchemaColumnType 

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

func (SchemaType_SchemaColumn_SchemaColumnType) EnumDescriptor 

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

func (SchemaType_SchemaColumn_SchemaColumnType) String 

func (x SchemaType_SchemaColumn_SchemaColumnType) String() string

type Secret 

type Secret struct {
	// The name of the secret group where to find the key referenced below. For K8s secrets, this should be the name of
	// the v1/secret object. For Confidant, this should be the Credential name. For Vault, this should be the secret name.
	// For AWS Secret Manager, this should be the name of the secret.
	// +required
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// The group version to fetch. This is not supported in all secret management systems. It'll be ignored for the ones
	// that do not support it.
	// +optional
	GroupVersion string `protobuf:"bytes,2,opt,name=group_version,json=groupVersion,proto3" json:"group_version,omitempty"`
	// The name of the secret to mount. This has to match an existing secret in the system. It's up to the implementation
	// of the secret management system to require case sensitivity. For K8s secrets, Confidant and Vault, this should
	// match one of the keys inside the secret. For AWS Secret Manager, it's ignored.
	// +optional
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// mount_requirement is optional. Indicates where the secret has to be mounted. If provided, the execution will fail
	// if the underlying key management system cannot satisfy that requirement. If not provided, the default location
	// will depend on the key management system.
	// +optional
	MountRequirement     Secret_MountType `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Secret encapsulates information about the secret a task needs to proceed. An environment variable FLYTE_SECRETS_ENV_PREFIX will be passed to indicate the prefix of the environment variables that will be present if secrets are passed through environment variables. FLYTE_SECRETS_DEFAULT_DIR will be passed to indicate the prefix of the path where secrets will be mounted if secrets are passed through file mounts.

func (*Secret) Descriptor 

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

func (*Secret) GetGroup 

func (m *Secret) GetGroup() string

func (*Secret) GetGroupVersion 

func (m *Secret) GetGroupVersion() string

func (*Secret) GetKey 

func (m *Secret) GetKey() string

func (*Secret) GetMountRequirement 

func (m *Secret) GetMountRequirement() Secret_MountType

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) Reset 

func (m *Secret) Reset()

func (*Secret) String 

func (m *Secret) String() string

func (*Secret) XXX_DiscardUnknown 

func (m *Secret) XXX_DiscardUnknown()

func (*Secret) XXX_Marshal 

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

func (*Secret) XXX_Merge 

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

func (*Secret) XXX_Size 

func (m *Secret) XXX_Size() int

func (*Secret) XXX_Unmarshal 

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

type Secret_MountType 

type Secret_MountType int32
const (
	// Default case, indicates the client can tolerate either mounting options.
	Secret_ANY Secret_MountType = 0
	// ENV_VAR indicates the secret needs to be mounted as an environment variable.
	Secret_ENV_VAR Secret_MountType = 1
	// FILE indicates the secret needs to be mounted as a file.
	Secret_FILE Secret_MountType = 2
)

func (Secret_MountType) EnumDescriptor 

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

func (Secret_MountType) String 

func (x Secret_MountType) String() string

type SecurityContext 

type SecurityContext struct {
	// run_as encapsulates the identity a pod should run as. If the task fills in multiple fields here, it'll be up to the
	// backend plugin to choose the appropriate identity for the execution engine the task will run on.
	RunAs *Identity `protobuf:"bytes,1,opt,name=run_as,json=runAs,proto3" json:"run_as,omitempty"`
	// secrets indicate the list of secrets the task needs in order to proceed. Secrets will be mounted/passed to the
	// pod as it starts. If the plugin responsible for kicking of the task will not run it on a flyte cluster (e.g. AWS
	// Batch), it's the responsibility of the plugin to fetch the secret (which means propeller identity will need access
	// to the secret) and to pass it to the remote execution engine.
	Secrets []*Secret `protobuf:"bytes,2,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// tokens indicate the list of token requests the task needs in order to proceed. Tokens will be mounted/passed to the
	// pod as it starts. If the plugin responsible for kicking of the task will not run it on a flyte cluster (e.g. AWS
	// Batch), it's the responsibility of the plugin to fetch the secret (which means propeller identity will need access
	// to the secret) and to pass it to the remote execution engine.
	Tokens               []*OAuth2TokenRequest `protobuf:"bytes,3,rep,name=tokens,proto3" json:"tokens,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

SecurityContext holds security attributes that apply to tasks.

func (*SecurityContext) Descriptor 

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

func (*SecurityContext) GetRunAs 

func (m *SecurityContext) GetRunAs() *Identity

func (*SecurityContext) GetSecrets 

func (m *SecurityContext) GetSecrets() []*Secret

func (*SecurityContext) GetTokens 

func (m *SecurityContext) GetTokens() []*OAuth2TokenRequest

func (*SecurityContext) ProtoMessage 

func (*SecurityContext) ProtoMessage()

func (*SecurityContext) Reset 

func (m *SecurityContext) Reset()

func (*SecurityContext) String 

func (m *SecurityContext) String() string

func (*SecurityContext) XXX_DiscardUnknown 

func (m *SecurityContext) XXX_DiscardUnknown()

func (*SecurityContext) XXX_Marshal 

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

func (*SecurityContext) XXX_Merge 

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

func (*SecurityContext) XXX_Size 

func (m *SecurityContext) XXX_Size() int

func (*SecurityContext) XXX_Unmarshal 

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

type SignalCondition 

type SignalCondition struct {
	// A unique identifier for the requested signal.
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// A type denoting the required value type for this signal.
	Type *LiteralType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// The variable name for the signal value in this nodes outputs.
	OutputVariableName   string   `protobuf:"bytes,3,opt,name=output_variable_name,json=outputVariableName,proto3" json:"output_variable_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SignalCondition represents a dependency on an signal.

func (*SignalCondition) Descriptor 

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

func (*SignalCondition) GetOutputVariableName 

func (m *SignalCondition) GetOutputVariableName() string

func (*SignalCondition) GetSignalId 

func (m *SignalCondition) GetSignalId() string

func (*SignalCondition) GetType 

func (m *SignalCondition) GetType() *LiteralType

func (*SignalCondition) ProtoMessage 

func (*SignalCondition) ProtoMessage()

func (*SignalCondition) Reset 

func (m *SignalCondition) Reset()

func (*SignalCondition) String 

func (m *SignalCondition) String() string

func (*SignalCondition) XXX_DiscardUnknown 

func (m *SignalCondition) XXX_DiscardUnknown()

func (*SignalCondition) XXX_Marshal 

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

func (*SignalCondition) XXX_Merge 

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

func (*SignalCondition) XXX_Size 

func (m *SignalCondition) XXX_Size() int

func (*SignalCondition) XXX_Unmarshal 

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

type SignalIdentifier 

type SignalIdentifier struct {
	// Unique identifier for a signal.
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// Identifies the Flyte workflow execution this signal belongs to.
	ExecutionId          *WorkflowExecutionIdentifier `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

Encapsulation of fields the uniquely identify a signal.

func (*SignalIdentifier) Descriptor 

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

func (*SignalIdentifier) GetExecutionId 

func (m *SignalIdentifier) GetExecutionId() *WorkflowExecutionIdentifier

func (*SignalIdentifier) GetSignalId 

func (m *SignalIdentifier) GetSignalId() string

func (*SignalIdentifier) ProtoMessage 

func (*SignalIdentifier) ProtoMessage()

func (*SignalIdentifier) Reset 

func (m *SignalIdentifier) Reset()

func (*SignalIdentifier) String 

func (m *SignalIdentifier) String() string

func (*SignalIdentifier) XXX_DiscardUnknown 

func (m *SignalIdentifier) XXX_DiscardUnknown()

func (*SignalIdentifier) XXX_Marshal 

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

func (*SignalIdentifier) XXX_Merge 

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

func (*SignalIdentifier) XXX_Size 

func (m *SignalIdentifier) XXX_Size() int

func (*SignalIdentifier) XXX_Unmarshal 

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

type SimpleType 

type SimpleType int32

Define a set of simple types. 

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

func (SimpleType) EnumDescriptor 

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

func (SimpleType) String 

func (x SimpleType) String() string

type SleepCondition 

type SleepCondition struct {
	// The overall duration for this sleep.
	Duration             *duration.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

SleepCondition represents a dependency on waiting for the specified duration.

func (*SleepCondition) Descriptor 

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

func (*SleepCondition) GetDuration 

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

func (*SleepCondition) ProtoMessage 

func (*SleepCondition) ProtoMessage()

func (*SleepCondition) Reset 

func (m *SleepCondition) Reset()

func (*SleepCondition) String 

func (m *SleepCondition) String() string

func (*SleepCondition) XXX_DiscardUnknown 

func (m *SleepCondition) XXX_DiscardUnknown()

func (*SleepCondition) XXX_Marshal 

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

func (*SleepCondition) XXX_Merge 

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

func (*SleepCondition) XXX_Size 

func (m *SleepCondition) XXX_Size() int

func (*SleepCondition) XXX_Unmarshal 

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

type Span 

type Span struct {
	// start_time defines the instance this span began.
	StartTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// end_time defines the instance this span completed.
	EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Types that are valid to be assigned to Id:
	//	*Span_WorkflowId
	//	*Span_NodeId
	//	*Span_TaskId
	//	*Span_OperationId
	Id isSpan_Id `protobuf_oneof:"id"`
	// spans defines a collection of Spans that breakdown this execution.
	Spans                []*Span  `protobuf:"bytes,7,rep,name=spans,proto3" json:"spans,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Span represents a duration trace of Flyte execution. The id field denotes a Flyte execution entity or an operation which uniquely identifies the Span. The spans attribute allows this Span to be further broken down into more precise definitions.

func (*Span) Descriptor 

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

func (*Span) GetEndTime 

func (m *Span) GetEndTime() *timestamp.Timestamp

func (*Span) GetId 

func (m *Span) GetId() isSpan_Id

func (*Span) GetNodeId 

func (m *Span) GetNodeId() *NodeExecutionIdentifier

func (*Span) GetOperationId 

func (m *Span) GetOperationId() string

func (*Span) GetSpans 

func (m *Span) GetSpans() []*Span

func (*Span) GetStartTime 

func (m *Span) GetStartTime() *timestamp.Timestamp

func (*Span) GetTaskId 

func (m *Span) GetTaskId() *TaskExecutionIdentifier

func (*Span) GetWorkflowId 

func (m *Span) GetWorkflowId() *WorkflowExecutionIdentifier

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) Reset 

func (m *Span) Reset()

func (*Span) String 

func (m *Span) String() string

func (*Span) XXX_DiscardUnknown 

func (m *Span) XXX_DiscardUnknown()

func (*Span) XXX_Marshal 

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

func (*Span) XXX_Merge 

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

func (*Span) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Span) XXX_Size 

func (m *Span) XXX_Size() int

func (*Span) XXX_Unmarshal 

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

type Span_NodeId 

type Span_NodeId struct {
	NodeId *NodeExecutionIdentifier `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3,oneof"`
}

type Span_OperationId 

type Span_OperationId struct {
	OperationId string `protobuf:"bytes,6,opt,name=operation_id,json=operationId,proto3,oneof"`
}

type Span_TaskId 

type Span_TaskId struct {
	TaskId *TaskExecutionIdentifier `protobuf:"bytes,5,opt,name=task_id,json=taskId,proto3,oneof"`
}

type Span_WorkflowId 

type Span_WorkflowId struct {
	WorkflowId *WorkflowExecutionIdentifier `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3,oneof"`
}

type Sql 

type Sql struct {
	// The actual query to run, the query can have templated parameters.
	// We use Flyte's Golang templating format for Query templating.
	// Refer to the templating documentation.
	// https://docs.flyte.org/projects/cookbook/en/latest/auto/integrations/external_services/hive/hive.html#sphx-glr-auto-integrations-external-services-hive-hive-py
	// For example,
	// insert overwrite directory '{{ .rawOutputDataPrefix }}' stored as parquet
	// select *
	// from my_table
	// where ds = '{{ .Inputs.ds }}'
	Statement            string      `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
	Dialect              Sql_Dialect `protobuf:"varint,2,opt,name=dialect,proto3,enum=flyteidl.core.Sql_Dialect" json:"dialect,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Sql represents a generic sql workload with a statement and dialect.

func (*Sql) Descriptor 

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

func (*Sql) GetDialect 

func (m *Sql) GetDialect() Sql_Dialect

func (*Sql) GetStatement 

func (m *Sql) GetStatement() string

func (*Sql) ProtoMessage 

func (*Sql) ProtoMessage()

func (*Sql) Reset 

func (m *Sql) Reset()

func (*Sql) String 

func (m *Sql) String() string

func (*Sql) XXX_DiscardUnknown 

func (m *Sql) XXX_DiscardUnknown()

func (*Sql) XXX_Marshal 

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

func (*Sql) XXX_Merge 

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

func (*Sql) XXX_Size 

func (m *Sql) XXX_Size() int

func (*Sql) XXX_Unmarshal 

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

type Sql_Dialect 

type Sql_Dialect int32

The dialect of the SQL statement. This is used to validate and parse SQL statements at compilation time to avoid expensive runtime operations. If set to an unsupported dialect, no validation will be done on the statement. We support the following dialect: ansi, hive. 

const (
	Sql_UNDEFINED Sql_Dialect = 0
	Sql_ANSI      Sql_Dialect = 1
	Sql_HIVE      Sql_Dialect = 2
	Sql_OTHER     Sql_Dialect = 3
)

func (Sql_Dialect) EnumDescriptor 

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

func (Sql_Dialect) String 

func (x Sql_Dialect) String() string

type StructuredDataset 

type StructuredDataset struct {
	// String location uniquely identifying where the data is.
	// Should start with the storage location (e.g. s3://, gs://, bq://, etc.)
	Uri                  string                     `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Metadata             *StructuredDatasetMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*StructuredDataset) Descriptor 

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

func (*StructuredDataset) GetMetadata 

func (m *StructuredDataset) GetMetadata() *StructuredDatasetMetadata

func (*StructuredDataset) GetUri 

func (m *StructuredDataset) GetUri() string

func (*StructuredDataset) ProtoMessage 

func (*StructuredDataset) ProtoMessage()

func (*StructuredDataset) Reset 

func (m *StructuredDataset) Reset()

func (*StructuredDataset) String 

func (m *StructuredDataset) String() string

func (*StructuredDataset) XXX_DiscardUnknown 

func (m *StructuredDataset) XXX_DiscardUnknown()

func (*StructuredDataset) XXX_Marshal 

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

func (*StructuredDataset) XXX_Merge 

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

func (*StructuredDataset) XXX_Size 

func (m *StructuredDataset) XXX_Size() int

func (*StructuredDataset) XXX_Unmarshal 

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

type StructuredDatasetMetadata 

type StructuredDatasetMetadata struct {
	// Bundle the type information along with the literal.
	// This is here because StructuredDatasets can often be more defined at run time than at compile time.
	// That is, at compile time you might only declare a task to return a pandas dataframe or a StructuredDataset,
	// without any column information, but at run time, you might have that column information.
	// flytekit python will copy this type information into the literal, from the type information, if not provided by
	// the various plugins (encoders).
	// Since this field is run time generated, it's not used for any type checking.
	StructuredDatasetType *StructuredDatasetType `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{}               `json:"-"`
	XXX_unrecognized      []byte                 `json:"-"`
	XXX_sizecache         int32                  `json:"-"`
}

func (*StructuredDatasetMetadata) Descriptor 

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

func (*StructuredDatasetMetadata) GetStructuredDatasetType 

func (m *StructuredDatasetMetadata) GetStructuredDatasetType() *StructuredDatasetType

func (*StructuredDatasetMetadata) ProtoMessage 

func (*StructuredDatasetMetadata) ProtoMessage()

func (*StructuredDatasetMetadata) Reset 

func (m *StructuredDatasetMetadata) Reset()

func (*StructuredDatasetMetadata) String 

func (m *StructuredDatasetMetadata) String() string

func (*StructuredDatasetMetadata) XXX_DiscardUnknown 

func (m *StructuredDatasetMetadata) XXX_DiscardUnknown()

func (*StructuredDatasetMetadata) XXX_Marshal 

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

func (*StructuredDatasetMetadata) XXX_Merge 

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

func (*StructuredDatasetMetadata) XXX_Size 

func (m *StructuredDatasetMetadata) XXX_Size() int

func (*StructuredDatasetMetadata) XXX_Unmarshal 

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

type StructuredDatasetType 

type StructuredDatasetType struct {
	// A list of ordered columns this schema comprises of.
	Columns []*StructuredDatasetType_DatasetColumn `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// This is the storage format, the format of the bits at rest
	// parquet, feather, csv, etc.
	// For two types to be compatible, the format will need to be an exact match.
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// This is a string representing the type that the bytes in external_schema_bytes are formatted in.
	// This is an optional field that will not be used for type checking.
	ExternalSchemaType string `protobuf:"bytes,3,opt,name=external_schema_type,json=externalSchemaType,proto3" json:"external_schema_type,omitempty"`
	// The serialized bytes of a third-party schema library like Arrow.
	// This is an optional field that will not be used for type checking.
	ExternalSchemaBytes  []byte   `protobuf:"bytes,4,opt,name=external_schema_bytes,json=externalSchemaBytes,proto3" json:"external_schema_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StructuredDatasetType) Descriptor 

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

func (*StructuredDatasetType) GetColumns 

func (m *StructuredDatasetType) GetColumns() []*StructuredDatasetType_DatasetColumn

func (*StructuredDatasetType) GetExternalSchemaBytes 

func (m *StructuredDatasetType) GetExternalSchemaBytes() []byte

func (*StructuredDatasetType) GetExternalSchemaType 

func (m *StructuredDatasetType) GetExternalSchemaType() string

func (*StructuredDatasetType) GetFormat 

func (m *StructuredDatasetType) GetFormat() string

func (*StructuredDatasetType) ProtoMessage 

func (*StructuredDatasetType) ProtoMessage()

func (*StructuredDatasetType) Reset 

func (m *StructuredDatasetType) Reset()

func (*StructuredDatasetType) String 

func (m *StructuredDatasetType) String() string

func (*StructuredDatasetType) XXX_DiscardUnknown 

func (m *StructuredDatasetType) XXX_DiscardUnknown()

func (*StructuredDatasetType) XXX_Marshal 

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

func (*StructuredDatasetType) XXX_Merge 

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

func (*StructuredDatasetType) XXX_Size 

func (m *StructuredDatasetType) XXX_Size() int

func (*StructuredDatasetType) XXX_Unmarshal 

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

type StructuredDatasetType_DatasetColumn 

type StructuredDatasetType_DatasetColumn struct {
	// A unique name within the schema type for the column.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The column type.
	LiteralType          *LiteralType `protobuf:"bytes,2,opt,name=literal_type,json=literalType,proto3" json:"literal_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StructuredDatasetType_DatasetColumn) Descriptor 

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

func (*StructuredDatasetType_DatasetColumn) GetLiteralType 

func (m *StructuredDatasetType_DatasetColumn) GetLiteralType() *LiteralType

func (*StructuredDatasetType_DatasetColumn) GetName 

func (m *StructuredDatasetType_DatasetColumn) GetName() string

func (*StructuredDatasetType_DatasetColumn) ProtoMessage 

func (*StructuredDatasetType_DatasetColumn) ProtoMessage()

func (*StructuredDatasetType_DatasetColumn) Reset 

func (m *StructuredDatasetType_DatasetColumn) Reset()

func (*StructuredDatasetType_DatasetColumn) String 

func (m *StructuredDatasetType_DatasetColumn) String() string

func (*StructuredDatasetType_DatasetColumn) XXX_DiscardUnknown 

func (m *StructuredDatasetType_DatasetColumn) XXX_DiscardUnknown()

func (*StructuredDatasetType_DatasetColumn) XXX_Marshal 

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

func (*StructuredDatasetType_DatasetColumn) XXX_Merge 

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

func (*StructuredDatasetType_DatasetColumn) XXX_Size 

func (m *StructuredDatasetType_DatasetColumn) XXX_Size() int

func (*StructuredDatasetType_DatasetColumn) XXX_Unmarshal 

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

type TaskExecution 

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

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

func (*TaskExecution) Descriptor 

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

func (*TaskExecution) ProtoMessage 

func (*TaskExecution) ProtoMessage()

func (*TaskExecution) Reset 

func (m *TaskExecution) Reset()

func (*TaskExecution) String 

func (m *TaskExecution) String() string

func (*TaskExecution) XXX_DiscardUnknown 

func (m *TaskExecution) XXX_DiscardUnknown()

func (*TaskExecution) XXX_Marshal 

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

func (*TaskExecution) XXX_Merge 

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

func (*TaskExecution) XXX_Size 

func (m *TaskExecution) XXX_Size() int

func (*TaskExecution) XXX_Unmarshal 

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

type TaskExecutionIdentifier 

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

Encapsulation of fields that identify a Flyte task execution entity.

func (*TaskExecutionIdentifier) Descriptor 

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

func (*TaskExecutionIdentifier) GetNodeExecutionId 

func (m *TaskExecutionIdentifier) GetNodeExecutionId() *NodeExecutionIdentifier

func (*TaskExecutionIdentifier) GetRetryAttempt 

func (m *TaskExecutionIdentifier) GetRetryAttempt() uint32

func (*TaskExecutionIdentifier) GetTaskId 

func (m *TaskExecutionIdentifier) GetTaskId() *Identifier

func (*TaskExecutionIdentifier) ProtoMessage 

func (*TaskExecutionIdentifier) ProtoMessage()

func (*TaskExecutionIdentifier) Reset 

func (m *TaskExecutionIdentifier) Reset()

func (*TaskExecutionIdentifier) String 

func (m *TaskExecutionIdentifier) String() string

func (*TaskExecutionIdentifier) XXX_DiscardUnknown 

func (m *TaskExecutionIdentifier) XXX_DiscardUnknown()

func (*TaskExecutionIdentifier) XXX_Marshal 

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

func (*TaskExecutionIdentifier) XXX_Merge 

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

func (*TaskExecutionIdentifier) XXX_Size 

func (m *TaskExecutionIdentifier) XXX_Size() int

func (*TaskExecutionIdentifier) XXX_Unmarshal 

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

type TaskExecution_Phase 

type TaskExecution_Phase int32
const (
	TaskExecution_UNDEFINED TaskExecution_Phase = 0
	TaskExecution_QUEUED    TaskExecution_Phase = 1
	TaskExecution_RUNNING   TaskExecution_Phase = 2
	TaskExecution_SUCCEEDED TaskExecution_Phase = 3
	TaskExecution_ABORTED   TaskExecution_Phase = 4
	TaskExecution_FAILED    TaskExecution_Phase = 5
	// To indicate cases where task is initializing, like: ErrImagePull, ContainerCreating, PodInitializing
	TaskExecution_INITIALIZING TaskExecution_Phase = 6
	// To address cases, where underlying resource is not available: Backoff error, Resource quota exceeded
	TaskExecution_WAITING_FOR_RESOURCES TaskExecution_Phase = 7
)

func (TaskExecution_Phase) EnumDescriptor 

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

func (TaskExecution_Phase) String 

func (x TaskExecution_Phase) String() string

type TaskLog 

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

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

func (*TaskLog) Descriptor 

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

func (*TaskLog) GetMessageFormat 

func (m *TaskLog) GetMessageFormat() TaskLog_MessageFormat

func (*TaskLog) GetName 

func (m *TaskLog) GetName() string

func (*TaskLog) GetTtl 

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

func (*TaskLog) GetUri 

func (m *TaskLog) GetUri() string

func (*TaskLog) ProtoMessage 

func (*TaskLog) ProtoMessage()

func (*TaskLog) Reset 

func (m *TaskLog) Reset()

func (*TaskLog) String 

func (m *TaskLog) String() string

func (*TaskLog) XXX_DiscardUnknown 

func (m *TaskLog) XXX_DiscardUnknown()

func (*TaskLog) XXX_Marshal 

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

func (*TaskLog) XXX_Merge 

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

func (*TaskLog) XXX_Size 

func (m *TaskLog) XXX_Size() int

func (*TaskLog) XXX_Unmarshal 

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

type TaskLog_MessageFormat 

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

func (TaskLog_MessageFormat) EnumDescriptor 

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

func (TaskLog_MessageFormat) String 

func (x TaskLog_MessageFormat) String() string

type TaskMetadata 

type TaskMetadata struct {
	// Indicates whether the system should attempt to lookup this task's output to avoid duplication of work.
	Discoverable bool `protobuf:"varint,1,opt,name=discoverable,proto3" json:"discoverable,omitempty"`
	// Runtime information about the task.
	Runtime *RuntimeMetadata `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// The overall timeout of a task including user-triggered retries.
	Timeout *duration.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of retries per task.
	Retries *RetryStrategy `protobuf:"bytes,5,opt,name=retries,proto3" json:"retries,omitempty"`
	// Indicates a logical version to apply to this task for the purpose of discovery.
	DiscoveryVersion string `protobuf:"bytes,6,opt,name=discovery_version,json=discoveryVersion,proto3" json:"discovery_version,omitempty"`
	// If set, this indicates that this task is deprecated.  This will enable owners of tasks to notify consumers
	// of the ending of support for a given task.
	DeprecatedErrorMessage string `` /* 129-byte string literal not displayed */
	// Identify whether task is interruptible
	//
	// Types that are valid to be assigned to InterruptibleValue:
	//	*TaskMetadata_Interruptible
	InterruptibleValue isTaskMetadata_InterruptibleValue `protobuf_oneof:"interruptible_value"`
	// Indicates whether the system should attempt to execute discoverable instances in serial to avoid duplicate work
	CacheSerializable bool `protobuf:"varint,9,opt,name=cache_serializable,json=cacheSerializable,proto3" json:"cache_serializable,omitempty"`
	// Indicates whether the task will generate a Deck URI when it finishes executing.
	GeneratesDeck bool `protobuf:"varint,10,opt,name=generates_deck,json=generatesDeck,proto3" json:"generates_deck,omitempty"`
	// Arbitrary tags that allow users and the platform to store small but arbitrary labels
	Tags map[string]string `` /* 150-byte string literal not displayed */
	// pod_template_name is the unique name of a PodTemplate k8s resource to be used as the base configuration if this
	// task creates a k8s Pod. If this value is set, the specified PodTemplate will be used instead of, but applied
	// identically as, the default PodTemplate configured in FlytePropeller.
	PodTemplateName string `protobuf:"bytes,12,opt,name=pod_template_name,json=podTemplateName,proto3" json:"pod_template_name,omitempty"`
	// cache_ignore_input_vars is the input variables that should not be included when calculating hash for cache.
	CacheIgnoreInputVars []string `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Task Metadata

func (*TaskMetadata) Descriptor 

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

func (*TaskMetadata) GetCacheIgnoreInputVars added in v1.10.7 

func (m *TaskMetadata) GetCacheIgnoreInputVars() []string

func (*TaskMetadata) GetCacheSerializable 

func (m *TaskMetadata) GetCacheSerializable() bool

func (*TaskMetadata) GetDeprecatedErrorMessage 

func (m *TaskMetadata) GetDeprecatedErrorMessage() string

func (*TaskMetadata) GetDiscoverable 

func (m *TaskMetadata) GetDiscoverable() bool

func (*TaskMetadata) GetDiscoveryVersion 

func (m *TaskMetadata) GetDiscoveryVersion() string

func (*TaskMetadata) GetGeneratesDeck 

func (m *TaskMetadata) GetGeneratesDeck() bool

func (*TaskMetadata) GetInterruptible 

func (m *TaskMetadata) GetInterruptible() bool

func (*TaskMetadata) GetInterruptibleValue 

func (m *TaskMetadata) GetInterruptibleValue() isTaskMetadata_InterruptibleValue

func (*TaskMetadata) GetPodTemplateName 

func (m *TaskMetadata) GetPodTemplateName() string

func (*TaskMetadata) GetRetries 

func (m *TaskMetadata) GetRetries() *RetryStrategy

func (*TaskMetadata) GetRuntime 

func (m *TaskMetadata) GetRuntime() *RuntimeMetadata

func (*TaskMetadata) GetTags 

func (m *TaskMetadata) GetTags() map[string]string

func (*TaskMetadata) GetTimeout 

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

func (*TaskMetadata) ProtoMessage 

func (*TaskMetadata) ProtoMessage()

func (*TaskMetadata) Reset 

func (m *TaskMetadata) Reset()

func (*TaskMetadata) String 

func (m *TaskMetadata) String() string

func (*TaskMetadata) XXX_DiscardUnknown 

func (m *TaskMetadata) XXX_DiscardUnknown()

func (*TaskMetadata) XXX_Marshal 

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

func (*TaskMetadata) XXX_Merge 

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

func (*TaskMetadata) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TaskMetadata) XXX_Size 

func (m *TaskMetadata) XXX_Size() int

func (*TaskMetadata) XXX_Unmarshal 

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

type TaskMetadata_Interruptible 

type TaskMetadata_Interruptible struct {
	Interruptible bool `protobuf:"varint,8,opt,name=interruptible,proto3,oneof"`
}

type TaskNode 

type TaskNode struct {
	// Types that are valid to be assigned to Reference:
	//	*TaskNode_ReferenceId
	Reference isTaskNode_Reference `protobuf_oneof:"reference"`
	// Optional overrides applied at task execution time.
	Overrides            *TaskNodeOverrides `protobuf:"bytes,2,opt,name=overrides,proto3" json:"overrides,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Refers to the task that the Node is to execute.

func (*TaskNode) Descriptor 

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

func (*TaskNode) GetOverrides 

func (m *TaskNode) GetOverrides() *TaskNodeOverrides

func (*TaskNode) GetReference 

func (m *TaskNode) GetReference() isTaskNode_Reference

func (*TaskNode) GetReferenceId 

func (m *TaskNode) GetReferenceId() *Identifier

func (*TaskNode) ProtoMessage 

func (*TaskNode) ProtoMessage()

func (*TaskNode) Reset 

func (m *TaskNode) Reset()

func (*TaskNode) String 

func (m *TaskNode) String() string

func (*TaskNode) XXX_DiscardUnknown 

func (m *TaskNode) XXX_DiscardUnknown()

func (*TaskNode) XXX_Marshal 

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

func (*TaskNode) XXX_Merge 

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

func (*TaskNode) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TaskNode) XXX_Size 

func (m *TaskNode) XXX_Size() int

func (*TaskNode) XXX_Unmarshal 

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

type TaskNodeOverrides 

type TaskNodeOverrides struct {
	// A customizable interface to convey resources requested for a task container.
	Resources *Resources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
	// Overrides for all non-standard resources, not captured by
	// v1.ResourceRequirements, to allocate to a task.
	ExtendedResources    *ExtendedResources `protobuf:"bytes,2,opt,name=extended_resources,json=extendedResources,proto3" json:"extended_resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Optional task node overrides that will be applied at task execution time.

func (*TaskNodeOverrides) Descriptor 

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

func (*TaskNodeOverrides) GetExtendedResources added in v1.9.20 

func (m *TaskNodeOverrides) GetExtendedResources() *ExtendedResources

func (*TaskNodeOverrides) GetResources 

func (m *TaskNodeOverrides) GetResources() *Resources

func (*TaskNodeOverrides) ProtoMessage 

func (*TaskNodeOverrides) ProtoMessage()

func (*TaskNodeOverrides) Reset 

func (m *TaskNodeOverrides) Reset()

func (*TaskNodeOverrides) String 

func (m *TaskNodeOverrides) String() string

func (*TaskNodeOverrides) XXX_DiscardUnknown 

func (m *TaskNodeOverrides) XXX_DiscardUnknown()

func (*TaskNodeOverrides) XXX_Marshal 

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

func (*TaskNodeOverrides) XXX_Merge 

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

func (*TaskNodeOverrides) XXX_Size 

func (m *TaskNodeOverrides) XXX_Size() int

func (*TaskNodeOverrides) XXX_Unmarshal 

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

type TaskNode_ReferenceId 

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

type TaskTemplate 

type TaskTemplate struct {
	// Auto generated taskId by the system. Task Id uniquely identifies this task globally.
	Id *Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A predefined yet extensible Task type identifier. This can be used to customize any of the components. If no
	// extensions are provided in the system, Flyte will resolve the this task to its TaskCategory and default the
	// implementation registered for the TaskCategory.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Extra metadata about the task.
	Metadata *TaskMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// A strongly typed interface for the task. This enables others to use this task within a workflow and guarantees
	// compile-time validation of the workflow to avoid costly runtime failures.
	Interface *TypedInterface `protobuf:"bytes,4,opt,name=interface,proto3" json:"interface,omitempty"`
	// Custom data about the task. This is extensible to allow various plugins in the system.
	Custom *_struct.Struct `protobuf:"bytes,5,opt,name=custom,proto3" json:"custom,omitempty"`
	// Known target types that the system will guarantee plugins for. Custom SDK plugins are allowed to set these if needed.
	// If no corresponding execution-layer plugins are found, the system will default to handling these using built-in
	// handlers.
	//
	// Types that are valid to be assigned to Target:
	//	*TaskTemplate_Container
	//	*TaskTemplate_K8SPod
	//	*TaskTemplate_Sql
	Target isTaskTemplate_Target `protobuf_oneof:"target"`
	// This can be used to customize task handling at execution time for the same task type.
	TaskTypeVersion int32 `protobuf:"varint,7,opt,name=task_type_version,json=taskTypeVersion,proto3" json:"task_type_version,omitempty"`
	// security_context encapsulates security attributes requested to run this task.
	SecurityContext *SecurityContext `protobuf:"bytes,8,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// Encapsulates all non-standard resources, not captured by
	// v1.ResourceRequirements, to allocate to a task.
	ExtendedResources *ExtendedResources `protobuf:"bytes,9,opt,name=extended_resources,json=extendedResources,proto3" json:"extended_resources,omitempty"`
	// Metadata about the custom defined for this task. This is extensible to allow various plugins in the system
	// to use as required.
	// reserve the field numbers 1 through 15 for very frequently occurring message elements
	Config               map[string]string `` /* 154-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*TaskTemplate) Descriptor 

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

func (*TaskTemplate) GetConfig 

func (m *TaskTemplate) GetConfig() map[string]string

func (*TaskTemplate) GetContainer 

func (m *TaskTemplate) GetContainer() *Container

func (*TaskTemplate) GetCustom 

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

func (*TaskTemplate) GetExtendedResources added in v1.9.20 

func (m *TaskTemplate) GetExtendedResources() *ExtendedResources

func (*TaskTemplate) GetId 

func (m *TaskTemplate) GetId() *Identifier

func (*TaskTemplate) GetInterface 

func (m *TaskTemplate) GetInterface() *TypedInterface

func (*TaskTemplate) GetK8SPod 

func (m *TaskTemplate) GetK8SPod() *K8SPod

func (*TaskTemplate) GetMetadata 

func (m *TaskTemplate) GetMetadata() *TaskMetadata

func (*TaskTemplate) GetSecurityContext 

func (m *TaskTemplate) GetSecurityContext() *SecurityContext

func (*TaskTemplate) GetSql 

func (m *TaskTemplate) GetSql() *Sql

func (*TaskTemplate) GetTarget 

func (m *TaskTemplate) GetTarget() isTaskTemplate_Target

func (*TaskTemplate) GetTaskTypeVersion 

func (m *TaskTemplate) GetTaskTypeVersion() int32

func (*TaskTemplate) GetType 

func (m *TaskTemplate) GetType() string

func (*TaskTemplate) ProtoMessage 

func (*TaskTemplate) ProtoMessage()

func (*TaskTemplate) Reset 

func (m *TaskTemplate) Reset()

func (*TaskTemplate) String 

func (m *TaskTemplate) String() string

func (*TaskTemplate) XXX_DiscardUnknown 

func (m *TaskTemplate) XXX_DiscardUnknown()

func (*TaskTemplate) XXX_Marshal 

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

func (*TaskTemplate) XXX_Merge 

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

func (*TaskTemplate) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TaskTemplate) XXX_Size 

func (m *TaskTemplate) XXX_Size() int

func (*TaskTemplate) XXX_Unmarshal 

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

type TaskTemplate_Container 

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

type TaskTemplate_K8SPod 

type TaskTemplate_K8SPod struct {
	K8SPod *K8SPod `protobuf:"bytes,17,opt,name=k8s_pod,json=k8sPod,proto3,oneof"`
}

type TaskTemplate_Sql 

type TaskTemplate_Sql struct {
	Sql *Sql `protobuf:"bytes,18,opt,name=sql,proto3,oneof"`
}

type Trigger 

type Trigger struct {
	// This will be set to a launch plan type, but note that this is different than the actual launch plan type.
	TriggerId *Identifier `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// These are partial artifact IDs that will be triggered on
	// Consider making these ArtifactQuery instead.
	Triggers             []*ArtifactID `protobuf:"bytes,2,rep,name=triggers,proto3" json:"triggers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Trigger) Descriptor 

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

func (*Trigger) GetTriggerId 

func (m *Trigger) GetTriggerId() *Identifier

func (*Trigger) GetTriggers 

func (m *Trigger) GetTriggers() []*ArtifactID

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) Reset 

func (m *Trigger) Reset()

func (*Trigger) String 

func (m *Trigger) String() string

func (*Trigger) XXX_DiscardUnknown 

func (m *Trigger) XXX_DiscardUnknown()

func (*Trigger) XXX_Marshal 

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

func (*Trigger) XXX_Merge 

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

func (*Trigger) XXX_Size 

func (m *Trigger) XXX_Size() int

func (*Trigger) XXX_Unmarshal 

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

type TypeAnnotation 

type TypeAnnotation struct {
	// A arbitrary JSON payload to describe a type.
	Annotations          *_struct.Struct `protobuf:"bytes,1,opt,name=annotations,proto3" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

TypeAnnotation encapsulates registration time information about a type. This can be used for various control-plane operations. TypeAnnotation will not be available at runtime when a task runs.

func (*TypeAnnotation) Descriptor 

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

func (*TypeAnnotation) GetAnnotations 

func (m *TypeAnnotation) GetAnnotations() *_struct.Struct

func (*TypeAnnotation) ProtoMessage 

func (*TypeAnnotation) ProtoMessage()

func (*TypeAnnotation) Reset 

func (m *TypeAnnotation) Reset()

func (*TypeAnnotation) String 

func (m *TypeAnnotation) String() string

func (*TypeAnnotation) XXX_DiscardUnknown 

func (m *TypeAnnotation) XXX_DiscardUnknown()

func (*TypeAnnotation) XXX_Marshal 

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

func (*TypeAnnotation) XXX_Merge 

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

func (*TypeAnnotation) XXX_Size 

func (m *TypeAnnotation) XXX_Size() int

func (*TypeAnnotation) XXX_Unmarshal 

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

type TypeStructure 

type TypeStructure struct {
	// Must exactly match for types to be castable
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// dataclass_type only exists for dataclasses.
	// This is used to resolve the type of the fields of dataclass
	// The key is the field name, and the value is the literal type of the field
	// e.g. For dataclass Foo, with fields a, and a is a string
	// Foo.a will be resolved as a literal type of string from dataclass_type
	DataclassType        map[string]*LiteralType `` /* 188-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

Hints to improve type matching e.g. allows distinguishing output from custom type transformers even if the underlying IDL serialization matches.

func (*TypeStructure) Descriptor 

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

func (*TypeStructure) GetDataclassType added in v1.9.33 

func (m *TypeStructure) GetDataclassType() map[string]*LiteralType

func (*TypeStructure) GetTag 

func (m *TypeStructure) GetTag() string

func (*TypeStructure) ProtoMessage 

func (*TypeStructure) ProtoMessage()

func (*TypeStructure) Reset 

func (m *TypeStructure) Reset()

func (*TypeStructure) String 

func (m *TypeStructure) String() string

func (*TypeStructure) XXX_DiscardUnknown 

func (m *TypeStructure) XXX_DiscardUnknown()

func (*TypeStructure) XXX_Marshal 

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

func (*TypeStructure) XXX_Merge 

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

func (*TypeStructure) XXX_Size 

func (m *TypeStructure) XXX_Size() int

func (*TypeStructure) XXX_Unmarshal 

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

type TypedInterface 

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

Defines strongly typed inputs and outputs.

func (*TypedInterface) Descriptor 

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

func (*TypedInterface) GetInputs 

func (m *TypedInterface) GetInputs() *VariableMap

func (*TypedInterface) GetOutputs 

func (m *TypedInterface) GetOutputs() *VariableMap

func (*TypedInterface) ProtoMessage 

func (*TypedInterface) ProtoMessage()

func (*TypedInterface) Reset 

func (m *TypedInterface) Reset()

func (*TypedInterface) String 

func (m *TypedInterface) String() string

func (*TypedInterface) XXX_DiscardUnknown 

func (m *TypedInterface) XXX_DiscardUnknown()

func (*TypedInterface) XXX_Marshal 

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

func (*TypedInterface) XXX_Merge 

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

func (*TypedInterface) XXX_Size 

func (m *TypedInterface) XXX_Size() int

func (*TypedInterface) XXX_Unmarshal 

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

type Union 

type Union struct {
	Value                *Literal     `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Type                 *LiteralType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

The runtime representation of a tagged union value. See `UnionType` for more details.

func (*Union) Descriptor 

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

func (*Union) GetType 

func (m *Union) GetType() *LiteralType

func (*Union) GetValue 

func (m *Union) GetValue() *Literal

func (*Union) ProtoMessage 

func (*Union) ProtoMessage()

func (*Union) Reset 

func (m *Union) Reset()

func (*Union) String 

func (m *Union) String() string

func (*Union) XXX_DiscardUnknown 

func (m *Union) XXX_DiscardUnknown()

func (*Union) XXX_Marshal 

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

func (*Union) XXX_Merge 

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

func (*Union) XXX_Size 

func (m *Union) XXX_Size() int

func (*Union) XXX_Unmarshal 

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

type UnionInfo 

type UnionInfo struct {
	TargetType           *LiteralType `protobuf:"bytes,1,opt,name=targetType,proto3" json:"targetType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*UnionInfo) Descriptor 

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

func (*UnionInfo) GetTargetType 

func (m *UnionInfo) GetTargetType() *LiteralType

func (*UnionInfo) ProtoMessage 

func (*UnionInfo) ProtoMessage()

func (*UnionInfo) Reset 

func (m *UnionInfo) Reset()

func (*UnionInfo) String 

func (m *UnionInfo) String() string

func (*UnionInfo) XXX_DiscardUnknown 

func (m *UnionInfo) XXX_DiscardUnknown()

func (*UnionInfo) XXX_Marshal 

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

func (*UnionInfo) XXX_Merge 

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

func (*UnionInfo) XXX_Size 

func (m *UnionInfo) XXX_Size() int

func (*UnionInfo) XXX_Unmarshal 

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

type UnionType 

type UnionType struct {
	// Predefined set of variants in union.
	Variants             []*LiteralType `protobuf:"bytes,1,rep,name=variants,proto3" json:"variants,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Defines a tagged union type, also known as a variant (and formally as the sum type).

A sum type S is defined by a sequence of types (A, B, C, ...), each tagged by a string tag A value of type S is constructed from a value of any of the variant types. The specific choice of type is recorded by storing the varaint's tag with the literal value and can be examined in runtime.

Type S is typically written as S := Apple A | Banana B | Cantaloupe C | ...

Notably, a nullable (optional) type is a sum type between some type X and the singleton type representing a null-value: Optional X := X | Null

See also: https://en.wikipedia.org/wiki/Tagged_union

func (*UnionType) Descriptor 

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

func (*UnionType) GetVariants 

func (m *UnionType) GetVariants() []*LiteralType

func (*UnionType) ProtoMessage 

func (*UnionType) ProtoMessage()

func (*UnionType) Reset 

func (m *UnionType) Reset()

func (*UnionType) String 

func (m *UnionType) String() string

func (*UnionType) XXX_DiscardUnknown 

func (m *UnionType) XXX_DiscardUnknown()

func (*UnionType) XXX_Marshal 

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

func (*UnionType) XXX_Merge 

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

func (*UnionType) XXX_Size 

func (m *UnionType) XXX_Size() int

func (*UnionType) XXX_Unmarshal 

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

type Variable 

type Variable struct {
	// Variable literal type.
	Type *LiteralType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	//+optional string describing input variable
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	//+optional This object allows the user to specify how Artifacts are created.
	// name, tag, partitions can be specified. The other fields (version and project/domain) are ignored.
	ArtifactPartialId    *ArtifactID  `protobuf:"bytes,3,opt,name=artifact_partial_id,json=artifactPartialId,proto3" json:"artifact_partial_id,omitempty"`
	ArtifactTag          *ArtifactTag `protobuf:"bytes,4,opt,name=artifact_tag,json=artifactTag,proto3" json:"artifact_tag,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Defines a strongly typed variable.

func (*Variable) Descriptor 

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

func (*Variable) GetArtifactPartialId added in v1.10.7 

func (m *Variable) GetArtifactPartialId() *ArtifactID

func (*Variable) GetArtifactTag added in v1.10.7 

func (m *Variable) GetArtifactTag() *ArtifactTag

func (*Variable) GetDescription 

func (m *Variable) GetDescription() string

func (*Variable) GetType 

func (m *Variable) GetType() *LiteralType

func (*Variable) ProtoMessage 

func (*Variable) ProtoMessage()

func (*Variable) Reset 

func (m *Variable) Reset()

func (*Variable) String 

func (m *Variable) String() string

func (*Variable) XXX_DiscardUnknown 

func (m *Variable) XXX_DiscardUnknown()

func (*Variable) XXX_Marshal 

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

func (*Variable) XXX_Merge 

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

func (*Variable) XXX_Size 

func (m *Variable) XXX_Size() int

func (*Variable) XXX_Unmarshal 

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

type VariableMap 

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

A map of Variables

func (*VariableMap) Descriptor 

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

func (*VariableMap) GetVariables 

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

func (*VariableMap) ProtoMessage 

func (*VariableMap) ProtoMessage()

func (*VariableMap) Reset 

func (m *VariableMap) Reset()

func (*VariableMap) String 

func (m *VariableMap) String() string

func (*VariableMap) XXX_DiscardUnknown 

func (m *VariableMap) XXX_DiscardUnknown()

func (*VariableMap) XXX_Marshal 

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

func (*VariableMap) XXX_Merge 

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

func (*VariableMap) XXX_Size 

func (m *VariableMap) XXX_Size() int

func (*VariableMap) XXX_Unmarshal 

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

type Void 

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

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

func (*Void) Descriptor 

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

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) Reset 

func (m *Void) Reset()

func (*Void) String 

func (m *Void) String() string

func (*Void) XXX_DiscardUnknown 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal 

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

func (*Void) XXX_Merge 

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

func (*Void) XXX_Size 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal 

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

type WorkflowClosure 

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

Defines an enclosed package of workflow and tasks it references.

func (*WorkflowClosure) Descriptor 

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

func (*WorkflowClosure) GetTasks 

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

func (*WorkflowClosure) GetWorkflow 

func (m *WorkflowClosure) GetWorkflow() *WorkflowTemplate

func (*WorkflowClosure) ProtoMessage 

func (*WorkflowClosure) ProtoMessage()

func (*WorkflowClosure) Reset 

func (m *WorkflowClosure) Reset()

func (*WorkflowClosure) String 

func (m *WorkflowClosure) String() string

func (*WorkflowClosure) XXX_DiscardUnknown 

func (m *WorkflowClosure) XXX_DiscardUnknown()

func (*WorkflowClosure) XXX_Marshal 

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

func (*WorkflowClosure) XXX_Merge 

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

func (*WorkflowClosure) XXX_Size 

func (m *WorkflowClosure) XXX_Size() int

func (*WorkflowClosure) XXX_Unmarshal 

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

type WorkflowExecution 

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

Indicates various phases of Workflow Execution

func (*WorkflowExecution) Descriptor 

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

func (*WorkflowExecution) ProtoMessage 

func (*WorkflowExecution) ProtoMessage()

func (*WorkflowExecution) Reset 

func (m *WorkflowExecution) Reset()

func (*WorkflowExecution) String 

func (m *WorkflowExecution) String() string

func (*WorkflowExecution) XXX_DiscardUnknown 

func (m *WorkflowExecution) XXX_DiscardUnknown()

func (*WorkflowExecution) XXX_Marshal 

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

func (*WorkflowExecution) XXX_Merge 

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

func (*WorkflowExecution) XXX_Size 

func (m *WorkflowExecution) XXX_Size() int

func (*WorkflowExecution) XXX_Unmarshal 

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

type WorkflowExecutionIdentifier 

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

Encapsulation of fields that uniquely identifies a Flyte workflow execution

func (*WorkflowExecutionIdentifier) Descriptor 

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

func (*WorkflowExecutionIdentifier) GetDomain 

func (m *WorkflowExecutionIdentifier) GetDomain() string

func (*WorkflowExecutionIdentifier) GetName 

func (m *WorkflowExecutionIdentifier) GetName() string

func (*WorkflowExecutionIdentifier) GetOrg added in v1.10.7 

func (m *WorkflowExecutionIdentifier) GetOrg() string

func (*WorkflowExecutionIdentifier) GetProject 

func (m *WorkflowExecutionIdentifier) GetProject() string

func (*WorkflowExecutionIdentifier) ProtoMessage 

func (*WorkflowExecutionIdentifier) ProtoMessage()

func (*WorkflowExecutionIdentifier) Reset 

func (m *WorkflowExecutionIdentifier) Reset()

func (*WorkflowExecutionIdentifier) String 

func (m *WorkflowExecutionIdentifier) String() string

func (*WorkflowExecutionIdentifier) XXX_DiscardUnknown 

func (m *WorkflowExecutionIdentifier) XXX_DiscardUnknown()

func (*WorkflowExecutionIdentifier) XXX_Marshal 

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

func (*WorkflowExecutionIdentifier) XXX_Merge 

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

func (*WorkflowExecutionIdentifier) XXX_Size 

func (m *WorkflowExecutionIdentifier) XXX_Size() int

func (*WorkflowExecutionIdentifier) XXX_Unmarshal 

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

type WorkflowExecution_Phase 

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

func (WorkflowExecution_Phase) EnumDescriptor 

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

func (WorkflowExecution_Phase) String 

func (x WorkflowExecution_Phase) String() string

type WorkflowMetadata 

type WorkflowMetadata struct {
	// Indicates the runtime priority of workflow executions.
	QualityOfService *QualityOfService `protobuf:"bytes,1,opt,name=quality_of_service,json=qualityOfService,proto3" json:"quality_of_service,omitempty"`
	// Defines how the system should behave when a failure is detected in the workflow execution.
	OnFailure WorkflowMetadata_OnFailurePolicy `` /* 141-byte string literal not displayed */
	// Arbitrary tags that allow users and the platform to store small but arbitrary labels
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

This is workflow layer metadata. These settings are only applicable to the workflow as a whole, and do not percolate down to child entities (like tasks) launched by the workflow.

func (*WorkflowMetadata) Descriptor 

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

func (*WorkflowMetadata) GetOnFailure 

func (m *WorkflowMetadata) GetOnFailure() WorkflowMetadata_OnFailurePolicy

func (*WorkflowMetadata) GetQualityOfService 

func (m *WorkflowMetadata) GetQualityOfService() *QualityOfService

func (*WorkflowMetadata) GetTags 

func (m *WorkflowMetadata) GetTags() map[string]string

func (*WorkflowMetadata) ProtoMessage 

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) Reset 

func (m *WorkflowMetadata) Reset()

func (*WorkflowMetadata) String 

func (m *WorkflowMetadata) String() string

func (*WorkflowMetadata) XXX_DiscardUnknown 

func (m *WorkflowMetadata) XXX_DiscardUnknown()

func (*WorkflowMetadata) XXX_Marshal 

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

func (*WorkflowMetadata) XXX_Merge 

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

func (*WorkflowMetadata) XXX_Size 

func (m *WorkflowMetadata) XXX_Size() int

func (*WorkflowMetadata) XXX_Unmarshal 

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

type WorkflowMetadataDefaults 

type WorkflowMetadataDefaults struct {
	// Whether child nodes of the workflow are interruptible.
	Interruptible        bool     `protobuf:"varint,1,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The difference between these settings and the WorkflowMetadata ones is that these are meant to be passed down to a workflow's underlying entities (like tasks). For instance, 'interruptible' has no meaning at the workflow layer, it is only relevant when a task executes. The settings here are the defaults that are passed to all nodes unless explicitly overridden at the node layer. If you are adding a setting that applies to both the Workflow itself, and everything underneath it, it should be added to both this object and the WorkflowMetadata object above.

func (*WorkflowMetadataDefaults) Descriptor 

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

func (*WorkflowMetadataDefaults) GetInterruptible 

func (m *WorkflowMetadataDefaults) GetInterruptible() bool

func (*WorkflowMetadataDefaults) ProtoMessage 

func (*WorkflowMetadataDefaults) ProtoMessage()

func (*WorkflowMetadataDefaults) Reset 

func (m *WorkflowMetadataDefaults) Reset()

func (*WorkflowMetadataDefaults) String 

func (m *WorkflowMetadataDefaults) String() string

func (*WorkflowMetadataDefaults) XXX_DiscardUnknown 

func (m *WorkflowMetadataDefaults) XXX_DiscardUnknown()

func (*WorkflowMetadataDefaults) XXX_Marshal 

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

func (*WorkflowMetadataDefaults) XXX_Merge 

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

func (*WorkflowMetadataDefaults) XXX_Size 

func (m *WorkflowMetadataDefaults) XXX_Size() int

func (*WorkflowMetadataDefaults) XXX_Unmarshal 

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

type WorkflowMetadata_OnFailurePolicy 

type WorkflowMetadata_OnFailurePolicy int32

Failure Handling Strategy 

const (
	// FAIL_IMMEDIATELY instructs the system to fail as soon as a node fails in the workflow. It'll automatically
	// abort all currently running nodes and clean up resources before finally marking the workflow executions as
	// failed.
	WorkflowMetadata_FAIL_IMMEDIATELY WorkflowMetadata_OnFailurePolicy = 0
	// FAIL_AFTER_EXECUTABLE_NODES_COMPLETE instructs the system to make as much progress as it can. The system will
	// not alter the dependencies of the execution graph so any node that depend on the failed node will not be run.
	// Other nodes that will be executed to completion before cleaning up resources and marking the workflow
	// execution as failed.
	WorkflowMetadata_FAIL_AFTER_EXECUTABLE_NODES_COMPLETE WorkflowMetadata_OnFailurePolicy = 1
)

func (WorkflowMetadata_OnFailurePolicy) EnumDescriptor 

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

func (WorkflowMetadata_OnFailurePolicy) String 

func (x WorkflowMetadata_OnFailurePolicy) String() string

type WorkflowNode 

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

Refers to a the workflow the node is to execute.

func (*WorkflowNode) Descriptor 

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

func (*WorkflowNode) GetLaunchplanRef 

func (m *WorkflowNode) GetLaunchplanRef() *Identifier

func (*WorkflowNode) GetReference 

func (m *WorkflowNode) GetReference() isWorkflowNode_Reference

func (*WorkflowNode) GetSubWorkflowRef 

func (m *WorkflowNode) GetSubWorkflowRef() *Identifier

func (*WorkflowNode) ProtoMessage 

func (*WorkflowNode) ProtoMessage()

func (*WorkflowNode) Reset 

func (m *WorkflowNode) Reset()

func (*WorkflowNode) String 

func (m *WorkflowNode) String() string

func (*WorkflowNode) XXX_DiscardUnknown 

func (m *WorkflowNode) XXX_DiscardUnknown()

func (*WorkflowNode) XXX_Marshal 

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

func (*WorkflowNode) XXX_Merge 

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

func (*WorkflowNode) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkflowNode) XXX_Size 

func (m *WorkflowNode) XXX_Size() int

func (*WorkflowNode) XXX_Unmarshal 

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

type WorkflowNode_LaunchplanRef 

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

type WorkflowNode_SubWorkflowRef 

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

type WorkflowTemplate 

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

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

func (*WorkflowTemplate) Descriptor 

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

func (*WorkflowTemplate) GetFailureNode 

func (m *WorkflowTemplate) GetFailureNode() *Node

func (*WorkflowTemplate) GetId 

func (m *WorkflowTemplate) GetId() *Identifier

func (*WorkflowTemplate) GetInterface 

func (m *WorkflowTemplate) GetInterface() *TypedInterface

func (*WorkflowTemplate) GetMetadata 

func (m *WorkflowTemplate) GetMetadata() *WorkflowMetadata

func (*WorkflowTemplate) GetMetadataDefaults 

func (m *WorkflowTemplate) GetMetadataDefaults() *WorkflowMetadataDefaults

func (*WorkflowTemplate) GetNodes 

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

func (*WorkflowTemplate) GetOutputs 

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

func (*WorkflowTemplate) ProtoMessage 

func (*WorkflowTemplate) ProtoMessage()

func (*WorkflowTemplate) Reset 

func (m *WorkflowTemplate) Reset()

func (*WorkflowTemplate) String 

func (m *WorkflowTemplate) String() string

func (*WorkflowTemplate) XXX_DiscardUnknown 

func (m *WorkflowTemplate) XXX_DiscardUnknown()

func (*WorkflowTemplate) XXX_Marshal 

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

func (*WorkflowTemplate) XXX_Merge 

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

func (*WorkflowTemplate) XXX_Size 

func (m *WorkflowTemplate) XXX_Size() int

func (*WorkflowTemplate) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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