task

package
v2.0.21 Latest Latest
Warning

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

Go to latest
Published: Jun 10, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TaskService_DeployTask_FullMethodName     = "/flyteidl2.task.TaskService/DeployTask"
	TaskService_GetTaskDetails_FullMethodName = "/flyteidl2.task.TaskService/GetTaskDetails"
	TaskService_ListTasks_FullMethodName      = "/flyteidl2.task.TaskService/ListTasks"
	TaskService_ListVersions_FullMethodName   = "/flyteidl2.task.TaskService/ListVersions"
)

Variables

View Source
var (
	FixedRateUnit_name = map[int32]string{
		0: "FIXED_RATE_UNIT_UNSPECIFIED",
		1: "FIXED_RATE_UNIT_MINUTE",
		2: "FIXED_RATE_UNIT_HOUR",
		3: "FIXED_RATE_UNIT_DAY",
	}
	FixedRateUnit_value = map[string]int32{
		"FIXED_RATE_UNIT_UNSPECIFIED": 0,
		"FIXED_RATE_UNIT_MINUTE":      1,
		"FIXED_RATE_UNIT_HOUR":        2,
		"FIXED_RATE_UNIT_DAY":         3,
	}
)

Enum value maps for FixedRateUnit.

View Source
var (
	TriggerAutomationSpecType_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_NONE",
		2: "TYPE_SCHEDULE",
	}
	TriggerAutomationSpecType_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_NONE":        1,
		"TYPE_SCHEDULE":    2,
	}
)

Enum value maps for TriggerAutomationSpecType.

View Source
var (
	CacheLookupScope_name = map[int32]string{
		0: "CACHE_LOOKUP_SCOPE_UNSPECIFIED",
		1: "CACHE_LOOKUP_SCOPE_GLOBAL",
		2: "CACHE_LOOKUP_SCOPE_PROJECT_DOMAIN",
	}
	CacheLookupScope_value = map[string]int32{
		"CACHE_LOOKUP_SCOPE_UNSPECIFIED":    0,
		"CACHE_LOOKUP_SCOPE_GLOBAL":         1,
		"CACHE_LOOKUP_SCOPE_PROJECT_DOMAIN": 2,
	}
)

Enum value maps for CacheLookupScope.

View Source
var File_flyteidl2_task_common_proto protoreflect.FileDescriptor
View Source
var File_flyteidl2_task_environment_proto protoreflect.FileDescriptor
View Source
var File_flyteidl2_task_run_proto protoreflect.FileDescriptor
View Source
var File_flyteidl2_task_task_definition_proto protoreflect.FileDescriptor
View Source
var File_flyteidl2_task_task_service_proto protoreflect.FileDescriptor
View Source
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "flyteidl2.task.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DeployTask",
			Handler:    _TaskService_DeployTask_Handler,
		},
		{
			MethodName: "GetTaskDetails",
			Handler:    _TaskService_GetTaskDetails_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _TaskService_ListTasks_Handler,
		},
		{
			MethodName: "ListVersions",
			Handler:    _TaskService_ListVersions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "flyteidl2/task/task_service.proto",
}

TaskService_ServiceDesc is the grpc.ServiceDesc for TaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTaskServiceServer

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

Types

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

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

func (*Annotations) Reset

func (x *Annotations) Reset()

func (*Annotations) String

func (x *Annotations) String() string

func (*Annotations) Validate

func (m *Annotations) Validate() error

Validate checks the field values on Annotations with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Annotations) ValidateAll

func (m *Annotations) ValidateAll() error

ValidateAll checks the field values on Annotations with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AnnotationsMultiError, or nil if none found.

type AnnotationsMultiError

type AnnotationsMultiError []error

AnnotationsMultiError is an error wrapping multiple validation errors returned by Annotations.ValidateAll() if the designated constraints aren't met.

func (AnnotationsMultiError) AllErrors

func (m AnnotationsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AnnotationsMultiError) Error

func (m AnnotationsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AnnotationsValidationError

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

AnnotationsValidationError is the validation error returned by Annotations.Validate if the designated constraints aren't met.

func (AnnotationsValidationError) Cause

Cause function returns cause value.

func (AnnotationsValidationError) Error

Error satisfies the builtin error interface

func (AnnotationsValidationError) ErrorName

func (e AnnotationsValidationError) ErrorName() string

ErrorName returns error name.

func (AnnotationsValidationError) Field

Field function returns field value.

func (AnnotationsValidationError) Key

Key function returns key value.

func (AnnotationsValidationError) Reason

Reason function returns reason value.

type CacheConfig

type CacheConfig struct {

	// If true, recompute outputs for this run and overwrite any existing cache.
	OverwriteCache bool `protobuf:"varint,1,opt,name=overwrite_cache,json=overwriteCache,proto3" json:"overwrite_cache,omitempty"`
	// CacheLookupScope defines the cache lookup behavior. If left unspecified, the default value from the system config
	// will be used (global unless configured otherwise).
	CacheLookupScope CacheLookupScope `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

CacheConfig contains configurations that influence the behavior of cache reads and writes

func (*CacheConfig) Descriptor deprecated

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

Deprecated: Use CacheConfig.ProtoReflect.Descriptor instead.

func (*CacheConfig) GetCacheLookupScope

func (x *CacheConfig) GetCacheLookupScope() CacheLookupScope

func (*CacheConfig) GetOverwriteCache

func (x *CacheConfig) GetOverwriteCache() bool

func (*CacheConfig) ProtoMessage

func (*CacheConfig) ProtoMessage()

func (*CacheConfig) ProtoReflect

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

func (*CacheConfig) Reset

func (x *CacheConfig) Reset()

func (*CacheConfig) String

func (x *CacheConfig) String() string

func (*CacheConfig) Validate

func (m *CacheConfig) Validate() error

Validate checks the field values on CacheConfig with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CacheConfig) ValidateAll

func (m *CacheConfig) ValidateAll() error

ValidateAll checks the field values on CacheConfig with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CacheConfigMultiError, or nil if none found.

type CacheConfigMultiError

type CacheConfigMultiError []error

CacheConfigMultiError is an error wrapping multiple validation errors returned by CacheConfig.ValidateAll() if the designated constraints aren't met.

func (CacheConfigMultiError) AllErrors

func (m CacheConfigMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CacheConfigMultiError) Error

func (m CacheConfigMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CacheConfigValidationError

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

CacheConfigValidationError is the validation error returned by CacheConfig.Validate if the designated constraints aren't met.

func (CacheConfigValidationError) Cause

Cause function returns cause value.

func (CacheConfigValidationError) Error

Error satisfies the builtin error interface

func (CacheConfigValidationError) ErrorName

func (e CacheConfigValidationError) ErrorName() string

ErrorName returns error name.

func (CacheConfigValidationError) Field

Field function returns field value.

func (CacheConfigValidationError) Key

Key function returns key value.

func (CacheConfigValidationError) Reason

Reason function returns reason value.

type CacheLookupScope

type CacheLookupScope int32
const (
	// CACHE_LOOKUP_SCOPE_UNSPECIFIED instructs cache lookup to follow the default behavior (global unless configured
	// otherwise)
	CacheLookupScope_CACHE_LOOKUP_SCOPE_UNSPECIFIED CacheLookupScope = 0
	// CACHE_LOOKUP_SCOPE_GLOBAL instructs cache lookups to do a global lookup (unless overridden by a system config).
	// This has traditionally been the default behavior. It requires all workloads running in all projects/domains
	// to have access to the same artifacts/buckets. Otherwise it risks runtime failures.
	CacheLookupScope_CACHE_LOOKUP_SCOPE_GLOBAL CacheLookupScope = 1
	// CACHE_LOOKUP_SCOPE_PROJECT_DOMAIN instructs cache lookups to do a project-domain scoped lookup. This ensures
	// data access success at the expense of potentially more cache misses and recomputation happening. This should not
	// be considered a security enforcement (that can happen through the system-wide config).
	CacheLookupScope_CACHE_LOOKUP_SCOPE_PROJECT_DOMAIN CacheLookupScope = 2
)

func (CacheLookupScope) Descriptor

func (CacheLookupScope) Enum

func (CacheLookupScope) EnumDescriptor deprecated

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

Deprecated: Use CacheLookupScope.Descriptor instead.

func (CacheLookupScope) Number

func (CacheLookupScope) String

func (x CacheLookupScope) String() string

func (CacheLookupScope) Type

type Cron

type Cron 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 * * * ? *
	Expression string `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	Timezone   string `protobuf:"bytes,2,opt,name=timezone,proto3" json:"timezone,omitempty"` // default is UTC
	// contains filtered or unexported fields
}

func (*Cron) Descriptor deprecated

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

Deprecated: Use Cron.ProtoReflect.Descriptor instead.

func (*Cron) GetExpression

func (x *Cron) GetExpression() string

func (*Cron) GetTimezone

func (x *Cron) GetTimezone() string

func (*Cron) ProtoMessage

func (*Cron) ProtoMessage()

func (*Cron) ProtoReflect

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

func (*Cron) Reset

func (x *Cron) Reset()

func (*Cron) String

func (x *Cron) String() string

func (*Cron) Validate

func (m *Cron) Validate() error

Validate checks the field values on Cron with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Cron) ValidateAll

func (m *Cron) ValidateAll() error

ValidateAll checks the field values on Cron with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CronMultiError, or nil if none found.

type CronMultiError

type CronMultiError []error

CronMultiError is an error wrapping multiple validation errors returned by Cron.ValidateAll() if the designated constraints aren't met.

func (CronMultiError) AllErrors

func (m CronMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CronMultiError) Error

