Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)
- type Annotations
- func (*Annotations) Descriptor() ([]byte, []int)deprecated
- func (x *Annotations) GetValues() map[string]string
- func (*Annotations) ProtoMessage()
- func (x *Annotations) ProtoReflect() protoreflect.Message
- func (x *Annotations) Reset()
- func (x *Annotations) String() string
- func (m *Annotations) Validate() error
- func (m *Annotations) ValidateAll() error
- type AnnotationsMultiError
- type AnnotationsValidationError
- func (e AnnotationsValidationError) Cause() error
- func (e AnnotationsValidationError) Error() string
- func (e AnnotationsValidationError) ErrorName() string
- func (e AnnotationsValidationError) Field() string
- func (e AnnotationsValidationError) Key() bool
- func (e AnnotationsValidationError) Reason() string
- type CacheConfig
- func (*CacheConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CacheConfig) GetCacheLookupScope() CacheLookupScope
- func (x *CacheConfig) GetOverwriteCache() bool
- func (*CacheConfig) ProtoMessage()
- func (x *CacheConfig) ProtoReflect() protoreflect.Message
- func (x *CacheConfig) Reset()
- func (x *CacheConfig) String() string
- func (m *CacheConfig) Validate() error
- func (m *CacheConfig) ValidateAll() error
- type CacheConfigMultiError
- type CacheConfigValidationError
- func (e CacheConfigValidationError) Cause() error
- func (e CacheConfigValidationError) Error() string
- func (e CacheConfigValidationError) ErrorName() string
- func (e CacheConfigValidationError) Field() string
- func (e CacheConfigValidationError) Key() bool
- func (e CacheConfigValidationError) Reason() string
- type CacheLookupScope
- func (CacheLookupScope) Descriptor() protoreflect.EnumDescriptor
- func (x CacheLookupScope) Enum() *CacheLookupScope
- func (CacheLookupScope) EnumDescriptor() ([]byte, []int)deprecated
- func (x CacheLookupScope) Number() protoreflect.EnumNumber
- func (x CacheLookupScope) String() string
- func (CacheLookupScope) Type() protoreflect.EnumType
- type Cron
- func (*Cron) Descriptor() ([]byte, []int)deprecated
- func (x *Cron) GetExpression() string
- func (x *Cron) GetTimezone() string
- func (*Cron) ProtoMessage()
- func (x *Cron) ProtoReflect() protoreflect.Message
- func (x *Cron) Reset()
- func (x *Cron) String() string
- func (m *Cron) Validate() error
- func (m *Cron) ValidateAll() error
- type CronMultiError
- type CronValidationError
- type DeployTaskRequest
- func (*DeployTaskRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeployTaskRequest) GetSpec() *TaskSpec
- func (x *DeployTaskRequest) GetTaskId() *TaskIdentifier
- func (x *DeployTaskRequest) GetTriggers() []*TaskTrigger
- func (*DeployTaskRequest) ProtoMessage()
- func (x *DeployTaskRequest) ProtoReflect() protoreflect.Message
- func (x *DeployTaskRequest) Reset()
- func (x *DeployTaskRequest) String() string
- func (m *DeployTaskRequest) Validate() error
- func (m *DeployTaskRequest) ValidateAll() error
- type DeployTaskRequestMultiError
- type DeployTaskRequestValidationError
- func (e DeployTaskRequestValidationError) Cause() error
- func (e DeployTaskRequestValidationError) Error() string
- func (e DeployTaskRequestValidationError) ErrorName() string
- func (e DeployTaskRequestValidationError) Field() string
- func (e DeployTaskRequestValidationError) Key() bool
- func (e DeployTaskRequestValidationError) Reason() string
- type DeployTaskResponse
- func (*DeployTaskResponse) Descriptor() ([]byte, []int)deprecated
- func (*DeployTaskResponse) ProtoMessage()
- func (x *DeployTaskResponse) ProtoReflect() protoreflect.Message
- func (x *DeployTaskResponse) Reset()
- func (x *DeployTaskResponse) String() string
- func (m *DeployTaskResponse) Validate() error
- func (m *DeployTaskResponse) ValidateAll() error
- type DeployTaskResponseMultiError
- type DeployTaskResponseValidationError
- func (e DeployTaskResponseValidationError) Cause() error
- func (e DeployTaskResponseValidationError) Error() string
- func (e DeployTaskResponseValidationError) ErrorName() string
- func (e DeployTaskResponseValidationError) Field() string
- func (e DeployTaskResponseValidationError) Key() bool
- func (e DeployTaskResponseValidationError) Reason() string
- type DocumentationEntity
- func (*DocumentationEntity) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentationEntity) GetLongDescription() string
- func (x *DocumentationEntity) GetShortDescription() string
- func (x *DocumentationEntity) GetSourceCode() *SourceCode
- func (*DocumentationEntity) ProtoMessage()
- func (x *DocumentationEntity) ProtoReflect() protoreflect.Message
- func (x *DocumentationEntity) Reset()
- func (x *DocumentationEntity) String() string
- func (m *DocumentationEntity) Validate() error
- func (m *DocumentationEntity) ValidateAll() error
- type DocumentationEntityMultiError
- type DocumentationEntityValidationError
- func (e DocumentationEntityValidationError) Cause() error
- func (e DocumentationEntityValidationError) Error() string
- func (e DocumentationEntityValidationError) ErrorName() string
- func (e DocumentationEntityValidationError) Field() string
- func (e DocumentationEntityValidationError) Key() bool
- func (e DocumentationEntityValidationError) Reason() string
- type Environment
- func (*Environment) Descriptor() ([]byte, []int)deprecated
- func (x *Environment) GetDescription() string
- func (x *Environment) GetName() string
- func (*Environment) ProtoMessage()
- func (x *Environment) ProtoReflect() protoreflect.Message
- func (x *Environment) Reset()
- func (x *Environment) String() string
- func (m *Environment) Validate() error
- func (m *Environment) ValidateAll() error
- type EnvironmentMultiError
- type EnvironmentValidationError
- func (e EnvironmentValidationError) Cause() error
- func (e EnvironmentValidationError) Error() string
- func (e EnvironmentValidationError) ErrorName() string
- func (e EnvironmentValidationError) Field() string
- func (e EnvironmentValidationError) Key() bool
- func (e EnvironmentValidationError) Reason() string
- type Envs
- type EnvsMultiError
- type EnvsValidationError
- type FixedRate
- func (*FixedRate) Descriptor() ([]byte, []int)deprecated
- func (x *FixedRate) GetStartTime() *timestamppb.Timestamp
- func (x *FixedRate) GetUnit() FixedRateUnit
- func (x *FixedRate) GetValue() uint32
- func (*FixedRate) ProtoMessage()
- func (x *FixedRate) ProtoReflect() protoreflect.Message
- func (x *FixedRate) Reset()
- func (x *FixedRate) String() string
- func (m *FixedRate) Validate() error
- func (m *FixedRate) ValidateAll() error
- type FixedRateMultiError
- type FixedRateUnit
- func (FixedRateUnit) Descriptor() protoreflect.EnumDescriptor
- func (x FixedRateUnit) Enum() *FixedRateUnit
- func (FixedRateUnit) EnumDescriptor() ([]byte, []int)deprecated
- func (x FixedRateUnit) Number() protoreflect.EnumNumber
- func (x FixedRateUnit) String() string
- func (FixedRateUnit) Type() protoreflect.EnumType
- type FixedRateValidationError
- type GetTaskDetailsRequest
- func (*GetTaskDetailsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskDetailsRequest) GetTaskId() *TaskIdentifier
- func (*GetTaskDetailsRequest) ProtoMessage()
- func (x *GetTaskDetailsRequest) ProtoReflect() protoreflect.Message
- func (x *GetTaskDetailsRequest) Reset()
- func (x *GetTaskDetailsRequest) String() string
- func (m *GetTaskDetailsRequest) Validate() error
- func (m *GetTaskDetailsRequest) ValidateAll() error
- type GetTaskDetailsRequestMultiError
- type GetTaskDetailsRequestValidationError
- func (e GetTaskDetailsRequestValidationError) Cause() error
- func (e GetTaskDetailsRequestValidationError) Error() string
- func (e GetTaskDetailsRequestValidationError) ErrorName() string
- func (e GetTaskDetailsRequestValidationError) Field() string
- func (e GetTaskDetailsRequestValidationError) Key() bool
- func (e GetTaskDetailsRequestValidationError) Reason() string
- type GetTaskDetailsResponse
- func (*GetTaskDetailsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTaskDetailsResponse) GetDetails() *TaskDetails
- func (*GetTaskDetailsResponse) ProtoMessage()
- func (x *GetTaskDetailsResponse) ProtoReflect() protoreflect.Message
- func (x *GetTaskDetailsResponse) Reset()
- func (x *GetTaskDetailsResponse) String() string
- func (m *GetTaskDetailsResponse) Validate() error
- func (m *GetTaskDetailsResponse) ValidateAll() error
- type GetTaskDetailsResponseMultiError
- type GetTaskDetailsResponseValidationError
- func (e GetTaskDetailsResponseValidationError) Cause() error
- func (e GetTaskDetailsResponseValidationError) Error() string
- func (e GetTaskDetailsResponseValidationError) ErrorName() string
- func (e GetTaskDetailsResponseValidationError) Field() string
- func (e GetTaskDetailsResponseValidationError) Key() bool
- func (e GetTaskDetailsResponseValidationError) Reason() string
- type InlineRule
- func (*InlineRule) Descriptor() ([]byte, []int)deprecated
- func (m *InlineRule) GetDelivery() isInlineRule_Delivery
- func (x *InlineRule) GetDeliveryConfigName() string
- func (x *InlineRule) GetDeliveryTemplate() *notification.DeliveryConfigTemplate
- func (x *InlineRule) GetOnPhases() []common.ActionPhase
- func (*InlineRule) ProtoMessage()
- func (x *InlineRule) ProtoReflect() protoreflect.Message
- func (x *InlineRule) Reset()
- func (x *InlineRule) String() string
- func (m *InlineRule) Validate() error
- func (m *InlineRule) ValidateAll() error
- type InlineRuleList
- func (*InlineRuleList) Descriptor() ([]byte, []int)deprecated
- func (x *InlineRuleList) GetRules() []*InlineRule
- func (*InlineRuleList) ProtoMessage()
- func (x *InlineRuleList) ProtoReflect() protoreflect.Message
- func (x *InlineRuleList) Reset()
- func (x *InlineRuleList) String() string
- func (m *InlineRuleList) Validate() error
- func (m *InlineRuleList) ValidateAll() error
- type InlineRuleListMultiError
- type InlineRuleListValidationError
- func (e InlineRuleListValidationError) Cause() error
- func (e InlineRuleListValidationError) Error() string
- func (e InlineRuleListValidationError) ErrorName() string
- func (e InlineRuleListValidationError) Field() string
- func (e InlineRuleListValidationError) Key() bool
- func (e InlineRuleListValidationError) Reason() string
- type InlineRuleMultiError
- type InlineRuleValidationError
- type InlineRule_DeliveryConfigName
- type InlineRule_DeliveryTemplate
- type Inputs
- func (*Inputs) Descriptor() ([]byte, []int)deprecated
- func (x *Inputs) GetContext() []*core.KeyValuePair
- func (x *Inputs) GetLiterals() []*NamedLiteral
- func (*Inputs) ProtoMessage()
- func (x *Inputs) ProtoReflect() protoreflect.Message
- func (x *Inputs) Reset()
- func (x *Inputs) String() string
- func (m *Inputs) Validate() error
- func (m *Inputs) ValidateAll() error
- type InputsMultiError
- type InputsValidationError
- type Labels
- func (*Labels) Descriptor() ([]byte, []int)deprecated
- func (x *Labels) GetValues() map[string]string
- func (*Labels) ProtoMessage()
- func (x *Labels) ProtoReflect() protoreflect.Message
- func (x *Labels) Reset()
- func (x *Labels) String() string
- func (m *Labels) Validate() error
- func (m *Labels) ValidateAll() error
- type LabelsMultiError
- type LabelsValidationError
- type LatestRunSummary
- func (*LatestRunSummary) Descriptor() ([]byte, []int)deprecated
- func (x *LatestRunSummary) GetPhase() common.ActionPhase
- func (x *LatestRunSummary) GetRootTaskName() string
- func (x *LatestRunSummary) GetRunId() *common.RunIdentifier
- func (x *LatestRunSummary) GetRunTime() *timestamppb.Timestamp
- func (*LatestRunSummary) ProtoMessage()
- func (x *LatestRunSummary) ProtoReflect() protoreflect.Message
- func (x *LatestRunSummary) Reset()
- func (x *LatestRunSummary) String() string
- func (m *LatestRunSummary) Validate() error
- func (m *LatestRunSummary) ValidateAll() error
- type LatestRunSummaryMultiError
- type LatestRunSummaryValidationError
- func (e LatestRunSummaryValidationError) Cause() error
- func (e LatestRunSummaryValidationError) Error() string
- func (e LatestRunSummaryValidationError) ErrorName() string
- func (e LatestRunSummaryValidationError) Field() string
- func (e LatestRunSummaryValidationError) Key() bool
- func (e LatestRunSummaryValidationError) Reason() string
- type ListTasksRequest
- func (*ListTasksRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListTasksRequest) GetKnownFilters() []*ListTasksRequest_KnownFilter
- func (x *ListTasksRequest) GetOrg() string
- func (x *ListTasksRequest) GetProjectId() *common.ProjectIdentifier
- func (x *ListTasksRequest) GetRequest() *common.ListRequest
- func (m *ListTasksRequest) GetScopeBy() isListTasksRequest_ScopeBy
- func (*ListTasksRequest) ProtoMessage()
- func (x *ListTasksRequest) ProtoReflect() protoreflect.Message
- func (x *ListTasksRequest) Reset()
- func (x *ListTasksRequest) String() string
- func (m *ListTasksRequest) Validate() error
- func (m *ListTasksRequest) ValidateAll() error
- type ListTasksRequestMultiError
- type ListTasksRequestValidationError
- func (e ListTasksRequestValidationError) Cause() error
- func (e ListTasksRequestValidationError) Error() string
- func (e ListTasksRequestValidationError) ErrorName() string
- func (e ListTasksRequestValidationError) Field() string
- func (e ListTasksRequestValidationError) Key() bool
- func (e ListTasksRequestValidationError) Reason() string
- type ListTasksRequest_KnownFilter
- func (*ListTasksRequest_KnownFilter) Descriptor() ([]byte, []int)deprecated
- func (x *ListTasksRequest_KnownFilter) GetDeployedBy() string
- func (m *ListTasksRequest_KnownFilter) GetFilterBy() isListTasksRequest_KnownFilter_FilterBy
- func (x *ListTasksRequest_KnownFilter) GetIsEntrypoint() bool
- func (*ListTasksRequest_KnownFilter) ProtoMessage()
- func (x *ListTasksRequest_KnownFilter) ProtoReflect() protoreflect.Message
- func (x *ListTasksRequest_KnownFilter) Reset()
- func (x *ListTasksRequest_KnownFilter) String() string
- func (m *ListTasksRequest_KnownFilter) Validate() error
- func (m *ListTasksRequest_KnownFilter) ValidateAll() error
- type ListTasksRequest_KnownFilterMultiError
- type ListTasksRequest_KnownFilterValidationError
- func (e ListTasksRequest_KnownFilterValidationError) Cause() error
- func (e ListTasksRequest_KnownFilterValidationError) Error() string
- func (e ListTasksRequest_KnownFilterValidationError) ErrorName() string
- func (e ListTasksRequest_KnownFilterValidationError) Field() string
- func (e ListTasksRequest_KnownFilterValidationError) Key() bool
- func (e ListTasksRequest_KnownFilterValidationError) Reason() string
- type ListTasksRequest_KnownFilter_DeployedBy
- type ListTasksRequest_KnownFilter_IsEntrypoint
- type ListTasksRequest_Org
- type ListTasksRequest_ProjectId
- type ListTasksResponse
- func (*ListTasksResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListTasksResponse) GetMetadata() *ListTasksResponse_ListTasksMetadata
- func (x *ListTasksResponse) GetTasks() []*Task
- func (x *ListTasksResponse) GetToken() string
- func (*ListTasksResponse) ProtoMessage()
- func (x *ListTasksResponse) ProtoReflect() protoreflect.Message
- func (x *ListTasksResponse) Reset()
- func (x *ListTasksResponse) String() string
- func (m *ListTasksResponse) Validate() error
- func (m *ListTasksResponse) ValidateAll() error
- type ListTasksResponseMultiError
- type ListTasksResponseValidationError
- func (e ListTasksResponseValidationError) Cause() error
- func (e ListTasksResponseValidationError) Error() string
- func (e ListTasksResponseValidationError) ErrorName() string
- func (e ListTasksResponseValidationError) Field() string
- func (e ListTasksResponseValidationError) Key() bool
- func (e ListTasksResponseValidationError) Reason() string
- type ListTasksResponse_ListTasksMetadata
- func (*ListTasksResponse_ListTasksMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ListTasksResponse_ListTasksMetadata) GetFilteredTotal() uint32
- func (x *ListTasksResponse_ListTasksMetadata) GetTotal() uint32
- func (*ListTasksResponse_ListTasksMetadata) ProtoMessage()
- func (x *ListTasksResponse_ListTasksMetadata) ProtoReflect() protoreflect.Message
- func (x *ListTasksResponse_ListTasksMetadata) Reset()
- func (x *ListTasksResponse_ListTasksMetadata) String() string
- func (m *ListTasksResponse_ListTasksMetadata) Validate() error
- func (m *ListTasksResponse_ListTasksMetadata) ValidateAll() error
- type ListTasksResponse_ListTasksMetadataMultiError
- type ListTasksResponse_ListTasksMetadataValidationError
- func (e ListTasksResponse_ListTasksMetadataValidationError) Cause() error
- func (e ListTasksResponse_ListTasksMetadataValidationError) Error() string
- func (e ListTasksResponse_ListTasksMetadataValidationError) ErrorName() string
- func (e ListTasksResponse_ListTasksMetadataValidationError) Field() string
- func (e ListTasksResponse_ListTasksMetadataValidationError) Key() bool
- func (e ListTasksResponse_ListTasksMetadataValidationError) Reason() string
- type ListVersionsRequest
- func (*ListVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListVersionsRequest) GetRequest() *common.ListRequest
- func (x *ListVersionsRequest) GetTaskName() *TaskName
- func (*ListVersionsRequest) ProtoMessage()
- func (x *ListVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListVersionsRequest) Reset()
- func (x *ListVersionsRequest) String() string
- func (m *ListVersionsRequest) Validate() error
- func (m *ListVersionsRequest) ValidateAll() error
- type ListVersionsRequestMultiError
- type ListVersionsRequestValidationError
- func (e ListVersionsRequestValidationError) Cause() error
- func (e ListVersionsRequestValidationError) Error() string
- func (e ListVersionsRequestValidationError) ErrorName() string
- func (e ListVersionsRequestValidationError) Field() string
- func (e ListVersionsRequestValidationError) Key() bool
- func (e ListVersionsRequestValidationError) Reason() string
- type ListVersionsResponse
- func (*ListVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVersionsResponse) GetToken() string
- func (x *ListVersionsResponse) GetVersions() []*ListVersionsResponse_VersionResponse
- func (*ListVersionsResponse) ProtoMessage()
- func (x *ListVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListVersionsResponse) Reset()
- func (x *ListVersionsResponse) String() string
- func (m *ListVersionsResponse) Validate() error
- func (m *ListVersionsResponse) ValidateAll() error
- type ListVersionsResponseMultiError
- type ListVersionsResponseValidationError
- func (e ListVersionsResponseValidationError) Cause() error
- func (e ListVersionsResponseValidationError) Error() string
- func (e ListVersionsResponseValidationError) ErrorName() string
- func (e ListVersionsResponseValidationError) Field() string
- func (e ListVersionsResponseValidationError) Key() bool
- func (e ListVersionsResponseValidationError) Reason() string
- type ListVersionsResponse_VersionResponse
- func (*ListVersionsResponse_VersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVersionsResponse_VersionResponse) GetDeployedAt() *timestamppb.Timestamp
- func (x *ListVersionsResponse_VersionResponse) GetDeployedBy() *common.EnrichedIdentity
- func (x *ListVersionsResponse_VersionResponse) GetLatestRun() *LatestRunSummary
- func (x *ListVersionsResponse_VersionResponse) GetVersion() string
- func (*ListVersionsResponse_VersionResponse) ProtoMessage()
- func (x *ListVersionsResponse_VersionResponse) ProtoReflect() protoreflect.Message
- func (x *ListVersionsResponse_VersionResponse) Reset()
- func (x *ListVersionsResponse_VersionResponse) String() string
- func (m *ListVersionsResponse_VersionResponse) Validate() error
- func (m *ListVersionsResponse_VersionResponse) ValidateAll() error
- type ListVersionsResponse_VersionResponseMultiError
- type ListVersionsResponse_VersionResponseValidationError
- func (e ListVersionsResponse_VersionResponseValidationError) Cause() error
- func (e ListVersionsResponse_VersionResponseValidationError) Error() string
- func (e ListVersionsResponse_VersionResponseValidationError) ErrorName() string
- func (e ListVersionsResponse_VersionResponseValidationError) Field() string
- func (e ListVersionsResponse_VersionResponseValidationError) Key() bool
- func (e ListVersionsResponse_VersionResponseValidationError) Reason() string
- type NamedLiteral
- func (*NamedLiteral) Descriptor() ([]byte, []int)deprecated
- func (x *NamedLiteral) GetName() string
- func (x *NamedLiteral) GetValue() *core.Literal
- func (*NamedLiteral) ProtoMessage()
- func (x *NamedLiteral) ProtoReflect() protoreflect.Message
- func (x *NamedLiteral) Reset()
- func (x *NamedLiteral) String() string
- func (m *NamedLiteral) Validate() error
- func (m *NamedLiteral) ValidateAll() error
- type NamedLiteralMultiError
- type NamedLiteralValidationError
- func (e NamedLiteralValidationError) Cause() error
- func (e NamedLiteralValidationError) Error() string
- func (e NamedLiteralValidationError) ErrorName() string
- func (e NamedLiteralValidationError) Field() string
- func (e NamedLiteralValidationError) Key() bool
- func (e NamedLiteralValidationError) Reason() string
- type NamedParameter
- func (*NamedParameter) Descriptor() ([]byte, []int)deprecated
- func (x *NamedParameter) GetName() string
- func (x *NamedParameter) GetParameter() *core.Parameter
- func (*NamedParameter) ProtoMessage()
- func (x *NamedParameter) ProtoReflect() protoreflect.Message
- func (x *NamedParameter) Reset()
- func (x *NamedParameter) String() string
- func (m *NamedParameter) Validate() error
- func (m *NamedParameter) ValidateAll() error
- type NamedParameterMultiError
- type NamedParameterValidationError
- func (e NamedParameterValidationError) Cause() error
- func (e NamedParameterValidationError) Error() string
- func (e NamedParameterValidationError) ErrorName() string
- func (e NamedParameterValidationError) Field() string
- func (e NamedParameterValidationError) Key() bool
- func (e NamedParameterValidationError) Reason() string
- type OutputReferences
- func (*OutputReferences) Descriptor() ([]byte, []int)deprecated
- func (x *OutputReferences) GetOutputUri() string
- func (x *OutputReferences) GetReportUri() string
- func (*OutputReferences) ProtoMessage()
- func (x *OutputReferences) ProtoReflect() protoreflect.Message
- func (x *OutputReferences) Reset()
- func (x *OutputReferences) String() string
- func (m *OutputReferences) Validate() error
- func (m *OutputReferences) ValidateAll() error
- type OutputReferencesMultiError
- type OutputReferencesValidationError
- func (e OutputReferencesValidationError) Cause() error
- func (e OutputReferencesValidationError) Error() string
- func (e OutputReferencesValidationError) ErrorName() string
- func (e OutputReferencesValidationError) Field() string
- func (e OutputReferencesValidationError) Key() bool
- func (e OutputReferencesValidationError) Reason() string
- type Outputs
- func (*Outputs) Descriptor() ([]byte, []int)deprecated
- func (x *Outputs) GetLiterals() []*NamedLiteral
- func (*Outputs) ProtoMessage()
- func (x *Outputs) ProtoReflect() protoreflect.Message
- func (x *Outputs) Reset()
- func (x *Outputs) String() string
- func (m *Outputs) Validate() error
- func (m *Outputs) ValidateAll() error
- type OutputsMultiError
- type OutputsValidationError
- type RawDataStorage
- func (*RawDataStorage) Descriptor() ([]byte, []int)deprecated
- func (x *RawDataStorage) GetRawDataPrefix() string
- func (*RawDataStorage) ProtoMessage()
- func (x *RawDataStorage) ProtoReflect() protoreflect.Message
- func (x *RawDataStorage) Reset()
- func (x *RawDataStorage) String() string
- func (m *RawDataStorage) Validate() error
- func (m *RawDataStorage) ValidateAll() error
- type RawDataStorageMultiError
- type RawDataStorageValidationError
- func (e RawDataStorageValidationError) Cause() error
- func (e RawDataStorageValidationError) Error() string
- func (e RawDataStorageValidationError) ErrorName() string
- func (e RawDataStorageValidationError) Field() string
- func (e RawDataStorageValidationError) Key() bool
- func (e RawDataStorageValidationError) Reason() string
- type RunSpec
- func (*RunSpec) Descriptor() ([]byte, []int)deprecated
- func (x *RunSpec) GetAnnotations() *Annotations
- func (x *RunSpec) GetCacheConfig() *CacheConfig
- func (x *RunSpec) GetCluster() string
- func (x *RunSpec) GetEnvs() *Envs
- func (x *RunSpec) GetInterruptible() *wrapperspb.BoolValue
- func (x *RunSpec) GetLabels() *Labels
- func (x *RunSpec) GetNotificationRuleName() string
- func (x *RunSpec) GetNotificationRules() *InlineRuleList
- func (m *RunSpec) GetNotificationSettings() isRunSpec_NotificationSettings
- func (x *RunSpec) GetOverwriteCache() booldeprecated
- func (x *RunSpec) GetRawDataStorage() *RawDataStorage
- func (x *RunSpec) GetRunStartTime() *timestamppb.Timestamp
- func (x *RunSpec) GetSecurityContext() *core.SecurityContext
- func (*RunSpec) ProtoMessage()
- func (x *RunSpec) ProtoReflect() protoreflect.Message
- func (x *RunSpec) Reset()
- func (x *RunSpec) String() string
- func (m *RunSpec) Validate() error
- func (m *RunSpec) ValidateAll() error
- type RunSpecMultiError
- type RunSpecValidationError
- type RunSpec_NotificationRuleName
- type RunSpec_NotificationRules
- type Schedule
- func (*Schedule) Descriptor() ([]byte, []int)deprecated
- func (x *Schedule) GetCron() *Cron
- func (x *Schedule) GetCronExpression() stringdeprecated
- func (m *Schedule) GetExpression() isSchedule_Expression
- func (x *Schedule) GetKickoffTimeInputArg() string
- func (x *Schedule) GetRate() *FixedRate
- func (*Schedule) ProtoMessage()
- func (x *Schedule) ProtoReflect() protoreflect.Message
- func (x *Schedule) Reset()
- func (x *Schedule) String() string
- func (m *Schedule) Validate() error
- func (m *Schedule) ValidateAll() error
- type ScheduleMultiError
- type ScheduleValidationError
- type Schedule_Cron
- type Schedule_CronExpression
- type Schedule_Rate
- type SourceCode
- func (*SourceCode) Descriptor() ([]byte, []int)deprecated
- func (x *SourceCode) GetLink() string
- func (*SourceCode) ProtoMessage()
- func (x *SourceCode) ProtoReflect() protoreflect.Message
- func (x *SourceCode) Reset()
- func (x *SourceCode) String() string
- func (m *SourceCode) Validate() error
- func (m *SourceCode) ValidateAll() error
- type SourceCodeMultiError
- type SourceCodeValidationError
- type Task
- func (*Task) Descriptor() ([]byte, []int)deprecated
- func (x *Task) GetMetadata() *TaskMetadata
- func (x *Task) GetTaskId() *TaskIdentifier
- func (x *Task) GetTaskSummary() *TaskSummary
- func (*Task) ProtoMessage()
- func (x *Task) ProtoReflect() protoreflect.Message
- func (x *Task) Reset()
- func (x *Task) String() string
- func (m *Task) Validate() error
- func (m *Task) ValidateAll() error
- type TaskDetails
- func (*TaskDetails) Descriptor() ([]byte, []int)deprecated
- func (x *TaskDetails) GetMetadata() *TaskMetadata
- func (x *TaskDetails) GetSpec() *TaskSpec
- func (x *TaskDetails) GetTaskId() *TaskIdentifier
- func (*TaskDetails) ProtoMessage()
- func (x *TaskDetails) ProtoReflect() protoreflect.Message
- func (x *TaskDetails) Reset()
- func (x *TaskDetails) String() string
- func (m *TaskDetails) Validate() error
- func (m *TaskDetails) ValidateAll() error
- type TaskDetailsMultiError
- type TaskDetailsValidationError
- func (e TaskDetailsValidationError) Cause() error
- func (e TaskDetailsValidationError) Error() string
- func (e TaskDetailsValidationError) ErrorName() string
- func (e TaskDetailsValidationError) Field() string
- func (e TaskDetailsValidationError) Key() bool
- func (e TaskDetailsValidationError) Reason() string
- type TaskIdentifier
- func (*TaskIdentifier) Descriptor() ([]byte, []int)deprecated
- func (x *TaskIdentifier) GetDomain() string
- func (x *TaskIdentifier) GetName() string
- func (x *TaskIdentifier) GetOrg() string
- func (x *TaskIdentifier) GetProject() string
- func (x *TaskIdentifier) GetVersion() string
- func (*TaskIdentifier) ProtoMessage()
- func (x *TaskIdentifier) ProtoReflect() protoreflect.Message
- func (x *TaskIdentifier) Reset()
- func (x *TaskIdentifier) String() string
- func (m *TaskIdentifier) Validate() error
- func (m *TaskIdentifier) ValidateAll() error
- type TaskIdentifierMultiError
- type TaskIdentifierValidationError
- func (e TaskIdentifierValidationError) Cause() error
- func (e TaskIdentifierValidationError) Error() string
- func (e TaskIdentifierValidationError) ErrorName() string
- func (e TaskIdentifierValidationError) Field() string
- func (e TaskIdentifierValidationError) Key() bool
- func (e TaskIdentifierValidationError) Reason() string
- type TaskMetadata
- func (*TaskMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TaskMetadata) GetDeployedAt() *timestamppb.Timestamp
- func (x *TaskMetadata) GetDeployedBy() *common.EnrichedIdentity
- func (x *TaskMetadata) GetEnvironmentName() string
- func (x *TaskMetadata) GetShortDescription() string
- func (x *TaskMetadata) GetShortName() string
- func (x *TaskMetadata) GetTriggersSummary() *TaskTriggersSummary
- func (*TaskMetadata) ProtoMessage()
- func (x *TaskMetadata) ProtoReflect() protoreflect.Message
- func (x *TaskMetadata) Reset()
- func (x *TaskMetadata) String() string
- func (m *TaskMetadata) Validate() error
- func (m *TaskMetadata) ValidateAll() error
- type TaskMetadataMultiError
- type TaskMetadataValidationError
- func (e TaskMetadataValidationError) Cause() error
- func (e TaskMetadataValidationError) Error() string
- func (e TaskMetadataValidationError) ErrorName() string
- func (e TaskMetadataValidationError) Field() string
- func (e TaskMetadataValidationError) Key() bool
- func (e TaskMetadataValidationError) Reason() string
- type TaskMultiError
- type TaskName
- func (*TaskName) Descriptor() ([]byte, []int)deprecated
- func (x *TaskName) GetDomain() string
- func (x *TaskName) GetName() string
- func (x *TaskName) GetOrg() string
- func (x *TaskName) GetProject() string
- func (*TaskName) ProtoMessage()
- func (x *TaskName) ProtoReflect() protoreflect.Message
- func (x *TaskName) Reset()
- func (x *TaskName) String() string
- func (m *TaskName) Validate() error
- func (m *TaskName) ValidateAll() error
- type TaskNameMultiError
- type TaskNameValidationError
- type TaskServiceClient
- type TaskServiceServer
- type TaskSpec
- func (*TaskSpec) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSpec) GetDefaultInputs() []*NamedParameter
- func (x *TaskSpec) GetDocumentation() *DocumentationEntity
- func (x *TaskSpec) GetEnvironment() *Environment
- func (x *TaskSpec) GetShortName() string
- func (x *TaskSpec) GetTaskTemplate() *core.TaskTemplate
- func (*TaskSpec) ProtoMessage()
- func (x *TaskSpec) ProtoReflect() protoreflect.Message
- func (x *TaskSpec) Reset()
- func (x *TaskSpec) String() string
- func (m *TaskSpec) Validate() error
- func (m *TaskSpec) ValidateAll() error
- type TaskSpecMultiError
- type TaskSpecValidationError
- type TaskSummary
- func (*TaskSummary) Descriptor() ([]byte, []int)deprecated
- func (x *TaskSummary) GetLatestRun() *LatestRunSummary
- func (*TaskSummary) ProtoMessage()
- func (x *TaskSummary) ProtoReflect() protoreflect.Message
- func (x *TaskSummary) Reset()
- func (x *TaskSummary) String() string
- func (m *TaskSummary) Validate() error
- func (m *TaskSummary) ValidateAll() error
- type TaskSummaryMultiError
- type TaskSummaryValidationError
- func (e TaskSummaryValidationError) Cause() error
- func (e TaskSummaryValidationError) Error() string
- func (e TaskSummaryValidationError) ErrorName() string
- func (e TaskSummaryValidationError) Field() string
- func (e TaskSummaryValidationError) Key() bool
- func (e TaskSummaryValidationError) Reason() string
- type TaskTrigger
- func (*TaskTrigger) Descriptor() ([]byte, []int)deprecated
- func (x *TaskTrigger) GetAutomationSpec() *TriggerAutomationSpec
- func (x *TaskTrigger) GetName() string
- func (x *TaskTrigger) GetSpec() *TaskTriggerSpec
- func (*TaskTrigger) ProtoMessage()
- func (x *TaskTrigger) ProtoReflect() protoreflect.Message
- func (x *TaskTrigger) Reset()
- func (x *TaskTrigger) String() string
- func (m *TaskTrigger) Validate() error
- func (m *TaskTrigger) ValidateAll() error
- type TaskTriggerMultiError
- type TaskTriggerSpec
- func (*TaskTriggerSpec) Descriptor() ([]byte, []int)deprecated
- func (x *TaskTriggerSpec) GetActive() bool
- func (x *TaskTriggerSpec) GetDescription() string
- func (m *TaskTriggerSpec) GetInputWrapper() isTaskTriggerSpec_InputWrapper
- func (x *TaskTriggerSpec) GetInputs() *Inputs
- func (x *TaskTriggerSpec) GetOffloadedInputData() *common.OffloadedInputData
- func (x *TaskTriggerSpec) GetRunSpec() *RunSpec
- func (*TaskTriggerSpec) ProtoMessage()
- func (x *TaskTriggerSpec) ProtoReflect() protoreflect.Message
- func (x *TaskTriggerSpec) Reset()
- func (x *TaskTriggerSpec) String() string
- func (m *TaskTriggerSpec) Validate() error
- func (m *TaskTriggerSpec) ValidateAll() error
- type TaskTriggerSpecMultiError
- type TaskTriggerSpecValidationError
- func (e TaskTriggerSpecValidationError) Cause() error
- func (e TaskTriggerSpecValidationError) Error() string
- func (e TaskTriggerSpecValidationError) ErrorName() string
- func (e TaskTriggerSpecValidationError) Field() string
- func (e TaskTriggerSpecValidationError) Key() bool
- func (e TaskTriggerSpecValidationError) Reason() string
- type TaskTriggerSpec_Inputs
- type TaskTriggerSpec_OffloadedInputData
- type TaskTriggerValidationError
- func (e TaskTriggerValidationError) Cause() error
- func (e TaskTriggerValidationError) Error() string
- func (e TaskTriggerValidationError) ErrorName() string
- func (e TaskTriggerValidationError) Field() string
- func (e TaskTriggerValidationError) Key() bool
- func (e TaskTriggerValidationError) Reason() string
- type TaskTriggersSummary
- func (*TaskTriggersSummary) Descriptor() ([]byte, []int)deprecated
- func (x *TaskTriggersSummary) GetDetails() *TaskTriggersSummary_TriggerDetails
- func (x *TaskTriggersSummary) GetStats() *TaskTriggersSummary_TriggerStats
- func (m *TaskTriggersSummary) GetSummary() isTaskTriggersSummary_Summary
- func (*TaskTriggersSummary) ProtoMessage()
- func (x *TaskTriggersSummary) ProtoReflect() protoreflect.Message
- func (x *TaskTriggersSummary) Reset()
- func (x *TaskTriggersSummary) String() string
- func (m *TaskTriggersSummary) Validate() error
- func (m *TaskTriggersSummary) ValidateAll() error
- type TaskTriggersSummaryMultiError
- type TaskTriggersSummaryValidationError
- func (e TaskTriggersSummaryValidationError) Cause() error
- func (e TaskTriggersSummaryValidationError) Error() string
- func (e TaskTriggersSummaryValidationError) ErrorName() string
- func (e TaskTriggersSummaryValidationError) Field() string
- func (e TaskTriggersSummaryValidationError) Key() bool
- func (e TaskTriggersSummaryValidationError) Reason() string
- type TaskTriggersSummary_Details
- type TaskTriggersSummary_Stats
- type TaskTriggersSummary_TriggerDetails
- func (*TaskTriggersSummary_TriggerDetails) Descriptor() ([]byte, []int)deprecated
- func (x *TaskTriggersSummary_TriggerDetails) GetActive() bool
- func (x *TaskTriggersSummary_TriggerDetails) GetAutomationSpec() *TriggerAutomationSpec
- func (x *TaskTriggersSummary_TriggerDetails) GetName() string
- func (*TaskTriggersSummary_TriggerDetails) ProtoMessage()
- func (x *TaskTriggersSummary_TriggerDetails) ProtoReflect() protoreflect.Message
- func (x *TaskTriggersSummary_TriggerDetails) Reset()
- func (x *TaskTriggersSummary_TriggerDetails) String() string
- func (m *TaskTriggersSummary_TriggerDetails) Validate() error
- func (m *TaskTriggersSummary_TriggerDetails) ValidateAll() error
- type TaskTriggersSummary_TriggerDetailsMultiError
- type TaskTriggersSummary_TriggerDetailsValidationError
- func (e TaskTriggersSummary_TriggerDetailsValidationError) Cause() error
- func (e TaskTriggersSummary_TriggerDetailsValidationError) Error() string
- func (e TaskTriggersSummary_TriggerDetailsValidationError) ErrorName() string
- func (e TaskTriggersSummary_TriggerDetailsValidationError) Field() string
- func (e TaskTriggersSummary_TriggerDetailsValidationError) Key() bool
- func (e TaskTriggersSummary_TriggerDetailsValidationError) Reason() string
- type TaskTriggersSummary_TriggerStats
- func (*TaskTriggersSummary_TriggerStats) Descriptor() ([]byte, []int)deprecated
- func (x *TaskTriggersSummary_TriggerStats) GetActive() uint32
- func (x *TaskTriggersSummary_TriggerStats) GetTotal() uint32
- func (*TaskTriggersSummary_TriggerStats) ProtoMessage()
- func (x *TaskTriggersSummary_TriggerStats) ProtoReflect() protoreflect.Message
- func (x *TaskTriggersSummary_TriggerStats) Reset()
- func (x *TaskTriggersSummary_TriggerStats) String() string
- func (m *TaskTriggersSummary_TriggerStats) Validate() error
- func (m *TaskTriggersSummary_TriggerStats) ValidateAll() error
- type TaskTriggersSummary_TriggerStatsMultiError
- type TaskTriggersSummary_TriggerStatsValidationError
- func (e TaskTriggersSummary_TriggerStatsValidationError) Cause() error
- func (e TaskTriggersSummary_TriggerStatsValidationError) Error() string
- func (e TaskTriggersSummary_TriggerStatsValidationError) ErrorName() string
- func (e TaskTriggersSummary_TriggerStatsValidationError) Field() string
- func (e TaskTriggersSummary_TriggerStatsValidationError) Key() bool
- func (e TaskTriggersSummary_TriggerStatsValidationError) Reason() string
- type TaskValidationError
- type TraceSpec
- func (*TraceSpec) Descriptor() ([]byte, []int)deprecated
- func (x *TraceSpec) GetInterface() *core.TypedInterface
- func (*TraceSpec) ProtoMessage()
- func (x *TraceSpec) ProtoReflect() protoreflect.Message
- func (x *TraceSpec) Reset()
- func (x *TraceSpec) String() string
- func (m *TraceSpec) Validate() error
- func (m *TraceSpec) ValidateAll() error
- type TraceSpecMultiError
- type TraceSpecValidationError
- type TriggerAutomationSpec
- func (*TriggerAutomationSpec) Descriptor() ([]byte, []int)deprecated
- func (m *TriggerAutomationSpec) GetAutomation() isTriggerAutomationSpec_Automation
- func (x *TriggerAutomationSpec) GetSchedule() *Schedule
- func (x *TriggerAutomationSpec) GetType() TriggerAutomationSpecType
- func (*TriggerAutomationSpec) ProtoMessage()
- func (x *TriggerAutomationSpec) ProtoReflect() protoreflect.Message
- func (x *TriggerAutomationSpec) Reset()
- func (x *TriggerAutomationSpec) String() string
- func (m *TriggerAutomationSpec) Validate() error
- func (m *TriggerAutomationSpec) ValidateAll() error
- type TriggerAutomationSpecMultiError
- type TriggerAutomationSpecType
- func (TriggerAutomationSpecType) Descriptor() protoreflect.EnumDescriptor
- func (x TriggerAutomationSpecType) Enum() *TriggerAutomationSpecType
- func (TriggerAutomationSpecType) EnumDescriptor() ([]byte, []int)deprecated
- func (x TriggerAutomationSpecType) Number() protoreflect.EnumNumber
- func (x TriggerAutomationSpecType) String() string
- func (TriggerAutomationSpecType) Type() protoreflect.EnumType
- type TriggerAutomationSpecValidationError
- func (e TriggerAutomationSpecValidationError) Cause() error
- func (e TriggerAutomationSpecValidationError) Error() string
- func (e TriggerAutomationSpecValidationError) ErrorName() string
- func (e TriggerAutomationSpecValidationError) Field() string
- func (e TriggerAutomationSpecValidationError) Key() bool
- func (e TriggerAutomationSpecValidationError) Reason() string
- type TriggerAutomationSpec_Schedule
- type UnimplementedTaskServiceServer
- func (UnimplementedTaskServiceServer) DeployTask(context.Context, *DeployTaskRequest) (*DeployTaskResponse, error)
- func (UnimplementedTaskServiceServer) GetTaskDetails(context.Context, *GetTaskDetailsRequest) (*GetTaskDetailsResponse, error)
- func (UnimplementedTaskServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
- func (UnimplementedTaskServiceServer) ListVersions(context.Context, *ListVersionsRequest) (*ListVersionsResponse, error)
- type UnsafeTaskServiceServer
Constants ¶
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 ¶
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.
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.
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.
var File_flyteidl2_task_common_proto protoreflect.FileDescriptor
var File_flyteidl2_task_environment_proto protoreflect.FileDescriptor
var File_flyteidl2_task_run_proto protoreflect.FileDescriptor
var File_flyteidl2_task_task_definition_proto protoreflect.FileDescriptor
var File_flyteidl2_task_task_service_proto protoreflect.FileDescriptor
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 ¶
func (e AnnotationsValidationError) Cause() error
Cause function returns cause value.
func (AnnotationsValidationError) Error ¶
func (e AnnotationsValidationError) Error() string
Error satisfies the builtin error interface
func (AnnotationsValidationError) ErrorName ¶
func (e AnnotationsValidationError) ErrorName() string
ErrorName returns error name.
func (AnnotationsValidationError) Field ¶
func (e AnnotationsValidationError) Field() string
Field function returns field value.
func (AnnotationsValidationError) Key ¶
func (e AnnotationsValidationError) Key() bool
Key function returns key value.
func (AnnotationsValidationError) Reason ¶
func (e AnnotationsValidationError) Reason() string
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 ¶
func (e CacheConfigValidationError) Cause() error
Cause function returns cause value.
func (CacheConfigValidationError) Error ¶
func (e CacheConfigValidationError) Error() string
Error satisfies the builtin error interface
func (CacheConfigValidationError) ErrorName ¶
func (e CacheConfigValidationError) ErrorName() string
ErrorName returns error name.
func (CacheConfigValidationError) Field ¶
func (e CacheConfigValidationError) Field() string
Field function returns field value.
func (CacheConfigValidationError) Key ¶
func (e CacheConfigValidationError) Key() bool
Key function returns key value.
func (CacheConfigValidationError) Reason ¶
func (e CacheConfigValidationError) Reason() string
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) Descriptor() protoreflect.EnumDescriptor
func (CacheLookupScope) Enum ¶
func (x CacheLookupScope) Enum() *CacheLookupScope
func (CacheLookupScope) EnumDescriptor
deprecated
func (CacheLookupScope) EnumDescriptor() ([]byte, []int)
Deprecated: Use CacheLookupScope.Descriptor instead.
func (CacheLookupScope) Number ¶
func (x CacheLookupScope) Number() protoreflect.EnumNumber
func (CacheLookupScope) String ¶
func (x CacheLookupScope) String() string
func (CacheLookupScope) Type ¶
func (CacheLookupScope) Type() protoreflect.EnumType
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) GetExpression ¶
func (*Cron) GetTimezone ¶
func (*Cron) ProtoMessage ¶
func (*Cron) ProtoMessage()
func (*Cron) ProtoReflect ¶
func (x *Cron) ProtoReflect() protoreflect.Message
func (*Cron) Validate ¶
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 ¶
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 ¶
func (m DeployTaskRequestMultiError) Error() string
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 ¶
func (e DeployTaskRequestValidationError) Cause() error
Cause function returns cause value.
func (DeployTaskRequestValidationError) Error ¶
func (e DeployTaskRequestValidationError) Error() string
Error satisfies the builtin error interface
func (DeployTaskRequestValidationError) ErrorName ¶
func (e DeployTaskRequestValidationError) ErrorName() string
ErrorName returns error name.
func (DeployTaskRequestValidationError) Field ¶
func (e DeployTaskRequestValidationError) Field() string
Field function returns field value.
func (DeployTaskRequestValidationError) Key ¶
func (e DeployTaskRequestValidationError) Key() bool
Key function returns key value.
func (DeployTaskRequestValidationError) Reason ¶
func (e DeployTaskRequestValidationError) Reason() string
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 ¶
func (m DeployTaskResponseMultiError) Error() string
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 ¶
func (e DeployTaskResponseValidationError) Cause() error
Cause function returns cause value.
func (DeployTaskResponseValidationError) Error ¶
func (e DeployTaskResponseValidationError) Error() string
Error satisfies the builtin error interface
func (DeployTaskResponseValidationError) ErrorName ¶
func (e DeployTaskResponseValidationError) ErrorName() string
ErrorName returns error name.
func (DeployTaskResponseValidationError) Field ¶
func (e DeployTaskResponseValidationError) Field() string
Field function returns field value.
func (DeployTaskResponseValidationError) Key ¶
func (e DeployTaskResponseValidationError) Key() bool
Key function returns key value.
func (DeployTaskResponseValidationError) Reason ¶
func (e DeployTaskResponseValidationError) Reason() string
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 ¶
func (m DocumentationEntityMultiError) Error() string
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 ¶
func (e DocumentationEntityValidationError) Cause() error
Cause function returns cause value.
func (DocumentationEntityValidationError) Error ¶
func (e DocumentationEntityValidationError) Error() string
Error satisfies the builtin error interface
func (DocumentationEntityValidationError) ErrorName ¶
func (e DocumentationEntityValidationError) ErrorName() string
ErrorName returns error name.
func (DocumentationEntityValidationError) Field ¶
func (e DocumentationEntityValidationError) Field() string
Field function returns field value.
func (DocumentationEntityValidationError) Key ¶
func (e DocumentationEntityValidationError) Key() bool
Key function returns key value.
func (DocumentationEntityValidationError) Reason ¶
func (e DocumentationEntityValidationError) Reason() string
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 ¶
func (e EnvironmentValidationError) Cause() error
Cause function returns cause value.
func (EnvironmentValidationError) Error ¶
func (e EnvironmentValidationError) Error() string
Error satisfies the builtin error interface
func (EnvironmentValidationError) ErrorName ¶
func (e EnvironmentValidationError) ErrorName() string
ErrorName returns error name.
func (EnvironmentValidationError) Field ¶
func (e EnvironmentValidationError) Field() string
Field function returns field value.
func (EnvironmentValidationError) Key ¶
func (e EnvironmentValidationError) Key() bool
Key function returns key value.
func (EnvironmentValidationError) Reason ¶
func (e EnvironmentValidationError) Reason() string
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) GetValues ¶
func (x *Envs) GetValues() []*core.KeyValuePair
func (*Envs) ProtoMessage ¶
func (*Envs) ProtoMessage()
func (*Envs) ProtoReflect ¶
func (x *Envs) ProtoReflect() protoreflect.Message
func (*Envs) Validate ¶
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 ¶
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) GetStartTime ¶
func (x *FixedRate) GetStartTime() *timestamppb.Timestamp
func (*FixedRate) GetUnit ¶
func (x *FixedRate) GetUnit() FixedRateUnit
func (*FixedRate) ProtoMessage ¶
func (*FixedRate) ProtoMessage()
func (*FixedRate) ProtoReflect ¶
func (x *FixedRate) ProtoReflect() protoreflect.Message
func (*FixedRate) Validate ¶
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 ¶
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) Descriptor() protoreflect.EnumDescriptor
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 (x FixedRateUnit) Number() protoreflect.EnumNumber
func (FixedRateUnit) String ¶
func (x FixedRateUnit) String() string
func (FixedRateUnit) Type ¶
func (FixedRateUnit) Type() protoreflect.EnumType
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 ¶
func (e FixedRateValidationError) Key() bool
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 ¶
func (m GetTaskDetailsRequestMultiError) Error() string
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 ¶
func (e GetTaskDetailsRequestValidationError) Cause() error
Cause function returns cause value.
func (GetTaskDetailsRequestValidationError) Error ¶
func (e GetTaskDetailsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (GetTaskDetailsRequestValidationError) ErrorName ¶
func (e GetTaskDetailsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (GetTaskDetailsRequestValidationError) Field ¶
func (e GetTaskDetailsRequestValidationError) Field() string
Field function returns field value.
func (GetTaskDetailsRequestValidationError) Key ¶
func (e GetTaskDetailsRequestValidationError) Key() bool
Key function returns key value.
func (GetTaskDetailsRequestValidationError) Reason ¶
func (e GetTaskDetailsRequestValidationError) Reason() string
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 ¶
func (m GetTaskDetailsResponseMultiError) Error() string
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 ¶
func (e GetTaskDetailsResponseValidationError) Cause() error
Cause function returns cause value.
func (GetTaskDetailsResponseValidationError) Error ¶
func (e GetTaskDetailsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (GetTaskDetailsResponseValidationError) ErrorName ¶
func (e GetTaskDetailsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (GetTaskDetailsResponseValidationError) Field ¶
func (e GetTaskDetailsResponseValidationError) Field() string
Field function returns field value.
func (GetTaskDetailsResponseValidationError) Key ¶
func (e GetTaskDetailsResponseValidationError) Key() bool
Key function returns key value.
func (GetTaskDetailsResponseValidationError) Reason ¶
func (e GetTaskDetailsResponseValidationError) Reason() string
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
func (e InlineRuleListValidationError) Cause() error
Cause function returns cause value.
func (InlineRuleListValidationError) Error ¶ added in v2.0.8
func (e InlineRuleListValidationError) Error() string
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
func (e InlineRuleListValidationError) Field() string
Field function returns field value.
func (InlineRuleListValidationError) Key ¶ added in v2.0.8
func (e InlineRuleListValidationError) Key() bool
Key function returns key value.
func (InlineRuleListValidationError) Reason ¶ added in v2.0.8
func (e InlineRuleListValidationError) Reason() string
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
func (e InlineRuleValidationError) Error() string
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
func (e InlineRuleValidationError) Field() string
Field function returns field value.
func (InlineRuleValidationError) Key ¶ added in v2.0.8
func (e InlineRuleValidationError) Key() bool
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) 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) Validate ¶
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 ¶
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) ProtoMessage ¶
func (*Labels) ProtoMessage()
func (*Labels) ProtoReflect ¶
func (x *Labels) ProtoReflect() protoreflect.Message
func (*Labels) Validate ¶
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 ¶
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 ¶
func (m LatestRunSummaryMultiError) Error() string
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 ¶
func (e LatestRunSummaryValidationError) Cause() error
Cause function returns cause value.
func (LatestRunSummaryValidationError) Error ¶
func (e LatestRunSummaryValidationError) Error() string
Error satisfies the builtin error interface
func (LatestRunSummaryValidationError) ErrorName ¶
func (e LatestRunSummaryValidationError) ErrorName() string
ErrorName returns error name.
func (LatestRunSummaryValidationError) Field ¶
func (e LatestRunSummaryValidationError) Field() string
Field function returns field value.
func (LatestRunSummaryValidationError) Key ¶
func (e LatestRunSummaryValidationError) Key() bool
Key function returns key value.
func (LatestRunSummaryValidationError) Reason ¶
func (e LatestRunSummaryValidationError) Reason() string
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 ¶
func (m ListTasksRequestMultiError) Error() string
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 ¶
func (e ListTasksRequestValidationError) Cause() error
Cause function returns cause value.
func (ListTasksRequestValidationError) Error ¶
func (e ListTasksRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ListTasksRequestValidationError) ErrorName ¶
func (e ListTasksRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ListTasksRequestValidationError) Field ¶
func (e ListTasksRequestValidationError) Field() string
Field function returns field value.
func (ListTasksRequestValidationError) Key ¶
func (e ListTasksRequestValidationError) Key() bool
Key function returns key value.
func (ListTasksRequestValidationError) Reason ¶
func (e ListTasksRequestValidationError) Reason() string
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 (x *ListTasksRequest_KnownFilter) ProtoReflect() protoreflect.Message
func (*ListTasksRequest_KnownFilter) Reset ¶
func (x *ListTasksRequest_KnownFilter) Reset()
func (*ListTasksRequest_KnownFilter) String ¶
func (x *ListTasksRequest_KnownFilter) String() 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 ¶
func (m ListTasksRequest_KnownFilterMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ListTasksRequest_KnownFilterMultiError) Error ¶
func (m ListTasksRequest_KnownFilterMultiError) Error() string
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 ¶
func (e ListTasksRequest_KnownFilterValidationError) Cause() error
Cause function returns cause value.
func (ListTasksRequest_KnownFilterValidationError) Error ¶
func (e ListTasksRequest_KnownFilterValidationError) Error() string
Error satisfies the builtin error interface
func (ListTasksRequest_KnownFilterValidationError) ErrorName ¶
func (e ListTasksRequest_KnownFilterValidationError) ErrorName() string
ErrorName returns error name.
func (ListTasksRequest_KnownFilterValidationError) Field ¶
func (e ListTasksRequest_KnownFilterValidationError) Field() string
Field function returns field value.
func (ListTasksRequest_KnownFilterValidationError) Key ¶
func (e ListTasksRequest_KnownFilterValidationError) Key() bool
Key function returns key value.
func (ListTasksRequest_KnownFilterValidationError) Reason ¶
func (e ListTasksRequest_KnownFilterValidationError) Reason() string
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 (x *ListTasksResponse) GetMetadata() *ListTasksResponse_ListTasksMetadata
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 ¶
func (m ListTasksResponseMultiError) Error() string
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 ¶
func (e ListTasksResponseValidationError) Cause() error
Cause function returns cause value.
func (ListTasksResponseValidationError) Error ¶
func (e ListTasksResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ListTasksResponseValidationError) ErrorName ¶
func (e ListTasksResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ListTasksResponseValidationError) Field ¶
func (e ListTasksResponseValidationError) Field() string
Field function returns field value.
func (ListTasksResponseValidationError) Key ¶
func (e ListTasksResponseValidationError) Key() bool
Key function returns key value.
func (ListTasksResponseValidationError) Reason ¶
func (e ListTasksResponseValidationError) Reason() string
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 (x *ListTasksResponse_ListTasksMetadata) GetTotal() uint32
func (*ListTasksResponse_ListTasksMetadata) ProtoMessage ¶
func (*ListTasksResponse_ListTasksMetadata) ProtoMessage()
func (*ListTasksResponse_ListTasksMetadata) ProtoReflect ¶
func (x *ListTasksResponse_ListTasksMetadata) ProtoReflect() protoreflect.Message
func (*ListTasksResponse_ListTasksMetadata) Reset ¶
func (x *ListTasksResponse_ListTasksMetadata) Reset()
func (*ListTasksResponse_ListTasksMetadata) String ¶
func (x *ListTasksResponse_ListTasksMetadata) String() string
func (*ListTasksResponse_ListTasksMetadata) Validate ¶
func (m *ListTasksResponse_ListTasksMetadata) Validate() error
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 ¶
func (m ListTasksResponse_ListTasksMetadataMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ListTasksResponse_ListTasksMetadataMultiError) Error ¶
func (m ListTasksResponse_ListTasksMetadataMultiError) Error() string
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 ¶
func (e ListTasksResponse_ListTasksMetadataValidationError) Cause() error
Cause function returns cause value.
func (ListTasksResponse_ListTasksMetadataValidationError) Error ¶
func (e ListTasksResponse_ListTasksMetadataValidationError) Error() string
Error satisfies the builtin error interface
func (ListTasksResponse_ListTasksMetadataValidationError) ErrorName ¶
func (e ListTasksResponse_ListTasksMetadataValidationError) ErrorName() string
ErrorName returns error name.
func (ListTasksResponse_ListTasksMetadataValidationError) Field ¶
func (e ListTasksResponse_ListTasksMetadataValidationError) Field() string
Field function returns field value.
func (ListTasksResponse_ListTasksMetadataValidationError) Key ¶
func (e ListTasksResponse_ListTasksMetadataValidationError) Key() bool
Key function returns key value.
func (ListTasksResponse_ListTasksMetadataValidationError) Reason ¶
func (e ListTasksResponse_ListTasksMetadataValidationError) Reason() string
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 ¶
func (m ListVersionsRequestMultiError) Error() string
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 ¶
func (e ListVersionsRequestValidationError) Cause() error
Cause function returns cause value.
func (ListVersionsRequestValidationError) Error ¶
func (e ListVersionsRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ListVersionsRequestValidationError) ErrorName ¶
func (e ListVersionsRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ListVersionsRequestValidationError) Field ¶
func (e ListVersionsRequestValidationError) Field() string
Field function returns field value.
func (ListVersionsRequestValidationError) Key ¶
func (e ListVersionsRequestValidationError) Key() bool
Key function returns key value.
func (ListVersionsRequestValidationError) Reason ¶
func (e ListVersionsRequestValidationError) Reason() string
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 (x *ListVersionsResponse) GetVersions() []*ListVersionsResponse_VersionResponse
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 ¶
func (m ListVersionsResponseMultiError) Error() string
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 ¶
func (e ListVersionsResponseValidationError) Cause() error
Cause function returns cause value.
func (ListVersionsResponseValidationError) Error ¶
func (e ListVersionsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ListVersionsResponseValidationError) ErrorName ¶
func (e ListVersionsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ListVersionsResponseValidationError) Field ¶
func (e ListVersionsResponseValidationError) Field() string
Field function returns field value.
func (ListVersionsResponseValidationError) Key ¶
func (e ListVersionsResponseValidationError) Key() bool
Key function returns key value.
func (ListVersionsResponseValidationError) Reason ¶
func (e ListVersionsResponseValidationError) Reason() string
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 (x *ListVersionsResponse_VersionResponse) GetDeployedAt() *timestamppb.Timestamp
func (*ListVersionsResponse_VersionResponse) GetDeployedBy ¶ added in v2.0.21
func (x *ListVersionsResponse_VersionResponse) GetDeployedBy() *common.EnrichedIdentity
func (*ListVersionsResponse_VersionResponse) GetLatestRun ¶ added in v2.0.21
func (x *ListVersionsResponse_VersionResponse) GetLatestRun() *LatestRunSummary
func (*ListVersionsResponse_VersionResponse) GetVersion ¶
func (x *ListVersionsResponse_VersionResponse) GetVersion() string
func (*ListVersionsResponse_VersionResponse) ProtoMessage ¶
func (*ListVersionsResponse_VersionResponse) ProtoMessage()
func (*ListVersionsResponse_VersionResponse) ProtoReflect ¶
func (x *ListVersionsResponse_VersionResponse) ProtoReflect() protoreflect.Message
func (*ListVersionsResponse_VersionResponse) Reset ¶
func (x *ListVersionsResponse_VersionResponse) Reset()
func (*ListVersionsResponse_VersionResponse) String ¶
func (x *ListVersionsResponse_VersionResponse) String() string
func (*ListVersionsResponse_VersionResponse) Validate ¶
func (m *ListVersionsResponse_VersionResponse) Validate() error
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 ¶
func (m *ListVersionsResponse_VersionResponse) ValidateAll() error
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 ¶
func (m ListVersionsResponse_VersionResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ListVersionsResponse_VersionResponseMultiError) Error ¶
func (m ListVersionsResponse_VersionResponseMultiError) Error() string
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 ¶
func (e ListVersionsResponse_VersionResponseValidationError) Cause() error
Cause function returns cause value.
func (ListVersionsResponse_VersionResponseValidationError) Error ¶
func (e ListVersionsResponse_VersionResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ListVersionsResponse_VersionResponseValidationError) ErrorName ¶
func (e ListVersionsResponse_VersionResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ListVersionsResponse_VersionResponseValidationError) Field ¶
func (e ListVersionsResponse_VersionResponseValidationError) Field() string
Field function returns field value.
func (ListVersionsResponse_VersionResponseValidationError) Key ¶
func (e ListVersionsResponse_VersionResponseValidationError) Key() bool
Key function returns key value.
func (ListVersionsResponse_VersionResponseValidationError) Reason ¶
func (e ListVersionsResponse_VersionResponseValidationError) Reason() string
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 ¶
func (e NamedLiteralValidationError) Cause() error
Cause function returns cause value.
func (NamedLiteralValidationError) Error ¶
func (e NamedLiteralValidationError) Error() string
Error satisfies the builtin error interface
func (NamedLiteralValidationError) ErrorName ¶
func (e NamedLiteralValidationError) ErrorName() string
ErrorName returns error name.
func (NamedLiteralValidationError) Field ¶
func (e NamedLiteralValidationError) Field() string
Field function returns field value.
func (NamedLiteralValidationError) Key ¶
func (e NamedLiteralValidationError) Key() bool
Key function returns key value.
func (NamedLiteralValidationError) Reason ¶
func (e NamedLiteralValidationError) Reason() string
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 ¶
func (e NamedParameterValidationError) Cause() error
Cause function returns cause value.
func (NamedParameterValidationError) Error ¶
func (e NamedParameterValidationError) Error() string
Error satisfies the builtin error interface
func (NamedParameterValidationError) ErrorName ¶
func (e NamedParameterValidationError) ErrorName() string
ErrorName returns error name.
func (NamedParameterValidationError) Field ¶
func (e NamedParameterValidationError) Field() string
Field function returns field value.
func (NamedParameterValidationError) Key ¶
func (e NamedParameterValidationError) Key() bool
Key function returns key value.
func (NamedParameterValidationError) Reason ¶
func (e NamedParameterValidationError) Reason() string
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 ¶
func (m OutputReferencesMultiError) Error() string
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 ¶
func (e OutputReferencesValidationError) Cause() error
Cause function returns cause value.
func (OutputReferencesValidationError) Error ¶
func (e OutputReferencesValidationError) Error() string
Error satisfies the builtin error interface
func (OutputReferencesValidationError) ErrorName ¶
func (e OutputReferencesValidationError) ErrorName() string
ErrorName returns error name.
func (OutputReferencesValidationError) Field ¶
func (e OutputReferencesValidationError) Field() string
Field function returns field value.
func (OutputReferencesValidationError) Key ¶
func (e OutputReferencesValidationError) Key() bool
Key function returns key value.
func (OutputReferencesValidationError) Reason ¶
func (e OutputReferencesValidationError) Reason() string
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) GetLiterals ¶
func (x *Outputs) GetLiterals() []*NamedLiteral
func (*Outputs) ProtoMessage ¶
func (*Outputs) ProtoMessage()
func (*Outputs) ProtoReflect ¶
func (x *Outputs) ProtoReflect() protoreflect.Message
func (*Outputs) Validate ¶
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 ¶
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 ¶
func (e RawDataStorageValidationError) Cause() error
Cause function returns cause value.
func (RawDataStorageValidationError) Error ¶
func (e RawDataStorageValidationError) Error() string
Error satisfies the builtin error interface
func (RawDataStorageValidationError) ErrorName ¶
func (e RawDataStorageValidationError) ErrorName() string
ErrorName returns error name.
func (RawDataStorageValidationError) Field ¶
func (e RawDataStorageValidationError) Field() string
Field function returns field value.
func (RawDataStorageValidationError) Key ¶
func (e RawDataStorageValidationError) Key() bool
Key function returns key value.
func (RawDataStorageValidationError) Reason ¶
func (e RawDataStorageValidationError) Reason() string
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) GetAnnotations ¶
func (x *RunSpec) GetAnnotations() *Annotations
func (*RunSpec) GetCacheConfig ¶
func (x *RunSpec) GetCacheConfig() *CacheConfig
func (*RunSpec) GetCluster ¶
func (*RunSpec) GetInterruptible ¶
func (x *RunSpec) GetInterruptible() *wrapperspb.BoolValue
func (*RunSpec) GetNotificationRuleName ¶ added in v2.0.8
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 (*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) Validate ¶
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 ¶
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) GetCronExpression
deprecated
func (*Schedule) GetExpression ¶
func (m *Schedule) GetExpression() isSchedule_Expression
func (*Schedule) GetKickoffTimeInputArg ¶
func (*Schedule) ProtoMessage ¶
func (*Schedule) ProtoMessage()
func (*Schedule) ProtoReflect ¶
func (x *Schedule) ProtoReflect() protoreflect.Message
func (*Schedule) Validate ¶
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 ¶
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 (*SourceCode) GetLink ¶
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 ¶
func (e SourceCodeValidationError) Error() string
Error satisfies the builtin error interface
func (SourceCodeValidationError) ErrorName ¶
func (e SourceCodeValidationError) ErrorName() string
ErrorName returns error name.
func (SourceCodeValidationError) Field ¶
func (e SourceCodeValidationError) Field() string
Field function returns field value.
func (SourceCodeValidationError) Key ¶
func (e SourceCodeValidationError) Key() bool
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) 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) Validate ¶
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 ¶
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 ¶
func (e TaskDetailsValidationError) Cause() error
Cause function returns cause value.
func (TaskDetailsValidationError) Error ¶
func (e TaskDetailsValidationError) Error() string
Error satisfies the builtin error interface
func (TaskDetailsValidationError) ErrorName ¶
func (e TaskDetailsValidationError) ErrorName() string
ErrorName returns error name.
func (TaskDetailsValidationError) Field ¶
func (e TaskDetailsValidationError) Field() string
Field function returns field value.
func (TaskDetailsValidationError) Key ¶
func (e TaskDetailsValidationError) Key() bool
Key function returns key value.
func (TaskDetailsValidationError) Reason ¶
func (e TaskDetailsValidationError) Reason() string
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 ¶
func (e TaskIdentifierValidationError) Cause() error
Cause function returns cause value.
func (TaskIdentifierValidationError) Error ¶
func (e TaskIdentifierValidationError) Error() string
Error satisfies the builtin error interface
func (TaskIdentifierValidationError) ErrorName ¶
func (e TaskIdentifierValidationError) ErrorName() string
ErrorName returns error name.
func (TaskIdentifierValidationError) Field ¶
func (e TaskIdentifierValidationError) Field() string
Field function returns field value.
func (TaskIdentifierValidationError) Key ¶
func (e TaskIdentifierValidationError) Key() bool
Key function returns key value.
func (TaskIdentifierValidationError) Reason ¶
func (e TaskIdentifierValidationError) Reason() string
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 ¶
func (e TaskMetadataValidationError) Cause() error
Cause function returns cause value.
func (TaskMetadataValidationError) Error ¶
func (e TaskMetadataValidationError) Error() string
Error satisfies the builtin error interface
func (TaskMetadataValidationError) ErrorName ¶
func (e TaskMetadataValidationError) ErrorName() string
ErrorName returns error name.
func (TaskMetadataValidationError) Field ¶
func (e TaskMetadataValidationError) Field() string
Field function returns field value.
func (TaskMetadataValidationError) Key ¶
func (e TaskMetadataValidationError) Key() bool
Key function returns key value.
func (TaskMetadataValidationError) Reason ¶
func (e TaskMetadataValidationError) Reason() string
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) GetProject ¶
func (*TaskName) ProtoMessage ¶
func (*TaskName) ProtoMessage()
func (*TaskName) ProtoReflect ¶
func (x *TaskName) ProtoReflect() protoreflect.Message
func (*TaskName) Validate ¶
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 ¶
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.
func NewTaskServiceClient ¶
func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient
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) 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 (*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) Validate ¶
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 ¶
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 ¶
func (e TaskSummaryValidationError) Cause() error
Cause function returns cause value.
func (TaskSummaryValidationError) Error ¶
func (e TaskSummaryValidationError) Error() string
Error satisfies the builtin error interface
func (TaskSummaryValidationError) ErrorName ¶
func (e TaskSummaryValidationError) ErrorName() string
ErrorName returns error name.
func (TaskSummaryValidationError) Field ¶
func (e TaskSummaryValidationError) Field() string
Field function returns field value.
func (TaskSummaryValidationError) Key ¶
func (e TaskSummaryValidationError) Key() bool
Key function returns key value.
func (TaskSummaryValidationError) Reason ¶
func (e TaskSummaryValidationError) Reason() string
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 ¶
func (m TaskTriggerSpecMultiError) Error() string
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 ¶
func (e TaskTriggerSpecValidationError) Cause() error
Cause function returns cause value.
func (TaskTriggerSpecValidationError) Error ¶
func (e TaskTriggerSpecValidationError) Error() string
Error satisfies the builtin error interface
func (TaskTriggerSpecValidationError) ErrorName ¶
func (e TaskTriggerSpecValidationError) ErrorName() string
ErrorName returns error name.
func (TaskTriggerSpecValidationError) Field ¶
func (e TaskTriggerSpecValidationError) Field() string
Field function returns field value.
func (TaskTriggerSpecValidationError) Key ¶
func (e TaskTriggerSpecValidationError) Key() bool
Key function returns key value.
func (TaskTriggerSpecValidationError) Reason ¶
func (e TaskTriggerSpecValidationError) Reason() string
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 ¶
func (e TaskTriggerValidationError) Cause() error
Cause function returns cause value.
func (TaskTriggerValidationError) Error ¶
func (e TaskTriggerValidationError) Error() string
Error satisfies the builtin error interface
func (TaskTriggerValidationError) ErrorName ¶
func (e TaskTriggerValidationError) ErrorName() string
ErrorName returns error name.
func (TaskTriggerValidationError) Field ¶
func (e TaskTriggerValidationError) Field() string
Field function returns field value.
func (TaskTriggerValidationError) Key ¶
func (e TaskTriggerValidationError) Key() bool
Key function returns key value.
func (TaskTriggerValidationError) Reason ¶
func (e TaskTriggerValidationError) Reason() string
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 (x *TaskTriggersSummary) GetDetails() *TaskTriggersSummary_TriggerDetails
func (*TaskTriggersSummary) GetStats ¶
func (x *TaskTriggersSummary) GetStats() *TaskTriggersSummary_TriggerStats
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 ¶
func (m TaskTriggersSummaryMultiError) Error() string
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 ¶
func (e TaskTriggersSummaryValidationError) Cause() error
Cause function returns cause value.
func (TaskTriggersSummaryValidationError) Error ¶
func (e TaskTriggersSummaryValidationError) Error() string
Error satisfies the builtin error interface
func (TaskTriggersSummaryValidationError) ErrorName ¶
func (e TaskTriggersSummaryValidationError) ErrorName() string
ErrorName returns error name.
func (TaskTriggersSummaryValidationError) Field ¶
func (e TaskTriggersSummaryValidationError) Field() string
Field function returns field value.
func (TaskTriggersSummaryValidationError) Key ¶
func (e TaskTriggersSummaryValidationError) Key() bool
Key function returns key value.
func (TaskTriggersSummaryValidationError) Reason ¶
func (e TaskTriggersSummaryValidationError) Reason() string
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 (x *TaskTriggersSummary_TriggerDetails) GetActive() bool
func (*TaskTriggersSummary_TriggerDetails) GetAutomationSpec ¶
func (x *TaskTriggersSummary_TriggerDetails) GetAutomationSpec() *TriggerAutomationSpec
func (*TaskTriggersSummary_TriggerDetails) GetName ¶
func (x *TaskTriggersSummary_TriggerDetails) GetName() string
func (*TaskTriggersSummary_TriggerDetails) ProtoMessage ¶
func (*TaskTriggersSummary_TriggerDetails) ProtoMessage()
func (*TaskTriggersSummary_TriggerDetails) ProtoReflect ¶
func (x *TaskTriggersSummary_TriggerDetails) ProtoReflect() protoreflect.Message
func (*TaskTriggersSummary_TriggerDetails) Reset ¶
func (x *TaskTriggersSummary_TriggerDetails) Reset()
func (*TaskTriggersSummary_TriggerDetails) String ¶
func (x *TaskTriggersSummary_TriggerDetails) String() string
func (*TaskTriggersSummary_TriggerDetails) Validate ¶
func (m *TaskTriggersSummary_TriggerDetails) Validate() error
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 ¶
func (m TaskTriggersSummary_TriggerDetailsMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (TaskTriggersSummary_TriggerDetailsMultiError) Error ¶
func (m TaskTriggersSummary_TriggerDetailsMultiError) Error() string
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 ¶
func (e TaskTriggersSummary_TriggerDetailsValidationError) Cause() error
Cause function returns cause value.
func (TaskTriggersSummary_TriggerDetailsValidationError) Error ¶
func (e TaskTriggersSummary_TriggerDetailsValidationError) Error() string
Error satisfies the builtin error interface
func (TaskTriggersSummary_TriggerDetailsValidationError) ErrorName ¶
func (e TaskTriggersSummary_TriggerDetailsValidationError) ErrorName() string
ErrorName returns error name.
func (TaskTriggersSummary_TriggerDetailsValidationError) Field ¶
func (e TaskTriggersSummary_TriggerDetailsValidationError) Field() string
Field function returns field value.
func (TaskTriggersSummary_TriggerDetailsValidationError) Key ¶
func (e TaskTriggersSummary_TriggerDetailsValidationError) Key() bool
Key function returns key value.
func (TaskTriggersSummary_TriggerDetailsValidationError) Reason ¶
func (e TaskTriggersSummary_TriggerDetailsValidationError) Reason() string
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 (x *TaskTriggersSummary_TriggerStats) GetActive() uint32
func (*TaskTriggersSummary_TriggerStats) GetTotal ¶
func (x *TaskTriggersSummary_TriggerStats) GetTotal() uint32
func (*TaskTriggersSummary_TriggerStats) ProtoMessage ¶
func (*TaskTriggersSummary_TriggerStats) ProtoMessage()
func (*TaskTriggersSummary_TriggerStats) ProtoReflect ¶
func (x *TaskTriggersSummary_TriggerStats) ProtoReflect() protoreflect.Message
func (*TaskTriggersSummary_TriggerStats) Reset ¶
func (x *TaskTriggersSummary_TriggerStats) Reset()
func (*TaskTriggersSummary_TriggerStats) String ¶
func (x *TaskTriggersSummary_TriggerStats) String() string
func (*TaskTriggersSummary_TriggerStats) Validate ¶
func (m *TaskTriggersSummary_TriggerStats) Validate() error
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 ¶
func (m TaskTriggersSummary_TriggerStatsMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (TaskTriggersSummary_TriggerStatsMultiError) Error ¶
func (m TaskTriggersSummary_TriggerStatsMultiError) Error() string
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 ¶
func (e TaskTriggersSummary_TriggerStatsValidationError) Cause() error
Cause function returns cause value.
func (TaskTriggersSummary_TriggerStatsValidationError) Error ¶
func (e TaskTriggersSummary_TriggerStatsValidationError) Error() string
Error satisfies the builtin error interface
func (TaskTriggersSummary_TriggerStatsValidationError) ErrorName ¶
func (e TaskTriggersSummary_TriggerStatsValidationError) ErrorName() string
ErrorName returns error name.
func (TaskTriggersSummary_TriggerStatsValidationError) Field ¶
func (e TaskTriggersSummary_TriggerStatsValidationError) Field() string
Field function returns field value.
func (TaskTriggersSummary_TriggerStatsValidationError) Key ¶
func (e TaskTriggersSummary_TriggerStatsValidationError) Key() bool
Key function returns key value.
func (TaskTriggersSummary_TriggerStatsValidationError) Reason ¶
func (e TaskTriggersSummary_TriggerStatsValidationError) Reason() string
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) GetInterface ¶
func (x *TraceSpec) GetInterface() *core.TypedInterface
func (*TraceSpec) ProtoMessage ¶
func (*TraceSpec) ProtoMessage()
func (*TraceSpec) ProtoReflect ¶
func (x *TraceSpec) ProtoReflect() protoreflect.Message
func (*TraceSpec) Validate ¶
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 ¶
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 ¶
func (e TraceSpecValidationError) Key() bool
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 (x *TriggerAutomationSpec) GetType() TriggerAutomationSpecType
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 ¶
func (m TriggerAutomationSpecMultiError) Error() string
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) Descriptor() protoreflect.EnumDescriptor
func (TriggerAutomationSpecType) Enum ¶
func (x TriggerAutomationSpecType) Enum() *TriggerAutomationSpecType
func (TriggerAutomationSpecType) EnumDescriptor
deprecated
func (TriggerAutomationSpecType) EnumDescriptor() ([]byte, []int)
Deprecated: Use TriggerAutomationSpecType.Descriptor instead.
func (TriggerAutomationSpecType) Number ¶
func (x TriggerAutomationSpecType) Number() protoreflect.EnumNumber
func (TriggerAutomationSpecType) String ¶
func (x TriggerAutomationSpecType) String() string
func (TriggerAutomationSpecType) Type ¶
func (TriggerAutomationSpecType) Type() protoreflect.EnumType
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 ¶
func (e TriggerAutomationSpecValidationError) Cause() error
Cause function returns cause value.
func (TriggerAutomationSpecValidationError) Error ¶
func (e TriggerAutomationSpecValidationError) Error() string
Error satisfies the builtin error interface
func (TriggerAutomationSpecValidationError) ErrorName ¶
func (e TriggerAutomationSpecValidationError) ErrorName() string
ErrorName returns error name.
func (TriggerAutomationSpecValidationError) Field ¶
func (e TriggerAutomationSpecValidationError) Field() string
Field function returns field value.
func (TriggerAutomationSpecValidationError) Key ¶
func (e TriggerAutomationSpecValidationError) Key() bool
Key function returns key value.
func (TriggerAutomationSpecValidationError) Reason ¶
func (e TriggerAutomationSpecValidationError) Reason() string
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) DeployTask(context.Context, *DeployTaskRequest) (*DeployTaskResponse, error)
func (UnimplementedTaskServiceServer) GetTaskDetails ¶
func (UnimplementedTaskServiceServer) GetTaskDetails(context.Context, *GetTaskDetailsRequest) (*GetTaskDetailsResponse, error)
func (UnimplementedTaskServiceServer) ListTasks ¶
func (UnimplementedTaskServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
func (UnimplementedTaskServiceServer) ListVersions ¶
func (UnimplementedTaskServiceServer) ListVersions(context.Context, *ListVersionsRequest) (*ListVersionsResponse, error)
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.