admin

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2024 License: Apache-2.0 Imports: 11 Imported by: 80

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	State_name = map[int32]string{
		0: "RETRYABLE_FAILURE",
		1: "PERMANENT_FAILURE",
		2: "PENDING",
		3: "RUNNING",
		4: "SUCCEEDED",
	}
	State_value = map[string]int32{
		"RETRYABLE_FAILURE": 0,
		"PERMANENT_FAILURE": 1,
		"PENDING":           2,
		"RUNNING":           3,
		"SUCCEEDED":         4,
	}
)

Enum value maps for State.

View Source 
var (
	NamedEntityState_name = map[int32]string{
		0: "NAMED_ENTITY_ACTIVE",
		1: "NAMED_ENTITY_ARCHIVED",
		2: "SYSTEM_GENERATED",
	}
	NamedEntityState_value = map[string]int32{
		"NAMED_ENTITY_ACTIVE":   0,
		"NAMED_ENTITY_ARCHIVED": 1,
		"SYSTEM_GENERATED":      2,
	}
)

Enum value maps for NamedEntityState.

View Source 
var (
	Sort_Direction_name = map[int32]string{
		0: "DESCENDING",
		1: "ASCENDING",
	}
	Sort_Direction_value = map[string]int32{
		"DESCENDING": 0,
		"ASCENDING":  1,
	}
)

Enum value maps for Sort_Direction.

View Source 
var (
	DescriptionFormat_name = map[int32]string{
		0: "DESCRIPTION_FORMAT_UNKNOWN",
		1: "DESCRIPTION_FORMAT_MARKDOWN",
		2: "DESCRIPTION_FORMAT_HTML",
		3: "DESCRIPTION_FORMAT_RST",
	}
	DescriptionFormat_value = map[string]int32{
		"DESCRIPTION_FORMAT_UNKNOWN":  0,
		"DESCRIPTION_FORMAT_MARKDOWN": 1,
		"DESCRIPTION_FORMAT_HTML":     2,
		"DESCRIPTION_FORMAT_RST":      3,
	}
)

Enum value maps for DescriptionFormat.

View Source 
var (
	ExecutionState_name = map[int32]string{
		0: "EXECUTION_ACTIVE",
		1: "EXECUTION_ARCHIVED",
	}
	ExecutionState_value = map[string]int32{
		"EXECUTION_ACTIVE":   0,
		"EXECUTION_ARCHIVED": 1,
	}
)

Enum value maps for ExecutionState.

View Source 
var (
	ExecutionMetadata_ExecutionMode_name = map[int32]string{
		0: "MANUAL",
		1: "SCHEDULED",
		2: "SYSTEM",
		3: "RELAUNCH",
		4: "CHILD_WORKFLOW",
		5: "RECOVERED",
		6: "TRIGGER",
	}
	ExecutionMetadata_ExecutionMode_value = map[string]int32{
		"MANUAL":         0,
		"SCHEDULED":      1,
		"SYSTEM":         2,
		"RELAUNCH":       3,
		"CHILD_WORKFLOW": 4,
		"RECOVERED":      5,
		"TRIGGER":        6,
	}
)

Enum value maps for ExecutionMetadata_ExecutionMode.

View Source 
var (
	LaunchPlanState_name = map[int32]string{
		0: "INACTIVE",
		1: "ACTIVE",
	}
	LaunchPlanState_value = map[string]int32{
		"INACTIVE": 0,
		"ACTIVE":   1,
	}
)

Enum value maps for LaunchPlanState.

View Source 
var (
	MatchableResource_name = map[int32]string{
		0: "TASK_RESOURCE",
		1: "CLUSTER_RESOURCE",
		2: "EXECUTION_QUEUE",
		3: "EXECUTION_CLUSTER_LABEL",
		4: "QUALITY_OF_SERVICE_SPECIFICATION",
		5: "PLUGIN_OVERRIDE",
		6: "WORKFLOW_EXECUTION_CONFIG",
		7: "CLUSTER_ASSIGNMENT",
	}
	MatchableResource_value = map[string]int32{
		"TASK_RESOURCE":                    0,
		"CLUSTER_RESOURCE":                 1,
		"EXECUTION_QUEUE":                  2,
		"EXECUTION_CLUSTER_LABEL":          3,
		"QUALITY_OF_SERVICE_SPECIFICATION": 4,
		"PLUGIN_OVERRIDE":                  5,
		"WORKFLOW_EXECUTION_CONFIG":        6,
		"CLUSTER_ASSIGNMENT":               7,
	}
)

Enum value maps for MatchableResource.

View Source 
var (
	PluginOverride_MissingPluginBehavior_name = map[int32]string{
		0: "FAIL",
		1: "USE_DEFAULT",
	}
	PluginOverride_MissingPluginBehavior_value = map[string]int32{
		"FAIL":        0,
		"USE_DEFAULT": 1,
	}
)

Enum value maps for PluginOverride_MissingPluginBehavior.

View Source 
var (
	Project_ProjectState_name = map[int32]string{
		0: "ACTIVE",
		1: "ARCHIVED",
		2: "SYSTEM_GENERATED",
	}
	Project_ProjectState_value = map[string]int32{
		"ACTIVE":           0,
		"ARCHIVED":         1,
		"SYSTEM_GENERATED": 2,
	}
)

Enum value maps for Project_ProjectState.

View Source 
var (
	FixedRateUnit_name = map[int32]string{
		0: "MINUTE",
		1: "HOUR",
		2: "DAY",
	}
	FixedRateUnit_value = map[string]int32{
		"MINUTE": 0,
		"HOUR":   1,
		"DAY":    2,
	}
)

Enum value maps for FixedRateUnit.

View Source 
var File_flyteidl_admin_agent_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_cluster_assignment_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_common_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_description_entity_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_event_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_execution_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_launch_plan_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_matchable_resource_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_node_execution_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_notification_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_project_attributes_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_project_domain_attributes_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_project_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_schedule_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_signal_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_task_execution_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_task_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_version_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_workflow_attributes_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_admin_workflow_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AbortMetadata 

type AbortMetadata struct {

	// In the case of a user-specified abort, this will pass along the user-supplied cause.
	Cause string `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"`
	// Identifies the entity (if any) responsible for terminating the execution
	Principal string `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	// contains filtered or unexported fields
}

Specifies metadata around an aborted workflow execution.

func (*AbortMetadata) Descriptor deprecated 

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

Deprecated: Use AbortMetadata.ProtoReflect.Descriptor instead.

func (*AbortMetadata) GetCause 

func (x *AbortMetadata) GetCause() string

func (*AbortMetadata) GetPrincipal 

func (x *AbortMetadata) GetPrincipal() string

func (*AbortMetadata) ProtoMessage 

func (*AbortMetadata) ProtoMessage()

func (*AbortMetadata) ProtoReflect added in v1.10.7 

func (x *AbortMetadata) ProtoReflect() protoreflect.Message

func (*AbortMetadata) Reset 

func (x *AbortMetadata) Reset()

func (*AbortMetadata) String 

func (x *AbortMetadata) String() string

type ActiveLaunchPlanListRequest 

type ActiveLaunchPlanListRequest struct {

	// Name of the project that contains the identifiers.
	// +required.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the identifiers belongs to within the project.
	// +required.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Indicates the number of resources to be returned.
	// +required.
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// Sort ordering.
	// +optional
	SortBy *Sort `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,6,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to list active launch plans within a project/domain and optional org. See :ref:`ref_flyteidl.admin.LaunchPlan` for more details

func (*ActiveLaunchPlanListRequest) Descriptor deprecated 

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

Deprecated: Use ActiveLaunchPlanListRequest.ProtoReflect.Descriptor instead.

func (*ActiveLaunchPlanListRequest) GetDomain 

func (x *ActiveLaunchPlanListRequest) GetDomain() string

func (*ActiveLaunchPlanListRequest) GetLimit 

func (x *ActiveLaunchPlanListRequest) GetLimit() uint32

func (*ActiveLaunchPlanListRequest) GetOrg added in v1.10.7 

func (x *ActiveLaunchPlanListRequest) GetOrg() string

func (*ActiveLaunchPlanListRequest) GetProject 

func (x *ActiveLaunchPlanListRequest) GetProject() string

func (*ActiveLaunchPlanListRequest) GetSortBy 

func (x *ActiveLaunchPlanListRequest) GetSortBy() *Sort

func (*ActiveLaunchPlanListRequest) GetToken 

func (x *ActiveLaunchPlanListRequest) GetToken() string

func (*ActiveLaunchPlanListRequest) ProtoMessage 

func (*ActiveLaunchPlanListRequest) ProtoMessage()

func (*ActiveLaunchPlanListRequest) ProtoReflect added in v1.10.7 

func (x *ActiveLaunchPlanListRequest) ProtoReflect() protoreflect.Message

func (*ActiveLaunchPlanListRequest) Reset 

func (x *ActiveLaunchPlanListRequest) Reset()

func (*ActiveLaunchPlanListRequest) String 

func (x *ActiveLaunchPlanListRequest) String() string

type ActiveLaunchPlanRequest 

type ActiveLaunchPlanRequest struct {

	// +required.
	Id *NamedEntityIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Represents a request struct for finding an active launch plan for a given NamedEntityIdentifier See :ref:`ref_flyteidl.admin.LaunchPlan` for more details

func (*ActiveLaunchPlanRequest) Descriptor deprecated 

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

Deprecated: Use ActiveLaunchPlanRequest.ProtoReflect.Descriptor instead.

func (*ActiveLaunchPlanRequest) GetId 

func (x *ActiveLaunchPlanRequest) GetId() *NamedEntityIdentifier

func (*ActiveLaunchPlanRequest) ProtoMessage 

func (*ActiveLaunchPlanRequest) ProtoMessage()

func (*ActiveLaunchPlanRequest) ProtoReflect added in v1.10.7 

func (x *ActiveLaunchPlanRequest) ProtoReflect() protoreflect.Message

func (*ActiveLaunchPlanRequest) Reset 

func (x *ActiveLaunchPlanRequest) Reset()

func (*ActiveLaunchPlanRequest) String 

func (x *ActiveLaunchPlanRequest) String() string

type Agent added in v1.10.7 

type Agent struct {

	// Name is the developer-assigned name of the agent.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// SupportedTaskTypes are the types of the tasks that the agent can handle.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.
	SupportedTaskTypes []string `protobuf:"bytes,2,rep,name=supported_task_types,json=supportedTaskTypes,proto3" json:"supported_task_types,omitempty"`
	// IsSync indicates whether this agent is a sync agent. Sync agents are expected to return their
	// results synchronously when called by propeller. Given that sync agents can affect the performance
	// of the system, it's important to enforce strict timeout policies.
	// An Async agent, on the other hand, is required to be able to identify jobs by an
	// identifier and query for job statuses as jobs progress.
	IsSync bool `protobuf:"varint,3,opt,name=is_sync,json=isSync,proto3" json:"is_sync,omitempty"`
	// Supported_task_categories are the categories of the tasks that the agent can handle.
	SupportedTaskCategories []*TaskCategory `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

A message containing the agent metadata.

func (*Agent) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use Agent.ProtoReflect.Descriptor instead.

func (*Agent) GetIsSync added in v1.11.0 

func (x *Agent) GetIsSync() bool

func (*Agent) GetName added in v1.10.7 

func (x *Agent) GetName() string

func (*Agent) GetSupportedTaskCategories added in v1.11.0 

func (x *Agent) GetSupportedTaskCategories() []*TaskCategory

func (*Agent) GetSupportedTaskTypes deprecated added in v1.10.7 

func (x *Agent) GetSupportedTaskTypes() []string

Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.

func (*Agent) ProtoMessage added in v1.10.7 

func (*Agent) ProtoMessage()

func (*Agent) ProtoReflect added in v1.10.7 

func (x *Agent) ProtoReflect() protoreflect.Message

func (*Agent) Reset added in v1.10.7 

func (x *Agent) Reset()

func (*Agent) String added in v1.10.7 

func (x *Agent) String() string

type Annotations 

type Annotations struct {

	// Map of custom annotations to be applied to the execution resource.
	Values map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Annotation values to be applied to an execution resource. In the future a mode (e.g. OVERRIDE, APPEND, etc) can be defined to specify how to merge annotations defined at registration and execution time.

func (*Annotations) Descriptor deprecated 

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

Deprecated: Use Annotations.ProtoReflect.Descriptor instead.

func (*Annotations) GetValues 

func (x *Annotations) GetValues() map[string]string

func (*Annotations) ProtoMessage 

func (*Annotations) ProtoMessage()

func (*Annotations) ProtoReflect added in v1.10.7 

func (x *Annotations) ProtoReflect() protoreflect.Message

func (*Annotations) Reset 

func (x *Annotations) Reset()

func (*Annotations) String 

func (x *Annotations) String() string

type Auth deprecated 

type Auth struct {

	// Defines an optional iam role which will be used for tasks run in executions created with this launch plan.
	AssumableIamRole string `protobuf:"bytes,1,opt,name=assumable_iam_role,json=assumableIamRole,proto3" json:"assumable_iam_role,omitempty"`
	// Defines an optional kubernetes service account which will be used for tasks run in executions created with this launch plan.
	KubernetesServiceAccount string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

Defines permissions associated with executions created by this launch plan spec. Use either of these roles when they have permissions required by your workflow execution. Deprecated.

Deprecated: Marked as deprecated in flyteidl/admin/launch_plan.proto.

func (*Auth) Descriptor deprecated 

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

Deprecated: Use Auth.ProtoReflect.Descriptor instead.

func (*Auth) GetAssumableIamRole 

func (x *Auth) GetAssumableIamRole() string

func (*Auth) GetKubernetesServiceAccount 

func (x *Auth) GetKubernetesServiceAccount() string

func (*Auth) ProtoMessage 

func (*Auth) ProtoMessage()

func (*Auth) ProtoReflect added in v1.10.7 

func (x *Auth) ProtoReflect() protoreflect.Message

func (*Auth) Reset 

func (x *Auth) Reset()

func (*Auth) String 

func (x *Auth) String() string

type AuthRole deprecated 

type AuthRole struct {

	// Defines an optional iam role which will be used for tasks run in executions created with this launch plan.
	AssumableIamRole string `protobuf:"bytes,1,opt,name=assumable_iam_role,json=assumableIamRole,proto3" json:"assumable_iam_role,omitempty"`
	// Defines an optional kubernetes service account which will be used for tasks run in executions created with this launch plan.
	KubernetesServiceAccount string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

Defines permissions associated with executions created by this launch plan spec. Use either of these roles when they have permissions required by your workflow execution. Deprecated.

Deprecated: Marked as deprecated in flyteidl/admin/common.proto.

func (*AuthRole) Descriptor deprecated 

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

Deprecated: Use AuthRole.ProtoReflect.Descriptor instead.

func (*AuthRole) GetAssumableIamRole 

func (x *AuthRole) GetAssumableIamRole() string

func (*AuthRole) GetKubernetesServiceAccount 

func (x *AuthRole) GetKubernetesServiceAccount() string

func (*AuthRole) ProtoMessage 

func (*AuthRole) ProtoMessage()

func (*AuthRole) ProtoReflect added in v1.10.7 

func (x *AuthRole) ProtoReflect() protoreflect.Message

func (*AuthRole) Reset 

func (x *AuthRole) Reset()

func (*AuthRole) String 

func (x *AuthRole) String() string

type ClusterAssignment 

type ClusterAssignment struct {
	ClusterPoolName string `protobuf:"bytes,3,opt,name=cluster_pool_name,json=clusterPoolName,proto3" json:"cluster_pool_name,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates specifications for routing an execution onto a specific cluster.

func (*ClusterAssignment) Descriptor deprecated 

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

Deprecated: Use ClusterAssignment.ProtoReflect.Descriptor instead.

func (*ClusterAssignment) GetClusterPoolName 

func (x *ClusterAssignment) GetClusterPoolName() string

func (*ClusterAssignment) ProtoMessage 

func (*ClusterAssignment) ProtoMessage()

func (*ClusterAssignment) ProtoReflect added in v1.10.7 

func (x *ClusterAssignment) ProtoReflect() protoreflect.Message

func (*ClusterAssignment) Reset 

func (x *ClusterAssignment) Reset()

func (*ClusterAssignment) String 

func (x *ClusterAssignment) String() string

type ClusterResourceAttributes 

type ClusterResourceAttributes struct {

	// Custom resource attributes which will be applied in cluster resource creation (e.g. quotas).
	// Map keys are the *case-sensitive* names of variables in templatized resource files.
	// Map values should be the custom values which get substituted during resource creation.
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClusterResourceAttributes) Descriptor deprecated 

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

Deprecated: Use ClusterResourceAttributes.ProtoReflect.Descriptor instead.

func (*ClusterResourceAttributes) GetAttributes 

func (x *ClusterResourceAttributes) GetAttributes() map[string]string

func (*ClusterResourceAttributes) ProtoMessage 

func (*ClusterResourceAttributes) ProtoMessage()

func (*ClusterResourceAttributes) ProtoReflect added in v1.10.7 

func (x *ClusterResourceAttributes) ProtoReflect() protoreflect.Message

func (*ClusterResourceAttributes) Reset 

func (x *ClusterResourceAttributes) Reset()

func (*ClusterResourceAttributes) String 

func (x *ClusterResourceAttributes) String() string

type CreateRequestHeader added in v1.11.0 

type CreateRequestHeader struct {

	// Template of the task that encapsulates all the metadata of the task.
	Template *core.TaskTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// Prefix for where task output data will be written. (e.g. s3://my-bucket/randomstring)
	OutputPrefix string `protobuf:"bytes,2,opt,name=output_prefix,json=outputPrefix,proto3" json:"output_prefix,omitempty"`
	// subset of runtime task execution metadata.
	TaskExecutionMetadata *TaskExecutionMetadata `` /* 126-byte string literal not displayed */
	// MaxDatasetSizeBytes is the maximum size of the dataset that can be generated by the task.
	MaxDatasetSizeBytes int64 `protobuf:"varint,4,opt,name=max_dataset_size_bytes,json=maxDatasetSizeBytes,proto3" json:"max_dataset_size_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequestHeader) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use CreateRequestHeader.ProtoReflect.Descriptor instead.

func (*CreateRequestHeader) GetMaxDatasetSizeBytes added in v1.11.0 

func (x *CreateRequestHeader) GetMaxDatasetSizeBytes() int64

func (*CreateRequestHeader) GetOutputPrefix added in v1.11.0 

func (x *CreateRequestHeader) GetOutputPrefix() string

func (*CreateRequestHeader) GetTaskExecutionMetadata added in v1.11.0 

func (x *CreateRequestHeader) GetTaskExecutionMetadata() *TaskExecutionMetadata

func (*CreateRequestHeader) GetTemplate added in v1.11.0 

func (x *CreateRequestHeader) GetTemplate() *core.TaskTemplate

func (*CreateRequestHeader) ProtoMessage added in v1.11.0 

func (*CreateRequestHeader) ProtoMessage()

func (*CreateRequestHeader) ProtoReflect added in v1.11.0 

func (x *CreateRequestHeader) ProtoReflect() protoreflect.Message

func (*CreateRequestHeader) Reset added in v1.11.0 

func (x *CreateRequestHeader) Reset()

func (*CreateRequestHeader) String added in v1.11.0 

func (x *CreateRequestHeader) String() string

type CreateTaskRequest 

type CreateTaskRequest struct {

	// The inputs required to start the execution. All required inputs must be
	// included in this map. If not required and not provided, defaults apply.
	// +optional
	Inputs *core.LiteralMap `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Template of the task that encapsulates all the metadata of the task.
	Template *core.TaskTemplate `protobuf:"bytes,2,opt,name=template,proto3" json:"template,omitempty"`
	// Prefix for where task output data will be written. (e.g. s3://my-bucket/randomstring)
	OutputPrefix string `protobuf:"bytes,3,opt,name=output_prefix,json=outputPrefix,proto3" json:"output_prefix,omitempty"`
	// subset of runtime task execution metadata.
	TaskExecutionMetadata *TaskExecutionMetadata `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represents a request structure to create task.

func (*CreateTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetInputs 

func (x *CreateTaskRequest) GetInputs() *core.LiteralMap

func (*CreateTaskRequest) GetOutputPrefix 

func (x *CreateTaskRequest) GetOutputPrefix() string

func (*CreateTaskRequest) GetTaskExecutionMetadata 

func (x *CreateTaskRequest) GetTaskExecutionMetadata() *TaskExecutionMetadata

func (*CreateTaskRequest) GetTemplate 

func (x *CreateTaskRequest) GetTemplate() *core.TaskTemplate

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect added in v1.10.7 

func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message

func (*CreateTaskRequest) Reset 

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (x *CreateTaskRequest) String() string

type CreateTaskResponse 

type CreateTaskResponse struct {

	// ResourceMeta is created by the agent. It could be a string (jobId) or a dict (more complex metadata).
	ResourceMeta []byte `protobuf:"bytes,1,opt,name=resource_meta,json=resourceMeta,proto3" json:"resource_meta,omitempty"`
	// contains filtered or unexported fields
}

Represents a create response structure.

func (*CreateTaskResponse) Descriptor deprecated 

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

Deprecated: Use CreateTaskResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskResponse) GetResourceMeta 

func (x *CreateTaskResponse) GetResourceMeta() []byte

func (*CreateTaskResponse) ProtoMessage 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) ProtoReflect added in v1.10.7 

func (x *CreateTaskResponse) ProtoReflect() protoreflect.Message

func (*CreateTaskResponse) Reset 

func (x *CreateTaskResponse) Reset()

func (*CreateTaskResponse) String 

func (x *CreateTaskResponse) String() string

type CreateWorkflowFailureReason 

type CreateWorkflowFailureReason struct {

	// Types that are assignable to Reason:
	//
	//	*CreateWorkflowFailureReason_ExistsDifferentStructure
	//	*CreateWorkflowFailureReason_ExistsIdenticalStructure
	Reason isCreateWorkflowFailureReason_Reason `protobuf_oneof:"reason"`
	// contains filtered or unexported fields
}

When a CreateWorkflowRequest fails due to matching id

func (*CreateWorkflowFailureReason) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowFailureReason.ProtoReflect.Descriptor instead.

func (*CreateWorkflowFailureReason) GetExistsDifferentStructure 

func (x *CreateWorkflowFailureReason) GetExistsDifferentStructure() *WorkflowErrorExistsDifferentStructure

func (*CreateWorkflowFailureReason) GetExistsIdenticalStructure 

func (x *CreateWorkflowFailureReason) GetExistsIdenticalStructure() *WorkflowErrorExistsIdenticalStructure

func (*CreateWorkflowFailureReason) GetReason 

func (m *CreateWorkflowFailureReason) GetReason() isCreateWorkflowFailureReason_Reason

func (*CreateWorkflowFailureReason) ProtoMessage 

func (*CreateWorkflowFailureReason) ProtoMessage()

func (*CreateWorkflowFailureReason) ProtoReflect added in v1.10.7 

func (x *CreateWorkflowFailureReason) ProtoReflect() protoreflect.Message

func (*CreateWorkflowFailureReason) Reset 

func (x *CreateWorkflowFailureReason) Reset()

func (*CreateWorkflowFailureReason) String 

func (x *CreateWorkflowFailureReason) String() string

type CreateWorkflowFailureReason_ExistsDifferentStructure 

type CreateWorkflowFailureReason_ExistsDifferentStructure struct {
	ExistsDifferentStructure *WorkflowErrorExistsDifferentStructure `protobuf:"bytes,1,opt,name=exists_different_structure,json=existsDifferentStructure,proto3,oneof"`
}

type CreateWorkflowFailureReason_ExistsIdenticalStructure 

type CreateWorkflowFailureReason_ExistsIdenticalStructure struct {
	ExistsIdenticalStructure *WorkflowErrorExistsIdenticalStructure `protobuf:"bytes,2,opt,name=exists_identical_structure,json=existsIdenticalStructure,proto3,oneof"`
}

type CronSchedule 

type CronSchedule struct {

	// Standard/default cron implementation as described by https://en.wikipedia.org/wiki/Cron#CRON_expression;
	// Also supports nonstandard predefined scheduling definitions
	// as described by https://docs.aws.amazon.com/AmazonCloudWatch/latest/events/ScheduledEvents.html#CronExpressions
	// except @reboot
	Schedule string `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// ISO 8601 duration as described by https://en.wikipedia.org/wiki/ISO_8601#Durations
	Offset string `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

Options for schedules to run according to a cron expression.

func (*CronSchedule) Descriptor deprecated 

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

Deprecated: Use CronSchedule.ProtoReflect.Descriptor instead.

func (*CronSchedule) GetOffset 

func (x *CronSchedule) GetOffset() string

func (*CronSchedule) GetSchedule 

func (x *CronSchedule) GetSchedule() string

func (*CronSchedule) ProtoMessage 

func (*CronSchedule) ProtoMessage()

func (*CronSchedule) ProtoReflect added in v1.10.7 

func (x *CronSchedule) ProtoReflect() protoreflect.Message

func (*CronSchedule) Reset 

func (x *CronSchedule) Reset()

func (*CronSchedule) String 

func (x *CronSchedule) String() string

type DeleteTaskRequest 

type DeleteTaskRequest struct {

	// A predefined yet extensible Task type identifier.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// Metadata about the resource to be pass to the agent.
	ResourceMeta []byte `protobuf:"bytes,2,opt,name=resource_meta,json=resourceMeta,proto3" json:"resource_meta,omitempty"`
	// A predefined yet extensible Task type identifier.
	TaskCategory *TaskCategory `protobuf:"bytes,3,opt,name=task_category,json=taskCategory,proto3" json:"task_category,omitempty"`
	// contains filtered or unexported fields
}

A message used to delete a task.

func (*DeleteTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetResourceMeta 

func (x *DeleteTaskRequest) GetResourceMeta() []byte

func (*DeleteTaskRequest) GetTaskCategory added in v1.11.0 

func (x *DeleteTaskRequest) GetTaskCategory() *TaskCategory

func (*DeleteTaskRequest) GetTaskType deprecated 

func (x *DeleteTaskRequest) GetTaskType() string

Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect added in v1.10.7 

func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

type DeleteTaskResponse 

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

Response to delete a task.

func (*DeleteTaskResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTaskResponse.ProtoReflect.Descriptor instead.

func (*DeleteTaskResponse) ProtoMessage 

func (*DeleteTaskResponse) ProtoMessage()

func (*DeleteTaskResponse) ProtoReflect added in v1.10.7 

func (x *DeleteTaskResponse) ProtoReflect() protoreflect.Message

func (*DeleteTaskResponse) Reset 

func (x *DeleteTaskResponse) Reset()

func (*DeleteTaskResponse) String 

func (x *DeleteTaskResponse) String() string

type Description 

type Description struct {

	// Types that are assignable to Content:
	//
	//	*Description_Value
	//	*Description_Uri
	Content isDescription_Content `protobuf_oneof:"content"`
	// Format of the long description
	Format DescriptionFormat `protobuf:"varint,3,opt,name=format,proto3,enum=flyteidl.admin.DescriptionFormat" json:"format,omitempty"`
	// Optional link to an icon for the entity
	IconLink string `protobuf:"bytes,4,opt,name=icon_link,json=iconLink,proto3" json:"icon_link,omitempty"`
	// contains filtered or unexported fields
}

Full user description with formatting preserved. This can be rendered by clients, such as the console or command line tools with in-tact formatting.

func (*Description) Descriptor deprecated 

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

Deprecated: Use Description.ProtoReflect.Descriptor instead.

func (*Description) GetContent 

func (m *Description) GetContent() isDescription_Content

func (*Description) GetFormat 

func (x *Description) GetFormat() DescriptionFormat
func (x *Description) GetIconLink() string

func (*Description) GetUri 

func (x *Description) GetUri() string

func (*Description) GetValue 

func (x *Description) GetValue() string

func (*Description) ProtoMessage 

func (*Description) ProtoMessage()

func (*Description) ProtoReflect added in v1.10.7 

func (x *Description) ProtoReflect() protoreflect.Message

func (*Description) Reset 

func (x *Description) Reset()

func (*Description) String 

func (x *Description) String() string

type DescriptionEntity 

type DescriptionEntity struct {

	// id represents the unique identifier of the description entity.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// One-liner overview of the entity.
	ShortDescription string `protobuf:"bytes,2,opt,name=short_description,json=shortDescription,proto3" json:"short_description,omitempty"`
	// Full user description with formatting preserved.
	LongDescription *Description `protobuf:"bytes,3,opt,name=long_description,json=longDescription,proto3" json:"long_description,omitempty"`
	// Optional link to source code used to define this entity.
	SourceCode *SourceCode `protobuf:"bytes,4,opt,name=source_code,json=sourceCode,proto3" json:"source_code,omitempty"`
	// User-specified tags. These are arbitrary and can be used for searching
	// filtering and discovering tasks.
	Tags []string `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

DescriptionEntity contains detailed description for the task/workflow. Documentation could provide insight into the algorithms, business use case, etc.

func (*DescriptionEntity) Descriptor deprecated 

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

Deprecated: Use DescriptionEntity.ProtoReflect.Descriptor instead.

func (*DescriptionEntity) GetId 

func (x *DescriptionEntity) GetId() *core.Identifier

func (*DescriptionEntity) GetLongDescription 

func (x *DescriptionEntity) GetLongDescription() *Description

func (*DescriptionEntity) GetShortDescription 

func (x *DescriptionEntity) GetShortDescription() string

func (*DescriptionEntity) GetSourceCode 

func (x *DescriptionEntity) GetSourceCode() *SourceCode

func (*DescriptionEntity) GetTags 

func (x *DescriptionEntity) GetTags() []string

func (*DescriptionEntity) ProtoMessage 

func (*DescriptionEntity) ProtoMessage()

func (*DescriptionEntity) ProtoReflect added in v1.10.7 

func (x *DescriptionEntity) ProtoReflect() protoreflect.Message

func (*DescriptionEntity) Reset 

func (x *DescriptionEntity) Reset()

func (*DescriptionEntity) String 

func (x *DescriptionEntity) String() string

type DescriptionEntityList 

type DescriptionEntityList struct {

	// A list of DescriptionEntities returned based on the request.
	DescriptionEntities []*DescriptionEntity `protobuf:"bytes,1,rep,name=descriptionEntities,proto3" json:"descriptionEntities,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Represents a list of DescriptionEntities returned from the admin. See :ref:`ref_flyteidl.admin.DescriptionEntity` for more details

func (*DescriptionEntityList) Descriptor deprecated 

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

Deprecated: Use DescriptionEntityList.ProtoReflect.Descriptor instead.

func (*DescriptionEntityList) GetDescriptionEntities 

func (x *DescriptionEntityList) GetDescriptionEntities() []*DescriptionEntity

func (*DescriptionEntityList) GetToken 

func (x *DescriptionEntityList) GetToken() string

func (*DescriptionEntityList) ProtoMessage 

func (*DescriptionEntityList) ProtoMessage()

func (*DescriptionEntityList) ProtoReflect added in v1.10.7 

func (x *DescriptionEntityList) ProtoReflect() protoreflect.Message

func (*DescriptionEntityList) Reset 

func (x *DescriptionEntityList) Reset()

func (*DescriptionEntityList) String 

func (x *DescriptionEntityList) String() string

type DescriptionEntityListRequest 

type DescriptionEntityListRequest struct {

	// Identifies the specific type of resource that this identifier corresponds to.
	ResourceType core.ResourceType `` /* 130-byte string literal not displayed */
	// The identifier for the description entity.
	// +required
	Id *NamedEntityIdentifier `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Indicates the number of resources to be returned.
	// +required
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,5,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering for returned list.
	// +optional
	SortBy *Sort `protobuf:"bytes,6,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to retrieve a list of DescriptionEntities. See :ref:`ref_flyteidl.admin.DescriptionEntity` for more details

func (*DescriptionEntityListRequest) Descriptor deprecated 

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

Deprecated: Use DescriptionEntityListRequest.ProtoReflect.Descriptor instead.

func (*DescriptionEntityListRequest) GetFilters 

func (x *DescriptionEntityListRequest) GetFilters() string

func (*DescriptionEntityListRequest) GetId 

func (x *DescriptionEntityListRequest) GetId() *NamedEntityIdentifier

func (*DescriptionEntityListRequest) GetLimit 

func (x *DescriptionEntityListRequest) GetLimit() uint32

func (*DescriptionEntityListRequest) GetResourceType 

func (x *DescriptionEntityListRequest) GetResourceType() core.ResourceType

func (*DescriptionEntityListRequest) GetSortBy 

func (x *DescriptionEntityListRequest) GetSortBy() *Sort

func (*DescriptionEntityListRequest) GetToken 

func (x *DescriptionEntityListRequest) GetToken() string

func (*DescriptionEntityListRequest) ProtoMessage 

func (*DescriptionEntityListRequest) ProtoMessage()

func (*DescriptionEntityListRequest) ProtoReflect added in v1.10.7 

func (x *DescriptionEntityListRequest) ProtoReflect() protoreflect.Message

func (*DescriptionEntityListRequest) Reset 

func (x *DescriptionEntityListRequest) Reset()

func (*DescriptionEntityListRequest) String 

func (x *DescriptionEntityListRequest) String() string

type DescriptionFormat 

type DescriptionFormat int32

The format of the long description 

const (
	DescriptionFormat_DESCRIPTION_FORMAT_UNKNOWN  DescriptionFormat = 0
	DescriptionFormat_DESCRIPTION_FORMAT_MARKDOWN DescriptionFormat = 1
	DescriptionFormat_DESCRIPTION_FORMAT_HTML     DescriptionFormat = 2
	// python default documentation - comments is rst
	DescriptionFormat_DESCRIPTION_FORMAT_RST DescriptionFormat = 3
)

func (DescriptionFormat) Descriptor added in v1.10.7 

func (DescriptionFormat) Descriptor() protoreflect.EnumDescriptor

func (DescriptionFormat) Enum added in v1.10.7 

func (x DescriptionFormat) Enum() *DescriptionFormat

func (DescriptionFormat) EnumDescriptor deprecated 

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

Deprecated: Use DescriptionFormat.Descriptor instead.

func (DescriptionFormat) Number added in v1.10.7 

func (x DescriptionFormat) Number() protoreflect.EnumNumber

func (DescriptionFormat) String 

func (x DescriptionFormat) String() string

func (DescriptionFormat) Type added in v1.10.7 

func (DescriptionFormat) Type() protoreflect.EnumType

type Description_Uri 

type Description_Uri struct {
	// if the description sizes exceed some threshold we can offload the entire
	// description proto altogether to an external data store, like S3 rather than store inline in the db
	Uri string `protobuf:"bytes,2,opt,name=uri,proto3,oneof"`
}

type Description_Value 

type Description_Value struct {
	// long description - no more than 4KB
	Value string `protobuf:"bytes,1,opt,name=value,proto3,oneof"`
}

type Domain 

type Domain struct {

	// Globally unique domain name.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Display name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Namespace within a project commonly used to differentiate between different service instances. e.g. "production", "development", etc.

func (*Domain) Descriptor deprecated 

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

Deprecated: Use Domain.ProtoReflect.Descriptor instead.

func (*Domain) GetId 

func (x *Domain) GetId() string

func (*Domain) GetName 

func (x *Domain) GetName() string

func (*Domain) ProtoMessage 

func (*Domain) ProtoMessage()

func (*Domain) ProtoReflect added in v1.10.7 

func (x *Domain) ProtoReflect() protoreflect.Message

func (*Domain) Reset 

func (x *Domain) Reset()

func (*Domain) String 

func (x *Domain) String() string

type DynamicNodeWorkflowResponse added in v1.10.7 

type DynamicNodeWorkflowResponse struct {
	CompiledWorkflow *core.CompiledWorkflowClosure `protobuf:"bytes,1,opt,name=compiled_workflow,json=compiledWorkflow,proto3" json:"compiled_workflow,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamicNodeWorkflowResponse) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use DynamicNodeWorkflowResponse.ProtoReflect.Descriptor instead.

func (*DynamicNodeWorkflowResponse) GetCompiledWorkflow added in v1.10.7 

func (x *DynamicNodeWorkflowResponse) GetCompiledWorkflow() *core.CompiledWorkflowClosure

func (*DynamicNodeWorkflowResponse) ProtoMessage added in v1.10.7 

func (*DynamicNodeWorkflowResponse) ProtoMessage()

func (*DynamicNodeWorkflowResponse) ProtoReflect added in v1.10.7 

func (x *DynamicNodeWorkflowResponse) ProtoReflect() protoreflect.Message

func (*DynamicNodeWorkflowResponse) Reset added in v1.10.7 

func (x *DynamicNodeWorkflowResponse) Reset()

func (*DynamicNodeWorkflowResponse) String added in v1.10.7 

func (x *DynamicNodeWorkflowResponse) String() string

type DynamicWorkflowNodeMetadata 

type DynamicWorkflowNodeMetadata struct {

	// id represents the unique identifier of the workflow.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Represents the compiled representation of the embedded dynamic workflow.
	CompiledWorkflow *core.CompiledWorkflowClosure `protobuf:"bytes,2,opt,name=compiled_workflow,json=compiledWorkflow,proto3" json:"compiled_workflow,omitempty"`
	// dynamic_job_spec_uri is the location of the DynamicJobSpec proto message for this DynamicWorkflow. This is
	// required to correctly recover partially completed executions where the subworkflow has already been compiled.
	DynamicJobSpecUri string `protobuf:"bytes,3,opt,name=dynamic_job_spec_uri,json=dynamicJobSpecUri,proto3" json:"dynamic_job_spec_uri,omitempty"`
	// contains filtered or unexported fields
}

For dynamic workflow nodes we capture information about the dynamic workflow definition that gets generated.

func (*DynamicWorkflowNodeMetadata) Descriptor deprecated 

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

Deprecated: Use DynamicWorkflowNodeMetadata.ProtoReflect.Descriptor instead.

func (*DynamicWorkflowNodeMetadata) GetCompiledWorkflow 

func (x *DynamicWorkflowNodeMetadata) GetCompiledWorkflow() *core.CompiledWorkflowClosure

func (*DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri 

func (x *DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri() string

func (*DynamicWorkflowNodeMetadata) GetId 

func (x *DynamicWorkflowNodeMetadata) GetId() *core.Identifier

func (*DynamicWorkflowNodeMetadata) ProtoMessage 

func (*DynamicWorkflowNodeMetadata) ProtoMessage()

func (*DynamicWorkflowNodeMetadata) ProtoReflect added in v1.10.7 

func (x *DynamicWorkflowNodeMetadata) ProtoReflect() protoreflect.Message

func (*DynamicWorkflowNodeMetadata) Reset 

func (x *DynamicWorkflowNodeMetadata) Reset()

func (*DynamicWorkflowNodeMetadata) String 

func (x *DynamicWorkflowNodeMetadata) String() string

type EmailMessage 

type EmailMessage struct {

	// The list of email addresses to receive an email with the content populated in the other fields.
	// Currently, each email recipient will receive its own email.
	// This populates the TO field.
	RecipientsEmail []string `protobuf:"bytes,1,rep,name=recipients_email,json=recipientsEmail,proto3" json:"recipients_email,omitempty"`
	// The email of the sender.
	// This populates the FROM field.
	SenderEmail string `protobuf:"bytes,2,opt,name=sender_email,json=senderEmail,proto3" json:"sender_email,omitempty"`
	// The content of the subject line.
	// This populates the SUBJECT field.
	SubjectLine string `protobuf:"bytes,3,opt,name=subject_line,json=subjectLine,proto3" json:"subject_line,omitempty"`
	// The content of the email body.
	// This populates the BODY field.
	Body string `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

Represents the Email object that is sent to a publisher/subscriber to forward the notification. Note: This is internal to Admin and doesn't need to be exposed to other components.

func (*EmailMessage) Descriptor deprecated 

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

Deprecated: Use EmailMessage.ProtoReflect.Descriptor instead.

func (*EmailMessage) GetBody 

func (x *EmailMessage) GetBody() string

func (*EmailMessage) GetRecipientsEmail 

func (x *EmailMessage) GetRecipientsEmail() []string

func (*EmailMessage) GetSenderEmail 

func (x *EmailMessage) GetSenderEmail() string

func (*EmailMessage) GetSubjectLine 

func (x *EmailMessage) GetSubjectLine() string

func (*EmailMessage) ProtoMessage 

func (*EmailMessage) ProtoMessage()

func (*EmailMessage) ProtoReflect added in v1.10.7 

func (x *EmailMessage) ProtoReflect() protoreflect.Message

func (*EmailMessage) Reset 

func (x *EmailMessage) Reset()

func (*EmailMessage) String 

func (x *EmailMessage) String() string

type EmailNotification 

type EmailNotification struct {

	// The list of email addresses recipients for this notification.
	// +required
	RecipientsEmail []string `protobuf:"bytes,1,rep,name=recipients_email,json=recipientsEmail,proto3" json:"recipients_email,omitempty"`
	// contains filtered or unexported fields
}

Defines an email notification specification.

func (*EmailNotification) Descriptor deprecated 

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

Deprecated: Use EmailNotification.ProtoReflect.Descriptor instead.

func (*EmailNotification) GetRecipientsEmail 

func (x *EmailNotification) GetRecipientsEmail() []string

func (*EmailNotification) ProtoMessage 

func (*EmailNotification) ProtoMessage()

func (*EmailNotification) ProtoReflect added in v1.10.7 

func (x *EmailNotification) ProtoReflect() protoreflect.Message

func (*EmailNotification) Reset 

func (x *EmailNotification) Reset()

func (*EmailNotification) String 

func (x *EmailNotification) String() string

type Envs 

type Envs struct {

	// Map of custom environment variables to be applied to the execution resource.
	Values []*core.KeyValuePair `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Environment variable values to be applied to an execution resource. In the future a mode (e.g. OVERRIDE, APPEND, etc) can be defined to specify how to merge environment variables defined at registration and execution time.

func (*Envs) Descriptor deprecated 

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

Deprecated: Use Envs.ProtoReflect.Descriptor instead.

func (*Envs) GetValues 

func (x *Envs) GetValues() []*core.KeyValuePair

func (*Envs) ProtoMessage 

func (*Envs) ProtoMessage()

func (*Envs) ProtoReflect added in v1.10.7 

func (x *Envs) ProtoReflect() protoreflect.Message

func (*Envs) Reset 

func (x *Envs) Reset()

func (*Envs) String 

func (x *Envs) String() string

type EventErrorAlreadyInTerminalState 

type EventErrorAlreadyInTerminalState struct {

	// +required
	CurrentPhase string `protobuf:"bytes,1,opt,name=current_phase,json=currentPhase,proto3" json:"current_phase,omitempty"`
	// contains filtered or unexported fields
}

Indicates that a sent event was not used to update execution state due to the referenced execution already being terminated (and therefore ineligible for further state transitions).

func (*EventErrorAlreadyInTerminalState) Descriptor deprecated 

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

Deprecated: Use EventErrorAlreadyInTerminalState.ProtoReflect.Descriptor instead.

func (*EventErrorAlreadyInTerminalState) GetCurrentPhase 

func (x *EventErrorAlreadyInTerminalState) GetCurrentPhase() string

func (*EventErrorAlreadyInTerminalState) ProtoMessage 

func (*EventErrorAlreadyInTerminalState) ProtoMessage()

func (*EventErrorAlreadyInTerminalState) ProtoReflect added in v1.10.7 

func (x *EventErrorAlreadyInTerminalState) ProtoReflect() protoreflect.Message

func (*EventErrorAlreadyInTerminalState) Reset 

func (x *EventErrorAlreadyInTerminalState) Reset()

func (*EventErrorAlreadyInTerminalState) String 

func (x *EventErrorAlreadyInTerminalState) String() string

type EventErrorIncompatibleCluster 

type EventErrorIncompatibleCluster struct {

	// The cluster which has been recorded as processing the execution.
	// +required
	Cluster string `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

Indicates an event was rejected because it came from a different cluster than is on record as running the execution.

func (*EventErrorIncompatibleCluster) Descriptor deprecated 

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

Deprecated: Use EventErrorIncompatibleCluster.ProtoReflect.Descriptor instead.

func (*EventErrorIncompatibleCluster) GetCluster 

func (x *EventErrorIncompatibleCluster) GetCluster() string

func (*EventErrorIncompatibleCluster) ProtoMessage 

func (*EventErrorIncompatibleCluster) ProtoMessage()

func (*EventErrorIncompatibleCluster) ProtoReflect added in v1.10.7 

func (x *EventErrorIncompatibleCluster) ProtoReflect() protoreflect.Message

func (*EventErrorIncompatibleCluster) Reset 

func (x *EventErrorIncompatibleCluster) Reset()

func (*EventErrorIncompatibleCluster) String 

func (x *EventErrorIncompatibleCluster) String() string

type EventFailureReason 

type EventFailureReason struct {

	// +required
	//
	// Types that are assignable to Reason:
	//
	//	*EventFailureReason_AlreadyInTerminalState
	//	*EventFailureReason_IncompatibleCluster
	Reason isEventFailureReason_Reason `protobuf_oneof:"reason"`
	// contains filtered or unexported fields
}

Indicates why a sent event was not used to update execution.

func (*EventFailureReason) Descriptor deprecated 

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

Deprecated: Use EventFailureReason.ProtoReflect.Descriptor instead.

func (*EventFailureReason) GetAlreadyInTerminalState 

func (x *EventFailureReason) GetAlreadyInTerminalState() *EventErrorAlreadyInTerminalState

func (*EventFailureReason) GetIncompatibleCluster 

func (x *EventFailureReason) GetIncompatibleCluster() *EventErrorIncompatibleCluster

func (*EventFailureReason) GetReason 

func (m *EventFailureReason) GetReason() isEventFailureReason_Reason

func (*EventFailureReason) ProtoMessage 

func (*EventFailureReason) ProtoMessage()

func (*EventFailureReason) ProtoReflect added in v1.10.7 

func (x *EventFailureReason) ProtoReflect() protoreflect.Message

func (*EventFailureReason) Reset 

func (x *EventFailureReason) Reset()

func (*EventFailureReason) String 

func (x *EventFailureReason) String() string

type EventFailureReason_AlreadyInTerminalState 

type EventFailureReason_AlreadyInTerminalState struct {
	AlreadyInTerminalState *EventErrorAlreadyInTerminalState `protobuf:"bytes,1,opt,name=already_in_terminal_state,json=alreadyInTerminalState,proto3,oneof"`
}

type EventFailureReason_IncompatibleCluster 

type EventFailureReason_IncompatibleCluster struct {
	IncompatibleCluster *EventErrorIncompatibleCluster `protobuf:"bytes,2,opt,name=incompatible_cluster,json=incompatibleCluster,proto3,oneof"`
}

type ExecuteTaskSyncRequest added in v1.11.0 

type ExecuteTaskSyncRequest struct {

	// Types that are assignable to Part:
	//
	//	*ExecuteTaskSyncRequest_Header
	//	*ExecuteTaskSyncRequest_Inputs
	Part isExecuteTaskSyncRequest_Part `protobuf_oneof:"part"`
	// contains filtered or unexported fields
}

func (*ExecuteTaskSyncRequest) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use ExecuteTaskSyncRequest.ProtoReflect.Descriptor instead.

func (*ExecuteTaskSyncRequest) GetHeader added in v1.11.0 

func (x *ExecuteTaskSyncRequest) GetHeader() *CreateRequestHeader

func (*ExecuteTaskSyncRequest) GetInputs added in v1.11.0 

func (x *ExecuteTaskSyncRequest) GetInputs() *core.LiteralMap

func (*ExecuteTaskSyncRequest) GetPart added in v1.11.0 

func (m *ExecuteTaskSyncRequest) GetPart() isExecuteTaskSyncRequest_Part

func (*ExecuteTaskSyncRequest) ProtoMessage added in v1.11.0 

func (*ExecuteTaskSyncRequest) ProtoMessage()

func (*ExecuteTaskSyncRequest) ProtoReflect added in v1.11.0 

func (x *ExecuteTaskSyncRequest) ProtoReflect() protoreflect.Message

func (*ExecuteTaskSyncRequest) Reset added in v1.11.0 

func (x *ExecuteTaskSyncRequest) Reset()

func (*ExecuteTaskSyncRequest) String added in v1.11.0 

func (x *ExecuteTaskSyncRequest) String() string

type ExecuteTaskSyncRequest_Header added in v1.11.0 

type ExecuteTaskSyncRequest_Header struct {
	Header *CreateRequestHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type ExecuteTaskSyncRequest_Inputs added in v1.11.0 

type ExecuteTaskSyncRequest_Inputs struct {
	Inputs *core.LiteralMap `protobuf:"bytes,2,opt,name=inputs,proto3,oneof"`
}

type ExecuteTaskSyncResponse added in v1.11.0 

type ExecuteTaskSyncResponse struct {

	// Metadata is created by the agent. It could be a string (jobId) or a dict (more complex metadata).
	// Resource is for synchronous task execution.
	//
	// Types that are assignable to Res:
	//
	//	*ExecuteTaskSyncResponse_Header
	//	*ExecuteTaskSyncResponse_Outputs
	Res isExecuteTaskSyncResponse_Res `protobuf_oneof:"res"`
	// contains filtered or unexported fields
}

func (*ExecuteTaskSyncResponse) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use ExecuteTaskSyncResponse.ProtoReflect.Descriptor instead.

func (*ExecuteTaskSyncResponse) GetHeader added in v1.11.0 

func (x *ExecuteTaskSyncResponse) GetHeader() *ExecuteTaskSyncResponseHeader

func (*ExecuteTaskSyncResponse) GetOutputs added in v1.11.0 

func (x *ExecuteTaskSyncResponse) GetOutputs() *core.LiteralMap

func (*ExecuteTaskSyncResponse) GetRes added in v1.11.0 

func (m *ExecuteTaskSyncResponse) GetRes() isExecuteTaskSyncResponse_Res

func (*ExecuteTaskSyncResponse) ProtoMessage added in v1.11.0 

func (*ExecuteTaskSyncResponse) ProtoMessage()

func (*ExecuteTaskSyncResponse) ProtoReflect added in v1.11.0 

func (x *ExecuteTaskSyncResponse) ProtoReflect() protoreflect.Message

func (*ExecuteTaskSyncResponse) Reset added in v1.11.0 

func (x *ExecuteTaskSyncResponse) Reset()

func (*ExecuteTaskSyncResponse) String added in v1.11.0 

func (x *ExecuteTaskSyncResponse) String() string

type ExecuteTaskSyncResponseHeader added in v1.11.0 

type ExecuteTaskSyncResponseHeader struct {
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteTaskSyncResponseHeader) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use ExecuteTaskSyncResponseHeader.ProtoReflect.Descriptor instead.

func (*ExecuteTaskSyncResponseHeader) GetResource added in v1.11.0 

func (x *ExecuteTaskSyncResponseHeader) GetResource() *Resource

func (*ExecuteTaskSyncResponseHeader) ProtoMessage added in v1.11.0 

func (*ExecuteTaskSyncResponseHeader) ProtoMessage()

func (*ExecuteTaskSyncResponseHeader) ProtoReflect added in v1.11.0 

func (x *ExecuteTaskSyncResponseHeader) ProtoReflect() protoreflect.Message

func (*ExecuteTaskSyncResponseHeader) Reset added in v1.11.0 

func (x *ExecuteTaskSyncResponseHeader) Reset()

func (*ExecuteTaskSyncResponseHeader) String added in v1.11.0 

func (x *ExecuteTaskSyncResponseHeader) String() string

type ExecuteTaskSyncResponse_Header added in v1.11.0 

type ExecuteTaskSyncResponse_Header struct {
	Header *ExecuteTaskSyncResponseHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type ExecuteTaskSyncResponse_Outputs added in v1.11.0 

type ExecuteTaskSyncResponse_Outputs struct {
	Outputs *core.LiteralMap `protobuf:"bytes,2,opt,name=outputs,proto3,oneof"`
}

type Execution 

type Execution struct {

	// Unique identifier of the workflow execution.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User-provided configuration and inputs for launching the execution.
	Spec *ExecutionSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Execution results.
	Closure *ExecutionClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	// contains filtered or unexported fields
}

A workflow execution represents an instantiated workflow, including all inputs and additional metadata as well as computed results included state, outputs, and duration-based attributes. Used as a response object used in Get and List execution requests.

func (*Execution) Descriptor deprecated 

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

Deprecated: Use Execution.ProtoReflect.Descriptor instead.

func (*Execution) GetClosure 

func (x *Execution) GetClosure() *ExecutionClosure

func (*Execution) GetId 

func (x *Execution) GetId() *core.WorkflowExecutionIdentifier

func (*Execution) GetSpec 

func (x *Execution) GetSpec() *ExecutionSpec

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) ProtoReflect added in v1.10.7 

func (x *Execution) ProtoReflect() protoreflect.Message

func (*Execution) Reset 

func (x *Execution) Reset()

func (*Execution) String 

func (x *Execution) String() string

type ExecutionClosure 

type ExecutionClosure struct {

	// A result produced by a terminated execution.
	// A pending (non-terminal) execution will not have any output result.
	//
	// Types that are assignable to OutputResult:
	//
	//	*ExecutionClosure_Outputs
	//	*ExecutionClosure_Error
	//	*ExecutionClosure_AbortCause
	//	*ExecutionClosure_AbortMetadata
	//	*ExecutionClosure_OutputData
	OutputResult isExecutionClosure_OutputResult `protobuf_oneof:"output_result"`
	// Inputs computed and passed for execution.
	// computed_inputs depends on inputs in ExecutionSpec, fixed and default inputs in launch plan
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	ComputedInputs *core.LiteralMap `protobuf:"bytes,3,opt,name=computed_inputs,json=computedInputs,proto3" json:"computed_inputs,omitempty"`
	// Most recent recorded phase for the execution.
	Phase core.WorkflowExecution_Phase `protobuf:"varint,4,opt,name=phase,proto3,enum=flyteidl.core.WorkflowExecution_Phase" json:"phase,omitempty"`
	// Reported time at which the execution began running.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// The amount of time the execution spent running.
	Duration *durationpb.Duration `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// Reported time at which the execution was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Reported time at which the execution was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// The notification settings to use after merging the CreateExecutionRequest and the launch plan
	// notification settings. An execution launched with notifications will always prefer that definition
	// to notifications defined statically in a launch plan.
	Notifications []*Notification `protobuf:"bytes,9,rep,name=notifications,proto3" json:"notifications,omitempty"`
	// Identifies the workflow definition for this execution.
	WorkflowId *core.Identifier `protobuf:"bytes,11,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Provides the details of the last stage change
	StateChangeDetails *ExecutionStateChangeDetails `protobuf:"bytes,14,opt,name=state_change_details,json=stateChangeDetails,proto3" json:"state_change_details,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates the results of the Execution

func (*ExecutionClosure) Descriptor deprecated 

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

Deprecated: Use ExecutionClosure.ProtoReflect.Descriptor instead.

func (*ExecutionClosure) GetAbortCause deprecated 

func (x *ExecutionClosure) GetAbortCause() string

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*ExecutionClosure) GetAbortMetadata 

func (x *ExecutionClosure) GetAbortMetadata() *AbortMetadata

func (*ExecutionClosure) GetComputedInputs deprecated 

func (x *ExecutionClosure) GetComputedInputs() *core.LiteralMap

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*ExecutionClosure) GetCreatedAt 

func (x *ExecutionClosure) GetCreatedAt() *timestamppb.Timestamp

func (*ExecutionClosure) GetDuration 

func (x *ExecutionClosure) GetDuration() *durationpb.Duration

func (*ExecutionClosure) GetError 

func (x *ExecutionClosure) GetError() *core.ExecutionError

func (*ExecutionClosure) GetNotifications 

func (x *ExecutionClosure) GetNotifications() []*Notification

func (*ExecutionClosure) GetOutputData deprecated 

func (x *ExecutionClosure) GetOutputData() *core.LiteralMap

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*ExecutionClosure) GetOutputResult 

func (m *ExecutionClosure) GetOutputResult() isExecutionClosure_OutputResult

func (*ExecutionClosure) GetOutputs deprecated 

func (x *ExecutionClosure) GetOutputs() *LiteralMapBlob

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*ExecutionClosure) GetPhase 

func (x *ExecutionClosure) GetPhase() core.WorkflowExecution_Phase

func (*ExecutionClosure) GetStartedAt 

func (x *ExecutionClosure) GetStartedAt() *timestamppb.Timestamp

func (*ExecutionClosure) GetStateChangeDetails 

func (x *ExecutionClosure) GetStateChangeDetails() *ExecutionStateChangeDetails

func (*ExecutionClosure) GetUpdatedAt 

func (x *ExecutionClosure) GetUpdatedAt() *timestamppb.Timestamp

func (*ExecutionClosure) GetWorkflowId 

func (x *ExecutionClosure) GetWorkflowId() *core.Identifier

func (*ExecutionClosure) ProtoMessage 

func (*ExecutionClosure) ProtoMessage()

func (*ExecutionClosure) ProtoReflect added in v1.10.7 

func (x *ExecutionClosure) ProtoReflect() protoreflect.Message

func (*ExecutionClosure) Reset 

func (x *ExecutionClosure) Reset()

func (*ExecutionClosure) String 

func (x *ExecutionClosure) String() string

type ExecutionClosure_AbortCause 

type ExecutionClosure_AbortCause struct {
	// In the case of a user-specified abort, this will pass along the user-supplied cause.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	AbortCause string `protobuf:"bytes,10,opt,name=abort_cause,json=abortCause,proto3,oneof"`
}

type ExecutionClosure_AbortMetadata 

type ExecutionClosure_AbortMetadata struct {
	// In the case of a user-specified abort, this will pass along the user and their supplied cause.
	AbortMetadata *AbortMetadata `protobuf:"bytes,12,opt,name=abort_metadata,json=abortMetadata,proto3,oneof"`
}

type ExecutionClosure_Error 

type ExecutionClosure_Error struct {
	// Error information in the case of a failed execution.
	Error *core.ExecutionError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type ExecutionClosure_OutputData 

type ExecutionClosure_OutputData struct {
	// Raw output data produced by this execution.
	// DEPRECATED. Use GetExecutionData to fetch output data instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	OutputData *core.LiteralMap `protobuf:"bytes,13,opt,name=output_data,json=outputData,proto3,oneof"`
}

type ExecutionClosure_Outputs 

type ExecutionClosure_Outputs struct {
	// Output URI in the case of a successful execution.
	// DEPRECATED. Use GetExecutionData to fetch output data instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	Outputs *LiteralMapBlob `protobuf:"bytes,1,opt,name=outputs,proto3,oneof"`
}

type ExecutionClusterLabel 

type ExecutionClusterLabel struct {

	// Label value to determine where the execution will be run
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionClusterLabel) Descriptor deprecated 

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

Deprecated: Use ExecutionClusterLabel.ProtoReflect.Descriptor instead.

func (*ExecutionClusterLabel) GetValue 

func (x *ExecutionClusterLabel) GetValue() string

func (*ExecutionClusterLabel) ProtoMessage 

func (*ExecutionClusterLabel) ProtoMessage()

func (*ExecutionClusterLabel) ProtoReflect added in v1.10.7 

func (x *ExecutionClusterLabel) ProtoReflect() protoreflect.Message

func (*ExecutionClusterLabel) Reset 

func (x *ExecutionClusterLabel) Reset()

func (*ExecutionClusterLabel) String 

func (x *ExecutionClusterLabel) String() string

type ExecutionCreateRequest 

type ExecutionCreateRequest struct {

	// Name of the project the execution belongs to.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the execution belongs to.
	// A domain can be considered as a subset within a specific project.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// User provided value for the resource.
	// If none is provided the system will generate a unique string.
	// +optional
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Additional fields necessary to launch the execution.
	// +optional
	Spec *ExecutionSpec `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// The inputs required to start the execution. All required inputs must be
	// included in this map. If not required and not provided, defaults apply.
	// +optional
	Inputs *core.LiteralMap `protobuf:"bytes,5,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,6,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to launch an execution with the given project, domain and optionally-assigned name.

func (*ExecutionCreateRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionCreateRequest.ProtoReflect.Descriptor instead.

func (*ExecutionCreateRequest) GetDomain 

func (x *ExecutionCreateRequest) GetDomain() string

func (*ExecutionCreateRequest) GetInputs 

func (x *ExecutionCreateRequest) GetInputs() *core.LiteralMap

func (*ExecutionCreateRequest) GetName 

func (x *ExecutionCreateRequest) GetName() string

func (*ExecutionCreateRequest) GetOrg added in v1.10.7 

func (x *ExecutionCreateRequest) GetOrg() string

func (*ExecutionCreateRequest) GetProject 

func (x *ExecutionCreateRequest) GetProject() string

func (*ExecutionCreateRequest) GetSpec 

func (x *ExecutionCreateRequest) GetSpec() *ExecutionSpec

func (*ExecutionCreateRequest) ProtoMessage 

func (*ExecutionCreateRequest) ProtoMessage()

func (*ExecutionCreateRequest) ProtoReflect added in v1.10.7 

func (x *ExecutionCreateRequest) ProtoReflect() protoreflect.Message

func (*ExecutionCreateRequest) Reset 

func (x *ExecutionCreateRequest) Reset()

func (*ExecutionCreateRequest) String 

func (x *ExecutionCreateRequest) String() string

type ExecutionCreateResponse 

type ExecutionCreateResponse struct {
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

The unique identifier for a successfully created execution. If the name was *not* specified in the create request, this identifier will include a generated name.

func (*ExecutionCreateResponse) Descriptor deprecated 

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

Deprecated: Use ExecutionCreateResponse.ProtoReflect.Descriptor instead.

func (*ExecutionCreateResponse) GetId 

func (x *ExecutionCreateResponse) GetId() *core.WorkflowExecutionIdentifier

func (*ExecutionCreateResponse) ProtoMessage 

func (*ExecutionCreateResponse) ProtoMessage()

func (*ExecutionCreateResponse) ProtoReflect added in v1.10.7 

func (x *ExecutionCreateResponse) ProtoReflect() protoreflect.Message

func (*ExecutionCreateResponse) Reset 

func (x *ExecutionCreateResponse) Reset()

func (*ExecutionCreateResponse) String 

func (x *ExecutionCreateResponse) String() string

type ExecutionList 

type ExecutionList struct {
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Used as a response for request to list executions. See :ref:`ref_flyteidl.admin.Execution` for more details

func (*ExecutionList) Descriptor deprecated 

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

Deprecated: Use ExecutionList.ProtoReflect.Descriptor instead.

func (*ExecutionList) GetExecutions 

func (x *ExecutionList) GetExecutions() []*Execution

func (*ExecutionList) GetToken 

func (x *ExecutionList) GetToken() string

func (*ExecutionList) ProtoMessage 

func (*ExecutionList) ProtoMessage()

func (*ExecutionList) ProtoReflect added in v1.10.7 

func (x *ExecutionList) ProtoReflect() protoreflect.Message

func (*ExecutionList) Reset 

func (x *ExecutionList) Reset()

func (*ExecutionList) String 

func (x *ExecutionList) String() string

type ExecutionMetadata 

type ExecutionMetadata struct {
	Mode ExecutionMetadata_ExecutionMode `protobuf:"varint,1,opt,name=mode,proto3,enum=flyteidl.admin.ExecutionMetadata_ExecutionMode" json:"mode,omitempty"`
	// Identifier of the entity that triggered this execution.
	// For systems using back-end authentication any value set here will be discarded in favor of the
	// authenticated user context.
	Principal string `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	// Indicates the nestedness of this execution.
	// If a user launches a workflow execution, the default nesting is 0.
	// If this execution further launches a workflow (child workflow), the nesting level is incremented by 0 => 1
	// Generally, if workflow at nesting level k launches a workflow then the child workflow will have
	// nesting = k + 1.
	Nesting uint32 `protobuf:"varint,3,opt,name=nesting,proto3" json:"nesting,omitempty"`
	// For scheduled executions, the requested time for execution for this specific schedule invocation.
	ScheduledAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// Which subworkflow node (if any) launched this execution
	ParentNodeExecution *core.NodeExecutionIdentifier `protobuf:"bytes,5,opt,name=parent_node_execution,json=parentNodeExecution,proto3" json:"parent_node_execution,omitempty"`
	// Optional, a reference workflow execution related to this execution.
	// In the case of a relaunch, this references the original workflow execution.
	ReferenceExecution *core.WorkflowExecutionIdentifier `protobuf:"bytes,16,opt,name=reference_execution,json=referenceExecution,proto3" json:"reference_execution,omitempty"`
	// Optional, platform-specific metadata about the execution.
	// In this the future this may be gated behind an ACL or some sort of authorization.
	SystemMetadata *SystemMetadata `protobuf:"bytes,17,opt,name=system_metadata,json=systemMetadata,proto3" json:"system_metadata,omitempty"`
	// Save a list of the artifacts used in this execution for now. This is a list only rather than a mapping
	// since we don't have a structure to handle nested ones anyways.
	ArtifactIds []*core.ArtifactID `protobuf:"bytes,18,rep,name=artifact_ids,json=artifactIds,proto3" json:"artifact_ids,omitempty"`
	// contains filtered or unexported fields
}

Represents attributes about an execution which are not required to launch the execution but are useful to record. These attributes are assigned at launch time and do not change.

func (*ExecutionMetadata) Descriptor deprecated 

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

Deprecated: Use ExecutionMetadata.ProtoReflect.Descriptor instead.

func (*ExecutionMetadata) GetArtifactIds added in v1.10.7 

func (x *ExecutionMetadata) GetArtifactIds() []*core.ArtifactID

func (*ExecutionMetadata) GetMode 

func (x *ExecutionMetadata) GetMode() ExecutionMetadata_ExecutionMode

func (*ExecutionMetadata) GetNesting 

func (x *ExecutionMetadata) GetNesting() uint32

func (*ExecutionMetadata) GetParentNodeExecution 

func (x *ExecutionMetadata) GetParentNodeExecution() *core.NodeExecutionIdentifier

func (*ExecutionMetadata) GetPrincipal 

func (x *ExecutionMetadata) GetPrincipal() string

func (*ExecutionMetadata) GetReferenceExecution 

func (x *ExecutionMetadata) GetReferenceExecution() *core.WorkflowExecutionIdentifier

func (*ExecutionMetadata) GetScheduledAt 

func (x *ExecutionMetadata) GetScheduledAt() *timestamppb.Timestamp

func (*ExecutionMetadata) GetSystemMetadata 

func (x *ExecutionMetadata) GetSystemMetadata() *SystemMetadata

func (*ExecutionMetadata) ProtoMessage 

func (*ExecutionMetadata) ProtoMessage()

func (*ExecutionMetadata) ProtoReflect added in v1.10.7 

func (x *ExecutionMetadata) ProtoReflect() protoreflect.Message

func (*ExecutionMetadata) Reset 

func (x *ExecutionMetadata) Reset()

func (*ExecutionMetadata) String 

func (x *ExecutionMetadata) String() string

type ExecutionMetadata_ExecutionMode 

type ExecutionMetadata_ExecutionMode int32

The method by which this execution was launched. 

const (
	// The default execution mode, MANUAL implies that an execution was launched by an individual.
	ExecutionMetadata_MANUAL ExecutionMetadata_ExecutionMode = 0
	// A schedule triggered this execution launch.
	ExecutionMetadata_SCHEDULED ExecutionMetadata_ExecutionMode = 1
	// A system process was responsible for launching this execution rather an individual.
	ExecutionMetadata_SYSTEM ExecutionMetadata_ExecutionMode = 2
	// This execution was launched with identical inputs as a previous execution.
	ExecutionMetadata_RELAUNCH ExecutionMetadata_ExecutionMode = 3
	// This execution was triggered by another execution.
	ExecutionMetadata_CHILD_WORKFLOW ExecutionMetadata_ExecutionMode = 4
	// This execution was recovered from another execution.
	ExecutionMetadata_RECOVERED ExecutionMetadata_ExecutionMode = 5
	// Execution was kicked off by the artifact trigger system
	ExecutionMetadata_TRIGGER ExecutionMetadata_ExecutionMode = 6
)

func (ExecutionMetadata_ExecutionMode) Descriptor added in v1.10.7 

func (ExecutionMetadata_ExecutionMode) Descriptor() protoreflect.EnumDescriptor

func (ExecutionMetadata_ExecutionMode) Enum added in v1.10.7 

func (x ExecutionMetadata_ExecutionMode) Enum() *ExecutionMetadata_ExecutionMode

func (ExecutionMetadata_ExecutionMode) EnumDescriptor deprecated 

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

Deprecated: Use ExecutionMetadata_ExecutionMode.Descriptor instead.

func (ExecutionMetadata_ExecutionMode) Number added in v1.10.7 

func (x ExecutionMetadata_ExecutionMode) Number() protoreflect.EnumNumber

func (ExecutionMetadata_ExecutionMode) String 

func (x ExecutionMetadata_ExecutionMode) String() string

func (ExecutionMetadata_ExecutionMode) Type added in v1.10.7 

func (ExecutionMetadata_ExecutionMode) Type() protoreflect.EnumType

type ExecutionQueueAttributes 

type ExecutionQueueAttributes struct {

	// Tags used for assigning execution queues for tasks defined within this project.
	Tags []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionQueueAttributes) Descriptor deprecated 

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

Deprecated: Use ExecutionQueueAttributes.ProtoReflect.Descriptor instead.

func (*ExecutionQueueAttributes) GetTags 

func (x *ExecutionQueueAttributes) GetTags() []string

func (*ExecutionQueueAttributes) ProtoMessage 

func (*ExecutionQueueAttributes) ProtoMessage()

func (*ExecutionQueueAttributes) ProtoReflect added in v1.10.7 

func (x *ExecutionQueueAttributes) ProtoReflect() protoreflect.Message

func (*ExecutionQueueAttributes) Reset 

func (x *ExecutionQueueAttributes) Reset()

func (*ExecutionQueueAttributes) String 

func (x *ExecutionQueueAttributes) String() string

type ExecutionRecoverRequest 

type ExecutionRecoverRequest struct {

	// Identifier of the workflow execution to recover.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User provided value for the recovered execution.
	// If none is provided the system will generate a unique string.
	// +optional
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Additional metadata which will be used to overwrite any metadata in the reference execution when triggering a recovery execution.
	Metadata *ExecutionMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Request to recover the referenced execution.

func (*ExecutionRecoverRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionRecoverRequest.ProtoReflect.Descriptor instead.

func (*ExecutionRecoverRequest) GetId 

func (x *ExecutionRecoverRequest) GetId() *core.WorkflowExecutionIdentifier

func (*ExecutionRecoverRequest) GetMetadata 

func (x *ExecutionRecoverRequest) GetMetadata() *ExecutionMetadata

func (*ExecutionRecoverRequest) GetName 

func (x *ExecutionRecoverRequest) GetName() string

func (*ExecutionRecoverRequest) ProtoMessage 

func (*ExecutionRecoverRequest) ProtoMessage()

func (*ExecutionRecoverRequest) ProtoReflect added in v1.10.7 

func (x *ExecutionRecoverRequest) ProtoReflect() protoreflect.Message

func (*ExecutionRecoverRequest) Reset 

func (x *ExecutionRecoverRequest) Reset()

func (*ExecutionRecoverRequest) String 

func (x *ExecutionRecoverRequest) String() string

type ExecutionRelaunchRequest 

type ExecutionRelaunchRequest struct {

	// Identifier of the workflow execution to relaunch.
	// +required
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User provided value for the relaunched execution.
	// If none is provided the system will generate a unique string.
	// +optional
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution.
	// If enabled, all calculations are performed even if cached results would be available, overwriting the stored
	// data once execution finishes successfully.
	OverwriteCache bool `protobuf:"varint,4,opt,name=overwrite_cache,json=overwriteCache,proto3" json:"overwrite_cache,omitempty"`
	// contains filtered or unexported fields
}

Request to relaunch the referenced execution.

func (*ExecutionRelaunchRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionRelaunchRequest.ProtoReflect.Descriptor instead.

func (*ExecutionRelaunchRequest) GetId 

func (x *ExecutionRelaunchRequest) GetId() *core.WorkflowExecutionIdentifier

func (*ExecutionRelaunchRequest) GetName 

func (x *ExecutionRelaunchRequest) GetName() string

func (*ExecutionRelaunchRequest) GetOverwriteCache 

func (x *ExecutionRelaunchRequest) GetOverwriteCache() bool

func (*ExecutionRelaunchRequest) ProtoMessage 

func (*ExecutionRelaunchRequest) ProtoMessage()

func (*ExecutionRelaunchRequest) ProtoReflect added in v1.10.7 

func (x *ExecutionRelaunchRequest) ProtoReflect() protoreflect.Message

func (*ExecutionRelaunchRequest) Reset 

func (x *ExecutionRelaunchRequest) Reset()

func (*ExecutionRelaunchRequest) String 

func (x *ExecutionRelaunchRequest) String() string

type ExecutionSpec 

type ExecutionSpec struct {

	// Launch plan to be executed
	LaunchPlan *core.Identifier `protobuf:"bytes,1,opt,name=launch_plan,json=launchPlan,proto3" json:"launch_plan,omitempty"`
	// Input values to be passed for the execution
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	Inputs *core.LiteralMap `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Metadata for the execution
	Metadata *ExecutionMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are assignable to NotificationOverrides:
	//
	//	*ExecutionSpec_Notifications
	//	*ExecutionSpec_DisableAll
	NotificationOverrides isExecutionSpec_NotificationOverrides `protobuf_oneof:"notification_overrides"`
	// Labels to apply to the execution resource.
	Labels *Labels `protobuf:"bytes,7,opt,name=labels,proto3" json:"labels,omitempty"`
	// Annotations to apply to the execution resource.
	Annotations *Annotations `protobuf:"bytes,8,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// Optional: security context override to apply this execution.
	SecurityContext *core.SecurityContext `protobuf:"bytes,10,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// Optional: auth override to apply this execution.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	AuthRole *AuthRole `protobuf:"bytes,16,opt,name=auth_role,json=authRole,proto3" json:"auth_role,omitempty"`
	// Indicates the runtime priority of the execution.
	QualityOfService *core.QualityOfService `protobuf:"bytes,17,opt,name=quality_of_service,json=qualityOfService,proto3" json:"quality_of_service,omitempty"`
	// Controls the maximum number of task nodes that can be run in parallel for the entire workflow.
	// This is useful to achieve fairness. Note: MapTasks are regarded as one unit,
	// and parallelism/concurrency of MapTasks is independent from this.
	MaxParallelism int32 `protobuf:"varint,18,opt,name=max_parallelism,json=maxParallelism,proto3" json:"max_parallelism,omitempty"`
	// User setting to configure where to store offloaded data (i.e. Blobs, structured datasets, query data, etc.).
	// This should be a prefix like s3://my-bucket/my-data
	RawOutputDataConfig *RawOutputDataConfig `protobuf:"bytes,19,opt,name=raw_output_data_config,json=rawOutputDataConfig,proto3" json:"raw_output_data_config,omitempty"`
	// Controls how to select an available cluster on which this execution should run.
	ClusterAssignment *ClusterAssignment `protobuf:"bytes,20,opt,name=cluster_assignment,json=clusterAssignment,proto3" json:"cluster_assignment,omitempty"`
	// Allows for the interruptible flag of a workflow to be overwritten for a single execution.
	// Omitting this field uses the workflow's value as a default.
	// As we need to distinguish between the field not being provided and its default value false, we have to use a wrapper
	// around the bool field.
	Interruptible *wrapperspb.BoolValue `protobuf:"bytes,21,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution.
	// If enabled, all calculations are performed even if cached results would be available, overwriting the stored
	// data once execution finishes successfully.
	OverwriteCache bool `protobuf:"varint,22,opt,name=overwrite_cache,json=overwriteCache,proto3" json:"overwrite_cache,omitempty"`
	// Environment variables to be set for the execution.
	Envs *Envs `protobuf:"bytes,23,opt,name=envs,proto3" json:"envs,omitempty"`
	// Tags to be set for the execution.
	Tags []string `protobuf:"bytes,24,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

An ExecutionSpec encompasses all data used to launch this execution. The Spec does not change over the lifetime of an execution as it progresses across phase changes.

func (*ExecutionSpec) Descriptor deprecated 

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

Deprecated: Use ExecutionSpec.ProtoReflect.Descriptor instead.

func (*ExecutionSpec) GetAnnotations 

func (x *ExecutionSpec) GetAnnotations() *Annotations

func (*ExecutionSpec) GetAuthRole deprecated 

func (x *ExecutionSpec) GetAuthRole() *AuthRole

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*ExecutionSpec) GetClusterAssignment 

func (x *ExecutionSpec) GetClusterAssignment() *ClusterAssignment

func (*ExecutionSpec) GetDisableAll 

func (x *ExecutionSpec) GetDisableAll() bool

func (*ExecutionSpec) GetEnvs 

func (x *ExecutionSpec) GetEnvs() *Envs

func (*ExecutionSpec) GetInputs deprecated 

func (x *ExecutionSpec) GetInputs() *core.LiteralMap

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*ExecutionSpec) GetInterruptible 

func (x *ExecutionSpec) GetInterruptible() *wrapperspb.BoolValue

func (*ExecutionSpec) GetLabels 

func (x *ExecutionSpec) GetLabels() *Labels

func (*ExecutionSpec) GetLaunchPlan 

func (x *ExecutionSpec) GetLaunchPlan() *core.Identifier

func (*ExecutionSpec) GetMaxParallelism 

func (x *ExecutionSpec) GetMaxParallelism() int32

func (*ExecutionSpec) GetMetadata 

func (x *ExecutionSpec) GetMetadata() *ExecutionMetadata

func (*ExecutionSpec) GetNotificationOverrides 

func (m *ExecutionSpec) GetNotificationOverrides() isExecutionSpec_NotificationOverrides

func (*ExecutionSpec) GetNotifications 

func (x *ExecutionSpec) GetNotifications() *NotificationList

func (*ExecutionSpec) GetOverwriteCache 

func (x *ExecutionSpec) GetOverwriteCache() bool

func (*ExecutionSpec) GetQualityOfService 

func (x *ExecutionSpec) GetQualityOfService() *core.QualityOfService

func (*ExecutionSpec) GetRawOutputDataConfig 

func (x *ExecutionSpec) GetRawOutputDataConfig() *RawOutputDataConfig

func (*ExecutionSpec) GetSecurityContext 

func (x *ExecutionSpec) GetSecurityContext() *core.SecurityContext

func (*ExecutionSpec) GetTags 

func (x *ExecutionSpec) GetTags() []string

func (*ExecutionSpec) ProtoMessage 

func (*ExecutionSpec) ProtoMessage()

func (*ExecutionSpec) ProtoReflect added in v1.10.7 

func (x *ExecutionSpec) ProtoReflect() protoreflect.Message

func (*ExecutionSpec) Reset 

func (x *ExecutionSpec) Reset()

func (*ExecutionSpec) String 

func (x *ExecutionSpec) String() string

type ExecutionSpec_DisableAll 

type ExecutionSpec_DisableAll struct {
	// This should be set to true if all notifications are intended to be disabled for this execution.
	DisableAll bool `protobuf:"varint,6,opt,name=disable_all,json=disableAll,proto3,oneof"`
}

type ExecutionSpec_Notifications 

type ExecutionSpec_Notifications struct {
	// List of notifications based on Execution status transitions
	// When this list is not empty it is used rather than any notifications defined in the referenced launch plan.
	// When this list is empty, the notifications defined for the launch plan will be applied.
	Notifications *NotificationList `protobuf:"bytes,5,opt,name=notifications,proto3,oneof"`
}

type ExecutionState 

type ExecutionState int32

The state of the execution is used to control its visibility in the UI/CLI. 

const (
	// By default, all executions are considered active.
	ExecutionState_EXECUTION_ACTIVE ExecutionState = 0
	// Archived executions are no longer visible in the UI.
	ExecutionState_EXECUTION_ARCHIVED ExecutionState = 1
)

func (ExecutionState) Descriptor added in v1.10.7 

func (ExecutionState) Descriptor() protoreflect.EnumDescriptor

func (ExecutionState) Enum added in v1.10.7 

func (x ExecutionState) Enum() *ExecutionState

func (ExecutionState) EnumDescriptor deprecated 

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

Deprecated: Use ExecutionState.Descriptor instead.

func (ExecutionState) Number added in v1.10.7 

func (x ExecutionState) Number() protoreflect.EnumNumber

func (ExecutionState) String 

func (x ExecutionState) String() string

func (ExecutionState) Type added in v1.10.7 

func (ExecutionState) Type() protoreflect.EnumType

type ExecutionStateChangeDetails 

type ExecutionStateChangeDetails struct {

	// The state of the execution is used to control its visibility in the UI/CLI.
	State ExecutionState `protobuf:"varint,1,opt,name=state,proto3,enum=flyteidl.admin.ExecutionState" json:"state,omitempty"`
	// This timestamp represents when the state changed.
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Identifies the entity (if any) responsible for causing the state change of the execution
	Principal string `protobuf:"bytes,3,opt,name=principal,proto3" json:"principal,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionStateChangeDetails) Descriptor deprecated 

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

Deprecated: Use ExecutionStateChangeDetails.ProtoReflect.Descriptor instead.

func (*ExecutionStateChangeDetails) GetOccurredAt 

func (x *ExecutionStateChangeDetails) GetOccurredAt() *timestamppb.Timestamp

func (*ExecutionStateChangeDetails) GetPrincipal 

func (x *ExecutionStateChangeDetails) GetPrincipal() string

func (*ExecutionStateChangeDetails) GetState 

func (x *ExecutionStateChangeDetails) GetState() ExecutionState

func (*ExecutionStateChangeDetails) ProtoMessage 

func (*ExecutionStateChangeDetails) ProtoMessage()

func (*ExecutionStateChangeDetails) ProtoReflect added in v1.10.7 

func (x *ExecutionStateChangeDetails) ProtoReflect() protoreflect.Message

func (*ExecutionStateChangeDetails) Reset 

func (x *ExecutionStateChangeDetails) Reset()

func (*ExecutionStateChangeDetails) String 

func (x *ExecutionStateChangeDetails) String() string

type ExecutionTerminateRequest 

type ExecutionTerminateRequest struct {

	// Uniquely identifies the individual workflow execution to be terminated.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Optional reason for aborting.
	Cause string `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

Request to terminate an in-progress execution. This action is irreversible. If an execution is already terminated, this request will simply be a no-op. This request will fail if it references a non-existent execution. If the request succeeds the phase "ABORTED" will be recorded for the termination with the optional cause added to the output_result.

func (*ExecutionTerminateRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionTerminateRequest.ProtoReflect.Descriptor instead.

func (*ExecutionTerminateRequest) GetCause 

func (x *ExecutionTerminateRequest) GetCause() string

func (*ExecutionTerminateRequest) GetId 

func (x *ExecutionTerminateRequest) GetId() *core.WorkflowExecutionIdentifier

func (*ExecutionTerminateRequest) ProtoMessage 

func (*ExecutionTerminateRequest) ProtoMessage()

func (*ExecutionTerminateRequest) ProtoReflect added in v1.10.7 

func (x *ExecutionTerminateRequest) ProtoReflect() protoreflect.Message

func (*ExecutionTerminateRequest) Reset 

func (x *ExecutionTerminateRequest) Reset()

func (*ExecutionTerminateRequest) String 

func (x *ExecutionTerminateRequest) String() string

type ExecutionTerminateResponse 

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

func (*ExecutionTerminateResponse) Descriptor deprecated 

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

Deprecated: Use ExecutionTerminateResponse.ProtoReflect.Descriptor instead.

func (*ExecutionTerminateResponse) ProtoMessage 

func (*ExecutionTerminateResponse) ProtoMessage()

func (*ExecutionTerminateResponse) ProtoReflect added in v1.10.7 

func (x *ExecutionTerminateResponse) ProtoReflect() protoreflect.Message

func (*ExecutionTerminateResponse) Reset 

func (x *ExecutionTerminateResponse) Reset()

func (*ExecutionTerminateResponse) String 

func (x *ExecutionTerminateResponse) String() string

type ExecutionUpdateRequest 

type ExecutionUpdateRequest struct {

	// Identifier of the execution to update
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// State to set as the new value active/archive
	State ExecutionState `protobuf:"varint,2,opt,name=state,proto3,enum=flyteidl.admin.ExecutionState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionUpdateRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionUpdateRequest.ProtoReflect.Descriptor instead.

func (*ExecutionUpdateRequest) GetId 

func (x *ExecutionUpdateRequest) GetId() *core.WorkflowExecutionIdentifier

func (*ExecutionUpdateRequest) GetState 

func (x *ExecutionUpdateRequest) GetState() ExecutionState

func (*ExecutionUpdateRequest) ProtoMessage 

func (*ExecutionUpdateRequest) ProtoMessage()

func (*ExecutionUpdateRequest) ProtoReflect added in v1.10.7 

func (x *ExecutionUpdateRequest) ProtoReflect() protoreflect.Message

func (*ExecutionUpdateRequest) Reset 

func (x *ExecutionUpdateRequest) Reset()

func (*ExecutionUpdateRequest) String 

func (x *ExecutionUpdateRequest) String() string

type ExecutionUpdateResponse 

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

func (*ExecutionUpdateResponse) Descriptor deprecated 

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

Deprecated: Use ExecutionUpdateResponse.ProtoReflect.Descriptor instead.

func (*ExecutionUpdateResponse) ProtoMessage 

func (*ExecutionUpdateResponse) ProtoMessage()

func (*ExecutionUpdateResponse) ProtoReflect added in v1.10.7 

func (x *ExecutionUpdateResponse) ProtoReflect() protoreflect.Message

func (*ExecutionUpdateResponse) Reset 

func (x *ExecutionUpdateResponse) Reset()

func (*ExecutionUpdateResponse) String 

func (x *ExecutionUpdateResponse) String() string

type FixedRate 

type FixedRate struct {
	Value uint32        `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Unit  FixedRateUnit `protobuf:"varint,2,opt,name=unit,proto3,enum=flyteidl.admin.FixedRateUnit" json:"unit,omitempty"`
	// contains filtered or unexported fields
}

Option for schedules run at a certain frequency e.g. every 2 minutes.

func (*FixedRate) Descriptor deprecated 

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

Deprecated: Use FixedRate.ProtoReflect.Descriptor instead.

func (*FixedRate) GetUnit 

func (x *FixedRate) GetUnit() FixedRateUnit

func (*FixedRate) GetValue 

func (x *FixedRate) GetValue() uint32

func (*FixedRate) ProtoMessage 

func (*FixedRate) ProtoMessage()

func (*FixedRate) ProtoReflect added in v1.10.7 

func (x *FixedRate) ProtoReflect() protoreflect.Message

func (*FixedRate) Reset 

func (x *FixedRate) Reset()

func (*FixedRate) String 

func (x *FixedRate) String() string

type FixedRateUnit 

type FixedRateUnit int32

Represents a frequency at which to run a schedule. 

const (
	FixedRateUnit_MINUTE FixedRateUnit = 0
	FixedRateUnit_HOUR   FixedRateUnit = 1
	FixedRateUnit_DAY    FixedRateUnit = 2
)

func (FixedRateUnit) Descriptor added in v1.10.7 

func (FixedRateUnit) Descriptor() protoreflect.EnumDescriptor

func (FixedRateUnit) Enum added in v1.10.7 

func (x FixedRateUnit) Enum() *FixedRateUnit

func (FixedRateUnit) EnumDescriptor deprecated 

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

Deprecated: Use FixedRateUnit.Descriptor instead.

func (FixedRateUnit) Number added in v1.10.7 

func (x FixedRateUnit) Number() protoreflect.EnumNumber

func (FixedRateUnit) String 

func (x FixedRateUnit) String() string

func (FixedRateUnit) Type added in v1.10.7 

func (FixedRateUnit) Type() protoreflect.EnumType

type FlyteURLs 

type FlyteURLs struct {
	Inputs  string `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs string `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	Deck    string `protobuf:"bytes,3,opt,name=deck,proto3" json:"deck,omitempty"`
	// contains filtered or unexported fields
}

These URLs are returned as part of node and task execution data requests.

func (*FlyteURLs) Descriptor deprecated 

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

Deprecated: Use FlyteURLs.ProtoReflect.Descriptor instead.

func (*FlyteURLs) GetDeck 

func (x *FlyteURLs) GetDeck() string

func (*FlyteURLs) GetInputs 

func (x *FlyteURLs) GetInputs() string

func (*FlyteURLs) GetOutputs 

func (x *FlyteURLs) GetOutputs() string

func (*FlyteURLs) ProtoMessage 

func (*FlyteURLs) ProtoMessage()

func (*FlyteURLs) ProtoReflect added in v1.10.7 

func (x *FlyteURLs) ProtoReflect() protoreflect.Message

func (*FlyteURLs) Reset 

func (x *FlyteURLs) Reset()

func (*FlyteURLs) String 

func (x *FlyteURLs) String() string

type GetAgentRequest added in v1.10.7 

type GetAgentRequest struct {

	// The name of the agent.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

A request to get an agent.

func (*GetAgentRequest) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use GetAgentRequest.ProtoReflect.Descriptor instead.

func (*GetAgentRequest) GetName added in v1.10.7 

func (x *GetAgentRequest) GetName() string

func (*GetAgentRequest) ProtoMessage added in v1.10.7 

func (*GetAgentRequest) ProtoMessage()

func (*GetAgentRequest) ProtoReflect added in v1.10.7 

func (x *GetAgentRequest) ProtoReflect() protoreflect.Message

func (*GetAgentRequest) Reset added in v1.10.7 

func (x *GetAgentRequest) Reset()

func (*GetAgentRequest) String added in v1.10.7 

func (x *GetAgentRequest) String() string

type GetAgentResponse added in v1.10.7 

type GetAgentResponse struct {
	Agent *Agent `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	// contains filtered or unexported fields
}

A response containing an agent.

func (*GetAgentResponse) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use GetAgentResponse.ProtoReflect.Descriptor instead.

func (*GetAgentResponse) GetAgent added in v1.10.7 

func (x *GetAgentResponse) GetAgent() *Agent

func (*GetAgentResponse) ProtoMessage added in v1.10.7 

func (*GetAgentResponse) ProtoMessage()

func (*GetAgentResponse) ProtoReflect added in v1.10.7 

func (x *GetAgentResponse) ProtoReflect() protoreflect.Message

func (*GetAgentResponse) Reset added in v1.10.7 

func (x *GetAgentResponse) Reset()

func (*GetAgentResponse) String added in v1.10.7 

func (x *GetAgentResponse) String() string

type GetDynamicNodeWorkflowRequest added in v1.10.7 

type GetDynamicNodeWorkflowRequest struct {
	Id *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDynamicNodeWorkflowRequest) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use GetDynamicNodeWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetDynamicNodeWorkflowRequest) GetId added in v1.10.7 

func (x *GetDynamicNodeWorkflowRequest) GetId() *core.NodeExecutionIdentifier

func (*GetDynamicNodeWorkflowRequest) ProtoMessage added in v1.10.7 

func (*GetDynamicNodeWorkflowRequest) ProtoMessage()

func (*GetDynamicNodeWorkflowRequest) ProtoReflect added in v1.10.7 

func (x *GetDynamicNodeWorkflowRequest) ProtoReflect() protoreflect.Message

func (*GetDynamicNodeWorkflowRequest) Reset added in v1.10.7 

func (x *GetDynamicNodeWorkflowRequest) Reset()

func (*GetDynamicNodeWorkflowRequest) String added in v1.10.7 

func (x *GetDynamicNodeWorkflowRequest) String() string

type GetTaskLogsRequest added in v1.10.7 

type GetTaskLogsRequest struct {

	// A predefined yet extensible Task type identifier.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// Metadata is created by the agent. It could be a string (jobId) or a dict (more complex metadata).
	ResourceMeta []byte `protobuf:"bytes,2,opt,name=resource_meta,json=resourceMeta,proto3" json:"resource_meta,omitempty"`
	// Number of lines to return.
	Lines uint64 `protobuf:"varint,3,opt,name=lines,proto3" json:"lines,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// A predefined yet extensible Task type identifier.
	TaskCategory *TaskCategory `protobuf:"bytes,5,opt,name=task_category,json=taskCategory,proto3" json:"task_category,omitempty"`
	// contains filtered or unexported fields
}

A request to get the log from a task execution.

func (*GetTaskLogsRequest) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use GetTaskLogsRequest.ProtoReflect.Descriptor instead.

func (*GetTaskLogsRequest) GetLines added in v1.10.7 

func (x *GetTaskLogsRequest) GetLines() uint64

func (*GetTaskLogsRequest) GetResourceMeta added in v1.10.7 

func (x *GetTaskLogsRequest) GetResourceMeta() []byte

func (*GetTaskLogsRequest) GetTaskCategory added in v1.11.0 

func (x *GetTaskLogsRequest) GetTaskCategory() *TaskCategory

func (*GetTaskLogsRequest) GetTaskType deprecated added in v1.10.7 

func (x *GetTaskLogsRequest) GetTaskType() string

Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.

func (*GetTaskLogsRequest) GetToken added in v1.10.7 

func (x *GetTaskLogsRequest) GetToken() string

func (*GetTaskLogsRequest) ProtoMessage added in v1.10.7 

func (*GetTaskLogsRequest) ProtoMessage()

func (*GetTaskLogsRequest) ProtoReflect added in v1.10.7 

func (x *GetTaskLogsRequest) ProtoReflect() protoreflect.Message

func (*GetTaskLogsRequest) Reset added in v1.10.7 

func (x *GetTaskLogsRequest) Reset()

func (*GetTaskLogsRequest) String added in v1.10.7 

func (x *GetTaskLogsRequest) String() string

type GetTaskLogsResponse added in v1.10.7 

type GetTaskLogsResponse struct {

	// Types that are assignable to Part:
	//
	//	*GetTaskLogsResponse_Header
	//	*GetTaskLogsResponse_Body
	Part isGetTaskLogsResponse_Part `protobuf_oneof:"part"`
	// contains filtered or unexported fields
}

A response containing the logs for a task execution.

func (*GetTaskLogsResponse) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use GetTaskLogsResponse.ProtoReflect.Descriptor instead.

func (*GetTaskLogsResponse) GetBody added in v1.11.0 

func (x *GetTaskLogsResponse) GetBody() *GetTaskLogsResponseBody

func (*GetTaskLogsResponse) GetHeader added in v1.11.0 

func (x *GetTaskLogsResponse) GetHeader() *GetTaskLogsResponseHeader

func (*GetTaskLogsResponse) GetPart added in v1.11.0 

func (m *GetTaskLogsResponse) GetPart() isGetTaskLogsResponse_Part

func (*GetTaskLogsResponse) ProtoMessage added in v1.10.7 

func (*GetTaskLogsResponse) ProtoMessage()

func (*GetTaskLogsResponse) ProtoReflect added in v1.10.7 

func (x *GetTaskLogsResponse) ProtoReflect() protoreflect.Message

func (*GetTaskLogsResponse) Reset added in v1.10.7 

func (x *GetTaskLogsResponse) Reset()

func (*GetTaskLogsResponse) String added in v1.10.7 

func (x *GetTaskLogsResponse) String() string

type GetTaskLogsResponseBody added in v1.11.0 

type GetTaskLogsResponseBody struct {

	// The execution log results.
	Results []string `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskLogsResponseBody) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use GetTaskLogsResponseBody.ProtoReflect.Descriptor instead.

func (*GetTaskLogsResponseBody) GetResults added in v1.11.0 

func (x *GetTaskLogsResponseBody) GetResults() []string

func (*GetTaskLogsResponseBody) ProtoMessage added in v1.11.0 

func (*GetTaskLogsResponseBody) ProtoMessage()

func (*GetTaskLogsResponseBody) ProtoReflect added in v1.11.0 

func (x *GetTaskLogsResponseBody) ProtoReflect() protoreflect.Message

func (*GetTaskLogsResponseBody) Reset added in v1.11.0 

func (x *GetTaskLogsResponseBody) Reset()

func (*GetTaskLogsResponseBody) String added in v1.11.0 

func (x *GetTaskLogsResponseBody) String() string

type GetTaskLogsResponseHeader added in v1.11.0 

type GetTaskLogsResponseHeader struct {

	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskLogsResponseHeader) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use GetTaskLogsResponseHeader.ProtoReflect.Descriptor instead.

func (*GetTaskLogsResponseHeader) GetToken added in v1.11.0 

func (x *GetTaskLogsResponseHeader) GetToken() string

func (*GetTaskLogsResponseHeader) ProtoMessage added in v1.11.0 

func (*GetTaskLogsResponseHeader) ProtoMessage()

func (*GetTaskLogsResponseHeader) ProtoReflect added in v1.11.0 

func (x *GetTaskLogsResponseHeader) ProtoReflect() protoreflect.Message

func (*GetTaskLogsResponseHeader) Reset added in v1.11.0 

func (x *GetTaskLogsResponseHeader) Reset()

func (*GetTaskLogsResponseHeader) String added in v1.11.0 

func (x *GetTaskLogsResponseHeader) String() string

type GetTaskLogsResponse_Body added in v1.11.0 

type GetTaskLogsResponse_Body struct {
	Body *GetTaskLogsResponseBody `protobuf:"bytes,2,opt,name=body,proto3,oneof"`
}

type GetTaskLogsResponse_Header added in v1.11.0 

type GetTaskLogsResponse_Header struct {
	Header *GetTaskLogsResponseHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof"`
}

type GetTaskMetricsRequest added in v1.10.7 

type GetTaskMetricsRequest struct {

	// A predefined yet extensible Task type identifier.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// Metadata is created by the agent. It could be a string (jobId) or a dict (more complex metadata).
	ResourceMeta []byte `protobuf:"bytes,2,opt,name=resource_meta,json=resourceMeta,proto3" json:"resource_meta,omitempty"`
	// The metrics to query. If empty, will return a default set of metrics.
	// e.g. EXECUTION_METRIC_USED_CPU_AVG or EXECUTION_METRIC_USED_MEMORY_BYTES_AVG
	Queries []string `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"`
	// Start timestamp, inclusive.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// End timestamp, inclusive..
	EndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Query resolution step width in duration format or float number of seconds.
	Step *durationpb.Duration `protobuf:"bytes,6,opt,name=step,proto3" json:"step,omitempty"`
	// A predefined yet extensible Task type identifier.
	TaskCategory *TaskCategory `protobuf:"bytes,7,opt,name=task_category,json=taskCategory,proto3" json:"task_category,omitempty"`
	// contains filtered or unexported fields
}

A request to get the metrics from a task execution.

func (*GetTaskMetricsRequest) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use GetTaskMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetTaskMetricsRequest) GetEndTime added in v1.10.7 

func (x *GetTaskMetricsRequest) GetEndTime() *timestamppb.Timestamp

func (*GetTaskMetricsRequest) GetQueries added in v1.10.7 

func (x *GetTaskMetricsRequest) GetQueries() []string

func (*GetTaskMetricsRequest) GetResourceMeta added in v1.10.7 

func (x *GetTaskMetricsRequest) GetResourceMeta() []byte

func (*GetTaskMetricsRequest) GetStartTime added in v1.10.7 

func (x *GetTaskMetricsRequest) GetStartTime() *timestamppb.Timestamp

func (*GetTaskMetricsRequest) GetStep added in v1.10.7 

func (x *GetTaskMetricsRequest) GetStep() *durationpb.Duration

func (*GetTaskMetricsRequest) GetTaskCategory added in v1.11.0 

func (x *GetTaskMetricsRequest) GetTaskCategory() *TaskCategory

func (*GetTaskMetricsRequest) GetTaskType deprecated added in v1.10.7 

func (x *GetTaskMetricsRequest) GetTaskType() string

Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.

func (*GetTaskMetricsRequest) ProtoMessage added in v1.10.7 

func (*GetTaskMetricsRequest) ProtoMessage()

func (*GetTaskMetricsRequest) ProtoReflect added in v1.10.7 

func (x *GetTaskMetricsRequest) ProtoReflect() protoreflect.Message

func (*GetTaskMetricsRequest) Reset added in v1.10.7 

func (x *GetTaskMetricsRequest) Reset()

func (*GetTaskMetricsRequest) String added in v1.10.7 

func (x *GetTaskMetricsRequest) String() string

type GetTaskMetricsResponse added in v1.10.7 

type GetTaskMetricsResponse struct {

	// The execution metric results.
	Results []*core.ExecutionMetricResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

A response containing a list of metrics for a task execution.

func (*GetTaskMetricsResponse) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use GetTaskMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetTaskMetricsResponse) GetResults added in v1.10.7 

func (x *GetTaskMetricsResponse) GetResults() []*core.ExecutionMetricResult

func (*GetTaskMetricsResponse) ProtoMessage added in v1.10.7 

func (*GetTaskMetricsResponse) ProtoMessage()

func (*GetTaskMetricsResponse) ProtoReflect added in v1.10.7 

func (x *GetTaskMetricsResponse) ProtoReflect() protoreflect.Message

func (*GetTaskMetricsResponse) Reset added in v1.10.7 

func (x *GetTaskMetricsResponse) Reset()

func (*GetTaskMetricsResponse) String added in v1.10.7 

func (x *GetTaskMetricsResponse) String() string

type GetTaskRequest 

type GetTaskRequest struct {

	// A predefined yet extensible Task type identifier.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// Metadata about the resource to be pass to the agent.
	ResourceMeta []byte `protobuf:"bytes,2,opt,name=resource_meta,json=resourceMeta,proto3" json:"resource_meta,omitempty"`
	// A predefined yet extensible Task type identifier.
	TaskCategory *TaskCategory `protobuf:"bytes,3,opt,name=task_category,json=taskCategory,proto3" json:"task_category,omitempty"`
	// contains filtered or unexported fields
}

A message used to fetch a job resource from flyte agent server.

func (*GetTaskRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetResourceMeta 

func (x *GetTaskRequest) GetResourceMeta() []byte

func (*GetTaskRequest) GetTaskCategory added in v1.11.0 

func (x *GetTaskRequest) GetTaskCategory() *TaskCategory

func (*GetTaskRequest) GetTaskType deprecated 

func (x *GetTaskRequest) GetTaskType() string

Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect added in v1.10.7 

func (x *GetTaskRequest) ProtoReflect() protoreflect.Message

func (*GetTaskRequest) Reset 

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (x *GetTaskRequest) String() string

type GetTaskResponse 

type GetTaskResponse struct {
	Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

Response to get an individual task resource.

func (*GetTaskResponse) Descriptor deprecated 

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

Deprecated: Use GetTaskResponse.ProtoReflect.Descriptor instead.

func (*GetTaskResponse) GetResource 

func (x *GetTaskResponse) GetResource() *Resource

func (*GetTaskResponse) ProtoMessage 

func (*GetTaskResponse) ProtoMessage()

func (*GetTaskResponse) ProtoReflect added in v1.10.7 

func (x *GetTaskResponse) ProtoReflect() protoreflect.Message

func (*GetTaskResponse) Reset 

func (x *GetTaskResponse) Reset()

func (*GetTaskResponse) String 

func (x *GetTaskResponse) String() string

type GetVersionRequest 

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

Empty request for GetVersion

func (*GetVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetVersionRequest.ProtoReflect.Descriptor instead.

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) ProtoReflect added in v1.10.7 

func (x *GetVersionRequest) ProtoReflect() protoreflect.Message

func (*GetVersionRequest) Reset 

func (x *GetVersionRequest) Reset()

func (*GetVersionRequest) String 

func (x *GetVersionRequest) String() string

type GetVersionResponse 

type GetVersionResponse struct {

	// The control plane version information. FlyteAdmin and related components
	// form the control plane of Flyte
	ControlPlaneVersion *Version `protobuf:"bytes,1,opt,name=control_plane_version,json=controlPlaneVersion,proto3" json:"control_plane_version,omitempty"`
	// contains filtered or unexported fields
}

Response for the GetVersion API

func (*GetVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetVersionResponse.ProtoReflect.Descriptor instead.

func (*GetVersionResponse) GetControlPlaneVersion 

func (x *GetVersionResponse) GetControlPlaneVersion() *Version

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) ProtoReflect added in v1.10.7 

func (x *GetVersionResponse) ProtoReflect() protoreflect.Message

func (*GetVersionResponse) Reset 

func (x *GetVersionResponse) Reset()

func (*GetVersionResponse) String 

func (x *GetVersionResponse) String() string

type Labels 

type Labels struct {

	// Map of custom labels to be applied to the execution resource.
	Values map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Label values to be applied to an execution resource. In the future a mode (e.g. OVERRIDE, APPEND, etc) can be defined to specify how to merge labels defined at registration and execution time.

func (*Labels) Descriptor deprecated 

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

Deprecated: Use Labels.ProtoReflect.Descriptor instead.

func (*Labels) GetValues 

func (x *Labels) GetValues() map[string]string

func (*Labels) ProtoMessage 

func (*Labels) ProtoMessage()

func (*Labels) ProtoReflect added in v1.10.7 

func (x *Labels) ProtoReflect() protoreflect.Message

func (*Labels) Reset 

func (x *Labels) Reset()

func (*Labels) String 

func (x *Labels) String() string

type LaunchPlan 

type LaunchPlan struct {

	// Uniquely identifies a launch plan entity.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User-provided launch plan details, including reference workflow, inputs and other metadata.
	Spec *LaunchPlanSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Values computed by the flyte platform after launch plan registration.
	Closure *LaunchPlanClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	// contains filtered or unexported fields
}

A LaunchPlan provides the capability to templatize workflow executions. Launch plans simplify associating one or more schedules, inputs and notifications with your workflows. Launch plans can be shared and used to trigger executions with predefined inputs even when a workflow definition doesn't necessarily have a default value for said input.

func (*LaunchPlan) Descriptor deprecated 

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

Deprecated: Use LaunchPlan.ProtoReflect.Descriptor instead.

func (*LaunchPlan) GetClosure 

func (x *LaunchPlan) GetClosure() *LaunchPlanClosure

func (*LaunchPlan) GetId 

func (x *LaunchPlan) GetId() *core.Identifier

func (*LaunchPlan) GetSpec 

func (x *LaunchPlan) GetSpec() *LaunchPlanSpec

func (*LaunchPlan) ProtoMessage 

func (*LaunchPlan) ProtoMessage()

func (*LaunchPlan) ProtoReflect added in v1.10.7 

func (x *LaunchPlan) ProtoReflect() protoreflect.Message

func (*LaunchPlan) Reset 

func (x *LaunchPlan) Reset()

func (*LaunchPlan) String 

func (x *LaunchPlan) String() string

type LaunchPlanClosure 

type LaunchPlanClosure struct {

	// Indicate the Launch plan state.
	State LaunchPlanState `protobuf:"varint,1,opt,name=state,proto3,enum=flyteidl.admin.LaunchPlanState" json:"state,omitempty"`
	// Indicates the set of inputs expected when creating an execution with the Launch plan
	ExpectedInputs *core.ParameterMap `protobuf:"bytes,2,opt,name=expected_inputs,json=expectedInputs,proto3" json:"expected_inputs,omitempty"`
	// Indicates the set of outputs expected to be produced by creating an execution with the Launch plan
	ExpectedOutputs *core.VariableMap `protobuf:"bytes,3,opt,name=expected_outputs,json=expectedOutputs,proto3" json:"expected_outputs,omitempty"`
	// Time at which the launch plan was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Time at which the launch plan was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Values computed by the flyte platform after launch plan registration. These include expected_inputs required to be present in a CreateExecutionRequest to launch the reference workflow as well timestamp values associated with the launch plan.

func (*LaunchPlanClosure) Descriptor deprecated 

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

Deprecated: Use LaunchPlanClosure.ProtoReflect.Descriptor instead.

func (*LaunchPlanClosure) GetCreatedAt 

func (x *LaunchPlanClosure) GetCreatedAt() *timestamppb.Timestamp

func (*LaunchPlanClosure) GetExpectedInputs 

func (x *LaunchPlanClosure) GetExpectedInputs() *core.ParameterMap

func (*LaunchPlanClosure) GetExpectedOutputs 

func (x *LaunchPlanClosure) GetExpectedOutputs() *core.VariableMap

func (*LaunchPlanClosure) GetState 

func (x *LaunchPlanClosure) GetState() LaunchPlanState

func (*LaunchPlanClosure) GetUpdatedAt 

func (x *LaunchPlanClosure) GetUpdatedAt() *timestamppb.Timestamp

func (*LaunchPlanClosure) ProtoMessage 

func (*LaunchPlanClosure) ProtoMessage()

func (*LaunchPlanClosure) ProtoReflect added in v1.10.7 

func (x *LaunchPlanClosure) ProtoReflect() protoreflect.Message

func (*LaunchPlanClosure) Reset 

func (x *LaunchPlanClosure) Reset()

func (*LaunchPlanClosure) String 

func (x *LaunchPlanClosure) String() string

type LaunchPlanCreateRequest 

type LaunchPlanCreateRequest struct {

	// Uniquely identifies a launch plan entity.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User-provided launch plan details, including reference workflow, inputs and other metadata.
	Spec *LaunchPlanSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Request to register a launch plan. The included LaunchPlanSpec may have a complete or incomplete set of inputs required to launch a workflow execution. By default all launch plans are registered in state INACTIVE. If you wish to set the state to ACTIVE, you must submit a LaunchPlanUpdateRequest, after you have successfully created a launch plan.

func (*LaunchPlanCreateRequest) Descriptor deprecated 

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

Deprecated: Use LaunchPlanCreateRequest.ProtoReflect.Descriptor instead.

func (*LaunchPlanCreateRequest) GetId 

func (x *LaunchPlanCreateRequest) GetId() *core.Identifier

func (*LaunchPlanCreateRequest) GetSpec 

func (x *LaunchPlanCreateRequest) GetSpec() *LaunchPlanSpec

func (*LaunchPlanCreateRequest) ProtoMessage 

func (*LaunchPlanCreateRequest) ProtoMessage()

func (*LaunchPlanCreateRequest) ProtoReflect added in v1.10.7 

func (x *LaunchPlanCreateRequest) ProtoReflect() protoreflect.Message

func (*LaunchPlanCreateRequest) Reset 

func (x *LaunchPlanCreateRequest) Reset()

func (*LaunchPlanCreateRequest) String 

func (x *LaunchPlanCreateRequest) String() string

type LaunchPlanCreateResponse 

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

func (*LaunchPlanCreateResponse) Descriptor deprecated 

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

Deprecated: Use LaunchPlanCreateResponse.ProtoReflect.Descriptor instead.

func (*LaunchPlanCreateResponse) ProtoMessage 

func (*LaunchPlanCreateResponse) ProtoMessage()

func (*LaunchPlanCreateResponse) ProtoReflect added in v1.10.7 

func (x *LaunchPlanCreateResponse) ProtoReflect() protoreflect.Message

func (*LaunchPlanCreateResponse) Reset 

func (x *LaunchPlanCreateResponse) Reset()

func (*LaunchPlanCreateResponse) String 

func (x *LaunchPlanCreateResponse) String() string

type LaunchPlanList 

type LaunchPlanList struct {
	LaunchPlans []*LaunchPlan `protobuf:"bytes,1,rep,name=launch_plans,json=launchPlans,proto3" json:"launch_plans,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Response object for list launch plan requests. See :ref:`ref_flyteidl.admin.LaunchPlan` for more details

func (*LaunchPlanList) Descriptor deprecated 

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

Deprecated: Use LaunchPlanList.ProtoReflect.Descriptor instead.

func (*LaunchPlanList) GetLaunchPlans 

func (x *LaunchPlanList) GetLaunchPlans() []*LaunchPlan

func (*LaunchPlanList) GetToken 

func (x *LaunchPlanList) GetToken() string

func (*LaunchPlanList) ProtoMessage 

func (*LaunchPlanList) ProtoMessage()

func (*LaunchPlanList) ProtoReflect added in v1.10.7 

func (x *LaunchPlanList) ProtoReflect() protoreflect.Message

func (*LaunchPlanList) Reset 

func (x *LaunchPlanList) Reset()

func (*LaunchPlanList) String 

func (x *LaunchPlanList) String() string

type LaunchPlanMetadata 

type LaunchPlanMetadata struct {

	// Schedule to execute the Launch Plan
	Schedule *Schedule `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// List of notifications based on Execution status transitions
	Notifications []*Notification `protobuf:"bytes,2,rep,name=notifications,proto3" json:"notifications,omitempty"`
	// Additional metadata for how to launch the launch plan
	LaunchConditions *anypb.Any `protobuf:"bytes,3,opt,name=launch_conditions,json=launchConditions,proto3" json:"launch_conditions,omitempty"`
	// contains filtered or unexported fields
}

Additional launch plan attributes included in the LaunchPlanSpec not strictly required to launch the reference workflow.

func (*LaunchPlanMetadata) Descriptor deprecated 

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

Deprecated: Use LaunchPlanMetadata.ProtoReflect.Descriptor instead.

func (*LaunchPlanMetadata) GetLaunchConditions added in v1.10.7 

func (x *LaunchPlanMetadata) GetLaunchConditions() *anypb.Any

func (*LaunchPlanMetadata) GetNotifications 

func (x *LaunchPlanMetadata) GetNotifications() []*Notification

func (*LaunchPlanMetadata) GetSchedule 

func (x *LaunchPlanMetadata) GetSchedule() *Schedule

func (*LaunchPlanMetadata) ProtoMessage 

func (*LaunchPlanMetadata) ProtoMessage()

func (*LaunchPlanMetadata) ProtoReflect added in v1.10.7 

func (x *LaunchPlanMetadata) ProtoReflect() protoreflect.Message

func (*LaunchPlanMetadata) Reset 

func (x *LaunchPlanMetadata) Reset()

func (*LaunchPlanMetadata) String 

func (x *LaunchPlanMetadata) String() string

type LaunchPlanSpec 

type LaunchPlanSpec struct {

	// Reference to the Workflow template that the launch plan references
	WorkflowId *core.Identifier `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Metadata for the Launch Plan
	EntityMetadata *LaunchPlanMetadata `protobuf:"bytes,2,opt,name=entity_metadata,json=entityMetadata,proto3" json:"entity_metadata,omitempty"`
	// Input values to be passed for the execution.
	// These can be overridden when an execution is created with this launch plan.
	DefaultInputs *core.ParameterMap `protobuf:"bytes,3,opt,name=default_inputs,json=defaultInputs,proto3" json:"default_inputs,omitempty"`
	// Fixed, non-overridable inputs for the Launch Plan.
	// These can not be overridden when an execution is created with this launch plan.
	FixedInputs *core.LiteralMap `protobuf:"bytes,4,opt,name=fixed_inputs,json=fixedInputs,proto3" json:"fixed_inputs,omitempty"`
	// String to indicate the role to use to execute the workflow underneath
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/launch_plan.proto.
	Role string `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"`
	// Custom labels to be applied to the execution resource.
	Labels *Labels `protobuf:"bytes,6,opt,name=labels,proto3" json:"labels,omitempty"`
	// Custom annotations to be applied to the execution resource.
	Annotations *Annotations `protobuf:"bytes,7,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// Indicates the permission associated with workflow executions triggered with this launch plan.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/launch_plan.proto.
	Auth *Auth `protobuf:"bytes,8,opt,name=auth,proto3" json:"auth,omitempty"`
	// Deprecated: Marked as deprecated in flyteidl/admin/launch_plan.proto.
	AuthRole *AuthRole `protobuf:"bytes,9,opt,name=auth_role,json=authRole,proto3" json:"auth_role,omitempty"`
	// Indicates security context for permissions triggered with this launch plan
	SecurityContext *core.SecurityContext `protobuf:"bytes,10,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// Indicates the runtime priority of the execution.
	QualityOfService *core.QualityOfService `protobuf:"bytes,16,opt,name=quality_of_service,json=qualityOfService,proto3" json:"quality_of_service,omitempty"`
	// Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.).
	RawOutputDataConfig *RawOutputDataConfig `protobuf:"bytes,17,opt,name=raw_output_data_config,json=rawOutputDataConfig,proto3" json:"raw_output_data_config,omitempty"`
	// Controls the maximum number of tasknodes that can be run in parallel for the entire workflow.
	// This is useful to achieve fairness. Note: MapTasks are regarded as one unit,
	// and parallelism/concurrency of MapTasks is independent from this.
	MaxParallelism int32 `protobuf:"varint,18,opt,name=max_parallelism,json=maxParallelism,proto3" json:"max_parallelism,omitempty"`
	// Allows for the interruptible flag of a workflow to be overwritten for a single execution.
	// Omitting this field uses the workflow's value as a default.
	// As we need to distinguish between the field not being provided and its default value false, we have to use a wrapper
	// around the bool field.
	Interruptible *wrapperspb.BoolValue `protobuf:"bytes,19,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution.
	// If enabled, all calculations are performed even if cached results would be available, overwriting the stored
	// data once execution finishes successfully.
	OverwriteCache bool `protobuf:"varint,20,opt,name=overwrite_cache,json=overwriteCache,proto3" json:"overwrite_cache,omitempty"`
	// Environment variables to be set for the execution.
	Envs *Envs `protobuf:"bytes,21,opt,name=envs,proto3" json:"envs,omitempty"`
	// contains filtered or unexported fields
}

User-provided launch plan definition and configuration values.

func (*LaunchPlanSpec) Descriptor deprecated 

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

Deprecated: Use LaunchPlanSpec.ProtoReflect.Descriptor instead.

func (*LaunchPlanSpec) GetAnnotations 

func (x *LaunchPlanSpec) GetAnnotations() *Annotations

func (*LaunchPlanSpec) GetAuth deprecated 

func (x *LaunchPlanSpec) GetAuth() *Auth

Deprecated: Marked as deprecated in flyteidl/admin/launch_plan.proto.

func (*LaunchPlanSpec) GetAuthRole deprecated 

func (x *LaunchPlanSpec) GetAuthRole() *AuthRole

Deprecated: Marked as deprecated in flyteidl/admin/launch_plan.proto.

func (*LaunchPlanSpec) GetDefaultInputs 

func (x *LaunchPlanSpec) GetDefaultInputs() *core.ParameterMap

func (*LaunchPlanSpec) GetEntityMetadata 

func (x *LaunchPlanSpec) GetEntityMetadata() *LaunchPlanMetadata

func (*LaunchPlanSpec) GetEnvs 

func (x *LaunchPlanSpec) GetEnvs() *Envs

func (*LaunchPlanSpec) GetFixedInputs 

func (x *LaunchPlanSpec) GetFixedInputs() *core.LiteralMap

func (*LaunchPlanSpec) GetInterruptible 

func (x *LaunchPlanSpec) GetInterruptible() *wrapperspb.BoolValue

func (*LaunchPlanSpec) GetLabels 

func (x *LaunchPlanSpec) GetLabels() *Labels

func (*LaunchPlanSpec) GetMaxParallelism 

func (x *LaunchPlanSpec) GetMaxParallelism() int32

func (*LaunchPlanSpec) GetOverwriteCache 

func (x *LaunchPlanSpec) GetOverwriteCache() bool

func (*LaunchPlanSpec) GetQualityOfService 

func (x *LaunchPlanSpec) GetQualityOfService() *core.QualityOfService

func (*LaunchPlanSpec) GetRawOutputDataConfig 

func (x *LaunchPlanSpec) GetRawOutputDataConfig() *RawOutputDataConfig

func (*LaunchPlanSpec) GetRole deprecated 

func (x *LaunchPlanSpec) GetRole() string

Deprecated: Marked as deprecated in flyteidl/admin/launch_plan.proto.

func (*LaunchPlanSpec) GetSecurityContext 

func (x *LaunchPlanSpec) GetSecurityContext() *core.SecurityContext

func (*LaunchPlanSpec) GetWorkflowId 

func (x *LaunchPlanSpec) GetWorkflowId() *core.Identifier

func (*LaunchPlanSpec) ProtoMessage 

func (*LaunchPlanSpec) ProtoMessage()

func (*LaunchPlanSpec) ProtoReflect added in v1.10.7 

func (x *LaunchPlanSpec) ProtoReflect() protoreflect.Message

func (*LaunchPlanSpec) Reset 

func (x *LaunchPlanSpec) Reset()

func (*LaunchPlanSpec) String 

func (x *LaunchPlanSpec) String() string

type LaunchPlanState 

type LaunchPlanState int32

By default any launch plan regardless of state can be used to launch a workflow execution. However, at most one version of a launch plan (e.g. a NamedEntityIdentifier set of shared project, domain and name values) can be active at a time in regards to *schedules*. That is, at most one schedule in a NamedEntityIdentifier group will be observed and trigger executions at a defined cadence. 

const (
	LaunchPlanState_INACTIVE LaunchPlanState = 0
	LaunchPlanState_ACTIVE   LaunchPlanState = 1
)

func (LaunchPlanState) Descriptor added in v1.10.7 

func (LaunchPlanState) Descriptor() protoreflect.EnumDescriptor

func (LaunchPlanState) Enum added in v1.10.7 

func (x LaunchPlanState) Enum() *LaunchPlanState

func (LaunchPlanState) EnumDescriptor deprecated 

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

Deprecated: Use LaunchPlanState.Descriptor instead.

func (LaunchPlanState) Number added in v1.10.7 

func (x LaunchPlanState) Number() protoreflect.EnumNumber

func (LaunchPlanState) String 

func (x LaunchPlanState) String() string

func (LaunchPlanState) Type added in v1.10.7 

func (LaunchPlanState) Type() protoreflect.EnumType

type LaunchPlanUpdateRequest 

type LaunchPlanUpdateRequest struct {

	// Identifier of launch plan for which to change state.
	// +required.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Desired state to apply to the launch plan.
	// +required.
	State LaunchPlanState `protobuf:"varint,2,opt,name=state,proto3,enum=flyteidl.admin.LaunchPlanState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Request to set the referenced launch plan state to the configured value. See :ref:`ref_flyteidl.admin.LaunchPlan` for more details

func (*LaunchPlanUpdateRequest) Descriptor deprecated 

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

Deprecated: Use LaunchPlanUpdateRequest.ProtoReflect.Descriptor instead.

func (*LaunchPlanUpdateRequest) GetId 

func (x *LaunchPlanUpdateRequest) GetId() *core.Identifier

func (*LaunchPlanUpdateRequest) GetState 

func (x *LaunchPlanUpdateRequest) GetState() LaunchPlanState

func (*LaunchPlanUpdateRequest) ProtoMessage 

func (*LaunchPlanUpdateRequest) ProtoMessage()

func (*LaunchPlanUpdateRequest) ProtoReflect added in v1.10.7 

func (x *LaunchPlanUpdateRequest) ProtoReflect() protoreflect.Message

func (*LaunchPlanUpdateRequest) Reset 

func (x *LaunchPlanUpdateRequest) Reset()

func (*LaunchPlanUpdateRequest) String 

func (x *LaunchPlanUpdateRequest) String() string

type LaunchPlanUpdateResponse 

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

Purposefully empty, may be populated in the future.

func (*LaunchPlanUpdateResponse) Descriptor deprecated 

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

Deprecated: Use LaunchPlanUpdateResponse.ProtoReflect.Descriptor instead.

func (*LaunchPlanUpdateResponse) ProtoMessage 

func (*LaunchPlanUpdateResponse) ProtoMessage()

func (*LaunchPlanUpdateResponse) ProtoReflect added in v1.10.7 

func (x *LaunchPlanUpdateResponse) ProtoReflect() protoreflect.Message

func (*LaunchPlanUpdateResponse) Reset 

func (x *LaunchPlanUpdateResponse) Reset()

func (*LaunchPlanUpdateResponse) String 

func (x *LaunchPlanUpdateResponse) String() string

type ListAgentsRequest added in v1.10.7 

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

A request to list all agents.

func (*ListAgentsRequest) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use ListAgentsRequest.ProtoReflect.Descriptor instead.

func (*ListAgentsRequest) ProtoMessage added in v1.10.7 

func (*ListAgentsRequest) ProtoMessage()

func (*ListAgentsRequest) ProtoReflect added in v1.10.7 

func (x *ListAgentsRequest) ProtoReflect() protoreflect.Message

func (*ListAgentsRequest) Reset added in v1.10.7 

func (x *ListAgentsRequest) Reset()

func (*ListAgentsRequest) String added in v1.10.7 

func (x *ListAgentsRequest) String() string

type ListAgentsResponse added in v1.10.7 

type ListAgentsResponse struct {
	Agents []*Agent `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

A response containing a list of agents.

func (*ListAgentsResponse) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use ListAgentsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentsResponse) GetAgents added in v1.10.7 

func (x *ListAgentsResponse) GetAgents() []*Agent

func (*ListAgentsResponse) ProtoMessage added in v1.10.7 

func (*ListAgentsResponse) ProtoMessage()

func (*ListAgentsResponse) ProtoReflect added in v1.10.7 

func (x *ListAgentsResponse) ProtoReflect() protoreflect.Message

func (*ListAgentsResponse) Reset added in v1.10.7 

func (x *ListAgentsResponse) Reset()

func (*ListAgentsResponse) String added in v1.10.7 

func (x *ListAgentsResponse) String() string

type ListMatchableAttributesRequest 

type ListMatchableAttributesRequest struct {

	// +required
	ResourceType MatchableResource `` /* 136-byte string literal not displayed */
	// Optional, org filter applied to list project requests.
	Org string `protobuf:"bytes,2,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request all matching resource attributes for a resource type. See :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for more details

func (*ListMatchableAttributesRequest) Descriptor deprecated 

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

Deprecated: Use ListMatchableAttributesRequest.ProtoReflect.Descriptor instead.

func (*ListMatchableAttributesRequest) GetOrg added in v1.10.7 

func (x *ListMatchableAttributesRequest) GetOrg() string

func (*ListMatchableAttributesRequest) GetResourceType 

func (x *ListMatchableAttributesRequest) GetResourceType() MatchableResource

func (*ListMatchableAttributesRequest) ProtoMessage 

func (*ListMatchableAttributesRequest) ProtoMessage()

func (*ListMatchableAttributesRequest) ProtoReflect added in v1.10.7 

func (x *ListMatchableAttributesRequest) ProtoReflect() protoreflect.Message

func (*ListMatchableAttributesRequest) Reset 

func (x *ListMatchableAttributesRequest) Reset()

func (*ListMatchableAttributesRequest) String 

func (x *ListMatchableAttributesRequest) String() string

type ListMatchableAttributesResponse 

type ListMatchableAttributesResponse struct {
	Configurations []*MatchableAttributesConfiguration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

Response for a request for all matching resource attributes for a resource type. See :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration` for more details

func (*ListMatchableAttributesResponse) Descriptor deprecated 

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

Deprecated: Use ListMatchableAttributesResponse.ProtoReflect.Descriptor instead.

func (*ListMatchableAttributesResponse) GetConfigurations 

func (x *ListMatchableAttributesResponse) GetConfigurations() []*MatchableAttributesConfiguration

func (*ListMatchableAttributesResponse) ProtoMessage 

func (*ListMatchableAttributesResponse) ProtoMessage()

func (*ListMatchableAttributesResponse) ProtoReflect added in v1.10.7 

func (x *ListMatchableAttributesResponse) ProtoReflect() protoreflect.Message

func (*ListMatchableAttributesResponse) Reset 

func (x *ListMatchableAttributesResponse) Reset()

func (*ListMatchableAttributesResponse) String 

func (x *ListMatchableAttributesResponse) String() string

type LiteralMapBlob 

type LiteralMapBlob struct {

	// Types that are assignable to Data:
	//
	//	*LiteralMapBlob_Values
	//	*LiteralMapBlob_Uri
	Data isLiteralMapBlob_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

Input/output data can represented by actual values or a link to where values are stored

func (*LiteralMapBlob) Descriptor deprecated 

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

Deprecated: Use LiteralMapBlob.ProtoReflect.Descriptor instead.

func (*LiteralMapBlob) GetData 

func (m *LiteralMapBlob) GetData() isLiteralMapBlob_Data

func (*LiteralMapBlob) GetUri 

func (x *LiteralMapBlob) GetUri() string

func (*LiteralMapBlob) GetValues deprecated 

func (x *LiteralMapBlob) GetValues() *core.LiteralMap

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*LiteralMapBlob) ProtoMessage 

func (*LiteralMapBlob) ProtoMessage()

func (*LiteralMapBlob) ProtoReflect added in v1.10.7 

func (x *LiteralMapBlob) ProtoReflect() protoreflect.Message

func (*LiteralMapBlob) Reset 

func (x *LiteralMapBlob) Reset()

func (*LiteralMapBlob) String 

func (x *LiteralMapBlob) String() string

type LiteralMapBlob_Uri 

type LiteralMapBlob_Uri struct {
	// In the event that the map is too large, we return a uri to the data
	Uri string `protobuf:"bytes,2,opt,name=uri,proto3,oneof"`
}

type LiteralMapBlob_Values 

type LiteralMapBlob_Values struct {
	// Data in LiteralMap format
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	Values *core.LiteralMap `protobuf:"bytes,1,opt,name=values,proto3,oneof"`
}

type MatchableAttributesConfiguration 

type MatchableAttributesConfiguration struct {
	Attributes *MatchingAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	Domain     string              `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	Project    string              `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	Workflow   string              `protobuf:"bytes,4,opt,name=workflow,proto3" json:"workflow,omitempty"`
	LaunchPlan string              `protobuf:"bytes,5,opt,name=launch_plan,json=launchPlan,proto3" json:"launch_plan,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,6,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Represents a custom set of attributes applied for either a domain (and optional org); a domain and project (and optional org); or domain, project and workflow name (and optional org). These are used to override system level defaults for kubernetes cluster resource management, default execution values, and more all across different levels of specificity.

func (*MatchableAttributesConfiguration) Descriptor deprecated 

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

Deprecated: Use MatchableAttributesConfiguration.ProtoReflect.Descriptor instead.

func (*MatchableAttributesConfiguration) GetAttributes 

func (x *MatchableAttributesConfiguration) GetAttributes() *MatchingAttributes

func (*MatchableAttributesConfiguration) GetDomain 

func (x *MatchableAttributesConfiguration) GetDomain() string

func (*MatchableAttributesConfiguration) GetLaunchPlan 

func (x *MatchableAttributesConfiguration) GetLaunchPlan() string

func (*MatchableAttributesConfiguration) GetOrg added in v1.10.7 

func (x *MatchableAttributesConfiguration) GetOrg() string

func (*MatchableAttributesConfiguration) GetProject 

func (x *MatchableAttributesConfiguration) GetProject() string

func (*MatchableAttributesConfiguration) GetWorkflow 

func (x *MatchableAttributesConfiguration) GetWorkflow() string

func (*MatchableAttributesConfiguration) ProtoMessage 

func (*MatchableAttributesConfiguration) ProtoMessage()

func (*MatchableAttributesConfiguration) ProtoReflect added in v1.10.7 

func (x *MatchableAttributesConfiguration) ProtoReflect() protoreflect.Message

func (*MatchableAttributesConfiguration) Reset 

func (x *MatchableAttributesConfiguration) Reset()

func (*MatchableAttributesConfiguration) String 

func (x *MatchableAttributesConfiguration) String() string

type MatchableResource 

type MatchableResource int32

Defines a resource that can be configured by customizable Project-, ProjectDomain- or WorkflowAttributes based on matching tags. 

const (
	// Applies to customizable task resource requests and limits.
	MatchableResource_TASK_RESOURCE MatchableResource = 0
	// Applies to configuring templated kubernetes cluster resources.
	MatchableResource_CLUSTER_RESOURCE MatchableResource = 1
	// Configures task and dynamic task execution queue assignment.
	MatchableResource_EXECUTION_QUEUE MatchableResource = 2
	// Configures the K8s cluster label to be used for execution to be run
	MatchableResource_EXECUTION_CLUSTER_LABEL MatchableResource = 3
	// Configures default quality of service when undefined in an execution spec.
	MatchableResource_QUALITY_OF_SERVICE_SPECIFICATION MatchableResource = 4
	// Selects configurable plugin implementation behavior for a given task type.
	MatchableResource_PLUGIN_OVERRIDE MatchableResource = 5
	// Adds defaults for customizable workflow-execution specifications and overrides.
	MatchableResource_WORKFLOW_EXECUTION_CONFIG MatchableResource = 6
	// Controls how to select an available cluster on which this execution should run.
	MatchableResource_CLUSTER_ASSIGNMENT MatchableResource = 7
)

func (MatchableResource) Descriptor added in v1.10.7 

func (MatchableResource) Descriptor() protoreflect.EnumDescriptor

func (MatchableResource) Enum added in v1.10.7 

func (x MatchableResource) Enum() *MatchableResource

func (MatchableResource) EnumDescriptor deprecated 

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

Deprecated: Use MatchableResource.Descriptor instead.

func (MatchableResource) Number added in v1.10.7 

func (x MatchableResource) Number() protoreflect.EnumNumber

func (MatchableResource) String 

func (x MatchableResource) String() string

func (MatchableResource) Type added in v1.10.7 

func (MatchableResource) Type() protoreflect.EnumType

type MatchingAttributes 

type MatchingAttributes struct {

	// Types that are assignable to Target:
	//
	//	*MatchingAttributes_TaskResourceAttributes
	//	*MatchingAttributes_ClusterResourceAttributes
	//	*MatchingAttributes_ExecutionQueueAttributes
	//	*MatchingAttributes_ExecutionClusterLabel
	//	*MatchingAttributes_QualityOfService
	//	*MatchingAttributes_PluginOverrides
	//	*MatchingAttributes_WorkflowExecutionConfig
	//	*MatchingAttributes_ClusterAssignment
	Target isMatchingAttributes_Target `protobuf_oneof:"target"`
	// contains filtered or unexported fields
}

Generic container for encapsulating all types of the above attributes messages.

func (*MatchingAttributes) Descriptor deprecated 

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

Deprecated: Use MatchingAttributes.ProtoReflect.Descriptor instead.

func (*MatchingAttributes) GetClusterAssignment 

func (x *MatchingAttributes) GetClusterAssignment() *ClusterAssignment

func (*MatchingAttributes) GetClusterResourceAttributes 

func (x *MatchingAttributes) GetClusterResourceAttributes() *ClusterResourceAttributes

func (*MatchingAttributes) GetExecutionClusterLabel 

func (x *MatchingAttributes) GetExecutionClusterLabel() *ExecutionClusterLabel

func (*MatchingAttributes) GetExecutionQueueAttributes 

func (x *MatchingAttributes) GetExecutionQueueAttributes() *ExecutionQueueAttributes

func (*MatchingAttributes) GetPluginOverrides 

func (x *MatchingAttributes) GetPluginOverrides() *PluginOverrides

func (*MatchingAttributes) GetQualityOfService 

func (x *MatchingAttributes) GetQualityOfService() *core.QualityOfService

func (*MatchingAttributes) GetTarget 

func (m *MatchingAttributes) GetTarget() isMatchingAttributes_Target

func (*MatchingAttributes) GetTaskResourceAttributes 

func (x *MatchingAttributes) GetTaskResourceAttributes() *TaskResourceAttributes

func (*MatchingAttributes) GetWorkflowExecutionConfig 

func (x *MatchingAttributes) GetWorkflowExecutionConfig() *WorkflowExecutionConfig

func (*MatchingAttributes) ProtoMessage 

func (*MatchingAttributes) ProtoMessage()

func (*MatchingAttributes) ProtoReflect added in v1.10.7 

func (x *MatchingAttributes) ProtoReflect() protoreflect.Message

func (*MatchingAttributes) Reset 

func (x *MatchingAttributes) Reset()

func (*MatchingAttributes) String 

func (x *MatchingAttributes) String() string

type MatchingAttributes_ClusterAssignment 

type MatchingAttributes_ClusterAssignment struct {
	ClusterAssignment *ClusterAssignment `protobuf:"bytes,8,opt,name=cluster_assignment,json=clusterAssignment,proto3,oneof"`
}

type MatchingAttributes_ClusterResourceAttributes 

type MatchingAttributes_ClusterResourceAttributes struct {
	ClusterResourceAttributes *ClusterResourceAttributes `protobuf:"bytes,2,opt,name=cluster_resource_attributes,json=clusterResourceAttributes,proto3,oneof"`
}

type MatchingAttributes_ExecutionClusterLabel 

type MatchingAttributes_ExecutionClusterLabel struct {
	ExecutionClusterLabel *ExecutionClusterLabel `protobuf:"bytes,4,opt,name=execution_cluster_label,json=executionClusterLabel,proto3,oneof"`
}

type MatchingAttributes_ExecutionQueueAttributes 

type MatchingAttributes_ExecutionQueueAttributes struct {
	ExecutionQueueAttributes *ExecutionQueueAttributes `protobuf:"bytes,3,opt,name=execution_queue_attributes,json=executionQueueAttributes,proto3,oneof"`
}

type MatchingAttributes_PluginOverrides 

type MatchingAttributes_PluginOverrides struct {
	PluginOverrides *PluginOverrides `protobuf:"bytes,6,opt,name=plugin_overrides,json=pluginOverrides,proto3,oneof"`
}

type MatchingAttributes_QualityOfService 

type MatchingAttributes_QualityOfService struct {
	QualityOfService *core.QualityOfService `protobuf:"bytes,5,opt,name=quality_of_service,json=qualityOfService,proto3,oneof"`
}

type MatchingAttributes_TaskResourceAttributes 

type MatchingAttributes_TaskResourceAttributes struct {
	TaskResourceAttributes *TaskResourceAttributes `protobuf:"bytes,1,opt,name=task_resource_attributes,json=taskResourceAttributes,proto3,oneof"`
}

type MatchingAttributes_WorkflowExecutionConfig 

type MatchingAttributes_WorkflowExecutionConfig struct {
	WorkflowExecutionConfig *WorkflowExecutionConfig `protobuf:"bytes,7,opt,name=workflow_execution_config,json=workflowExecutionConfig,proto3,oneof"`
}

type NamedEntity 

type NamedEntity struct {

	// Resource type of the named entity. One of Task, Workflow or LaunchPlan.
	ResourceType core.ResourceType      `` /* 130-byte string literal not displayed */
	Id           *NamedEntityIdentifier `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Additional metadata around a named entity.
	Metadata *NamedEntityMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates information common to a NamedEntity, a Flyte resource such as a task, workflow or launch plan. A NamedEntity is exclusively identified by its resource type and identifier.

func (*NamedEntity) Descriptor deprecated 

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

Deprecated: Use NamedEntity.ProtoReflect.Descriptor instead.

func (*NamedEntity) GetId 

func (x *NamedEntity) GetId() *NamedEntityIdentifier

func (*NamedEntity) GetMetadata 

func (x *NamedEntity) GetMetadata() *NamedEntityMetadata

func (*NamedEntity) GetResourceType 

func (x *NamedEntity) GetResourceType() core.ResourceType

func (*NamedEntity) ProtoMessage 

func (*NamedEntity) ProtoMessage()

func (*NamedEntity) ProtoReflect added in v1.10.7 

func (x *NamedEntity) ProtoReflect() protoreflect.Message

func (*NamedEntity) Reset 

func (x *NamedEntity) Reset()

func (*NamedEntity) String 

func (x *NamedEntity) String() string

type NamedEntityGetRequest 

type NamedEntityGetRequest struct {

	// Resource type of the metadata to get. One of Task, Workflow or LaunchPlan.
	// +required
	ResourceType core.ResourceType `` /* 130-byte string literal not displayed */
	// The identifier for the named entity for which to fetch metadata.
	// +required
	Id *NamedEntityIdentifier `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A request to retrieve the metadata associated with a NamedEntityIdentifier

func (*NamedEntityGetRequest) Descriptor deprecated 

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

Deprecated: Use NamedEntityGetRequest.ProtoReflect.Descriptor instead.

func (*NamedEntityGetRequest) GetId 

func (x *NamedEntityGetRequest) GetId() *NamedEntityIdentifier

func (*NamedEntityGetRequest) GetResourceType 

func (x *NamedEntityGetRequest) GetResourceType() core.ResourceType

func (*NamedEntityGetRequest) ProtoMessage 

func (*NamedEntityGetRequest) ProtoMessage()

func (*NamedEntityGetRequest) ProtoReflect added in v1.10.7 

func (x *NamedEntityGetRequest) ProtoReflect() protoreflect.Message

func (*NamedEntityGetRequest) Reset 

func (x *NamedEntityGetRequest) Reset()

func (*NamedEntityGetRequest) String 

func (x *NamedEntityGetRequest) String() string

type NamedEntityIdentifier 

type NamedEntityIdentifier 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 provided value for the resource.
	// The combination of project + domain + name uniquely identifies the resource.
	// +optional - in certain contexts - like 'List API', 'Launch plans'
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,4,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Encapsulation of fields that identifies a Flyte resource. A Flyte resource can be a task, workflow or launch plan. A resource can internally have multiple versions and is uniquely identified by project, domain, and name.

func (*NamedEntityIdentifier) Descriptor deprecated 

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

Deprecated: Use NamedEntityIdentifier.ProtoReflect.Descriptor instead.

func (*NamedEntityIdentifier) GetDomain 

func (x *NamedEntityIdentifier) GetDomain() string

func (*NamedEntityIdentifier) GetName 

func (x *NamedEntityIdentifier) GetName() string

func (*NamedEntityIdentifier) GetOrg added in v1.10.7 

func (x *NamedEntityIdentifier) GetOrg() string

func (*NamedEntityIdentifier) GetProject 

func (x *NamedEntityIdentifier) GetProject() string

func (*NamedEntityIdentifier) ProtoMessage 

func (*NamedEntityIdentifier) ProtoMessage()

func (*NamedEntityIdentifier) ProtoReflect added in v1.10.7 

func (x *NamedEntityIdentifier) ProtoReflect() protoreflect.Message

func (*NamedEntityIdentifier) Reset 

func (x *NamedEntityIdentifier) Reset()

func (*NamedEntityIdentifier) String 

func (x *NamedEntityIdentifier) String() string

type NamedEntityIdentifierList 

type NamedEntityIdentifierList struct {

	// A list of identifiers.
	Entities []*NamedEntityIdentifier `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Represents a list of NamedEntityIdentifiers.

func (*NamedEntityIdentifierList) Descriptor deprecated 

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

Deprecated: Use NamedEntityIdentifierList.ProtoReflect.Descriptor instead.

func (*NamedEntityIdentifierList) GetEntities 

func (x *NamedEntityIdentifierList) GetEntities() []*NamedEntityIdentifier

func (*NamedEntityIdentifierList) GetToken 

func (x *NamedEntityIdentifierList) GetToken() string

func (*NamedEntityIdentifierList) ProtoMessage 

func (*NamedEntityIdentifierList) ProtoMessage()

func (*NamedEntityIdentifierList) ProtoReflect added in v1.10.7 

func (x *NamedEntityIdentifierList) ProtoReflect() protoreflect.Message

func (*NamedEntityIdentifierList) Reset 

func (x *NamedEntityIdentifierList) Reset()

func (*NamedEntityIdentifierList) String 

func (x *NamedEntityIdentifierList) String() string

type NamedEntityIdentifierListRequest 

type NamedEntityIdentifierListRequest struct {

	// Name of the project that contains the identifiers.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the identifiers belongs to within the project.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Indicates the number of resources to be returned.
	// +required
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// Specifies how listed entities should be sorted in the response.
	// +optional
	SortBy *Sort `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// Indicates a list of filters passed as string.
	// +optional
	Filters string `protobuf:"bytes,6,opt,name=filters,proto3" json:"filters,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,7,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to list NamedEntityIdentifiers.

func (*NamedEntityIdentifierListRequest) Descriptor deprecated 

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

Deprecated: Use NamedEntityIdentifierListRequest.ProtoReflect.Descriptor instead.

func (*NamedEntityIdentifierListRequest) GetDomain 

func (x *NamedEntityIdentifierListRequest) GetDomain() string

func (*NamedEntityIdentifierListRequest) GetFilters 

func (x *NamedEntityIdentifierListRequest) GetFilters() string

func (*NamedEntityIdentifierListRequest) GetLimit 

func (x *NamedEntityIdentifierListRequest) GetLimit() uint32

func (*NamedEntityIdentifierListRequest) GetOrg added in v1.10.7 

func (x *NamedEntityIdentifierListRequest) GetOrg() string

func (*NamedEntityIdentifierListRequest) GetProject 

func (x *NamedEntityIdentifierListRequest) GetProject() string

func (*NamedEntityIdentifierListRequest) GetSortBy 

func (x *NamedEntityIdentifierListRequest) GetSortBy() *Sort

func (*NamedEntityIdentifierListRequest) GetToken 

func (x *NamedEntityIdentifierListRequest) GetToken() string

func (*NamedEntityIdentifierListRequest) ProtoMessage 

func (*NamedEntityIdentifierListRequest) ProtoMessage()

func (*NamedEntityIdentifierListRequest) ProtoReflect added in v1.10.7 

func (x *NamedEntityIdentifierListRequest) ProtoReflect() protoreflect.Message

func (*NamedEntityIdentifierListRequest) Reset 

func (x *NamedEntityIdentifierListRequest) Reset()

func (*NamedEntityIdentifierListRequest) String 

func (x *NamedEntityIdentifierListRequest) String() string

type NamedEntityList 

type NamedEntityList struct {

	// A list of NamedEntity objects
	Entities []*NamedEntity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Represents a list of NamedEntityIdentifiers.

func (*NamedEntityList) Descriptor deprecated 

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

Deprecated: Use NamedEntityList.ProtoReflect.Descriptor instead.

func (*NamedEntityList) GetEntities 

func (x *NamedEntityList) GetEntities() []*NamedEntity

func (*NamedEntityList) GetToken 

func (x *NamedEntityList) GetToken() string

func (*NamedEntityList) ProtoMessage 

func (*NamedEntityList) ProtoMessage()

func (*NamedEntityList) ProtoReflect added in v1.10.7 

func (x *NamedEntityList) ProtoReflect() protoreflect.Message

func (*NamedEntityList) Reset 

func (x *NamedEntityList) Reset()

func (*NamedEntityList) String 

func (x *NamedEntityList) String() string

type NamedEntityListRequest 

type NamedEntityListRequest struct {

	// Resource type of the metadata to query. One of Task, Workflow or LaunchPlan.
	// +required
	ResourceType core.ResourceType `` /* 130-byte string literal not displayed */
	// Name of the project that contains the identifiers.
	// +required
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the identifiers belongs to within the project.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// Indicates the number of resources to be returned.
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	// Specifies how listed entities should be sorted in the response.
	// +optional
	SortBy *Sort `protobuf:"bytes,6,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// Indicates a list of filters passed as string.
	// +optional
	Filters string `protobuf:"bytes,7,opt,name=filters,proto3" json:"filters,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,8,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to list NamedEntity objects

func (*NamedEntityListRequest) Descriptor deprecated 

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

Deprecated: Use NamedEntityListRequest.ProtoReflect.Descriptor instead.

func (*NamedEntityListRequest) GetDomain 

func (x *NamedEntityListRequest) GetDomain() string

func (*NamedEntityListRequest) GetFilters 

func (x *NamedEntityListRequest) GetFilters() string

func (*NamedEntityListRequest) GetLimit 

func (x *NamedEntityListRequest) GetLimit() uint32

func (*NamedEntityListRequest) GetOrg added in v1.10.7 

func (x *NamedEntityListRequest) GetOrg() string

func (*NamedEntityListRequest) GetProject 

func (x *NamedEntityListRequest) GetProject() string

func (*NamedEntityListRequest) GetResourceType 

func (x *NamedEntityListRequest) GetResourceType() core.ResourceType

func (*NamedEntityListRequest) GetSortBy 

func (x *NamedEntityListRequest) GetSortBy() *Sort

func (*NamedEntityListRequest) GetToken 

func (x *NamedEntityListRequest) GetToken() string

func (*NamedEntityListRequest) ProtoMessage 

func (*NamedEntityListRequest) ProtoMessage()

func (*NamedEntityListRequest) ProtoReflect added in v1.10.7 

func (x *NamedEntityListRequest) ProtoReflect() protoreflect.Message

func (*NamedEntityListRequest) Reset 

func (x *NamedEntityListRequest) Reset()

func (*NamedEntityListRequest) String 

func (x *NamedEntityListRequest) String() string

type NamedEntityMetadata 

type NamedEntityMetadata struct {

	// Common description across all versions of the entity
	// +optional
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// Shared state across all version of the entity
	// At this point in time, only workflow entities can have their state archived.
	State NamedEntityState `protobuf:"varint,2,opt,name=state,proto3,enum=flyteidl.admin.NamedEntityState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Additional metadata around a named entity.

func (*NamedEntityMetadata) Descriptor deprecated 

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

Deprecated: Use NamedEntityMetadata.ProtoReflect.Descriptor instead.

func (*NamedEntityMetadata) GetDescription 

func (x *NamedEntityMetadata) GetDescription() string

func (*NamedEntityMetadata) GetState 

func (x *NamedEntityMetadata) GetState() NamedEntityState

func (*NamedEntityMetadata) ProtoMessage 

func (*NamedEntityMetadata) ProtoMessage()

func (*NamedEntityMetadata) ProtoReflect added in v1.10.7 

func (x *NamedEntityMetadata) ProtoReflect() protoreflect.Message

func (*NamedEntityMetadata) Reset 

func (x *NamedEntityMetadata) Reset()

func (*NamedEntityMetadata) String 

func (x *NamedEntityMetadata) String() string

type NamedEntityState 

type NamedEntityState int32

The status of the named entity is used to control its visibility in the UI. 

const (
	// By default, all named entities are considered active and under development.
	NamedEntityState_NAMED_ENTITY_ACTIVE NamedEntityState = 0
	// Archived named entities are no longer visible in the UI.
	NamedEntityState_NAMED_ENTITY_ARCHIVED NamedEntityState = 1
	// System generated entities that aren't explicitly created or managed by a user.
	NamedEntityState_SYSTEM_GENERATED NamedEntityState = 2
)

func (NamedEntityState) Descriptor added in v1.10.7 

func (NamedEntityState) Descriptor() protoreflect.EnumDescriptor

func (NamedEntityState) Enum added in v1.10.7 

func (x NamedEntityState) Enum() *NamedEntityState

func (NamedEntityState) EnumDescriptor deprecated 

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

Deprecated: Use NamedEntityState.Descriptor instead.

func (NamedEntityState) Number added in v1.10.7 

func (x NamedEntityState) Number() protoreflect.EnumNumber

func (NamedEntityState) String 

func (x NamedEntityState) String() string

func (NamedEntityState) Type added in v1.10.7 

func (NamedEntityState) Type() protoreflect.EnumType

type NamedEntityUpdateRequest 

type NamedEntityUpdateRequest struct {

	// Resource type of the metadata to update
	// +required
	ResourceType core.ResourceType `` /* 130-byte string literal not displayed */
	// Identifier of the metadata to update
	// +required
	Id *NamedEntityIdentifier `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Metadata object to set as the new value
	// +required
	Metadata *NamedEntityMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Request to set the referenced named entity state to the configured value.

func (*NamedEntityUpdateRequest) Descriptor deprecated 

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

Deprecated: Use NamedEntityUpdateRequest.ProtoReflect.Descriptor instead.

func (*NamedEntityUpdateRequest) GetId 

func (x *NamedEntityUpdateRequest) GetId() *NamedEntityIdentifier

func (*NamedEntityUpdateRequest) GetMetadata 

func (x *NamedEntityUpdateRequest) GetMetadata() *NamedEntityMetadata

func (*NamedEntityUpdateRequest) GetResourceType 

func (x *NamedEntityUpdateRequest) GetResourceType() core.ResourceType

func (*NamedEntityUpdateRequest) ProtoMessage 

func (*NamedEntityUpdateRequest) ProtoMessage()

func (*NamedEntityUpdateRequest) ProtoReflect added in v1.10.7 

func (x *NamedEntityUpdateRequest) ProtoReflect() protoreflect.Message

func (*NamedEntityUpdateRequest) Reset 

func (x *NamedEntityUpdateRequest) Reset()

func (*NamedEntityUpdateRequest) String 

func (x *NamedEntityUpdateRequest) String() string

type NamedEntityUpdateResponse 

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

Purposefully empty, may be populated in the future.

func (*NamedEntityUpdateResponse) Descriptor deprecated 

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

Deprecated: Use NamedEntityUpdateResponse.ProtoReflect.Descriptor instead.

func (*NamedEntityUpdateResponse) ProtoMessage 

func (*NamedEntityUpdateResponse) ProtoMessage()

func (*NamedEntityUpdateResponse) ProtoReflect added in v1.10.7 

func (x *NamedEntityUpdateResponse) ProtoReflect() protoreflect.Message

func (*NamedEntityUpdateResponse) Reset 

func (x *NamedEntityUpdateResponse) Reset()

func (*NamedEntityUpdateResponse) String 

func (x *NamedEntityUpdateResponse) String() string

type NodeExecution 

type NodeExecution struct {

	// Uniquely identifies an individual node execution.
	Id *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Path to remote data store where input blob is stored.
	InputUri string `protobuf:"bytes,2,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Computed results associated with this node execution.
	Closure *NodeExecutionClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	// Metadata for Node Execution
	Metadata *NodeExecutionMetaData `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates all details for a single node execution entity. A node represents a component in the overall workflow graph. A node launch a task, multiple tasks, an entire nested sub-workflow, or even a separate child-workflow execution. The same task can be called repeatedly in a single workflow but each node is unique.

func (*NodeExecution) Descriptor deprecated 

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

Deprecated: Use NodeExecution.ProtoReflect.Descriptor instead.

func (*NodeExecution) GetClosure 

func (x *NodeExecution) GetClosure() *NodeExecutionClosure

func (*NodeExecution) GetId 

func (x *NodeExecution) GetId() *core.NodeExecutionIdentifier

func (*NodeExecution) GetInputUri 

func (x *NodeExecution) GetInputUri() string

func (*NodeExecution) GetMetadata 

func (x *NodeExecution) GetMetadata() *NodeExecutionMetaData

func (*NodeExecution) ProtoMessage 

func (*NodeExecution) ProtoMessage()

func (*NodeExecution) ProtoReflect added in v1.10.7 

func (x *NodeExecution) ProtoReflect() protoreflect.Message

func (*NodeExecution) Reset 

func (x *NodeExecution) Reset()

func (*NodeExecution) String 

func (x *NodeExecution) String() string

type NodeExecutionClosure 

type NodeExecutionClosure struct {

	// Only a node in a terminal state will have a non-empty output_result.
	//
	// Types that are assignable to OutputResult:
	//
	//	*NodeExecutionClosure_OutputUri
	//	*NodeExecutionClosure_Error
	//	*NodeExecutionClosure_OutputData
	OutputResult isNodeExecutionClosure_OutputResult `protobuf_oneof:"output_result"`
	// The last recorded phase for this node execution.
	Phase core.NodeExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.NodeExecution_Phase" json:"phase,omitempty"`
	// Time at which the node execution began running.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// The amount of time the node execution spent running.
	Duration *durationpb.Duration `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"`
	// Time at which the node execution was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Time at which the node execution was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Store metadata for what the node launched.
	// for ex: if this is a workflow node, we store information for the launched workflow.
	//
	// Types that are assignable to TargetMetadata:
	//
	//	*NodeExecutionClosure_WorkflowNodeMetadata
	//	*NodeExecutionClosure_TaskNodeMetadata
	TargetMetadata isNodeExecutionClosure_TargetMetadata `protobuf_oneof:"target_metadata"`
	// String location uniquely identifying where the deck HTML file is.
	// NativeUrl specifies the url in the format of the configured storage provider (e.g. s3://my-bucket/randomstring/suffix.tar)
	DeckUri string `protobuf:"bytes,11,opt,name=deck_uri,json=deckUri,proto3" json:"deck_uri,omitempty"`
	// dynamic_job_spec_uri is the location of the DynamicJobSpec proto message for a DynamicWorkflow. This is required
	// to correctly recover partially completed executions where the subworkflow has already been compiled.
	DynamicJobSpecUri string `protobuf:"bytes,12,opt,name=dynamic_job_spec_uri,json=dynamicJobSpecUri,proto3" json:"dynamic_job_spec_uri,omitempty"`
	// contains filtered or unexported fields
}

Container for node execution details and results.

func (*NodeExecutionClosure) Descriptor deprecated 

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

Deprecated: Use NodeExecutionClosure.ProtoReflect.Descriptor instead.

func (*NodeExecutionClosure) GetCreatedAt 

func (x *NodeExecutionClosure) GetCreatedAt() *timestamppb.Timestamp

func (*NodeExecutionClosure) GetDeckUri 

func (x *NodeExecutionClosure) GetDeckUri() string

func (*NodeExecutionClosure) GetDuration 

func (x *NodeExecutionClosure) GetDuration() *durationpb.Duration

func (*NodeExecutionClosure) GetDynamicJobSpecUri 

func (x *NodeExecutionClosure) GetDynamicJobSpecUri() string

func (*NodeExecutionClosure) GetError 

func (x *NodeExecutionClosure) GetError() *core.ExecutionError

func (*NodeExecutionClosure) GetOutputData deprecated 

func (x *NodeExecutionClosure) GetOutputData() *core.LiteralMap

Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.

func (*NodeExecutionClosure) GetOutputResult 

func (m *NodeExecutionClosure) GetOutputResult() isNodeExecutionClosure_OutputResult

func (*NodeExecutionClosure) GetOutputUri deprecated 

func (x *NodeExecutionClosure) GetOutputUri() string

Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.

func (*NodeExecutionClosure) GetPhase 

func (x *NodeExecutionClosure) GetPhase() core.NodeExecution_Phase

func (*NodeExecutionClosure) GetStartedAt 

func (x *NodeExecutionClosure) GetStartedAt() *timestamppb.Timestamp

func (*NodeExecutionClosure) GetTargetMetadata 

func (m *NodeExecutionClosure) GetTargetMetadata() isNodeExecutionClosure_TargetMetadata

func (*NodeExecutionClosure) GetTaskNodeMetadata 

func (x *NodeExecutionClosure) GetTaskNodeMetadata() *TaskNodeMetadata

func (*NodeExecutionClosure) GetUpdatedAt 

func (x *NodeExecutionClosure) GetUpdatedAt() *timestamppb.Timestamp

func (*NodeExecutionClosure) GetWorkflowNodeMetadata 

func (x *NodeExecutionClosure) GetWorkflowNodeMetadata() *WorkflowNodeMetadata

func (*NodeExecutionClosure) ProtoMessage 

func (*NodeExecutionClosure) ProtoMessage()

func (*NodeExecutionClosure) ProtoReflect added in v1.10.7 

func (x *NodeExecutionClosure) ProtoReflect() protoreflect.Message

func (*NodeExecutionClosure) Reset 

func (x *NodeExecutionClosure) Reset()

func (*NodeExecutionClosure) String 

func (x *NodeExecutionClosure) String() string

type NodeExecutionClosure_Error 

type NodeExecutionClosure_Error struct {
	// Error information for the Node
	Error *core.ExecutionError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type NodeExecutionClosure_OutputData 

type NodeExecutionClosure_OutputData struct {
	// Raw output data produced by this node execution.
	// DEPRECATED. Use GetNodeExecutionData to fetch output data instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.
	OutputData *core.LiteralMap `protobuf:"bytes,10,opt,name=output_data,json=outputData,proto3,oneof"`
}

type NodeExecutionClosure_OutputUri 

type NodeExecutionClosure_OutputUri struct {
	// Links to a remotely stored, serialized core.LiteralMap of node execution outputs.
	// DEPRECATED. Use GetNodeExecutionData to fetch output data instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.
	OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type NodeExecutionClosure_TaskNodeMetadata 

type NodeExecutionClosure_TaskNodeMetadata struct {
	TaskNodeMetadata *TaskNodeMetadata `protobuf:"bytes,9,opt,name=task_node_metadata,json=taskNodeMetadata,proto3,oneof"`
}

type NodeExecutionClosure_WorkflowNodeMetadata 

type NodeExecutionClosure_WorkflowNodeMetadata struct {
	WorkflowNodeMetadata *WorkflowNodeMetadata `protobuf:"bytes,8,opt,name=workflow_node_metadata,json=workflowNodeMetadata,proto3,oneof"`
}

type NodeExecutionEventRequest 

type NodeExecutionEventRequest struct {

	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event *event.NodeExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

Request to send a notification that a node execution event has occurred.

func (*NodeExecutionEventRequest) Descriptor deprecated 

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

Deprecated: Use NodeExecutionEventRequest.ProtoReflect.Descriptor instead.

func (*NodeExecutionEventRequest) GetEvent 

func (x *NodeExecutionEventRequest) GetEvent() *event.NodeExecutionEvent

func (*NodeExecutionEventRequest) GetRequestId 

func (x *NodeExecutionEventRequest) GetRequestId() string

func (*NodeExecutionEventRequest) ProtoMessage 

func (*NodeExecutionEventRequest) ProtoMessage()

func (*NodeExecutionEventRequest) ProtoReflect added in v1.10.7 

func (x *NodeExecutionEventRequest) ProtoReflect() protoreflect.Message

func (*NodeExecutionEventRequest) Reset 

func (x *NodeExecutionEventRequest) Reset()

func (*NodeExecutionEventRequest) String 

func (x *NodeExecutionEventRequest) String() string

type NodeExecutionEventResponse 

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

func (*NodeExecutionEventResponse) Descriptor deprecated 

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

Deprecated: Use NodeExecutionEventResponse.ProtoReflect.Descriptor instead.

func (*NodeExecutionEventResponse) ProtoMessage 

func (*NodeExecutionEventResponse) ProtoMessage()

func (*NodeExecutionEventResponse) ProtoReflect added in v1.10.7 

func (x *NodeExecutionEventResponse) ProtoReflect() protoreflect.Message

func (*NodeExecutionEventResponse) Reset 

func (x *NodeExecutionEventResponse) Reset()

func (*NodeExecutionEventResponse) String 

func (x *NodeExecutionEventResponse) String() string

type NodeExecutionForTaskListRequest 

type NodeExecutionForTaskListRequest struct {

	// Indicates the node execution to filter by.
	// +required
	TaskExecutionId *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=task_execution_id,json=taskExecutionId,proto3" json:"task_execution_id,omitempty"`
	// Indicates the number of resources to be returned.
	// +required
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the, server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering.
	// +optional
	SortBy *Sort `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to retrieve a list of node execution entities launched by a specific task. This can arise when a task yields a subworkflow.

func (*NodeExecutionForTaskListRequest) Descriptor deprecated 

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

Deprecated: Use NodeExecutionForTaskListRequest.ProtoReflect.Descriptor instead.

func (*NodeExecutionForTaskListRequest) GetFilters 

func (x *NodeExecutionForTaskListRequest) GetFilters() string

func (*NodeExecutionForTaskListRequest) GetLimit 

func (x *NodeExecutionForTaskListRequest) GetLimit() uint32

func (*NodeExecutionForTaskListRequest) GetSortBy 

func (x *NodeExecutionForTaskListRequest) GetSortBy() *Sort

func (*NodeExecutionForTaskListRequest) GetTaskExecutionId 

func (x *NodeExecutionForTaskListRequest) GetTaskExecutionId() *core.TaskExecutionIdentifier

func (*NodeExecutionForTaskListRequest) GetToken 

func (x *NodeExecutionForTaskListRequest) GetToken() string

func (*NodeExecutionForTaskListRequest) ProtoMessage 

func (*NodeExecutionForTaskListRequest) ProtoMessage()

func (*NodeExecutionForTaskListRequest) ProtoReflect added in v1.10.7 

func (x *NodeExecutionForTaskListRequest) ProtoReflect() protoreflect.Message

func (*NodeExecutionForTaskListRequest) Reset 

func (x *NodeExecutionForTaskListRequest) Reset()

func (*NodeExecutionForTaskListRequest) String 

func (x *NodeExecutionForTaskListRequest) String() string

type NodeExecutionGetDataRequest 

type NodeExecutionGetDataRequest struct {

	// The identifier of the node execution for which to fetch inputs and outputs.
	Id *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Request structure to fetch inputs and output for a node execution. By default, these are not returned in :ref:`ref_flyteidl.admin.NodeExecutionGetRequest`

func (*NodeExecutionGetDataRequest) Descriptor deprecated 

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

Deprecated: Use NodeExecutionGetDataRequest.ProtoReflect.Descriptor instead.

func (*NodeExecutionGetDataRequest) GetId 

func (x *NodeExecutionGetDataRequest) GetId() *core.NodeExecutionIdentifier

func (*NodeExecutionGetDataRequest) ProtoMessage 

func (*NodeExecutionGetDataRequest) ProtoMessage()

func (*NodeExecutionGetDataRequest) ProtoReflect added in v1.10.7 

func (x *NodeExecutionGetDataRequest) ProtoReflect() protoreflect.Message

func (*NodeExecutionGetDataRequest) Reset 

func (x *NodeExecutionGetDataRequest) Reset()

func (*NodeExecutionGetDataRequest) String 

func (x *NodeExecutionGetDataRequest) String() string

type NodeExecutionGetDataResponse 

type NodeExecutionGetDataResponse struct {

	// Signed url to fetch a core.LiteralMap of node execution inputs.
	// Deprecated: Please use full_inputs instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.
	Inputs *UrlBlob `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of node execution outputs.
	// Deprecated: Please use full_outputs instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.
	Outputs *UrlBlob `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// Full_inputs will only be populated if they are under a configured size threshold.
	FullInputs *core.LiteralMap `protobuf:"bytes,3,opt,name=full_inputs,json=fullInputs,proto3" json:"full_inputs,omitempty"`
	// Full_outputs will only be populated if they are under a configured size threshold.
	FullOutputs *core.LiteralMap `protobuf:"bytes,4,opt,name=full_outputs,json=fullOutputs,proto3" json:"full_outputs,omitempty"`
	// Optional Workflow closure for a dynamically generated workflow, in the case this node yields a dynamic workflow we return its structure here.
	DynamicWorkflow *DynamicWorkflowNodeMetadata `protobuf:"bytes,16,opt,name=dynamic_workflow,json=dynamicWorkflow,proto3" json:"dynamic_workflow,omitempty"`
	FlyteUrls       *FlyteURLs                   `protobuf:"bytes,17,opt,name=flyte_urls,json=flyteUrls,proto3" json:"flyte_urls,omitempty"`
	// contains filtered or unexported fields
}

Response structure for NodeExecutionGetDataRequest which contains inputs and outputs for a node execution.

func (*NodeExecutionGetDataResponse) Descriptor deprecated 

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

Deprecated: Use NodeExecutionGetDataResponse.ProtoReflect.Descriptor instead.

func (*NodeExecutionGetDataResponse) GetDynamicWorkflow 

func (x *NodeExecutionGetDataResponse) GetDynamicWorkflow() *DynamicWorkflowNodeMetadata

func (*NodeExecutionGetDataResponse) GetFlyteUrls 

func (x *NodeExecutionGetDataResponse) GetFlyteUrls() *FlyteURLs

func (*NodeExecutionGetDataResponse) GetFullInputs 

func (x *NodeExecutionGetDataResponse) GetFullInputs() *core.LiteralMap

func (*NodeExecutionGetDataResponse) GetFullOutputs 

func (x *NodeExecutionGetDataResponse) GetFullOutputs() *core.LiteralMap

func (*NodeExecutionGetDataResponse) GetInputs deprecated 

func (x *NodeExecutionGetDataResponse) GetInputs() *UrlBlob

Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.

func (*NodeExecutionGetDataResponse) GetOutputs deprecated 

func (x *NodeExecutionGetDataResponse) GetOutputs() *UrlBlob

Deprecated: Marked as deprecated in flyteidl/admin/node_execution.proto.

func (*NodeExecutionGetDataResponse) ProtoMessage 

func (*NodeExecutionGetDataResponse) ProtoMessage()

func (*NodeExecutionGetDataResponse) ProtoReflect added in v1.10.7 

func (x *NodeExecutionGetDataResponse) ProtoReflect() protoreflect.Message

func (*NodeExecutionGetDataResponse) Reset 

func (x *NodeExecutionGetDataResponse) Reset()

func (*NodeExecutionGetDataResponse) String 

func (x *NodeExecutionGetDataResponse) String() string

type NodeExecutionGetRequest 

type NodeExecutionGetRequest struct {

	// Uniquely identifies an individual node execution.
	// +required
	Id *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A message used to fetch a single node execution entity. See :ref:`ref_flyteidl.admin.NodeExecution` for more details

func (*NodeExecutionGetRequest) Descriptor deprecated 

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

Deprecated: Use NodeExecutionGetRequest.ProtoReflect.Descriptor instead.

func (*NodeExecutionGetRequest) GetId 

func (x *NodeExecutionGetRequest) GetId() *core.NodeExecutionIdentifier

func (*NodeExecutionGetRequest) ProtoMessage 

func (*NodeExecutionGetRequest) ProtoMessage()

func (*NodeExecutionGetRequest) ProtoReflect added in v1.10.7 

func (x *NodeExecutionGetRequest) ProtoReflect() protoreflect.Message

func (*NodeExecutionGetRequest) Reset 

func (x *NodeExecutionGetRequest) Reset()

func (*NodeExecutionGetRequest) String 

func (x *NodeExecutionGetRequest) String() string

type NodeExecutionList 

type NodeExecutionList struct {
	NodeExecutions []*NodeExecution `protobuf:"bytes,1,rep,name=node_executions,json=nodeExecutions,proto3" json:"node_executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Request structure to retrieve a list of node execution entities. See :ref:`ref_flyteidl.admin.NodeExecution` for more details

func (*NodeExecutionList) Descriptor deprecated 

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

Deprecated: Use NodeExecutionList.ProtoReflect.Descriptor instead.

func (*NodeExecutionList) GetNodeExecutions 

func (x *NodeExecutionList) GetNodeExecutions() []*NodeExecution

func (*NodeExecutionList) GetToken 

func (x *NodeExecutionList) GetToken() string

func (*NodeExecutionList) ProtoMessage 

func (*NodeExecutionList) ProtoMessage()

func (*NodeExecutionList) ProtoReflect added in v1.10.7 

func (x *NodeExecutionList) ProtoReflect() protoreflect.Message

func (*NodeExecutionList) Reset 

func (x *NodeExecutionList) Reset()

func (*NodeExecutionList) String 

func (x *NodeExecutionList) String() string

type NodeExecutionListRequest 

type NodeExecutionListRequest struct {

	// Indicates the workflow execution to filter by.
	// +required
	WorkflowExecutionId *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=workflow_execution_id,json=workflowExecutionId,proto3" json:"workflow_execution_id,omitempty"`
	// Indicates the number of resources to be returned.
	// +required
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering.
	// +optional
	SortBy *Sort `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// Unique identifier of the parent node in the execution
	// +optional
	UniqueParentId string `protobuf:"bytes,6,opt,name=unique_parent_id,json=uniqueParentId,proto3" json:"unique_parent_id,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to retrieve a list of node execution entities. See :ref:`ref_flyteidl.admin.NodeExecution` for more details

func (*NodeExecutionListRequest) Descriptor deprecated 

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

Deprecated: Use NodeExecutionListRequest.ProtoReflect.Descriptor instead.

func (*NodeExecutionListRequest) GetFilters 

func (x *NodeExecutionListRequest) GetFilters() string

func (*NodeExecutionListRequest) GetLimit 

func (x *NodeExecutionListRequest) GetLimit() uint32

func (*NodeExecutionListRequest) GetSortBy 

func (x *NodeExecutionListRequest) GetSortBy() *Sort

func (*NodeExecutionListRequest) GetToken 

func (x *NodeExecutionListRequest) GetToken() string

func (*NodeExecutionListRequest) GetUniqueParentId 

func (x *NodeExecutionListRequest) GetUniqueParentId() string

func (*NodeExecutionListRequest) GetWorkflowExecutionId 

func (x *NodeExecutionListRequest) GetWorkflowExecutionId() *core.WorkflowExecutionIdentifier

func (*NodeExecutionListRequest) ProtoMessage 

func (*NodeExecutionListRequest) ProtoMessage()

func (*NodeExecutionListRequest) ProtoReflect added in v1.10.7 

func (x *NodeExecutionListRequest) ProtoReflect() protoreflect.Message

func (*NodeExecutionListRequest) Reset 

func (x *NodeExecutionListRequest) Reset()

func (*NodeExecutionListRequest) String 

func (x *NodeExecutionListRequest) String() string

type NodeExecutionMetaData 

type NodeExecutionMetaData struct {

	// Node executions are grouped depending on retries of the parent
	// Retry group is unique within the context of a parent node.
	RetryGroup string `protobuf:"bytes,1,opt,name=retry_group,json=retryGroup,proto3" json:"retry_group,omitempty"`
	// Boolean flag indicating if the node has child nodes under it
	// This can be true when a node contains a dynamic workflow which then produces
	// child nodes.
	IsParentNode bool `protobuf:"varint,2,opt,name=is_parent_node,json=isParentNode,proto3" json:"is_parent_node,omitempty"`
	// Node id of the node in the original workflow
	// This maps to value of WorkflowTemplate.nodes[X].id
	SpecNodeId string `protobuf:"bytes,3,opt,name=spec_node_id,json=specNodeId,proto3" json:"spec_node_id,omitempty"`
	// Boolean flag indicating if the node has contains a dynamic workflow which then produces child nodes.
	// This is to distinguish between subworkflows and dynamic workflows which can both have is_parent_node as true.
	IsDynamic bool `protobuf:"varint,4,opt,name=is_dynamic,json=isDynamic,proto3" json:"is_dynamic,omitempty"`
	// Boolean flag indicating if the node is an array node. This is intended to uniquely identify
	// array nodes from other nodes which can have is_parent_node as true.
	IsArray bool `protobuf:"varint,5,opt,name=is_array,json=isArray,proto3" json:"is_array,omitempty"`
	// contains filtered or unexported fields
}

Represents additional attributes related to a Node Execution

func (*NodeExecutionMetaData) Descriptor deprecated 

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

Deprecated: Use NodeExecutionMetaData.ProtoReflect.Descriptor instead.

func (*NodeExecutionMetaData) GetIsArray added in v1.9.14 

func (x *NodeExecutionMetaData) GetIsArray() bool

func (*NodeExecutionMetaData) GetIsDynamic 

func (x *NodeExecutionMetaData) GetIsDynamic() bool

func (*NodeExecutionMetaData) GetIsParentNode 

func (x *NodeExecutionMetaData) GetIsParentNode() bool

func (*NodeExecutionMetaData) GetRetryGroup 

func (x *NodeExecutionMetaData) GetRetryGroup() string

func (*NodeExecutionMetaData) GetSpecNodeId 

func (x *NodeExecutionMetaData) GetSpecNodeId() string

func (*NodeExecutionMetaData) ProtoMessage 

func (*NodeExecutionMetaData) ProtoMessage()

func (*NodeExecutionMetaData) ProtoReflect added in v1.10.7 

func (x *NodeExecutionMetaData) ProtoReflect() protoreflect.Message

func (*NodeExecutionMetaData) Reset 

func (x *NodeExecutionMetaData) Reset()

func (*NodeExecutionMetaData) String 

func (x *NodeExecutionMetaData) String() string

type Notification 

type Notification struct {

	// A list of phases to which users can associate the notifications to.
	// +required
	Phases []core.WorkflowExecution_Phase `protobuf:"varint,1,rep,packed,name=phases,proto3,enum=flyteidl.core.WorkflowExecution_Phase" json:"phases,omitempty"`
	// The type of notification to trigger.
	// +required
	//
	// Types that are assignable to Type:
	//
	//	*Notification_Email
	//	*Notification_PagerDuty
	//	*Notification_Slack
	Type isNotification_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

Represents a structure for notifications based on execution status. The notification content is configured within flyte admin but can be templatized. Future iterations could expose configuring notifications with custom content.

func (*Notification) Descriptor deprecated 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetEmail 

func (x *Notification) GetEmail() *EmailNotification

func (*Notification) GetPagerDuty 

func (x *Notification) GetPagerDuty() *PagerDutyNotification

func (*Notification) GetPhases 

func (x *Notification) GetPhases() []core.WorkflowExecution_Phase

func (*Notification) GetSlack 

func (x *Notification) GetSlack() *SlackNotification

func (*Notification) GetType 

func (m *Notification) GetType() isNotification_Type

func (*Notification) ProtoMessage 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect added in v1.10.7 

func (x *Notification) ProtoReflect() protoreflect.Message

func (*Notification) Reset 

func (x *Notification) Reset()

func (*Notification) String 

func (x *Notification) String() string

type NotificationList 

type NotificationList struct {
	Notifications []*Notification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"`
	// contains filtered or unexported fields
}

func (*NotificationList) Descriptor deprecated 

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

Deprecated: Use NotificationList.ProtoReflect.Descriptor instead.

func (*NotificationList) GetNotifications 

func (x *NotificationList) GetNotifications() []*Notification

func (*NotificationList) ProtoMessage 

func (*NotificationList) ProtoMessage()

func (*NotificationList) ProtoReflect added in v1.10.7 

func (x *NotificationList) ProtoReflect() protoreflect.Message

func (*NotificationList) Reset 

func (x *NotificationList) Reset()

func (*NotificationList) String 

func (x *NotificationList) String() string

type Notification_Email 

type Notification_Email struct {
	Email *EmailNotification `protobuf:"bytes,2,opt,name=email,proto3,oneof"`
}

type Notification_PagerDuty 

type Notification_PagerDuty struct {
	PagerDuty *PagerDutyNotification `protobuf:"bytes,3,opt,name=pager_duty,json=pagerDuty,proto3,oneof"`
}

type Notification_Slack 

type Notification_Slack struct {
	Slack *SlackNotification `protobuf:"bytes,4,opt,name=slack,proto3,oneof"`
}

type ObjectGetRequest 

type ObjectGetRequest struct {

	// Indicates a unique version of resource.
	// +required
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Shared request structure to fetch a single resource. Resources include: Task, Workflow, LaunchPlan

func (*ObjectGetRequest) Descriptor deprecated 

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

Deprecated: Use ObjectGetRequest.ProtoReflect.Descriptor instead.

func (*ObjectGetRequest) GetId 

func (x *ObjectGetRequest) GetId() *core.Identifier

func (*ObjectGetRequest) ProtoMessage 

func (*ObjectGetRequest) ProtoMessage()

func (*ObjectGetRequest) ProtoReflect added in v1.10.7 

func (x *ObjectGetRequest) ProtoReflect() protoreflect.Message

func (*ObjectGetRequest) Reset 

func (x *ObjectGetRequest) Reset()

func (*ObjectGetRequest) String 

func (x *ObjectGetRequest) String() string

type PagerDutyNotification 

type PagerDutyNotification struct {

	// Currently, PagerDuty notifications leverage email to trigger a notification.
	// +required
	RecipientsEmail []string `protobuf:"bytes,1,rep,name=recipients_email,json=recipientsEmail,proto3" json:"recipients_email,omitempty"`
	// contains filtered or unexported fields
}

Defines a pager duty notification specification.

func (*PagerDutyNotification) Descriptor deprecated 

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

Deprecated: Use PagerDutyNotification.ProtoReflect.Descriptor instead.

func (*PagerDutyNotification) GetRecipientsEmail 

func (x *PagerDutyNotification) GetRecipientsEmail() []string

func (*PagerDutyNotification) ProtoMessage 

func (*PagerDutyNotification) ProtoMessage()

func (*PagerDutyNotification) ProtoReflect added in v1.10.7 

func (x *PagerDutyNotification) ProtoReflect() protoreflect.Message

func (*PagerDutyNotification) Reset 

func (x *PagerDutyNotification) Reset()

func (*PagerDutyNotification) String 

func (x *PagerDutyNotification) String() string

type PluginOverride 

type PluginOverride struct {

	// A predefined yet extensible Task type identifier.
	TaskType string `protobuf:"bytes,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// A set of plugin ids which should handle tasks of this type instead of the default registered plugin. The list will be tried in order until a plugin is found with that id.
	PluginId []string `protobuf:"bytes,2,rep,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	// Defines the behavior when no plugin from the plugin_id list is not found.
	MissingPluginBehavior PluginOverride_MissingPluginBehavior `` /* 184-byte string literal not displayed */
	// contains filtered or unexported fields
}

This MatchableAttribute configures selecting alternate plugin implementations for a given task type. In addition to an override implementation a selection of fallbacks can be provided or other modes for handling cases where the desired plugin override is not enabled in a given Flyte deployment.

func (*PluginOverride) Descriptor deprecated 

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

Deprecated: Use PluginOverride.ProtoReflect.Descriptor instead.

func (*PluginOverride) GetMissingPluginBehavior 

func (x *PluginOverride) GetMissingPluginBehavior() PluginOverride_MissingPluginBehavior

func (*PluginOverride) GetPluginId 

func (x *PluginOverride) GetPluginId() []string

func (*PluginOverride) GetTaskType 

func (x *PluginOverride) GetTaskType() string

func (*PluginOverride) ProtoMessage 

func (*PluginOverride) ProtoMessage()

func (*PluginOverride) ProtoReflect added in v1.10.7 

func (x *PluginOverride) ProtoReflect() protoreflect.Message

func (*PluginOverride) Reset 

func (x *PluginOverride) Reset()

func (*PluginOverride) String 

func (x *PluginOverride) String() string

type PluginOverride_MissingPluginBehavior 

type PluginOverride_MissingPluginBehavior int32
const (
	// By default, if this plugin is not enabled for a Flyte deployment then execution will fail.
	PluginOverride_FAIL PluginOverride_MissingPluginBehavior = 0
	// Uses the system-configured default implementation.
	PluginOverride_USE_DEFAULT PluginOverride_MissingPluginBehavior = 1
)

func (PluginOverride_MissingPluginBehavior) Descriptor added in v1.10.7 

func (PluginOverride_MissingPluginBehavior) Descriptor() protoreflect.EnumDescriptor

func (PluginOverride_MissingPluginBehavior) Enum added in v1.10.7 

func (x PluginOverride_MissingPluginBehavior) Enum() *PluginOverride_MissingPluginBehavior

func (PluginOverride_MissingPluginBehavior) EnumDescriptor deprecated 

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

Deprecated: Use PluginOverride_MissingPluginBehavior.Descriptor instead.

func (PluginOverride_MissingPluginBehavior) Number added in v1.10.7 

func (x PluginOverride_MissingPluginBehavior) Number() protoreflect.EnumNumber

func (PluginOverride_MissingPluginBehavior) String 

func (x PluginOverride_MissingPluginBehavior) String() string

func (PluginOverride_MissingPluginBehavior) Type added in v1.10.7 

func (PluginOverride_MissingPluginBehavior) Type() protoreflect.EnumType

type PluginOverrides 

type PluginOverrides struct {
	Overrides []*PluginOverride `protobuf:"bytes,1,rep,name=overrides,proto3" json:"overrides,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginOverrides) Descriptor deprecated 

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

Deprecated: Use PluginOverrides.ProtoReflect.Descriptor instead.

func (*PluginOverrides) GetOverrides 

func (x *PluginOverrides) GetOverrides() []*PluginOverride

func (*PluginOverrides) ProtoMessage 

func (*PluginOverrides) ProtoMessage()

func (*PluginOverrides) ProtoReflect added in v1.10.7 

func (x *PluginOverrides) ProtoReflect() protoreflect.Message

func (*PluginOverrides) Reset 

func (x *PluginOverrides) Reset()

func (*PluginOverrides) String 

func (x *PluginOverrides) String() string

type Project 

type Project struct {

	// Globally unique project name.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Display name.
	Name        string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Domains     []*Domain `protobuf:"bytes,3,rep,name=domains,proto3" json:"domains,omitempty"`
	Description string    `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Leverage Labels from flyteidl.admin.common.proto to
	// tag projects with ownership information.
	Labels *Labels              `protobuf:"bytes,5,opt,name=labels,proto3" json:"labels,omitempty"`
	State  Project_ProjectState `protobuf:"varint,6,opt,name=state,proto3,enum=flyteidl.admin.Project_ProjectState" json:"state,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,7,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Top-level namespace used to classify different entities like workflows and executions.

func (*Project) Descriptor deprecated 

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

Deprecated: Use Project.ProtoReflect.Descriptor instead.

func (*Project) GetDescription 

func (x *Project) GetDescription() string

func (*Project) GetDomains 

func (x *Project) GetDomains() []*Domain

func (*Project) GetId 

func (x *Project) GetId() string

func (*Project) GetLabels 

func (x *Project) GetLabels() *Labels

func (*Project) GetName 

func (x *Project) GetName() string

func (*Project) GetOrg added in v1.10.7 

func (x *Project) GetOrg() string

func (*Project) GetState 

func (x *Project) GetState() Project_ProjectState

func (*Project) ProtoMessage 

func (*Project) ProtoMessage()

func (*Project) ProtoReflect added in v1.10.7 

func (x *Project) ProtoReflect() protoreflect.Message

func (*Project) Reset 

func (x *Project) Reset()

func (*Project) String 

func (x *Project) String() string

type ProjectAttributes 

type ProjectAttributes struct {

	// Unique project id for which this set of attributes will be applied.
	Project            string              `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	MatchingAttributes *MatchingAttributes `protobuf:"bytes,2,opt,name=matching_attributes,json=matchingAttributes,proto3" json:"matching_attributes,omitempty"`
	// Optional, org key applied to the project.
	Org string `protobuf:"bytes,3,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Defines a set of custom matching attributes at the project level. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectAttributes) Descriptor deprecated 

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

Deprecated: Use ProjectAttributes.ProtoReflect.Descriptor instead.

func (*ProjectAttributes) GetMatchingAttributes 

func (x *ProjectAttributes) GetMatchingAttributes() *MatchingAttributes

func (*ProjectAttributes) GetOrg added in v1.10.7 

func (x *ProjectAttributes) GetOrg() string

func (*ProjectAttributes) GetProject 

func (x *ProjectAttributes) GetProject() string

func (*ProjectAttributes) ProtoMessage 

func (*ProjectAttributes) ProtoMessage()

func (*ProjectAttributes) ProtoReflect added in v1.10.7 

func (x *ProjectAttributes) ProtoReflect() protoreflect.Message

func (*ProjectAttributes) Reset 

func (x *ProjectAttributes) Reset()

func (*ProjectAttributes) String 

func (x *ProjectAttributes) String() string

type ProjectAttributesDeleteRequest 

type ProjectAttributesDeleteRequest struct {

	// Unique project id which this set of attributes references.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Which type of matchable attributes to delete.
	// +required
	ResourceType MatchableResource `` /* 136-byte string literal not displayed */
	// Optional, org key applied to the project.
	Org string `protobuf:"bytes,3,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to delete a set matchable project level attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectAttributesDeleteRequest) Descriptor deprecated 

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

Deprecated: Use ProjectAttributesDeleteRequest.ProtoReflect.Descriptor instead.

func (*ProjectAttributesDeleteRequest) GetOrg added in v1.10.7 

func (x *ProjectAttributesDeleteRequest) GetOrg() string

func (*ProjectAttributesDeleteRequest) GetProject 

func (x *ProjectAttributesDeleteRequest) GetProject() string

func (*ProjectAttributesDeleteRequest) GetResourceType 

func (x *ProjectAttributesDeleteRequest) GetResourceType() MatchableResource

func (*ProjectAttributesDeleteRequest) ProtoMessage 

func (*ProjectAttributesDeleteRequest) ProtoMessage()

func (*ProjectAttributesDeleteRequest) ProtoReflect added in v1.10.7 

func (x *ProjectAttributesDeleteRequest) ProtoReflect() protoreflect.Message

func (*ProjectAttributesDeleteRequest) Reset 

func (x *ProjectAttributesDeleteRequest) Reset()

func (*ProjectAttributesDeleteRequest) String 

func (x *ProjectAttributesDeleteRequest) String() string

type ProjectAttributesDeleteResponse 

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

Purposefully empty, may be populated in the future.

func (*ProjectAttributesDeleteResponse) Descriptor deprecated 

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

Deprecated: Use ProjectAttributesDeleteResponse.ProtoReflect.Descriptor instead.

func (*ProjectAttributesDeleteResponse) ProtoMessage 

func (*ProjectAttributesDeleteResponse) ProtoMessage()

func (*ProjectAttributesDeleteResponse) ProtoReflect added in v1.10.7 

func (x *ProjectAttributesDeleteResponse) ProtoReflect() protoreflect.Message

func (*ProjectAttributesDeleteResponse) Reset 

func (x *ProjectAttributesDeleteResponse) Reset()

func (*ProjectAttributesDeleteResponse) String 

func (x *ProjectAttributesDeleteResponse) String() string

type ProjectAttributesGetRequest 

type ProjectAttributesGetRequest struct {

	// Unique project id which this set of attributes references.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Which type of matchable attributes to return.
	// +required
	ResourceType MatchableResource `` /* 136-byte string literal not displayed */
	// Optional, org key applied to the project.
	Org string `protobuf:"bytes,3,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to get an individual project level attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectAttributesGetRequest) Descriptor deprecated 

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

Deprecated: Use ProjectAttributesGetRequest.ProtoReflect.Descriptor instead.

func (*ProjectAttributesGetRequest) GetOrg added in v1.10.7 

func (x *ProjectAttributesGetRequest) GetOrg() string

func (*ProjectAttributesGetRequest) GetProject 

func (x *ProjectAttributesGetRequest) GetProject() string

func (*ProjectAttributesGetRequest) GetResourceType 

func (x *ProjectAttributesGetRequest) GetResourceType() MatchableResource

func (*ProjectAttributesGetRequest) ProtoMessage 

func (*ProjectAttributesGetRequest) ProtoMessage()

func (*ProjectAttributesGetRequest) ProtoReflect added in v1.10.7 

func (x *ProjectAttributesGetRequest) ProtoReflect() protoreflect.Message

func (*ProjectAttributesGetRequest) Reset 

func (x *ProjectAttributesGetRequest) Reset()

func (*ProjectAttributesGetRequest) String 

func (x *ProjectAttributesGetRequest) String() string

type ProjectAttributesGetResponse 

type ProjectAttributesGetResponse struct {
	Attributes *ProjectAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Response to get an individual project level attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectAttributesGetResponse) Descriptor deprecated 

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

Deprecated: Use ProjectAttributesGetResponse.ProtoReflect.Descriptor instead.

func (*ProjectAttributesGetResponse) GetAttributes 

func (x *ProjectAttributesGetResponse) GetAttributes() *ProjectAttributes

func (*ProjectAttributesGetResponse) ProtoMessage 

func (*ProjectAttributesGetResponse) ProtoMessage()

func (*ProjectAttributesGetResponse) ProtoReflect added in v1.10.7 

func (x *ProjectAttributesGetResponse) ProtoReflect() protoreflect.Message

func (*ProjectAttributesGetResponse) Reset 

func (x *ProjectAttributesGetResponse) Reset()

func (*ProjectAttributesGetResponse) String 

func (x *ProjectAttributesGetResponse) String() string

type ProjectAttributesUpdateRequest 

type ProjectAttributesUpdateRequest struct {

	// +required
	Attributes *ProjectAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Sets custom attributes for a project For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectAttributesUpdateRequest) Descriptor deprecated 

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

Deprecated: Use ProjectAttributesUpdateRequest.ProtoReflect.Descriptor instead.

func (*ProjectAttributesUpdateRequest) GetAttributes 

func (x *ProjectAttributesUpdateRequest) GetAttributes() *ProjectAttributes

func (*ProjectAttributesUpdateRequest) ProtoMessage 

func (*ProjectAttributesUpdateRequest) ProtoMessage()

func (*ProjectAttributesUpdateRequest) ProtoReflect added in v1.10.7 

func (x *ProjectAttributesUpdateRequest) ProtoReflect() protoreflect.Message

func (*ProjectAttributesUpdateRequest) Reset 

func (x *ProjectAttributesUpdateRequest) Reset()

func (*ProjectAttributesUpdateRequest) String 

func (x *ProjectAttributesUpdateRequest) String() string

type ProjectAttributesUpdateResponse 

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

Purposefully empty, may be populated in the future.

func (*ProjectAttributesUpdateResponse) Descriptor deprecated 

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

Deprecated: Use ProjectAttributesUpdateResponse.ProtoReflect.Descriptor instead.

func (*ProjectAttributesUpdateResponse) ProtoMessage 

func (*ProjectAttributesUpdateResponse) ProtoMessage()

func (*ProjectAttributesUpdateResponse) ProtoReflect added in v1.10.7 

func (x *ProjectAttributesUpdateResponse) ProtoReflect() protoreflect.Message

func (*ProjectAttributesUpdateResponse) Reset 

func (x *ProjectAttributesUpdateResponse) Reset()

func (*ProjectAttributesUpdateResponse) String 

func (x *ProjectAttributesUpdateResponse) String() string

type ProjectDomainAttributes 

type ProjectDomainAttributes struct {

	// Unique project id for which this set of attributes will be applied.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id for which this set of attributes will be applied.
	Domain             string              `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	MatchingAttributes *MatchingAttributes `protobuf:"bytes,3,opt,name=matching_attributes,json=matchingAttributes,proto3" json:"matching_attributes,omitempty"`
	// Optional, org key applied to the attributes.
	Org string `protobuf:"bytes,4,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Defines a set of custom matching attributes which defines resource defaults for a project and domain. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectDomainAttributes) Descriptor deprecated 

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

Deprecated: Use ProjectDomainAttributes.ProtoReflect.Descriptor instead.

func (*ProjectDomainAttributes) GetDomain 

func (x *ProjectDomainAttributes) GetDomain() string

func (*ProjectDomainAttributes) GetMatchingAttributes 

func (x *ProjectDomainAttributes) GetMatchingAttributes() *MatchingAttributes

func (*ProjectDomainAttributes) GetOrg added in v1.10.7 

func (x *ProjectDomainAttributes) GetOrg() string

func (*ProjectDomainAttributes) GetProject 

func (x *ProjectDomainAttributes) GetProject() string

func (*ProjectDomainAttributes) ProtoMessage 

func (*ProjectDomainAttributes) ProtoMessage()

func (*ProjectDomainAttributes) ProtoReflect added in v1.10.7 

func (x *ProjectDomainAttributes) ProtoReflect() protoreflect.Message

func (*ProjectDomainAttributes) Reset 

func (x *ProjectDomainAttributes) Reset()

func (*ProjectDomainAttributes) String 

func (x *ProjectDomainAttributes) String() string

type ProjectDomainAttributesDeleteRequest 

type ProjectDomainAttributesDeleteRequest struct {

	// Unique project id which this set of attributes references.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Which type of matchable attributes to delete.
	// +required
	ResourceType MatchableResource `` /* 136-byte string literal not displayed */
	// Optional, org key applied to the attributes.
	Org string `protobuf:"bytes,4,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to delete a set matchable project domain attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectDomainAttributesDeleteRequest) Descriptor deprecated 

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

Deprecated: Use ProjectDomainAttributesDeleteRequest.ProtoReflect.Descriptor instead.

func (*ProjectDomainAttributesDeleteRequest) GetDomain 

func (x *ProjectDomainAttributesDeleteRequest) GetDomain() string

func (*ProjectDomainAttributesDeleteRequest) GetOrg added in v1.10.7 

func (x *ProjectDomainAttributesDeleteRequest) GetOrg() string

func (*ProjectDomainAttributesDeleteRequest) GetProject 

func (x *ProjectDomainAttributesDeleteRequest) GetProject() string

func (*ProjectDomainAttributesDeleteRequest) GetResourceType 

func (x *ProjectDomainAttributesDeleteRequest) GetResourceType() MatchableResource

func (*ProjectDomainAttributesDeleteRequest) ProtoMessage 

func (*ProjectDomainAttributesDeleteRequest) ProtoMessage()

func (*ProjectDomainAttributesDeleteRequest) ProtoReflect added in v1.10.7 

func (x *ProjectDomainAttributesDeleteRequest) ProtoReflect() protoreflect.Message

func (*ProjectDomainAttributesDeleteRequest) Reset 

func (x *ProjectDomainAttributesDeleteRequest) Reset()

func (*ProjectDomainAttributesDeleteRequest) String 

func (x *ProjectDomainAttributesDeleteRequest) String() string

type ProjectDomainAttributesDeleteResponse 

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

Purposefully empty, may be populated in the future.

func (*ProjectDomainAttributesDeleteResponse) Descriptor deprecated 

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

Deprecated: Use ProjectDomainAttributesDeleteResponse.ProtoReflect.Descriptor instead.

func (*ProjectDomainAttributesDeleteResponse) ProtoMessage 

func (*ProjectDomainAttributesDeleteResponse) ProtoMessage()

func (*ProjectDomainAttributesDeleteResponse) ProtoReflect added in v1.10.7 

func (x *ProjectDomainAttributesDeleteResponse) ProtoReflect() protoreflect.Message

func (*ProjectDomainAttributesDeleteResponse) Reset 

func (x *ProjectDomainAttributesDeleteResponse) Reset()

func (*ProjectDomainAttributesDeleteResponse) String 

func (x *ProjectDomainAttributesDeleteResponse) String() string

type ProjectDomainAttributesGetRequest 

type ProjectDomainAttributesGetRequest struct {

	// Unique project id which this set of attributes references.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Which type of matchable attributes to return.
	// +required
	ResourceType MatchableResource `` /* 136-byte string literal not displayed */
	// Optional, org key applied to the attributes.
	Org string `protobuf:"bytes,4,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to get an individual project domain attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectDomainAttributesGetRequest) Descriptor deprecated 

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

Deprecated: Use ProjectDomainAttributesGetRequest.ProtoReflect.Descriptor instead.

func (*ProjectDomainAttributesGetRequest) GetDomain 

func (x *ProjectDomainAttributesGetRequest) GetDomain() string

func (*ProjectDomainAttributesGetRequest) GetOrg added in v1.10.7 

func (x *ProjectDomainAttributesGetRequest) GetOrg() string

func (*ProjectDomainAttributesGetRequest) GetProject 

func (x *ProjectDomainAttributesGetRequest) GetProject() string

func (*ProjectDomainAttributesGetRequest) GetResourceType 

func (x *ProjectDomainAttributesGetRequest) GetResourceType() MatchableResource

func (*ProjectDomainAttributesGetRequest) ProtoMessage 

func (*ProjectDomainAttributesGetRequest) ProtoMessage()

func (*ProjectDomainAttributesGetRequest) ProtoReflect added in v1.10.7 

func (x *ProjectDomainAttributesGetRequest) ProtoReflect() protoreflect.Message

func (*ProjectDomainAttributesGetRequest) Reset 

func (x *ProjectDomainAttributesGetRequest) Reset()

func (*ProjectDomainAttributesGetRequest) String 

func (x *ProjectDomainAttributesGetRequest) String() string

type ProjectDomainAttributesGetResponse 

type ProjectDomainAttributesGetResponse struct {
	Attributes *ProjectDomainAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Response to get an individual project domain attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectDomainAttributesGetResponse) Descriptor deprecated 

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

Deprecated: Use ProjectDomainAttributesGetResponse.ProtoReflect.Descriptor instead.

func (*ProjectDomainAttributesGetResponse) GetAttributes 

func (x *ProjectDomainAttributesGetResponse) GetAttributes() *ProjectDomainAttributes

func (*ProjectDomainAttributesGetResponse) ProtoMessage 

func (*ProjectDomainAttributesGetResponse) ProtoMessage()

func (*ProjectDomainAttributesGetResponse) ProtoReflect added in v1.10.7 

func (x *ProjectDomainAttributesGetResponse) ProtoReflect() protoreflect.Message

func (*ProjectDomainAttributesGetResponse) Reset 

func (x *ProjectDomainAttributesGetResponse) Reset()

func (*ProjectDomainAttributesGetResponse) String 

func (x *ProjectDomainAttributesGetResponse) String() string

type ProjectDomainAttributesUpdateRequest 

type ProjectDomainAttributesUpdateRequest struct {

	// +required
	Attributes *ProjectDomainAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Sets custom attributes for a project-domain combination. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*ProjectDomainAttributesUpdateRequest) Descriptor deprecated 

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

Deprecated: Use ProjectDomainAttributesUpdateRequest.ProtoReflect.Descriptor instead.

func (*ProjectDomainAttributesUpdateRequest) GetAttributes 

func (x *ProjectDomainAttributesUpdateRequest) GetAttributes() *ProjectDomainAttributes

func (*ProjectDomainAttributesUpdateRequest) ProtoMessage 

func (*ProjectDomainAttributesUpdateRequest) ProtoMessage()

func (*ProjectDomainAttributesUpdateRequest) ProtoReflect added in v1.10.7 

func (x *ProjectDomainAttributesUpdateRequest) ProtoReflect() protoreflect.Message

func (*ProjectDomainAttributesUpdateRequest) Reset 

func (x *ProjectDomainAttributesUpdateRequest) Reset()

func (*ProjectDomainAttributesUpdateRequest) String 

func (x *ProjectDomainAttributesUpdateRequest) String() string

type ProjectDomainAttributesUpdateResponse 

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

Purposefully empty, may be populated in the future.

func (*ProjectDomainAttributesUpdateResponse) Descriptor deprecated 

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

Deprecated: Use ProjectDomainAttributesUpdateResponse.ProtoReflect.Descriptor instead.

func (*ProjectDomainAttributesUpdateResponse) ProtoMessage 

func (*ProjectDomainAttributesUpdateResponse) ProtoMessage()

func (*ProjectDomainAttributesUpdateResponse) ProtoReflect added in v1.10.7 

func (x *ProjectDomainAttributesUpdateResponse) ProtoReflect() protoreflect.Message

func (*ProjectDomainAttributesUpdateResponse) Reset 

func (x *ProjectDomainAttributesUpdateResponse) Reset()

func (*ProjectDomainAttributesUpdateResponse) String 

func (x *ProjectDomainAttributesUpdateResponse) String() string

type ProjectListRequest 

type ProjectListRequest struct {

	// Indicates the number of projects to be returned.
	// +required
	Limit uint32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, this server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,3,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering.
	// +optional
	SortBy *Sort `protobuf:"bytes,4,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// Optional, org filter applied to list project requests.
	Org string `protobuf:"bytes,5,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to retrieve a list of projects matching specified filters. See :ref:`ref_flyteidl.admin.Project` for more details

func (*ProjectListRequest) Descriptor deprecated 

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

Deprecated: Use ProjectListRequest.ProtoReflect.Descriptor instead.

func (*ProjectListRequest) GetFilters 

func (x *ProjectListRequest) GetFilters() string

func (*ProjectListRequest) GetLimit 

func (x *ProjectListRequest) GetLimit() uint32

func (*ProjectListRequest) GetOrg added in v1.10.7 

func (x *ProjectListRequest) GetOrg() string

func (*ProjectListRequest) GetSortBy 

func (x *ProjectListRequest) GetSortBy() *Sort

func (*ProjectListRequest) GetToken 

func (x *ProjectListRequest) GetToken() string

func (*ProjectListRequest) ProtoMessage 

func (*ProjectListRequest) ProtoMessage()

func (*ProjectListRequest) ProtoReflect added in v1.10.7 

func (x *ProjectListRequest) ProtoReflect() protoreflect.Message

func (*ProjectListRequest) Reset 

func (x *ProjectListRequest) Reset()

func (*ProjectListRequest) String 

func (x *ProjectListRequest) String() string

type ProjectRegisterRequest 

type ProjectRegisterRequest struct {

	// +required
	Project *Project `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

Adds a new user-project within the Flyte deployment. See :ref:`ref_flyteidl.admin.Project` for more details

func (*ProjectRegisterRequest) Descriptor deprecated 

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

Deprecated: Use ProjectRegisterRequest.ProtoReflect.Descriptor instead.

func (*ProjectRegisterRequest) GetProject 

func (x *ProjectRegisterRequest) GetProject() *Project

func (*ProjectRegisterRequest) ProtoMessage 

func (*ProjectRegisterRequest) ProtoMessage()

func (*ProjectRegisterRequest) ProtoReflect added in v1.10.7 

func (x *ProjectRegisterRequest) ProtoReflect() protoreflect.Message

func (*ProjectRegisterRequest) Reset 

func (x *ProjectRegisterRequest) Reset()

func (*ProjectRegisterRequest) String 

func (x *ProjectRegisterRequest) String() string

type ProjectRegisterResponse 

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

Purposefully empty, may be updated in the future.

func (*ProjectRegisterResponse) Descriptor deprecated 

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

Deprecated: Use ProjectRegisterResponse.ProtoReflect.Descriptor instead.

func (*ProjectRegisterResponse) ProtoMessage 

func (*ProjectRegisterResponse) ProtoMessage()

func (*ProjectRegisterResponse) ProtoReflect added in v1.10.7 

func (x *ProjectRegisterResponse) ProtoReflect() protoreflect.Message

func (*ProjectRegisterResponse) Reset 

func (x *ProjectRegisterResponse) Reset()

func (*ProjectRegisterResponse) String 

func (x *ProjectRegisterResponse) String() string

type ProjectUpdateResponse 

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

Purposefully empty, may be updated in the future.

func (*ProjectUpdateResponse) Descriptor deprecated 

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

Deprecated: Use ProjectUpdateResponse.ProtoReflect.Descriptor instead.

func (*ProjectUpdateResponse) ProtoMessage 

func (*ProjectUpdateResponse) ProtoMessage()

func (*ProjectUpdateResponse) ProtoReflect added in v1.10.7 

func (x *ProjectUpdateResponse) ProtoReflect() protoreflect.Message

func (*ProjectUpdateResponse) Reset 

func (x *ProjectUpdateResponse) Reset()

func (*ProjectUpdateResponse) String 

func (x *ProjectUpdateResponse) String() string

type Project_ProjectState 

type Project_ProjectState int32

The state of the project is used to control its visibility in the UI and validity. 

const (
	// By default, all projects are considered active.
	Project_ACTIVE Project_ProjectState = 0
	// Archived projects are no longer visible in the UI and no longer valid.
	Project_ARCHIVED Project_ProjectState = 1
	// System generated projects that aren't explicitly created or managed by a user.
	Project_SYSTEM_GENERATED Project_ProjectState = 2
)

func (Project_ProjectState) Descriptor added in v1.10.7 

func (Project_ProjectState) Descriptor() protoreflect.EnumDescriptor

func (Project_ProjectState) Enum added in v1.10.7 

func (x Project_ProjectState) Enum() *Project_ProjectState

func (Project_ProjectState) EnumDescriptor deprecated 

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

Deprecated: Use Project_ProjectState.Descriptor instead.

func (Project_ProjectState) Number added in v1.10.7 

func (x Project_ProjectState) Number() protoreflect.EnumNumber

func (Project_ProjectState) String 

func (x Project_ProjectState) String() string

func (Project_ProjectState) Type added in v1.10.7 

func (Project_ProjectState) Type() protoreflect.EnumType

type Projects 

type Projects struct {
	Projects []*Project `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Represents a list of projects. See :ref:`ref_flyteidl.admin.Project` for more details

func (*Projects) Descriptor deprecated 

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

Deprecated: Use Projects.ProtoReflect.Descriptor instead.

func (*Projects) GetProjects 

func (x *Projects) GetProjects() []*Project

func (*Projects) GetToken 

func (x *Projects) GetToken() string

func (*Projects) ProtoMessage 

func (*Projects) ProtoMessage()

func (*Projects) ProtoReflect added in v1.10.7 

func (x *Projects) ProtoReflect() protoreflect.Message

func (*Projects) Reset 

func (x *Projects) Reset()

func (*Projects) String 

func (x *Projects) String() string

type RawOutputDataConfig 

type RawOutputDataConfig struct {

	// Prefix for where offloaded data from user workflows will be written
	// e.g. s3://bucket/key or s3://bucket/
	OutputLocationPrefix string `protobuf:"bytes,1,opt,name=output_location_prefix,json=outputLocationPrefix,proto3" json:"output_location_prefix,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.). See https://github.com/flyteorg/flyte/issues/211 for more background information.

func (*RawOutputDataConfig) Descriptor deprecated 

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

Deprecated: Use RawOutputDataConfig.ProtoReflect.Descriptor instead.

func (*RawOutputDataConfig) GetOutputLocationPrefix 

func (x *RawOutputDataConfig) GetOutputLocationPrefix() string

func (*RawOutputDataConfig) ProtoMessage 

func (*RawOutputDataConfig) ProtoMessage()

func (*RawOutputDataConfig) ProtoReflect added in v1.10.7 

func (x *RawOutputDataConfig) ProtoReflect() protoreflect.Message

func (*RawOutputDataConfig) Reset 

func (x *RawOutputDataConfig) Reset()

func (*RawOutputDataConfig) String 

func (x *RawOutputDataConfig) String() string

type Reason 

type Reason struct {

	// occurred_at is the timestamp indicating the instant that this reason happened.
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// message is the explanation for the most recent phase transition or status update.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Reason is a single message annotated with a timestamp to indicate the instant the reason occurred.

func (*Reason) Descriptor deprecated 

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

Deprecated: Use Reason.ProtoReflect.Descriptor instead.

func (*Reason) GetMessage 

func (x *Reason) GetMessage() string

func (*Reason) GetOccurredAt 

func (x *Reason) GetOccurredAt() *timestamppb.Timestamp

func (*Reason) ProtoMessage 

func (*Reason) ProtoMessage()

func (*Reason) ProtoReflect added in v1.10.7 

func (x *Reason) ProtoReflect() protoreflect.Message

func (*Reason) Reset 

func (x *Reason) Reset()

func (*Reason) String 

func (x *Reason) String() string

type Resource 

type Resource struct {

	// DEPRECATED. The state of the execution is used to control its visibility in the UI/CLI.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=flyteidl.admin.State" json:"state,omitempty"`
	// The outputs of the execution. It's typically used by sql task. Agent service will create a
	// Structured dataset pointing to the query result table.
	// +optional
	Outputs *core.LiteralMap `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// A descriptive message for the current state. e.g. waiting for cluster.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// log information for the task execution.
	LogLinks []*core.TaskLog `protobuf:"bytes,4,rep,name=log_links,json=logLinks,proto3" json:"log_links,omitempty"`
	// The phase of the execution is used to determine the phase of the plugin's execution.
	Phase core.TaskExecution_Phase `protobuf:"varint,5,opt,name=phase,proto3,enum=flyteidl.core.TaskExecution_Phase" json:"phase,omitempty"`
	// Custom data specific to the agent.
	CustomInfo *structpb.Struct `protobuf:"bytes,6,opt,name=custom_info,json=customInfo,proto3" json:"custom_info,omitempty"`
	// contains filtered or unexported fields
}

func (*Resource) Descriptor deprecated 

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetCustomInfo added in v1.11.0 

func (x *Resource) GetCustomInfo() *structpb.Struct
func (x *Resource) GetLogLinks() []*core.TaskLog

func (*Resource) GetMessage added in v1.9.15 

func (x *Resource) GetMessage() string

func (*Resource) GetOutputs 

func (x *Resource) GetOutputs() *core.LiteralMap

func (*Resource) GetPhase added in v1.10.7 

func (x *Resource) GetPhase() core.TaskExecution_Phase

func (*Resource) GetState deprecated 

func (x *Resource) GetState() State

Deprecated: Marked as deprecated in flyteidl/admin/agent.proto.

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect added in v1.10.7 

func (x *Resource) ProtoReflect() protoreflect.Message

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

type ResourceListRequest 

type ResourceListRequest struct {

	// id represents the unique identifier of the resource.
	// +required
	Id *NamedEntityIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Indicates the number of resources to be returned.
	// +required
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, this server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering.
	// +optional
	SortBy *Sort `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// contains filtered or unexported fields
}

Shared request structure to retrieve a list of resources. Resources include: Task, Workflow, LaunchPlan

func (*ResourceListRequest) Descriptor deprecated 

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

Deprecated: Use ResourceListRequest.ProtoReflect.Descriptor instead.

func (*ResourceListRequest) GetFilters 

func (x *ResourceListRequest) GetFilters() string

func (*ResourceListRequest) GetId 

func (x *ResourceListRequest) GetId() *NamedEntityIdentifier

func (*ResourceListRequest) GetLimit 

func (x *ResourceListRequest) GetLimit() uint32

func (*ResourceListRequest) GetSortBy 

func (x *ResourceListRequest) GetSortBy() *Sort

func (*ResourceListRequest) GetToken 

func (x *ResourceListRequest) GetToken() string

func (*ResourceListRequest) ProtoMessage 

func (*ResourceListRequest) ProtoMessage()

func (*ResourceListRequest) ProtoReflect added in v1.10.7 

func (x *ResourceListRequest) ProtoReflect() protoreflect.Message

func (*ResourceListRequest) Reset 

func (x *ResourceListRequest) Reset()

func (*ResourceListRequest) String 

func (x *ResourceListRequest) String() string

type Schedule 

type Schedule struct {

	// Types that are assignable to ScheduleExpression:
	//
	//	*Schedule_CronExpression
	//	*Schedule_Rate
	//	*Schedule_CronSchedule
	ScheduleExpression isSchedule_ScheduleExpression `protobuf_oneof:"ScheduleExpression"`
	// Name of the input variable that the kickoff time will be supplied to when the workflow is kicked off.
	KickoffTimeInputArg string `protobuf:"bytes,3,opt,name=kickoff_time_input_arg,json=kickoffTimeInputArg,proto3" json:"kickoff_time_input_arg,omitempty"`
	// contains filtered or unexported fields
}

Defines complete set of information required to trigger an execution on a schedule.

func (*Schedule) Descriptor deprecated 

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

Deprecated: Use Schedule.ProtoReflect.Descriptor instead.

func (*Schedule) GetCronExpression deprecated 

func (x *Schedule) GetCronExpression() string

Deprecated: Marked as deprecated in flyteidl/admin/schedule.proto.

func (*Schedule) GetCronSchedule 

func (x *Schedule) GetCronSchedule() *CronSchedule

func (*Schedule) GetKickoffTimeInputArg 

func (x *Schedule) GetKickoffTimeInputArg() string

func (*Schedule) GetRate 

func (x *Schedule) GetRate() *FixedRate

func (*Schedule) GetScheduleExpression 

func (m *Schedule) GetScheduleExpression() isSchedule_ScheduleExpression

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect added in v1.10.7 

func (x *Schedule) ProtoReflect() protoreflect.Message

func (*Schedule) Reset 

func (x *Schedule) Reset()

func (*Schedule) String 

func (x *Schedule) String() string

type Schedule_CronExpression 

type Schedule_CronExpression struct {
	// Uses AWS syntax: Minutes Hours Day-of-month Month Day-of-week Year
	// e.g. for a schedule that runs every 15 minutes: 0/15 * * * ? *
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/schedule.proto.
	CronExpression string `protobuf:"bytes,1,opt,name=cron_expression,json=cronExpression,proto3,oneof"`
}

type Schedule_CronSchedule 

type Schedule_CronSchedule struct {
	CronSchedule *CronSchedule `protobuf:"bytes,4,opt,name=cron_schedule,json=cronSchedule,proto3,oneof"`
}

type Schedule_Rate 

type Schedule_Rate struct {
	Rate *FixedRate `protobuf:"bytes,2,opt,name=rate,proto3,oneof"`
}

type Signal 

type Signal struct {

	// A unique identifier for the requested signal.
	Id *core.SignalIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A type denoting the required value type for this signal.
	Type *core.LiteralType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// The value of the signal. This is only available if the signal has been "set" and must match
	// the defined the type.
	Value *core.Literal `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Signal encapsulates a unique identifier, associated metadata, and a value for a single Flyte signal. Signals may exist either without a set value (representing a signal request) or with a populated value (indicating the signal has been given).

func (*Signal) Descriptor deprecated 

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

Deprecated: Use Signal.ProtoReflect.Descriptor instead.

func (*Signal) GetId 

func (x *Signal) GetId() *core.SignalIdentifier

func (*Signal) GetType 

func (x *Signal) GetType() *core.LiteralType

func (*Signal) GetValue 

func (x *Signal) GetValue() *core.Literal

func (*Signal) ProtoMessage 

func (*Signal) ProtoMessage()

func (*Signal) ProtoReflect added in v1.10.7 

func (x *Signal) ProtoReflect() protoreflect.Message

func (*Signal) Reset 

func (x *Signal) Reset()

func (*Signal) String 

func (x *Signal) String() string

type SignalGetOrCreateRequest 

type SignalGetOrCreateRequest struct {

	// A unique identifier for the requested signal.
	Id *core.SignalIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A type denoting the required value type for this signal.
	Type *core.LiteralType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

SignalGetOrCreateRequest represents a request structure to retrieve or create a signal. See :ref:`ref_flyteidl.admin.Signal` for more details

func (*SignalGetOrCreateRequest) Descriptor deprecated 

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

Deprecated: Use SignalGetOrCreateRequest.ProtoReflect.Descriptor instead.

func (*SignalGetOrCreateRequest) GetId 

func (x *SignalGetOrCreateRequest) GetId() *core.SignalIdentifier

func (*SignalGetOrCreateRequest) GetType 

func (x *SignalGetOrCreateRequest) GetType() *core.LiteralType

func (*SignalGetOrCreateRequest) ProtoMessage 

func (*SignalGetOrCreateRequest) ProtoMessage()

func (*SignalGetOrCreateRequest) ProtoReflect added in v1.10.7 

func (x *SignalGetOrCreateRequest) ProtoReflect() protoreflect.Message

func (*SignalGetOrCreateRequest) Reset 

func (x *SignalGetOrCreateRequest) Reset()

func (*SignalGetOrCreateRequest) String 

func (x *SignalGetOrCreateRequest) String() string

type SignalList 

type SignalList struct {

	// A list of signals matching the input filters.
	Signals []*Signal `protobuf:"bytes,1,rep,name=signals,proto3" json:"signals,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

SignalList represents collection of signals along with the token of the last result. See :ref:`ref_flyteidl.admin.Signal` for more details

func (*SignalList) Descriptor deprecated 

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

Deprecated: Use SignalList.ProtoReflect.Descriptor instead.

func (*SignalList) GetSignals 

func (x *SignalList) GetSignals() []*Signal

func (*SignalList) GetToken 

func (x *SignalList) GetToken() string

func (*SignalList) ProtoMessage 

func (*SignalList) ProtoMessage()

func (*SignalList) ProtoReflect added in v1.10.7 

func (x *SignalList) ProtoReflect() protoreflect.Message

func (*SignalList) Reset 

func (x *SignalList) Reset()

func (*SignalList) String 

func (x *SignalList) String() string

type SignalListRequest 

type SignalListRequest struct {

	// Indicates the workflow execution to filter by.
	// +required
	WorkflowExecutionId *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=workflow_execution_id,json=workflowExecutionId,proto3" json:"workflow_execution_id,omitempty"`
	// Indicates the number of resources to be returned.
	// +required
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the, server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// +optional
	Filters string `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering.
	// +optional
	SortBy *Sort `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// contains filtered or unexported fields
}

SignalListRequest represents a request structure to retrieve a collection of signals. See :ref:`ref_flyteidl.admin.Signal` for more details

func (*SignalListRequest) Descriptor deprecated 

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

Deprecated: Use SignalListRequest.ProtoReflect.Descriptor instead.

func (*SignalListRequest) GetFilters 

func (x *SignalListRequest) GetFilters() string

func (*SignalListRequest) GetLimit 

func (x *SignalListRequest) GetLimit() uint32

func (*SignalListRequest) GetSortBy 

func (x *SignalListRequest) GetSortBy() *Sort

func (*SignalListRequest) GetToken 

func (x *SignalListRequest) GetToken() string

func (*SignalListRequest) GetWorkflowExecutionId 

func (x *SignalListRequest) GetWorkflowExecutionId() *core.WorkflowExecutionIdentifier

func (*SignalListRequest) ProtoMessage 

func (*SignalListRequest) ProtoMessage()

func (*SignalListRequest) ProtoReflect added in v1.10.7 

func (x *SignalListRequest) ProtoReflect() protoreflect.Message

func (*SignalListRequest) Reset 

func (x *SignalListRequest) Reset()

func (*SignalListRequest) String 

func (x *SignalListRequest) String() string

type SignalSetRequest 

type SignalSetRequest struct {

	// A unique identifier for the requested signal.
	Id *core.SignalIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The value of this signal, must match the defining signal type.
	Value *core.Literal `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

SignalSetRequest represents a request structure to set the value on a signal. Setting a signal effetively satisfies the signal condition within a Flyte workflow. See :ref:`ref_flyteidl.admin.Signal` for more details

func (*SignalSetRequest) Descriptor deprecated 

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

Deprecated: Use SignalSetRequest.ProtoReflect.Descriptor instead.

func (*SignalSetRequest) GetId 

func (x *SignalSetRequest) GetId() *core.SignalIdentifier

func (*SignalSetRequest) GetValue 

func (x *SignalSetRequest) GetValue() *core.Literal

func (*SignalSetRequest) ProtoMessage 

func (*SignalSetRequest) ProtoMessage()

func (*SignalSetRequest) ProtoReflect added in v1.10.7 

func (x *SignalSetRequest) ProtoReflect() protoreflect.Message

func (*SignalSetRequest) Reset 

func (x *SignalSetRequest) Reset()

func (*SignalSetRequest) String 

func (x *SignalSetRequest) String() string

type SignalSetResponse 

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

SignalSetResponse represents a response structure if signal setting succeeds.

func (*SignalSetResponse) Descriptor deprecated 

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

Deprecated: Use SignalSetResponse.ProtoReflect.Descriptor instead.

func (*SignalSetResponse) ProtoMessage 

func (*SignalSetResponse) ProtoMessage()

func (*SignalSetResponse) ProtoReflect added in v1.10.7 

func (x *SignalSetResponse) ProtoReflect() protoreflect.Message

func (*SignalSetResponse) Reset 

func (x *SignalSetResponse) Reset()

func (*SignalSetResponse) String 

func (x *SignalSetResponse) String() string

type SlackNotification 

type SlackNotification struct {

	// Currently, Slack notifications leverage email to trigger a notification.
	// +required
	RecipientsEmail []string `protobuf:"bytes,1,rep,name=recipients_email,json=recipientsEmail,proto3" json:"recipients_email,omitempty"`
	// contains filtered or unexported fields
}

Defines a slack notification specification.

func (*SlackNotification) Descriptor deprecated 

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

Deprecated: Use SlackNotification.ProtoReflect.Descriptor instead.

func (*SlackNotification) GetRecipientsEmail 

func (x *SlackNotification) GetRecipientsEmail() []string

func (*SlackNotification) ProtoMessage 

func (*SlackNotification) ProtoMessage()

func (*SlackNotification) ProtoReflect added in v1.10.7 

func (x *SlackNotification) ProtoReflect() protoreflect.Message

func (*SlackNotification) Reset 

func (x *SlackNotification) Reset()

func (*SlackNotification) String 

func (x *SlackNotification) String() string

type Sort 

type Sort struct {

	// Indicates an attribute to sort the response values.
	// +required
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Indicates the direction to apply sort key for response values.
	// +optional
	Direction Sort_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=flyteidl.admin.Sort_Direction" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

Specifies sort ordering in a list request.

func (*Sort) Descriptor deprecated 

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

Deprecated: Use Sort.ProtoReflect.Descriptor instead.

func (*Sort) GetDirection 

func (x *Sort) GetDirection() Sort_Direction

func (*Sort) GetKey 

func (x *Sort) GetKey() string

func (*Sort) ProtoMessage 

func (*Sort) ProtoMessage()

func (*Sort) ProtoReflect added in v1.10.7 

func (x *Sort) ProtoReflect() protoreflect.Message

func (*Sort) Reset 

func (x *Sort) Reset()

func (*Sort) String 

func (x *Sort) String() string

type Sort_Direction 

type Sort_Direction int32
const (
	// By default, fields are sorted in descending order.
	Sort_DESCENDING Sort_Direction = 0
	Sort_ASCENDING  Sort_Direction = 1
)

func (Sort_Direction) Descriptor added in v1.10.7 

func (Sort_Direction) Descriptor() protoreflect.EnumDescriptor

func (Sort_Direction) Enum added in v1.10.7 

func (x Sort_Direction) Enum() *Sort_Direction

func (Sort_Direction) EnumDescriptor deprecated 

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

Deprecated: Use Sort_Direction.Descriptor instead.

func (Sort_Direction) Number added in v1.10.7 

func (x Sort_Direction) Number() protoreflect.EnumNumber

func (Sort_Direction) String 

func (x Sort_Direction) String() string

func (Sort_Direction) Type added in v1.10.7 

func (Sort_Direction) Type() protoreflect.EnumType

type SourceCode 

type SourceCode struct {
	Link string `protobuf:"bytes,1,opt,name=link,proto3" json:"link,omitempty"`
	// contains filtered or unexported fields
}

Link to source code used to define this entity

func (*SourceCode) Descriptor deprecated 

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

Deprecated: Use SourceCode.ProtoReflect.Descriptor instead. 

func (x *SourceCode) GetLink() string

func (*SourceCode) ProtoMessage 

func (*SourceCode) ProtoMessage()

func (*SourceCode) ProtoReflect added in v1.10.7 

func (x *SourceCode) ProtoReflect() protoreflect.Message

func (*SourceCode) Reset 

func (x *SourceCode) Reset()

func (*SourceCode) String 

func (x *SourceCode) String() string

type State deprecated 

type State int32

The state of the execution is used to control its visibility in the UI/CLI.

Deprecated: Marked as deprecated in flyteidl/admin/agent.proto. 

const (
	State_RETRYABLE_FAILURE State = 0
	State_PERMANENT_FAILURE State = 1
	State_PENDING           State = 2
	State_RUNNING           State = 3
	State_SUCCEEDED         State = 4
)

func (State) Descriptor added in v1.10.7 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum added in v1.10.7 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number added in v1.10.7 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

func (State) Type added in v1.10.7 

func (State) Type() protoreflect.EnumType

type SystemMetadata 

type SystemMetadata struct {

	// Which execution cluster this execution ran on.
	ExecutionCluster string `protobuf:"bytes,1,opt,name=execution_cluster,json=executionCluster,proto3" json:"execution_cluster,omitempty"`
	// Which kubernetes namespace the execution ran under.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

Represents system, rather than user-facing, metadata about an execution.

func (*SystemMetadata) Descriptor deprecated 

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

Deprecated: Use SystemMetadata.ProtoReflect.Descriptor instead.

func (*SystemMetadata) GetExecutionCluster 

func (x *SystemMetadata) GetExecutionCluster() string

func (*SystemMetadata) GetNamespace 

func (x *SystemMetadata) GetNamespace() string

func (*SystemMetadata) ProtoMessage 

func (*SystemMetadata) ProtoMessage()

func (*SystemMetadata) ProtoReflect added in v1.10.7 

func (x *SystemMetadata) ProtoReflect() protoreflect.Message

func (*SystemMetadata) Reset 

func (x *SystemMetadata) Reset()

func (*SystemMetadata) String 

func (x *SystemMetadata) String() string

type Task 

type Task struct {

	// id represents the unique identifier of the task.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// closure encapsulates all the fields that maps to a compiled version of the task.
	Closure *TaskClosure `protobuf:"bytes,2,opt,name=closure,proto3" json:"closure,omitempty"`
	// One-liner overview of the entity.
	ShortDescription string `protobuf:"bytes,3,opt,name=short_description,json=shortDescription,proto3" json:"short_description,omitempty"`
	// contains filtered or unexported fields
}

Flyte workflows are composed of many ordered tasks. That is small, reusable, self-contained logical blocks arranged to process workflow inputs and produce a deterministic set of outputs. Tasks can come in many varieties tuned for specialized behavior.

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetClosure 

func (x *Task) GetClosure() *TaskClosure

func (*Task) GetId 

func (x *Task) GetId() *core.Identifier

func (*Task) GetShortDescription 

func (x *Task) GetShortDescription() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect added in v1.10.7 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskCategory added in v1.11.0 

type TaskCategory struct {

	// The name of the task type.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The version of the task type.
	Version int32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskCategory) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use TaskCategory.ProtoReflect.Descriptor instead.

func (*TaskCategory) GetName added in v1.11.0 

func (x *TaskCategory) GetName() string

func (*TaskCategory) GetVersion added in v1.11.0 

func (x *TaskCategory) GetVersion() int32

func (*TaskCategory) ProtoMessage added in v1.11.0 

func (*TaskCategory) ProtoMessage()

func (*TaskCategory) ProtoReflect added in v1.11.0 

func (x *TaskCategory) ProtoReflect() protoreflect.Message

func (*TaskCategory) Reset added in v1.11.0 

func (x *TaskCategory) Reset()

func (*TaskCategory) String added in v1.11.0 

func (x *TaskCategory) String() string

type TaskClosure 

type TaskClosure struct {

	// Represents the compiled representation of the task from the specification provided.
	CompiledTask *core.CompiledTask `protobuf:"bytes,1,opt,name=compiled_task,json=compiledTask,proto3" json:"compiled_task,omitempty"`
	// Time at which the task was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

Compute task attributes which include values derived from the TaskSpec, as well as plugin-specific data and task metadata.

func (*TaskClosure) Descriptor deprecated 

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

Deprecated: Use TaskClosure.ProtoReflect.Descriptor instead.

func (*TaskClosure) GetCompiledTask 

func (x *TaskClosure) GetCompiledTask() *core.CompiledTask

func (*TaskClosure) GetCreatedAt 

func (x *TaskClosure) GetCreatedAt() *timestamppb.Timestamp

func (*TaskClosure) ProtoMessage 

func (*TaskClosure) ProtoMessage()

func (*TaskClosure) ProtoReflect added in v1.10.7 

func (x *TaskClosure) ProtoReflect() protoreflect.Message

func (*TaskClosure) Reset 

func (x *TaskClosure) Reset()

func (*TaskClosure) String 

func (x *TaskClosure) String() string

type TaskCreateRequest 

type TaskCreateRequest struct {

	// id represents the unique identifier of the task.
	// +required
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Represents the specification for task.
	// +required
	Spec *TaskSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to create a revision of a task. See :ref:`ref_flyteidl.admin.Task` for more details

func (*TaskCreateRequest) Descriptor deprecated 

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

Deprecated: Use TaskCreateRequest.ProtoReflect.Descriptor instead.

func (*TaskCreateRequest) GetId 

func (x *TaskCreateRequest) GetId() *core.Identifier

func (*TaskCreateRequest) GetSpec 

func (x *TaskCreateRequest) GetSpec() *TaskSpec

func (*TaskCreateRequest) ProtoMessage 

func (*TaskCreateRequest) ProtoMessage()

func (*TaskCreateRequest) ProtoReflect added in v1.10.7 

func (x *TaskCreateRequest) ProtoReflect() protoreflect.Message

func (*TaskCreateRequest) Reset 

func (x *TaskCreateRequest) Reset()

func (*TaskCreateRequest) String 

func (x *TaskCreateRequest) String() string

type TaskCreateResponse 

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

Represents a response structure if task creation succeeds.

func (*TaskCreateResponse) Descriptor deprecated 

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

Deprecated: Use TaskCreateResponse.ProtoReflect.Descriptor instead.

func (*TaskCreateResponse) ProtoMessage 

func (*TaskCreateResponse) ProtoMessage()

func (*TaskCreateResponse) ProtoReflect added in v1.10.7 

func (x *TaskCreateResponse) ProtoReflect() protoreflect.Message

func (*TaskCreateResponse) Reset 

func (x *TaskCreateResponse) Reset()

func (*TaskCreateResponse) String 

func (x *TaskCreateResponse) String() string

type TaskExecution 

type TaskExecution struct {

	// Unique identifier for the task execution.
	Id *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Path to remote data store where input blob is stored.
	InputUri string `protobuf:"bytes,2,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Task execution details and results.
	Closure *TaskExecutionClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	// Whether this task spawned nodes.
	IsParent bool `protobuf:"varint,4,opt,name=is_parent,json=isParent,proto3" json:"is_parent,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates all details for a single task execution entity. A task execution represents an instantiated task, including all inputs and additional metadata as well as computed results included state, outputs, and duration-based attributes.

func (*TaskExecution) Descriptor deprecated 

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

Deprecated: Use TaskExecution.ProtoReflect.Descriptor instead.

func (*TaskExecution) GetClosure 

func (x *TaskExecution) GetClosure() *TaskExecutionClosure

func (*TaskExecution) GetId 

func (x *TaskExecution) GetId() *core.TaskExecutionIdentifier

func (*TaskExecution) GetInputUri 

func (x *TaskExecution) GetInputUri() string

func (*TaskExecution) GetIsParent 

func (x *TaskExecution) GetIsParent() bool

func (*TaskExecution) ProtoMessage 

func (*TaskExecution) ProtoMessage()

func (*TaskExecution) ProtoReflect added in v1.10.7 

func (x *TaskExecution) ProtoReflect() protoreflect.Message

func (*TaskExecution) Reset 

func (x *TaskExecution) Reset()

func (*TaskExecution) String 

func (x *TaskExecution) String() string

type TaskExecutionClosure 

type TaskExecutionClosure struct {

	// Types that are assignable to OutputResult:
	//
	//	*TaskExecutionClosure_OutputUri
	//	*TaskExecutionClosure_Error
	//	*TaskExecutionClosure_OutputData
	OutputResult isTaskExecutionClosure_OutputResult `protobuf_oneof:"output_result"`
	// The last recorded phase for this task execution.
	Phase core.TaskExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.TaskExecution_Phase" json:"phase,omitempty"`
	// Detailed log information output by the task execution.
	Logs []*core.TaskLog `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"`
	// Time at which the task execution began running.
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// The amount of time the task execution spent running.
	Duration *durationpb.Duration `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// Time at which the task execution was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Time at which the task execution was last updated.
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Custom data specific to the task plugin.
	CustomInfo *structpb.Struct `protobuf:"bytes,9,opt,name=custom_info,json=customInfo,proto3" json:"custom_info,omitempty"`
	// If there is an explanation for the most recent phase transition, the reason will capture it.
	Reason string `protobuf:"bytes,10,opt,name=reason,proto3" json:"reason,omitempty"`
	// A predefined yet extensible Task type identifier.
	TaskType string `protobuf:"bytes,11,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// Metadata around how a task was executed.
	Metadata *event.TaskExecutionMetadata `protobuf:"bytes,16,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The event version is used to indicate versioned changes in how data is maintained using this
	// proto message. For example, event_verison > 0 means that maps tasks logs use the
	// TaskExecutionMetadata ExternalResourceInfo fields for each subtask rather than the TaskLog
	// in this message.
	EventVersion int32 `protobuf:"varint,17,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
	// A time-series of the phase transition or update explanations. This, when compared to storing a singular reason
	// as previously done, is much more valuable in visualizing and understanding historical evaluations.
	Reasons []*Reason `protobuf:"bytes,18,rep,name=reasons,proto3" json:"reasons,omitempty"`
	// contains filtered or unexported fields
}

Container for task execution details and results.

func (*TaskExecutionClosure) Descriptor deprecated 

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

Deprecated: Use TaskExecutionClosure.ProtoReflect.Descriptor instead.

func (*TaskExecutionClosure) GetCreatedAt 

func (x *TaskExecutionClosure) GetCreatedAt() *timestamppb.Timestamp

func (*TaskExecutionClosure) GetCustomInfo 

func (x *TaskExecutionClosure) GetCustomInfo() *structpb.Struct

func (*TaskExecutionClosure) GetDuration 

func (x *TaskExecutionClosure) GetDuration() *durationpb.Duration

func (*TaskExecutionClosure) GetError 

func (x *TaskExecutionClosure) GetError() *core.ExecutionError

func (*TaskExecutionClosure) GetEventVersion 

func (x *TaskExecutionClosure) GetEventVersion() int32

func (*TaskExecutionClosure) GetLogs 

func (x *TaskExecutionClosure) GetLogs() []*core.TaskLog

func (*TaskExecutionClosure) GetMetadata 

func (x *TaskExecutionClosure) GetMetadata() *event.TaskExecutionMetadata

func (*TaskExecutionClosure) GetOutputData deprecated 

func (x *TaskExecutionClosure) GetOutputData() *core.LiteralMap

Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.

func (*TaskExecutionClosure) GetOutputResult 

func (m *TaskExecutionClosure) GetOutputResult() isTaskExecutionClosure_OutputResult

func (*TaskExecutionClosure) GetOutputUri deprecated 

func (x *TaskExecutionClosure) GetOutputUri() string

Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.

func (*TaskExecutionClosure) GetPhase 

func (x *TaskExecutionClosure) GetPhase() core.TaskExecution_Phase

func (*TaskExecutionClosure) GetReason 

func (x *TaskExecutionClosure) GetReason() string

func (*TaskExecutionClosure) GetReasons 

func (x *TaskExecutionClosure) GetReasons() []*Reason

func (*TaskExecutionClosure) GetStartedAt 

func (x *TaskExecutionClosure) GetStartedAt() *timestamppb.Timestamp

func (*TaskExecutionClosure) GetTaskType 

func (x *TaskExecutionClosure) GetTaskType() string

func (*TaskExecutionClosure) GetUpdatedAt 

func (x *TaskExecutionClosure) GetUpdatedAt() *timestamppb.Timestamp

func (*TaskExecutionClosure) ProtoMessage 

func (*TaskExecutionClosure) ProtoMessage()

func (*TaskExecutionClosure) ProtoReflect added in v1.10.7 

func (x *TaskExecutionClosure) ProtoReflect() protoreflect.Message

func (*TaskExecutionClosure) Reset 

func (x *TaskExecutionClosure) Reset()

func (*TaskExecutionClosure) String 

func (x *TaskExecutionClosure) String() string

type TaskExecutionClosure_Error 

type TaskExecutionClosure_Error struct {
	// Error information for the task execution. Populated if the execution failed.
	Error *core.ExecutionError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type TaskExecutionClosure_OutputData 

type TaskExecutionClosure_OutputData struct {
	// Raw output data produced by this task execution.
	// DEPRECATED. Use GetTaskExecutionData to fetch output data instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.
	OutputData *core.LiteralMap `protobuf:"bytes,12,opt,name=output_data,json=outputData,proto3,oneof"`
}

type TaskExecutionClosure_OutputUri 

type TaskExecutionClosure_OutputUri struct {
	// Path to remote data store where output blob is stored if the execution succeeded (and produced outputs).
	// DEPRECATED. Use GetTaskExecutionData to fetch output data instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.
	OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type TaskExecutionEventRequest 

type TaskExecutionEventRequest struct {

	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event *event.TaskExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

Request to send a notification that a task execution event has occurred.

func (*TaskExecutionEventRequest) Descriptor deprecated 

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

Deprecated: Use TaskExecutionEventRequest.ProtoReflect.Descriptor instead.

func (*TaskExecutionEventRequest) GetEvent 

func (x *TaskExecutionEventRequest) GetEvent() *event.TaskExecutionEvent

func (*TaskExecutionEventRequest) GetRequestId 

func (x *TaskExecutionEventRequest) GetRequestId() string

func (*TaskExecutionEventRequest) ProtoMessage 

func (*TaskExecutionEventRequest) ProtoMessage()

func (*TaskExecutionEventRequest) ProtoReflect added in v1.10.7 

func (x *TaskExecutionEventRequest) ProtoReflect() protoreflect.Message

func (*TaskExecutionEventRequest) Reset 

func (x *TaskExecutionEventRequest) Reset()

func (*TaskExecutionEventRequest) String 

func (x *TaskExecutionEventRequest) String() string

type TaskExecutionEventResponse 

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

func (*TaskExecutionEventResponse) Descriptor deprecated 

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

Deprecated: Use TaskExecutionEventResponse.ProtoReflect.Descriptor instead.

func (*TaskExecutionEventResponse) ProtoMessage 

func (*TaskExecutionEventResponse) ProtoMessage()

func (*TaskExecutionEventResponse) ProtoReflect added in v1.10.7 

func (x *TaskExecutionEventResponse) ProtoReflect() protoreflect.Message

func (*TaskExecutionEventResponse) Reset 

func (x *TaskExecutionEventResponse) Reset()

func (*TaskExecutionEventResponse) String 

func (x *TaskExecutionEventResponse) String() string

type TaskExecutionGetDataRequest 

type TaskExecutionGetDataRequest struct {

	// The identifier of the task execution for which to fetch inputs and outputs.
	// +required
	Id *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Request structure to fetch inputs and output for a task execution. By default this data is not returned inline in :ref:`ref_flyteidl.admin.TaskExecutionGetRequest`

func (*TaskExecutionGetDataRequest) Descriptor deprecated 

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

Deprecated: Use TaskExecutionGetDataRequest.ProtoReflect.Descriptor instead.

func (*TaskExecutionGetDataRequest) GetId 

func (x *TaskExecutionGetDataRequest) GetId() *core.TaskExecutionIdentifier

func (*TaskExecutionGetDataRequest) ProtoMessage 

func (*TaskExecutionGetDataRequest) ProtoMessage()

func (*TaskExecutionGetDataRequest) ProtoReflect added in v1.10.7 

func (x *TaskExecutionGetDataRequest) ProtoReflect() protoreflect.Message

func (*TaskExecutionGetDataRequest) Reset 

func (x *TaskExecutionGetDataRequest) Reset()

func (*TaskExecutionGetDataRequest) String 

func (x *TaskExecutionGetDataRequest) String() string

type TaskExecutionGetDataResponse 

type TaskExecutionGetDataResponse struct {

	// Signed url to fetch a core.LiteralMap of task execution inputs.
	// Deprecated: Please use full_inputs instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.
	Inputs *UrlBlob `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of task execution outputs.
	// Deprecated: Please use full_outputs instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.
	Outputs *UrlBlob `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// Full_inputs will only be populated if they are under a configured size threshold.
	FullInputs *core.LiteralMap `protobuf:"bytes,3,opt,name=full_inputs,json=fullInputs,proto3" json:"full_inputs,omitempty"`
	// Full_outputs will only be populated if they are under a configured size threshold.
	FullOutputs *core.LiteralMap `protobuf:"bytes,4,opt,name=full_outputs,json=fullOutputs,proto3" json:"full_outputs,omitempty"`
	// flyte tiny url to fetch a core.LiteralMap of task execution's IO
	// Deck will be empty for task
	FlyteUrls *FlyteURLs `protobuf:"bytes,5,opt,name=flyte_urls,json=flyteUrls,proto3" json:"flyte_urls,omitempty"`
	// contains filtered or unexported fields
}

Response structure for TaskExecutionGetDataRequest which contains inputs and outputs for a task execution.

func (*TaskExecutionGetDataResponse) Descriptor deprecated 

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

Deprecated: Use TaskExecutionGetDataResponse.ProtoReflect.Descriptor instead.

func (*TaskExecutionGetDataResponse) GetFlyteUrls 

func (x *TaskExecutionGetDataResponse) GetFlyteUrls() *FlyteURLs

func (*TaskExecutionGetDataResponse) GetFullInputs 

func (x *TaskExecutionGetDataResponse) GetFullInputs() *core.LiteralMap

func (*TaskExecutionGetDataResponse) GetFullOutputs 

func (x *TaskExecutionGetDataResponse) GetFullOutputs() *core.LiteralMap

func (*TaskExecutionGetDataResponse) GetInputs deprecated 

func (x *TaskExecutionGetDataResponse) GetInputs() *UrlBlob

Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.

func (*TaskExecutionGetDataResponse) GetOutputs deprecated 

func (x *TaskExecutionGetDataResponse) GetOutputs() *UrlBlob

Deprecated: Marked as deprecated in flyteidl/admin/task_execution.proto.

func (*TaskExecutionGetDataResponse) ProtoMessage 

func (*TaskExecutionGetDataResponse) ProtoMessage()

func (*TaskExecutionGetDataResponse) ProtoReflect added in v1.10.7 

func (x *TaskExecutionGetDataResponse) ProtoReflect() protoreflect.Message

func (*TaskExecutionGetDataResponse) Reset 

func (x *TaskExecutionGetDataResponse) Reset()

func (*TaskExecutionGetDataResponse) String 

func (x *TaskExecutionGetDataResponse) String() string

type TaskExecutionGetRequest 

type TaskExecutionGetRequest struct {

	// Unique identifier for the task execution.
	// +required
	Id *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A message used to fetch a single task execution entity. See :ref:`ref_flyteidl.admin.TaskExecution` for more details

func (*TaskExecutionGetRequest) Descriptor deprecated 

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

Deprecated: Use TaskExecutionGetRequest.ProtoReflect.Descriptor instead.

func (*TaskExecutionGetRequest) GetId 

func (x *TaskExecutionGetRequest) GetId() *core.TaskExecutionIdentifier

func (*TaskExecutionGetRequest) ProtoMessage 

func (*TaskExecutionGetRequest) ProtoMessage()

func (*TaskExecutionGetRequest) ProtoReflect added in v1.10.7 

func (x *TaskExecutionGetRequest) ProtoReflect() protoreflect.Message

func (*TaskExecutionGetRequest) Reset 

func (x *TaskExecutionGetRequest) Reset()

func (*TaskExecutionGetRequest) String 

func (x *TaskExecutionGetRequest) String() string

type TaskExecutionList 

type TaskExecutionList struct {
	TaskExecutions []*TaskExecution `protobuf:"bytes,1,rep,name=task_executions,json=taskExecutions,proto3" json:"task_executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Response structure for a query to list of task execution entities. See :ref:`ref_flyteidl.admin.TaskExecution` for more details

func (*TaskExecutionList) Descriptor deprecated 

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

Deprecated: Use TaskExecutionList.ProtoReflect.Descriptor instead.

func (*TaskExecutionList) GetTaskExecutions 

func (x *TaskExecutionList) GetTaskExecutions() []*TaskExecution

func (*TaskExecutionList) GetToken 

func (x *TaskExecutionList) GetToken() string

func (*TaskExecutionList) ProtoMessage 

func (*TaskExecutionList) ProtoMessage()

func (*TaskExecutionList) ProtoReflect added in v1.10.7 

func (x *TaskExecutionList) ProtoReflect() protoreflect.Message

func (*TaskExecutionList) Reset 

func (x *TaskExecutionList) Reset()

func (*TaskExecutionList) String 

func (x *TaskExecutionList) String() string

type TaskExecutionListRequest 

type TaskExecutionListRequest struct {

	// Indicates the node execution to filter by.
	// +required
	NodeExecutionId *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=node_execution_id,json=nodeExecutionId,proto3" json:"node_execution_id,omitempty"`
	// Indicates the number of resources to be returned.
	// +required
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering for returned list.
	// +optional
	SortBy *Sort `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to retrieve a list of task execution entities yielded by a specific node execution. See :ref:`ref_flyteidl.admin.TaskExecution` for more details

func (*TaskExecutionListRequest) Descriptor deprecated 

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

Deprecated: Use TaskExecutionListRequest.ProtoReflect.Descriptor instead.

func (*TaskExecutionListRequest) GetFilters 

func (x *TaskExecutionListRequest) GetFilters() string

func (*TaskExecutionListRequest) GetLimit 

func (x *TaskExecutionListRequest) GetLimit() uint32

func (*TaskExecutionListRequest) GetNodeExecutionId 

func (x *TaskExecutionListRequest) GetNodeExecutionId() *core.NodeExecutionIdentifier

func (*TaskExecutionListRequest) GetSortBy 

func (x *TaskExecutionListRequest) GetSortBy() *Sort

func (*TaskExecutionListRequest) GetToken 

func (x *TaskExecutionListRequest) GetToken() string

func (*TaskExecutionListRequest) ProtoMessage 

func (*TaskExecutionListRequest) ProtoMessage()

func (*TaskExecutionListRequest) ProtoReflect added in v1.10.7 

func (x *TaskExecutionListRequest) ProtoReflect() protoreflect.Message

func (*TaskExecutionListRequest) Reset 

func (x *TaskExecutionListRequest) Reset()

func (*TaskExecutionListRequest) String 

func (x *TaskExecutionListRequest) String() string

type TaskExecutionMetadata 

type TaskExecutionMetadata struct {

	// ID of the task execution
	TaskExecutionId *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=task_execution_id,json=taskExecutionId,proto3" json:"task_execution_id,omitempty"`
	// k8s namespace where the task is executed in
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Labels attached to the task execution
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Annotations attached to the task execution
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// k8s service account associated with the task execution
	K8SServiceAccount string `protobuf:"bytes,5,opt,name=k8s_service_account,json=k8sServiceAccount,proto3" json:"k8s_service_account,omitempty"`
	// Environment variables attached to the task execution
	EnvironmentVariables map[string]string `` /* 209-byte string literal not displayed */
	// Represents the maximum number of attempts allowed for a task.
	// If a task fails, it can be retried up to this maximum number of attempts.
	MaxAttempts int32 `protobuf:"varint,7,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	// Indicates whether the task execution can be interrupted.
	// If set to true, the task can be stopped before completion.
	Interruptible bool `protobuf:"varint,8,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	// Specifies the threshold for failure count at which the interruptible property
	// will take effect. If the number of consecutive task failures exceeds this threshold,
	// interruptible behavior will be activated.
	InterruptibleFailureThreshold int32 `` /* 151-byte string literal not displayed */
	// Overrides for specific properties of the task node.
	// These overrides can be used to customize the behavior of the task node.
	Overrides *core.TaskNodeOverrides `protobuf:"bytes,10,opt,name=overrides,proto3" json:"overrides,omitempty"`
	// contains filtered or unexported fields
}

Represents a subset of runtime task execution metadata that are relevant to external plugins.

func (*TaskExecutionMetadata) Descriptor deprecated 

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

Deprecated: Use TaskExecutionMetadata.ProtoReflect.Descriptor instead.

func (*TaskExecutionMetadata) GetAnnotations 

func (x *TaskExecutionMetadata) GetAnnotations() map[string]string

func (*TaskExecutionMetadata) GetEnvironmentVariables 

func (x *TaskExecutionMetadata) GetEnvironmentVariables() map[string]string

func (*TaskExecutionMetadata) GetInterruptible added in v1.11.0 

func (x *TaskExecutionMetadata) GetInterruptible() bool

func (*TaskExecutionMetadata) GetInterruptibleFailureThreshold added in v1.11.0 

func (x *TaskExecutionMetadata) GetInterruptibleFailureThreshold() int32

func (*TaskExecutionMetadata) GetK8SServiceAccount 

func (x *TaskExecutionMetadata) GetK8SServiceAccount() string

func (*TaskExecutionMetadata) GetLabels 

func (x *TaskExecutionMetadata) GetLabels() map[string]string

func (*TaskExecutionMetadata) GetMaxAttempts added in v1.11.0 

func (x *TaskExecutionMetadata) GetMaxAttempts() int32

func (*TaskExecutionMetadata) GetNamespace 

func (x *TaskExecutionMetadata) GetNamespace() string

func (*TaskExecutionMetadata) GetOverrides added in v1.11.0 

func (x *TaskExecutionMetadata) GetOverrides() *core.TaskNodeOverrides

func (*TaskExecutionMetadata) GetTaskExecutionId 

func (x *TaskExecutionMetadata) GetTaskExecutionId() *core.TaskExecutionIdentifier

func (*TaskExecutionMetadata) ProtoMessage 

func (*TaskExecutionMetadata) ProtoMessage()

func (*TaskExecutionMetadata) ProtoReflect added in v1.10.7 

func (x *TaskExecutionMetadata) ProtoReflect() protoreflect.Message

func (*TaskExecutionMetadata) Reset 

func (x *TaskExecutionMetadata) Reset()

func (*TaskExecutionMetadata) String 

func (x *TaskExecutionMetadata) String() string

type TaskList 

type TaskList struct {

	// A list of tasks returned based on the request.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Represents a list of tasks returned from the admin. See :ref:`ref_flyteidl.admin.Task` for more details

func (*TaskList) Descriptor deprecated 

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

Deprecated: Use TaskList.ProtoReflect.Descriptor instead.

func (*TaskList) GetTasks 

func (x *TaskList) GetTasks() []*Task

func (*TaskList) GetToken 

func (x *TaskList) GetToken() string

func (*TaskList) ProtoMessage 

func (*TaskList) ProtoMessage()

func (*TaskList) ProtoReflect added in v1.10.7 

func (x *TaskList) ProtoReflect() protoreflect.Message

func (*TaskList) Reset 

func (x *TaskList) Reset()

func (*TaskList) String 

func (x *TaskList) String() string

type TaskNodeMetadata 

type TaskNodeMetadata struct {

	// Captures the status of caching for this execution.
	CacheStatus core.CatalogCacheStatus `` /* 133-byte string literal not displayed */
	// This structure carries the catalog artifact information
	CatalogKey *core.CatalogMetadata `protobuf:"bytes,2,opt,name=catalog_key,json=catalogKey,proto3" json:"catalog_key,omitempty"`
	// The latest checkpoint location
	CheckpointUri string `protobuf:"bytes,4,opt,name=checkpoint_uri,json=checkpointUri,proto3" json:"checkpoint_uri,omitempty"`
	// contains filtered or unexported fields
}

Metadata for the case in which the node is a TaskNode

func (*TaskNodeMetadata) Descriptor deprecated 

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

Deprecated: Use TaskNodeMetadata.ProtoReflect.Descriptor instead.

func (*TaskNodeMetadata) GetCacheStatus 

func (x *TaskNodeMetadata) GetCacheStatus() core.CatalogCacheStatus

func (*TaskNodeMetadata) GetCatalogKey 

func (x *TaskNodeMetadata) GetCatalogKey() *core.CatalogMetadata

func (*TaskNodeMetadata) GetCheckpointUri 

func (x *TaskNodeMetadata) GetCheckpointUri() string

func (*TaskNodeMetadata) ProtoMessage 

func (*TaskNodeMetadata) ProtoMessage()

func (*TaskNodeMetadata) ProtoReflect added in v1.10.7 

func (x *TaskNodeMetadata) ProtoReflect() protoreflect.Message

func (*TaskNodeMetadata) Reset 

func (x *TaskNodeMetadata) Reset()

func (*TaskNodeMetadata) String 

func (x *TaskNodeMetadata) String() string

type TaskResourceAttributes 

type TaskResourceAttributes struct {
	Defaults *TaskResourceSpec `protobuf:"bytes,1,opt,name=defaults,proto3" json:"defaults,omitempty"`
	Limits   *TaskResourceSpec `protobuf:"bytes,2,opt,name=limits,proto3" json:"limits,omitempty"`
	// contains filtered or unexported fields
}

Defines task resource defaults and limits that will be applied at task registration.

func (*TaskResourceAttributes) Descriptor deprecated 

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

Deprecated: Use TaskResourceAttributes.ProtoReflect.Descriptor instead.

func (*TaskResourceAttributes) GetDefaults 

func (x *TaskResourceAttributes) GetDefaults() *TaskResourceSpec

func (*TaskResourceAttributes) GetLimits 

func (x *TaskResourceAttributes) GetLimits() *TaskResourceSpec

func (*TaskResourceAttributes) ProtoMessage 

func (*TaskResourceAttributes) ProtoMessage()

func (*TaskResourceAttributes) ProtoReflect added in v1.10.7 

func (x *TaskResourceAttributes) ProtoReflect() protoreflect.Message

func (*TaskResourceAttributes) Reset 

func (x *TaskResourceAttributes) Reset()

func (*TaskResourceAttributes) String 

func (x *TaskResourceAttributes) String() string

type TaskResourceSpec 

type TaskResourceSpec struct {
	Cpu              string `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Gpu              string `protobuf:"bytes,2,opt,name=gpu,proto3" json:"gpu,omitempty"`
	Memory           string `protobuf:"bytes,3,opt,name=memory,proto3" json:"memory,omitempty"`
	Storage          string `protobuf:"bytes,4,opt,name=storage,proto3" json:"storage,omitempty"`
	EphemeralStorage string `protobuf:"bytes,5,opt,name=ephemeral_storage,json=ephemeralStorage,proto3" json:"ephemeral_storage,omitempty"`
	// contains filtered or unexported fields
}

Defines a set of overridable task resource attributes set during task registration.

func (*TaskResourceSpec) Descriptor deprecated 

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

Deprecated: Use TaskResourceSpec.ProtoReflect.Descriptor instead.

func (*TaskResourceSpec) GetCpu 

func (x *TaskResourceSpec) GetCpu() string

func (*TaskResourceSpec) GetEphemeralStorage 

func (x *TaskResourceSpec) GetEphemeralStorage() string

func (*TaskResourceSpec) GetGpu 

func (x *TaskResourceSpec) GetGpu() string

func (*TaskResourceSpec) GetMemory 

func (x *TaskResourceSpec) GetMemory() string

func (*TaskResourceSpec) GetStorage 

func (x *TaskResourceSpec) GetStorage() string

func (*TaskResourceSpec) ProtoMessage 

func (*TaskResourceSpec) ProtoMessage()

func (*TaskResourceSpec) ProtoReflect added in v1.10.7 

func (x *TaskResourceSpec) ProtoReflect() protoreflect.Message

func (*TaskResourceSpec) Reset 

func (x *TaskResourceSpec) Reset()

func (*TaskResourceSpec) String 

func (x *TaskResourceSpec) String() string

type TaskSpec 

type TaskSpec struct {

	// Template of the task that encapsulates all the metadata of the task.
	Template *core.TaskTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// Represents the specification for description entity.
	Description *DescriptionEntity `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

Represents a structure that encapsulates the user-configured specification of the task.

func (*TaskSpec) Descriptor deprecated 

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

Deprecated: Use TaskSpec.ProtoReflect.Descriptor instead.

func (*TaskSpec) GetDescription 

func (x *TaskSpec) GetDescription() *DescriptionEntity

func (*TaskSpec) GetTemplate 

func (x *TaskSpec) GetTemplate() *core.TaskTemplate

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) ProtoReflect added in v1.10.7 

func (x *TaskSpec) ProtoReflect() protoreflect.Message

func (*TaskSpec) Reset 

func (x *TaskSpec) Reset()

func (*TaskSpec) String 

func (x *TaskSpec) String() string

type UrlBlob deprecated 

type UrlBlob struct {

	// Actual url value.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Represents the size of the file accessible at the above url.
	Bytes int64 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// contains filtered or unexported fields
}

Represents a string url and associated metadata used throughout the platform.

Deprecated: Marked as deprecated in flyteidl/admin/common.proto.

func (*UrlBlob) Descriptor deprecated 

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

Deprecated: Use UrlBlob.ProtoReflect.Descriptor instead.

func (*UrlBlob) GetBytes 

func (x *UrlBlob) GetBytes() int64

func (*UrlBlob) GetUrl 

func (x *UrlBlob) GetUrl() string

func (*UrlBlob) ProtoMessage 

func (*UrlBlob) ProtoMessage()

func (*UrlBlob) ProtoReflect added in v1.10.7 

func (x *UrlBlob) ProtoReflect() protoreflect.Message

func (*UrlBlob) Reset 

func (x *UrlBlob) Reset()

func (*UrlBlob) String 

func (x *UrlBlob) String() string

type Version 

type Version struct {

	// Specifies the GIT sha of the build
	Build string `protobuf:"bytes,1,opt,name=Build,proto3" json:"Build,omitempty"`
	// Version for the build, should follow a semver
	Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	// Build timestamp
	BuildTime string `protobuf:"bytes,3,opt,name=BuildTime,proto3" json:"BuildTime,omitempty"`
	// contains filtered or unexported fields
}

Provides Version information for a component

func (*Version) Descriptor deprecated 

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetBuild 

func (x *Version) GetBuild() string

func (*Version) GetBuildTime 

func (x *Version) GetBuildTime() string

func (*Version) GetVersion 

func (x *Version) GetVersion() string

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect added in v1.10.7 

func (x *Version) ProtoReflect() protoreflect.Message

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

type Workflow 

type Workflow struct {

	// id represents the unique identifier of the workflow.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// closure encapsulates all the fields that maps to a compiled version of the workflow.
	Closure *WorkflowClosure `protobuf:"bytes,2,opt,name=closure,proto3" json:"closure,omitempty"`
	// One-liner overview of the entity.
	ShortDescription string `protobuf:"bytes,3,opt,name=short_description,json=shortDescription,proto3" json:"short_description,omitempty"`
	// contains filtered or unexported fields
}

Represents the workflow structure stored in the Admin A workflow is created by ordering tasks and associating outputs to inputs in order to produce a directed-acyclic execution graph.

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetClosure 

func (x *Workflow) GetClosure() *WorkflowClosure

func (*Workflow) GetId 

func (x *Workflow) GetId() *core.Identifier

func (*Workflow) GetShortDescription 

func (x *Workflow) GetShortDescription() string

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect added in v1.10.7 

func (x *Workflow) ProtoReflect() protoreflect.Message

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) String 

func (x *Workflow) String() string

type WorkflowAttributes 

type WorkflowAttributes struct {

	// Unique project id for which this set of attributes will be applied.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id for which this set of attributes will be applied.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Workflow name for which this set of attributes will be applied.
	Workflow           string              `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	MatchingAttributes *MatchingAttributes `protobuf:"bytes,4,opt,name=matching_attributes,json=matchingAttributes,proto3" json:"matching_attributes,omitempty"`
	// Optional, org key applied to the attributes.
	Org string `protobuf:"bytes,5,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Defines a set of custom matching attributes which defines resource defaults for a project, domain and workflow. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*WorkflowAttributes) Descriptor deprecated 

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

Deprecated: Use WorkflowAttributes.ProtoReflect.Descriptor instead.

func (*WorkflowAttributes) GetDomain 

func (x *WorkflowAttributes) GetDomain() string

func (*WorkflowAttributes) GetMatchingAttributes 

func (x *WorkflowAttributes) GetMatchingAttributes() *MatchingAttributes

func (*WorkflowAttributes) GetOrg added in v1.10.7 

func (x *WorkflowAttributes) GetOrg() string

func (*WorkflowAttributes) GetProject 

func (x *WorkflowAttributes) GetProject() string

func (*WorkflowAttributes) GetWorkflow 

func (x *WorkflowAttributes) GetWorkflow() string

func (*WorkflowAttributes) ProtoMessage 

func (*WorkflowAttributes) ProtoMessage()

func (*WorkflowAttributes) ProtoReflect added in v1.10.7 

func (x *WorkflowAttributes) ProtoReflect() protoreflect.Message

func (*WorkflowAttributes) Reset 

func (x *WorkflowAttributes) Reset()

func (*WorkflowAttributes) String 

func (x *WorkflowAttributes) String() string

type WorkflowAttributesDeleteRequest 

type WorkflowAttributesDeleteRequest struct {

	// Unique project id which this set of attributes references.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Workflow name which this set of attributes references.
	// +required
	Workflow string `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// Which type of matchable attributes to delete.
	// +required
	ResourceType MatchableResource `` /* 136-byte string literal not displayed */
	// Optional, org key applied to the attributes.
	Org string `protobuf:"bytes,5,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to delete a set matchable workflow attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*WorkflowAttributesDeleteRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowAttributesDeleteRequest.ProtoReflect.Descriptor instead.

func (*WorkflowAttributesDeleteRequest) GetDomain 

func (x *WorkflowAttributesDeleteRequest) GetDomain() string

func (*WorkflowAttributesDeleteRequest) GetOrg added in v1.10.7 

func (x *WorkflowAttributesDeleteRequest) GetOrg() string

func (*WorkflowAttributesDeleteRequest) GetProject 

func (x *WorkflowAttributesDeleteRequest) GetProject() string

func (*WorkflowAttributesDeleteRequest) GetResourceType 

func (x *WorkflowAttributesDeleteRequest) GetResourceType() MatchableResource

func (*WorkflowAttributesDeleteRequest) GetWorkflow 

func (x *WorkflowAttributesDeleteRequest) GetWorkflow() string

func (*WorkflowAttributesDeleteRequest) ProtoMessage 

func (*WorkflowAttributesDeleteRequest) ProtoMessage()

func (*WorkflowAttributesDeleteRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowAttributesDeleteRequest) ProtoReflect() protoreflect.Message

func (*WorkflowAttributesDeleteRequest) Reset 

func (x *WorkflowAttributesDeleteRequest) Reset()

func (*WorkflowAttributesDeleteRequest) String 

func (x *WorkflowAttributesDeleteRequest) String() string

type WorkflowAttributesDeleteResponse 

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

Purposefully empty, may be populated in the future.

func (*WorkflowAttributesDeleteResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowAttributesDeleteResponse.ProtoReflect.Descriptor instead.

func (*WorkflowAttributesDeleteResponse) ProtoMessage 

func (*WorkflowAttributesDeleteResponse) ProtoMessage()

func (*WorkflowAttributesDeleteResponse) ProtoReflect added in v1.10.7 

func (x *WorkflowAttributesDeleteResponse) ProtoReflect() protoreflect.Message

func (*WorkflowAttributesDeleteResponse) Reset 

func (x *WorkflowAttributesDeleteResponse) Reset()

func (*WorkflowAttributesDeleteResponse) String 

func (x *WorkflowAttributesDeleteResponse) String() string

type WorkflowAttributesGetRequest 

type WorkflowAttributesGetRequest struct {

	// Unique project id which this set of attributes references.
	// +required
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	// +required
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Workflow name which this set of attributes references.
	// +required
	Workflow string `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// Which type of matchable attributes to return.
	// +required
	ResourceType MatchableResource `` /* 136-byte string literal not displayed */
	// Optional, org key applied to the attributes.
	Org string `protobuf:"bytes,5,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Request to get an individual workflow attribute override. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*WorkflowAttributesGetRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowAttributesGetRequest.ProtoReflect.Descriptor instead.

func (*WorkflowAttributesGetRequest) GetDomain 

func (x *WorkflowAttributesGetRequest) GetDomain() string

func (*WorkflowAttributesGetRequest) GetOrg added in v1.10.7 

func (x *WorkflowAttributesGetRequest) GetOrg() string

func (*WorkflowAttributesGetRequest) GetProject 

func (x *WorkflowAttributesGetRequest) GetProject() string

func (*WorkflowAttributesGetRequest) GetResourceType 

func (x *WorkflowAttributesGetRequest) GetResourceType() MatchableResource

func (*WorkflowAttributesGetRequest) GetWorkflow 

func (x *WorkflowAttributesGetRequest) GetWorkflow() string

func (*WorkflowAttributesGetRequest) ProtoMessage 

func (*WorkflowAttributesGetRequest) ProtoMessage()

func (*WorkflowAttributesGetRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowAttributesGetRequest) ProtoReflect() protoreflect.Message

func (*WorkflowAttributesGetRequest) Reset 

func (x *WorkflowAttributesGetRequest) Reset()

func (*WorkflowAttributesGetRequest) String 

func (x *WorkflowAttributesGetRequest) String() string

type WorkflowAttributesGetResponse 

type WorkflowAttributesGetResponse struct {
	Attributes *WorkflowAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Response to get an individual workflow attribute override.

func (*WorkflowAttributesGetResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowAttributesGetResponse.ProtoReflect.Descriptor instead.

func (*WorkflowAttributesGetResponse) GetAttributes 

func (x *WorkflowAttributesGetResponse) GetAttributes() *WorkflowAttributes

func (*WorkflowAttributesGetResponse) ProtoMessage 

func (*WorkflowAttributesGetResponse) ProtoMessage()

func (*WorkflowAttributesGetResponse) ProtoReflect added in v1.10.7 

func (x *WorkflowAttributesGetResponse) ProtoReflect() protoreflect.Message

func (*WorkflowAttributesGetResponse) Reset 

func (x *WorkflowAttributesGetResponse) Reset()

func (*WorkflowAttributesGetResponse) String 

func (x *WorkflowAttributesGetResponse) String() string

type WorkflowAttributesUpdateRequest 

type WorkflowAttributesUpdateRequest struct {
	Attributes *WorkflowAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

Sets custom attributes for a project, domain and workflow combination. For more info on matchable attributes, see :ref:`ref_flyteidl.admin.MatchableAttributesConfiguration`

func (*WorkflowAttributesUpdateRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowAttributesUpdateRequest.ProtoReflect.Descriptor instead.

func (*WorkflowAttributesUpdateRequest) GetAttributes 

func (x *WorkflowAttributesUpdateRequest) GetAttributes() *WorkflowAttributes

func (*WorkflowAttributesUpdateRequest) ProtoMessage 

func (*WorkflowAttributesUpdateRequest) ProtoMessage()

func (*WorkflowAttributesUpdateRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowAttributesUpdateRequest) ProtoReflect() protoreflect.Message

func (*WorkflowAttributesUpdateRequest) Reset 

func (x *WorkflowAttributesUpdateRequest) Reset()

func (*WorkflowAttributesUpdateRequest) String 

func (x *WorkflowAttributesUpdateRequest) String() string

type WorkflowAttributesUpdateResponse 

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

Purposefully empty, may be populated in the future.

func (*WorkflowAttributesUpdateResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowAttributesUpdateResponse.ProtoReflect.Descriptor instead.

func (*WorkflowAttributesUpdateResponse) ProtoMessage 

func (*WorkflowAttributesUpdateResponse) ProtoMessage()

func (*WorkflowAttributesUpdateResponse) ProtoReflect added in v1.10.7 

func (x *WorkflowAttributesUpdateResponse) ProtoReflect() protoreflect.Message

func (*WorkflowAttributesUpdateResponse) Reset 

func (x *WorkflowAttributesUpdateResponse) Reset()

func (*WorkflowAttributesUpdateResponse) String 

func (x *WorkflowAttributesUpdateResponse) String() string

type WorkflowClosure 

type WorkflowClosure struct {

	// Represents the compiled representation of the workflow from the specification provided.
	CompiledWorkflow *core.CompiledWorkflowClosure `protobuf:"bytes,1,opt,name=compiled_workflow,json=compiledWorkflow,proto3" json:"compiled_workflow,omitempty"`
	// Time at which the workflow was created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

A container holding the compiled workflow produced from the WorkflowSpec and additional metadata.

func (*WorkflowClosure) Descriptor deprecated 

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

Deprecated: Use WorkflowClosure.ProtoReflect.Descriptor instead.

func (*WorkflowClosure) GetCompiledWorkflow 

func (x *WorkflowClosure) GetCompiledWorkflow() *core.CompiledWorkflowClosure

func (*WorkflowClosure) GetCreatedAt 

func (x *WorkflowClosure) GetCreatedAt() *timestamppb.Timestamp

func (*WorkflowClosure) ProtoMessage 

func (*WorkflowClosure) ProtoMessage()

func (*WorkflowClosure) ProtoReflect added in v1.10.7 

func (x *WorkflowClosure) ProtoReflect() protoreflect.Message

func (*WorkflowClosure) Reset 

func (x *WorkflowClosure) Reset()

func (*WorkflowClosure) String 

func (x *WorkflowClosure) String() string

type WorkflowCreateRequest 

type WorkflowCreateRequest struct {

	// id represents the unique identifier of the workflow.
	// +required
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Represents the specification for workflow.
	// +required
	Spec *WorkflowSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Represents a request structure to create a revision of a workflow. See :ref:`ref_flyteidl.admin.Workflow` for more details

func (*WorkflowCreateRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowCreateRequest.ProtoReflect.Descriptor instead.

func (*WorkflowCreateRequest) GetId 

func (x *WorkflowCreateRequest) GetId() *core.Identifier

func (*WorkflowCreateRequest) GetSpec 

func (x *WorkflowCreateRequest) GetSpec() *WorkflowSpec

func (*WorkflowCreateRequest) ProtoMessage 

func (*WorkflowCreateRequest) ProtoMessage()

func (*WorkflowCreateRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowCreateRequest) ProtoReflect() protoreflect.Message

func (*WorkflowCreateRequest) Reset 

func (x *WorkflowCreateRequest) Reset()

func (*WorkflowCreateRequest) String 

func (x *WorkflowCreateRequest) String() string

type WorkflowCreateResponse 

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

func (*WorkflowCreateResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowCreateResponse.ProtoReflect.Descriptor instead.

func (*WorkflowCreateResponse) ProtoMessage 

func (*WorkflowCreateResponse) ProtoMessage()

func (*WorkflowCreateResponse) ProtoReflect added in v1.10.7 

func (x *WorkflowCreateResponse) ProtoReflect() protoreflect.Message

func (*WorkflowCreateResponse) Reset 

func (x *WorkflowCreateResponse) Reset()

func (*WorkflowCreateResponse) String 

func (x *WorkflowCreateResponse) String() string

type WorkflowErrorExistsDifferentStructure 

type WorkflowErrorExistsDifferentStructure struct {
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

The workflow id is already used and the structure is different

func (*WorkflowErrorExistsDifferentStructure) Descriptor deprecated 

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

Deprecated: Use WorkflowErrorExistsDifferentStructure.ProtoReflect.Descriptor instead.

func (*WorkflowErrorExistsDifferentStructure) GetId 

func (x *WorkflowErrorExistsDifferentStructure) GetId() *core.Identifier

func (*WorkflowErrorExistsDifferentStructure) ProtoMessage 

func (*WorkflowErrorExistsDifferentStructure) ProtoMessage()

func (*WorkflowErrorExistsDifferentStructure) ProtoReflect added in v1.10.7 

func (x *WorkflowErrorExistsDifferentStructure) ProtoReflect() protoreflect.Message

func (*WorkflowErrorExistsDifferentStructure) Reset 

func (x *WorkflowErrorExistsDifferentStructure) Reset()

func (*WorkflowErrorExistsDifferentStructure) String 

func (x *WorkflowErrorExistsDifferentStructure) String() string

type WorkflowErrorExistsIdenticalStructure 

type WorkflowErrorExistsIdenticalStructure struct {
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

The workflow id is already used with an identical sctructure

func (*WorkflowErrorExistsIdenticalStructure) Descriptor deprecated 

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

Deprecated: Use WorkflowErrorExistsIdenticalStructure.ProtoReflect.Descriptor instead.

func (*WorkflowErrorExistsIdenticalStructure) GetId 

func (x *WorkflowErrorExistsIdenticalStructure) GetId() *core.Identifier

func (*WorkflowErrorExistsIdenticalStructure) ProtoMessage 

func (*WorkflowErrorExistsIdenticalStructure) ProtoMessage()

func (*WorkflowErrorExistsIdenticalStructure) ProtoReflect added in v1.10.7 

func (x *WorkflowErrorExistsIdenticalStructure) ProtoReflect() protoreflect.Message

func (*WorkflowErrorExistsIdenticalStructure) Reset 

func (x *WorkflowErrorExistsIdenticalStructure) Reset()

func (*WorkflowErrorExistsIdenticalStructure) String 

func (x *WorkflowErrorExistsIdenticalStructure) String() string

type WorkflowExecutionConfig 

type WorkflowExecutionConfig struct {

	// Can be used to control the number of parallel nodes to run within the workflow. This is useful to achieve fairness.
	MaxParallelism int32 `protobuf:"varint,1,opt,name=max_parallelism,json=maxParallelism,proto3" json:"max_parallelism,omitempty"`
	// Indicates security context permissions for executions triggered with this matchable attribute.
	SecurityContext *core.SecurityContext `protobuf:"bytes,2,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.).
	RawOutputDataConfig *RawOutputDataConfig `protobuf:"bytes,3,opt,name=raw_output_data_config,json=rawOutputDataConfig,proto3" json:"raw_output_data_config,omitempty"`
	// Custom labels to be applied to a triggered execution resource.
	Labels *Labels `protobuf:"bytes,4,opt,name=labels,proto3" json:"labels,omitempty"`
	// Custom annotations to be applied to a triggered execution resource.
	Annotations *Annotations `protobuf:"bytes,5,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// Allows for the interruptible flag of a workflow to be overwritten for a single execution.
	// Omitting this field uses the workflow's value as a default.
	// As we need to distinguish between the field not being provided and its default value false, we have to use a wrapper
	// around the bool field.
	Interruptible *wrapperspb.BoolValue `protobuf:"bytes,6,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	// Allows for all cached values of a workflow and its tasks to be overwritten for a single execution.
	// If enabled, all calculations are performed even if cached results would be available, overwriting the stored
	// data once execution finishes successfully.
	OverwriteCache bool `protobuf:"varint,7,opt,name=overwrite_cache,json=overwriteCache,proto3" json:"overwrite_cache,omitempty"`
	// Environment variables to be set for the execution.
	Envs *Envs `protobuf:"bytes,8,opt,name=envs,proto3" json:"envs,omitempty"`
	// contains filtered or unexported fields
}

Adds defaults for customizable workflow-execution specifications and overrides.

func (*WorkflowExecutionConfig) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionConfig.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionConfig) GetAnnotations 

func (x *WorkflowExecutionConfig) GetAnnotations() *Annotations

func (*WorkflowExecutionConfig) GetEnvs 

func (x *WorkflowExecutionConfig) GetEnvs() *Envs

func (*WorkflowExecutionConfig) GetInterruptible 

func (x *WorkflowExecutionConfig) GetInterruptible() *wrapperspb.BoolValue

func (*WorkflowExecutionConfig) GetLabels 

func (x *WorkflowExecutionConfig) GetLabels() *Labels

func (*WorkflowExecutionConfig) GetMaxParallelism 

func (x *WorkflowExecutionConfig) GetMaxParallelism() int32

func (*WorkflowExecutionConfig) GetOverwriteCache 

func (x *WorkflowExecutionConfig) GetOverwriteCache() bool

func (*WorkflowExecutionConfig) GetRawOutputDataConfig 

func (x *WorkflowExecutionConfig) GetRawOutputDataConfig() *RawOutputDataConfig

func (*WorkflowExecutionConfig) GetSecurityContext 

func (x *WorkflowExecutionConfig) GetSecurityContext() *core.SecurityContext

func (*WorkflowExecutionConfig) ProtoMessage 

func (*WorkflowExecutionConfig) ProtoMessage()

func (*WorkflowExecutionConfig) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionConfig) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionConfig) Reset 

func (x *WorkflowExecutionConfig) Reset()

func (*WorkflowExecutionConfig) String 

func (x *WorkflowExecutionConfig) String() string

type WorkflowExecutionEventRequest 

type WorkflowExecutionEventRequest struct {

	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event *event.WorkflowExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

Request to send a notification that a workflow execution event has occurred.

func (*WorkflowExecutionEventRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionEventRequest.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionEventRequest) GetEvent 

func (x *WorkflowExecutionEventRequest) GetEvent() *event.WorkflowExecutionEvent

func (*WorkflowExecutionEventRequest) GetRequestId 

func (x *WorkflowExecutionEventRequest) GetRequestId() string

func (*WorkflowExecutionEventRequest) ProtoMessage 

func (*WorkflowExecutionEventRequest) ProtoMessage()

func (*WorkflowExecutionEventRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionEventRequest) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionEventRequest) Reset 

func (x *WorkflowExecutionEventRequest) Reset()

func (*WorkflowExecutionEventRequest) String 

func (x *WorkflowExecutionEventRequest) String() string

type WorkflowExecutionEventResponse 

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

func (*WorkflowExecutionEventResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionEventResponse.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionEventResponse) ProtoMessage 

func (*WorkflowExecutionEventResponse) ProtoMessage()

func (*WorkflowExecutionEventResponse) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionEventResponse) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionEventResponse) Reset 

func (x *WorkflowExecutionEventResponse) Reset()

func (*WorkflowExecutionEventResponse) String 

func (x *WorkflowExecutionEventResponse) String() string

type WorkflowExecutionGetDataRequest 

type WorkflowExecutionGetDataRequest struct {

	// The identifier of the execution for which to fetch inputs and outputs.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Request structure to fetch inputs, output and other data produced by an execution. By default this data is not returned inline in :ref:`ref_flyteidl.admin.WorkflowExecutionGetRequest`

func (*WorkflowExecutionGetDataRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionGetDataRequest.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionGetDataRequest) GetId 

func (x *WorkflowExecutionGetDataRequest) GetId() *core.WorkflowExecutionIdentifier

func (*WorkflowExecutionGetDataRequest) ProtoMessage 

func (*WorkflowExecutionGetDataRequest) ProtoMessage()

func (*WorkflowExecutionGetDataRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionGetDataRequest) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionGetDataRequest) Reset 

func (x *WorkflowExecutionGetDataRequest) Reset()

func (*WorkflowExecutionGetDataRequest) String 

func (x *WorkflowExecutionGetDataRequest) String() string

type WorkflowExecutionGetDataResponse 

type WorkflowExecutionGetDataResponse struct {

	// Signed url to fetch a core.LiteralMap of execution outputs.
	// Deprecated: Please use full_outputs instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	Outputs *UrlBlob `protobuf:"bytes,1,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of execution inputs.
	// Deprecated: Please use full_inputs instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.
	Inputs *UrlBlob `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Full_inputs will only be populated if they are under a configured size threshold.
	FullInputs *core.LiteralMap `protobuf:"bytes,3,opt,name=full_inputs,json=fullInputs,proto3" json:"full_inputs,omitempty"`
	// Full_outputs will only be populated if they are under a configured size threshold.
	FullOutputs *core.LiteralMap `protobuf:"bytes,4,opt,name=full_outputs,json=fullOutputs,proto3" json:"full_outputs,omitempty"`
	// contains filtered or unexported fields
}

Response structure for WorkflowExecutionGetDataRequest which contains inputs and outputs for an execution.

func (*WorkflowExecutionGetDataResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionGetDataResponse.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionGetDataResponse) GetFullInputs 

func (x *WorkflowExecutionGetDataResponse) GetFullInputs() *core.LiteralMap

func (*WorkflowExecutionGetDataResponse) GetFullOutputs 

func (x *WorkflowExecutionGetDataResponse) GetFullOutputs() *core.LiteralMap

func (*WorkflowExecutionGetDataResponse) GetInputs deprecated 

func (x *WorkflowExecutionGetDataResponse) GetInputs() *UrlBlob

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*WorkflowExecutionGetDataResponse) GetOutputs deprecated 

func (x *WorkflowExecutionGetDataResponse) GetOutputs() *UrlBlob

Deprecated: Marked as deprecated in flyteidl/admin/execution.proto.

func (*WorkflowExecutionGetDataResponse) ProtoMessage 

func (*WorkflowExecutionGetDataResponse) ProtoMessage()

func (*WorkflowExecutionGetDataResponse) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionGetDataResponse) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionGetDataResponse) Reset 

func (x *WorkflowExecutionGetDataResponse) Reset()

func (*WorkflowExecutionGetDataResponse) String 

func (x *WorkflowExecutionGetDataResponse) String() string

type WorkflowExecutionGetMetricsRequest 

type WorkflowExecutionGetMetricsRequest struct {

	// id defines the workflow execution to query for.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// depth defines the number of Flyte entity levels to traverse when breaking down execution details.
	Depth int32 `protobuf:"varint,2,opt,name=depth,proto3" json:"depth,omitempty"`
	// contains filtered or unexported fields
}

WorkflowExecutionGetMetricsRequest represents a request to retrieve metrics for the specified workflow execution.

func (*WorkflowExecutionGetMetricsRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionGetMetricsRequest.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionGetMetricsRequest) GetDepth 

func (x *WorkflowExecutionGetMetricsRequest) GetDepth() int32

func (*WorkflowExecutionGetMetricsRequest) GetId 

func (x *WorkflowExecutionGetMetricsRequest) GetId() *core.WorkflowExecutionIdentifier

func (*WorkflowExecutionGetMetricsRequest) ProtoMessage 

func (*WorkflowExecutionGetMetricsRequest) ProtoMessage()

func (*WorkflowExecutionGetMetricsRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionGetMetricsRequest) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionGetMetricsRequest) Reset 

func (x *WorkflowExecutionGetMetricsRequest) Reset()

func (*WorkflowExecutionGetMetricsRequest) String 

func (x *WorkflowExecutionGetMetricsRequest) String() string

type WorkflowExecutionGetMetricsResponse 

type WorkflowExecutionGetMetricsResponse struct {

	// Span defines the top-level breakdown of the workflows execution. More precise information is nested in a
	// hierarchical structure using Flyte entity references.
	Span *core.Span `protobuf:"bytes,1,opt,name=span,proto3" json:"span,omitempty"`
	// contains filtered or unexported fields
}

WorkflowExecutionGetMetricsResponse represents the response containing metrics for the specified workflow execution.

func (*WorkflowExecutionGetMetricsResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionGetMetricsResponse.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionGetMetricsResponse) GetSpan 

func (x *WorkflowExecutionGetMetricsResponse) GetSpan() *core.Span

func (*WorkflowExecutionGetMetricsResponse) ProtoMessage 

func (*WorkflowExecutionGetMetricsResponse) ProtoMessage()

func (*WorkflowExecutionGetMetricsResponse) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionGetMetricsResponse) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionGetMetricsResponse) Reset 

func (x *WorkflowExecutionGetMetricsResponse) Reset()

func (*WorkflowExecutionGetMetricsResponse) String 

func (x *WorkflowExecutionGetMetricsResponse) String() string

type WorkflowExecutionGetRequest 

type WorkflowExecutionGetRequest struct {

	// Uniquely identifies an individual workflow execution.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A message used to fetch a single workflow execution entity. See :ref:`ref_flyteidl.admin.Execution` for more details

func (*WorkflowExecutionGetRequest) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionGetRequest.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionGetRequest) GetId 

func (x *WorkflowExecutionGetRequest) GetId() *core.WorkflowExecutionIdentifier

func (*WorkflowExecutionGetRequest) ProtoMessage 

func (*WorkflowExecutionGetRequest) ProtoMessage()

func (*WorkflowExecutionGetRequest) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionGetRequest) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionGetRequest) Reset 

func (x *WorkflowExecutionGetRequest) Reset()

func (*WorkflowExecutionGetRequest) String 

func (x *WorkflowExecutionGetRequest) String() string

type WorkflowList 

type WorkflowList struct {

	// A list of workflows returned based on the request.
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Represents a list of workflows returned from the admin. See :ref:`ref_flyteidl.admin.Workflow` for more details

func (*WorkflowList) Descriptor deprecated 

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

Deprecated: Use WorkflowList.ProtoReflect.Descriptor instead.

func (*WorkflowList) GetToken 

func (x *WorkflowList) GetToken() string

func (*WorkflowList) GetWorkflows 

func (x *WorkflowList) GetWorkflows() []*Workflow

func (*WorkflowList) ProtoMessage 

func (*WorkflowList) ProtoMessage()

func (*WorkflowList) ProtoReflect added in v1.10.7 

func (x *WorkflowList) ProtoReflect() protoreflect.Message

func (*WorkflowList) Reset 

func (x *WorkflowList) Reset()

func (*WorkflowList) String 

func (x *WorkflowList) String() string

type WorkflowNodeMetadata 

type WorkflowNodeMetadata struct {

	// The identifier for a workflow execution launched by a node.
	ExecutionId *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=executionId,proto3" json:"executionId,omitempty"`
	// contains filtered or unexported fields
}

Metadata for a WorkflowNode

func (*WorkflowNodeMetadata) Descriptor deprecated 

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

Deprecated: Use WorkflowNodeMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowNodeMetadata) GetExecutionId 

func (x *WorkflowNodeMetadata) GetExecutionId() *core.WorkflowExecutionIdentifier

func (*WorkflowNodeMetadata) ProtoMessage 

func (*WorkflowNodeMetadata) ProtoMessage()

func (*WorkflowNodeMetadata) ProtoReflect added in v1.10.7 

func (x *WorkflowNodeMetadata) ProtoReflect() protoreflect.Message

func (*WorkflowNodeMetadata) Reset 

func (x *WorkflowNodeMetadata) Reset()

func (*WorkflowNodeMetadata) String 

func (x *WorkflowNodeMetadata) String() string

type WorkflowSpec 

type WorkflowSpec struct {

	// Template of the task that encapsulates all the metadata of the workflow.
	Template *core.WorkflowTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// Workflows that are embedded into other workflows need to be passed alongside the parent workflow to the
	// propeller compiler (since the compiler doesn't have any knowledge of other workflows - ie, it doesn't reach out
	// to Admin to see other registered workflows).  In fact, subworkflows do not even need to be registered.
	SubWorkflows []*core.WorkflowTemplate `protobuf:"bytes,2,rep,name=sub_workflows,json=subWorkflows,proto3" json:"sub_workflows,omitempty"`
	// Represents the specification for description entity.
	Description *DescriptionEntity `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

Represents a structure that encapsulates the specification of the workflow.

func (*WorkflowSpec) Descriptor deprecated 

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

Deprecated: Use WorkflowSpec.ProtoReflect.Descriptor instead.

func (*WorkflowSpec) GetDescription 

func (x *WorkflowSpec) GetDescription() *DescriptionEntity

func (*WorkflowSpec) GetSubWorkflows 

func (x *WorkflowSpec) GetSubWorkflows() []*core.WorkflowTemplate

func (*WorkflowSpec) GetTemplate 

func (x *WorkflowSpec) GetTemplate() *core.WorkflowTemplate

func (*WorkflowSpec) ProtoMessage 

func (*WorkflowSpec) ProtoMessage()

func (*WorkflowSpec) ProtoReflect added in v1.10.7 

func (x *WorkflowSpec) ProtoReflect() protoreflect.Message

func (*WorkflowSpec) Reset 

func (x *WorkflowSpec) Reset()

func (*WorkflowSpec) String 

func (x *WorkflowSpec) String() string

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.