func (m CronMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type CronValidationError

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

CronValidationError is the validation error returned by Cron.Validate if the designated constraints aren't met.

func (CronValidationError) Cause

func (e CronValidationError) Cause() error

Cause function returns cause value.

func (CronValidationError) Error

func (e CronValidationError) Error() string

Error satisfies the builtin error interface

func (CronValidationError) ErrorName

func (e CronValidationError) ErrorName() string

ErrorName returns error name.

func (CronValidationError) Field

func (e CronValidationError) Field() string

Field function returns field value.

func (CronValidationError) Key

func (e CronValidationError) Key() bool

Key function returns key value.

func (CronValidationError) Reason

func (e CronValidationError) Reason() string

Reason function returns reason value.

type DeployTaskRequest

type DeployTaskRequest struct {

	// The user provided task id.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Specification for the task.
	Spec *TaskSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Optional, set of triggers for a given task. Replaces previous set of triggers entirely if any.
	Triggers []*TaskTrigger `protobuf:"bytes,3,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// contains filtered or unexported fields
}

Request message for deploying a task.

func (*DeployTaskRequest) Descriptor deprecated

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

Deprecated: Use DeployTaskRequest.ProtoReflect.Descriptor instead.

func (*DeployTaskRequest) GetSpec

func (x *DeployTaskRequest) GetSpec() *TaskSpec

func (*DeployTaskRequest) GetTaskId

func (x *DeployTaskRequest) GetTaskId() *TaskIdentifier

func (*DeployTaskRequest) GetTriggers

func (x *DeployTaskRequest) GetTriggers() []*TaskTrigger

func (*DeployTaskRequest) ProtoMessage

func (*DeployTaskRequest) ProtoMessage()

func (*DeployTaskRequest) ProtoReflect

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

func (*DeployTaskRequest) Reset

func (x *DeployTaskRequest) Reset()

func (*DeployTaskRequest) String

func (x *DeployTaskRequest) String() string

func (*DeployTaskRequest) Validate

func (m *DeployTaskRequest) Validate() error

Validate checks the field values on DeployTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeployTaskRequest) ValidateAll

func (m *DeployTaskRequest) ValidateAll() error

ValidateAll checks the field values on DeployTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeployTaskRequestMultiError, or nil if none found.

type DeployTaskRequestMultiError

type DeployTaskRequestMultiError []error

DeployTaskRequestMultiError is an error wrapping multiple validation errors returned by DeployTaskRequest.ValidateAll() if the designated constraints aren't met.

func (DeployTaskRequestMultiError) AllErrors

func (m DeployTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeployTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeployTaskRequestValidationError

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

DeployTaskRequestValidationError is the validation error returned by DeployTaskRequest.Validate if the designated constraints aren't met.

func (DeployTaskRequestValidationError) Cause

Cause function returns cause value.

func (DeployTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (DeployTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (DeployTaskRequestValidationError) Field

Field function returns field value.

func (DeployTaskRequestValidationError) Key

Key function returns key value.

func (DeployTaskRequestValidationError) Reason

Reason function returns reason value.

type DeployTaskResponse

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

Response message for deploying a task.

func (*DeployTaskResponse) Descriptor deprecated

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

Deprecated: Use DeployTaskResponse.ProtoReflect.Descriptor instead.

func (*DeployTaskResponse) ProtoMessage

func (*DeployTaskResponse) ProtoMessage()

func (*DeployTaskResponse) ProtoReflect

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

func (*DeployTaskResponse) Reset

func (x *DeployTaskResponse) Reset()

func (*DeployTaskResponse) String

func (x *DeployTaskResponse) String() string

func (*DeployTaskResponse) Validate

func (m *DeployTaskResponse) Validate() error

Validate checks the field values on DeployTaskResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeployTaskResponse) ValidateAll

func (m *DeployTaskResponse) ValidateAll() error

ValidateAll checks the field values on DeployTaskResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeployTaskResponseMultiError, or nil if none found.

type DeployTaskResponseMultiError

type DeployTaskResponseMultiError []error

DeployTaskResponseMultiError is an error wrapping multiple validation errors returned by DeployTaskResponse.ValidateAll() if the designated constraints aren't met.

func (DeployTaskResponseMultiError) AllErrors

func (m DeployTaskResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeployTaskResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeployTaskResponseValidationError

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

DeployTaskResponseValidationError is the validation error returned by DeployTaskResponse.Validate if the designated constraints aren't met.

func (DeployTaskResponseValidationError) Cause

Cause function returns cause value.

func (DeployTaskResponseValidationError) Error

Error satisfies the builtin error interface

func (DeployTaskResponseValidationError) ErrorName

ErrorName returns error name.

func (DeployTaskResponseValidationError) Field

Field function returns field value.

func (DeployTaskResponseValidationError) Key

Key function returns key value.

func (DeployTaskResponseValidationError) Reason

Reason function returns reason value.

type DocumentationEntity

type DocumentationEntity struct {

	// One-liner overview of the entity.
	ShortDescription string `protobuf:"bytes,1,opt,name=short_description,json=shortDescription,proto3" json:"short_description,omitempty"`
	// Full user description with formatting preserved.
	LongDescription string `protobuf:"bytes,2,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,3,opt,name=source_code,json=sourceCode,proto3" json:"source_code,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentationEntity) Descriptor deprecated

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

Deprecated: Use DocumentationEntity.ProtoReflect.Descriptor instead.

func (*DocumentationEntity) GetLongDescription

func (x *DocumentationEntity) GetLongDescription() string

func (*DocumentationEntity) GetShortDescription

func (x *DocumentationEntity) GetShortDescription() string

func (*DocumentationEntity) GetSourceCode

func (x *DocumentationEntity) GetSourceCode() *SourceCode

func (*DocumentationEntity) ProtoMessage

func (*DocumentationEntity) ProtoMessage()

func (*DocumentationEntity) ProtoReflect

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

func (*DocumentationEntity) Reset

func (x *DocumentationEntity) Reset()

func (*DocumentationEntity) String

func (x *DocumentationEntity) String() string

func (*DocumentationEntity) Validate

func (m *DocumentationEntity) Validate() error

Validate checks the field values on DocumentationEntity with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DocumentationEntity) ValidateAll

func (m *DocumentationEntity) ValidateAll() error

ValidateAll checks the field values on DocumentationEntity with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DocumentationEntityMultiError, or nil if none found.

type DocumentationEntityMultiError

type DocumentationEntityMultiError []error

DocumentationEntityMultiError is an error wrapping multiple validation errors returned by DocumentationEntity.ValidateAll() if the designated constraints aren't met.

func (DocumentationEntityMultiError) AllErrors

func (m DocumentationEntityMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DocumentationEntityMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DocumentationEntityValidationError

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

DocumentationEntityValidationError is the validation error returned by DocumentationEntity.Validate if the designated constraints aren't met.

func (DocumentationEntityValidationError) Cause

Cause function returns cause value.

func (DocumentationEntityValidationError) Error

Error satisfies the builtin error interface

func (DocumentationEntityValidationError) ErrorName

ErrorName returns error name.

func (DocumentationEntityValidationError) Field

Field function returns field value.

func (DocumentationEntityValidationError) Key

Key function returns key value.

func (DocumentationEntityValidationError) Reason

Reason function returns reason value.

type Environment

type Environment struct {

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

Environment for a task.

func (*Environment) Descriptor deprecated

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

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetDescription

func (x *Environment) GetDescription() string

func (*Environment) GetName

func (x *Environment) GetName() string

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect

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

func (*Environment) Reset

func (x *Environment) Reset()

func (*Environment) String

func (x *Environment) String() string

func (*Environment) Validate

func (m *Environment) Validate() error

Validate checks the field values on Environment with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Environment) ValidateAll

func (m *Environment) ValidateAll() error

ValidateAll checks the field values on Environment with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnvironmentMultiError, or nil if none found.

type EnvironmentMultiError

type EnvironmentMultiError []error

EnvironmentMultiError is an error wrapping multiple validation errors returned by Environment.ValidateAll() if the designated constraints aren't met.

func (EnvironmentMultiError) AllErrors

func (m EnvironmentMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnvironmentMultiError) Error

func (m EnvironmentMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EnvironmentValidationError

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

EnvironmentValidationError is the validation error returned by Environment.Validate if the designated constraints aren't met.

func (EnvironmentValidationError) Cause

Cause function returns cause value.

func (EnvironmentValidationError) Error

Error satisfies the builtin error interface

func (EnvironmentValidationError) ErrorName

func (e EnvironmentValidationError) ErrorName() string

ErrorName returns error name.

func (EnvironmentValidationError) Field

Field function returns field value.

func (EnvironmentValidationError) Key

Key function returns key value.

func (EnvironmentValidationError) Reason

Reason function returns reason value.

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

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

func (*Envs) Reset

func (x *Envs) Reset()

func (*Envs) String

func (x *Envs) String() string

func (*Envs) Validate

func (m *Envs) Validate() error

Validate checks the field values on Envs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Envs) ValidateAll

func (m *Envs) ValidateAll() error

ValidateAll checks the field values on Envs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnvsMultiError, or nil if none found.

type EnvsMultiError

type EnvsMultiError []error

EnvsMultiError is an error wrapping multiple validation errors returned by Envs.ValidateAll() if the designated constraints aren't met.

func (EnvsMultiError) AllErrors

func (m EnvsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnvsMultiError) Error

func (m EnvsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type EnvsValidationError

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

EnvsValidationError is the validation error returned by Envs.Validate if the designated constraints aren't met.

func (EnvsValidationError) Cause

func (e EnvsValidationError) Cause() error

Cause function returns cause value.

func (EnvsValidationError) Error

func (e EnvsValidationError) Error() string

Error satisfies the builtin error interface

func (EnvsValidationError) ErrorName

func (e EnvsValidationError) ErrorName() string

ErrorName returns error name.

func (EnvsValidationError) Field

func (e EnvsValidationError) Field() string

Field function returns field value.

func (EnvsValidationError) Key

func (e EnvsValidationError) Key() bool

Key function returns key value.

func (EnvsValidationError) Reason

func (e EnvsValidationError) Reason() string

Reason function returns reason value.

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=flyteidl2.task.FixedRateUnit" json:"unit,omitempty"`
	// Optional, timestamp after which rate should be calculated. Can be only in future.
	// E.g. We create a rate schedule "every 5 minutes" with start_time="12:00" inactive.
	// Activate it at "12:04".
	// Trigger should fire at "12:05" as it adds 5 minutes to start_time="12:00".
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,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) GetStartTime

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

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

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

func (*FixedRate) Reset

func (x *FixedRate) Reset()

func (*FixedRate) String

func (x *FixedRate) String() string

func (*FixedRate) Validate

func (m *FixedRate) Validate() error

Validate checks the field values on FixedRate with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*FixedRate) ValidateAll

func (m *FixedRate) ValidateAll() error

ValidateAll checks the field values on FixedRate with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FixedRateMultiError, or nil if none found.

type FixedRateMultiError

type FixedRateMultiError []error

FixedRateMultiError is an error wrapping multiple validation errors returned by FixedRate.ValidateAll() if the designated constraints aren't met.

func (FixedRateMultiError) AllErrors

func (m FixedRateMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (FixedRateMultiError) Error

func (m FixedRateMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type FixedRateUnit

type FixedRateUnit int32

Represents a frequency at which to run a schedule.

const (
	FixedRateUnit_FIXED_RATE_UNIT_UNSPECIFIED FixedRateUnit = 0
	FixedRateUnit_FIXED_RATE_UNIT_MINUTE      FixedRateUnit = 1
	FixedRateUnit_FIXED_RATE_UNIT_HOUR        FixedRateUnit = 2
	FixedRateUnit_FIXED_RATE_UNIT_DAY         FixedRateUnit = 3
)

func (FixedRateUnit) Descriptor

func (FixedRateUnit) Enum

func (x FixedRateUnit) Enum() *FixedRateUnit

func (FixedRateUnit) EnumDescriptor deprecated

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

Deprecated: Use FixedRateUnit.Descriptor instead.

func (FixedRateUnit) Number

func (FixedRateUnit) String

func (x FixedRateUnit) String() string

func (FixedRateUnit) Type

type FixedRateValidationError

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

FixedRateValidationError is the validation error returned by FixedRate.Validate if the designated constraints aren't met.

func (FixedRateValidationError) Cause

func (e FixedRateValidationError) Cause() error

Cause function returns cause value.

func (FixedRateValidationError) Error

func (e FixedRateValidationError) Error() string

Error satisfies the builtin error interface

func (FixedRateValidationError) ErrorName

func (e FixedRateValidationError) ErrorName() string

ErrorName returns error name.

func (FixedRateValidationError) Field

func (e FixedRateValidationError) Field() string

Field function returns field value.

func (FixedRateValidationError) Key

Key function returns key value.

func (FixedRateValidationError) Reason

func (e FixedRateValidationError) Reason() string

Reason function returns reason value.

type GetTaskDetailsRequest

type GetTaskDetailsRequest struct {

	// Id of the task.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

Request message for getting detailed information about a task.

func (*GetTaskDetailsRequest) Descriptor deprecated

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

Deprecated: Use GetTaskDetailsRequest.ProtoReflect.Descriptor instead.

func (*GetTaskDetailsRequest) GetTaskId

func (x *GetTaskDetailsRequest) GetTaskId() *TaskIdentifier

func (*GetTaskDetailsRequest) ProtoMessage

func (*GetTaskDetailsRequest) ProtoMessage()

func (*GetTaskDetailsRequest) ProtoReflect

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

func (*GetTaskDetailsRequest) Reset

func (x *GetTaskDetailsRequest) Reset()

func (*GetTaskDetailsRequest) String

func (x *GetTaskDetailsRequest) String() string

func (*GetTaskDetailsRequest) Validate

func (m *GetTaskDetailsRequest) Validate() error

Validate checks the field values on GetTaskDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetTaskDetailsRequest) ValidateAll

func (m *GetTaskDetailsRequest) ValidateAll() error

ValidateAll checks the field values on GetTaskDetailsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetTaskDetailsRequestMultiError, or nil if none found.

type GetTaskDetailsRequestMultiError

type GetTaskDetailsRequestMultiError []error

GetTaskDetailsRequestMultiError is an error wrapping multiple validation errors returned by GetTaskDetailsRequest.ValidateAll() if the designated constraints aren't met.

func (GetTaskDetailsRequestMultiError) AllErrors

func (m GetTaskDetailsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetTaskDetailsRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type GetTaskDetailsRequestValidationError

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

GetTaskDetailsRequestValidationError is the validation error returned by GetTaskDetailsRequest.Validate if the designated constraints aren't met.

func (GetTaskDetailsRequestValidationError) Cause

Cause function returns cause value.

func (GetTaskDetailsRequestValidationError) Error

Error satisfies the builtin error interface

func (GetTaskDetailsRequestValidationError) ErrorName

ErrorName returns error name.

func (GetTaskDetailsRequestValidationError) Field

Field function returns field value.

func (GetTaskDetailsRequestValidationError) Key

Key function returns key value.

func (GetTaskDetailsRequestValidationError) Reason

Reason function returns reason value.

type GetTaskDetailsResponse

type GetTaskDetailsResponse struct {

	// Detailed information about the task.
	Details *TaskDetails `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

Response message for deploying a task.

func (*GetTaskDetailsResponse) Descriptor deprecated

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

Deprecated: Use GetTaskDetailsResponse.ProtoReflect.Descriptor instead.

func (*GetTaskDetailsResponse) GetDetails

func (x *GetTaskDetailsResponse) GetDetails() *TaskDetails

func (*GetTaskDetailsResponse) ProtoMessage

func (*GetTaskDetailsResponse) ProtoMessage()

func (*GetTaskDetailsResponse) ProtoReflect

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

func (*GetTaskDetailsResponse) Reset

func (x *GetTaskDetailsResponse) Reset()

func (*GetTaskDetailsResponse) String

func (x *GetTaskDetailsResponse) String() string

func (*GetTaskDetailsResponse) Validate

func (m *GetTaskDetailsResponse) Validate() error

Validate checks the field values on GetTaskDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetTaskDetailsResponse) ValidateAll

func (m *GetTaskDetailsResponse) ValidateAll() error

ValidateAll checks the field values on GetTaskDetailsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetTaskDetailsResponseMultiError, or nil if none found.

type GetTaskDetailsResponseMultiError

type GetTaskDetailsResponseMultiError []error

GetTaskDetailsResponseMultiError is an error wrapping multiple validation errors returned by GetTaskDetailsResponse.ValidateAll() if the designated constraints aren't met.

func (GetTaskDetailsResponseMultiError) AllErrors

func (m GetTaskDetailsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetTaskDetailsResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type GetTaskDetailsResponseValidationError

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

GetTaskDetailsResponseValidationError is the validation error returned by GetTaskDetailsResponse.Validate if the designated constraints aren't met.

func (GetTaskDetailsResponseValidationError) Cause

Cause function returns cause value.

func (GetTaskDetailsResponseValidationError) Error

Error satisfies the builtin error interface

func (GetTaskDetailsResponseValidationError) ErrorName

ErrorName returns error name.

func (GetTaskDetailsResponseValidationError) Field

Field function returns field value.

func (GetTaskDetailsResponseValidationError) Key

Key function returns key value.

func (GetTaskDetailsResponseValidationError) Reason

Reason function returns reason value.

type InlineRule added in v2.0.8

type InlineRule struct {
	OnPhases []common.ActionPhase `` /* 127-byte string literal not displayed */
	// Types that are assignable to Delivery:
	//
	//	*InlineRule_DeliveryConfigName
	//	*InlineRule_DeliveryTemplate
	Delivery isInlineRule_Delivery `protobuf_oneof:"delivery"`
	// contains filtered or unexported fields
}

func (*InlineRule) Descriptor deprecated added in v2.0.8

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

Deprecated: Use InlineRule.ProtoReflect.Descriptor instead.

func (*InlineRule) GetDelivery added in v2.0.8

func (m *InlineRule) GetDelivery() isInlineRule_Delivery

func (*InlineRule) GetDeliveryConfigName added in v2.0.8

func (x *InlineRule) GetDeliveryConfigName() string

func (*InlineRule) GetDeliveryTemplate added in v2.0.8

func (x *InlineRule) GetDeliveryTemplate() *notification.DeliveryConfigTemplate

func (*InlineRule) GetOnPhases added in v2.0.8

func (x *InlineRule) GetOnPhases() []common.ActionPhase

func (*InlineRule) ProtoMessage added in v2.0.8

func (*InlineRule) ProtoMessage()

func (*InlineRule) ProtoReflect added in v2.0.8

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

func (*InlineRule) Reset added in v2.0.8

func (x *InlineRule) Reset()

func (*InlineRule) String added in v2.0.8

func (x *InlineRule) String() string

func (*InlineRule) Validate added in v2.0.8

func (m *InlineRule) Validate() error

Validate checks the field values on InlineRule with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*InlineRule) ValidateAll added in v2.0.8

func (m *InlineRule) ValidateAll() error

ValidateAll checks the field values on InlineRule with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in InlineRuleMultiError, or nil if none found.

type InlineRuleList added in v2.0.8

type InlineRuleList struct {
	Rules []*InlineRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// contains filtered or unexported fields
}

func (*InlineRuleList) Descriptor deprecated added in v2.0.8

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

Deprecated: Use InlineRuleList.ProtoReflect.Descriptor instead.

func (*InlineRuleList) GetRules added in v2.0.8

func (x *InlineRuleList) GetRules() []*InlineRule

func (*InlineRuleList) ProtoMessage added in v2.0.8

func (*InlineRuleList) ProtoMessage()

func (*InlineRuleList) ProtoReflect added in v2.0.8

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

func (*InlineRuleList) Reset added in v2.0.8

func (x *InlineRuleList) Reset()

func (*InlineRuleList) String added in v2.0.8

func (x *InlineRuleList) String() string

func (*InlineRuleList) Validate added in v2.0.8

func (m *InlineRuleList) Validate() error

Validate checks the field values on InlineRuleList with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*InlineRuleList) ValidateAll added in v2.0.8

func (m *InlineRuleList) ValidateAll() error

ValidateAll checks the field values on InlineRuleList with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in InlineRuleListMultiError, or nil if none found.

type InlineRuleListMultiError added in v2.0.8

type InlineRuleListMultiError []error

InlineRuleListMultiError is an error wrapping multiple validation errors returned by InlineRuleList.ValidateAll() if the designated constraints aren't met.

func (InlineRuleListMultiError) AllErrors added in v2.0.8

func (m InlineRuleListMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InlineRuleListMultiError) Error added in v2.0.8

func (m InlineRuleListMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type InlineRuleListValidationError added in v2.0.8

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

InlineRuleListValidationError is the validation error returned by InlineRuleList.Validate if the designated constraints aren't met.

func (InlineRuleListValidationError) Cause added in v2.0.8

Cause function returns cause value.

func (InlineRuleListValidationError) Error added in v2.0.8

Error satisfies the builtin error interface

func (InlineRuleListValidationError) ErrorName added in v2.0.8

func (e InlineRuleListValidationError) ErrorName() string

ErrorName returns error name.

func (InlineRuleListValidationError) Field added in v2.0.8

Field function returns field value.

func (InlineRuleListValidationError) Key added in v2.0.8

Key function returns key value.

func (InlineRuleListValidationError) Reason added in v2.0.8

Reason function returns reason value.

type InlineRuleMultiError added in v2.0.8

type InlineRuleMultiError []error

InlineRuleMultiError is an error wrapping multiple validation errors returned by InlineRule.ValidateAll() if the designated constraints aren't met.

func (InlineRuleMultiError) AllErrors added in v2.0.8

func (m InlineRuleMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InlineRuleMultiError) Error added in v2.0.8

func (m InlineRuleMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type InlineRuleValidationError added in v2.0.8

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

InlineRuleValidationError is the validation error returned by InlineRule.Validate if the designated constraints aren't met.

func (InlineRuleValidationError) Cause added in v2.0.8

func (e InlineRuleValidationError) Cause() error

Cause function returns cause value.

func (InlineRuleValidationError) Error added in v2.0.8

Error satisfies the builtin error interface

func (InlineRuleValidationError) ErrorName added in v2.0.8

func (e InlineRuleValidationError) ErrorName() string

ErrorName returns error name.

func (InlineRuleValidationError) Field added in v2.0.8

Field function returns field value.

func (InlineRuleValidationError) Key added in v2.0.8

Key function returns key value.

func (InlineRuleValidationError) Reason added in v2.0.8

func (e InlineRuleValidationError) Reason() string

Reason function returns reason value.

type InlineRule_DeliveryConfigName added in v2.0.8

type InlineRule_DeliveryConfigName struct {
	// (run org + delivery_config_name) will be used as a delivery config id
	DeliveryConfigName string `protobuf:"bytes,2,opt,name=delivery_config_name,json=deliveryConfigName,proto3,oneof"`
}

type InlineRule_DeliveryTemplate added in v2.0.8

type InlineRule_DeliveryTemplate struct {
	// template can only have fields defined in flyteidl2.notification.RunCompletedNotificationTemplateData
	DeliveryTemplate *notification.DeliveryConfigTemplate `protobuf:"bytes,3,opt,name=delivery_template,json=deliveryTemplate,proto3,oneof"`
}

type Inputs

type Inputs struct {

	// Ordered inputs. THIS FIELD MUST REMAIN FIRST as this would break Run service assumptions if it were to move.
	Literals []*NamedLiteral `protobuf:"bytes,1,rep,name=literals,proto3" json:"literals,omitempty"`
	// Context for the action. If an action receives context, it'll automatically pass it to any actions it spawns.
	// Context will not be used for cache key computation.
	// Examples for context include:
	//   - User-provided metadata that is not part of the action's inputs.
	//   - Information about the environment the action is running in (e.g. cluster, region, etc.)
	//   - Tracing information about the action
	Context []*core.KeyValuePair `protobuf:"bytes,2,rep,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

Input payload for an action.

func (*Inputs) Descriptor deprecated

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

Deprecated: Use Inputs.ProtoReflect.Descriptor instead.

func (*Inputs) GetContext

func (x *Inputs) GetContext() []*core.KeyValuePair

func (*Inputs) GetLiterals

func (x *Inputs) GetLiterals() []*NamedLiteral

func (*Inputs) ProtoMessage

func (*Inputs) ProtoMessage()

func (*Inputs) ProtoReflect

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

func (*Inputs) Reset

func (x *Inputs) Reset()

func (*Inputs) String

func (x *Inputs) String() string

func (*Inputs) Validate

func (m *Inputs) Validate() error

Validate checks the field values on Inputs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Inputs) ValidateAll

func (m *Inputs) ValidateAll() error

ValidateAll checks the field values on Inputs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in InputsMultiError, or nil if none found.

type InputsMultiError

type InputsMultiError []error

InputsMultiError is an error wrapping multiple validation errors returned by Inputs.ValidateAll() if the designated constraints aren't met.

func (InputsMultiError) AllErrors

func (m InputsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (InputsMultiError) Error

func (m InputsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type InputsValidationError

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

InputsValidationError is the validation error returned by Inputs.Validate if the designated constraints aren't met.

func (InputsValidationError) Cause

func (e InputsValidationError) Cause() error

Cause function returns cause value.

func (InputsValidationError) Error

func (e InputsValidationError) Error() string

Error satisfies the builtin error interface

func (InputsValidationError) ErrorName

func (e InputsValidationError) ErrorName() string

ErrorName returns error name.

func (InputsValidationError) Field

func (e InputsValidationError) Field() string

Field function returns field value.

func (InputsValidationError) Key

func (e InputsValidationError) Key() bool

Key function returns key value.

func (InputsValidationError) Reason

func (e InputsValidationError) Reason() string

Reason function returns reason value.

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

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

func (*Labels) Reset

func (x *Labels) Reset()

func (*Labels) String

func (x *Labels) String() string

func (*Labels) Validate

func (m *Labels) Validate() error

Validate checks the field values on Labels with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Labels) ValidateAll

func (m *Labels) ValidateAll() error

ValidateAll checks the field values on Labels with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LabelsMultiError, or nil if none found.

type LabelsMultiError

type LabelsMultiError []error

LabelsMultiError is an error wrapping multiple validation errors returned by Labels.ValidateAll() if the designated constraints aren't met.

func (LabelsMultiError) AllErrors

func (m LabelsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LabelsMultiError) Error

func (m LabelsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LabelsValidationError

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

LabelsValidationError is the validation error returned by Labels.Validate if the designated constraints aren't met.

func (LabelsValidationError) Cause

func (e LabelsValidationError) Cause() error

Cause function returns cause value.

func (LabelsValidationError) Error

func (e LabelsValidationError) Error() string

Error satisfies the builtin error interface

func (LabelsValidationError) ErrorName

func (e LabelsValidationError) ErrorName() string

ErrorName returns error name.

func (LabelsValidationError) Field

func (e LabelsValidationError) Field() string

Field function returns field value.

func (LabelsValidationError) Key

func (e LabelsValidationError) Key() bool

Key function returns key value.

func (LabelsValidationError) Reason

func (e LabelsValidationError) Reason() string

Reason function returns reason value.

type LatestRunSummary

type LatestRunSummary struct {

	// Run identifier
	RunId *common.RunIdentifier `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Last run time
	RunTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=run_time,json=runTime,proto3" json:"run_time,omitempty"`
	// Phase of the last run
	Phase common.ActionPhase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl2.common.ActionPhase" json:"phase,omitempty"`
	// Name of the root task of the last run (env.task name)
	RootTaskName string `protobuf:"bytes,4,opt,name=root_task_name,json=rootTaskName,proto3" json:"root_task_name,omitempty"`
	// contains filtered or unexported fields
}

LatestRunSummary contains minimal information about the most recent run of a task. This is a lightweight summary that avoids circular dependencies with workflow package.

func (*LatestRunSummary) Descriptor deprecated

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

Deprecated: Use LatestRunSummary.ProtoReflect.Descriptor instead.

func (*LatestRunSummary) GetPhase

func (x *LatestRunSummary) GetPhase() common.ActionPhase

func (*LatestRunSummary) GetRootTaskName

func (x *LatestRunSummary) GetRootTaskName() string

func (*LatestRunSummary) GetRunId

func (x *LatestRunSummary) GetRunId() *common.RunIdentifier

func (*LatestRunSummary) GetRunTime

func (x *LatestRunSummary) GetRunTime() *timestamppb.Timestamp

func (*LatestRunSummary) ProtoMessage

func (*LatestRunSummary) ProtoMessage()

func (*LatestRunSummary) ProtoReflect

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

func (*LatestRunSummary) Reset

func (x *LatestRunSummary) Reset()

func (*LatestRunSummary) String

func (x *LatestRunSummary) String() string

func (*LatestRunSummary) Validate

func (m *LatestRunSummary) Validate() error

Validate checks the field values on LatestRunSummary with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LatestRunSummary) ValidateAll

func (m *LatestRunSummary) ValidateAll() error

ValidateAll checks the field values on LatestRunSummary with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LatestRunSummaryMultiError, or nil if none found.

type LatestRunSummaryMultiError

type LatestRunSummaryMultiError []error

LatestRunSummaryMultiError is an error wrapping multiple validation errors returned by LatestRunSummary.ValidateAll() if the designated constraints aren't met.

func (LatestRunSummaryMultiError) AllErrors

func (m LatestRunSummaryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LatestRunSummaryMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type LatestRunSummaryValidationError

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

LatestRunSummaryValidationError is the validation error returned by LatestRunSummary.Validate if the designated constraints aren't met.

func (LatestRunSummaryValidationError) Cause

Cause function returns cause value.

func (LatestRunSummaryValidationError) Error

Error satisfies the builtin error interface

func (LatestRunSummaryValidationError) ErrorName

ErrorName returns error name.

func (LatestRunSummaryValidationError) Field

Field function returns field value.

func (LatestRunSummaryValidationError) Key

Key function returns key value.

func (LatestRunSummaryValidationError) Reason

Reason function returns reason value.

type ListTasksRequest

type ListTasksRequest struct {

	// Common list request parameters.
	Request *common.ListRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Types that are assignable to ScopeBy:
	//
	//	*ListTasksRequest_Org
	//	*ListTasksRequest_ProjectId
	ScopeBy isListTasksRequest_ScopeBy `protobuf_oneof:"scope_by"`
	// Known filters for listing tasks.
	KnownFilters []*ListTasksRequest_KnownFilter `protobuf:"bytes,4,rep,name=known_filters,json=knownFilters,proto3" json:"known_filters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetKnownFilters

func (x *ListTasksRequest) GetKnownFilters() []*ListTasksRequest_KnownFilter

func (*ListTasksRequest) GetOrg

func (x *ListTasksRequest) GetOrg() string

func (*ListTasksRequest) GetProjectId

func (x *ListTasksRequest) GetProjectId() *common.ProjectIdentifier

func (*ListTasksRequest) GetRequest

func (x *ListTasksRequest) GetRequest() *common.ListRequest

func (*ListTasksRequest) GetScopeBy

func (m *ListTasksRequest) GetScopeBy() isListTasksRequest_ScopeBy

func (*ListTasksRequest) ProtoMessage

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect

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

func (*ListTasksRequest) Reset

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String

func (x *ListTasksRequest) String() string

func (*ListTasksRequest) Validate

func (m *ListTasksRequest) Validate() error

Validate checks the field values on ListTasksRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTasksRequest) ValidateAll

func (m *ListTasksRequest) ValidateAll() error

ValidateAll checks the field values on ListTasksRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTasksRequestMultiError, or nil if none found.

type ListTasksRequestMultiError

type ListTasksRequestMultiError []error

ListTasksRequestMultiError is an error wrapping multiple validation errors returned by ListTasksRequest.ValidateAll() if the designated constraints aren't met.

func (ListTasksRequestMultiError) AllErrors

func (m ListTasksRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTasksRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ListTasksRequestValidationError

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

ListTasksRequestValidationError is the validation error returned by ListTasksRequest.Validate if the designated constraints aren't met.

func (ListTasksRequestValidationError) Cause

Cause function returns cause value.

func (ListTasksRequestValidationError) Error

Error satisfies the builtin error interface

func (ListTasksRequestValidationError) ErrorName

ErrorName returns error name.

func (ListTasksRequestValidationError) Field

Field function returns field value.

func (ListTasksRequestValidationError) Key

Key function returns key value.

func (ListTasksRequestValidationError) Reason

Reason function returns reason value.

type ListTasksRequest_KnownFilter

type ListTasksRequest_KnownFilter struct {

	// Types that are assignable to FilterBy:
	//
	//	*ListTasksRequest_KnownFilter_DeployedBy
	//	*ListTasksRequest_KnownFilter_IsEntrypoint
	FilterBy isListTasksRequest_KnownFilter_FilterBy `protobuf_oneof:"filter_by"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest_KnownFilter) Descriptor deprecated

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

Deprecated: Use ListTasksRequest_KnownFilter.ProtoReflect.Descriptor instead.

func (*ListTasksRequest_KnownFilter) GetDeployedBy

func (x *ListTasksRequest_KnownFilter) GetDeployedBy() string

func (*ListTasksRequest_KnownFilter) GetFilterBy

func (m *ListTasksRequest_KnownFilter) GetFilterBy() isListTasksRequest_KnownFilter_FilterBy

func (*ListTasksRequest_KnownFilter) GetIsEntrypoint added in v2.0.9

func (x *ListTasksRequest_KnownFilter) GetIsEntrypoint() bool

func (*ListTasksRequest_KnownFilter) ProtoMessage

func (*ListTasksRequest_KnownFilter) ProtoMessage()

func (*ListTasksRequest_KnownFilter) ProtoReflect

func (*ListTasksRequest_KnownFilter) Reset

func (x *ListTasksRequest_KnownFilter) Reset()

func (*ListTasksRequest_KnownFilter) String

func (*ListTasksRequest_KnownFilter) Validate

func (m *ListTasksRequest_KnownFilter) Validate() error

Validate checks the field values on ListTasksRequest_KnownFilter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTasksRequest_KnownFilter) ValidateAll

func (m *ListTasksRequest_KnownFilter) ValidateAll() error

ValidateAll checks the field values on ListTasksRequest_KnownFilter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTasksRequest_KnownFilterMultiError, or nil if none found.

type ListTasksRequest_KnownFilterMultiError

type ListTasksRequest_KnownFilterMultiError []error

ListTasksRequest_KnownFilterMultiError is an error wrapping multiple validation errors returned by ListTasksRequest_KnownFilter.ValidateAll() if the designated constraints aren't met.

func (ListTasksRequest_KnownFilterMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (ListTasksRequest_KnownFilterMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ListTasksRequest_KnownFilterValidationError

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

ListTasksRequest_KnownFilterValidationError is the validation error returned by ListTasksRequest_KnownFilter.Validate if the designated constraints aren't met.

func (ListTasksRequest_KnownFilterValidationError) Cause

Cause function returns cause value.

func (ListTasksRequest_KnownFilterValidationError) Error

Error satisfies the builtin error interface

func (ListTasksRequest_KnownFilterValidationError) ErrorName

ErrorName returns error name.

func (ListTasksRequest_KnownFilterValidationError) Field

Field function returns field value.

func (ListTasksRequest_KnownFilterValidationError) Key

Key function returns key value.

func (ListTasksRequest_KnownFilterValidationError) Reason

Reason function returns reason value.

type ListTasksRequest_KnownFilter_DeployedBy

type ListTasksRequest_KnownFilter_DeployedBy struct {
	// Filter by user
	DeployedBy string `protobuf:"bytes,1,opt,name=deployed_by,json=deployedBy,proto3,oneof"`
}

type ListTasksRequest_KnownFilter_IsEntrypoint added in v2.0.9

type ListTasksRequest_KnownFilter_IsEntrypoint struct {
	// Filter to only entrypoint tasks
	IsEntrypoint bool `protobuf:"varint,2,opt,name=is_entrypoint,json=isEntrypoint,proto3,oneof"`
}

type ListTasksRequest_Org

type ListTasksRequest_Org struct {
	// Organization name for filtering.
	Org string `protobuf:"bytes,2,opt,name=org,proto3,oneof"`
}

type ListTasksRequest_ProjectId

type ListTasksRequest_ProjectId struct {
	// Project identifier for filtering.
	ProjectId *common.ProjectIdentifier `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3,oneof"`
}

type ListTasksResponse

type ListTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// Pagination token for the next page of tasks.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// Metadata for the ListTasksResponse
	Metadata *ListTasksResponse_ListTasksMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetMetadata

func (*ListTasksResponse) GetTasks

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) GetToken

func (x *ListTasksResponse) GetToken() string

func (*ListTasksResponse) ProtoMessage

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect

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

func (*ListTasksResponse) Reset

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String

func (x *ListTasksResponse) String() string

func (*ListTasksResponse) Validate

func (m *ListTasksResponse) Validate() error

Validate checks the field values on ListTasksResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTasksResponse) ValidateAll

func (m *ListTasksResponse) ValidateAll() error

ValidateAll checks the field values on ListTasksResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTasksResponseMultiError, or nil if none found.

type ListTasksResponseMultiError

type ListTasksResponseMultiError []error

ListTasksResponseMultiError is an error wrapping multiple validation errors returned by ListTasksResponse.ValidateAll() if the designated constraints aren't met.

func (ListTasksResponseMultiError) AllErrors

func (m ListTasksResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListTasksResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ListTasksResponseValidationError

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

ListTasksResponseValidationError is the validation error returned by ListTasksResponse.Validate if the designated constraints aren't met.

func (ListTasksResponseValidationError) Cause

Cause function returns cause value.

func (ListTasksResponseValidationError) Error

Error satisfies the builtin error interface

func (ListTasksResponseValidationError) ErrorName

ErrorName returns error name.

func (ListTasksResponseValidationError) Field

Field function returns field value.

func (ListTasksResponseValidationError) Key

Key function returns key value.

func (ListTasksResponseValidationError) Reason

Reason function returns reason value.

type ListTasksResponse_ListTasksMetadata

type ListTasksResponse_ListTasksMetadata struct {

	// Total number of tasks without filters applied
	Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// Total number of tasks matching the applied filters.
	FilteredTotal uint32 `protobuf:"varint,2,opt,name=filtered_total,json=filteredTotal,proto3" json:"filtered_total,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse_ListTasksMetadata) Descriptor deprecated

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

Deprecated: Use ListTasksResponse_ListTasksMetadata.ProtoReflect.Descriptor instead.

func (*ListTasksResponse_ListTasksMetadata) GetFilteredTotal

func (x *ListTasksResponse_ListTasksMetadata) GetFilteredTotal() uint32

func (*ListTasksResponse_ListTasksMetadata) GetTotal

func (*ListTasksResponse_ListTasksMetadata) ProtoMessage

func (*ListTasksResponse_ListTasksMetadata) ProtoMessage()

func (*ListTasksResponse_ListTasksMetadata) ProtoReflect

func (*ListTasksResponse_ListTasksMetadata) Reset

func (*ListTasksResponse_ListTasksMetadata) String

func (*ListTasksResponse_ListTasksMetadata) Validate

Validate checks the field values on ListTasksResponse_ListTasksMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListTasksResponse_ListTasksMetadata) ValidateAll

func (m *ListTasksResponse_ListTasksMetadata) ValidateAll() error

ValidateAll checks the field values on ListTasksResponse_ListTasksMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListTasksResponse_ListTasksMetadataMultiError, or nil if none found.

type ListTasksResponse_ListTasksMetadataMultiError

type ListTasksResponse_ListTasksMetadataMultiError []error

ListTasksResponse_ListTasksMetadataMultiError is an error wrapping multiple validation errors returned by ListTasksResponse_ListTasksMetadata.ValidateAll() if the designated constraints aren't met.

func (ListTasksResponse_ListTasksMetadataMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (ListTasksResponse_ListTasksMetadataMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ListTasksResponse_ListTasksMetadataValidationError

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

ListTasksResponse_ListTasksMetadataValidationError is the validation error returned by ListTasksResponse_ListTasksMetadata.Validate if the designated constraints aren't met.

func (ListTasksResponse_ListTasksMetadataValidationError) Cause

Cause function returns cause value.

func (ListTasksResponse_ListTasksMetadataValidationError) Error

Error satisfies the builtin error interface

func (ListTasksResponse_ListTasksMetadataValidationError) ErrorName

ErrorName returns error name.

func (ListTasksResponse_ListTasksMetadataValidationError) Field

Field function returns field value.

func (ListTasksResponse_ListTasksMetadataValidationError) Key

Key function returns key value.

func (ListTasksResponse_ListTasksMetadataValidationError) Reason

Reason function returns reason value.

type ListVersionsRequest

type ListVersionsRequest struct {

	// Common list request parameters.
	Request *common.ListRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Id of the task.
	TaskName *TaskName `protobuf:"bytes,2,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// contains filtered or unexported fields
}

Request message for listing versions for a task.

func (*ListVersionsRequest) Descriptor deprecated

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

Deprecated: Use ListVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListVersionsRequest) GetRequest

func (x *ListVersionsRequest) GetRequest() *common.ListRequest

func (*ListVersionsRequest) GetTaskName

func (x *ListVersionsRequest) GetTaskName() *TaskName

func (*ListVersionsRequest) ProtoMessage

func (*ListVersionsRequest) ProtoMessage()

func (*ListVersionsRequest) ProtoReflect

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

func (*ListVersionsRequest) Reset

func (x *ListVersionsRequest) Reset()

func (*ListVersionsRequest) String

func (x *ListVersionsRequest) String() string

func (*ListVersionsRequest) Validate

func (m *ListVersionsRequest) Validate() error

Validate checks the field values on ListVersionsRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListVersionsRequest) ValidateAll

func (m *ListVersionsRequest) ValidateAll() error

ValidateAll checks the field values on ListVersionsRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListVersionsRequestMultiError, or nil if none found.

type ListVersionsRequestMultiError

type ListVersionsRequestMultiError []error

ListVersionsRequestMultiError is an error wrapping multiple validation errors returned by ListVersionsRequest.ValidateAll() if the designated constraints aren't met.

func (ListVersionsRequestMultiError) AllErrors

func (m ListVersionsRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListVersionsRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ListVersionsRequestValidationError

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

ListVersionsRequestValidationError is the validation error returned by ListVersionsRequest.Validate if the designated constraints aren't met.

func (ListVersionsRequestValidationError) Cause

Cause function returns cause value.

func (ListVersionsRequestValidationError) Error

Error satisfies the builtin error interface

func (ListVersionsRequestValidationError) ErrorName

ErrorName returns error name.

func (ListVersionsRequestValidationError) Field

Field function returns field value.

func (ListVersionsRequestValidationError) Key

Key function returns key value.

func (ListVersionsRequestValidationError) Reason

Reason function returns reason value.

type ListVersionsResponse

type ListVersionsResponse struct {

	// Version with deployed_at
	Versions []*ListVersionsResponse_VersionResponse `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	// Pagination token for the next page of versions.
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Response message for listing versions.

func (*ListVersionsResponse) Descriptor deprecated

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

Deprecated: Use ListVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListVersionsResponse) GetToken

func (x *ListVersionsResponse) GetToken() string

func (*ListVersionsResponse) GetVersions

func (*ListVersionsResponse) ProtoMessage

func (*ListVersionsResponse) ProtoMessage()

func (*ListVersionsResponse) ProtoReflect

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

func (*ListVersionsResponse) Reset

func (x *ListVersionsResponse) Reset()

func (*ListVersionsResponse) String

func (x *ListVersionsResponse) String() string

func (*ListVersionsResponse) Validate

func (m *ListVersionsResponse) Validate() error

Validate checks the field values on ListVersionsResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListVersionsResponse) ValidateAll

func (m *ListVersionsResponse) ValidateAll() error

ValidateAll checks the field values on ListVersionsResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListVersionsResponseMultiError, or nil if none found.

type ListVersionsResponseMultiError

type ListVersionsResponseMultiError []error

ListVersionsResponseMultiError is an error wrapping multiple validation errors returned by ListVersionsResponse.ValidateAll() if the designated constraints aren't met.

func (ListVersionsResponseMultiError) AllErrors

func (m ListVersionsResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ListVersionsResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ListVersionsResponseValidationError

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

ListVersionsResponseValidationError is the validation error returned by ListVersionsResponse.Validate if the designated constraints aren't met.

func (ListVersionsResponseValidationError) Cause

Cause function returns cause value.

func (ListVersionsResponseValidationError) Error

Error satisfies the builtin error interface

func (ListVersionsResponseValidationError) ErrorName

ErrorName returns error name.

func (ListVersionsResponseValidationError) Field

Field function returns field value.

func (ListVersionsResponseValidationError) Key

Key function returns key value.

func (ListVersionsResponseValidationError) Reason

Reason function returns reason value.

type ListVersionsResponse_VersionResponse

type ListVersionsResponse_VersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// The time the task version was deployed
	DeployedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=deployed_at,json=deployedAt,proto3" json:"deployed_at,omitempty"`
	// Identity that deployed this version
	DeployedBy *common.EnrichedIdentity `protobuf:"bytes,3,opt,name=deployed_by,json=deployedBy,proto3" json:"deployed_by,omitempty"`
	// Summary of the latest run for this version, if any
	LatestRun *LatestRunSummary `protobuf:"bytes,4,opt,name=latest_run,json=latestRun,proto3,oneof" json:"latest_run,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVersionsResponse_VersionResponse) Descriptor deprecated

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

Deprecated: Use ListVersionsResponse_VersionResponse.ProtoReflect.Descriptor instead.

func (*ListVersionsResponse_VersionResponse) GetDeployedAt

func (*ListVersionsResponse_VersionResponse) GetDeployedBy added in v2.0.21

func (*ListVersionsResponse_VersionResponse) GetLatestRun added in v2.0.21

func (*ListVersionsResponse_VersionResponse) GetVersion

func (*ListVersionsResponse_VersionResponse) ProtoMessage

func (*ListVersionsResponse_VersionResponse) ProtoMessage()

func (*ListVersionsResponse_VersionResponse) ProtoReflect

func (*ListVersionsResponse_VersionResponse) Reset

func (*ListVersionsResponse_VersionResponse) String

func (*ListVersionsResponse_VersionResponse) Validate

Validate checks the field values on ListVersionsResponse_VersionResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ListVersionsResponse_VersionResponse) ValidateAll

ValidateAll checks the field values on ListVersionsResponse_VersionResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ListVersionsResponse_VersionResponseMultiError, or nil if none found.

type ListVersionsResponse_VersionResponseMultiError

type ListVersionsResponse_VersionResponseMultiError []error

ListVersionsResponse_VersionResponseMultiError is an error wrapping multiple validation errors returned by ListVersionsResponse_VersionResponse.ValidateAll() if the designated constraints aren't met.

func (ListVersionsResponse_VersionResponseMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (ListVersionsResponse_VersionResponseMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ListVersionsResponse_VersionResponseValidationError

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

ListVersionsResponse_VersionResponseValidationError is the validation error returned by ListVersionsResponse_VersionResponse.Validate if the designated constraints aren't met.

func (ListVersionsResponse_VersionResponseValidationError) Cause

Cause function returns cause value.

func (ListVersionsResponse_VersionResponseValidationError) Error

Error satisfies the builtin error interface

func (ListVersionsResponse_VersionResponseValidationError) ErrorName

ErrorName returns error name.

func (ListVersionsResponse_VersionResponseValidationError) Field

Field function returns field value.

func (ListVersionsResponse_VersionResponseValidationError) Key

Key function returns key value.

func (ListVersionsResponse_VersionResponseValidationError) Reason

Reason function returns reason value.

type NamedLiteral

type NamedLiteral struct {

	// Name of the literal.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Literal value.
	Value *core.Literal `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Named literal value.

func (*NamedLiteral) Descriptor deprecated

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

Deprecated: Use NamedLiteral.ProtoReflect.Descriptor instead.

func (*NamedLiteral) GetName

func (x *NamedLiteral) GetName() string

func (*NamedLiteral) GetValue

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

func (*NamedLiteral) ProtoMessage

func (*NamedLiteral) ProtoMessage()

func (*NamedLiteral) ProtoReflect

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

func (*NamedLiteral) Reset

func (x *NamedLiteral) Reset()

func (*NamedLiteral) String

func (x *NamedLiteral) String() string

func (*NamedLiteral) Validate

func (m *NamedLiteral) Validate() error

Validate checks the field values on NamedLiteral with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NamedLiteral) ValidateAll

func (m *NamedLiteral) ValidateAll() error

ValidateAll checks the field values on NamedLiteral with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NamedLiteralMultiError, or nil if none found.

type NamedLiteralMultiError

type NamedLiteralMultiError []error

NamedLiteralMultiError is an error wrapping multiple validation errors returned by NamedLiteral.ValidateAll() if the designated constraints aren't met.

func (NamedLiteralMultiError) AllErrors

func (m NamedLiteralMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NamedLiteralMultiError) Error

func (m NamedLiteralMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NamedLiteralValidationError

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

NamedLiteralValidationError is the validation error returned by NamedLiteral.Validate if the designated constraints aren't met.

func (NamedLiteralValidationError) Cause

Cause function returns cause value.

func (NamedLiteralValidationError) Error

Error satisfies the builtin error interface

func (NamedLiteralValidationError) ErrorName

func (e NamedLiteralValidationError) ErrorName() string

ErrorName returns error name.

func (NamedLiteralValidationError) Field

Field function returns field value.

func (NamedLiteralValidationError) Key

Key function returns key value.

func (NamedLiteralValidationError) Reason

Reason function returns reason value.

type NamedParameter

type NamedParameter struct {
	Name      string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Parameter *core.Parameter `protobuf:"bytes,2,opt,name=parameter,proto3" json:"parameter,omitempty"`
	// contains filtered or unexported fields
}

func (*NamedParameter) Descriptor deprecated

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

Deprecated: Use NamedParameter.ProtoReflect.Descriptor instead.

func (*NamedParameter) GetName

func (x *NamedParameter) GetName() string

func (*NamedParameter) GetParameter

func (x *NamedParameter) GetParameter() *core.Parameter

func (*NamedParameter) ProtoMessage

func (*NamedParameter) ProtoMessage()

func (*NamedParameter) ProtoReflect

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

func (*NamedParameter) Reset

func (x *NamedParameter) Reset()

func (*NamedParameter) String

func (x *NamedParameter) String() string

func (*NamedParameter) Validate

func (m *NamedParameter) Validate() error

Validate checks the field values on NamedParameter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*NamedParameter) ValidateAll

func (m *NamedParameter) ValidateAll() error

ValidateAll checks the field values on NamedParameter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in NamedParameterMultiError, or nil if none found.

type NamedParameterMultiError

type NamedParameterMultiError []error

NamedParameterMultiError is an error wrapping multiple validation errors returned by NamedParameter.ValidateAll() if the designated constraints aren't met.

func (NamedParameterMultiError) AllErrors

func (m NamedParameterMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (NamedParameterMultiError) Error

func (m NamedParameterMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type NamedParameterValidationError

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

NamedParameterValidationError is the validation error returned by NamedParameter.Validate if the designated constraints aren't met.

func (NamedParameterValidationError) Cause

Cause function returns cause value.

func (NamedParameterValidationError) Error

Error satisfies the builtin error interface

func (NamedParameterValidationError) ErrorName

func (e NamedParameterValidationError) ErrorName() string

ErrorName returns error name.

func (NamedParameterValidationError) Field

Field function returns field value.

func (NamedParameterValidationError) Key

Key function returns key value.

func (NamedParameterValidationError) Reason

Reason function returns reason value.

type OutputReferences

type OutputReferences struct {

	// The output uri.
	OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3" json:"output_uri,omitempty"`
	// Native URI to HTML report
	ReportUri string `protobuf:"bytes,2,opt,name=report_uri,json=reportUri,proto3" json:"report_uri,omitempty"`
	// contains filtered or unexported fields
}

Output references.

func (*OutputReferences) Descriptor deprecated

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

Deprecated: Use OutputReferences.ProtoReflect.Descriptor instead.

func (*OutputReferences) GetOutputUri

func (x *OutputReferences) GetOutputUri() string

func (*OutputReferences) GetReportUri

func (x *OutputReferences) GetReportUri() string

func (*OutputReferences) ProtoMessage

func (*OutputReferences) ProtoMessage()

func (*OutputReferences) ProtoReflect

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

func (*OutputReferences) Reset

func (x *OutputReferences) Reset()

func (*OutputReferences) String

func (x *OutputReferences) String() string

func (*OutputReferences) Validate

func (m *OutputReferences) Validate() error

Validate checks the field values on OutputReferences with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*OutputReferences) ValidateAll

func (m *OutputReferences) ValidateAll() error

ValidateAll checks the field values on OutputReferences with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OutputReferencesMultiError, or nil if none found.

type OutputReferencesMultiError

type OutputReferencesMultiError []error

OutputReferencesMultiError is an error wrapping multiple validation errors returned by OutputReferences.ValidateAll() if the designated constraints aren't met.

func (OutputReferencesMultiError) AllErrors

func (m OutputReferencesMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OutputReferencesMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type OutputReferencesValidationError

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

OutputReferencesValidationError is the validation error returned by OutputReferences.Validate if the designated constraints aren't met.

func (OutputReferencesValidationError) Cause

Cause function returns cause value.

func (OutputReferencesValidationError) Error

Error satisfies the builtin error interface

func (OutputReferencesValidationError) ErrorName

ErrorName returns error name.

func (OutputReferencesValidationError) Field

Field function returns field value.

func (OutputReferencesValidationError) Key

Key function returns key value.

func (OutputReferencesValidationError) Reason

Reason function returns reason value.

type Outputs

type Outputs struct {

	// Ordered outputs. THIS FIELD MUST REMAIN FIRST as this would break Run service assumptions if it were to move.
	Literals []*NamedLiteral `protobuf:"bytes,1,rep,name=literals,proto3" json:"literals,omitempty"`
	// contains filtered or unexported fields
}

Output payload for an action.

func (*Outputs) Descriptor deprecated

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

Deprecated: Use Outputs.ProtoReflect.Descriptor instead.

func (*Outputs) GetLiterals

func (x *Outputs) GetLiterals() []*NamedLiteral

func (*Outputs) ProtoMessage

func (*Outputs) ProtoMessage()

func (*Outputs) ProtoReflect

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

func (*Outputs) Reset

func (x *Outputs) Reset()

func (*Outputs) String

func (x *Outputs) String() string

func (*Outputs) Validate

func (m *Outputs) Validate() error

Validate checks the field values on Outputs with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Outputs) ValidateAll

func (m *Outputs) ValidateAll() error

ValidateAll checks the field values on Outputs with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in OutputsMultiError, or nil if none found.

type OutputsMultiError

type OutputsMultiError []error

OutputsMultiError is an error wrapping multiple validation errors returned by Outputs.ValidateAll() if the designated constraints aren't met.

func (OutputsMultiError) AllErrors

func (m OutputsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (OutputsMultiError) Error

func (m OutputsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type OutputsValidationError

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

OutputsValidationError is the validation error returned by Outputs.Validate if the designated constraints aren't met.

func (OutputsValidationError) Cause

func (e OutputsValidationError) Cause() error

Cause function returns cause value.

func (OutputsValidationError) Error

func (e OutputsValidationError) Error() string

Error satisfies the builtin error interface

func (OutputsValidationError) ErrorName

func (e OutputsValidationError) ErrorName() string

ErrorName returns error name.

func (OutputsValidationError) Field

func (e OutputsValidationError) Field() string

Field function returns field value.

func (OutputsValidationError) Key

func (e OutputsValidationError) Key() bool

Key function returns key value.

func (OutputsValidationError) Reason

func (e OutputsValidationError) Reason() string

Reason function returns reason value.

type RawDataStorage

type RawDataStorage struct {

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

func (*RawDataStorage) Descriptor deprecated

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

Deprecated: Use RawDataStorage.ProtoReflect.Descriptor instead.

func (*RawDataStorage) GetRawDataPrefix

func (x *RawDataStorage) GetRawDataPrefix() string

func (*RawDataStorage) ProtoMessage

func (*RawDataStorage) ProtoMessage()

func (*RawDataStorage) ProtoReflect

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

func (*RawDataStorage) Reset

func (x *RawDataStorage) Reset()

func (*RawDataStorage) String

func (x *RawDataStorage) String() string

func (*RawDataStorage) Validate

func (m *RawDataStorage) Validate() error

Validate checks the field values on RawDataStorage with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RawDataStorage) ValidateAll

func (m *RawDataStorage) ValidateAll() error

ValidateAll checks the field values on RawDataStorage with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RawDataStorageMultiError, or nil if none found.

type RawDataStorageMultiError

type RawDataStorageMultiError []error

RawDataStorageMultiError is an error wrapping multiple validation errors returned by RawDataStorage.ValidateAll() if the designated constraints aren't met.

func (RawDataStorageMultiError) AllErrors

func (m RawDataStorageMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RawDataStorageMultiError) Error

func (m RawDataStorageMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RawDataStorageValidationError

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

RawDataStorageValidationError is the validation error returned by RawDataStorage.Validate if the designated constraints aren't met.

func (RawDataStorageValidationError) Cause

Cause function returns cause value.

func (RawDataStorageValidationError) Error

Error satisfies the builtin error interface

func (RawDataStorageValidationError) ErrorName

func (e RawDataStorageValidationError) ErrorName() string

ErrorName returns error name.

func (RawDataStorageValidationError) Field

Field function returns field value.

func (RawDataStorageValidationError) Key

Key function returns key value.

func (RawDataStorageValidationError) Reason

Reason function returns reason value.

type RunSpec

type RunSpec struct {

	// Labels to apply to the run.
	Labels *Labels `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
	// Annotations to apply to the run.
	Annotations *Annotations `protobuf:"bytes,2,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// Envs to apply to the run.
	Envs *Envs `protobuf:"bytes,3,opt,name=envs,proto3" json:"envs,omitempty"`
	// Explicit override for executing this run as interruptible or not. If not set, use the default.
	Interruptible *wrapperspb.BoolValue `protobuf:"bytes,4,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	// If true, recompute outputs for this run and overwrite any existing cache.
	// Deprecated, please use CacheConfig.OverwriteCache instead
	//
	// Deprecated: Marked as deprecated in flyteidl2/task/run.proto.
	OverwriteCache bool `protobuf:"varint,5,opt,name=overwrite_cache,json=overwriteCache,proto3" json:"overwrite_cache,omitempty"`
	// the specific cluster that this action should be executed on. this value will be used as the
	// default for all actions in the run unless overridden.
	Cluster string `protobuf:"bytes,6,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.).
	RawDataStorage *RawDataStorage `protobuf:"bytes,7,opt,name=raw_data_storage,json=rawDataStorage,proto3" json:"raw_data_storage,omitempty"`
	// SecurityContext holds security attributes that apply to tasks.
	SecurityContext *core.SecurityContext `protobuf:"bytes,8,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// CacheConfig contains configurations that influence the behavior of cache reads and writes
	CacheConfig *CacheConfig `protobuf:"bytes,9,opt,name=cache_config,json=cacheConfig,proto3" json:"cache_config,omitempty"`
	// Optionally, you can send a notification when your run completes.
	//
	// Types that are assignable to NotificationSettings:
	//
	//	*RunSpec_NotificationRuleName
	//	*RunSpec_NotificationRules
	NotificationSettings isRunSpec_NotificationSettings `protobuf_oneof:"notification_settings"`
	// The time at which the run was started. For scheduled-trigger runs this is the trigger's
	// scheduled fire time; for ad-hoc runs the server defaults it to run-creation time. It is
	// substituted into the {{.runStartTime}} container-arg template so task code can read it via
	// flyte.ctx().run_start_time (SDK >= 2.3.6). Older task templates omit the placeholder, so
	// the substitution is a harmless no-op for them.
	RunStartTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=run_start_time,json=runStartTime,proto3" json:"run_start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*RunSpec) Descriptor deprecated

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

Deprecated: Use RunSpec.ProtoReflect.Descriptor instead.

func (*RunSpec) GetAnnotations

func (x *RunSpec) GetAnnotations() *Annotations

func (*RunSpec) GetCacheConfig

func (x *RunSpec) GetCacheConfig() *CacheConfig

func (*RunSpec) GetCluster

func (x *RunSpec) GetCluster() string

func (*RunSpec) GetEnvs

func (x *RunSpec) GetEnvs() *Envs

func (*RunSpec) GetInterruptible

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

func (*RunSpec) GetLabels

func (x *RunSpec) GetLabels() *Labels

func (*RunSpec) GetNotificationRuleName added in v2.0.8

func (x *RunSpec) GetNotificationRuleName() string

func (*RunSpec) GetNotificationRules added in v2.0.8

func (x *RunSpec) GetNotificationRules() *InlineRuleList

func (*RunSpec) GetNotificationSettings added in v2.0.8

func (m *RunSpec) GetNotificationSettings() isRunSpec_NotificationSettings

func (*RunSpec) GetOverwriteCache deprecated

func (x *RunSpec) GetOverwriteCache() bool

Deprecated: Marked as deprecated in flyteidl2/task/run.proto.

func (*RunSpec) GetRawDataStorage

func (x *RunSpec) GetRawDataStorage() *RawDataStorage

func (*RunSpec) GetRunStartTime added in v2.0.21

func (x *RunSpec) GetRunStartTime() *timestamppb.Timestamp

func (*RunSpec) GetSecurityContext

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

func (*RunSpec) ProtoMessage

func (*RunSpec) ProtoMessage()

func (*RunSpec) ProtoReflect

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

func (*RunSpec) Reset

func (x *RunSpec) Reset()

func (*RunSpec) String

func (x *RunSpec) String() string

func (*RunSpec) Validate

func (m *RunSpec) Validate() error

Validate checks the field values on RunSpec with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*RunSpec) ValidateAll

func (m *RunSpec) ValidateAll() error

ValidateAll checks the field values on RunSpec with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RunSpecMultiError, or nil if none found.

type RunSpecMultiError

type RunSpecMultiError []error

RunSpecMultiError is an error wrapping multiple validation errors returned by RunSpec.ValidateAll() if the designated constraints aren't met.

func (RunSpecMultiError) AllErrors

func (m RunSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (RunSpecMultiError) Error

func (m RunSpecMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type RunSpecValidationError

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

RunSpecValidationError is the validation error returned by RunSpec.Validate if the designated constraints aren't met.

func (RunSpecValidationError) Cause

func (e RunSpecValidationError) Cause() error

Cause function returns cause value.

func (RunSpecValidationError) Error

func (e RunSpecValidationError) Error() string

Error satisfies the builtin error interface

func (RunSpecValidationError) ErrorName

func (e RunSpecValidationError) ErrorName() string

ErrorName returns error name.

func (RunSpecValidationError) Field

func (e RunSpecValidationError) Field() string

Field function returns field value.

func (RunSpecValidationError) Key

func (e RunSpecValidationError) Key() bool

Key function returns key value.

func (RunSpecValidationError) Reason

func (e RunSpecValidationError) Reason() string

Reason function returns reason value.

type RunSpec_NotificationRuleName added in v2.0.8

type RunSpec_NotificationRuleName struct {
	NotificationRuleName string `protobuf:"bytes,10,opt,name=notification_rule_name,json=notificationRuleName,proto3,oneof"` // either refer to a previously stored notification rule
}

type RunSpec_NotificationRules added in v2.0.8

type RunSpec_NotificationRules struct {
	NotificationRules *InlineRuleList `protobuf:"bytes,11,opt,name=notification_rules,json=notificationRules,proto3,oneof"` // either define an inline one-off rule
}

type Schedule

type Schedule struct {

	// Types that are assignable to Expression:
	//
	//	*Schedule_Rate
	//	*Schedule_CronExpression
	//	*Schedule_Cron
	Expression isSchedule_Expression `protobuf_oneof:"expression"`
	// 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) GetCron

func (x *Schedule) GetCron() *Cron

func (*Schedule) GetCronExpression deprecated

func (x *Schedule) GetCronExpression() string

Deprecated: Marked as deprecated in flyteidl2/task/common.proto.

func (*Schedule) GetExpression

func (m *Schedule) GetExpression() isSchedule_Expression

func (*Schedule) GetKickoffTimeInputArg

func (x *Schedule) GetKickoffTimeInputArg() string

func (*Schedule) GetRate

func (x *Schedule) GetRate() *FixedRate

func (*Schedule) ProtoMessage

func (*Schedule) ProtoMessage()

func (*Schedule) ProtoReflect

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

func (*Schedule) Reset

func (x *Schedule) Reset()

func (*Schedule) String

func (x *Schedule) String() string

func (*Schedule) Validate

func (m *Schedule) Validate() error

Validate checks the field values on Schedule with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Schedule) ValidateAll

func (m *Schedule) ValidateAll() error

ValidateAll checks the field values on Schedule with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ScheduleMultiError, or nil if none found.

type ScheduleMultiError

type ScheduleMultiError []error

ScheduleMultiError is an error wrapping multiple validation errors returned by Schedule.ValidateAll() if the designated constraints aren't met.

func (ScheduleMultiError) AllErrors

func (m ScheduleMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ScheduleMultiError) Error

func (m ScheduleMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type ScheduleValidationError

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

ScheduleValidationError is the validation error returned by Schedule.Validate if the designated constraints aren't met.

func (ScheduleValidationError) Cause

func (e ScheduleValidationError) Cause() error

Cause function returns cause value.

func (ScheduleValidationError) Error

func (e ScheduleValidationError) Error() string

Error satisfies the builtin error interface

func (ScheduleValidationError) ErrorName

func (e ScheduleValidationError) ErrorName() string

ErrorName returns error name.

func (ScheduleValidationError) Field

func (e ScheduleValidationError) Field() string

Field function returns field value.

func (ScheduleValidationError) Key

func (e ScheduleValidationError) Key() bool

Key function returns key value.

func (ScheduleValidationError) Reason

func (e ScheduleValidationError) Reason() string

Reason function returns reason value.

type Schedule_Cron

type Schedule_Cron struct {
	Cron *Cron `protobuf:"bytes,4,opt,name=cron,proto3,oneof"`
}

type Schedule_CronExpression

type Schedule_CronExpression struct {
	// Deprecated: Marked as deprecated in flyteidl2/task/common.proto.
	CronExpression string `protobuf:"bytes,2,opt,name=cron_expression,json=cronExpression,proto3,oneof"`
}

type Schedule_Rate

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

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

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

func (*SourceCode) Reset

func (x *SourceCode) Reset()

func (*SourceCode) String

func (x *SourceCode) String() string

func (*SourceCode) Validate

func (m *SourceCode) Validate() error

Validate checks the field values on SourceCode with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*SourceCode) ValidateAll

func (m *SourceCode) ValidateAll() error

ValidateAll checks the field values on SourceCode with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in SourceCodeMultiError, or nil if none found.

type SourceCodeMultiError

type SourceCodeMultiError []error

SourceCodeMultiError is an error wrapping multiple validation errors returned by SourceCode.ValidateAll() if the designated constraints aren't met.

func (SourceCodeMultiError) AllErrors

func (m SourceCodeMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (SourceCodeMultiError) Error

func (m SourceCodeMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type SourceCodeValidationError

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

SourceCodeValidationError is the validation error returned by SourceCode.Validate if the designated constraints aren't met.

func (SourceCodeValidationError) Cause

func (e SourceCodeValidationError) Cause() error

Cause function returns cause value.

func (SourceCodeValidationError) Error

Error satisfies the builtin error interface

func (SourceCodeValidationError) ErrorName

func (e SourceCodeValidationError) ErrorName() string

ErrorName returns error name.

func (SourceCodeValidationError) Field

Field function returns field value.

func (SourceCodeValidationError) Key

Key function returns key value.

func (SourceCodeValidationError) Reason

func (e SourceCodeValidationError) Reason() string

Reason function returns reason value.

type Task

type Task struct {

	// Id for this task.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Metadata for this task.
	Metadata *TaskMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Summary for this task.
	TaskSummary *TaskSummary `protobuf:"bytes,3,opt,name=task_summary,json=taskSummary,proto3,oneof" json:"task_summary,omitempty"`
	// contains filtered or unexported fields
}

Lightweight representation of a task.

func (*Task) Descriptor deprecated

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetMetadata

func (x *Task) GetMetadata() *TaskMetadata

func (*Task) GetTaskId

func (x *Task) GetTaskId() *TaskIdentifier

func (*Task) GetTaskSummary

func (x *Task) GetTaskSummary() *TaskSummary

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

func (*Task) Validate

func (m *Task) Validate() error

Validate checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Task) ValidateAll

func (m *Task) ValidateAll() error

ValidateAll checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskMultiError, or nil if none found.

type TaskDetails

type TaskDetails struct {

	// Id for this task.
	TaskId *TaskIdentifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Metadata for this task.
	Metadata *TaskMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Specification for this task.
	Spec *TaskSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

Detailed information about a task.

func (*TaskDetails) Descriptor deprecated

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

Deprecated: Use TaskDetails.ProtoReflect.Descriptor instead.

func (*TaskDetails) GetMetadata

func (x *TaskDetails) GetMetadata() *TaskMetadata

func (*TaskDetails) GetSpec

func (x *TaskDetails) GetSpec() *TaskSpec

func (*TaskDetails) GetTaskId

func (x *TaskDetails) GetTaskId() *TaskIdentifier

func (*TaskDetails) ProtoMessage

func (*TaskDetails) ProtoMessage()

func (*TaskDetails) ProtoReflect

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

func (*TaskDetails) Reset

func (x *TaskDetails) Reset()

func (*TaskDetails) String

func (x *TaskDetails) String() string

func (*TaskDetails) Validate

func (m *TaskDetails) Validate() error

Validate checks the field values on TaskDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskDetails) ValidateAll

func (m *TaskDetails) ValidateAll() error

ValidateAll checks the field values on TaskDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskDetailsMultiError, or nil if none found.

type TaskDetailsMultiError

type TaskDetailsMultiError []error

TaskDetailsMultiError is an error wrapping multiple validation errors returned by TaskDetails.ValidateAll() if the designated constraints aren't met.

func (TaskDetailsMultiError) AllErrors

func (m TaskDetailsMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskDetailsMultiError) Error

func (m TaskDetailsMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskDetailsValidationError

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

TaskDetailsValidationError is the validation error returned by TaskDetails.Validate if the designated constraints aren't met.

func (TaskDetailsValidationError) Cause

Cause function returns cause value.

func (TaskDetailsValidationError) Error

Error satisfies the builtin error interface

func (TaskDetailsValidationError) ErrorName

func (e TaskDetailsValidationError) ErrorName() string

ErrorName returns error name.

func (TaskDetailsValidationError) Field

Field function returns field value.

func (TaskDetailsValidationError) Key

Key function returns key value.

func (TaskDetailsValidationError) Reason

Reason function returns reason value.

type TaskIdentifier

type TaskIdentifier struct {

	// Org this task belongs to.
	Org string `protobuf:"bytes,1,opt,name=org,proto3" json:"org,omitempty"`
	// Project this task belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Domain this task belongs to.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// Unique name of the task. Should not be interpreted/parsed. Use `short_name` and `environment_name` for user facing names.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Version of the task.
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

TaskIdentifier is the unique identifier for a task.

func (*TaskIdentifier) Descriptor deprecated

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

Deprecated: Use TaskIdentifier.ProtoReflect.Descriptor instead.

func (*TaskIdentifier) GetDomain

func (x *TaskIdentifier) GetDomain() string

func (*TaskIdentifier) GetName

func (x *TaskIdentifier) GetName() string

func (*TaskIdentifier) GetOrg

func (x *TaskIdentifier) GetOrg() string

func (*TaskIdentifier) GetProject

func (x *TaskIdentifier) GetProject() string

func (*TaskIdentifier) GetVersion

func (x *TaskIdentifier) GetVersion() string

func (*TaskIdentifier) ProtoMessage

func (*TaskIdentifier) ProtoMessage()

func (*TaskIdentifier) ProtoReflect

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

func (*TaskIdentifier) Reset

func (x *TaskIdentifier) Reset()

func (*TaskIdentifier) String

func (x *TaskIdentifier) String() string

func (*TaskIdentifier) Validate

func (m *TaskIdentifier) Validate() error

Validate checks the field values on TaskIdentifier with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskIdentifier) ValidateAll

func (m *TaskIdentifier) ValidateAll() error

ValidateAll checks the field values on TaskIdentifier with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskIdentifierMultiError, or nil if none found.

type TaskIdentifierMultiError

type TaskIdentifierMultiError []error

TaskIdentifierMultiError is an error wrapping multiple validation errors returned by TaskIdentifier.ValidateAll() if the designated constraints aren't met.

func (TaskIdentifierMultiError) AllErrors

func (m TaskIdentifierMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskIdentifierMultiError) Error

func (m TaskIdentifierMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskIdentifierValidationError

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

TaskIdentifierValidationError is the validation error returned by TaskIdentifier.Validate if the designated constraints aren't met.

func (TaskIdentifierValidationError) Cause

Cause function returns cause value.

func (TaskIdentifierValidationError) Error

Error satisfies the builtin error interface

func (TaskIdentifierValidationError) ErrorName

func (e TaskIdentifierValidationError) ErrorName() string

ErrorName returns error name.

func (TaskIdentifierValidationError) Field

Field function returns field value.

func (TaskIdentifierValidationError) Key

Key function returns key value.

func (TaskIdentifierValidationError) Reason

Reason function returns reason value.

type TaskMetadata

type TaskMetadata struct {

	// Identity that deployed the task.
	DeployedBy *common.EnrichedIdentity `protobuf:"bytes,1,opt,name=deployed_by,json=deployedBy,proto3" json:"deployed_by,omitempty"`
	// The short name for this task
	ShortName string `protobuf:"bytes,2,opt,name=short_name,json=shortName,proto3" json:"short_name,omitempty"`
	// The time the task was deployed
	DeployedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deployed_at,json=deployedAt,proto3" json:"deployed_at,omitempty"`
	// The environment name for this task, if present.
	EnvironmentName string `protobuf:"bytes,4,opt,name=environment_name,json=environmentName,proto3" json:"environment_name,omitempty"`
	// Brief overview of attached triggers if any.
	TriggersSummary *TaskTriggersSummary `protobuf:"bytes,5,opt,name=triggers_summary,json=triggersSummary,proto3" json:"triggers_summary,omitempty"`
	// The short description for this task
	ShortDescription string `protobuf:"bytes,6,opt,name=short_description,json=shortDescription,proto3" json:"short_description,omitempty"`
	// contains filtered or unexported fields
}

TaskMetadata is static, lightweight metadata about a task.

func (*TaskMetadata) Descriptor deprecated

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

Deprecated: Use TaskMetadata.ProtoReflect.Descriptor instead.

func (*TaskMetadata) GetDeployedAt

func (x *TaskMetadata) GetDeployedAt() *timestamppb.Timestamp

func (*TaskMetadata) GetDeployedBy

func (x *TaskMetadata) GetDeployedBy() *common.EnrichedIdentity

func (*TaskMetadata) GetEnvironmentName

func (x *TaskMetadata) GetEnvironmentName() string

func (*TaskMetadata) GetShortDescription

func (x *TaskMetadata) GetShortDescription() string

func (*TaskMetadata) GetShortName

func (x *TaskMetadata) GetShortName() string

func (*TaskMetadata) GetTriggersSummary

func (x *TaskMetadata) GetTriggersSummary() *TaskTriggersSummary

func (*TaskMetadata) ProtoMessage

func (*TaskMetadata) ProtoMessage()

func (*TaskMetadata) ProtoReflect

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

func (*TaskMetadata) Reset

func (x *TaskMetadata) Reset()

func (*TaskMetadata) String

func (x *TaskMetadata) String() string

func (*TaskMetadata) Validate

func (m *TaskMetadata) Validate() error

Validate checks the field values on TaskMetadata with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskMetadata) ValidateAll

func (m *TaskMetadata) ValidateAll() error

ValidateAll checks the field values on TaskMetadata with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskMetadataMultiError, or nil if none found.

type TaskMetadataMultiError

type TaskMetadataMultiError []error

TaskMetadataMultiError is an error wrapping multiple validation errors returned by TaskMetadata.ValidateAll() if the designated constraints aren't met.

func (TaskMetadataMultiError) AllErrors

func (m TaskMetadataMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMetadataMultiError) Error

func (m TaskMetadataMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskMetadataValidationError

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

TaskMetadataValidationError is the validation error returned by TaskMetadata.Validate if the designated constraints aren't met.

func (TaskMetadataValidationError) Cause

Cause function returns cause value.

func (TaskMetadataValidationError) Error

Error satisfies the builtin error interface

func (TaskMetadataValidationError) ErrorName

func (e TaskMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskMetadataValidationError) Field

Field function returns field value.

func (TaskMetadataValidationError) Key

Key function returns key value.

func (TaskMetadataValidationError) Reason

Reason function returns reason value.

type TaskMultiError

type TaskMultiError []error

TaskMultiError is an error wrapping multiple validation errors returned by Task.ValidateAll() if the designated constraints aren't met.

func (TaskMultiError) AllErrors

func (m TaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMultiError) Error

func (m TaskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskName

type TaskName struct {

	// Org this task belongs to.
	Org string `protobuf:"bytes,1,opt,name=org,proto3" json:"org,omitempty"`
	// Project this task belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Domain this task belongs to.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// Unique name of the task. Should not be interpreted/parsed. Use `short_name` and `environment_name` for user facing names.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Name of a task. It may have multiple versions deployed.

func (*TaskName) Descriptor deprecated

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

Deprecated: Use TaskName.ProtoReflect.Descriptor instead.

func (*TaskName) GetDomain

func (x *TaskName) GetDomain() string

func (*TaskName) GetName

func (x *TaskName) GetName() string

func (*TaskName) GetOrg

func (x *TaskName) GetOrg() string

func (*TaskName) GetProject

func (x *TaskName) GetProject() string

func (*TaskName) ProtoMessage

func (*TaskName) ProtoMessage()

func (*TaskName) ProtoReflect

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

func (*TaskName) Reset

func (x *TaskName) Reset()

func (*TaskName) String

func (x *TaskName) String() string

func (*TaskName) Validate

func (m *TaskName) Validate() error

Validate checks the field values on TaskName with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskName) ValidateAll

func (m *TaskName) ValidateAll() error

ValidateAll checks the field values on TaskName with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskNameMultiError, or nil if none found.

type TaskNameMultiError

type TaskNameMultiError []error

TaskNameMultiError is an error wrapping multiple validation errors returned by TaskName.ValidateAll() if the designated constraints aren't met.

func (TaskNameMultiError) AllErrors

func (m TaskNameMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskNameMultiError) Error

func (m TaskNameMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskNameValidationError

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

TaskNameValidationError is the validation error returned by TaskName.Validate if the designated constraints aren't met.

func (TaskNameValidationError) Cause

func (e TaskNameValidationError) Cause() error

Cause function returns cause value.

func (TaskNameValidationError) Error

func (e TaskNameValidationError) Error() string

Error satisfies the builtin error interface

func (TaskNameValidationError) ErrorName

func (e TaskNameValidationError) ErrorName() string

ErrorName returns error name.

func (TaskNameValidationError) Field

func (e TaskNameValidationError) Field() string

Field function returns field value.

func (TaskNameValidationError) Key

func (e TaskNameValidationError) Key() bool

Key function returns key value.

func (TaskNameValidationError) Reason

func (e TaskNameValidationError) Reason() string

Reason function returns reason value.

type TaskServiceClient

type TaskServiceClient interface {
	// Deploy a task.
	DeployTask(ctx context.Context, in *DeployTaskRequest, opts ...grpc.CallOption) (*DeployTaskResponse, error)
	// Get detailed information about a task.
	GetTaskDetails(ctx context.Context, in *GetTaskDetailsRequest, opts ...grpc.CallOption) (*GetTaskDetailsResponse, error)
	// Lists tasks, one per task name, returning the latest version and who it was deployed by.
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	// Lists all versions for a task.
	ListVersions(ctx context.Context, in *ListVersionsRequest, opts ...grpc.CallOption) (*ListVersionsResponse, error)
}

TaskServiceClient is the client API for TaskService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type TaskServiceServer

type TaskServiceServer interface {
	// Deploy a task.
	DeployTask(context.Context, *DeployTaskRequest) (*DeployTaskResponse, error)
	// Get detailed information about a task.
	GetTaskDetails(context.Context, *GetTaskDetailsRequest) (*GetTaskDetailsResponse, error)
	// Lists tasks, one per task name, returning the latest version and who it was deployed by.
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	// Lists all versions for a task.
	ListVersions(context.Context, *ListVersionsRequest) (*ListVersionsResponse, error)
}

TaskServiceServer is the server API for TaskService service. All implementations should embed UnimplementedTaskServiceServer for forward compatibility

type TaskSpec

type TaskSpec struct {

	// The template for this task.
	TaskTemplate *core.TaskTemplate `protobuf:"bytes,1,opt,name=task_template,json=taskTemplate,proto3" json:"task_template,omitempty"`
	// Ordered default inputs.
	// These can be overridden when an run is created.
	// Client should not send required=true flag in underlying flyteidl2.core.Parameter.
	DefaultInputs []*NamedParameter `protobuf:"bytes,2,rep,name=default_inputs,json=defaultInputs,proto3" json:"default_inputs,omitempty"`
	// User facing display name for this task. Not required to be unique.
	// This is passed in via the SDK when the task is created and is either a user defined override or the name of the task.
	ShortName string `protobuf:"bytes,3,opt,name=short_name,json=shortName,proto3" json:"short_name,omitempty"`
	// Optional environment for this task. Note, some tasks may not be run in the context of an environment.
	Environment *Environment `protobuf:"bytes,4,opt,name=environment,proto3" json:"environment,omitempty"`
	// The documentation entity for the task
	Documentation *DocumentationEntity `protobuf:"bytes,5,opt,name=documentation,proto3" json:"documentation,omitempty"`
	// contains filtered or unexported fields
}

Specification for a task.

func (*TaskSpec) Descriptor deprecated

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

Deprecated: Use TaskSpec.ProtoReflect.Descriptor instead.

func (*TaskSpec) GetDefaultInputs

func (x *TaskSpec) GetDefaultInputs() []*NamedParameter

func (*TaskSpec) GetDocumentation

func (x *TaskSpec) GetDocumentation() *DocumentationEntity

func (*TaskSpec) GetEnvironment

func (x *TaskSpec) GetEnvironment() *Environment

func (*TaskSpec) GetShortName

func (x *TaskSpec) GetShortName() string

func (*TaskSpec) GetTaskTemplate

func (x *TaskSpec) GetTaskTemplate() *core.TaskTemplate

func (*TaskSpec) ProtoMessage

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) ProtoReflect

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

func (*TaskSpec) Reset

func (x *TaskSpec) Reset()

func (*TaskSpec) String

func (x *TaskSpec) String() string

func (*TaskSpec) Validate

func (m *TaskSpec) Validate() error

Validate checks the field values on TaskSpec with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskSpec) ValidateAll

func (m *TaskSpec) ValidateAll() error

ValidateAll checks the field values on TaskSpec with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskSpecMultiError, or nil if none found.

type TaskSpecMultiError

type TaskSpecMultiError []error

TaskSpecMultiError is an error wrapping multiple validation errors returned by TaskSpec.ValidateAll() if the designated constraints aren't met.

func (TaskSpecMultiError) AllErrors

func (m TaskSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskSpecMultiError) Error

func (m TaskSpecMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskSpecValidationError

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

TaskSpecValidationError is the validation error returned by TaskSpec.Validate if the designated constraints aren't met.

func (TaskSpecValidationError) Cause

func (e TaskSpecValidationError) Cause() error

Cause function returns cause value.

func (TaskSpecValidationError) Error

func (e TaskSpecValidationError) Error() string

Error satisfies the builtin error interface

func (TaskSpecValidationError) ErrorName

func (e TaskSpecValidationError) ErrorName() string

ErrorName returns error name.

func (TaskSpecValidationError) Field

func (e TaskSpecValidationError) Field() string

Field function returns field value.

func (TaskSpecValidationError) Key

func (e TaskSpecValidationError) Key() bool

Key function returns key value.

func (TaskSpecValidationError) Reason

func (e TaskSpecValidationError) Reason() string

Reason function returns reason value.

type TaskSummary

type TaskSummary struct {

	// Summary of the latest run for this task, if any
	LatestRun *LatestRunSummary `protobuf:"bytes,1,opt,name=latest_run,json=latestRun,proto3,oneof" json:"latest_run,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskSummary) Descriptor deprecated

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

Deprecated: Use TaskSummary.ProtoReflect.Descriptor instead.

func (*TaskSummary) GetLatestRun

func (x *TaskSummary) GetLatestRun() *LatestRunSummary

func (*TaskSummary) ProtoMessage

func (*TaskSummary) ProtoMessage()

func (*TaskSummary) ProtoReflect

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

func (*TaskSummary) Reset

func (x *TaskSummary) Reset()

func (*TaskSummary) String

func (x *TaskSummary) String() string

func (*TaskSummary) Validate

func (m *TaskSummary) Validate() error

Validate checks the field values on TaskSummary with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskSummary) ValidateAll

func (m *TaskSummary) ValidateAll() error

ValidateAll checks the field values on TaskSummary with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskSummaryMultiError, or nil if none found.

type TaskSummaryMultiError

type TaskSummaryMultiError []error

TaskSummaryMultiError is an error wrapping multiple validation errors returned by TaskSummary.ValidateAll() if the designated constraints aren't met.

func (TaskSummaryMultiError) AllErrors

func (m TaskSummaryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskSummaryMultiError) Error

func (m TaskSummaryMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskSummaryValidationError

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

TaskSummaryValidationError is the validation error returned by TaskSummary.Validate if the designated constraints aren't met.

func (TaskSummaryValidationError) Cause

Cause function returns cause value.

func (TaskSummaryValidationError) Error

Error satisfies the builtin error interface

func (TaskSummaryValidationError) ErrorName

func (e TaskSummaryValidationError) ErrorName() string

ErrorName returns error name.

func (TaskSummaryValidationError) Field

Field function returns field value.

func (TaskSummaryValidationError) Key

Key function returns key value.

func (TaskSummaryValidationError) Reason

Reason function returns reason value.

type TaskTrigger

type TaskTrigger struct {
	Name string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Spec *TaskTriggerSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Optional automation spec.
	AutomationSpec *TriggerAutomationSpec `protobuf:"bytes,3,opt,name=automation_spec,json=automationSpec,proto3" json:"automation_spec,omitempty"`
	// contains filtered or unexported fields
}

Contains details about a single trigger attached to a task. Should only be used in DeployTask endpoint.

func (*TaskTrigger) Descriptor deprecated

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

Deprecated: Use TaskTrigger.ProtoReflect.Descriptor instead.

func (*TaskTrigger) GetAutomationSpec

func (x *TaskTrigger) GetAutomationSpec() *TriggerAutomationSpec

func (*TaskTrigger) GetName

func (x *TaskTrigger) GetName() string

func (*TaskTrigger) GetSpec

func (x *TaskTrigger) GetSpec() *TaskTriggerSpec

func (*TaskTrigger) ProtoMessage

func (*TaskTrigger) ProtoMessage()

func (*TaskTrigger) ProtoReflect

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

func (*TaskTrigger) Reset

func (x *TaskTrigger) Reset()

func (*TaskTrigger) String

func (x *TaskTrigger) String() string

func (*TaskTrigger) Validate

func (m *TaskTrigger) Validate() error

Validate checks the field values on TaskTrigger with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskTrigger) ValidateAll

func (m *TaskTrigger) ValidateAll() error

ValidateAll checks the field values on TaskTrigger with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskTriggerMultiError, or nil if none found.

type TaskTriggerMultiError

type TaskTriggerMultiError []error

TaskTriggerMultiError is an error wrapping multiple validation errors returned by TaskTrigger.ValidateAll() if the designated constraints aren't met.

func (TaskTriggerMultiError) AllErrors

func (m TaskTriggerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskTriggerMultiError) Error

func (m TaskTriggerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskTriggerSpec

type TaskTriggerSpec struct {

	// Whether trigger is active
	Active bool `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
	// Inputs for the triggered task. Inline literals are set by older SDKs; newer SDKs (>= 2.3.6)
	// offload the inputs via UploadInputs at registration and set offloaded_input_data instead.
	//
	// Types that are assignable to InputWrapper:
	//
	//	*TaskTriggerSpec_Inputs
	//	*TaskTriggerSpec_OffloadedInputData
	InputWrapper isTaskTriggerSpec_InputWrapper `protobuf_oneof:"input_wrapper"`
	// The run spec for triggered task.
	RunSpec *RunSpec `protobuf:"bytes,3,opt,name=run_spec,json=runSpec,proto3" json:"run_spec,omitempty"`
	// Optional description
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

TaskTriggerSpec this is a copy of TriggerSpec without mandatory 'task_version' field. This is supposed to be used only in DeployTask endpoint where 'task_version' is already provided in task_id.

func (*TaskTriggerSpec) Descriptor deprecated

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

Deprecated: Use TaskTriggerSpec.ProtoReflect.Descriptor instead.

func (*TaskTriggerSpec) GetActive

func (x *TaskTriggerSpec) GetActive() bool

func (*TaskTriggerSpec) GetDescription

func (x *TaskTriggerSpec) GetDescription() string

func (*TaskTriggerSpec) GetInputWrapper added in v2.0.21

func (m *TaskTriggerSpec) GetInputWrapper() isTaskTriggerSpec_InputWrapper

func (*TaskTriggerSpec) GetInputs

func (x *TaskTriggerSpec) GetInputs() *Inputs

func (*TaskTriggerSpec) GetOffloadedInputData added in v2.0.21

func (x *TaskTriggerSpec) GetOffloadedInputData() *common.OffloadedInputData

func (*TaskTriggerSpec) GetRunSpec

func (x *TaskTriggerSpec) GetRunSpec() *RunSpec

func (*TaskTriggerSpec) ProtoMessage

func (*TaskTriggerSpec) ProtoMessage()

func (*TaskTriggerSpec) ProtoReflect

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

func (*TaskTriggerSpec) Reset

func (x *TaskTriggerSpec) Reset()

func (*TaskTriggerSpec) String

func (x *TaskTriggerSpec) String() string

func (*TaskTriggerSpec) Validate

func (m *TaskTriggerSpec) Validate() error

Validate checks the field values on TaskTriggerSpec with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskTriggerSpec) ValidateAll

func (m *TaskTriggerSpec) ValidateAll() error

ValidateAll checks the field values on TaskTriggerSpec with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskTriggerSpecMultiError, or nil if none found.

type TaskTriggerSpecMultiError

type TaskTriggerSpecMultiError []error

TaskTriggerSpecMultiError is an error wrapping multiple validation errors returned by TaskTriggerSpec.ValidateAll() if the designated constraints aren't met.

func (TaskTriggerSpecMultiError) AllErrors

func (m TaskTriggerSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskTriggerSpecMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TaskTriggerSpecValidationError

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

TaskTriggerSpecValidationError is the validation error returned by TaskTriggerSpec.Validate if the designated constraints aren't met.

func (TaskTriggerSpecValidationError) Cause

Cause function returns cause value.

func (TaskTriggerSpecValidationError) Error

Error satisfies the builtin error interface

func (TaskTriggerSpecValidationError) ErrorName

func (e TaskTriggerSpecValidationError) ErrorName() string

ErrorName returns error name.

func (TaskTriggerSpecValidationError) Field

Field function returns field value.

func (TaskTriggerSpecValidationError) Key

Key function returns key value.

func (TaskTriggerSpecValidationError) Reason

Reason function returns reason value.

type TaskTriggerSpec_Inputs added in v2.0.21

type TaskTriggerSpec_Inputs struct {
	// Inline inputs for the triggered task.
	Inputs *Inputs `protobuf:"bytes,2,opt,name=inputs,proto3,oneof"`
}

type TaskTriggerSpec_OffloadedInputData added in v2.0.21

type TaskTriggerSpec_OffloadedInputData struct {
	// Offloaded inputs for the triggered task (URI + hash from UploadInputs). When present,
	// launches pass this directly as the run's OffloadedInputData and rely on run_start_time
	// rather than merging a kickoff-time input literal.
	OffloadedInputData *common.OffloadedInputData `protobuf:"bytes,5,opt,name=offloaded_input_data,json=offloadedInputData,proto3,oneof"`
}

type TaskTriggerValidationError

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

TaskTriggerValidationError is the validation error returned by TaskTrigger.Validate if the designated constraints aren't met.

func (TaskTriggerValidationError) Cause

Cause function returns cause value.

func (TaskTriggerValidationError) Error

Error satisfies the builtin error interface

func (TaskTriggerValidationError) ErrorName

func (e TaskTriggerValidationError) ErrorName() string

ErrorName returns error name.

func (TaskTriggerValidationError) Field

Field function returns field value.

func (TaskTriggerValidationError) Key

Key function returns key value.

func (TaskTriggerValidationError) Reason

Reason function returns reason value.

type TaskTriggersSummary

type TaskTriggersSummary struct {

	// Types that are assignable to Summary:
	//
	//	*TaskTriggersSummary_Details
	//	*TaskTriggersSummary_Stats
	Summary isTaskTriggersSummary_Summary `protobuf_oneof:"summary"`
	// contains filtered or unexported fields
}

func (*TaskTriggersSummary) Descriptor deprecated

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

Deprecated: Use TaskTriggersSummary.ProtoReflect.Descriptor instead.

func (*TaskTriggersSummary) GetDetails

func (*TaskTriggersSummary) GetStats

func (*TaskTriggersSummary) GetSummary

func (m *TaskTriggersSummary) GetSummary() isTaskTriggersSummary_Summary

func (*TaskTriggersSummary) ProtoMessage

func (*TaskTriggersSummary) ProtoMessage()

func (*TaskTriggersSummary) ProtoReflect

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

func (*TaskTriggersSummary) Reset

func (x *TaskTriggersSummary) Reset()

func (*TaskTriggersSummary) String

func (x *TaskTriggersSummary) String() string

func (*TaskTriggersSummary) Validate

func (m *TaskTriggersSummary) Validate() error

Validate checks the field values on TaskTriggersSummary with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskTriggersSummary) ValidateAll

func (m *TaskTriggersSummary) ValidateAll() error

ValidateAll checks the field values on TaskTriggersSummary with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskTriggersSummaryMultiError, or nil if none found.

type TaskTriggersSummaryMultiError

type TaskTriggersSummaryMultiError []error

TaskTriggersSummaryMultiError is an error wrapping multiple validation errors returned by TaskTriggersSummary.ValidateAll() if the designated constraints aren't met.

func (TaskTriggersSummaryMultiError) AllErrors

func (m TaskTriggersSummaryMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskTriggersSummaryMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TaskTriggersSummaryValidationError

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

TaskTriggersSummaryValidationError is the validation error returned by TaskTriggersSummary.Validate if the designated constraints aren't met.

func (TaskTriggersSummaryValidationError) Cause

Cause function returns cause value.

func (TaskTriggersSummaryValidationError) Error

Error satisfies the builtin error interface

func (TaskTriggersSummaryValidationError) ErrorName

ErrorName returns error name.

func (TaskTriggersSummaryValidationError) Field

Field function returns field value.

func (TaskTriggersSummaryValidationError) Key

Key function returns key value.

func (TaskTriggersSummaryValidationError) Reason

Reason function returns reason value.

type TaskTriggersSummary_Details

type TaskTriggersSummary_Details struct {
	Details *TaskTriggersSummary_TriggerDetails `protobuf:"bytes,3,opt,name=details,proto3,oneof"`
}

type TaskTriggersSummary_Stats

type TaskTriggersSummary_Stats struct {
	Stats *TaskTriggersSummary_TriggerStats `protobuf:"bytes,2,opt,name=stats,proto3,oneof"`
}

type TaskTriggersSummary_TriggerDetails

type TaskTriggersSummary_TriggerDetails struct {
	Name           string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Active         bool                   `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	AutomationSpec *TriggerAutomationSpec `protobuf:"bytes,3,opt,name=automation_spec,json=automationSpec,proto3" json:"automation_spec,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskTriggersSummary_TriggerDetails) Descriptor deprecated

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

Deprecated: Use TaskTriggersSummary_TriggerDetails.ProtoReflect.Descriptor instead.

func (*TaskTriggersSummary_TriggerDetails) GetActive

func (*TaskTriggersSummary_TriggerDetails) GetAutomationSpec

func (*TaskTriggersSummary_TriggerDetails) GetName

func (*TaskTriggersSummary_TriggerDetails) ProtoMessage

func (*TaskTriggersSummary_TriggerDetails) ProtoMessage()

func (*TaskTriggersSummary_TriggerDetails) ProtoReflect

func (*TaskTriggersSummary_TriggerDetails) Reset

func (*TaskTriggersSummary_TriggerDetails) String

func (*TaskTriggersSummary_TriggerDetails) Validate

Validate checks the field values on TaskTriggersSummary_TriggerDetails with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskTriggersSummary_TriggerDetails) ValidateAll

func (m *TaskTriggersSummary_TriggerDetails) ValidateAll() error

ValidateAll checks the field values on TaskTriggersSummary_TriggerDetails with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskTriggersSummary_TriggerDetailsMultiError, or nil if none found.

type TaskTriggersSummary_TriggerDetailsMultiError

type TaskTriggersSummary_TriggerDetailsMultiError []error

TaskTriggersSummary_TriggerDetailsMultiError is an error wrapping multiple validation errors returned by TaskTriggersSummary_TriggerDetails.ValidateAll() if the designated constraints aren't met.

func (TaskTriggersSummary_TriggerDetailsMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (TaskTriggersSummary_TriggerDetailsMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TaskTriggersSummary_TriggerDetailsValidationError

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

TaskTriggersSummary_TriggerDetailsValidationError is the validation error returned by TaskTriggersSummary_TriggerDetails.Validate if the designated constraints aren't met.

func (TaskTriggersSummary_TriggerDetailsValidationError) Cause

Cause function returns cause value.

func (TaskTriggersSummary_TriggerDetailsValidationError) Error

Error satisfies the builtin error interface

func (TaskTriggersSummary_TriggerDetailsValidationError) ErrorName

ErrorName returns error name.

func (TaskTriggersSummary_TriggerDetailsValidationError) Field

Field function returns field value.

func (TaskTriggersSummary_TriggerDetailsValidationError) Key

Key function returns key value.

func (TaskTriggersSummary_TriggerDetailsValidationError) Reason

Reason function returns reason value.

type TaskTriggersSummary_TriggerStats

type TaskTriggersSummary_TriggerStats struct {
	Total  uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Active uint32 `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskTriggersSummary_TriggerStats) Descriptor deprecated

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

Deprecated: Use TaskTriggersSummary_TriggerStats.ProtoReflect.Descriptor instead.

func (*TaskTriggersSummary_TriggerStats) GetActive

func (*TaskTriggersSummary_TriggerStats) GetTotal

func (*TaskTriggersSummary_TriggerStats) ProtoMessage

func (*TaskTriggersSummary_TriggerStats) ProtoMessage()

func (*TaskTriggersSummary_TriggerStats) ProtoReflect

func (*TaskTriggersSummary_TriggerStats) Reset

func (*TaskTriggersSummary_TriggerStats) String

func (*TaskTriggersSummary_TriggerStats) Validate

Validate checks the field values on TaskTriggersSummary_TriggerStats with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskTriggersSummary_TriggerStats) ValidateAll

func (m *TaskTriggersSummary_TriggerStats) ValidateAll() error

ValidateAll checks the field values on TaskTriggersSummary_TriggerStats with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskTriggersSummary_TriggerStatsMultiError, or nil if none found.

type TaskTriggersSummary_TriggerStatsMultiError

type TaskTriggersSummary_TriggerStatsMultiError []error

TaskTriggersSummary_TriggerStatsMultiError is an error wrapping multiple validation errors returned by TaskTriggersSummary_TriggerStats.ValidateAll() if the designated constraints aren't met.

func (TaskTriggersSummary_TriggerStatsMultiError) AllErrors

AllErrors returns a list of validation violation errors.

func (TaskTriggersSummary_TriggerStatsMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TaskTriggersSummary_TriggerStatsValidationError

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

TaskTriggersSummary_TriggerStatsValidationError is the validation error returned by TaskTriggersSummary_TriggerStats.Validate if the designated constraints aren't met.

func (TaskTriggersSummary_TriggerStatsValidationError) Cause

Cause function returns cause value.

func (TaskTriggersSummary_TriggerStatsValidationError) Error

Error satisfies the builtin error interface

func (TaskTriggersSummary_TriggerStatsValidationError) ErrorName

ErrorName returns error name.

func (TaskTriggersSummary_TriggerStatsValidationError) Field

Field function returns field value.

func (TaskTriggersSummary_TriggerStatsValidationError) Key

Key function returns key value.

func (TaskTriggersSummary_TriggerStatsValidationError) Reason

Reason function returns reason value.

type TaskValidationError

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

TaskValidationError is the validation error returned by Task.Validate if the designated constraints aren't met.

func (TaskValidationError) Cause

func (e TaskValidationError) Cause() error

Cause function returns cause value.

func (TaskValidationError) Error

func (e TaskValidationError) Error() string

Error satisfies the builtin error interface

func (TaskValidationError) ErrorName

func (e TaskValidationError) ErrorName() string

ErrorName returns error name.

func (TaskValidationError) Field

func (e TaskValidationError) Field() string

Field function returns field value.

func (TaskValidationError) Key

func (e TaskValidationError) Key() bool

Key function returns key value.

func (TaskValidationError) Reason

func (e TaskValidationError) Reason() string

Reason function returns reason value.

type TraceSpec

type TraceSpec struct {

	// A strongly typed interface for the trace.
	Interface *core.TypedInterface `protobuf:"bytes,1,opt,name=interface,proto3" json:"interface,omitempty"`
	// contains filtered or unexported fields
}

Specification for a trace action.

func (*TraceSpec) Descriptor deprecated

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

Deprecated: Use TraceSpec.ProtoReflect.Descriptor instead.

func (*TraceSpec) GetInterface

func (x *TraceSpec) GetInterface() *core.TypedInterface

func (*TraceSpec) ProtoMessage

func (*TraceSpec) ProtoMessage()

func (*TraceSpec) ProtoReflect

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

func (*TraceSpec) Reset

func (x *TraceSpec) Reset()

func (*TraceSpec) String

func (x *TraceSpec) String() string

func (*TraceSpec) Validate

func (m *TraceSpec) Validate() error

Validate checks the field values on TraceSpec with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TraceSpec) ValidateAll

func (m *TraceSpec) ValidateAll() error

ValidateAll checks the field values on TraceSpec with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TraceSpecMultiError, or nil if none found.

type TraceSpecMultiError

type TraceSpecMultiError []error

TraceSpecMultiError is an error wrapping multiple validation errors returned by TraceSpec.ValidateAll() if the designated constraints aren't met.

func (TraceSpecMultiError) AllErrors

func (m TraceSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TraceSpecMultiError) Error

func (m TraceSpecMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TraceSpecValidationError

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

TraceSpecValidationError is the validation error returned by TraceSpec.Validate if the designated constraints aren't met.

func (TraceSpecValidationError) Cause

func (e TraceSpecValidationError) Cause() error

Cause function returns cause value.

func (TraceSpecValidationError) Error

func (e TraceSpecValidationError) Error() string

Error satisfies the builtin error interface

func (TraceSpecValidationError) ErrorName

func (e TraceSpecValidationError) ErrorName() string

ErrorName returns error name.

func (TraceSpecValidationError) Field

func (e TraceSpecValidationError) Field() string

Field function returns field value.

func (TraceSpecValidationError) Key

Key function returns key value.

func (TraceSpecValidationError) Reason

func (e TraceSpecValidationError) Reason() string

Reason function returns reason value.

type TriggerAutomationSpec

type TriggerAutomationSpec struct {

	// Explicitly defines trigger automation type.
	Type TriggerAutomationSpecType `protobuf:"varint,1,opt,name=type,proto3,enum=flyteidl2.task.TriggerAutomationSpecType" json:"type,omitempty"`
	// Types that are assignable to Automation:
	//
	//	*TriggerAutomationSpec_Schedule
	Automation isTriggerAutomationSpec_Automation `protobuf_oneof:"automation"`
	// contains filtered or unexported fields
}

func (*TriggerAutomationSpec) Descriptor deprecated

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

Deprecated: Use TriggerAutomationSpec.ProtoReflect.Descriptor instead.

func (*TriggerAutomationSpec) GetAutomation

func (m *TriggerAutomationSpec) GetAutomation() isTriggerAutomationSpec_Automation

func (*TriggerAutomationSpec) GetSchedule

func (x *TriggerAutomationSpec) GetSchedule() *Schedule

func (*TriggerAutomationSpec) GetType

func (*TriggerAutomationSpec) ProtoMessage

func (*TriggerAutomationSpec) ProtoMessage()

func (*TriggerAutomationSpec) ProtoReflect

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

func (*TriggerAutomationSpec) Reset

func (x *TriggerAutomationSpec) Reset()

func (*TriggerAutomationSpec) String

func (x *TriggerAutomationSpec) String() string

func (*TriggerAutomationSpec) Validate

func (m *TriggerAutomationSpec) Validate() error

Validate checks the field values on TriggerAutomationSpec with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TriggerAutomationSpec) ValidateAll

func (m *TriggerAutomationSpec) ValidateAll() error

ValidateAll checks the field values on TriggerAutomationSpec with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TriggerAutomationSpecMultiError, or nil if none found.

type TriggerAutomationSpecMultiError

type TriggerAutomationSpecMultiError []error

TriggerAutomationSpecMultiError is an error wrapping multiple validation errors returned by TriggerAutomationSpec.ValidateAll() if the designated constraints aren't met.

func (TriggerAutomationSpecMultiError) AllErrors

func (m TriggerAutomationSpecMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TriggerAutomationSpecMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type TriggerAutomationSpecType

type TriggerAutomationSpecType int32
const (
	TriggerAutomationSpecType_TYPE_UNSPECIFIED TriggerAutomationSpecType = 0
	TriggerAutomationSpecType_TYPE_NONE        TriggerAutomationSpecType = 1
	TriggerAutomationSpecType_TYPE_SCHEDULE    TriggerAutomationSpecType = 2
)

func (TriggerAutomationSpecType) Descriptor

func (TriggerAutomationSpecType) Enum

func (TriggerAutomationSpecType) EnumDescriptor deprecated

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

Deprecated: Use TriggerAutomationSpecType.Descriptor instead.

func (TriggerAutomationSpecType) Number

func (TriggerAutomationSpecType) String

func (x TriggerAutomationSpecType) String() string

func (TriggerAutomationSpecType) Type

type TriggerAutomationSpecValidationError

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

TriggerAutomationSpecValidationError is the validation error returned by TriggerAutomationSpec.Validate if the designated constraints aren't met.

func (TriggerAutomationSpecValidationError) Cause

Cause function returns cause value.

func (TriggerAutomationSpecValidationError) Error

Error satisfies the builtin error interface

func (TriggerAutomationSpecValidationError) ErrorName

ErrorName returns error name.

func (TriggerAutomationSpecValidationError) Field

Field function returns field value.

func (TriggerAutomationSpecValidationError) Key

Key function returns key value.

func (TriggerAutomationSpecValidationError) Reason

Reason function returns reason value.

type TriggerAutomationSpec_Schedule

type TriggerAutomationSpec_Schedule struct {
	Schedule *Schedule `protobuf:"bytes,2,opt,name=schedule,proto3,oneof"`
}

type UnimplementedTaskServiceServer

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) DeployTask

func (UnimplementedTaskServiceServer) GetTaskDetails

func (UnimplementedTaskServiceServer) ListTasks

func (UnimplementedTaskServiceServer) ListVersions

type UnsafeTaskServiceServer

type UnsafeTaskServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeTaskServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TaskServiceServer will result in compilation errors.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL