admin

package
v0.16.6 Latest Latest
Warning

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

Go to latest
Published: Jan 10, 2020 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ExecutionMetadata_ExecutionMode_name = map[int32]string{
	0: "MANUAL",
	1: "SCHEDULED",
	2: "SYSTEM",
	3: "RELAUNCH",
	4: "CHILD_WORKFLOW",
}
View Source
var ExecutionMetadata_ExecutionMode_value = map[string]int32{
	"MANUAL":         0,
	"SCHEDULED":      1,
	"SYSTEM":         2,
	"RELAUNCH":       3,
	"CHILD_WORKFLOW": 4,
}
View Source
var FixedRateUnit_name = map[int32]string{
	0: "MINUTE",
	1: "HOUR",
	2: "DAY",
}
View Source
var FixedRateUnit_value = map[string]int32{
	"MINUTE": 0,
	"HOUR":   1,
	"DAY":    2,
}
View Source
var LaunchPlanState_name = map[int32]string{
	0: "INACTIVE",
	1: "ACTIVE",
}
View Source
var LaunchPlanState_value = map[string]int32{
	"INACTIVE": 0,
	"ACTIVE":   1,
}
View Source
var MatchableResource_name = map[int32]string{
	0: "TASK_RESOURCE",
	1: "CLUSTER_RESOURCE",
	2: "EXECUTION_QUEUE",
}
View Source
var MatchableResource_value = map[string]int32{
	"TASK_RESOURCE":    0,
	"CLUSTER_RESOURCE": 1,
	"EXECUTION_QUEUE":  2,
}
View Source
var Sort_Direction_name = map[int32]string{
	0: "DESCENDING",
	1: "ASCENDING",
}
View Source
var Sort_Direction_value = map[string]int32{
	"DESCENDING": 0,
	"ASCENDING":  1,
}

Functions

This section is empty.

Types

type AbortMetadata added in v0.16.2

type AbortMetadata struct {
	// In the case of a user-specified abort, this will pass along the user-supplied cause.
	Cause string `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"`
	// Identifies the entity (if any) responsible for terminating the execution
	Principal            string   `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AbortMetadata) Descriptor added in v0.16.2

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

func (*AbortMetadata) GetCause added in v0.16.2

func (m *AbortMetadata) GetCause() string

func (*AbortMetadata) GetPrincipal added in v0.16.2

func (m *AbortMetadata) GetPrincipal() string

func (*AbortMetadata) ProtoMessage added in v0.16.2

func (*AbortMetadata) ProtoMessage()

func (*AbortMetadata) Reset added in v0.16.2

func (m *AbortMetadata) Reset()

func (*AbortMetadata) String added in v0.16.2

func (m *AbortMetadata) String() string

func (*AbortMetadata) Validate added in v0.16.2

func (m *AbortMetadata) Validate() error

Validate checks the field values on AbortMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*AbortMetadata) XXX_DiscardUnknown added in v0.16.2

func (m *AbortMetadata) XXX_DiscardUnknown()

func (*AbortMetadata) XXX_Marshal added in v0.16.2

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

func (*AbortMetadata) XXX_Merge added in v0.16.2

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

func (*AbortMetadata) XXX_Size added in v0.16.2

func (m *AbortMetadata) XXX_Size() int

func (*AbortMetadata) XXX_Unmarshal added in v0.16.2

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

type AbortMetadataValidationError added in v0.16.2

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

AbortMetadataValidationError is the validation error returned by AbortMetadata.Validate if the designated constraints aren't met.

func (AbortMetadataValidationError) Cause added in v0.16.2

Cause function returns cause value.

func (AbortMetadataValidationError) Error added in v0.16.2

Error satisfies the builtin error interface

func (AbortMetadataValidationError) ErrorName added in v0.16.2

func (e AbortMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (AbortMetadataValidationError) Field added in v0.16.2

Field function returns field value.

func (AbortMetadataValidationError) Key added in v0.16.2

Key function returns key value.

func (AbortMetadataValidationError) Reason added in v0.16.2

Reason function returns reason value.

type ActiveLaunchPlanListRequest added in v0.1.1

type ActiveLaunchPlanListRequest struct {
	// Name of the project that contains the identifiers.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the identifiers belongs to within the project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Indicates the number of resources to be returned.
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// Sort ordering.
	// +optional
	SortBy               *Sort    `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a request structure to list active launch plans within a project/domain.

func (*ActiveLaunchPlanListRequest) Descriptor added in v0.1.1

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

func (*ActiveLaunchPlanListRequest) GetDomain added in v0.1.1

func (m *ActiveLaunchPlanListRequest) GetDomain() string

func (*ActiveLaunchPlanListRequest) GetLimit added in v0.1.1

func (m *ActiveLaunchPlanListRequest) GetLimit() uint32

func (*ActiveLaunchPlanListRequest) GetProject added in v0.1.1

func (m *ActiveLaunchPlanListRequest) GetProject() string

func (*ActiveLaunchPlanListRequest) GetSortBy added in v0.1.1

func (m *ActiveLaunchPlanListRequest) GetSortBy() *Sort

func (*ActiveLaunchPlanListRequest) GetToken added in v0.1.1

func (m *ActiveLaunchPlanListRequest) GetToken() string

func (*ActiveLaunchPlanListRequest) ProtoMessage added in v0.1.1

func (*ActiveLaunchPlanListRequest) ProtoMessage()

func (*ActiveLaunchPlanListRequest) Reset added in v0.1.1

func (m *ActiveLaunchPlanListRequest) Reset()

func (*ActiveLaunchPlanListRequest) String added in v0.1.1

func (m *ActiveLaunchPlanListRequest) String() string

func (*ActiveLaunchPlanListRequest) Validate added in v0.1.1

func (m *ActiveLaunchPlanListRequest) Validate() error

Validate checks the field values on ActiveLaunchPlanListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ActiveLaunchPlanListRequest) XXX_DiscardUnknown added in v0.1.1

func (m *ActiveLaunchPlanListRequest) XXX_DiscardUnknown()

func (*ActiveLaunchPlanListRequest) XXX_Marshal added in v0.1.1

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

func (*ActiveLaunchPlanListRequest) XXX_Merge added in v0.1.1

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

func (*ActiveLaunchPlanListRequest) XXX_Size added in v0.1.1

func (m *ActiveLaunchPlanListRequest) XXX_Size() int

func (*ActiveLaunchPlanListRequest) XXX_Unmarshal added in v0.1.1

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

type ActiveLaunchPlanListRequestValidationError added in v0.1.1

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

ActiveLaunchPlanListRequestValidationError is the validation error returned by ActiveLaunchPlanListRequest.Validate if the designated constraints aren't met.

func (ActiveLaunchPlanListRequestValidationError) Cause added in v0.1.1

Cause function returns cause value.

func (ActiveLaunchPlanListRequestValidationError) Error added in v0.1.1

Error satisfies the builtin error interface

func (ActiveLaunchPlanListRequestValidationError) ErrorName added in v0.1.1

ErrorName returns error name.

func (ActiveLaunchPlanListRequestValidationError) Field added in v0.1.1

Field function returns field value.

func (ActiveLaunchPlanListRequestValidationError) Key added in v0.1.1

Key function returns key value.

func (ActiveLaunchPlanListRequestValidationError) Reason added in v0.1.1

Reason function returns reason value.

type ActiveLaunchPlanRequest added in v0.1.1

type ActiveLaunchPlanRequest struct {
	Id                   *NamedEntityIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Represents a request struct for finding an active launch plan for a given NamedEntityIdentifier

func (*ActiveLaunchPlanRequest) Descriptor added in v0.1.1

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

func (*ActiveLaunchPlanRequest) GetId added in v0.1.1

func (*ActiveLaunchPlanRequest) ProtoMessage added in v0.1.1

func (*ActiveLaunchPlanRequest) ProtoMessage()

func (*ActiveLaunchPlanRequest) Reset added in v0.1.1

func (m *ActiveLaunchPlanRequest) Reset()

func (*ActiveLaunchPlanRequest) String added in v0.1.1

func (m *ActiveLaunchPlanRequest) String() string

func (*ActiveLaunchPlanRequest) Validate added in v0.1.1

func (m *ActiveLaunchPlanRequest) Validate() error

Validate checks the field values on ActiveLaunchPlanRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ActiveLaunchPlanRequest) XXX_DiscardUnknown added in v0.1.1

func (m *ActiveLaunchPlanRequest) XXX_DiscardUnknown()

func (*ActiveLaunchPlanRequest) XXX_Marshal added in v0.1.1

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

func (*ActiveLaunchPlanRequest) XXX_Merge added in v0.1.1

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

func (*ActiveLaunchPlanRequest) XXX_Size added in v0.1.1

func (m *ActiveLaunchPlanRequest) XXX_Size() int

func (*ActiveLaunchPlanRequest) XXX_Unmarshal added in v0.1.1

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

type ActiveLaunchPlanRequestValidationError added in v0.1.1

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

ActiveLaunchPlanRequestValidationError is the validation error returned by ActiveLaunchPlanRequest.Validate if the designated constraints aren't met.

func (ActiveLaunchPlanRequestValidationError) Cause added in v0.1.1

Cause function returns cause value.

func (ActiveLaunchPlanRequestValidationError) Error added in v0.1.1

Error satisfies the builtin error interface

func (ActiveLaunchPlanRequestValidationError) ErrorName added in v0.1.1

ErrorName returns error name.

func (ActiveLaunchPlanRequestValidationError) Field added in v0.1.1

Field function returns field value.

func (ActiveLaunchPlanRequestValidationError) Key added in v0.1.1

Key function returns key value.

func (ActiveLaunchPlanRequestValidationError) Reason added in v0.1.1

Reason function returns reason value.

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

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

func (*Annotations) GetValues

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

func (*Annotations) ProtoMessage

func (*Annotations) ProtoMessage()

func (*Annotations) Reset

func (m *Annotations) Reset()

func (*Annotations) String

func (m *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, an error is returned.

func (*Annotations) XXX_DiscardUnknown

func (m *Annotations) XXX_DiscardUnknown()

func (*Annotations) XXX_Marshal

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

func (*Annotations) XXX_Merge

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

func (*Annotations) XXX_Size

func (m *Annotations) XXX_Size() int

func (*Annotations) XXX_Unmarshal

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

type AnnotationsValidationError

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

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

func (AnnotationsValidationError) Cause

Cause function returns cause value.

func (AnnotationsValidationError) Error

Error satisfies the builtin error interface

func (AnnotationsValidationError) ErrorName

func (e AnnotationsValidationError) ErrorName() string

ErrorName returns error name.

func (AnnotationsValidationError) Field

Field function returns field value.

func (AnnotationsValidationError) Key

Key function returns key value.

func (AnnotationsValidationError) Reason

Reason function returns reason value.

type Auth

type Auth struct {
	// Types that are valid to be assigned to Method:
	//	*Auth_AssumableIamRole
	//	*Auth_KubernetesServiceAccount
	Method               isAuth_Method `protobuf_oneof:"method"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Defines permissions associated with executions created by this launch plan spec.

func (*Auth) Descriptor

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

func (*Auth) GetAssumableIamRole

func (m *Auth) GetAssumableIamRole() string

func (*Auth) GetKubernetesServiceAccount

func (m *Auth) GetKubernetesServiceAccount() string

func (*Auth) GetMethod

func (m *Auth) GetMethod() isAuth_Method

func (*Auth) ProtoMessage

func (*Auth) ProtoMessage()

func (*Auth) Reset

func (m *Auth) Reset()

func (*Auth) String

func (m *Auth) String() string

func (*Auth) Validate

func (m *Auth) Validate() error

Validate checks the field values on Auth with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Auth) XXX_DiscardUnknown

func (m *Auth) XXX_DiscardUnknown()

func (*Auth) XXX_Marshal

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

func (*Auth) XXX_Merge

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

func (*Auth) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Auth) XXX_Size

func (m *Auth) XXX_Size() int

func (*Auth) XXX_Unmarshal

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

type AuthValidationError

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

AuthValidationError is the validation error returned by Auth.Validate if the designated constraints aren't met.

func (AuthValidationError) Cause

func (e AuthValidationError) Cause() error

Cause function returns cause value.

func (AuthValidationError) Error

func (e AuthValidationError) Error() string

Error satisfies the builtin error interface

func (AuthValidationError) ErrorName

func (e AuthValidationError) ErrorName() string

ErrorName returns error name.

func (AuthValidationError) Field

func (e AuthValidationError) Field() string

Field function returns field value.

func (AuthValidationError) Key

func (e AuthValidationError) Key() bool

Key function returns key value.

func (AuthValidationError) Reason

func (e AuthValidationError) Reason() string

Reason function returns reason value.

type Auth_AssumableIamRole

type Auth_AssumableIamRole struct {
	AssumableIamRole string `protobuf:"bytes,1,opt,name=assumable_iam_role,json=assumableIamRole,proto3,oneof"`
}

type Auth_KubernetesServiceAccount

type Auth_KubernetesServiceAccount struct {
	KubernetesServiceAccount string `protobuf:"bytes,2,opt,name=kubernetes_service_account,json=kubernetesServiceAccount,proto3,oneof"`
}

type ClusterResourceAttributes added in v0.16.4

type ClusterResourceAttributes struct {
	// Custom resource attributes which will be applied in cluster resource creation (e.g. quotas).
	// Map keys are the *case-sensitive* names of variables in templatized resource files.
	// Map values should be the custom values which get substituted during resource creation.
	Attributes           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ClusterResourceAttributes) Descriptor added in v0.16.4

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

func (*ClusterResourceAttributes) GetAttributes added in v0.16.4

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

func (*ClusterResourceAttributes) ProtoMessage added in v0.16.4

func (*ClusterResourceAttributes) ProtoMessage()

func (*ClusterResourceAttributes) Reset added in v0.16.4

func (m *ClusterResourceAttributes) Reset()

func (*ClusterResourceAttributes) String added in v0.16.4

func (m *ClusterResourceAttributes) String() string

func (*ClusterResourceAttributes) Validate added in v0.16.4

func (m *ClusterResourceAttributes) Validate() error

Validate checks the field values on ClusterResourceAttributes with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ClusterResourceAttributes) XXX_DiscardUnknown added in v0.16.4

func (m *ClusterResourceAttributes) XXX_DiscardUnknown()

func (*ClusterResourceAttributes) XXX_Marshal added in v0.16.4

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

func (*ClusterResourceAttributes) XXX_Merge added in v0.16.4

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

func (*ClusterResourceAttributes) XXX_Size added in v0.16.4

func (m *ClusterResourceAttributes) XXX_Size() int

func (*ClusterResourceAttributes) XXX_Unmarshal added in v0.16.4

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

type ClusterResourceAttributesValidationError added in v0.16.4

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

ClusterResourceAttributesValidationError is the validation error returned by ClusterResourceAttributes.Validate if the designated constraints aren't met.

func (ClusterResourceAttributesValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (ClusterResourceAttributesValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (ClusterResourceAttributesValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (ClusterResourceAttributesValidationError) Field added in v0.16.4

Field function returns field value.

func (ClusterResourceAttributesValidationError) Key added in v0.16.4

Key function returns key value.

func (ClusterResourceAttributesValidationError) Reason added in v0.16.4

Reason function returns reason value.

type Domain

type Domain struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Display name.
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Domain) Descriptor

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

func (*Domain) GetId

func (m *Domain) GetId() string

func (*Domain) GetName

func (m *Domain) GetName() string

func (*Domain) ProtoMessage

func (*Domain) ProtoMessage()

func (*Domain) Reset

func (m *Domain) Reset()

func (*Domain) String

func (m *Domain) String() string

func (*Domain) Validate

func (m *Domain) Validate() error

Validate checks the field values on Domain with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Domain) XXX_DiscardUnknown

func (m *Domain) XXX_DiscardUnknown()

func (*Domain) XXX_Marshal

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

func (*Domain) XXX_Merge

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

func (*Domain) XXX_Size

func (m *Domain) XXX_Size() int

func (*Domain) XXX_Unmarshal

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

type DomainValidationError

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

DomainValidationError is the validation error returned by Domain.Validate if the designated constraints aren't met.

func (DomainValidationError) Cause

func (e DomainValidationError) Cause() error

Cause function returns cause value.

func (DomainValidationError) Error

func (e DomainValidationError) Error() string

Error satisfies the builtin error interface

func (DomainValidationError) ErrorName

func (e DomainValidationError) ErrorName() string

ErrorName returns error name.

func (DomainValidationError) Field

func (e DomainValidationError) Field() string

Field function returns field value.

func (DomainValidationError) Key

func (e DomainValidationError) Key() bool

Key function returns key value.

func (DomainValidationError) Reason

func (e DomainValidationError) Reason() string

Reason function returns reason value.

type EmailMessage

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

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

func (*EmailMessage) Descriptor

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

func (*EmailMessage) GetBody

func (m *EmailMessage) GetBody() string

func (*EmailMessage) GetRecipientsEmail

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

func (*EmailMessage) GetSenderEmail

func (m *EmailMessage) GetSenderEmail() string

func (*EmailMessage) GetSubjectLine

func (m *EmailMessage) GetSubjectLine() string

func (*EmailMessage) ProtoMessage

func (*EmailMessage) ProtoMessage()

func (*EmailMessage) Reset

func (m *EmailMessage) Reset()

func (*EmailMessage) String

func (m *EmailMessage) String() string

func (*EmailMessage) Validate

func (m *EmailMessage) Validate() error

Validate checks the field values on EmailMessage with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*EmailMessage) XXX_DiscardUnknown

func (m *EmailMessage) XXX_DiscardUnknown()

func (*EmailMessage) XXX_Marshal

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

func (*EmailMessage) XXX_Merge

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

func (*EmailMessage) XXX_Size

func (m *EmailMessage) XXX_Size() int

func (*EmailMessage) XXX_Unmarshal

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

type EmailMessageValidationError

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

EmailMessageValidationError is the validation error returned by EmailMessage.Validate if the designated constraints aren't met.

func (EmailMessageValidationError) Cause

Cause function returns cause value.

func (EmailMessageValidationError) Error

Error satisfies the builtin error interface

func (EmailMessageValidationError) ErrorName

func (e EmailMessageValidationError) ErrorName() string

ErrorName returns error name.

func (EmailMessageValidationError) Field

Field function returns field value.

func (EmailMessageValidationError) Key

Key function returns key value.

func (EmailMessageValidationError) Reason

Reason function returns reason value.

type EmailNotification

type EmailNotification struct {
	// The list of email addresses recipients for this notification.
	RecipientsEmail      []string `protobuf:"bytes,1,rep,name=recipients_email,json=recipientsEmail,proto3" json:"recipients_email,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmailNotification) Descriptor

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

func (*EmailNotification) GetRecipientsEmail

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

func (*EmailNotification) ProtoMessage

func (*EmailNotification) ProtoMessage()

func (*EmailNotification) Reset

func (m *EmailNotification) Reset()

func (*EmailNotification) String

func (m *EmailNotification) String() string

func (*EmailNotification) Validate

func (m *EmailNotification) Validate() error

Validate checks the field values on EmailNotification with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*EmailNotification) XXX_DiscardUnknown

func (m *EmailNotification) XXX_DiscardUnknown()

func (*EmailNotification) XXX_Marshal

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

func (*EmailNotification) XXX_Merge

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

func (*EmailNotification) XXX_Size

func (m *EmailNotification) XXX_Size() int

func (*EmailNotification) XXX_Unmarshal

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

type EmailNotificationValidationError

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

EmailNotificationValidationError is the validation error returned by EmailNotification.Validate if the designated constraints aren't met.

func (EmailNotificationValidationError) Cause

Cause function returns cause value.

func (EmailNotificationValidationError) Error

Error satisfies the builtin error interface

func (EmailNotificationValidationError) ErrorName

ErrorName returns error name.

func (EmailNotificationValidationError) Field

Field function returns field value.

func (EmailNotificationValidationError) Key

Key function returns key value.

func (EmailNotificationValidationError) Reason

Reason function returns reason value.

type EventErrorAlreadyInTerminalState

type EventErrorAlreadyInTerminalState struct {
	CurrentPhase         string   `protobuf:"bytes,1,opt,name=current_phase,json=currentPhase,proto3" json:"current_phase,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventErrorAlreadyInTerminalState) Descriptor

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

func (*EventErrorAlreadyInTerminalState) GetCurrentPhase

func (m *EventErrorAlreadyInTerminalState) GetCurrentPhase() string

func (*EventErrorAlreadyInTerminalState) ProtoMessage

func (*EventErrorAlreadyInTerminalState) ProtoMessage()

func (*EventErrorAlreadyInTerminalState) Reset

func (*EventErrorAlreadyInTerminalState) String

func (*EventErrorAlreadyInTerminalState) Validate

Validate checks the field values on EventErrorAlreadyInTerminalState with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*EventErrorAlreadyInTerminalState) XXX_DiscardUnknown

func (m *EventErrorAlreadyInTerminalState) XXX_DiscardUnknown()

func (*EventErrorAlreadyInTerminalState) XXX_Marshal

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

func (*EventErrorAlreadyInTerminalState) XXX_Merge

func (*EventErrorAlreadyInTerminalState) XXX_Size

func (m *EventErrorAlreadyInTerminalState) XXX_Size() int

func (*EventErrorAlreadyInTerminalState) XXX_Unmarshal

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

type EventErrorAlreadyInTerminalStateValidationError

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

EventErrorAlreadyInTerminalStateValidationError is the validation error returned by EventErrorAlreadyInTerminalState.Validate if the designated constraints aren't met.

func (EventErrorAlreadyInTerminalStateValidationError) Cause

Cause function returns cause value.

func (EventErrorAlreadyInTerminalStateValidationError) Error

Error satisfies the builtin error interface

func (EventErrorAlreadyInTerminalStateValidationError) ErrorName

ErrorName returns error name.

func (EventErrorAlreadyInTerminalStateValidationError) Field

Field function returns field value.

func (EventErrorAlreadyInTerminalStateValidationError) Key

Key function returns key value.

func (EventErrorAlreadyInTerminalStateValidationError) Reason

Reason function returns reason value.

type EventFailureReason

type EventFailureReason struct {
	// Types that are valid to be assigned to Reason:
	//	*EventFailureReason_AlreadyInTerminalState
	Reason               isEventFailureReason_Reason `protobuf_oneof:"reason"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*EventFailureReason) Descriptor

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

func (*EventFailureReason) GetAlreadyInTerminalState

func (m *EventFailureReason) GetAlreadyInTerminalState() *EventErrorAlreadyInTerminalState

func (*EventFailureReason) GetReason

func (m *EventFailureReason) GetReason() isEventFailureReason_Reason

func (*EventFailureReason) ProtoMessage

func (*EventFailureReason) ProtoMessage()

func (*EventFailureReason) Reset

func (m *EventFailureReason) Reset()

func (*EventFailureReason) String

func (m *EventFailureReason) String() string

func (*EventFailureReason) Validate

func (m *EventFailureReason) Validate() error

Validate checks the field values on EventFailureReason with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*EventFailureReason) XXX_DiscardUnknown

func (m *EventFailureReason) XXX_DiscardUnknown()

func (*EventFailureReason) XXX_Marshal

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

func (*EventFailureReason) XXX_Merge

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

func (*EventFailureReason) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*EventFailureReason) XXX_Size

func (m *EventFailureReason) XXX_Size() int

func (*EventFailureReason) XXX_Unmarshal

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

type EventFailureReasonValidationError

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

EventFailureReasonValidationError is the validation error returned by EventFailureReason.Validate if the designated constraints aren't met.

func (EventFailureReasonValidationError) Cause

Cause function returns cause value.

func (EventFailureReasonValidationError) Error

Error satisfies the builtin error interface

func (EventFailureReasonValidationError) ErrorName

ErrorName returns error name.

func (EventFailureReasonValidationError) Field

Field function returns field value.

func (EventFailureReasonValidationError) Key

Key function returns key value.

func (EventFailureReasonValidationError) Reason

Reason function returns reason value.

type EventFailureReason_AlreadyInTerminalState

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

type Execution

type Execution struct {
	// Unique identifier of the workflow execution.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User-provided configuration and inputs for launching the execution.
	Spec *ExecutionSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Execution results.
	Closure              *ExecutionClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*Execution) Descriptor

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

func (*Execution) GetClosure

func (m *Execution) GetClosure() *ExecutionClosure

func (*Execution) GetId

func (*Execution) GetSpec

func (m *Execution) GetSpec() *ExecutionSpec

func (*Execution) ProtoMessage

func (*Execution) ProtoMessage()

func (*Execution) Reset

func (m *Execution) Reset()

func (*Execution) String

func (m *Execution) String() string

func (*Execution) Validate

func (m *Execution) Validate() error

Validate checks the field values on Execution with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Execution) XXX_DiscardUnknown

func (m *Execution) XXX_DiscardUnknown()

func (*Execution) XXX_Marshal

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

func (*Execution) XXX_Merge

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

func (*Execution) XXX_Size

func (m *Execution) XXX_Size() int

func (*Execution) XXX_Unmarshal

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

type ExecutionClosure

type ExecutionClosure struct {
	// A result produced by a terminated execution.
	// A pending (non-terminal) execution will not have any output result.
	//
	// Types that are valid to be assigned to OutputResult:
	//	*ExecutionClosure_Outputs
	//	*ExecutionClosure_Error
	//	*ExecutionClosure_AbortCause
	//	*ExecutionClosure_AbortMetadata
	OutputResult isExecutionClosure_OutputResult `protobuf_oneof:"output_result"`
	// Inputs computed and passed for execution.
	// computed_inputs depends on inputs in ExecutionSpec, fixed and default inputs in launch plan
	ComputedInputs *core.LiteralMap `protobuf:"bytes,3,opt,name=computed_inputs,json=computedInputs,proto3" json:"computed_inputs,omitempty"` // Deprecated: Do not use.
	// Most recent recorded phase for the execution.
	Phase core.WorkflowExecution_Phase `protobuf:"varint,4,opt,name=phase,proto3,enum=flyteidl.core.WorkflowExecution_Phase" json:"phase,omitempty"`
	// Reported ime at which the execution began running.
	StartedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// The amount of time the execution spent running.
	Duration *duration.Duration `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// Reported time at which the execution was created.
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Reported time at which the execution was last updated.
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// The notification settings to use after merging the CreateExecutionRequest and the launch plan
	// notification settings. An execution launched with notifications will always prefer that definition
	// to notifications defined statically in a launch plan.
	Notifications []*Notification `protobuf:"bytes,9,rep,name=notifications,proto3" json:"notifications,omitempty"`
	// Identifies the workflow definition for this execution.
	WorkflowId           *core.Identifier `protobuf:"bytes,11,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Encapsulates the results of the Execution

func (*ExecutionClosure) Descriptor

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

func (*ExecutionClosure) GetAbortCause deprecated

func (m *ExecutionClosure) GetAbortCause() string

Deprecated: Do not use.

func (*ExecutionClosure) GetAbortMetadata added in v0.16.2

func (m *ExecutionClosure) GetAbortMetadata() *AbortMetadata

func (*ExecutionClosure) GetComputedInputs deprecated

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

Deprecated: Do not use.

func (*ExecutionClosure) GetCreatedAt

func (m *ExecutionClosure) GetCreatedAt() *timestamp.Timestamp

func (*ExecutionClosure) GetDuration

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

func (*ExecutionClosure) GetError

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

func (*ExecutionClosure) GetNotifications

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

func (*ExecutionClosure) GetOutputResult

func (m *ExecutionClosure) GetOutputResult() isExecutionClosure_OutputResult

func (*ExecutionClosure) GetOutputs

func (m *ExecutionClosure) GetOutputs() *LiteralMapBlob

func (*ExecutionClosure) GetPhase

func (*ExecutionClosure) GetStartedAt

func (m *ExecutionClosure) GetStartedAt() *timestamp.Timestamp

func (*ExecutionClosure) GetUpdatedAt

func (m *ExecutionClosure) GetUpdatedAt() *timestamp.Timestamp

func (*ExecutionClosure) GetWorkflowId

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

func (*ExecutionClosure) ProtoMessage

func (*ExecutionClosure) ProtoMessage()

func (*ExecutionClosure) Reset

func (m *ExecutionClosure) Reset()

func (*ExecutionClosure) String

func (m *ExecutionClosure) String() string

func (*ExecutionClosure) Validate

func (m *ExecutionClosure) Validate() error

Validate checks the field values on ExecutionClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionClosure) XXX_DiscardUnknown

func (m *ExecutionClosure) XXX_DiscardUnknown()

func (*ExecutionClosure) XXX_Marshal

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

func (*ExecutionClosure) XXX_Merge

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

func (*ExecutionClosure) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExecutionClosure) XXX_Size

func (m *ExecutionClosure) XXX_Size() int

func (*ExecutionClosure) XXX_Unmarshal

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

type ExecutionClosureValidationError

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

ExecutionClosureValidationError is the validation error returned by ExecutionClosure.Validate if the designated constraints aren't met.

func (ExecutionClosureValidationError) Cause

Cause function returns cause value.

func (ExecutionClosureValidationError) Error

Error satisfies the builtin error interface

func (ExecutionClosureValidationError) ErrorName

ErrorName returns error name.

func (ExecutionClosureValidationError) Field

Field function returns field value.

func (ExecutionClosureValidationError) Key

Key function returns key value.

func (ExecutionClosureValidationError) Reason

Reason function returns reason value.

type ExecutionClosure_AbortCause

type ExecutionClosure_AbortCause struct {
	AbortCause string `protobuf:"bytes,10,opt,name=abort_cause,json=abortCause,proto3,oneof"`
}

type ExecutionClosure_AbortMetadata added in v0.16.2

type ExecutionClosure_AbortMetadata struct {
	AbortMetadata *AbortMetadata `protobuf:"bytes,12,opt,name=abort_metadata,json=abortMetadata,proto3,oneof"`
}

type ExecutionClosure_Error

type ExecutionClosure_Error struct {
	Error *core.ExecutionError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type ExecutionClosure_Outputs

type ExecutionClosure_Outputs struct {
	Outputs *LiteralMapBlob `protobuf:"bytes,1,opt,name=outputs,proto3,oneof"`
}

type ExecutionCreateRequest

type ExecutionCreateRequest struct {
	// Name of the project the execution belongs to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the execution belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// User provided value for the resource.
	// If none is provided the system will generate a unique string.
	// +optional
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Additional fields necessary to launch the execution.
	Spec *ExecutionSpec `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// The inputs required to start the execution. All required inputs must be
	// included in this map. If not required and not provided, defaults apply.
	Inputs               *core.LiteralMap `protobuf:"bytes,5,opt,name=inputs,proto3" json:"inputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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

func (*ExecutionCreateRequest) Descriptor

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

func (*ExecutionCreateRequest) GetDomain

func (m *ExecutionCreateRequest) GetDomain() string

func (*ExecutionCreateRequest) GetInputs added in v0.15.0

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

func (*ExecutionCreateRequest) GetName

func (m *ExecutionCreateRequest) GetName() string

func (*ExecutionCreateRequest) GetProject

func (m *ExecutionCreateRequest) GetProject() string

func (*ExecutionCreateRequest) GetSpec

func (m *ExecutionCreateRequest) GetSpec() *ExecutionSpec

func (*ExecutionCreateRequest) ProtoMessage

func (*ExecutionCreateRequest) ProtoMessage()

func (*ExecutionCreateRequest) Reset

func (m *ExecutionCreateRequest) Reset()

func (*ExecutionCreateRequest) String

func (m *ExecutionCreateRequest) String() string

func (*ExecutionCreateRequest) Validate

func (m *ExecutionCreateRequest) Validate() error

Validate checks the field values on ExecutionCreateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionCreateRequest) XXX_DiscardUnknown

func (m *ExecutionCreateRequest) XXX_DiscardUnknown()

func (*ExecutionCreateRequest) XXX_Marshal

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

func (*ExecutionCreateRequest) XXX_Merge

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

func (*ExecutionCreateRequest) XXX_Size

func (m *ExecutionCreateRequest) XXX_Size() int

func (*ExecutionCreateRequest) XXX_Unmarshal

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

type ExecutionCreateRequestValidationError

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

ExecutionCreateRequestValidationError is the validation error returned by ExecutionCreateRequest.Validate if the designated constraints aren't met.

func (ExecutionCreateRequestValidationError) Cause

Cause function returns cause value.

func (ExecutionCreateRequestValidationError) Error

Error satisfies the builtin error interface

func (ExecutionCreateRequestValidationError) ErrorName

ErrorName returns error name.

func (ExecutionCreateRequestValidationError) Field

Field function returns field value.

func (ExecutionCreateRequestValidationError) Key

Key function returns key value.

func (ExecutionCreateRequestValidationError) Reason

Reason function returns reason value.

type ExecutionCreateResponse

type ExecutionCreateResponse struct {
	Id                   *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

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

func (*ExecutionCreateResponse) Descriptor

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

func (*ExecutionCreateResponse) GetId

func (*ExecutionCreateResponse) ProtoMessage

func (*ExecutionCreateResponse) ProtoMessage()

func (*ExecutionCreateResponse) Reset

func (m *ExecutionCreateResponse) Reset()

func (*ExecutionCreateResponse) String

func (m *ExecutionCreateResponse) String() string

func (*ExecutionCreateResponse) Validate

func (m *ExecutionCreateResponse) Validate() error

Validate checks the field values on ExecutionCreateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionCreateResponse) XXX_DiscardUnknown

func (m *ExecutionCreateResponse) XXX_DiscardUnknown()

func (*ExecutionCreateResponse) XXX_Marshal

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

func (*ExecutionCreateResponse) XXX_Merge

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

func (*ExecutionCreateResponse) XXX_Size

func (m *ExecutionCreateResponse) XXX_Size() int

func (*ExecutionCreateResponse) XXX_Unmarshal

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

type ExecutionCreateResponseValidationError

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

ExecutionCreateResponseValidationError is the validation error returned by ExecutionCreateResponse.Validate if the designated constraints aren't met.

func (ExecutionCreateResponseValidationError) Cause

Cause function returns cause value.

func (ExecutionCreateResponseValidationError) Error

Error satisfies the builtin error interface

func (ExecutionCreateResponseValidationError) ErrorName

ErrorName returns error name.

func (ExecutionCreateResponseValidationError) Field

Field function returns field value.

func (ExecutionCreateResponseValidationError) Key

Key function returns key value.

func (ExecutionCreateResponseValidationError) Reason

Reason function returns reason value.

type ExecutionList

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

Used as a response for request to list executions.

func (*ExecutionList) Descriptor

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

func (*ExecutionList) GetExecutions

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

func (*ExecutionList) GetToken

func (m *ExecutionList) GetToken() string

func (*ExecutionList) ProtoMessage

func (*ExecutionList) ProtoMessage()

func (*ExecutionList) Reset

func (m *ExecutionList) Reset()

func (*ExecutionList) String

func (m *ExecutionList) String() string

func (*ExecutionList) Validate

func (m *ExecutionList) Validate() error

Validate checks the field values on ExecutionList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionList) XXX_DiscardUnknown

func (m *ExecutionList) XXX_DiscardUnknown()

func (*ExecutionList) XXX_Marshal

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

func (*ExecutionList) XXX_Merge

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

func (*ExecutionList) XXX_Size

func (m *ExecutionList) XXX_Size() int

func (*ExecutionList) XXX_Unmarshal

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

type ExecutionListValidationError

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

ExecutionListValidationError is the validation error returned by ExecutionList.Validate if the designated constraints aren't met.

func (ExecutionListValidationError) Cause

Cause function returns cause value.

func (ExecutionListValidationError) Error

Error satisfies the builtin error interface

func (ExecutionListValidationError) ErrorName

func (e ExecutionListValidationError) ErrorName() string

ErrorName returns error name.

func (ExecutionListValidationError) Field

Field function returns field value.

func (ExecutionListValidationError) Key

Key function returns key value.

func (ExecutionListValidationError) Reason

Reason function returns reason value.

type ExecutionMetadata

type ExecutionMetadata struct {
	Mode ExecutionMetadata_ExecutionMode `protobuf:"varint,1,opt,name=mode,proto3,enum=flyteidl.admin.ExecutionMetadata_ExecutionMode" json:"mode,omitempty"`
	// Identifier of the entity that triggered this execution.
	// For systems using back-end authentication any value set here will be discarded in favor of the
	// authenticated user context.
	Principal string `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	// Indicates the "nestedness" of this execution.
	// If a user launches a workflow execution, the default nesting is 0.
	// If this execution further launches a workflow (child workflow), the nesting level is incremented by 0 => 1
	// Generally, if workflow at nesting level k launches a workflow then the child workflow will have
	// nesting = k + 1.
	Nesting uint32 `protobuf:"varint,3,opt,name=nesting,proto3" json:"nesting,omitempty"`
	// For scheduled executions, the requested time for execution for this specific schedule invocation.
	ScheduledAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// Which subworkflow node launched this execution
	ParentNodeExecution *core.NodeExecutionIdentifier `protobuf:"bytes,5,opt,name=parent_node_execution,json=parentNodeExecution,proto3" json:"parent_node_execution,omitempty"`
	// Optional, a reference workflow execution related to this execution.
	// In the case of a relaunch, this references the original workflow execution.
	ReferenceExecution   *core.WorkflowExecutionIdentifier `protobuf:"bytes,16,opt,name=reference_execution,json=referenceExecution,proto3" json:"reference_execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

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

func (*ExecutionMetadata) Descriptor

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

func (*ExecutionMetadata) GetMode

func (*ExecutionMetadata) GetNesting

func (m *ExecutionMetadata) GetNesting() uint32

func (*ExecutionMetadata) GetParentNodeExecution

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

func (*ExecutionMetadata) GetPrincipal

func (m *ExecutionMetadata) GetPrincipal() string

func (*ExecutionMetadata) GetReferenceExecution

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

func (*ExecutionMetadata) GetScheduledAt

func (m *ExecutionMetadata) GetScheduledAt() *timestamp.Timestamp

func (*ExecutionMetadata) ProtoMessage

func (*ExecutionMetadata) ProtoMessage()

func (*ExecutionMetadata) Reset

func (m *ExecutionMetadata) Reset()

func (*ExecutionMetadata) String

func (m *ExecutionMetadata) String() string

func (*ExecutionMetadata) Validate

func (m *ExecutionMetadata) Validate() error

Validate checks the field values on ExecutionMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionMetadata) XXX_DiscardUnknown

func (m *ExecutionMetadata) XXX_DiscardUnknown()

func (*ExecutionMetadata) XXX_Marshal

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

func (*ExecutionMetadata) XXX_Merge

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

func (*ExecutionMetadata) XXX_Size

func (m *ExecutionMetadata) XXX_Size() int

func (*ExecutionMetadata) XXX_Unmarshal

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

type ExecutionMetadataValidationError

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

ExecutionMetadataValidationError is the validation error returned by ExecutionMetadata.Validate if the designated constraints aren't met.

func (ExecutionMetadataValidationError) Cause

Cause function returns cause value.

func (ExecutionMetadataValidationError) Error

Error satisfies the builtin error interface

func (ExecutionMetadataValidationError) ErrorName

ErrorName returns error name.

func (ExecutionMetadataValidationError) Field

Field function returns field value.

func (ExecutionMetadataValidationError) Key

Key function returns key value.

func (ExecutionMetadataValidationError) Reason

Reason function returns reason value.

type ExecutionMetadata_ExecutionMode

type ExecutionMetadata_ExecutionMode int32

The method by which this execution was launched.

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

func (ExecutionMetadata_ExecutionMode) EnumDescriptor

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

func (ExecutionMetadata_ExecutionMode) String

type ExecutionQueueAttributes added in v0.16.4

type ExecutionQueueAttributes struct {
	// Tags used for assigning execution queues for tasks defined within this project.
	Tags                 []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecutionQueueAttributes) Descriptor added in v0.16.4

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

func (*ExecutionQueueAttributes) GetTags added in v0.16.4

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

func (*ExecutionQueueAttributes) ProtoMessage added in v0.16.4

func (*ExecutionQueueAttributes) ProtoMessage()

func (*ExecutionQueueAttributes) Reset added in v0.16.4

func (m *ExecutionQueueAttributes) Reset()

func (*ExecutionQueueAttributes) String added in v0.16.4

func (m *ExecutionQueueAttributes) String() string

func (*ExecutionQueueAttributes) Validate added in v0.16.4

func (m *ExecutionQueueAttributes) Validate() error

Validate checks the field values on ExecutionQueueAttributes with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionQueueAttributes) XXX_DiscardUnknown added in v0.16.4

func (m *ExecutionQueueAttributes) XXX_DiscardUnknown()

func (*ExecutionQueueAttributes) XXX_Marshal added in v0.16.4

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

func (*ExecutionQueueAttributes) XXX_Merge added in v0.16.4

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

func (*ExecutionQueueAttributes) XXX_Size added in v0.16.4

func (m *ExecutionQueueAttributes) XXX_Size() int

func (*ExecutionQueueAttributes) XXX_Unmarshal added in v0.16.4

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

type ExecutionQueueAttributesValidationError added in v0.16.4

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

ExecutionQueueAttributesValidationError is the validation error returned by ExecutionQueueAttributes.Validate if the designated constraints aren't met.

func (ExecutionQueueAttributesValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (ExecutionQueueAttributesValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (ExecutionQueueAttributesValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (ExecutionQueueAttributesValidationError) Field added in v0.16.4

Field function returns field value.

func (ExecutionQueueAttributesValidationError) Key added in v0.16.4

Key function returns key value.

func (ExecutionQueueAttributesValidationError) Reason added in v0.16.4

Reason function returns reason value.

type ExecutionRelaunchRequest

type ExecutionRelaunchRequest struct {
	// Identifier of the workflow execution to relaunch.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User provided value for the relaunched execution.
	// If none is provided the system will generate a unique string.
	// +optional
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request to relaunch the referenced execution.

func (*ExecutionRelaunchRequest) Descriptor

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

func (*ExecutionRelaunchRequest) GetId

func (*ExecutionRelaunchRequest) GetName

func (m *ExecutionRelaunchRequest) GetName() string

func (*ExecutionRelaunchRequest) ProtoMessage

func (*ExecutionRelaunchRequest) ProtoMessage()

func (*ExecutionRelaunchRequest) Reset

func (m *ExecutionRelaunchRequest) Reset()

func (*ExecutionRelaunchRequest) String

func (m *ExecutionRelaunchRequest) String() string

func (*ExecutionRelaunchRequest) Validate

func (m *ExecutionRelaunchRequest) Validate() error

Validate checks the field values on ExecutionRelaunchRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionRelaunchRequest) XXX_DiscardUnknown

func (m *ExecutionRelaunchRequest) XXX_DiscardUnknown()

func (*ExecutionRelaunchRequest) XXX_Marshal

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

func (*ExecutionRelaunchRequest) XXX_Merge

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

func (*ExecutionRelaunchRequest) XXX_Size

func (m *ExecutionRelaunchRequest) XXX_Size() int

func (*ExecutionRelaunchRequest) XXX_Unmarshal

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

type ExecutionRelaunchRequestValidationError

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

ExecutionRelaunchRequestValidationError is the validation error returned by ExecutionRelaunchRequest.Validate if the designated constraints aren't met.

func (ExecutionRelaunchRequestValidationError) Cause

Cause function returns cause value.

func (ExecutionRelaunchRequestValidationError) Error

Error satisfies the builtin error interface

func (ExecutionRelaunchRequestValidationError) ErrorName

ErrorName returns error name.

func (ExecutionRelaunchRequestValidationError) Field

Field function returns field value.

func (ExecutionRelaunchRequestValidationError) Key

Key function returns key value.

func (ExecutionRelaunchRequestValidationError) Reason

Reason function returns reason value.

type ExecutionSpec

type ExecutionSpec struct {
	// Launch plan to be executed
	LaunchPlan *core.Identifier `protobuf:"bytes,1,opt,name=launch_plan,json=launchPlan,proto3" json:"launch_plan,omitempty"`
	// Input values to be passed for the execution
	Inputs *core.LiteralMap `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"` // Deprecated: Do not use.
	// Metadata for the execution
	Metadata *ExecutionMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are valid to be assigned to NotificationOverrides:
	//	*ExecutionSpec_Notifications
	//	*ExecutionSpec_DisableAll
	NotificationOverrides isExecutionSpec_NotificationOverrides `protobuf_oneof:"notification_overrides"`
	// Labels to apply to the execution resource.
	Labels *Labels `protobuf:"bytes,7,opt,name=labels,proto3" json:"labels,omitempty"`
	// Annotations to apply to the execution resource.
	Annotations          *Annotations `protobuf:"bytes,8,opt,name=annotations,proto3" json:"annotations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*ExecutionSpec) Descriptor

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

func (*ExecutionSpec) GetAnnotations

func (m *ExecutionSpec) GetAnnotations() *Annotations

func (*ExecutionSpec) GetDisableAll

func (m *ExecutionSpec) GetDisableAll() bool

func (*ExecutionSpec) GetInputs deprecated

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

Deprecated: Do not use.

func (*ExecutionSpec) GetLabels

func (m *ExecutionSpec) GetLabels() *Labels

func (*ExecutionSpec) GetLaunchPlan

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

func (*ExecutionSpec) GetMetadata

func (m *ExecutionSpec) GetMetadata() *ExecutionMetadata

func (*ExecutionSpec) GetNotificationOverrides

func (m *ExecutionSpec) GetNotificationOverrides() isExecutionSpec_NotificationOverrides

func (*ExecutionSpec) GetNotifications

func (m *ExecutionSpec) GetNotifications() *NotificationList

func (*ExecutionSpec) ProtoMessage

func (*ExecutionSpec) ProtoMessage()

func (*ExecutionSpec) Reset

func (m *ExecutionSpec) Reset()

func (*ExecutionSpec) String

func (m *ExecutionSpec) String() string

func (*ExecutionSpec) Validate

func (m *ExecutionSpec) Validate() error

Validate checks the field values on ExecutionSpec with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionSpec) XXX_DiscardUnknown

func (m *ExecutionSpec) XXX_DiscardUnknown()

func (*ExecutionSpec) XXX_Marshal

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

func (*ExecutionSpec) XXX_Merge

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

func (*ExecutionSpec) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExecutionSpec) XXX_Size

func (m *ExecutionSpec) XXX_Size() int

func (*ExecutionSpec) XXX_Unmarshal

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

type ExecutionSpecValidationError

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

ExecutionSpecValidationError is the validation error returned by ExecutionSpec.Validate if the designated constraints aren't met.

func (ExecutionSpecValidationError) Cause

Cause function returns cause value.

func (ExecutionSpecValidationError) Error

Error satisfies the builtin error interface

func (ExecutionSpecValidationError) ErrorName

func (e ExecutionSpecValidationError) ErrorName() string

ErrorName returns error name.

func (ExecutionSpecValidationError) Field

Field function returns field value.

func (ExecutionSpecValidationError) Key

Key function returns key value.

func (ExecutionSpecValidationError) Reason

Reason function returns reason value.

type ExecutionSpec_DisableAll

type ExecutionSpec_DisableAll struct {
	DisableAll bool `protobuf:"varint,6,opt,name=disable_all,json=disableAll,proto3,oneof"`
}

type ExecutionSpec_Notifications

type ExecutionSpec_Notifications struct {
	Notifications *NotificationList `protobuf:"bytes,5,opt,name=notifications,proto3,oneof"`
}

type ExecutionTerminateRequest

type ExecutionTerminateRequest struct {
	// Uniquely identifies the individual workflow execution to be terminated.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Optional reason for aborting.
	Cause                string   `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ExecutionTerminateRequest) Descriptor

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

func (*ExecutionTerminateRequest) GetCause

func (m *ExecutionTerminateRequest) GetCause() string

func (*ExecutionTerminateRequest) GetId

func (*ExecutionTerminateRequest) ProtoMessage

func (*ExecutionTerminateRequest) ProtoMessage()

func (*ExecutionTerminateRequest) Reset

func (m *ExecutionTerminateRequest) Reset()

func (*ExecutionTerminateRequest) String

func (m *ExecutionTerminateRequest) String() string

func (*ExecutionTerminateRequest) Validate

func (m *ExecutionTerminateRequest) Validate() error

Validate checks the field values on ExecutionTerminateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionTerminateRequest) XXX_DiscardUnknown

func (m *ExecutionTerminateRequest) XXX_DiscardUnknown()

func (*ExecutionTerminateRequest) XXX_Marshal

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

func (*ExecutionTerminateRequest) XXX_Merge

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

func (*ExecutionTerminateRequest) XXX_Size

func (m *ExecutionTerminateRequest) XXX_Size() int

func (*ExecutionTerminateRequest) XXX_Unmarshal

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

type ExecutionTerminateRequestValidationError

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

ExecutionTerminateRequestValidationError is the validation error returned by ExecutionTerminateRequest.Validate if the designated constraints aren't met.

func (ExecutionTerminateRequestValidationError) Cause

Cause function returns cause value.

func (ExecutionTerminateRequestValidationError) Error

Error satisfies the builtin error interface

func (ExecutionTerminateRequestValidationError) ErrorName

ErrorName returns error name.

func (ExecutionTerminateRequestValidationError) Field

Field function returns field value.

func (ExecutionTerminateRequestValidationError) Key

Key function returns key value.

func (ExecutionTerminateRequestValidationError) Reason

Reason function returns reason value.

type ExecutionTerminateResponse

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

func (*ExecutionTerminateResponse) Descriptor

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

func (*ExecutionTerminateResponse) ProtoMessage

func (*ExecutionTerminateResponse) ProtoMessage()

func (*ExecutionTerminateResponse) Reset

func (m *ExecutionTerminateResponse) Reset()

func (*ExecutionTerminateResponse) String

func (m *ExecutionTerminateResponse) String() string

func (*ExecutionTerminateResponse) Validate

func (m *ExecutionTerminateResponse) Validate() error

Validate checks the field values on ExecutionTerminateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExecutionTerminateResponse) XXX_DiscardUnknown

func (m *ExecutionTerminateResponse) XXX_DiscardUnknown()

func (*ExecutionTerminateResponse) XXX_Marshal

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

func (*ExecutionTerminateResponse) XXX_Merge

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

func (*ExecutionTerminateResponse) XXX_Size

func (m *ExecutionTerminateResponse) XXX_Size() int

func (*ExecutionTerminateResponse) XXX_Unmarshal

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

type ExecutionTerminateResponseValidationError

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

ExecutionTerminateResponseValidationError is the validation error returned by ExecutionTerminateResponse.Validate if the designated constraints aren't met.

func (ExecutionTerminateResponseValidationError) Cause

Cause function returns cause value.

func (ExecutionTerminateResponseValidationError) Error

Error satisfies the builtin error interface

func (ExecutionTerminateResponseValidationError) ErrorName

ErrorName returns error name.

func (ExecutionTerminateResponseValidationError) Field

Field function returns field value.

func (ExecutionTerminateResponseValidationError) Key

Key function returns key value.

func (ExecutionTerminateResponseValidationError) Reason

Reason function returns reason value.

type ExecutionValidationError

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

ExecutionValidationError is the validation error returned by Execution.Validate if the designated constraints aren't met.

func (ExecutionValidationError) Cause

func (e ExecutionValidationError) Cause() error

Cause function returns cause value.

func (ExecutionValidationError) Error

func (e ExecutionValidationError) Error() string

Error satisfies the builtin error interface

func (ExecutionValidationError) ErrorName

func (e ExecutionValidationError) ErrorName() string

ErrorName returns error name.

func (ExecutionValidationError) Field

func (e ExecutionValidationError) Field() string

Field function returns field value.

func (ExecutionValidationError) Key

Key function returns key value.

func (ExecutionValidationError) Reason

func (e ExecutionValidationError) 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=flyteidl.admin.FixedRateUnit" json:"unit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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

func (*FixedRate) Descriptor

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

func (*FixedRate) GetUnit

func (m *FixedRate) GetUnit() FixedRateUnit

func (*FixedRate) GetValue

func (m *FixedRate) GetValue() uint32

func (*FixedRate) ProtoMessage

func (*FixedRate) ProtoMessage()

func (*FixedRate) Reset

func (m *FixedRate) Reset()

func (*FixedRate) String

func (m *FixedRate) String() string

func (*FixedRate) Validate

func (m *FixedRate) Validate() error

Validate checks the field values on FixedRate with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*FixedRate) XXX_DiscardUnknown

func (m *FixedRate) XXX_DiscardUnknown()

func (*FixedRate) XXX_Marshal

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

func (*FixedRate) XXX_Merge

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

func (*FixedRate) XXX_Size

func (m *FixedRate) XXX_Size() int

func (*FixedRate) XXX_Unmarshal

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

type FixedRateUnit

type FixedRateUnit int32

Represents a frequency at which to run a schedule.

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

func (FixedRateUnit) EnumDescriptor

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

func (FixedRateUnit) String

func (x FixedRateUnit) String() string

type FixedRateValidationError

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

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

func (FixedRateValidationError) Cause

func (e FixedRateValidationError) Cause() error

Cause function returns cause value.

func (FixedRateValidationError) Error

func (e FixedRateValidationError) Error() string

Error satisfies the builtin error interface

func (FixedRateValidationError) ErrorName

func (e FixedRateValidationError) ErrorName() string

ErrorName returns error name.

func (FixedRateValidationError) Field

func (e FixedRateValidationError) Field() string

Field function returns field value.

func (FixedRateValidationError) Key

Key function returns key value.

func (FixedRateValidationError) Reason

func (e FixedRateValidationError) Reason() string

Reason function returns reason value.

type 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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

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

func (*Labels) GetValues

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

func (*Labels) ProtoMessage

func (*Labels) ProtoMessage()

func (*Labels) Reset

func (m *Labels) Reset()

func (*Labels) String

func (m *Labels) String() string

func (*Labels) Validate

func (m *Labels) Validate() error

Validate checks the field values on Labels with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Labels) XXX_DiscardUnknown

func (m *Labels) XXX_DiscardUnknown()

func (*Labels) XXX_Marshal

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

func (*Labels) XXX_Merge

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

func (*Labels) XXX_Size

func (m *Labels) XXX_Size() int

func (*Labels) XXX_Unmarshal

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

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 LaunchPlan

type LaunchPlan struct {
	Id                   *core.Identifier   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Spec                 *LaunchPlanSpec    `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Closure              *LaunchPlanClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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

func (*LaunchPlan) Descriptor

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

func (*LaunchPlan) GetClosure

func (m *LaunchPlan) GetClosure() *LaunchPlanClosure

func (*LaunchPlan) GetId

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

func (*LaunchPlan) GetSpec

func (m *LaunchPlan) GetSpec() *LaunchPlanSpec

func (*LaunchPlan) ProtoMessage

func (*LaunchPlan) ProtoMessage()

func (*LaunchPlan) Reset

func (m *LaunchPlan) Reset()

func (*LaunchPlan) String

func (m *LaunchPlan) String() string

func (*LaunchPlan) Validate

func (m *LaunchPlan) Validate() error

Validate checks the field values on LaunchPlan with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlan) XXX_DiscardUnknown

func (m *LaunchPlan) XXX_DiscardUnknown()

func (*LaunchPlan) XXX_Marshal

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

func (*LaunchPlan) XXX_Merge

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

func (*LaunchPlan) XXX_Size

func (m *LaunchPlan) XXX_Size() int

func (*LaunchPlan) XXX_Unmarshal

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

type LaunchPlanClosure

type LaunchPlanClosure struct {
	// Indicate the Launch plan phase
	State LaunchPlanState `protobuf:"varint,1,opt,name=state,proto3,enum=flyteidl.admin.LaunchPlanState" json:"state,omitempty"`
	// Indicates the set of inputs to execute the Launch plan
	ExpectedInputs *core.ParameterMap `protobuf:"bytes,2,opt,name=expected_inputs,json=expectedInputs,proto3" json:"expected_inputs,omitempty"`
	// Indicates the set of outputs from the Launch plan
	ExpectedOutputs *core.VariableMap `protobuf:"bytes,3,opt,name=expected_outputs,json=expectedOutputs,proto3" json:"expected_outputs,omitempty"`
	// Time at which the launch plan was created.
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Time at which the launch plan was last updated.
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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

func (*LaunchPlanClosure) Descriptor

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

func (*LaunchPlanClosure) GetCreatedAt

func (m *LaunchPlanClosure) GetCreatedAt() *timestamp.Timestamp

func (*LaunchPlanClosure) GetExpectedInputs

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

func (*LaunchPlanClosure) GetExpectedOutputs

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

func (*LaunchPlanClosure) GetState

func (m *LaunchPlanClosure) GetState() LaunchPlanState

func (*LaunchPlanClosure) GetUpdatedAt

func (m *LaunchPlanClosure) GetUpdatedAt() *timestamp.Timestamp

func (*LaunchPlanClosure) ProtoMessage

func (*LaunchPlanClosure) ProtoMessage()

func (*LaunchPlanClosure) Reset

func (m *LaunchPlanClosure) Reset()

func (*LaunchPlanClosure) String

func (m *LaunchPlanClosure) String() string

func (*LaunchPlanClosure) Validate

func (m *LaunchPlanClosure) Validate() error

Validate checks the field values on LaunchPlanClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanClosure) XXX_DiscardUnknown

func (m *LaunchPlanClosure) XXX_DiscardUnknown()

func (*LaunchPlanClosure) XXX_Marshal

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

func (*LaunchPlanClosure) XXX_Merge

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

func (*LaunchPlanClosure) XXX_Size

func (m *LaunchPlanClosure) XXX_Size() int

func (*LaunchPlanClosure) XXX_Unmarshal

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

type LaunchPlanClosureValidationError

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

LaunchPlanClosureValidationError is the validation error returned by LaunchPlanClosure.Validate if the designated constraints aren't met.

func (LaunchPlanClosureValidationError) Cause

Cause function returns cause value.

func (LaunchPlanClosureValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanClosureValidationError) ErrorName

ErrorName returns error name.

func (LaunchPlanClosureValidationError) Field

Field function returns field value.

func (LaunchPlanClosureValidationError) Key

Key function returns key value.

func (LaunchPlanClosureValidationError) Reason

Reason function returns reason value.

type LaunchPlanCreateRequest

type LaunchPlanCreateRequest struct {
	// Uniquely identifies a launch plan entity.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User-provided launch plan details, including reference workflow, inputs and other metadata.
	Spec                 *LaunchPlanSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*LaunchPlanCreateRequest) Descriptor

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

func (*LaunchPlanCreateRequest) GetId

func (*LaunchPlanCreateRequest) GetSpec

func (*LaunchPlanCreateRequest) ProtoMessage

func (*LaunchPlanCreateRequest) ProtoMessage()

func (*LaunchPlanCreateRequest) Reset

func (m *LaunchPlanCreateRequest) Reset()

func (*LaunchPlanCreateRequest) String

func (m *LaunchPlanCreateRequest) String() string

func (*LaunchPlanCreateRequest) Validate

func (m *LaunchPlanCreateRequest) Validate() error

Validate checks the field values on LaunchPlanCreateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanCreateRequest) XXX_DiscardUnknown

func (m *LaunchPlanCreateRequest) XXX_DiscardUnknown()

func (*LaunchPlanCreateRequest) XXX_Marshal

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

func (*LaunchPlanCreateRequest) XXX_Merge

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

func (*LaunchPlanCreateRequest) XXX_Size

func (m *LaunchPlanCreateRequest) XXX_Size() int

func (*LaunchPlanCreateRequest) XXX_Unmarshal

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

type LaunchPlanCreateRequestValidationError

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

LaunchPlanCreateRequestValidationError is the validation error returned by LaunchPlanCreateRequest.Validate if the designated constraints aren't met.

func (LaunchPlanCreateRequestValidationError) Cause

Cause function returns cause value.

func (LaunchPlanCreateRequestValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanCreateRequestValidationError) ErrorName

ErrorName returns error name.

func (LaunchPlanCreateRequestValidationError) Field

Field function returns field value.

func (LaunchPlanCreateRequestValidationError) Key

Key function returns key value.

func (LaunchPlanCreateRequestValidationError) Reason

Reason function returns reason value.

type LaunchPlanCreateResponse

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

func (*LaunchPlanCreateResponse) Descriptor

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

func (*LaunchPlanCreateResponse) ProtoMessage

func (*LaunchPlanCreateResponse) ProtoMessage()

func (*LaunchPlanCreateResponse) Reset

func (m *LaunchPlanCreateResponse) Reset()

func (*LaunchPlanCreateResponse) String

func (m *LaunchPlanCreateResponse) String() string

func (*LaunchPlanCreateResponse) Validate

func (m *LaunchPlanCreateResponse) Validate() error

Validate checks the field values on LaunchPlanCreateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanCreateResponse) XXX_DiscardUnknown

func (m *LaunchPlanCreateResponse) XXX_DiscardUnknown()

func (*LaunchPlanCreateResponse) XXX_Marshal

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

func (*LaunchPlanCreateResponse) XXX_Merge

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

func (*LaunchPlanCreateResponse) XXX_Size

func (m *LaunchPlanCreateResponse) XXX_Size() int

func (*LaunchPlanCreateResponse) XXX_Unmarshal

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

type LaunchPlanCreateResponseValidationError

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

LaunchPlanCreateResponseValidationError is the validation error returned by LaunchPlanCreateResponse.Validate if the designated constraints aren't met.

func (LaunchPlanCreateResponseValidationError) Cause

Cause function returns cause value.

func (LaunchPlanCreateResponseValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanCreateResponseValidationError) ErrorName

ErrorName returns error name.

func (LaunchPlanCreateResponseValidationError) Field

Field function returns field value.

func (LaunchPlanCreateResponseValidationError) Key

Key function returns key value.

func (LaunchPlanCreateResponseValidationError) Reason

Reason function returns reason value.

type LaunchPlanList

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

Response object for list launch plan requests.

func (*LaunchPlanList) Descriptor

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

func (*LaunchPlanList) GetLaunchPlans

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

func (*LaunchPlanList) GetToken

func (m *LaunchPlanList) GetToken() string

func (*LaunchPlanList) ProtoMessage

func (*LaunchPlanList) ProtoMessage()

func (*LaunchPlanList) Reset

func (m *LaunchPlanList) Reset()

func (*LaunchPlanList) String

func (m *LaunchPlanList) String() string

func (*LaunchPlanList) Validate

func (m *LaunchPlanList) Validate() error

Validate checks the field values on LaunchPlanList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanList) XXX_DiscardUnknown

func (m *LaunchPlanList) XXX_DiscardUnknown()

func (*LaunchPlanList) XXX_Marshal

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

func (*LaunchPlanList) XXX_Merge

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

func (*LaunchPlanList) XXX_Size

func (m *LaunchPlanList) XXX_Size() int

func (*LaunchPlanList) XXX_Unmarshal

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

type LaunchPlanListValidationError

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

LaunchPlanListValidationError is the validation error returned by LaunchPlanList.Validate if the designated constraints aren't met.

func (LaunchPlanListValidationError) Cause

Cause function returns cause value.

func (LaunchPlanListValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanListValidationError) ErrorName

func (e LaunchPlanListValidationError) ErrorName() string

ErrorName returns error name.

func (LaunchPlanListValidationError) Field

Field function returns field value.

func (LaunchPlanListValidationError) Key

Key function returns key value.

func (LaunchPlanListValidationError) Reason

Reason function returns reason value.

type LaunchPlanMetadata

type LaunchPlanMetadata struct {
	// Schedule to execute the Launch Plan
	Schedule *Schedule `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// List of notifications based on Execution status transitions
	Notifications        []*Notification `protobuf:"bytes,2,rep,name=notifications,proto3" json:"notifications,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*LaunchPlanMetadata) Descriptor

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

func (*LaunchPlanMetadata) GetNotifications

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

func (*LaunchPlanMetadata) GetSchedule

func (m *LaunchPlanMetadata) GetSchedule() *Schedule

func (*LaunchPlanMetadata) ProtoMessage

func (*LaunchPlanMetadata) ProtoMessage()

func (*LaunchPlanMetadata) Reset

func (m *LaunchPlanMetadata) Reset()

func (*LaunchPlanMetadata) String

func (m *LaunchPlanMetadata) String() string

func (*LaunchPlanMetadata) Validate

func (m *LaunchPlanMetadata) Validate() error

Validate checks the field values on LaunchPlanMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanMetadata) XXX_DiscardUnknown

func (m *LaunchPlanMetadata) XXX_DiscardUnknown()

func (*LaunchPlanMetadata) XXX_Marshal

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

func (*LaunchPlanMetadata) XXX_Merge

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

func (*LaunchPlanMetadata) XXX_Size

func (m *LaunchPlanMetadata) XXX_Size() int

func (*LaunchPlanMetadata) XXX_Unmarshal

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

type LaunchPlanMetadataValidationError

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

LaunchPlanMetadataValidationError is the validation error returned by LaunchPlanMetadata.Validate if the designated constraints aren't met.

func (LaunchPlanMetadataValidationError) Cause

Cause function returns cause value.

func (LaunchPlanMetadataValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanMetadataValidationError) ErrorName

ErrorName returns error name.

func (LaunchPlanMetadataValidationError) Field

Field function returns field value.

func (LaunchPlanMetadataValidationError) Key

Key function returns key value.

func (LaunchPlanMetadataValidationError) Reason

Reason function returns reason value.

type LaunchPlanSpec

type LaunchPlanSpec struct {
	// Reference to the Workflow template that the launch plan references
	WorkflowId *core.Identifier `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Metadata for the Launch Plan
	EntityMetadata *LaunchPlanMetadata `protobuf:"bytes,2,opt,name=entity_metadata,json=entityMetadata,proto3" json:"entity_metadata,omitempty"`
	// Input values to be passed for the execution
	DefaultInputs *core.ParameterMap `protobuf:"bytes,3,opt,name=default_inputs,json=defaultInputs,proto3" json:"default_inputs,omitempty"`
	// Fixed, non-overridable inputs for the Launch Plan
	FixedInputs *core.LiteralMap `protobuf:"bytes,4,opt,name=fixed_inputs,json=fixedInputs,proto3" json:"fixed_inputs,omitempty"`
	// String to indicate the role to use to execute the workflow underneath
	Role string `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"` // Deprecated: Do not use.
	// Custom labels to be applied to the execution resource.
	Labels *Labels `protobuf:"bytes,6,opt,name=labels,proto3" json:"labels,omitempty"`
	// Custom annotations to be applied to the execution resource.
	Annotations *Annotations `protobuf:"bytes,7,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// Indicates the permission associated with workflow executions triggered with this launch plan.
	Auth                 *Auth    `protobuf:"bytes,8,opt,name=auth,proto3" json:"auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

User-provided launch plan definition and configuration values.

func (*LaunchPlanSpec) Descriptor

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

func (*LaunchPlanSpec) GetAnnotations

func (m *LaunchPlanSpec) GetAnnotations() *Annotations

func (*LaunchPlanSpec) GetAuth

func (m *LaunchPlanSpec) GetAuth() *Auth

func (*LaunchPlanSpec) GetDefaultInputs

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

func (*LaunchPlanSpec) GetEntityMetadata

func (m *LaunchPlanSpec) GetEntityMetadata() *LaunchPlanMetadata

func (*LaunchPlanSpec) GetFixedInputs

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

func (*LaunchPlanSpec) GetLabels

func (m *LaunchPlanSpec) GetLabels() *Labels

func (*LaunchPlanSpec) GetRole deprecated

func (m *LaunchPlanSpec) GetRole() string

Deprecated: Do not use.

func (*LaunchPlanSpec) GetWorkflowId

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

func (*LaunchPlanSpec) ProtoMessage

func (*LaunchPlanSpec) ProtoMessage()

func (*LaunchPlanSpec) Reset

func (m *LaunchPlanSpec) Reset()

func (*LaunchPlanSpec) String

func (m *LaunchPlanSpec) String() string

func (*LaunchPlanSpec) Validate

func (m *LaunchPlanSpec) Validate() error

Validate checks the field values on LaunchPlanSpec with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanSpec) XXX_DiscardUnknown

func (m *LaunchPlanSpec) XXX_DiscardUnknown()

func (*LaunchPlanSpec) XXX_Marshal

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

func (*LaunchPlanSpec) XXX_Merge

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

func (*LaunchPlanSpec) XXX_Size

func (m *LaunchPlanSpec) XXX_Size() int

func (*LaunchPlanSpec) XXX_Unmarshal

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

type LaunchPlanSpecValidationError

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

LaunchPlanSpecValidationError is the validation error returned by LaunchPlanSpec.Validate if the designated constraints aren't met.

func (LaunchPlanSpecValidationError) Cause

Cause function returns cause value.

func (LaunchPlanSpecValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanSpecValidationError) ErrorName

func (e LaunchPlanSpecValidationError) ErrorName() string

ErrorName returns error name.

func (LaunchPlanSpecValidationError) Field

Field function returns field value.

func (LaunchPlanSpecValidationError) Key

Key function returns key value.

func (LaunchPlanSpecValidationError) Reason

Reason function returns reason value.

type LaunchPlanState

type LaunchPlanState int32

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

const (
	LaunchPlanState_INACTIVE LaunchPlanState = 0
	LaunchPlanState_ACTIVE   LaunchPlanState = 1
)

func (LaunchPlanState) EnumDescriptor

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

func (LaunchPlanState) String

func (x LaunchPlanState) String() string

type LaunchPlanUpdateRequest

type LaunchPlanUpdateRequest struct {
	// Identifier of launch plan for which to change state.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Desired state to apply to the launch plan.
	State                LaunchPlanState `protobuf:"varint,2,opt,name=state,proto3,enum=flyteidl.admin.LaunchPlanState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Request to set the referenced launch plan state to the configured value.

func (*LaunchPlanUpdateRequest) Descriptor

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

func (*LaunchPlanUpdateRequest) GetId

func (*LaunchPlanUpdateRequest) GetState

func (*LaunchPlanUpdateRequest) ProtoMessage

func (*LaunchPlanUpdateRequest) ProtoMessage()

func (*LaunchPlanUpdateRequest) Reset

func (m *LaunchPlanUpdateRequest) Reset()

func (*LaunchPlanUpdateRequest) String

func (m *LaunchPlanUpdateRequest) String() string

func (*LaunchPlanUpdateRequest) Validate

func (m *LaunchPlanUpdateRequest) Validate() error

Validate checks the field values on LaunchPlanUpdateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanUpdateRequest) XXX_DiscardUnknown

func (m *LaunchPlanUpdateRequest) XXX_DiscardUnknown()

func (*LaunchPlanUpdateRequest) XXX_Marshal

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

func (*LaunchPlanUpdateRequest) XXX_Merge

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

func (*LaunchPlanUpdateRequest) XXX_Size

func (m *LaunchPlanUpdateRequest) XXX_Size() int

func (*LaunchPlanUpdateRequest) XXX_Unmarshal

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

type LaunchPlanUpdateRequestValidationError

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

LaunchPlanUpdateRequestValidationError is the validation error returned by LaunchPlanUpdateRequest.Validate if the designated constraints aren't met.

func (LaunchPlanUpdateRequestValidationError) Cause

Cause function returns cause value.

func (LaunchPlanUpdateRequestValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanUpdateRequestValidationError) ErrorName

ErrorName returns error name.

func (LaunchPlanUpdateRequestValidationError) Field

Field function returns field value.

func (LaunchPlanUpdateRequestValidationError) Key

Key function returns key value.

func (LaunchPlanUpdateRequestValidationError) Reason

Reason function returns reason value.

type LaunchPlanUpdateResponse

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

Purposefully empty, may be populated in the future.

func (*LaunchPlanUpdateResponse) Descriptor

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

func (*LaunchPlanUpdateResponse) ProtoMessage

func (*LaunchPlanUpdateResponse) ProtoMessage()

func (*LaunchPlanUpdateResponse) Reset

func (m *LaunchPlanUpdateResponse) Reset()

func (*LaunchPlanUpdateResponse) String

func (m *LaunchPlanUpdateResponse) String() string

func (*LaunchPlanUpdateResponse) Validate

func (m *LaunchPlanUpdateResponse) Validate() error

Validate checks the field values on LaunchPlanUpdateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LaunchPlanUpdateResponse) XXX_DiscardUnknown

func (m *LaunchPlanUpdateResponse) XXX_DiscardUnknown()

func (*LaunchPlanUpdateResponse) XXX_Marshal

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

func (*LaunchPlanUpdateResponse) XXX_Merge

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

func (*LaunchPlanUpdateResponse) XXX_Size

func (m *LaunchPlanUpdateResponse) XXX_Size() int

func (*LaunchPlanUpdateResponse) XXX_Unmarshal

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

type LaunchPlanUpdateResponseValidationError

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

LaunchPlanUpdateResponseValidationError is the validation error returned by LaunchPlanUpdateResponse.Validate if the designated constraints aren't met.

func (LaunchPlanUpdateResponseValidationError) Cause

Cause function returns cause value.

func (LaunchPlanUpdateResponseValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanUpdateResponseValidationError) ErrorName

ErrorName returns error name.

func (LaunchPlanUpdateResponseValidationError) Field

Field function returns field value.

func (LaunchPlanUpdateResponseValidationError) Key

Key function returns key value.

func (LaunchPlanUpdateResponseValidationError) Reason

Reason function returns reason value.

type LaunchPlanValidationError

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

LaunchPlanValidationError is the validation error returned by LaunchPlan.Validate if the designated constraints aren't met.

func (LaunchPlanValidationError) Cause

func (e LaunchPlanValidationError) Cause() error

Cause function returns cause value.

func (LaunchPlanValidationError) Error

Error satisfies the builtin error interface

func (LaunchPlanValidationError) ErrorName

func (e LaunchPlanValidationError) ErrorName() string

ErrorName returns error name.

func (LaunchPlanValidationError) Field

Field function returns field value.

func (LaunchPlanValidationError) Key

Key function returns key value.

func (LaunchPlanValidationError) Reason

func (e LaunchPlanValidationError) Reason() string

Reason function returns reason value.

type LiteralMapBlob

type LiteralMapBlob struct {
	// Types that are valid to be assigned to Data:
	//	*LiteralMapBlob_Values
	//	*LiteralMapBlob_Uri
	Data                 isLiteralMapBlob_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*LiteralMapBlob) Descriptor

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

func (*LiteralMapBlob) GetData

func (m *LiteralMapBlob) GetData() isLiteralMapBlob_Data

func (*LiteralMapBlob) GetUri

func (m *LiteralMapBlob) GetUri() string

func (*LiteralMapBlob) GetValues

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

func (*LiteralMapBlob) ProtoMessage

func (*LiteralMapBlob) ProtoMessage()

func (*LiteralMapBlob) Reset

func (m *LiteralMapBlob) Reset()

func (*LiteralMapBlob) String

func (m *LiteralMapBlob) String() string

func (*LiteralMapBlob) Validate

func (m *LiteralMapBlob) Validate() error

Validate checks the field values on LiteralMapBlob with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*LiteralMapBlob) XXX_DiscardUnknown

func (m *LiteralMapBlob) XXX_DiscardUnknown()

func (*LiteralMapBlob) XXX_Marshal

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

func (*LiteralMapBlob) XXX_Merge

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

func (*LiteralMapBlob) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*LiteralMapBlob) XXX_Size

func (m *LiteralMapBlob) XXX_Size() int

func (*LiteralMapBlob) XXX_Unmarshal

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

type LiteralMapBlobValidationError

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

LiteralMapBlobValidationError is the validation error returned by LiteralMapBlob.Validate if the designated constraints aren't met.

func (LiteralMapBlobValidationError) Cause

Cause function returns cause value.

func (LiteralMapBlobValidationError) Error

Error satisfies the builtin error interface

func (LiteralMapBlobValidationError) ErrorName

func (e LiteralMapBlobValidationError) ErrorName() string

ErrorName returns error name.

func (LiteralMapBlobValidationError) Field

Field function returns field value.

func (LiteralMapBlobValidationError) Key

Key function returns key value.

func (LiteralMapBlobValidationError) Reason

Reason function returns reason value.

type LiteralMapBlob_Uri

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

type LiteralMapBlob_Values

type LiteralMapBlob_Values struct {
	Values *core.LiteralMap `protobuf:"bytes,1,opt,name=values,proto3,oneof"`
}

type MatchableResource added in v0.16.4

type MatchableResource int32

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

const (
	// Applies to customizable task resource requests and limits.
	MatchableResource_TASK_RESOURCE MatchableResource = 0
	// Applies to configuring templated kubernetes cluster resources.
	MatchableResource_CLUSTER_RESOURCE MatchableResource = 1
	// Configures task and dynamic task execution queue assignment.
	MatchableResource_EXECUTION_QUEUE MatchableResource = 2
)

func (MatchableResource) EnumDescriptor added in v0.16.4

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

func (MatchableResource) String added in v0.16.4

func (x MatchableResource) String() string

type MatchingAttributes added in v0.16.4

type MatchingAttributes struct {
	// Types that are valid to be assigned to Target:
	//	*MatchingAttributes_TaskResourceAttributes
	//	*MatchingAttributes_ClusterResourceAttributes
	//	*MatchingAttributes_ExecutionQueueAttributes
	Target               isMatchingAttributes_Target `protobuf_oneof:"target"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

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

func (*MatchingAttributes) Descriptor added in v0.16.4

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

func (*MatchingAttributes) GetClusterResourceAttributes added in v0.16.4

func (m *MatchingAttributes) GetClusterResourceAttributes() *ClusterResourceAttributes

func (*MatchingAttributes) GetExecutionQueueAttributes added in v0.16.4

func (m *MatchingAttributes) GetExecutionQueueAttributes() *ExecutionQueueAttributes

func (*MatchingAttributes) GetTarget added in v0.16.4

func (m *MatchingAttributes) GetTarget() isMatchingAttributes_Target

func (*MatchingAttributes) GetTaskResourceAttributes added in v0.16.4

func (m *MatchingAttributes) GetTaskResourceAttributes() *TaskResourceAttributes

func (*MatchingAttributes) ProtoMessage added in v0.16.4

func (*MatchingAttributes) ProtoMessage()

func (*MatchingAttributes) Reset added in v0.16.4

func (m *MatchingAttributes) Reset()

func (*MatchingAttributes) String added in v0.16.4

func (m *MatchingAttributes) String() string

func (*MatchingAttributes) Validate added in v0.16.4

func (m *MatchingAttributes) Validate() error

Validate checks the field values on MatchingAttributes with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*MatchingAttributes) XXX_DiscardUnknown added in v0.16.4

func (m *MatchingAttributes) XXX_DiscardUnknown()

func (*MatchingAttributes) XXX_Marshal added in v0.16.4

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

func (*MatchingAttributes) XXX_Merge added in v0.16.4

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

func (*MatchingAttributes) XXX_OneofWrappers added in v0.16.4

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MatchingAttributes) XXX_Size added in v0.16.4

func (m *MatchingAttributes) XXX_Size() int

func (*MatchingAttributes) XXX_Unmarshal added in v0.16.4

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

type MatchingAttributesValidationError added in v0.16.4

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

MatchingAttributesValidationError is the validation error returned by MatchingAttributes.Validate if the designated constraints aren't met.

func (MatchingAttributesValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (MatchingAttributesValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (MatchingAttributesValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (MatchingAttributesValidationError) Field added in v0.16.4

Field function returns field value.

func (MatchingAttributesValidationError) Key added in v0.16.4

Key function returns key value.

func (MatchingAttributesValidationError) Reason added in v0.16.4

Reason function returns reason value.

type MatchingAttributes_ClusterResourceAttributes added in v0.16.4

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

type MatchingAttributes_ExecutionQueueAttributes added in v0.16.4

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

type MatchingAttributes_TaskResourceAttributes added in v0.16.4

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

type NamedEntity added in v0.16.1

type NamedEntity struct {
	ResourceType         core.ResourceType      `` /* 130-byte string literal not displayed */
	Id                   *NamedEntityIdentifier `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Metadata             *NamedEntityMetadata   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Describes information common to a NamedEntity, identified by a project / domain / name / resource type combination

func (*NamedEntity) Descriptor added in v0.16.1

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

func (*NamedEntity) GetId added in v0.16.1

func (m *NamedEntity) GetId() *NamedEntityIdentifier

func (*NamedEntity) GetMetadata added in v0.16.1

func (m *NamedEntity) GetMetadata() *NamedEntityMetadata

func (*NamedEntity) GetResourceType added in v0.16.1

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

func (*NamedEntity) ProtoMessage added in v0.16.1

func (*NamedEntity) ProtoMessage()

func (*NamedEntity) Reset added in v0.16.1

func (m *NamedEntity) Reset()

func (*NamedEntity) String added in v0.16.1

func (m *NamedEntity) String() string

func (*NamedEntity) Validate added in v0.16.1

func (m *NamedEntity) Validate() error

Validate checks the field values on NamedEntity with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntity) XXX_DiscardUnknown added in v0.16.1

func (m *NamedEntity) XXX_DiscardUnknown()

func (*NamedEntity) XXX_Marshal added in v0.16.1

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

func (*NamedEntity) XXX_Merge added in v0.16.1

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

func (*NamedEntity) XXX_Size added in v0.16.1

func (m *NamedEntity) XXX_Size() int

func (*NamedEntity) XXX_Unmarshal added in v0.16.1

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

type NamedEntityGetRequest added in v0.16.1

type NamedEntityGetRequest struct {
	ResourceType         core.ResourceType      `` /* 130-byte string literal not displayed */
	Id                   *NamedEntityIdentifier `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

A request to retrieve the metadata associated with a NamedEntityIdentifier

func (*NamedEntityGetRequest) Descriptor added in v0.16.1

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

func (*NamedEntityGetRequest) GetId added in v0.16.1

func (*NamedEntityGetRequest) GetResourceType added in v0.16.1

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

func (*NamedEntityGetRequest) ProtoMessage added in v0.16.1

func (*NamedEntityGetRequest) ProtoMessage()

func (*NamedEntityGetRequest) Reset added in v0.16.1

func (m *NamedEntityGetRequest) Reset()

func (*NamedEntityGetRequest) String added in v0.16.1

func (m *NamedEntityGetRequest) String() string

func (*NamedEntityGetRequest) Validate added in v0.16.1

func (m *NamedEntityGetRequest) Validate() error

Validate checks the field values on NamedEntityGetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityGetRequest) XXX_DiscardUnknown added in v0.16.1

func (m *NamedEntityGetRequest) XXX_DiscardUnknown()

func (*NamedEntityGetRequest) XXX_Marshal added in v0.16.1

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

func (*NamedEntityGetRequest) XXX_Merge added in v0.16.1

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

func (*NamedEntityGetRequest) XXX_Size added in v0.16.1

func (m *NamedEntityGetRequest) XXX_Size() int

func (*NamedEntityGetRequest) XXX_Unmarshal added in v0.16.1

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

type NamedEntityGetRequestValidationError added in v0.16.1

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

NamedEntityGetRequestValidationError is the validation error returned by NamedEntityGetRequest.Validate if the designated constraints aren't met.

func (NamedEntityGetRequestValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (NamedEntityGetRequestValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (NamedEntityGetRequestValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (NamedEntityGetRequestValidationError) Field added in v0.16.1

Field function returns field value.

func (NamedEntityGetRequestValidationError) Key added in v0.16.1

Key function returns key value.

func (NamedEntityGetRequestValidationError) Reason added in v0.16.1

Reason function returns reason value.

type NamedEntityIdentifier

type NamedEntityIdentifier struct {
	// Name of the project the resource belongs to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the resource belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// User provided value for the resource.
	// The combination of project + domain + name uniquely identifies the resource.
	// +optional - in certain contexts - like 'List API', 'Launch plans'
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Encapsulation of fields that identifies a Flyte resource. A resource can internally have multiple versions.

func (*NamedEntityIdentifier) Descriptor

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

func (*NamedEntityIdentifier) GetDomain

func (m *NamedEntityIdentifier) GetDomain() string

func (*NamedEntityIdentifier) GetName

func (m *NamedEntityIdentifier) GetName() string

func (*NamedEntityIdentifier) GetProject

func (m *NamedEntityIdentifier) GetProject() string

func (*NamedEntityIdentifier) ProtoMessage

func (*NamedEntityIdentifier) ProtoMessage()

func (*NamedEntityIdentifier) Reset

func (m *NamedEntityIdentifier) Reset()

func (*NamedEntityIdentifier) String

func (m *NamedEntityIdentifier) String() string

func (*NamedEntityIdentifier) Validate

func (m *NamedEntityIdentifier) Validate() error

Validate checks the field values on NamedEntityIdentifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityIdentifier) XXX_DiscardUnknown

func (m *NamedEntityIdentifier) XXX_DiscardUnknown()

func (*NamedEntityIdentifier) XXX_Marshal

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

func (*NamedEntityIdentifier) XXX_Merge

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

func (*NamedEntityIdentifier) XXX_Size

func (m *NamedEntityIdentifier) XXX_Size() int

func (*NamedEntityIdentifier) XXX_Unmarshal

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

type NamedEntityIdentifierList

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

Represents a list of NamedEntityIdentifiers.

func (*NamedEntityIdentifierList) Descriptor

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

func (*NamedEntityIdentifierList) GetEntities

func (*NamedEntityIdentifierList) GetToken

func (m *NamedEntityIdentifierList) GetToken() string

func (*NamedEntityIdentifierList) ProtoMessage

func (*NamedEntityIdentifierList) ProtoMessage()

func (*NamedEntityIdentifierList) Reset

func (m *NamedEntityIdentifierList) Reset()

func (*NamedEntityIdentifierList) String

func (m *NamedEntityIdentifierList) String() string

func (*NamedEntityIdentifierList) Validate

func (m *NamedEntityIdentifierList) Validate() error

Validate checks the field values on NamedEntityIdentifierList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityIdentifierList) XXX_DiscardUnknown

func (m *NamedEntityIdentifierList) XXX_DiscardUnknown()

func (*NamedEntityIdentifierList) XXX_Marshal

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

func (*NamedEntityIdentifierList) XXX_Merge

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

func (*NamedEntityIdentifierList) XXX_Size

func (m *NamedEntityIdentifierList) XXX_Size() int

func (*NamedEntityIdentifierList) XXX_Unmarshal

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

type NamedEntityIdentifierListRequest

type NamedEntityIdentifierListRequest struct {
	// Name of the project that contains the identifiers.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the identifiers belongs to within the project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Indicates the number of resources to be returned.
	Limit uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// Sort ordering.
	// +optional
	SortBy               *Sort    `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a request structure to list identifiers.

func (*NamedEntityIdentifierListRequest) Descriptor

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

func (*NamedEntityIdentifierListRequest) GetDomain

func (*NamedEntityIdentifierListRequest) GetLimit

func (*NamedEntityIdentifierListRequest) GetProject

func (m *NamedEntityIdentifierListRequest) GetProject() string

func (*NamedEntityIdentifierListRequest) GetSortBy

func (m *NamedEntityIdentifierListRequest) GetSortBy() *Sort

func (*NamedEntityIdentifierListRequest) GetToken

func (*NamedEntityIdentifierListRequest) ProtoMessage

func (*NamedEntityIdentifierListRequest) ProtoMessage()

func (*NamedEntityIdentifierListRequest) Reset

func (*NamedEntityIdentifierListRequest) String

func (*NamedEntityIdentifierListRequest) Validate

Validate checks the field values on NamedEntityIdentifierListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityIdentifierListRequest) XXX_DiscardUnknown

func (m *NamedEntityIdentifierListRequest) XXX_DiscardUnknown()

func (*NamedEntityIdentifierListRequest) XXX_Marshal

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

func (*NamedEntityIdentifierListRequest) XXX_Merge

func (*NamedEntityIdentifierListRequest) XXX_Size

func (m *NamedEntityIdentifierListRequest) XXX_Size() int

func (*NamedEntityIdentifierListRequest) XXX_Unmarshal

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

type NamedEntityIdentifierListRequestValidationError

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

NamedEntityIdentifierListRequestValidationError is the validation error returned by NamedEntityIdentifierListRequest.Validate if the designated constraints aren't met.

func (NamedEntityIdentifierListRequestValidationError) Cause

Cause function returns cause value.

func (NamedEntityIdentifierListRequestValidationError) Error

Error satisfies the builtin error interface

func (NamedEntityIdentifierListRequestValidationError) ErrorName

ErrorName returns error name.

func (NamedEntityIdentifierListRequestValidationError) Field

Field function returns field value.

func (NamedEntityIdentifierListRequestValidationError) Key

Key function returns key value.

func (NamedEntityIdentifierListRequestValidationError) Reason

Reason function returns reason value.

type NamedEntityIdentifierListValidationError

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

NamedEntityIdentifierListValidationError is the validation error returned by NamedEntityIdentifierList.Validate if the designated constraints aren't met.

func (NamedEntityIdentifierListValidationError) Cause

Cause function returns cause value.

func (NamedEntityIdentifierListValidationError) Error

Error satisfies the builtin error interface

func (NamedEntityIdentifierListValidationError) ErrorName

ErrorName returns error name.

func (NamedEntityIdentifierListValidationError) Field

Field function returns field value.

func (NamedEntityIdentifierListValidationError) Key

Key function returns key value.

func (NamedEntityIdentifierListValidationError) Reason

Reason function returns reason value.

type NamedEntityIdentifierValidationError

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

NamedEntityIdentifierValidationError is the validation error returned by NamedEntityIdentifier.Validate if the designated constraints aren't met.

func (NamedEntityIdentifierValidationError) Cause

Cause function returns cause value.

func (NamedEntityIdentifierValidationError) Error

Error satisfies the builtin error interface

func (NamedEntityIdentifierValidationError) ErrorName

ErrorName returns error name.

func (NamedEntityIdentifierValidationError) Field

Field function returns field value.

func (NamedEntityIdentifierValidationError) Key

Key function returns key value.

func (NamedEntityIdentifierValidationError) Reason

Reason function returns reason value.

type NamedEntityList added in v0.16.1

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

Represents a list of NamedEntityIdentifiers.

func (*NamedEntityList) Descriptor added in v0.16.1

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

func (*NamedEntityList) GetEntities added in v0.16.1

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

func (*NamedEntityList) GetToken added in v0.16.1

func (m *NamedEntityList) GetToken() string

func (*NamedEntityList) ProtoMessage added in v0.16.1

func (*NamedEntityList) ProtoMessage()

func (*NamedEntityList) Reset added in v0.16.1

func (m *NamedEntityList) Reset()

func (*NamedEntityList) String added in v0.16.1

func (m *NamedEntityList) String() string

func (*NamedEntityList) Validate added in v0.16.1

func (m *NamedEntityList) Validate() error

Validate checks the field values on NamedEntityList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityList) XXX_DiscardUnknown added in v0.16.1

func (m *NamedEntityList) XXX_DiscardUnknown()

func (*NamedEntityList) XXX_Marshal added in v0.16.1

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

func (*NamedEntityList) XXX_Merge added in v0.16.1

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

func (*NamedEntityList) XXX_Size added in v0.16.1

func (m *NamedEntityList) XXX_Size() int

func (*NamedEntityList) XXX_Unmarshal added in v0.16.1

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

type NamedEntityListRequest added in v0.16.1

type NamedEntityListRequest struct {
	ResourceType core.ResourceType `` /* 130-byte string literal not displayed */
	// Name of the project that contains the identifiers.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the identifiers belongs to within the project.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// Indicates the number of resources to be returned.
	Limit uint32 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	// Sort ordering.
	// +optional
	SortBy               *Sort    `protobuf:"bytes,6,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a request structure to list NamedEntity objects

func (*NamedEntityListRequest) Descriptor added in v0.16.1

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

func (*NamedEntityListRequest) GetDomain added in v0.16.1

func (m *NamedEntityListRequest) GetDomain() string

func (*NamedEntityListRequest) GetLimit added in v0.16.1

func (m *NamedEntityListRequest) GetLimit() uint32

func (*NamedEntityListRequest) GetProject added in v0.16.1

func (m *NamedEntityListRequest) GetProject() string

func (*NamedEntityListRequest) GetResourceType added in v0.16.1

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

func (*NamedEntityListRequest) GetSortBy added in v0.16.1

func (m *NamedEntityListRequest) GetSortBy() *Sort

func (*NamedEntityListRequest) GetToken added in v0.16.1

func (m *NamedEntityListRequest) GetToken() string

func (*NamedEntityListRequest) ProtoMessage added in v0.16.1

func (*NamedEntityListRequest) ProtoMessage()

func (*NamedEntityListRequest) Reset added in v0.16.1

func (m *NamedEntityListRequest) Reset()

func (*NamedEntityListRequest) String added in v0.16.1

func (m *NamedEntityListRequest) String() string

func (*NamedEntityListRequest) Validate added in v0.16.1

func (m *NamedEntityListRequest) Validate() error

Validate checks the field values on NamedEntityListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityListRequest) XXX_DiscardUnknown added in v0.16.1

func (m *NamedEntityListRequest) XXX_DiscardUnknown()

func (*NamedEntityListRequest) XXX_Marshal added in v0.16.1

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

func (*NamedEntityListRequest) XXX_Merge added in v0.16.1

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

func (*NamedEntityListRequest) XXX_Size added in v0.16.1

func (m *NamedEntityListRequest) XXX_Size() int

func (*NamedEntityListRequest) XXX_Unmarshal added in v0.16.1

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

type NamedEntityListRequestValidationError added in v0.16.1

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

NamedEntityListRequestValidationError is the validation error returned by NamedEntityListRequest.Validate if the designated constraints aren't met.

func (NamedEntityListRequestValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (NamedEntityListRequestValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (NamedEntityListRequestValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (NamedEntityListRequestValidationError) Field added in v0.16.1

Field function returns field value.

func (NamedEntityListRequestValidationError) Key added in v0.16.1

Key function returns key value.

func (NamedEntityListRequestValidationError) Reason added in v0.16.1

Reason function returns reason value.

type NamedEntityListValidationError added in v0.16.1

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

NamedEntityListValidationError is the validation error returned by NamedEntityList.Validate if the designated constraints aren't met.

func (NamedEntityListValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (NamedEntityListValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (NamedEntityListValidationError) ErrorName added in v0.16.1

func (e NamedEntityListValidationError) ErrorName() string

ErrorName returns error name.

func (NamedEntityListValidationError) Field added in v0.16.1

Field function returns field value.

func (NamedEntityListValidationError) Key added in v0.16.1

Key function returns key value.

func (NamedEntityListValidationError) Reason added in v0.16.1

Reason function returns reason value.

type NamedEntityMetadata added in v0.16.1

type NamedEntityMetadata struct {
	// Common description across all versions of the entity
	// +optional
	Description          string   `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NamedEntityMetadata) Descriptor added in v0.16.1

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

func (*NamedEntityMetadata) GetDescription added in v0.16.1

func (m *NamedEntityMetadata) GetDescription() string

func (*NamedEntityMetadata) ProtoMessage added in v0.16.1

func (*NamedEntityMetadata) ProtoMessage()

func (*NamedEntityMetadata) Reset added in v0.16.1

func (m *NamedEntityMetadata) Reset()

func (*NamedEntityMetadata) String added in v0.16.1

func (m *NamedEntityMetadata) String() string

func (*NamedEntityMetadata) Validate added in v0.16.1

func (m *NamedEntityMetadata) Validate() error

Validate checks the field values on NamedEntityMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityMetadata) XXX_DiscardUnknown added in v0.16.1

func (m *NamedEntityMetadata) XXX_DiscardUnknown()

func (*NamedEntityMetadata) XXX_Marshal added in v0.16.1

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

func (*NamedEntityMetadata) XXX_Merge added in v0.16.1

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

func (*NamedEntityMetadata) XXX_Size added in v0.16.1

func (m *NamedEntityMetadata) XXX_Size() int

func (*NamedEntityMetadata) XXX_Unmarshal added in v0.16.1

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

type NamedEntityMetadataValidationError added in v0.16.1

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

NamedEntityMetadataValidationError is the validation error returned by NamedEntityMetadata.Validate if the designated constraints aren't met.

func (NamedEntityMetadataValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (NamedEntityMetadataValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (NamedEntityMetadataValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (NamedEntityMetadataValidationError) Field added in v0.16.1

Field function returns field value.

func (NamedEntityMetadataValidationError) Key added in v0.16.1

Key function returns key value.

func (NamedEntityMetadataValidationError) Reason added in v0.16.1

Reason function returns reason value.

type NamedEntityUpdateRequest added in v0.16.1

type NamedEntityUpdateRequest struct {
	// Resource type of the metadata to update
	ResourceType core.ResourceType `` /* 130-byte string literal not displayed */
	// Identifier of the metadata to update
	Id *NamedEntityIdentifier `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Metadata object to set as the new value
	Metadata             *NamedEntityMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Request to set the referenced launch plan state to the configured value.

func (*NamedEntityUpdateRequest) Descriptor added in v0.16.1

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

func (*NamedEntityUpdateRequest) GetId added in v0.16.1

func (*NamedEntityUpdateRequest) GetMetadata added in v0.16.1

func (*NamedEntityUpdateRequest) GetResourceType added in v0.16.1

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

func (*NamedEntityUpdateRequest) ProtoMessage added in v0.16.1

func (*NamedEntityUpdateRequest) ProtoMessage()

func (*NamedEntityUpdateRequest) Reset added in v0.16.1

func (m *NamedEntityUpdateRequest) Reset()

func (*NamedEntityUpdateRequest) String added in v0.16.1

func (m *NamedEntityUpdateRequest) String() string

func (*NamedEntityUpdateRequest) Validate added in v0.16.1

func (m *NamedEntityUpdateRequest) Validate() error

Validate checks the field values on NamedEntityUpdateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityUpdateRequest) XXX_DiscardUnknown added in v0.16.1

func (m *NamedEntityUpdateRequest) XXX_DiscardUnknown()

func (*NamedEntityUpdateRequest) XXX_Marshal added in v0.16.1

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

func (*NamedEntityUpdateRequest) XXX_Merge added in v0.16.1

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

func (*NamedEntityUpdateRequest) XXX_Size added in v0.16.1

func (m *NamedEntityUpdateRequest) XXX_Size() int

func (*NamedEntityUpdateRequest) XXX_Unmarshal added in v0.16.1

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

type NamedEntityUpdateRequestValidationError added in v0.16.1

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

NamedEntityUpdateRequestValidationError is the validation error returned by NamedEntityUpdateRequest.Validate if the designated constraints aren't met.

func (NamedEntityUpdateRequestValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (NamedEntityUpdateRequestValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (NamedEntityUpdateRequestValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (NamedEntityUpdateRequestValidationError) Field added in v0.16.1

Field function returns field value.

func (NamedEntityUpdateRequestValidationError) Key added in v0.16.1

Key function returns key value.

func (NamedEntityUpdateRequestValidationError) Reason added in v0.16.1

Reason function returns reason value.

type NamedEntityUpdateResponse added in v0.16.1

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

Purposefully empty, may be populated in the future.

func (*NamedEntityUpdateResponse) Descriptor added in v0.16.1

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

func (*NamedEntityUpdateResponse) ProtoMessage added in v0.16.1

func (*NamedEntityUpdateResponse) ProtoMessage()

func (*NamedEntityUpdateResponse) Reset added in v0.16.1

func (m *NamedEntityUpdateResponse) Reset()

func (*NamedEntityUpdateResponse) String added in v0.16.1

func (m *NamedEntityUpdateResponse) String() string

func (*NamedEntityUpdateResponse) Validate added in v0.16.1

func (m *NamedEntityUpdateResponse) Validate() error

Validate checks the field values on NamedEntityUpdateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NamedEntityUpdateResponse) XXX_DiscardUnknown added in v0.16.1

func (m *NamedEntityUpdateResponse) XXX_DiscardUnknown()

func (*NamedEntityUpdateResponse) XXX_Marshal added in v0.16.1

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

func (*NamedEntityUpdateResponse) XXX_Merge added in v0.16.1

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

func (*NamedEntityUpdateResponse) XXX_Size added in v0.16.1

func (m *NamedEntityUpdateResponse) XXX_Size() int

func (*NamedEntityUpdateResponse) XXX_Unmarshal added in v0.16.1

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

type NamedEntityUpdateResponseValidationError added in v0.16.1

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

NamedEntityUpdateResponseValidationError is the validation error returned by NamedEntityUpdateResponse.Validate if the designated constraints aren't met.

func (NamedEntityUpdateResponseValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (NamedEntityUpdateResponseValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (NamedEntityUpdateResponseValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (NamedEntityUpdateResponseValidationError) Field added in v0.16.1

Field function returns field value.

func (NamedEntityUpdateResponseValidationError) Key added in v0.16.1

Key function returns key value.

func (NamedEntityUpdateResponseValidationError) Reason added in v0.16.1

Reason function returns reason value.

type NamedEntityValidationError added in v0.16.1

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

NamedEntityValidationError is the validation error returned by NamedEntity.Validate if the designated constraints aren't met.

func (NamedEntityValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (NamedEntityValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (NamedEntityValidationError) ErrorName added in v0.16.1

func (e NamedEntityValidationError) ErrorName() string

ErrorName returns error name.

func (NamedEntityValidationError) Field added in v0.16.1

Field function returns field value.

func (NamedEntityValidationError) Key added in v0.16.1

Key function returns key value.

func (NamedEntityValidationError) Reason added in v0.16.1

Reason function returns reason value.

type NodeExecution

type NodeExecution struct {
	// Uniquely identifies an individual node execution.
	Id *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Path to remote data store where input blob is stored.
	InputUri string `protobuf:"bytes,2,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Computed results associated with this node execution.
	Closure              *NodeExecutionClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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

func (*NodeExecution) Descriptor

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

func (*NodeExecution) GetClosure

func (m *NodeExecution) GetClosure() *NodeExecutionClosure

func (*NodeExecution) GetId

func (*NodeExecution) GetInputUri

func (m *NodeExecution) GetInputUri() string

func (*NodeExecution) ProtoMessage

func (*NodeExecution) ProtoMessage()

func (*NodeExecution) Reset

func (m *NodeExecution) Reset()

func (*NodeExecution) String

func (m *NodeExecution) String() string

func (*NodeExecution) Validate

func (m *NodeExecution) Validate() error

Validate checks the field values on NodeExecution with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecution) XXX_DiscardUnknown

func (m *NodeExecution) XXX_DiscardUnknown()

func (*NodeExecution) XXX_Marshal

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

func (*NodeExecution) XXX_Merge

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

func (*NodeExecution) XXX_Size

func (m *NodeExecution) XXX_Size() int

func (*NodeExecution) XXX_Unmarshal

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

type NodeExecutionClosure

type NodeExecutionClosure struct {
	// Only a node in a terminal state will have a non-empty output_result.
	//
	// Types that are valid to be assigned to OutputResult:
	//	*NodeExecutionClosure_OutputUri
	//	*NodeExecutionClosure_Error
	OutputResult isNodeExecutionClosure_OutputResult `protobuf_oneof:"output_result"`
	// The last recorded phase for this node execution.
	Phase core.NodeExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.NodeExecution_Phase" json:"phase,omitempty"`
	// Time at which the node execution began running.
	StartedAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// The amount of time the node execution spent running.
	Duration *duration.Duration `protobuf:"bytes,5,opt,name=duration,proto3" json:"duration,omitempty"`
	// Time at which the node execution was created.
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Time at which the node execution was last updated.
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Store metadata for what the node launched.
	// for ex: if this is a workflow node, we store information for the launched workflow.
	//
	// Types that are valid to be assigned to TargetMetadata:
	//	*NodeExecutionClosure_WorkflowNodeMetadata
	TargetMetadata       isNodeExecutionClosure_TargetMetadata `protobuf_oneof:"target_metadata"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

Container for node execution details and results.

func (*NodeExecutionClosure) Descriptor

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

func (*NodeExecutionClosure) GetCreatedAt

func (m *NodeExecutionClosure) GetCreatedAt() *timestamp.Timestamp

func (*NodeExecutionClosure) GetDuration

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

func (*NodeExecutionClosure) GetError

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

func (*NodeExecutionClosure) GetOutputResult

func (m *NodeExecutionClosure) GetOutputResult() isNodeExecutionClosure_OutputResult

func (*NodeExecutionClosure) GetOutputUri

func (m *NodeExecutionClosure) GetOutputUri() string

func (*NodeExecutionClosure) GetPhase

func (*NodeExecutionClosure) GetStartedAt

func (m *NodeExecutionClosure) GetStartedAt() *timestamp.Timestamp

func (*NodeExecutionClosure) GetTargetMetadata

func (m *NodeExecutionClosure) GetTargetMetadata() isNodeExecutionClosure_TargetMetadata

func (*NodeExecutionClosure) GetUpdatedAt

func (m *NodeExecutionClosure) GetUpdatedAt() *timestamp.Timestamp

func (*NodeExecutionClosure) GetWorkflowNodeMetadata

func (m *NodeExecutionClosure) GetWorkflowNodeMetadata() *WorkflowNodeMetadata

func (*NodeExecutionClosure) ProtoMessage

func (*NodeExecutionClosure) ProtoMessage()

func (*NodeExecutionClosure) Reset

func (m *NodeExecutionClosure) Reset()

func (*NodeExecutionClosure) String

func (m *NodeExecutionClosure) String() string

func (*NodeExecutionClosure) Validate

func (m *NodeExecutionClosure) Validate() error

Validate checks the field values on NodeExecutionClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionClosure) XXX_DiscardUnknown

func (m *NodeExecutionClosure) XXX_DiscardUnknown()

func (*NodeExecutionClosure) XXX_Marshal

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

func (*NodeExecutionClosure) XXX_Merge

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

func (*NodeExecutionClosure) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*NodeExecutionClosure) XXX_Size

func (m *NodeExecutionClosure) XXX_Size() int

func (*NodeExecutionClosure) XXX_Unmarshal

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

type NodeExecutionClosureValidationError

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

NodeExecutionClosureValidationError is the validation error returned by NodeExecutionClosure.Validate if the designated constraints aren't met.

func (NodeExecutionClosureValidationError) Cause

Cause function returns cause value.

func (NodeExecutionClosureValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionClosureValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionClosureValidationError) Field

Field function returns field value.

func (NodeExecutionClosureValidationError) Key

Key function returns key value.

func (NodeExecutionClosureValidationError) Reason

Reason function returns reason value.

type NodeExecutionClosure_Error

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

type NodeExecutionClosure_OutputUri

type NodeExecutionClosure_OutputUri struct {
	OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type NodeExecutionClosure_WorkflowNodeMetadata

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

type NodeExecutionEventRequest

type NodeExecutionEventRequest struct {
	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event                *event.NodeExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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

func (*NodeExecutionEventRequest) Descriptor

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

func (*NodeExecutionEventRequest) GetEvent

func (*NodeExecutionEventRequest) GetRequestId

func (m *NodeExecutionEventRequest) GetRequestId() string

func (*NodeExecutionEventRequest) ProtoMessage

func (*NodeExecutionEventRequest) ProtoMessage()

func (*NodeExecutionEventRequest) Reset

func (m *NodeExecutionEventRequest) Reset()

func (*NodeExecutionEventRequest) String

func (m *NodeExecutionEventRequest) String() string

func (*NodeExecutionEventRequest) Validate

func (m *NodeExecutionEventRequest) Validate() error

Validate checks the field values on NodeExecutionEventRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionEventRequest) XXX_DiscardUnknown

func (m *NodeExecutionEventRequest) XXX_DiscardUnknown()

func (*NodeExecutionEventRequest) XXX_Marshal

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

func (*NodeExecutionEventRequest) XXX_Merge

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

func (*NodeExecutionEventRequest) XXX_Size

func (m *NodeExecutionEventRequest) XXX_Size() int

func (*NodeExecutionEventRequest) XXX_Unmarshal

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

type NodeExecutionEventRequestValidationError

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

NodeExecutionEventRequestValidationError is the validation error returned by NodeExecutionEventRequest.Validate if the designated constraints aren't met.

func (NodeExecutionEventRequestValidationError) Cause

Cause function returns cause value.

func (NodeExecutionEventRequestValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionEventRequestValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionEventRequestValidationError) Field

Field function returns field value.

func (NodeExecutionEventRequestValidationError) Key

Key function returns key value.

func (NodeExecutionEventRequestValidationError) Reason

Reason function returns reason value.

type NodeExecutionEventResponse

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

func (*NodeExecutionEventResponse) Descriptor

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

func (*NodeExecutionEventResponse) ProtoMessage

func (*NodeExecutionEventResponse) ProtoMessage()

func (*NodeExecutionEventResponse) Reset

func (m *NodeExecutionEventResponse) Reset()

func (*NodeExecutionEventResponse) String

func (m *NodeExecutionEventResponse) String() string

func (*NodeExecutionEventResponse) Validate

func (m *NodeExecutionEventResponse) Validate() error

Validate checks the field values on NodeExecutionEventResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionEventResponse) XXX_DiscardUnknown

func (m *NodeExecutionEventResponse) XXX_DiscardUnknown()

func (*NodeExecutionEventResponse) XXX_Marshal

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

func (*NodeExecutionEventResponse) XXX_Merge

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

func (*NodeExecutionEventResponse) XXX_Size

func (m *NodeExecutionEventResponse) XXX_Size() int

func (*NodeExecutionEventResponse) XXX_Unmarshal

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

type NodeExecutionEventResponseValidationError

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

NodeExecutionEventResponseValidationError is the validation error returned by NodeExecutionEventResponse.Validate if the designated constraints aren't met.

func (NodeExecutionEventResponseValidationError) Cause

Cause function returns cause value.

func (NodeExecutionEventResponseValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionEventResponseValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionEventResponseValidationError) Field

Field function returns field value.

func (NodeExecutionEventResponseValidationError) Key

Key function returns key value.

func (NodeExecutionEventResponseValidationError) Reason

Reason function returns reason value.

type NodeExecutionForTaskListRequest

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

Represents a request structure to retrieve a list of node execution entities launched by a specific task.

func (*NodeExecutionForTaskListRequest) Descriptor

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

func (*NodeExecutionForTaskListRequest) GetFilters

func (m *NodeExecutionForTaskListRequest) GetFilters() string

func (*NodeExecutionForTaskListRequest) GetLimit

func (*NodeExecutionForTaskListRequest) GetSortBy

func (m *NodeExecutionForTaskListRequest) GetSortBy() *Sort

func (*NodeExecutionForTaskListRequest) GetTaskExecutionId

func (*NodeExecutionForTaskListRequest) GetToken

func (*NodeExecutionForTaskListRequest) ProtoMessage

func (*NodeExecutionForTaskListRequest) ProtoMessage()

func (*NodeExecutionForTaskListRequest) Reset

func (*NodeExecutionForTaskListRequest) String

func (*NodeExecutionForTaskListRequest) Validate

func (m *NodeExecutionForTaskListRequest) Validate() error

Validate checks the field values on NodeExecutionForTaskListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionForTaskListRequest) XXX_DiscardUnknown

func (m *NodeExecutionForTaskListRequest) XXX_DiscardUnknown()

func (*NodeExecutionForTaskListRequest) XXX_Marshal

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

func (*NodeExecutionForTaskListRequest) XXX_Merge

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

func (*NodeExecutionForTaskListRequest) XXX_Size

func (m *NodeExecutionForTaskListRequest) XXX_Size() int

func (*NodeExecutionForTaskListRequest) XXX_Unmarshal

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

type NodeExecutionForTaskListRequestValidationError

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

NodeExecutionForTaskListRequestValidationError is the validation error returned by NodeExecutionForTaskListRequest.Validate if the designated constraints aren't met.

func (NodeExecutionForTaskListRequestValidationError) Cause

Cause function returns cause value.

func (NodeExecutionForTaskListRequestValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionForTaskListRequestValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionForTaskListRequestValidationError) Field

Field function returns field value.

func (NodeExecutionForTaskListRequestValidationError) Key

Key function returns key value.

func (NodeExecutionForTaskListRequestValidationError) Reason

Reason function returns reason value.

type NodeExecutionGetDataRequest

type NodeExecutionGetDataRequest struct {
	// The identifier of the node execution for which to fetch inputs and outputs.
	Id                   *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

Request structure to fetch inputs and output urls for a node execution.

func (*NodeExecutionGetDataRequest) Descriptor

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

func (*NodeExecutionGetDataRequest) GetId

func (*NodeExecutionGetDataRequest) ProtoMessage

func (*NodeExecutionGetDataRequest) ProtoMessage()

func (*NodeExecutionGetDataRequest) Reset

func (m *NodeExecutionGetDataRequest) Reset()

func (*NodeExecutionGetDataRequest) String

func (m *NodeExecutionGetDataRequest) String() string

func (*NodeExecutionGetDataRequest) Validate

func (m *NodeExecutionGetDataRequest) Validate() error

Validate checks the field values on NodeExecutionGetDataRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionGetDataRequest) XXX_DiscardUnknown

func (m *NodeExecutionGetDataRequest) XXX_DiscardUnknown()

func (*NodeExecutionGetDataRequest) XXX_Marshal

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

func (*NodeExecutionGetDataRequest) XXX_Merge

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

func (*NodeExecutionGetDataRequest) XXX_Size

func (m *NodeExecutionGetDataRequest) XXX_Size() int

func (*NodeExecutionGetDataRequest) XXX_Unmarshal

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

type NodeExecutionGetDataRequestValidationError

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

NodeExecutionGetDataRequestValidationError is the validation error returned by NodeExecutionGetDataRequest.Validate if the designated constraints aren't met.

func (NodeExecutionGetDataRequestValidationError) Cause

Cause function returns cause value.

func (NodeExecutionGetDataRequestValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionGetDataRequestValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionGetDataRequestValidationError) Field

Field function returns field value.

func (NodeExecutionGetDataRequestValidationError) Key

Key function returns key value.

func (NodeExecutionGetDataRequestValidationError) Reason

Reason function returns reason value.

type NodeExecutionGetDataResponse

type NodeExecutionGetDataResponse struct {
	// Signed url to fetch a core.LiteralMap of node execution inputs.
	Inputs *UrlBlob `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of node execution outputs.
	Outputs              *UrlBlob `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*NodeExecutionGetDataResponse) Descriptor

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

func (*NodeExecutionGetDataResponse) GetInputs

func (m *NodeExecutionGetDataResponse) GetInputs() *UrlBlob

func (*NodeExecutionGetDataResponse) GetOutputs

func (m *NodeExecutionGetDataResponse) GetOutputs() *UrlBlob

func (*NodeExecutionGetDataResponse) ProtoMessage

func (*NodeExecutionGetDataResponse) ProtoMessage()

func (*NodeExecutionGetDataResponse) Reset

func (m *NodeExecutionGetDataResponse) Reset()

func (*NodeExecutionGetDataResponse) String

func (*NodeExecutionGetDataResponse) Validate

func (m *NodeExecutionGetDataResponse) Validate() error

Validate checks the field values on NodeExecutionGetDataResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionGetDataResponse) XXX_DiscardUnknown

func (m *NodeExecutionGetDataResponse) XXX_DiscardUnknown()

func (*NodeExecutionGetDataResponse) XXX_Marshal

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

func (*NodeExecutionGetDataResponse) XXX_Merge

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

func (*NodeExecutionGetDataResponse) XXX_Size

func (m *NodeExecutionGetDataResponse) XXX_Size() int

func (*NodeExecutionGetDataResponse) XXX_Unmarshal

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

type NodeExecutionGetDataResponseValidationError

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

NodeExecutionGetDataResponseValidationError is the validation error returned by NodeExecutionGetDataResponse.Validate if the designated constraints aren't met.

func (NodeExecutionGetDataResponseValidationError) Cause

Cause function returns cause value.

func (NodeExecutionGetDataResponseValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionGetDataResponseValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionGetDataResponseValidationError) Field

Field function returns field value.

func (NodeExecutionGetDataResponseValidationError) Key

Key function returns key value.

func (NodeExecutionGetDataResponseValidationError) Reason

Reason function returns reason value.

type NodeExecutionGetRequest

type NodeExecutionGetRequest struct {
	// Uniquely identifies an individual node execution.
	Id                   *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

A message used to fetch a single node execution entity.

func (*NodeExecutionGetRequest) Descriptor

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

func (*NodeExecutionGetRequest) GetId

func (*NodeExecutionGetRequest) ProtoMessage

func (*NodeExecutionGetRequest) ProtoMessage()

func (*NodeExecutionGetRequest) Reset

func (m *NodeExecutionGetRequest) Reset()

func (*NodeExecutionGetRequest) String

func (m *NodeExecutionGetRequest) String() string

func (*NodeExecutionGetRequest) Validate

func (m *NodeExecutionGetRequest) Validate() error

Validate checks the field values on NodeExecutionGetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionGetRequest) XXX_DiscardUnknown

func (m *NodeExecutionGetRequest) XXX_DiscardUnknown()

func (*NodeExecutionGetRequest) XXX_Marshal

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

func (*NodeExecutionGetRequest) XXX_Merge

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

func (*NodeExecutionGetRequest) XXX_Size

func (m *NodeExecutionGetRequest) XXX_Size() int

func (*NodeExecutionGetRequest) XXX_Unmarshal

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

type NodeExecutionGetRequestValidationError

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

NodeExecutionGetRequestValidationError is the validation error returned by NodeExecutionGetRequest.Validate if the designated constraints aren't met.

func (NodeExecutionGetRequestValidationError) Cause

Cause function returns cause value.

func (NodeExecutionGetRequestValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionGetRequestValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionGetRequestValidationError) Field

Field function returns field value.

func (NodeExecutionGetRequestValidationError) Key

Key function returns key value.

func (NodeExecutionGetRequestValidationError) Reason

Reason function returns reason value.

type NodeExecutionList

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

Request structure to retrieve a list of node execution entities.

func (*NodeExecutionList) Descriptor

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

func (*NodeExecutionList) GetNodeExecutions

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

func (*NodeExecutionList) GetToken

func (m *NodeExecutionList) GetToken() string

func (*NodeExecutionList) ProtoMessage

func (*NodeExecutionList) ProtoMessage()

func (*NodeExecutionList) Reset

func (m *NodeExecutionList) Reset()

func (*NodeExecutionList) String

func (m *NodeExecutionList) String() string

func (*NodeExecutionList) Validate

func (m *NodeExecutionList) Validate() error

Validate checks the field values on NodeExecutionList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionList) XXX_DiscardUnknown

func (m *NodeExecutionList) XXX_DiscardUnknown()

func (*NodeExecutionList) XXX_Marshal

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

func (*NodeExecutionList) XXX_Merge

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

func (*NodeExecutionList) XXX_Size

func (m *NodeExecutionList) XXX_Size() int

func (*NodeExecutionList) XXX_Unmarshal

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

type NodeExecutionListRequest

type NodeExecutionListRequest struct {
	// Indicates the workflow execution to filter by.
	WorkflowExecutionId *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=workflow_execution_id,json=workflowExecutionId,proto3" json:"workflow_execution_id,omitempty"`
	// Indicates the number of resources to be returned.
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the, server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering.
	// +optional
	SortBy               *Sort    `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a request structure to retrieve a list of node execution entities.

func (*NodeExecutionListRequest) Descriptor

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

func (*NodeExecutionListRequest) GetFilters

func (m *NodeExecutionListRequest) GetFilters() string

func (*NodeExecutionListRequest) GetLimit

func (m *NodeExecutionListRequest) GetLimit() uint32

func (*NodeExecutionListRequest) GetSortBy

func (m *NodeExecutionListRequest) GetSortBy() *Sort

func (*NodeExecutionListRequest) GetToken

func (m *NodeExecutionListRequest) GetToken() string

func (*NodeExecutionListRequest) GetWorkflowExecutionId

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

func (*NodeExecutionListRequest) ProtoMessage

func (*NodeExecutionListRequest) ProtoMessage()

func (*NodeExecutionListRequest) Reset

func (m *NodeExecutionListRequest) Reset()

func (*NodeExecutionListRequest) String

func (m *NodeExecutionListRequest) String() string

func (*NodeExecutionListRequest) Validate

func (m *NodeExecutionListRequest) Validate() error

Validate checks the field values on NodeExecutionListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionListRequest) XXX_DiscardUnknown

func (m *NodeExecutionListRequest) XXX_DiscardUnknown()

func (*NodeExecutionListRequest) XXX_Marshal

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

func (*NodeExecutionListRequest) XXX_Merge

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

func (*NodeExecutionListRequest) XXX_Size

func (m *NodeExecutionListRequest) XXX_Size() int

func (*NodeExecutionListRequest) XXX_Unmarshal

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

type NodeExecutionListRequestValidationError

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

NodeExecutionListRequestValidationError is the validation error returned by NodeExecutionListRequest.Validate if the designated constraints aren't met.

func (NodeExecutionListRequestValidationError) Cause

Cause function returns cause value.

func (NodeExecutionListRequestValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionListRequestValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionListRequestValidationError) Field

Field function returns field value.

func (NodeExecutionListRequestValidationError) Key

Key function returns key value.

func (NodeExecutionListRequestValidationError) Reason

Reason function returns reason value.

type NodeExecutionListValidationError

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

NodeExecutionListValidationError is the validation error returned by NodeExecutionList.Validate if the designated constraints aren't met.

func (NodeExecutionListValidationError) Cause

Cause function returns cause value.

func (NodeExecutionListValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionListValidationError) ErrorName

ErrorName returns error name.

func (NodeExecutionListValidationError) Field

Field function returns field value.

func (NodeExecutionListValidationError) Key

Key function returns key value.

func (NodeExecutionListValidationError) Reason

Reason function returns reason value.

type NodeExecutionValidationError

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

NodeExecutionValidationError is the validation error returned by NodeExecution.Validate if the designated constraints aren't met.

func (NodeExecutionValidationError) Cause

Cause function returns cause value.

func (NodeExecutionValidationError) Error

Error satisfies the builtin error interface

func (NodeExecutionValidationError) ErrorName

func (e NodeExecutionValidationError) ErrorName() string

ErrorName returns error name.

func (NodeExecutionValidationError) Field

Field function returns field value.

func (NodeExecutionValidationError) Key

Key function returns key value.

func (NodeExecutionValidationError) Reason

Reason function returns reason value.

type Notification

type Notification struct {
	// A list of phases to which users can associate the notifications to.
	Phases []core.WorkflowExecution_Phase `protobuf:"varint,1,rep,packed,name=phases,proto3,enum=flyteidl.core.WorkflowExecution_Phase" json:"phases,omitempty"`
	// Types that are valid to be assigned to Type:
	//	*Notification_Email
	//	*Notification_PagerDuty
	//	*Notification_Slack
	Type                 isNotification_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Represents a structure for notifications based on execution status. The Notification content is configured within Admin. Future iterations could expose configuring notifications with custom content.

func (*Notification) Descriptor

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

func (*Notification) GetEmail

func (m *Notification) GetEmail() *EmailNotification

func (*Notification) GetPagerDuty

func (m *Notification) GetPagerDuty() *PagerDutyNotification

func (*Notification) GetPhases

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

func (*Notification) GetSlack

func (m *Notification) GetSlack() *SlackNotification

func (*Notification) GetType

func (m *Notification) GetType() isNotification_Type

func (*Notification) ProtoMessage

func (*Notification) ProtoMessage()

func (*Notification) Reset

func (m *Notification) Reset()

func (*Notification) String

func (m *Notification) String() string

func (*Notification) Validate

func (m *Notification) Validate() error

Validate checks the field values on Notification with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Notification) XXX_DiscardUnknown

func (m *Notification) XXX_DiscardUnknown()

func (*Notification) XXX_Marshal

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

func (*Notification) XXX_Merge

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

func (*Notification) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Notification) XXX_Size

func (m *Notification) XXX_Size() int

func (*Notification) XXX_Unmarshal

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

type NotificationList

type NotificationList struct {
	Notifications        []*Notification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*NotificationList) Descriptor

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

func (*NotificationList) GetNotifications

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

func (*NotificationList) ProtoMessage

func (*NotificationList) ProtoMessage()

func (*NotificationList) Reset

func (m *NotificationList) Reset()

func (*NotificationList) String

func (m *NotificationList) String() string

func (*NotificationList) Validate

func (m *NotificationList) Validate() error

Validate checks the field values on NotificationList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NotificationList) XXX_DiscardUnknown

func (m *NotificationList) XXX_DiscardUnknown()

func (*NotificationList) XXX_Marshal

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

func (*NotificationList) XXX_Merge

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

func (*NotificationList) XXX_Size

func (m *NotificationList) XXX_Size() int

func (*NotificationList) XXX_Unmarshal

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

type NotificationListValidationError

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

NotificationListValidationError is the validation error returned by NotificationList.Validate if the designated constraints aren't met.

func (NotificationListValidationError) Cause

Cause function returns cause value.

func (NotificationListValidationError) Error

Error satisfies the builtin error interface

func (NotificationListValidationError) ErrorName

ErrorName returns error name.

func (NotificationListValidationError) Field

Field function returns field value.

func (NotificationListValidationError) Key

Key function returns key value.

func (NotificationListValidationError) Reason

Reason function returns reason value.

type NotificationValidationError

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

NotificationValidationError is the validation error returned by Notification.Validate if the designated constraints aren't met.

func (NotificationValidationError) Cause

Cause function returns cause value.

func (NotificationValidationError) Error

Error satisfies the builtin error interface

func (NotificationValidationError) ErrorName

func (e NotificationValidationError) ErrorName() string

ErrorName returns error name.

func (NotificationValidationError) Field

Field function returns field value.

func (NotificationValidationError) Key

Key function returns key value.

func (NotificationValidationError) Reason

Reason function returns reason value.

type Notification_Email

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

type Notification_PagerDuty

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

type Notification_Slack

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

type ObjectGetRequest

type ObjectGetRequest struct {
	// Indicates a unique version of resource.
	Id                   *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Represents a structure to fetch a single resource.

func (*ObjectGetRequest) Descriptor

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

func (*ObjectGetRequest) GetId

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

func (*ObjectGetRequest) ProtoMessage

func (*ObjectGetRequest) ProtoMessage()

func (*ObjectGetRequest) Reset

func (m *ObjectGetRequest) Reset()

func (*ObjectGetRequest) String

func (m *ObjectGetRequest) String() string

func (*ObjectGetRequest) Validate

func (m *ObjectGetRequest) Validate() error

Validate checks the field values on ObjectGetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ObjectGetRequest) XXX_DiscardUnknown

func (m *ObjectGetRequest) XXX_DiscardUnknown()

func (*ObjectGetRequest) XXX_Marshal

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

func (*ObjectGetRequest) XXX_Merge

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

func (*ObjectGetRequest) XXX_Size

func (m *ObjectGetRequest) XXX_Size() int

func (*ObjectGetRequest) XXX_Unmarshal

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

type ObjectGetRequestValidationError

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

ObjectGetRequestValidationError is the validation error returned by ObjectGetRequest.Validate if the designated constraints aren't met.

func (ObjectGetRequestValidationError) Cause

Cause function returns cause value.

func (ObjectGetRequestValidationError) Error

Error satisfies the builtin error interface

func (ObjectGetRequestValidationError) ErrorName

ErrorName returns error name.

func (ObjectGetRequestValidationError) Field

Field function returns field value.

func (ObjectGetRequestValidationError) Key

Key function returns key value.

func (ObjectGetRequestValidationError) Reason

Reason function returns reason value.

type PagerDutyNotification

type PagerDutyNotification struct {
	// Currently, PagerDuty notifications leverage email to trigger a notification.
	RecipientsEmail      []string `protobuf:"bytes,1,rep,name=recipients_email,json=recipientsEmail,proto3" json:"recipients_email,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PagerDutyNotification) Descriptor

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

func (*PagerDutyNotification) GetRecipientsEmail

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

func (*PagerDutyNotification) ProtoMessage

func (*PagerDutyNotification) ProtoMessage()

func (*PagerDutyNotification) Reset

func (m *PagerDutyNotification) Reset()

func (*PagerDutyNotification) String

func (m *PagerDutyNotification) String() string

func (*PagerDutyNotification) Validate

func (m *PagerDutyNotification) Validate() error

Validate checks the field values on PagerDutyNotification with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*PagerDutyNotification) XXX_DiscardUnknown

func (m *PagerDutyNotification) XXX_DiscardUnknown()

func (*PagerDutyNotification) XXX_Marshal

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

func (*PagerDutyNotification) XXX_Merge

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

func (*PagerDutyNotification) XXX_Size

func (m *PagerDutyNotification) XXX_Size() int

func (*PagerDutyNotification) XXX_Unmarshal

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

type PagerDutyNotificationValidationError

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

PagerDutyNotificationValidationError is the validation error returned by PagerDutyNotification.Validate if the designated constraints aren't met.

func (PagerDutyNotificationValidationError) Cause

Cause function returns cause value.

func (PagerDutyNotificationValidationError) Error

Error satisfies the builtin error interface

func (PagerDutyNotificationValidationError) ErrorName

ErrorName returns error name.

func (PagerDutyNotificationValidationError) Field

Field function returns field value.

func (PagerDutyNotificationValidationError) Key

Key function returns key value.

func (PagerDutyNotificationValidationError) Reason

Reason function returns reason value.

type Project

type Project struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Display name.
	Name                 string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Domains              []*Domain `protobuf:"bytes,3,rep,name=domains,proto3" json:"domains,omitempty"`
	Description          string    `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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

func (*Project) Descriptor

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

func (*Project) GetDescription added in v0.16.0

func (m *Project) GetDescription() string

func (*Project) GetDomains

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

func (*Project) GetId

func (m *Project) GetId() string

func (*Project) GetName

func (m *Project) GetName() string

func (*Project) ProtoMessage

func (*Project) ProtoMessage()

func (*Project) Reset

func (m *Project) Reset()

func (*Project) String

func (m *Project) String() string

func (*Project) Validate

func (m *Project) Validate() error

Validate checks the field values on Project with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Project) XXX_DiscardUnknown

func (m *Project) XXX_DiscardUnknown()

func (*Project) XXX_Marshal

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

func (*Project) XXX_Merge

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

func (*Project) XXX_Size

func (m *Project) XXX_Size() int

func (*Project) XXX_Unmarshal

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

type ProjectDomainAttributes added in v0.16.1

type ProjectDomainAttributes struct {
	// Unique project id for which this set of attributes will be applied.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id for which this set of attributes will be applied.
	Domain               string              `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	MatchingAttributes   *MatchingAttributes `protobuf:"bytes,3,opt,name=matching_attributes,json=matchingAttributes,proto3" json:"matching_attributes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ProjectDomainAttributes) Descriptor added in v0.16.1

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

func (*ProjectDomainAttributes) GetDomain added in v0.16.1

func (m *ProjectDomainAttributes) GetDomain() string

func (*ProjectDomainAttributes) GetMatchingAttributes added in v0.16.4

func (m *ProjectDomainAttributes) GetMatchingAttributes() *MatchingAttributes

func (*ProjectDomainAttributes) GetProject added in v0.16.1

func (m *ProjectDomainAttributes) GetProject() string

func (*ProjectDomainAttributes) ProtoMessage added in v0.16.1

func (*ProjectDomainAttributes) ProtoMessage()

func (*ProjectDomainAttributes) Reset added in v0.16.1

func (m *ProjectDomainAttributes) Reset()

func (*ProjectDomainAttributes) String added in v0.16.1

func (m *ProjectDomainAttributes) String() string

func (*ProjectDomainAttributes) Validate added in v0.16.1

func (m *ProjectDomainAttributes) Validate() error

Validate checks the field values on ProjectDomainAttributes with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectDomainAttributes) XXX_DiscardUnknown added in v0.16.1

func (m *ProjectDomainAttributes) XXX_DiscardUnknown()

func (*ProjectDomainAttributes) XXX_Marshal added in v0.16.1

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

func (*ProjectDomainAttributes) XXX_Merge added in v0.16.1

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

func (*ProjectDomainAttributes) XXX_Size added in v0.16.1

func (m *ProjectDomainAttributes) XXX_Size() int

func (*ProjectDomainAttributes) XXX_Unmarshal added in v0.16.1

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

type ProjectDomainAttributesDeleteRequest added in v0.16.5

type ProjectDomainAttributesDeleteRequest struct {
	// Unique project id which this set of attributes references.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	Domain               string            `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	ResourceType         MatchableResource `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ProjectDomainAttributesDeleteRequest) Descriptor added in v0.16.5

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

func (*ProjectDomainAttributesDeleteRequest) GetDomain added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) GetProject added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) GetResourceType added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) ProtoMessage added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) ProtoMessage()

func (*ProjectDomainAttributesDeleteRequest) Reset added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) String added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) Validate added in v0.16.5

Validate checks the field values on ProjectDomainAttributesDeleteRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectDomainAttributesDeleteRequest) XXX_DiscardUnknown added in v0.16.5

func (m *ProjectDomainAttributesDeleteRequest) XXX_DiscardUnknown()

func (*ProjectDomainAttributesDeleteRequest) XXX_Marshal added in v0.16.5

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

func (*ProjectDomainAttributesDeleteRequest) XXX_Merge added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) XXX_Size added in v0.16.5

func (*ProjectDomainAttributesDeleteRequest) XXX_Unmarshal added in v0.16.5

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

type ProjectDomainAttributesDeleteRequestValidationError added in v0.16.5

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

ProjectDomainAttributesDeleteRequestValidationError is the validation error returned by ProjectDomainAttributesDeleteRequest.Validate if the designated constraints aren't met.

func (ProjectDomainAttributesDeleteRequestValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (ProjectDomainAttributesDeleteRequestValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (ProjectDomainAttributesDeleteRequestValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (ProjectDomainAttributesDeleteRequestValidationError) Field added in v0.16.5

Field function returns field value.

func (ProjectDomainAttributesDeleteRequestValidationError) Key added in v0.16.5

Key function returns key value.

func (ProjectDomainAttributesDeleteRequestValidationError) Reason added in v0.16.5

Reason function returns reason value.

type ProjectDomainAttributesDeleteResponse added in v0.16.5

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

Purposefully empty, may be populated in the future.

func (*ProjectDomainAttributesDeleteResponse) Descriptor added in v0.16.5

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

func (*ProjectDomainAttributesDeleteResponse) ProtoMessage added in v0.16.5

func (*ProjectDomainAttributesDeleteResponse) ProtoMessage()

func (*ProjectDomainAttributesDeleteResponse) Reset added in v0.16.5

func (*ProjectDomainAttributesDeleteResponse) String added in v0.16.5

func (*ProjectDomainAttributesDeleteResponse) Validate added in v0.16.5

Validate checks the field values on ProjectDomainAttributesDeleteResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectDomainAttributesDeleteResponse) XXX_DiscardUnknown added in v0.16.5

func (m *ProjectDomainAttributesDeleteResponse) XXX_DiscardUnknown()

func (*ProjectDomainAttributesDeleteResponse) XXX_Marshal added in v0.16.5

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

func (*ProjectDomainAttributesDeleteResponse) XXX_Merge added in v0.16.5

func (*ProjectDomainAttributesDeleteResponse) XXX_Size added in v0.16.5

func (*ProjectDomainAttributesDeleteResponse) XXX_Unmarshal added in v0.16.5

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

type ProjectDomainAttributesDeleteResponseValidationError added in v0.16.5

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

ProjectDomainAttributesDeleteResponseValidationError is the validation error returned by ProjectDomainAttributesDeleteResponse.Validate if the designated constraints aren't met.

func (ProjectDomainAttributesDeleteResponseValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (ProjectDomainAttributesDeleteResponseValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (ProjectDomainAttributesDeleteResponseValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (ProjectDomainAttributesDeleteResponseValidationError) Field added in v0.16.5

Field function returns field value.

func (ProjectDomainAttributesDeleteResponseValidationError) Key added in v0.16.5

Key function returns key value.

func (ProjectDomainAttributesDeleteResponseValidationError) Reason added in v0.16.5

Reason function returns reason value.

type ProjectDomainAttributesGetRequest added in v0.16.5

type ProjectDomainAttributesGetRequest struct {
	// Unique project id which this set of attributes references.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	Domain               string            `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	ResourceType         MatchableResource `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ProjectDomainAttributesGetRequest) Descriptor added in v0.16.5

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

func (*ProjectDomainAttributesGetRequest) GetDomain added in v0.16.5

func (*ProjectDomainAttributesGetRequest) GetProject added in v0.16.5

func (m *ProjectDomainAttributesGetRequest) GetProject() string

func (*ProjectDomainAttributesGetRequest) GetResourceType added in v0.16.5

func (*ProjectDomainAttributesGetRequest) ProtoMessage added in v0.16.5

func (*ProjectDomainAttributesGetRequest) ProtoMessage()

func (*ProjectDomainAttributesGetRequest) Reset added in v0.16.5

func (*ProjectDomainAttributesGetRequest) String added in v0.16.5

func (*ProjectDomainAttributesGetRequest) Validate added in v0.16.5

Validate checks the field values on ProjectDomainAttributesGetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectDomainAttributesGetRequest) XXX_DiscardUnknown added in v0.16.5

func (m *ProjectDomainAttributesGetRequest) XXX_DiscardUnknown()

func (*ProjectDomainAttributesGetRequest) XXX_Marshal added in v0.16.5

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

func (*ProjectDomainAttributesGetRequest) XXX_Merge added in v0.16.5

func (*ProjectDomainAttributesGetRequest) XXX_Size added in v0.16.5

func (m *ProjectDomainAttributesGetRequest) XXX_Size() int

func (*ProjectDomainAttributesGetRequest) XXX_Unmarshal added in v0.16.5

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

type ProjectDomainAttributesGetRequestValidationError added in v0.16.5

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

ProjectDomainAttributesGetRequestValidationError is the validation error returned by ProjectDomainAttributesGetRequest.Validate if the designated constraints aren't met.

func (ProjectDomainAttributesGetRequestValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (ProjectDomainAttributesGetRequestValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (ProjectDomainAttributesGetRequestValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (ProjectDomainAttributesGetRequestValidationError) Field added in v0.16.5

Field function returns field value.

func (ProjectDomainAttributesGetRequestValidationError) Key added in v0.16.5

Key function returns key value.

func (ProjectDomainAttributesGetRequestValidationError) Reason added in v0.16.5

Reason function returns reason value.

type ProjectDomainAttributesGetResponse added in v0.16.5

type ProjectDomainAttributesGetResponse struct {
	Attributes           *ProjectDomainAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ProjectDomainAttributesGetResponse) Descriptor added in v0.16.5

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

func (*ProjectDomainAttributesGetResponse) GetAttributes added in v0.16.5

func (*ProjectDomainAttributesGetResponse) ProtoMessage added in v0.16.5

func (*ProjectDomainAttributesGetResponse) ProtoMessage()

func (*ProjectDomainAttributesGetResponse) Reset added in v0.16.5

func (*ProjectDomainAttributesGetResponse) String added in v0.16.5

func (*ProjectDomainAttributesGetResponse) Validate added in v0.16.5

Validate checks the field values on ProjectDomainAttributesGetResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectDomainAttributesGetResponse) XXX_DiscardUnknown added in v0.16.5

func (m *ProjectDomainAttributesGetResponse) XXX_DiscardUnknown()

func (*ProjectDomainAttributesGetResponse) XXX_Marshal added in v0.16.5

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

func (*ProjectDomainAttributesGetResponse) XXX_Merge added in v0.16.5

func (*ProjectDomainAttributesGetResponse) XXX_Size added in v0.16.5

func (*ProjectDomainAttributesGetResponse) XXX_Unmarshal added in v0.16.5

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

type ProjectDomainAttributesGetResponseValidationError added in v0.16.5

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

ProjectDomainAttributesGetResponseValidationError is the validation error returned by ProjectDomainAttributesGetResponse.Validate if the designated constraints aren't met.

func (ProjectDomainAttributesGetResponseValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (ProjectDomainAttributesGetResponseValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (ProjectDomainAttributesGetResponseValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (ProjectDomainAttributesGetResponseValidationError) Field added in v0.16.5

Field function returns field value.

func (ProjectDomainAttributesGetResponseValidationError) Key added in v0.16.5

Key function returns key value.

func (ProjectDomainAttributesGetResponseValidationError) Reason added in v0.16.5

Reason function returns reason value.

type ProjectDomainAttributesUpdateRequest added in v0.16.1

type ProjectDomainAttributesUpdateRequest struct {
	Attributes           *ProjectDomainAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Sets custom attributes for a project-domain combination.

func (*ProjectDomainAttributesUpdateRequest) Descriptor added in v0.16.1

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

func (*ProjectDomainAttributesUpdateRequest) GetAttributes added in v0.16.1

func (*ProjectDomainAttributesUpdateRequest) ProtoMessage added in v0.16.1

func (*ProjectDomainAttributesUpdateRequest) ProtoMessage()

func (*ProjectDomainAttributesUpdateRequest) Reset added in v0.16.1

func (*ProjectDomainAttributesUpdateRequest) String added in v0.16.1

func (*ProjectDomainAttributesUpdateRequest) Validate added in v0.16.1

Validate checks the field values on ProjectDomainAttributesUpdateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectDomainAttributesUpdateRequest) XXX_DiscardUnknown added in v0.16.1

func (m *ProjectDomainAttributesUpdateRequest) XXX_DiscardUnknown()

func (*ProjectDomainAttributesUpdateRequest) XXX_Marshal added in v0.16.1

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

func (*ProjectDomainAttributesUpdateRequest) XXX_Merge added in v0.16.1

func (*ProjectDomainAttributesUpdateRequest) XXX_Size added in v0.16.1

func (*ProjectDomainAttributesUpdateRequest) XXX_Unmarshal added in v0.16.1

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

type ProjectDomainAttributesUpdateRequestValidationError added in v0.16.1

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

ProjectDomainAttributesUpdateRequestValidationError is the validation error returned by ProjectDomainAttributesUpdateRequest.Validate if the designated constraints aren't met.

func (ProjectDomainAttributesUpdateRequestValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (ProjectDomainAttributesUpdateRequestValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (ProjectDomainAttributesUpdateRequestValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (ProjectDomainAttributesUpdateRequestValidationError) Field added in v0.16.1

Field function returns field value.

func (ProjectDomainAttributesUpdateRequestValidationError) Key added in v0.16.1

Key function returns key value.

func (ProjectDomainAttributesUpdateRequestValidationError) Reason added in v0.16.1

Reason function returns reason value.

type ProjectDomainAttributesUpdateResponse added in v0.16.1

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

Purposefully empty, may be populated in the future.

func (*ProjectDomainAttributesUpdateResponse) Descriptor added in v0.16.1

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

func (*ProjectDomainAttributesUpdateResponse) ProtoMessage added in v0.16.1

func (*ProjectDomainAttributesUpdateResponse) ProtoMessage()

func (*ProjectDomainAttributesUpdateResponse) Reset added in v0.16.1

func (*ProjectDomainAttributesUpdateResponse) String added in v0.16.1

func (*ProjectDomainAttributesUpdateResponse) Validate added in v0.16.1

Validate checks the field values on ProjectDomainAttributesUpdateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectDomainAttributesUpdateResponse) XXX_DiscardUnknown added in v0.16.1

func (m *ProjectDomainAttributesUpdateResponse) XXX_DiscardUnknown()

func (*ProjectDomainAttributesUpdateResponse) XXX_Marshal added in v0.16.1

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

func (*ProjectDomainAttributesUpdateResponse) XXX_Merge added in v0.16.1

func (*ProjectDomainAttributesUpdateResponse) XXX_Size added in v0.16.1

func (*ProjectDomainAttributesUpdateResponse) XXX_Unmarshal added in v0.16.1

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

type ProjectDomainAttributesUpdateResponseValidationError added in v0.16.1

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

ProjectDomainAttributesUpdateResponseValidationError is the validation error returned by ProjectDomainAttributesUpdateResponse.Validate if the designated constraints aren't met.

func (ProjectDomainAttributesUpdateResponseValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (ProjectDomainAttributesUpdateResponseValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (ProjectDomainAttributesUpdateResponseValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (ProjectDomainAttributesUpdateResponseValidationError) Field added in v0.16.1

Field function returns field value.

func (ProjectDomainAttributesUpdateResponseValidationError) Key added in v0.16.1

Key function returns key value.

func (ProjectDomainAttributesUpdateResponseValidationError) Reason added in v0.16.1

Reason function returns reason value.

type ProjectDomainAttributesValidationError added in v0.16.1

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

ProjectDomainAttributesValidationError is the validation error returned by ProjectDomainAttributes.Validate if the designated constraints aren't met.

func (ProjectDomainAttributesValidationError) Cause added in v0.16.1

Cause function returns cause value.

func (ProjectDomainAttributesValidationError) Error added in v0.16.1

Error satisfies the builtin error interface

func (ProjectDomainAttributesValidationError) ErrorName added in v0.16.1

ErrorName returns error name.

func (ProjectDomainAttributesValidationError) Field added in v0.16.1

Field function returns field value.

func (ProjectDomainAttributesValidationError) Key added in v0.16.1

Key function returns key value.

func (ProjectDomainAttributesValidationError) Reason added in v0.16.1

Reason function returns reason value.

type ProjectListRequest

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

func (*ProjectListRequest) Descriptor

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

func (*ProjectListRequest) ProtoMessage

func (*ProjectListRequest) ProtoMessage()

func (*ProjectListRequest) Reset

func (m *ProjectListRequest) Reset()

func (*ProjectListRequest) String

func (m *ProjectListRequest) String() string

func (*ProjectListRequest) Validate

func (m *ProjectListRequest) Validate() error

Validate checks the field values on ProjectListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectListRequest) XXX_DiscardUnknown

func (m *ProjectListRequest) XXX_DiscardUnknown()

func (*ProjectListRequest) XXX_Marshal

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

func (*ProjectListRequest) XXX_Merge

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

func (*ProjectListRequest) XXX_Size

func (m *ProjectListRequest) XXX_Size() int

func (*ProjectListRequest) XXX_Unmarshal

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

type ProjectListRequestValidationError

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

ProjectListRequestValidationError is the validation error returned by ProjectListRequest.Validate if the designated constraints aren't met.

func (ProjectListRequestValidationError) Cause

Cause function returns cause value.

func (ProjectListRequestValidationError) Error

Error satisfies the builtin error interface

func (ProjectListRequestValidationError) ErrorName

ErrorName returns error name.

func (ProjectListRequestValidationError) Field

Field function returns field value.

func (ProjectListRequestValidationError) Key

Key function returns key value.

func (ProjectListRequestValidationError) Reason

Reason function returns reason value.

type ProjectRegisterRequest

type ProjectRegisterRequest struct {
	Project              *Project `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProjectRegisterRequest) Descriptor

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

func (*ProjectRegisterRequest) GetProject

func (m *ProjectRegisterRequest) GetProject() *Project

func (*ProjectRegisterRequest) ProtoMessage

func (*ProjectRegisterRequest) ProtoMessage()

func (*ProjectRegisterRequest) Reset

func (m *ProjectRegisterRequest) Reset()

func (*ProjectRegisterRequest) String

func (m *ProjectRegisterRequest) String() string

func (*ProjectRegisterRequest) Validate

func (m *ProjectRegisterRequest) Validate() error

Validate checks the field values on ProjectRegisterRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectRegisterRequest) XXX_DiscardUnknown

func (m *ProjectRegisterRequest) XXX_DiscardUnknown()

func (*ProjectRegisterRequest) XXX_Marshal

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

func (*ProjectRegisterRequest) XXX_Merge

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

func (*ProjectRegisterRequest) XXX_Size

func (m *ProjectRegisterRequest) XXX_Size() int

func (*ProjectRegisterRequest) XXX_Unmarshal

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

type ProjectRegisterRequestValidationError

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

ProjectRegisterRequestValidationError is the validation error returned by ProjectRegisterRequest.Validate if the designated constraints aren't met.

func (ProjectRegisterRequestValidationError) Cause

Cause function returns cause value.

func (ProjectRegisterRequestValidationError) Error

Error satisfies the builtin error interface

func (ProjectRegisterRequestValidationError) ErrorName

ErrorName returns error name.

func (ProjectRegisterRequestValidationError) Field

Field function returns field value.

func (ProjectRegisterRequestValidationError) Key

Key function returns key value.

func (ProjectRegisterRequestValidationError) Reason

Reason function returns reason value.

type ProjectRegisterResponse

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

func (*ProjectRegisterResponse) Descriptor

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

func (*ProjectRegisterResponse) ProtoMessage

func (*ProjectRegisterResponse) ProtoMessage()

func (*ProjectRegisterResponse) Reset

func (m *ProjectRegisterResponse) Reset()

func (*ProjectRegisterResponse) String

func (m *ProjectRegisterResponse) String() string

func (*ProjectRegisterResponse) Validate

func (m *ProjectRegisterResponse) Validate() error

Validate checks the field values on ProjectRegisterResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ProjectRegisterResponse) XXX_DiscardUnknown

func (m *ProjectRegisterResponse) XXX_DiscardUnknown()

func (*ProjectRegisterResponse) XXX_Marshal

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

func (*ProjectRegisterResponse) XXX_Merge

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

func (*ProjectRegisterResponse) XXX_Size

func (m *ProjectRegisterResponse) XXX_Size() int

func (*ProjectRegisterResponse) XXX_Unmarshal

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

type ProjectRegisterResponseValidationError

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

ProjectRegisterResponseValidationError is the validation error returned by ProjectRegisterResponse.Validate if the designated constraints aren't met.

func (ProjectRegisterResponseValidationError) Cause

Cause function returns cause value.

func (ProjectRegisterResponseValidationError) Error

Error satisfies the builtin error interface

func (ProjectRegisterResponseValidationError) ErrorName

ErrorName returns error name.

func (ProjectRegisterResponseValidationError) Field

Field function returns field value.

func (ProjectRegisterResponseValidationError) Key

Key function returns key value.

func (ProjectRegisterResponseValidationError) Reason

Reason function returns reason value.

type ProjectValidationError

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

ProjectValidationError is the validation error returned by Project.Validate if the designated constraints aren't met.

func (ProjectValidationError) Cause

func (e ProjectValidationError) Cause() error

Cause function returns cause value.

func (ProjectValidationError) Error

func (e ProjectValidationError) Error() string

Error satisfies the builtin error interface

func (ProjectValidationError) ErrorName

func (e ProjectValidationError) ErrorName() string

ErrorName returns error name.

func (ProjectValidationError) Field

func (e ProjectValidationError) Field() string

Field function returns field value.

func (ProjectValidationError) Key

func (e ProjectValidationError) Key() bool

Key function returns key value.

func (ProjectValidationError) Reason

func (e ProjectValidationError) Reason() string

Reason function returns reason value.

type Projects

type Projects struct {
	Projects             []*Project `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Projects) Descriptor

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

func (*Projects) GetProjects

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

func (*Projects) ProtoMessage

func (*Projects) ProtoMessage()

func (*Projects) Reset

func (m *Projects) Reset()

func (*Projects) String

func (m *Projects) String() string

func (*Projects) Validate

func (m *Projects) Validate() error

Validate checks the field values on Projects with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Projects) XXX_DiscardUnknown

func (m *Projects) XXX_DiscardUnknown()

func (*Projects) XXX_Marshal

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

func (*Projects) XXX_Merge

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

func (*Projects) XXX_Size

func (m *Projects) XXX_Size() int

func (*Projects) XXX_Unmarshal

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

type ProjectsValidationError

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

ProjectsValidationError is the validation error returned by Projects.Validate if the designated constraints aren't met.

func (ProjectsValidationError) Cause

func (e ProjectsValidationError) Cause() error

Cause function returns cause value.

func (ProjectsValidationError) Error

func (e ProjectsValidationError) Error() string

Error satisfies the builtin error interface

func (ProjectsValidationError) ErrorName

func (e ProjectsValidationError) ErrorName() string

ErrorName returns error name.

func (ProjectsValidationError) Field

func (e ProjectsValidationError) Field() string

Field function returns field value.

func (ProjectsValidationError) Key

func (e ProjectsValidationError) Key() bool

Key function returns key value.

func (ProjectsValidationError) Reason

func (e ProjectsValidationError) Reason() string

Reason function returns reason value.

type ResourceListRequest

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

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

func (*ResourceListRequest) Descriptor

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

func (*ResourceListRequest) GetFilters

func (m *ResourceListRequest) GetFilters() string

func (*ResourceListRequest) GetId

func (*ResourceListRequest) GetLimit

func (m *ResourceListRequest) GetLimit() uint32

func (*ResourceListRequest) GetSortBy

func (m *ResourceListRequest) GetSortBy() *Sort

func (*ResourceListRequest) GetToken

func (m *ResourceListRequest) GetToken() string

func (*ResourceListRequest) ProtoMessage

func (*ResourceListRequest) ProtoMessage()

func (*ResourceListRequest) Reset

func (m *ResourceListRequest) Reset()

func (*ResourceListRequest) String

func (m *ResourceListRequest) String() string

func (*ResourceListRequest) Validate

func (m *ResourceListRequest) Validate() error

Validate checks the field values on ResourceListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ResourceListRequest) XXX_DiscardUnknown

func (m *ResourceListRequest) XXX_DiscardUnknown()

func (*ResourceListRequest) XXX_Marshal

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

func (*ResourceListRequest) XXX_Merge

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

func (*ResourceListRequest) XXX_Size

func (m *ResourceListRequest) XXX_Size() int

func (*ResourceListRequest) XXX_Unmarshal

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

type ResourceListRequestValidationError

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

ResourceListRequestValidationError is the validation error returned by ResourceListRequest.Validate if the designated constraints aren't met.

func (ResourceListRequestValidationError) Cause

Cause function returns cause value.

func (ResourceListRequestValidationError) Error

Error satisfies the builtin error interface

func (ResourceListRequestValidationError) ErrorName

ErrorName returns error name.

func (ResourceListRequestValidationError) Field

Field function returns field value.

func (ResourceListRequestValidationError) Key

Key function returns key value.

func (ResourceListRequestValidationError) Reason

Reason function returns reason value.

type Schedule

type Schedule struct {
	// Types that are valid to be assigned to ScheduleExpression:
	//	*Schedule_CronExpression
	//	*Schedule_Rate
	ScheduleExpression isSchedule_ScheduleExpression `protobuf_oneof:"ScheduleExpression"`
	// Name of the input variable that the kickoff time will be supplied to when the workflow is kicked off.
	KickoffTimeInputArg  string   `protobuf:"bytes,3,opt,name=kickoff_time_input_arg,json=kickoffTimeInputArg,proto3" json:"kickoff_time_input_arg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*Schedule) Descriptor

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

func (*Schedule) GetCronExpression

func (m *Schedule) GetCronExpression() string

func (*Schedule) GetKickoffTimeInputArg

func (m *Schedule) GetKickoffTimeInputArg() string

func (*Schedule) GetRate

func (m *Schedule) GetRate() *FixedRate

func (*Schedule) GetScheduleExpression

func (m *Schedule) GetScheduleExpression() isSchedule_ScheduleExpression

func (*Schedule) ProtoMessage

func (*Schedule) ProtoMessage()

func (*Schedule) Reset

func (m *Schedule) Reset()

func (*Schedule) String

func (m *Schedule) String() string

func (*Schedule) Validate

func (m *Schedule) Validate() error

Validate checks the field values on Schedule with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Schedule) XXX_DiscardUnknown

func (m *Schedule) XXX_DiscardUnknown()

func (*Schedule) XXX_Marshal

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

func (*Schedule) XXX_Merge

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

func (*Schedule) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Schedule) XXX_Size

func (m *Schedule) XXX_Size() int

func (*Schedule) XXX_Unmarshal

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

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_CronExpression

type Schedule_CronExpression struct {
	CronExpression string `protobuf:"bytes,1,opt,name=cron_expression,json=cronExpression,proto3,oneof"`
}

type Schedule_Rate

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

type SlackNotification

type SlackNotification struct {
	// Currently, Slack notifications leverage email to trigger a notification.
	RecipientsEmail      []string `protobuf:"bytes,1,rep,name=recipients_email,json=recipientsEmail,proto3" json:"recipients_email,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SlackNotification) Descriptor

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

func (*SlackNotification) GetRecipientsEmail

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

func (*SlackNotification) ProtoMessage

func (*SlackNotification) ProtoMessage()

func (*SlackNotification) Reset

func (m *SlackNotification) Reset()

func (*SlackNotification) String

func (m *SlackNotification) String() string

func (*SlackNotification) Validate

func (m *SlackNotification) Validate() error

Validate checks the field values on SlackNotification with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SlackNotification) XXX_DiscardUnknown

func (m *SlackNotification) XXX_DiscardUnknown()

func (*SlackNotification) XXX_Marshal

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

func (*SlackNotification) XXX_Merge

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

func (*SlackNotification) XXX_Size

func (m *SlackNotification) XXX_Size() int

func (*SlackNotification) XXX_Unmarshal

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

type SlackNotificationValidationError

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

SlackNotificationValidationError is the validation error returned by SlackNotification.Validate if the designated constraints aren't met.

func (SlackNotificationValidationError) Cause

Cause function returns cause value.

func (SlackNotificationValidationError) Error

Error satisfies the builtin error interface

func (SlackNotificationValidationError) ErrorName

ErrorName returns error name.

func (SlackNotificationValidationError) Field

Field function returns field value.

func (SlackNotificationValidationError) Key

Key function returns key value.

func (SlackNotificationValidationError) Reason

Reason function returns reason value.

type Sort

type Sort struct {
	// Indicates an attribute to sort the response values.
	// TODO(katrogan): Add string validation here. This should never be empty.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Indicates the direction to apply sort key for response values.
	// +optional
	Direction            Sort_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=flyteidl.admin.Sort_Direction" json:"direction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

Species sort ordering in a list request.

func (*Sort) Descriptor

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

func (*Sort) GetDirection

func (m *Sort) GetDirection() Sort_Direction

func (*Sort) GetKey

func (m *Sort) GetKey() string

func (*Sort) ProtoMessage

func (*Sort) ProtoMessage()

func (*Sort) Reset

func (m *Sort) Reset()

func (*Sort) String

func (m *Sort) String() string

func (*Sort) Validate

func (m *Sort) Validate() error

Validate checks the field values on Sort with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Sort) XXX_DiscardUnknown

func (m *Sort) XXX_DiscardUnknown()

func (*Sort) XXX_Marshal

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

func (*Sort) XXX_Merge

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

func (*Sort) XXX_Size

func (m *Sort) XXX_Size() int

func (*Sort) XXX_Unmarshal

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

type SortValidationError

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

SortValidationError is the validation error returned by Sort.Validate if the designated constraints aren't met.

func (SortValidationError) Cause

func (e SortValidationError) Cause() error

Cause function returns cause value.

func (SortValidationError) Error

func (e SortValidationError) Error() string

Error satisfies the builtin error interface

func (SortValidationError) ErrorName

func (e SortValidationError) ErrorName() string

ErrorName returns error name.

func (SortValidationError) Field

func (e SortValidationError) Field() string

Field function returns field value.

func (SortValidationError) Key

func (e SortValidationError) Key() bool

Key function returns key value.

func (SortValidationError) Reason

func (e SortValidationError) Reason() string

Reason function returns reason value.

type Sort_Direction

type Sort_Direction int32
const (
	Sort_DESCENDING Sort_Direction = 0
	Sort_ASCENDING  Sort_Direction = 1
)

func (Sort_Direction) EnumDescriptor

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

func (Sort_Direction) String

func (x Sort_Direction) String() string

type Task

type Task struct {
	// id represents the unique identifier of the task.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// closure encapsulates all the fields that maps to a compiled version of the task.
	Closure              *TaskClosure `protobuf:"bytes,2,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*Task) Descriptor

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

func (*Task) GetClosure

func (m *Task) GetClosure() *TaskClosure

func (*Task) GetId

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

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) Reset

func (m *Task) Reset()

func (*Task) String

func (m *Task) String() string

func (*Task) Validate

func (m *Task) Validate() error

Validate checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Task) XXX_DiscardUnknown

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal

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

func (*Task) XXX_Merge

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

func (*Task) XXX_Size

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal

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

type TaskClosure

type TaskClosure struct {
	// Represents the compiled representation of the task from the specification provided.
	CompiledTask *core.CompiledTask `protobuf:"bytes,1,opt,name=compiled_task,json=compiledTask,proto3" json:"compiled_task,omitempty"`
	// Time at which the task was created.
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

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

func (*TaskClosure) Descriptor

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

func (*TaskClosure) GetCompiledTask

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

func (*TaskClosure) GetCreatedAt

func (m *TaskClosure) GetCreatedAt() *timestamp.Timestamp

func (*TaskClosure) ProtoMessage

func (*TaskClosure) ProtoMessage()

func (*TaskClosure) Reset

func (m *TaskClosure) Reset()

func (*TaskClosure) String

func (m *TaskClosure) String() string

func (*TaskClosure) Validate

func (m *TaskClosure) Validate() error

Validate checks the field values on TaskClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskClosure) XXX_DiscardUnknown

func (m *TaskClosure) XXX_DiscardUnknown()

func (*TaskClosure) XXX_Marshal

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

func (*TaskClosure) XXX_Merge

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

func (*TaskClosure) XXX_Size

func (m *TaskClosure) XXX_Size() int

func (*TaskClosure) XXX_Unmarshal

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

type TaskClosureValidationError

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

TaskClosureValidationError is the validation error returned by TaskClosure.Validate if the designated constraints aren't met.

func (TaskClosureValidationError) Cause

Cause function returns cause value.

func (TaskClosureValidationError) Error

Error satisfies the builtin error interface

func (TaskClosureValidationError) ErrorName

func (e TaskClosureValidationError) ErrorName() string

ErrorName returns error name.

func (TaskClosureValidationError) Field

Field function returns field value.

func (TaskClosureValidationError) Key

Key function returns key value.

func (TaskClosureValidationError) Reason

Reason function returns reason value.

type TaskCreateRequest

type TaskCreateRequest struct {
	// id represents the unique identifier of the task.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Represents the specification for task.
	Spec                 *TaskSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Represents a request structure to create a revision of a task.

func (*TaskCreateRequest) Descriptor

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

func (*TaskCreateRequest) GetId

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

func (*TaskCreateRequest) GetSpec

func (m *TaskCreateRequest) GetSpec() *TaskSpec

func (*TaskCreateRequest) ProtoMessage

func (*TaskCreateRequest) ProtoMessage()

func (*TaskCreateRequest) Reset

func (m *TaskCreateRequest) Reset()

func (*TaskCreateRequest) String

func (m *TaskCreateRequest) String() string

func (*TaskCreateRequest) Validate

func (m *TaskCreateRequest) Validate() error

Validate checks the field values on TaskCreateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskCreateRequest) XXX_DiscardUnknown

func (m *TaskCreateRequest) XXX_DiscardUnknown()

func (*TaskCreateRequest) XXX_Marshal

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

func (*TaskCreateRequest) XXX_Merge

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

func (*TaskCreateRequest) XXX_Size

func (m *TaskCreateRequest) XXX_Size() int

func (*TaskCreateRequest) XXX_Unmarshal

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

type TaskCreateRequestValidationError

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

TaskCreateRequestValidationError is the validation error returned by TaskCreateRequest.Validate if the designated constraints aren't met.

func (TaskCreateRequestValidationError) Cause

Cause function returns cause value.

func (TaskCreateRequestValidationError) Error

Error satisfies the builtin error interface

func (TaskCreateRequestValidationError) ErrorName

ErrorName returns error name.

func (TaskCreateRequestValidationError) Field

Field function returns field value.

func (TaskCreateRequestValidationError) Key

Key function returns key value.

func (TaskCreateRequestValidationError) Reason

Reason function returns reason value.

type TaskCreateResponse

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

Represents a response structure if task creation succeeds.

func (*TaskCreateResponse) Descriptor

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

func (*TaskCreateResponse) ProtoMessage

func (*TaskCreateResponse) ProtoMessage()

func (*TaskCreateResponse) Reset

func (m *TaskCreateResponse) Reset()

func (*TaskCreateResponse) String

func (m *TaskCreateResponse) String() string

func (*TaskCreateResponse) Validate

func (m *TaskCreateResponse) Validate() error

Validate checks the field values on TaskCreateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskCreateResponse) XXX_DiscardUnknown

func (m *TaskCreateResponse) XXX_DiscardUnknown()

func (*TaskCreateResponse) XXX_Marshal

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

func (*TaskCreateResponse) XXX_Merge

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

func (*TaskCreateResponse) XXX_Size

func (m *TaskCreateResponse) XXX_Size() int

func (*TaskCreateResponse) XXX_Unmarshal

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

type TaskCreateResponseValidationError

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

TaskCreateResponseValidationError is the validation error returned by TaskCreateResponse.Validate if the designated constraints aren't met.

func (TaskCreateResponseValidationError) Cause

Cause function returns cause value.

func (TaskCreateResponseValidationError) Error

Error satisfies the builtin error interface

func (TaskCreateResponseValidationError) ErrorName

ErrorName returns error name.

func (TaskCreateResponseValidationError) Field

Field function returns field value.

func (TaskCreateResponseValidationError) Key

Key function returns key value.

func (TaskCreateResponseValidationError) Reason

Reason function returns reason value.

type TaskExecution

type TaskExecution struct {
	// Unique identifier for the task execution.
	Id *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Path to remote data store where input blob is stored.
	InputUri string `protobuf:"bytes,2,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Task execution details and results.
	Closure *TaskExecutionClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	// Whether this task spawned nodes.
	IsParent             bool     `protobuf:"varint,4,opt,name=is_parent,json=isParent,proto3" json:"is_parent,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*TaskExecution) Descriptor

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

func (*TaskExecution) GetClosure

func (m *TaskExecution) GetClosure() *TaskExecutionClosure

func (*TaskExecution) GetId

func (*TaskExecution) GetInputUri

func (m *TaskExecution) GetInputUri() string

func (*TaskExecution) GetIsParent

func (m *TaskExecution) GetIsParent() bool

func (*TaskExecution) ProtoMessage

func (*TaskExecution) ProtoMessage()

func (*TaskExecution) Reset

func (m *TaskExecution) Reset()

func (*TaskExecution) String

func (m *TaskExecution) String() string

func (*TaskExecution) Validate

func (m *TaskExecution) Validate() error

Validate checks the field values on TaskExecution with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecution) XXX_DiscardUnknown

func (m *TaskExecution) XXX_DiscardUnknown()

func (*TaskExecution) XXX_Marshal

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

func (*TaskExecution) XXX_Merge

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

func (*TaskExecution) XXX_Size

func (m *TaskExecution) XXX_Size() int

func (*TaskExecution) XXX_Unmarshal

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

type TaskExecutionClosure

type TaskExecutionClosure struct {
	// Types that are valid to be assigned to OutputResult:
	//	*TaskExecutionClosure_OutputUri
	//	*TaskExecutionClosure_Error
	OutputResult isTaskExecutionClosure_OutputResult `protobuf_oneof:"output_result"`
	// The last recorded phase for this task execution.
	Phase core.TaskExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.TaskExecution_Phase" json:"phase,omitempty"`
	// Detailed log information output by the task execution.
	Logs []*core.TaskLog `protobuf:"bytes,4,rep,name=logs,proto3" json:"logs,omitempty"`
	// Time at which the task execution began running.
	StartedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// The amount of time the task execution spent running.
	Duration *duration.Duration `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// Time at which the task execution was created.
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Time at which the task execution was last updated.
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// Custom data specific to the task plugin.
	CustomInfo           *_struct.Struct `protobuf:"bytes,9,opt,name=custom_info,json=customInfo,proto3" json:"custom_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Container for task execution details and results.

func (*TaskExecutionClosure) Descriptor

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

func (*TaskExecutionClosure) GetCreatedAt

func (m *TaskExecutionClosure) GetCreatedAt() *timestamp.Timestamp

func (*TaskExecutionClosure) GetCustomInfo

func (m *TaskExecutionClosure) GetCustomInfo() *_struct.Struct

func (*TaskExecutionClosure) GetDuration

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

func (*TaskExecutionClosure) GetError

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

func (*TaskExecutionClosure) GetLogs

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

func (*TaskExecutionClosure) GetOutputResult

func (m *TaskExecutionClosure) GetOutputResult() isTaskExecutionClosure_OutputResult

func (*TaskExecutionClosure) GetOutputUri

func (m *TaskExecutionClosure) GetOutputUri() string

func (*TaskExecutionClosure) GetPhase

func (*TaskExecutionClosure) GetStartedAt

func (m *TaskExecutionClosure) GetStartedAt() *timestamp.Timestamp

func (*TaskExecutionClosure) GetUpdatedAt

func (m *TaskExecutionClosure) GetUpdatedAt() *timestamp.Timestamp

func (*TaskExecutionClosure) ProtoMessage

func (*TaskExecutionClosure) ProtoMessage()

func (*TaskExecutionClosure) Reset

func (m *TaskExecutionClosure) Reset()

func (*TaskExecutionClosure) String

func (m *TaskExecutionClosure) String() string

func (*TaskExecutionClosure) Validate

func (m *TaskExecutionClosure) Validate() error

Validate checks the field values on TaskExecutionClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionClosure) XXX_DiscardUnknown

func (m *TaskExecutionClosure) XXX_DiscardUnknown()

func (*TaskExecutionClosure) XXX_Marshal

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

func (*TaskExecutionClosure) XXX_Merge

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

func (*TaskExecutionClosure) XXX_OneofWrappers added in v0.16.1

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TaskExecutionClosure) XXX_Size

func (m *TaskExecutionClosure) XXX_Size() int

func (*TaskExecutionClosure) XXX_Unmarshal

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

type TaskExecutionClosureValidationError

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

TaskExecutionClosureValidationError is the validation error returned by TaskExecutionClosure.Validate if the designated constraints aren't met.

func (TaskExecutionClosureValidationError) Cause

Cause function returns cause value.

func (TaskExecutionClosureValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionClosureValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionClosureValidationError) Field

Field function returns field value.

func (TaskExecutionClosureValidationError) Key

Key function returns key value.

func (TaskExecutionClosureValidationError) Reason

Reason function returns reason value.

type TaskExecutionClosure_Error

type TaskExecutionClosure_Error struct {
	Error *core.ExecutionError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type TaskExecutionClosure_OutputUri

type TaskExecutionClosure_OutputUri struct {
	OutputUri string `protobuf:"bytes,1,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type TaskExecutionEventRequest

type TaskExecutionEventRequest struct {
	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event                *event.TaskExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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

func (*TaskExecutionEventRequest) Descriptor

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

func (*TaskExecutionEventRequest) GetEvent

func (*TaskExecutionEventRequest) GetRequestId

func (m *TaskExecutionEventRequest) GetRequestId() string

func (*TaskExecutionEventRequest) ProtoMessage

func (*TaskExecutionEventRequest) ProtoMessage()

func (*TaskExecutionEventRequest) Reset

func (m *TaskExecutionEventRequest) Reset()

func (*TaskExecutionEventRequest) String

func (m *TaskExecutionEventRequest) String() string

func (*TaskExecutionEventRequest) Validate

func (m *TaskExecutionEventRequest) Validate() error

Validate checks the field values on TaskExecutionEventRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionEventRequest) XXX_DiscardUnknown

func (m *TaskExecutionEventRequest) XXX_DiscardUnknown()

func (*TaskExecutionEventRequest) XXX_Marshal

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

func (*TaskExecutionEventRequest) XXX_Merge

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

func (*TaskExecutionEventRequest) XXX_Size

func (m *TaskExecutionEventRequest) XXX_Size() int

func (*TaskExecutionEventRequest) XXX_Unmarshal

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

type TaskExecutionEventRequestValidationError

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

TaskExecutionEventRequestValidationError is the validation error returned by TaskExecutionEventRequest.Validate if the designated constraints aren't met.

func (TaskExecutionEventRequestValidationError) Cause

Cause function returns cause value.

func (TaskExecutionEventRequestValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionEventRequestValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionEventRequestValidationError) Field

Field function returns field value.

func (TaskExecutionEventRequestValidationError) Key

Key function returns key value.

func (TaskExecutionEventRequestValidationError) Reason

Reason function returns reason value.

type TaskExecutionEventResponse

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

func (*TaskExecutionEventResponse) Descriptor

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

func (*TaskExecutionEventResponse) ProtoMessage

func (*TaskExecutionEventResponse) ProtoMessage()

func (*TaskExecutionEventResponse) Reset

func (m *TaskExecutionEventResponse) Reset()

func (*TaskExecutionEventResponse) String

func (m *TaskExecutionEventResponse) String() string

func (*TaskExecutionEventResponse) Validate

func (m *TaskExecutionEventResponse) Validate() error

Validate checks the field values on TaskExecutionEventResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionEventResponse) XXX_DiscardUnknown

func (m *TaskExecutionEventResponse) XXX_DiscardUnknown()

func (*TaskExecutionEventResponse) XXX_Marshal

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

func (*TaskExecutionEventResponse) XXX_Merge

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

func (*TaskExecutionEventResponse) XXX_Size

func (m *TaskExecutionEventResponse) XXX_Size() int

func (*TaskExecutionEventResponse) XXX_Unmarshal

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

type TaskExecutionEventResponseValidationError

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

TaskExecutionEventResponseValidationError is the validation error returned by TaskExecutionEventResponse.Validate if the designated constraints aren't met.

func (TaskExecutionEventResponseValidationError) Cause

Cause function returns cause value.

func (TaskExecutionEventResponseValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionEventResponseValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionEventResponseValidationError) Field

Field function returns field value.

func (TaskExecutionEventResponseValidationError) Key

Key function returns key value.

func (TaskExecutionEventResponseValidationError) Reason

Reason function returns reason value.

type TaskExecutionGetDataRequest

type TaskExecutionGetDataRequest struct {
	// The identifier of the task execution for which to fetch inputs and outputs.
	Id                   *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

Request structure to fetch inputs and output urls for a task execution.

func (*TaskExecutionGetDataRequest) Descriptor

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

func (*TaskExecutionGetDataRequest) GetId

func (*TaskExecutionGetDataRequest) ProtoMessage

func (*TaskExecutionGetDataRequest) ProtoMessage()

func (*TaskExecutionGetDataRequest) Reset

func (m *TaskExecutionGetDataRequest) Reset()

func (*TaskExecutionGetDataRequest) String

func (m *TaskExecutionGetDataRequest) String() string

func (*TaskExecutionGetDataRequest) Validate

func (m *TaskExecutionGetDataRequest) Validate() error

Validate checks the field values on TaskExecutionGetDataRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionGetDataRequest) XXX_DiscardUnknown

func (m *TaskExecutionGetDataRequest) XXX_DiscardUnknown()

func (*TaskExecutionGetDataRequest) XXX_Marshal

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

func (*TaskExecutionGetDataRequest) XXX_Merge

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

func (*TaskExecutionGetDataRequest) XXX_Size

func (m *TaskExecutionGetDataRequest) XXX_Size() int

func (*TaskExecutionGetDataRequest) XXX_Unmarshal

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

type TaskExecutionGetDataRequestValidationError

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

TaskExecutionGetDataRequestValidationError is the validation error returned by TaskExecutionGetDataRequest.Validate if the designated constraints aren't met.

func (TaskExecutionGetDataRequestValidationError) Cause

Cause function returns cause value.

func (TaskExecutionGetDataRequestValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionGetDataRequestValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionGetDataRequestValidationError) Field

Field function returns field value.

func (TaskExecutionGetDataRequestValidationError) Key

Key function returns key value.

func (TaskExecutionGetDataRequestValidationError) Reason

Reason function returns reason value.

type TaskExecutionGetDataResponse

type TaskExecutionGetDataResponse struct {
	// Signed url to fetch a core.LiteralMap of task execution inputs.
	Inputs *UrlBlob `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of task execution outputs.
	Outputs              *UrlBlob `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response structure for TaskExecutionGetDataRequest which contains inputs and outputs for a task execution.

func (*TaskExecutionGetDataResponse) Descriptor

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

func (*TaskExecutionGetDataResponse) GetInputs

func (m *TaskExecutionGetDataResponse) GetInputs() *UrlBlob

func (*TaskExecutionGetDataResponse) GetOutputs

func (m *TaskExecutionGetDataResponse) GetOutputs() *UrlBlob

func (*TaskExecutionGetDataResponse) ProtoMessage

func (*TaskExecutionGetDataResponse) ProtoMessage()

func (*TaskExecutionGetDataResponse) Reset

func (m *TaskExecutionGetDataResponse) Reset()

func (*TaskExecutionGetDataResponse) String

func (*TaskExecutionGetDataResponse) Validate

func (m *TaskExecutionGetDataResponse) Validate() error

Validate checks the field values on TaskExecutionGetDataResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionGetDataResponse) XXX_DiscardUnknown

func (m *TaskExecutionGetDataResponse) XXX_DiscardUnknown()

func (*TaskExecutionGetDataResponse) XXX_Marshal

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

func (*TaskExecutionGetDataResponse) XXX_Merge

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

func (*TaskExecutionGetDataResponse) XXX_Size

func (m *TaskExecutionGetDataResponse) XXX_Size() int

func (*TaskExecutionGetDataResponse) XXX_Unmarshal

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

type TaskExecutionGetDataResponseValidationError

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

TaskExecutionGetDataResponseValidationError is the validation error returned by TaskExecutionGetDataResponse.Validate if the designated constraints aren't met.

func (TaskExecutionGetDataResponseValidationError) Cause

Cause function returns cause value.

func (TaskExecutionGetDataResponseValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionGetDataResponseValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionGetDataResponseValidationError) Field

Field function returns field value.

func (TaskExecutionGetDataResponseValidationError) Key

Key function returns key value.

func (TaskExecutionGetDataResponseValidationError) Reason

Reason function returns reason value.

type TaskExecutionGetRequest

type TaskExecutionGetRequest struct {
	// Unique identifier for the task execution.
	Id                   *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

A message used to fetch a single task execution entity.

func (*TaskExecutionGetRequest) Descriptor

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

func (*TaskExecutionGetRequest) GetId

func (*TaskExecutionGetRequest) ProtoMessage

func (*TaskExecutionGetRequest) ProtoMessage()

func (*TaskExecutionGetRequest) Reset

func (m *TaskExecutionGetRequest) Reset()

func (*TaskExecutionGetRequest) String

func (m *TaskExecutionGetRequest) String() string

func (*TaskExecutionGetRequest) Validate

func (m *TaskExecutionGetRequest) Validate() error

Validate checks the field values on TaskExecutionGetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionGetRequest) XXX_DiscardUnknown

func (m *TaskExecutionGetRequest) XXX_DiscardUnknown()

func (*TaskExecutionGetRequest) XXX_Marshal

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

func (*TaskExecutionGetRequest) XXX_Merge

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

func (*TaskExecutionGetRequest) XXX_Size

func (m *TaskExecutionGetRequest) XXX_Size() int

func (*TaskExecutionGetRequest) XXX_Unmarshal

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

type TaskExecutionGetRequestValidationError

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

TaskExecutionGetRequestValidationError is the validation error returned by TaskExecutionGetRequest.Validate if the designated constraints aren't met.

func (TaskExecutionGetRequestValidationError) Cause

Cause function returns cause value.

func (TaskExecutionGetRequestValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionGetRequestValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionGetRequestValidationError) Field

Field function returns field value.

func (TaskExecutionGetRequestValidationError) Key

Key function returns key value.

func (TaskExecutionGetRequestValidationError) Reason

Reason function returns reason value.

type TaskExecutionList

type TaskExecutionList struct {
	TaskExecutions []*TaskExecution `protobuf:"bytes,1,rep,name=task_executions,json=taskExecutions,proto3" json:"task_executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response structure for a query to list of task execution entities.

func (*TaskExecutionList) Descriptor

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

func (*TaskExecutionList) GetTaskExecutions

func (m *TaskExecutionList) GetTaskExecutions() []*TaskExecution

func (*TaskExecutionList) GetToken

func (m *TaskExecutionList) GetToken() string

func (*TaskExecutionList) ProtoMessage

func (*TaskExecutionList) ProtoMessage()

func (*TaskExecutionList) Reset

func (m *TaskExecutionList) Reset()

func (*TaskExecutionList) String

func (m *TaskExecutionList) String() string

func (*TaskExecutionList) Validate

func (m *TaskExecutionList) Validate() error

Validate checks the field values on TaskExecutionList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionList) XXX_DiscardUnknown

func (m *TaskExecutionList) XXX_DiscardUnknown()

func (*TaskExecutionList) XXX_Marshal

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

func (*TaskExecutionList) XXX_Merge

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

func (*TaskExecutionList) XXX_Size

func (m *TaskExecutionList) XXX_Size() int

func (*TaskExecutionList) XXX_Unmarshal

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

type TaskExecutionListRequest

type TaskExecutionListRequest struct {
	// Indicates the node execution to filter by.
	NodeExecutionId *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=node_execution_id,json=nodeExecutionId,proto3" json:"node_execution_id,omitempty"`
	// Indicates the number of resources to be returned.
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query.
	// +optional
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// Indicates a list of filters passed as string.
	// More info on constructing filters : <Link>
	// +optional
	Filters string `protobuf:"bytes,4,opt,name=filters,proto3" json:"filters,omitempty"`
	// Sort ordering for returned list.
	// +optional
	SortBy               *Sort    `protobuf:"bytes,5,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a request structure to retrieve a list of task execution entities.

func (*TaskExecutionListRequest) Descriptor

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

func (*TaskExecutionListRequest) GetFilters

func (m *TaskExecutionListRequest) GetFilters() string

func (*TaskExecutionListRequest) GetLimit

func (m *TaskExecutionListRequest) GetLimit() uint32

func (*TaskExecutionListRequest) GetNodeExecutionId

func (m *TaskExecutionListRequest) GetNodeExecutionId() *core.NodeExecutionIdentifier

func (*TaskExecutionListRequest) GetSortBy

func (m *TaskExecutionListRequest) GetSortBy() *Sort

func (*TaskExecutionListRequest) GetToken

func (m *TaskExecutionListRequest) GetToken() string

func (*TaskExecutionListRequest) ProtoMessage

func (*TaskExecutionListRequest) ProtoMessage()

func (*TaskExecutionListRequest) Reset

func (m *TaskExecutionListRequest) Reset()

func (*TaskExecutionListRequest) String

func (m *TaskExecutionListRequest) String() string

func (*TaskExecutionListRequest) Validate

func (m *TaskExecutionListRequest) Validate() error

Validate checks the field values on TaskExecutionListRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionListRequest) XXX_DiscardUnknown

func (m *TaskExecutionListRequest) XXX_DiscardUnknown()

func (*TaskExecutionListRequest) XXX_Marshal

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

func (*TaskExecutionListRequest) XXX_Merge

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

func (*TaskExecutionListRequest) XXX_Size

func (m *TaskExecutionListRequest) XXX_Size() int

func (*TaskExecutionListRequest) XXX_Unmarshal

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

type TaskExecutionListRequestValidationError

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

TaskExecutionListRequestValidationError is the validation error returned by TaskExecutionListRequest.Validate if the designated constraints aren't met.

func (TaskExecutionListRequestValidationError) Cause

Cause function returns cause value.

func (TaskExecutionListRequestValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionListRequestValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionListRequestValidationError) Field

Field function returns field value.

func (TaskExecutionListRequestValidationError) Key

Key function returns key value.

func (TaskExecutionListRequestValidationError) Reason

Reason function returns reason value.

type TaskExecutionListValidationError

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

TaskExecutionListValidationError is the validation error returned by TaskExecutionList.Validate if the designated constraints aren't met.

func (TaskExecutionListValidationError) Cause

Cause function returns cause value.

func (TaskExecutionListValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionListValidationError) ErrorName

ErrorName returns error name.

func (TaskExecutionListValidationError) Field

Field function returns field value.

func (TaskExecutionListValidationError) Key

Key function returns key value.

func (TaskExecutionListValidationError) Reason

Reason function returns reason value.

type TaskExecutionValidationError

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

TaskExecutionValidationError is the validation error returned by TaskExecution.Validate if the designated constraints aren't met.

func (TaskExecutionValidationError) Cause

Cause function returns cause value.

func (TaskExecutionValidationError) Error

Error satisfies the builtin error interface

func (TaskExecutionValidationError) ErrorName

func (e TaskExecutionValidationError) ErrorName() string

ErrorName returns error name.

func (TaskExecutionValidationError) Field

Field function returns field value.

func (TaskExecutionValidationError) Key

Key function returns key value.

func (TaskExecutionValidationError) Reason

Reason function returns reason value.

type TaskList

type TaskList struct {
	// A list of tasks returned based on the request.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a list of tasks returned from the admin.

func (*TaskList) Descriptor

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

func (*TaskList) GetTasks

func (m *TaskList) GetTasks() []*Task

func (*TaskList) GetToken

func (m *TaskList) GetToken() string

func (*TaskList) ProtoMessage

func (*TaskList) ProtoMessage()

func (*TaskList) Reset

func (m *TaskList) Reset()

func (*TaskList) String

func (m *TaskList) String() string

func (*TaskList) Validate

func (m *TaskList) Validate() error

Validate checks the field values on TaskList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskList) XXX_DiscardUnknown

func (m *TaskList) XXX_DiscardUnknown()

func (*TaskList) XXX_Marshal

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

func (*TaskList) XXX_Merge

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

func (*TaskList) XXX_Size

func (m *TaskList) XXX_Size() int

func (*TaskList) XXX_Unmarshal

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

type TaskListValidationError

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

TaskListValidationError is the validation error returned by TaskList.Validate if the designated constraints aren't met.

func (TaskListValidationError) Cause

func (e TaskListValidationError) Cause() error

Cause function returns cause value.

func (TaskListValidationError) Error

func (e TaskListValidationError) Error() string

Error satisfies the builtin error interface

func (TaskListValidationError) ErrorName

func (e TaskListValidationError) ErrorName() string

ErrorName returns error name.

func (TaskListValidationError) Field

func (e TaskListValidationError) Field() string

Field function returns field value.

func (TaskListValidationError) Key

func (e TaskListValidationError) Key() bool

Key function returns key value.

func (TaskListValidationError) Reason

func (e TaskListValidationError) Reason() string

Reason function returns reason value.

type TaskResourceAttributes added in v0.16.4

type TaskResourceAttributes struct {
	Defaults             *TaskResourceSpec `protobuf:"bytes,1,opt,name=defaults,proto3" json:"defaults,omitempty"`
	Limits               *TaskResourceSpec `protobuf:"bytes,2,opt,name=limits,proto3" json:"limits,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TaskResourceAttributes) Descriptor added in v0.16.4

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

func (*TaskResourceAttributes) GetDefaults added in v0.16.4

func (m *TaskResourceAttributes) GetDefaults() *TaskResourceSpec

func (*TaskResourceAttributes) GetLimits added in v0.16.4

func (m *TaskResourceAttributes) GetLimits() *TaskResourceSpec

func (*TaskResourceAttributes) ProtoMessage added in v0.16.4

func (*TaskResourceAttributes) ProtoMessage()

func (*TaskResourceAttributes) Reset added in v0.16.4

func (m *TaskResourceAttributes) Reset()

func (*TaskResourceAttributes) String added in v0.16.4

func (m *TaskResourceAttributes) String() string

func (*TaskResourceAttributes) Validate added in v0.16.4

func (m *TaskResourceAttributes) Validate() error

Validate checks the field values on TaskResourceAttributes with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskResourceAttributes) XXX_DiscardUnknown added in v0.16.4

func (m *TaskResourceAttributes) XXX_DiscardUnknown()

func (*TaskResourceAttributes) XXX_Marshal added in v0.16.4

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

func (*TaskResourceAttributes) XXX_Merge added in v0.16.4

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

func (*TaskResourceAttributes) XXX_Size added in v0.16.4

func (m *TaskResourceAttributes) XXX_Size() int

func (*TaskResourceAttributes) XXX_Unmarshal added in v0.16.4

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

type TaskResourceAttributesValidationError added in v0.16.4

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

TaskResourceAttributesValidationError is the validation error returned by TaskResourceAttributes.Validate if the designated constraints aren't met.

func (TaskResourceAttributesValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (TaskResourceAttributesValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (TaskResourceAttributesValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (TaskResourceAttributesValidationError) Field added in v0.16.4

Field function returns field value.

func (TaskResourceAttributesValidationError) Key added in v0.16.4

Key function returns key value.

func (TaskResourceAttributesValidationError) Reason added in v0.16.4

Reason function returns reason value.

type TaskResourceSpec added in v0.16.4

type TaskResourceSpec struct {
	Cpu                  string   `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Gpu                  string   `protobuf:"bytes,2,opt,name=gpu,proto3" json:"gpu,omitempty"`
	Memory               string   `protobuf:"bytes,3,opt,name=memory,proto3" json:"memory,omitempty"`
	Storage              string   `protobuf:"bytes,4,opt,name=storage,proto3" json:"storage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskResourceSpec) Descriptor added in v0.16.4

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

func (*TaskResourceSpec) GetCpu added in v0.16.4

func (m *TaskResourceSpec) GetCpu() string

func (*TaskResourceSpec) GetGpu added in v0.16.4

func (m *TaskResourceSpec) GetGpu() string

func (*TaskResourceSpec) GetMemory added in v0.16.4

func (m *TaskResourceSpec) GetMemory() string

func (*TaskResourceSpec) GetStorage added in v0.16.4

func (m *TaskResourceSpec) GetStorage() string

func (*TaskResourceSpec) ProtoMessage added in v0.16.4

func (*TaskResourceSpec) ProtoMessage()

func (*TaskResourceSpec) Reset added in v0.16.4

func (m *TaskResourceSpec) Reset()

func (*TaskResourceSpec) String added in v0.16.4

func (m *TaskResourceSpec) String() string

func (*TaskResourceSpec) Validate added in v0.16.4

func (m *TaskResourceSpec) Validate() error

Validate checks the field values on TaskResourceSpec with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskResourceSpec) XXX_DiscardUnknown added in v0.16.4

func (m *TaskResourceSpec) XXX_DiscardUnknown()

func (*TaskResourceSpec) XXX_Marshal added in v0.16.4

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

func (*TaskResourceSpec) XXX_Merge added in v0.16.4

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

func (*TaskResourceSpec) XXX_Size added in v0.16.4

func (m *TaskResourceSpec) XXX_Size() int

func (*TaskResourceSpec) XXX_Unmarshal added in v0.16.4

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

type TaskResourceSpecValidationError added in v0.16.4

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

TaskResourceSpecValidationError is the validation error returned by TaskResourceSpec.Validate if the designated constraints aren't met.

func (TaskResourceSpecValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (TaskResourceSpecValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (TaskResourceSpecValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (TaskResourceSpecValidationError) Field added in v0.16.4

Field function returns field value.

func (TaskResourceSpecValidationError) Key added in v0.16.4

Key function returns key value.

func (TaskResourceSpecValidationError) Reason added in v0.16.4

Reason function returns reason value.

type TaskSpec

type TaskSpec struct {
	// Template of the task that encapsulates all the metadata of the task.
	Template             *core.TaskTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Represents a structure that encapsulates the user-configured specification of the task.

func (*TaskSpec) Descriptor

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

func (*TaskSpec) GetTemplate

func (m *TaskSpec) GetTemplate() *core.TaskTemplate

func (*TaskSpec) ProtoMessage

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) Reset

func (m *TaskSpec) Reset()

func (*TaskSpec) String

func (m *TaskSpec) String() string

func (*TaskSpec) Validate

func (m *TaskSpec) Validate() error

Validate checks the field values on TaskSpec with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskSpec) XXX_DiscardUnknown

func (m *TaskSpec) XXX_DiscardUnknown()

func (*TaskSpec) XXX_Marshal

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

func (*TaskSpec) XXX_Merge

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

func (*TaskSpec) XXX_Size

func (m *TaskSpec) XXX_Size() int

func (*TaskSpec) XXX_Unmarshal

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

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

type UrlBlob struct {
	// Actual url value.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Represents the size of the file accessible at the above url.
	Bytes                int64    `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a string url and associated metadata used throughout the platform.

func (*UrlBlob) Descriptor

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

func (*UrlBlob) GetBytes

func (m *UrlBlob) GetBytes() int64

func (*UrlBlob) GetUrl

func (m *UrlBlob) GetUrl() string

func (*UrlBlob) ProtoMessage

func (*UrlBlob) ProtoMessage()

func (*UrlBlob) Reset

func (m *UrlBlob) Reset()

func (*UrlBlob) String

func (m *UrlBlob) String() string

func (*UrlBlob) Validate

func (m *UrlBlob) Validate() error

Validate checks the field values on UrlBlob with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*UrlBlob) XXX_DiscardUnknown

func (m *UrlBlob) XXX_DiscardUnknown()

func (*UrlBlob) XXX_Marshal

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

func (*UrlBlob) XXX_Merge

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

func (*UrlBlob) XXX_Size

func (m *UrlBlob) XXX_Size() int

func (*UrlBlob) XXX_Unmarshal

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

type UrlBlobValidationError

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

UrlBlobValidationError is the validation error returned by UrlBlob.Validate if the designated constraints aren't met.

func (UrlBlobValidationError) Cause

func (e UrlBlobValidationError) Cause() error

Cause function returns cause value.

func (UrlBlobValidationError) Error

func (e UrlBlobValidationError) Error() string

Error satisfies the builtin error interface

func (UrlBlobValidationError) ErrorName

func (e UrlBlobValidationError) ErrorName() string

ErrorName returns error name.

func (UrlBlobValidationError) Field

func (e UrlBlobValidationError) Field() string

Field function returns field value.

func (UrlBlobValidationError) Key

func (e UrlBlobValidationError) Key() bool

Key function returns key value.

func (UrlBlobValidationError) Reason

func (e UrlBlobValidationError) Reason() string

Reason function returns reason value.

type Workflow

type Workflow struct {
	// id represents the unique identifier of the workflow.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// closure encapsulates all the fields that maps to a compiled version of the workflow.
	Closure              *WorkflowClosure `protobuf:"bytes,2,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Represents the workflow structure stored in the Admin A workflow is created by ordering tasks and associating outputs to inputs in order to produce a directed-acyclic execution graph.

func (*Workflow) Descriptor

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

func (*Workflow) GetClosure

func (m *Workflow) GetClosure() *WorkflowClosure

func (*Workflow) GetId

func (m *Workflow) GetId() *core.Identifier

func (*Workflow) ProtoMessage

func (*Workflow) ProtoMessage()

func (*Workflow) Reset

func (m *Workflow) Reset()

func (*Workflow) String

func (m *Workflow) String() string

func (*Workflow) Validate

func (m *Workflow) Validate() error

Validate checks the field values on Workflow with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Workflow) XXX_DiscardUnknown

func (m *Workflow) XXX_DiscardUnknown()

func (*Workflow) XXX_Marshal

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

func (*Workflow) XXX_Merge

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

func (*Workflow) XXX_Size

func (m *Workflow) XXX_Size() int

func (*Workflow) XXX_Unmarshal

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

type WorkflowAttributes added in v0.16.4

type WorkflowAttributes struct {
	// Unique project id for which this set of attributes will be applied.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id for which this set of attributes will be applied.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Workflow name for which this set of attributes will be applied.
	Workflow             string              `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	MatchingAttributes   *MatchingAttributes `protobuf:"bytes,4,opt,name=matching_attributes,json=matchingAttributes,proto3" json:"matching_attributes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*WorkflowAttributes) Descriptor added in v0.16.4

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

func (*WorkflowAttributes) GetDomain added in v0.16.4

func (m *WorkflowAttributes) GetDomain() string

func (*WorkflowAttributes) GetMatchingAttributes added in v0.16.4

func (m *WorkflowAttributes) GetMatchingAttributes() *MatchingAttributes

func (*WorkflowAttributes) GetProject added in v0.16.4

func (m *WorkflowAttributes) GetProject() string

func (*WorkflowAttributes) GetWorkflow added in v0.16.4

func (m *WorkflowAttributes) GetWorkflow() string

func (*WorkflowAttributes) ProtoMessage added in v0.16.4

func (*WorkflowAttributes) ProtoMessage()

func (*WorkflowAttributes) Reset added in v0.16.4

func (m *WorkflowAttributes) Reset()

func (*WorkflowAttributes) String added in v0.16.4

func (m *WorkflowAttributes) String() string

func (*WorkflowAttributes) Validate added in v0.16.4

func (m *WorkflowAttributes) Validate() error

Validate checks the field values on WorkflowAttributes with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowAttributes) XXX_DiscardUnknown added in v0.16.4

func (m *WorkflowAttributes) XXX_DiscardUnknown()

func (*WorkflowAttributes) XXX_Marshal added in v0.16.4

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

func (*WorkflowAttributes) XXX_Merge added in v0.16.4

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

func (*WorkflowAttributes) XXX_Size added in v0.16.4

func (m *WorkflowAttributes) XXX_Size() int

func (*WorkflowAttributes) XXX_Unmarshal added in v0.16.4

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

type WorkflowAttributesDeleteRequest added in v0.16.5

type WorkflowAttributesDeleteRequest struct {
	// Unique project id which this set of attributes references.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Workflow name which this set of attributes references.
	Workflow             string            `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	ResourceType         MatchableResource `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkflowAttributesDeleteRequest) Descriptor added in v0.16.5

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

func (*WorkflowAttributesDeleteRequest) GetDomain added in v0.16.5

func (m *WorkflowAttributesDeleteRequest) GetDomain() string

func (*WorkflowAttributesDeleteRequest) GetProject added in v0.16.5

func (m *WorkflowAttributesDeleteRequest) GetProject() string

func (*WorkflowAttributesDeleteRequest) GetResourceType added in v0.16.5

func (*WorkflowAttributesDeleteRequest) GetWorkflow added in v0.16.5

func (m *WorkflowAttributesDeleteRequest) GetWorkflow() string

func (*WorkflowAttributesDeleteRequest) ProtoMessage added in v0.16.5

func (*WorkflowAttributesDeleteRequest) ProtoMessage()

func (*WorkflowAttributesDeleteRequest) Reset added in v0.16.5

func (*WorkflowAttributesDeleteRequest) String added in v0.16.5

func (*WorkflowAttributesDeleteRequest) Validate added in v0.16.5

func (m *WorkflowAttributesDeleteRequest) Validate() error

Validate checks the field values on WorkflowAttributesDeleteRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowAttributesDeleteRequest) XXX_DiscardUnknown added in v0.16.5

func (m *WorkflowAttributesDeleteRequest) XXX_DiscardUnknown()

func (*WorkflowAttributesDeleteRequest) XXX_Marshal added in v0.16.5

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

func (*WorkflowAttributesDeleteRequest) XXX_Merge added in v0.16.5

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

func (*WorkflowAttributesDeleteRequest) XXX_Size added in v0.16.5

func (m *WorkflowAttributesDeleteRequest) XXX_Size() int

func (*WorkflowAttributesDeleteRequest) XXX_Unmarshal added in v0.16.5

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

type WorkflowAttributesDeleteRequestValidationError added in v0.16.5

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

WorkflowAttributesDeleteRequestValidationError is the validation error returned by WorkflowAttributesDeleteRequest.Validate if the designated constraints aren't met.

func (WorkflowAttributesDeleteRequestValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (WorkflowAttributesDeleteRequestValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (WorkflowAttributesDeleteRequestValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (WorkflowAttributesDeleteRequestValidationError) Field added in v0.16.5

Field function returns field value.

func (WorkflowAttributesDeleteRequestValidationError) Key added in v0.16.5

Key function returns key value.

func (WorkflowAttributesDeleteRequestValidationError) Reason added in v0.16.5

Reason function returns reason value.

type WorkflowAttributesDeleteResponse added in v0.16.5

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

Purposefully empty, may be populated in the future.

func (*WorkflowAttributesDeleteResponse) Descriptor added in v0.16.5

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

func (*WorkflowAttributesDeleteResponse) ProtoMessage added in v0.16.5

func (*WorkflowAttributesDeleteResponse) ProtoMessage()

func (*WorkflowAttributesDeleteResponse) Reset added in v0.16.5

func (*WorkflowAttributesDeleteResponse) String added in v0.16.5

func (*WorkflowAttributesDeleteResponse) Validate added in v0.16.5

Validate checks the field values on WorkflowAttributesDeleteResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowAttributesDeleteResponse) XXX_DiscardUnknown added in v0.16.5

func (m *WorkflowAttributesDeleteResponse) XXX_DiscardUnknown()

func (*WorkflowAttributesDeleteResponse) XXX_Marshal added in v0.16.5

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

func (*WorkflowAttributesDeleteResponse) XXX_Merge added in v0.16.5

func (*WorkflowAttributesDeleteResponse) XXX_Size added in v0.16.5

func (m *WorkflowAttributesDeleteResponse) XXX_Size() int

func (*WorkflowAttributesDeleteResponse) XXX_Unmarshal added in v0.16.5

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

type WorkflowAttributesDeleteResponseValidationError added in v0.16.5

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

WorkflowAttributesDeleteResponseValidationError is the validation error returned by WorkflowAttributesDeleteResponse.Validate if the designated constraints aren't met.

func (WorkflowAttributesDeleteResponseValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (WorkflowAttributesDeleteResponseValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (WorkflowAttributesDeleteResponseValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (WorkflowAttributesDeleteResponseValidationError) Field added in v0.16.5

Field function returns field value.

func (WorkflowAttributesDeleteResponseValidationError) Key added in v0.16.5

Key function returns key value.

func (WorkflowAttributesDeleteResponseValidationError) Reason added in v0.16.5

Reason function returns reason value.

type WorkflowAttributesGetRequest added in v0.16.5

type WorkflowAttributesGetRequest struct {
	// Unique project id which this set of attributes references.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Unique domain id which this set of attributes references.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// Workflow name which this set of attributes references.
	Workflow             string            `protobuf:"bytes,3,opt,name=workflow,proto3" json:"workflow,omitempty"`
	ResourceType         MatchableResource `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkflowAttributesGetRequest) Descriptor added in v0.16.5

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

func (*WorkflowAttributesGetRequest) GetDomain added in v0.16.5

func (m *WorkflowAttributesGetRequest) GetDomain() string

func (*WorkflowAttributesGetRequest) GetProject added in v0.16.5

func (m *WorkflowAttributesGetRequest) GetProject() string

func (*WorkflowAttributesGetRequest) GetResourceType added in v0.16.5

func (m *WorkflowAttributesGetRequest) GetResourceType() MatchableResource

func (*WorkflowAttributesGetRequest) GetWorkflow added in v0.16.5

func (m *WorkflowAttributesGetRequest) GetWorkflow() string

func (*WorkflowAttributesGetRequest) ProtoMessage added in v0.16.5

func (*WorkflowAttributesGetRequest) ProtoMessage()

func (*WorkflowAttributesGetRequest) Reset added in v0.16.5

func (m *WorkflowAttributesGetRequest) Reset()

func (*WorkflowAttributesGetRequest) String added in v0.16.5

func (*WorkflowAttributesGetRequest) Validate added in v0.16.5

func (m *WorkflowAttributesGetRequest) Validate() error

Validate checks the field values on WorkflowAttributesGetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowAttributesGetRequest) XXX_DiscardUnknown added in v0.16.5

func (m *WorkflowAttributesGetRequest) XXX_DiscardUnknown()

func (*WorkflowAttributesGetRequest) XXX_Marshal added in v0.16.5

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

func (*WorkflowAttributesGetRequest) XXX_Merge added in v0.16.5

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

func (*WorkflowAttributesGetRequest) XXX_Size added in v0.16.5

func (m *WorkflowAttributesGetRequest) XXX_Size() int

func (*WorkflowAttributesGetRequest) XXX_Unmarshal added in v0.16.5

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

type WorkflowAttributesGetRequestValidationError added in v0.16.5

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

WorkflowAttributesGetRequestValidationError is the validation error returned by WorkflowAttributesGetRequest.Validate if the designated constraints aren't met.

func (WorkflowAttributesGetRequestValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (WorkflowAttributesGetRequestValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (WorkflowAttributesGetRequestValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (WorkflowAttributesGetRequestValidationError) Field added in v0.16.5

Field function returns field value.

func (WorkflowAttributesGetRequestValidationError) Key added in v0.16.5

Key function returns key value.

func (WorkflowAttributesGetRequestValidationError) Reason added in v0.16.5

Reason function returns reason value.

type WorkflowAttributesGetResponse added in v0.16.5

type WorkflowAttributesGetResponse struct {
	Attributes           *WorkflowAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*WorkflowAttributesGetResponse) Descriptor added in v0.16.5

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

func (*WorkflowAttributesGetResponse) GetAttributes added in v0.16.5

func (*WorkflowAttributesGetResponse) ProtoMessage added in v0.16.5

func (*WorkflowAttributesGetResponse) ProtoMessage()

func (*WorkflowAttributesGetResponse) Reset added in v0.16.5

func (m *WorkflowAttributesGetResponse) Reset()

func (*WorkflowAttributesGetResponse) String added in v0.16.5

func (*WorkflowAttributesGetResponse) Validate added in v0.16.5

func (m *WorkflowAttributesGetResponse) Validate() error

Validate checks the field values on WorkflowAttributesGetResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowAttributesGetResponse) XXX_DiscardUnknown added in v0.16.5

func (m *WorkflowAttributesGetResponse) XXX_DiscardUnknown()

func (*WorkflowAttributesGetResponse) XXX_Marshal added in v0.16.5

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

func (*WorkflowAttributesGetResponse) XXX_Merge added in v0.16.5

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

func (*WorkflowAttributesGetResponse) XXX_Size added in v0.16.5

func (m *WorkflowAttributesGetResponse) XXX_Size() int

func (*WorkflowAttributesGetResponse) XXX_Unmarshal added in v0.16.5

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

type WorkflowAttributesGetResponseValidationError added in v0.16.5

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

WorkflowAttributesGetResponseValidationError is the validation error returned by WorkflowAttributesGetResponse.Validate if the designated constraints aren't met.

func (WorkflowAttributesGetResponseValidationError) Cause added in v0.16.5

Cause function returns cause value.

func (WorkflowAttributesGetResponseValidationError) Error added in v0.16.5

Error satisfies the builtin error interface

func (WorkflowAttributesGetResponseValidationError) ErrorName added in v0.16.5

ErrorName returns error name.

func (WorkflowAttributesGetResponseValidationError) Field added in v0.16.5

Field function returns field value.

func (WorkflowAttributesGetResponseValidationError) Key added in v0.16.5

Key function returns key value.

func (WorkflowAttributesGetResponseValidationError) Reason added in v0.16.5

Reason function returns reason value.

type WorkflowAttributesUpdateRequest added in v0.16.4

type WorkflowAttributesUpdateRequest struct {
	Attributes           *WorkflowAttributes `protobuf:"bytes,1,opt,name=attributes,proto3" json:"attributes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Sets custom attributes for a project, domain and workflow combination.

func (*WorkflowAttributesUpdateRequest) Descriptor added in v0.16.4

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

func (*WorkflowAttributesUpdateRequest) GetAttributes added in v0.16.4

func (*WorkflowAttributesUpdateRequest) ProtoMessage added in v0.16.4

func (*WorkflowAttributesUpdateRequest) ProtoMessage()

func (*WorkflowAttributesUpdateRequest) Reset added in v0.16.4

func (*WorkflowAttributesUpdateRequest) String added in v0.16.4

func (*WorkflowAttributesUpdateRequest) Validate added in v0.16.4

func (m *WorkflowAttributesUpdateRequest) Validate() error

Validate checks the field values on WorkflowAttributesUpdateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowAttributesUpdateRequest) XXX_DiscardUnknown added in v0.16.4

func (m *WorkflowAttributesUpdateRequest) XXX_DiscardUnknown()

func (*WorkflowAttributesUpdateRequest) XXX_Marshal added in v0.16.4

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

func (*WorkflowAttributesUpdateRequest) XXX_Merge added in v0.16.4

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

func (*WorkflowAttributesUpdateRequest) XXX_Size added in v0.16.4

func (m *WorkflowAttributesUpdateRequest) XXX_Size() int

func (*WorkflowAttributesUpdateRequest) XXX_Unmarshal added in v0.16.4

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

type WorkflowAttributesUpdateRequestValidationError added in v0.16.4

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

WorkflowAttributesUpdateRequestValidationError is the validation error returned by WorkflowAttributesUpdateRequest.Validate if the designated constraints aren't met.

func (WorkflowAttributesUpdateRequestValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (WorkflowAttributesUpdateRequestValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (WorkflowAttributesUpdateRequestValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (WorkflowAttributesUpdateRequestValidationError) Field added in v0.16.4

Field function returns field value.

func (WorkflowAttributesUpdateRequestValidationError) Key added in v0.16.4

Key function returns key value.

func (WorkflowAttributesUpdateRequestValidationError) Reason added in v0.16.4

Reason function returns reason value.

type WorkflowAttributesUpdateResponse added in v0.16.4

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

Purposefully empty, may be populated in the future.

func (*WorkflowAttributesUpdateResponse) Descriptor added in v0.16.4

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

func (*WorkflowAttributesUpdateResponse) ProtoMessage added in v0.16.4

func (*WorkflowAttributesUpdateResponse) ProtoMessage()

func (*WorkflowAttributesUpdateResponse) Reset added in v0.16.4

func (*WorkflowAttributesUpdateResponse) String added in v0.16.4

func (*WorkflowAttributesUpdateResponse) Validate added in v0.16.4

Validate checks the field values on WorkflowAttributesUpdateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowAttributesUpdateResponse) XXX_DiscardUnknown added in v0.16.4

func (m *WorkflowAttributesUpdateResponse) XXX_DiscardUnknown()

func (*WorkflowAttributesUpdateResponse) XXX_Marshal added in v0.16.4

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

func (*WorkflowAttributesUpdateResponse) XXX_Merge added in v0.16.4

func (*WorkflowAttributesUpdateResponse) XXX_Size added in v0.16.4

func (m *WorkflowAttributesUpdateResponse) XXX_Size() int

func (*WorkflowAttributesUpdateResponse) XXX_Unmarshal added in v0.16.4

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

type WorkflowAttributesUpdateResponseValidationError added in v0.16.4

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

WorkflowAttributesUpdateResponseValidationError is the validation error returned by WorkflowAttributesUpdateResponse.Validate if the designated constraints aren't met.

func (WorkflowAttributesUpdateResponseValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (WorkflowAttributesUpdateResponseValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (WorkflowAttributesUpdateResponseValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (WorkflowAttributesUpdateResponseValidationError) Field added in v0.16.4

Field function returns field value.

func (WorkflowAttributesUpdateResponseValidationError) Key added in v0.16.4

Key function returns key value.

func (WorkflowAttributesUpdateResponseValidationError) Reason added in v0.16.4

Reason function returns reason value.

type WorkflowAttributesValidationError added in v0.16.4

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

WorkflowAttributesValidationError is the validation error returned by WorkflowAttributes.Validate if the designated constraints aren't met.

func (WorkflowAttributesValidationError) Cause added in v0.16.4

Cause function returns cause value.

func (WorkflowAttributesValidationError) Error added in v0.16.4

Error satisfies the builtin error interface

func (WorkflowAttributesValidationError) ErrorName added in v0.16.4

ErrorName returns error name.

func (WorkflowAttributesValidationError) Field added in v0.16.4

Field function returns field value.

func (WorkflowAttributesValidationError) Key added in v0.16.4

Key function returns key value.

func (WorkflowAttributesValidationError) Reason added in v0.16.4

Reason function returns reason value.

type WorkflowClosure

type WorkflowClosure struct {
	// Represents the compiled representation of the workflow from the specification provided.
	CompiledWorkflow *core.CompiledWorkflowClosure `protobuf:"bytes,1,opt,name=compiled_workflow,json=compiledWorkflow,proto3" json:"compiled_workflow,omitempty"`
	// Time at which the workflow was created.
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

A container holding the compiled workflow produced from the WorkflowSpec and additional metadata.

func (*WorkflowClosure) Descriptor

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

func (*WorkflowClosure) GetCompiledWorkflow

func (m *WorkflowClosure) GetCompiledWorkflow() *core.CompiledWorkflowClosure

func (*WorkflowClosure) GetCreatedAt

func (m *WorkflowClosure) GetCreatedAt() *timestamp.Timestamp

func (*WorkflowClosure) ProtoMessage

func (*WorkflowClosure) ProtoMessage()

func (*WorkflowClosure) Reset

func (m *WorkflowClosure) Reset()

func (*WorkflowClosure) String

func (m *WorkflowClosure) String() string

func (*WorkflowClosure) Validate

func (m *WorkflowClosure) Validate() error

Validate checks the field values on WorkflowClosure with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowClosure) XXX_DiscardUnknown

func (m *WorkflowClosure) XXX_DiscardUnknown()

func (*WorkflowClosure) XXX_Marshal

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

func (*WorkflowClosure) XXX_Merge

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

func (*WorkflowClosure) XXX_Size

func (m *WorkflowClosure) XXX_Size() int

func (*WorkflowClosure) XXX_Unmarshal

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

type WorkflowClosureValidationError

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

WorkflowClosureValidationError is the validation error returned by WorkflowClosure.Validate if the designated constraints aren't met.

func (WorkflowClosureValidationError) Cause

Cause function returns cause value.

func (WorkflowClosureValidationError) Error

Error satisfies the builtin error interface

func (WorkflowClosureValidationError) ErrorName

func (e WorkflowClosureValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowClosureValidationError) Field

Field function returns field value.

func (WorkflowClosureValidationError) Key

Key function returns key value.

func (WorkflowClosureValidationError) Reason

Reason function returns reason value.

type WorkflowCreateRequest

type WorkflowCreateRequest struct {
	// id represents the unique identifier of the workflow.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Represents the specification for workflow.
	Spec                 *WorkflowSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Represents a request structure to create a revision of a workflow.

func (*WorkflowCreateRequest) Descriptor

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

func (*WorkflowCreateRequest) GetId

func (*WorkflowCreateRequest) GetSpec

func (m *WorkflowCreateRequest) GetSpec() *WorkflowSpec

func (*WorkflowCreateRequest) ProtoMessage

func (*WorkflowCreateRequest) ProtoMessage()

func (*WorkflowCreateRequest) Reset

func (m *WorkflowCreateRequest) Reset()

func (*WorkflowCreateRequest) String

func (m *WorkflowCreateRequest) String() string

func (*WorkflowCreateRequest) Validate

func (m *WorkflowCreateRequest) Validate() error

Validate checks the field values on WorkflowCreateRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowCreateRequest) XXX_DiscardUnknown

func (m *WorkflowCreateRequest) XXX_DiscardUnknown()

func (*WorkflowCreateRequest) XXX_Marshal

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

func (*WorkflowCreateRequest) XXX_Merge

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

func (*WorkflowCreateRequest) XXX_Size

func (m *WorkflowCreateRequest) XXX_Size() int

func (*WorkflowCreateRequest) XXX_Unmarshal

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

type WorkflowCreateRequestValidationError

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

WorkflowCreateRequestValidationError is the validation error returned by WorkflowCreateRequest.Validate if the designated constraints aren't met.

func (WorkflowCreateRequestValidationError) Cause

Cause function returns cause value.

func (WorkflowCreateRequestValidationError) Error

Error satisfies the builtin error interface

func (WorkflowCreateRequestValidationError) ErrorName

ErrorName returns error name.

func (WorkflowCreateRequestValidationError) Field

Field function returns field value.

func (WorkflowCreateRequestValidationError) Key

Key function returns key value.

func (WorkflowCreateRequestValidationError) Reason

Reason function returns reason value.

type WorkflowCreateResponse

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

func (*WorkflowCreateResponse) Descriptor

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

func (*WorkflowCreateResponse) ProtoMessage

func (*WorkflowCreateResponse) ProtoMessage()

func (*WorkflowCreateResponse) Reset

func (m *WorkflowCreateResponse) Reset()

func (*WorkflowCreateResponse) String

func (m *WorkflowCreateResponse) String() string

func (*WorkflowCreateResponse) Validate

func (m *WorkflowCreateResponse) Validate() error

Validate checks the field values on WorkflowCreateResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowCreateResponse) XXX_DiscardUnknown

func (m *WorkflowCreateResponse) XXX_DiscardUnknown()

func (*WorkflowCreateResponse) XXX_Marshal

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

func (*WorkflowCreateResponse) XXX_Merge

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

func (*WorkflowCreateResponse) XXX_Size

func (m *WorkflowCreateResponse) XXX_Size() int

func (*WorkflowCreateResponse) XXX_Unmarshal

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

type WorkflowCreateResponseValidationError

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

WorkflowCreateResponseValidationError is the validation error returned by WorkflowCreateResponse.Validate if the designated constraints aren't met.

func (WorkflowCreateResponseValidationError) Cause

Cause function returns cause value.

func (WorkflowCreateResponseValidationError) Error

Error satisfies the builtin error interface

func (WorkflowCreateResponseValidationError) ErrorName

ErrorName returns error name.

func (WorkflowCreateResponseValidationError) Field

Field function returns field value.

func (WorkflowCreateResponseValidationError) Key

Key function returns key value.

func (WorkflowCreateResponseValidationError) Reason

Reason function returns reason value.

type WorkflowExecutionEventRequest

type WorkflowExecutionEventRequest struct {
	// Unique ID for this request that can be traced between services
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Details about the event that occurred.
	Event                *event.WorkflowExecutionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

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

func (*WorkflowExecutionEventRequest) Descriptor

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

func (*WorkflowExecutionEventRequest) GetEvent

func (*WorkflowExecutionEventRequest) GetRequestId

func (m *WorkflowExecutionEventRequest) GetRequestId() string

func (*WorkflowExecutionEventRequest) ProtoMessage

func (*WorkflowExecutionEventRequest) ProtoMessage()

func (*WorkflowExecutionEventRequest) Reset

func (m *WorkflowExecutionEventRequest) Reset()

func (*WorkflowExecutionEventRequest) String

func (*WorkflowExecutionEventRequest) Validate

func (m *WorkflowExecutionEventRequest) Validate() error

Validate checks the field values on WorkflowExecutionEventRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecutionEventRequest) XXX_DiscardUnknown

func (m *WorkflowExecutionEventRequest) XXX_DiscardUnknown()

func (*WorkflowExecutionEventRequest) XXX_Marshal

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

func (*WorkflowExecutionEventRequest) XXX_Merge

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

func (*WorkflowExecutionEventRequest) XXX_Size

func (m *WorkflowExecutionEventRequest) XXX_Size() int

func (*WorkflowExecutionEventRequest) XXX_Unmarshal

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

type WorkflowExecutionEventRequestValidationError

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

WorkflowExecutionEventRequestValidationError is the validation error returned by WorkflowExecutionEventRequest.Validate if the designated constraints aren't met.

func (WorkflowExecutionEventRequestValidationError) Cause

Cause function returns cause value.

func (WorkflowExecutionEventRequestValidationError) Error

Error satisfies the builtin error interface

func (WorkflowExecutionEventRequestValidationError) ErrorName

ErrorName returns error name.

func (WorkflowExecutionEventRequestValidationError) Field

Field function returns field value.

func (WorkflowExecutionEventRequestValidationError) Key

Key function returns key value.

func (WorkflowExecutionEventRequestValidationError) Reason

Reason function returns reason value.

type WorkflowExecutionEventResponse

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

func (*WorkflowExecutionEventResponse) Descriptor

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

func (*WorkflowExecutionEventResponse) ProtoMessage

func (*WorkflowExecutionEventResponse) ProtoMessage()

func (*WorkflowExecutionEventResponse) Reset

func (m *WorkflowExecutionEventResponse) Reset()

func (*WorkflowExecutionEventResponse) String

func (*WorkflowExecutionEventResponse) Validate

func (m *WorkflowExecutionEventResponse) Validate() error

Validate checks the field values on WorkflowExecutionEventResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecutionEventResponse) XXX_DiscardUnknown

func (m *WorkflowExecutionEventResponse) XXX_DiscardUnknown()

func (*WorkflowExecutionEventResponse) XXX_Marshal

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

func (*WorkflowExecutionEventResponse) XXX_Merge

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

func (*WorkflowExecutionEventResponse) XXX_Size

func (m *WorkflowExecutionEventResponse) XXX_Size() int

func (*WorkflowExecutionEventResponse) XXX_Unmarshal

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

type WorkflowExecutionEventResponseValidationError

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

WorkflowExecutionEventResponseValidationError is the validation error returned by WorkflowExecutionEventResponse.Validate if the designated constraints aren't met.

func (WorkflowExecutionEventResponseValidationError) Cause

Cause function returns cause value.

func (WorkflowExecutionEventResponseValidationError) Error

Error satisfies the builtin error interface

func (WorkflowExecutionEventResponseValidationError) ErrorName

ErrorName returns error name.

func (WorkflowExecutionEventResponseValidationError) Field

Field function returns field value.

func (WorkflowExecutionEventResponseValidationError) Key

Key function returns key value.

func (WorkflowExecutionEventResponseValidationError) Reason

Reason function returns reason value.

type WorkflowExecutionGetDataRequest

type WorkflowExecutionGetDataRequest struct {
	// The identifier of the execution for which to fetch inputs and outputs.
	Id                   *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

Request structure to fetch inputs and output urls for an execution.

func (*WorkflowExecutionGetDataRequest) Descriptor

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

func (*WorkflowExecutionGetDataRequest) GetId

func (*WorkflowExecutionGetDataRequest) ProtoMessage

func (*WorkflowExecutionGetDataRequest) ProtoMessage()

func (*WorkflowExecutionGetDataRequest) Reset

func (*WorkflowExecutionGetDataRequest) String

func (*WorkflowExecutionGetDataRequest) Validate

func (m *WorkflowExecutionGetDataRequest) Validate() error

Validate checks the field values on WorkflowExecutionGetDataRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecutionGetDataRequest) XXX_DiscardUnknown

func (m *WorkflowExecutionGetDataRequest) XXX_DiscardUnknown()

func (*WorkflowExecutionGetDataRequest) XXX_Marshal

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

func (*WorkflowExecutionGetDataRequest) XXX_Merge

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

func (*WorkflowExecutionGetDataRequest) XXX_Size

func (m *WorkflowExecutionGetDataRequest) XXX_Size() int

func (*WorkflowExecutionGetDataRequest) XXX_Unmarshal

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

type WorkflowExecutionGetDataRequestValidationError

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

WorkflowExecutionGetDataRequestValidationError is the validation error returned by WorkflowExecutionGetDataRequest.Validate if the designated constraints aren't met.

func (WorkflowExecutionGetDataRequestValidationError) Cause

Cause function returns cause value.

func (WorkflowExecutionGetDataRequestValidationError) Error

Error satisfies the builtin error interface

func (WorkflowExecutionGetDataRequestValidationError) ErrorName

ErrorName returns error name.

func (WorkflowExecutionGetDataRequestValidationError) Field

Field function returns field value.

func (WorkflowExecutionGetDataRequestValidationError) Key

Key function returns key value.

func (WorkflowExecutionGetDataRequestValidationError) Reason

Reason function returns reason value.

type WorkflowExecutionGetDataResponse

type WorkflowExecutionGetDataResponse struct {
	// Signed url to fetch a core.LiteralMap of execution outputs.
	Outputs *UrlBlob `protobuf:"bytes,1,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of execution inputs.
	Inputs               *UrlBlob `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response structure for WorkflowExecutionGetDataRequest which contains inputs and outputs for an execution.

func (*WorkflowExecutionGetDataResponse) Descriptor

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

func (*WorkflowExecutionGetDataResponse) GetInputs added in v0.15.0

func (m *WorkflowExecutionGetDataResponse) GetInputs() *UrlBlob

func (*WorkflowExecutionGetDataResponse) GetOutputs

func (m *WorkflowExecutionGetDataResponse) GetOutputs() *UrlBlob

func (*WorkflowExecutionGetDataResponse) ProtoMessage

func (*WorkflowExecutionGetDataResponse) ProtoMessage()

func (*WorkflowExecutionGetDataResponse) Reset

func (*WorkflowExecutionGetDataResponse) String

func (*WorkflowExecutionGetDataResponse) Validate

Validate checks the field values on WorkflowExecutionGetDataResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecutionGetDataResponse) XXX_DiscardUnknown

func (m *WorkflowExecutionGetDataResponse) XXX_DiscardUnknown()

func (*WorkflowExecutionGetDataResponse) XXX_Marshal

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

func (*WorkflowExecutionGetDataResponse) XXX_Merge

func (*WorkflowExecutionGetDataResponse) XXX_Size

func (m *WorkflowExecutionGetDataResponse) XXX_Size() int

func (*WorkflowExecutionGetDataResponse) XXX_Unmarshal

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

type WorkflowExecutionGetDataResponseValidationError

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

WorkflowExecutionGetDataResponseValidationError is the validation error returned by WorkflowExecutionGetDataResponse.Validate if the designated constraints aren't met.

func (WorkflowExecutionGetDataResponseValidationError) Cause

Cause function returns cause value.

func (WorkflowExecutionGetDataResponseValidationError) Error

Error satisfies the builtin error interface

func (WorkflowExecutionGetDataResponseValidationError) ErrorName

ErrorName returns error name.

func (WorkflowExecutionGetDataResponseValidationError) Field

Field function returns field value.

func (WorkflowExecutionGetDataResponseValidationError) Key

Key function returns key value.

func (WorkflowExecutionGetDataResponseValidationError) Reason

Reason function returns reason value.

type WorkflowExecutionGetRequest

type WorkflowExecutionGetRequest struct {
	// Uniquely identifies an individual workflow execution.
	Id                   *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

A message used to fetch a single workflow execution entity.

func (*WorkflowExecutionGetRequest) Descriptor

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

func (*WorkflowExecutionGetRequest) GetId

func (*WorkflowExecutionGetRequest) ProtoMessage

func (*WorkflowExecutionGetRequest) ProtoMessage()

func (*WorkflowExecutionGetRequest) Reset

func (m *WorkflowExecutionGetRequest) Reset()

func (*WorkflowExecutionGetRequest) String

func (m *WorkflowExecutionGetRequest) String() string

func (*WorkflowExecutionGetRequest) Validate

func (m *WorkflowExecutionGetRequest) Validate() error

Validate checks the field values on WorkflowExecutionGetRequest with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecutionGetRequest) XXX_DiscardUnknown

func (m *WorkflowExecutionGetRequest) XXX_DiscardUnknown()

func (*WorkflowExecutionGetRequest) XXX_Marshal

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

func (*WorkflowExecutionGetRequest) XXX_Merge

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

func (*WorkflowExecutionGetRequest) XXX_Size

func (m *WorkflowExecutionGetRequest) XXX_Size() int

func (*WorkflowExecutionGetRequest) XXX_Unmarshal

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

type WorkflowExecutionGetRequestValidationError

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

WorkflowExecutionGetRequestValidationError is the validation error returned by WorkflowExecutionGetRequest.Validate if the designated constraints aren't met.

func (WorkflowExecutionGetRequestValidationError) Cause

Cause function returns cause value.

func (WorkflowExecutionGetRequestValidationError) Error

Error satisfies the builtin error interface

func (WorkflowExecutionGetRequestValidationError) ErrorName

ErrorName returns error name.

func (WorkflowExecutionGetRequestValidationError) Field

Field function returns field value.

func (WorkflowExecutionGetRequestValidationError) Key

Key function returns key value.

func (WorkflowExecutionGetRequestValidationError) Reason

Reason function returns reason value.

type WorkflowList

type WorkflowList struct {
	// A list of workflows returned based on the request.
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Represents a list of workflows returned from the admin.

func (*WorkflowList) Descriptor

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

func (*WorkflowList) GetToken

func (m *WorkflowList) GetToken() string

func (*WorkflowList) GetWorkflows

func (m *WorkflowList) GetWorkflows() []*Workflow

func (*WorkflowList) ProtoMessage

func (*WorkflowList) ProtoMessage()

func (*WorkflowList) Reset

func (m *WorkflowList) Reset()

func (*WorkflowList) String

func (m *WorkflowList) String() string

func (*WorkflowList) Validate

func (m *WorkflowList) Validate() error

Validate checks the field values on WorkflowList with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowList) XXX_DiscardUnknown

func (m *WorkflowList) XXX_DiscardUnknown()

func (*WorkflowList) XXX_Marshal

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

func (*WorkflowList) XXX_Merge

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

func (*WorkflowList) XXX_Size

func (m *WorkflowList) XXX_Size() int

func (*WorkflowList) XXX_Unmarshal

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

type WorkflowListValidationError

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

WorkflowListValidationError is the validation error returned by WorkflowList.Validate if the designated constraints aren't met.

func (WorkflowListValidationError) Cause

Cause function returns cause value.

func (WorkflowListValidationError) Error

Error satisfies the builtin error interface

func (WorkflowListValidationError) ErrorName

func (e WorkflowListValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowListValidationError) Field

Field function returns field value.

func (WorkflowListValidationError) Key

Key function returns key value.

func (WorkflowListValidationError) Reason

Reason function returns reason value.

type WorkflowNodeMetadata

type WorkflowNodeMetadata struct {
	ExecutionId          *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=executionId,proto3" json:"executionId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

Metadata for a WorkflowNode

func (*WorkflowNodeMetadata) Descriptor

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

func (*WorkflowNodeMetadata) GetExecutionId

func (*WorkflowNodeMetadata) ProtoMessage

func (*WorkflowNodeMetadata) ProtoMessage()

func (*WorkflowNodeMetadata) Reset

func (m *WorkflowNodeMetadata) Reset()

func (*WorkflowNodeMetadata) String

func (m *WorkflowNodeMetadata) String() string

func (*WorkflowNodeMetadata) Validate

func (m *WorkflowNodeMetadata) Validate() error

Validate checks the field values on WorkflowNodeMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowNodeMetadata) XXX_DiscardUnknown

func (m *WorkflowNodeMetadata) XXX_DiscardUnknown()

func (*WorkflowNodeMetadata) XXX_Marshal

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

func (*WorkflowNodeMetadata) XXX_Merge

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

func (*WorkflowNodeMetadata) XXX_Size

func (m *WorkflowNodeMetadata) XXX_Size() int

func (*WorkflowNodeMetadata) XXX_Unmarshal

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

type WorkflowNodeMetadataValidationError

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

WorkflowNodeMetadataValidationError is the validation error returned by WorkflowNodeMetadata.Validate if the designated constraints aren't met.

func (WorkflowNodeMetadataValidationError) Cause

Cause function returns cause value.

func (WorkflowNodeMetadataValidationError) Error

Error satisfies the builtin error interface

func (WorkflowNodeMetadataValidationError) ErrorName

ErrorName returns error name.

func (WorkflowNodeMetadataValidationError) Field

Field function returns field value.

func (WorkflowNodeMetadataValidationError) Key

Key function returns key value.

func (WorkflowNodeMetadataValidationError) Reason

Reason function returns reason value.

type WorkflowSpec

type WorkflowSpec struct {
	// Template of the task that encapsulates all the metadata of the workflow.
	Template             *core.WorkflowTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Represents a structure that encapsulates the specification of the workflow.

func (*WorkflowSpec) Descriptor

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

func (*WorkflowSpec) GetTemplate

func (m *WorkflowSpec) GetTemplate() *core.WorkflowTemplate

func (*WorkflowSpec) ProtoMessage

func (*WorkflowSpec) ProtoMessage()

func (*WorkflowSpec) Reset

func (m *WorkflowSpec) Reset()

func (*WorkflowSpec) String

func (m *WorkflowSpec) String() string

func (*WorkflowSpec) Validate

func (m *WorkflowSpec) Validate() error

Validate checks the field values on WorkflowSpec with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowSpec) XXX_DiscardUnknown

func (m *WorkflowSpec) XXX_DiscardUnknown()

func (*WorkflowSpec) XXX_Marshal

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

func (*WorkflowSpec) XXX_Merge

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

func (*WorkflowSpec) XXX_Size

func (m *WorkflowSpec) XXX_Size() int

func (*WorkflowSpec) XXX_Unmarshal

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

type WorkflowSpecValidationError

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

WorkflowSpecValidationError is the validation error returned by WorkflowSpec.Validate if the designated constraints aren't met.

func (WorkflowSpecValidationError) Cause

Cause function returns cause value.

func (WorkflowSpecValidationError) Error

Error satisfies the builtin error interface

func (WorkflowSpecValidationError) ErrorName

func (e WorkflowSpecValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowSpecValidationError) Field

Field function returns field value.

func (WorkflowSpecValidationError) Key

Key function returns key value.

func (WorkflowSpecValidationError) Reason

Reason function returns reason value.

type WorkflowValidationError

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

WorkflowValidationError is the validation error returned by Workflow.Validate if the designated constraints aren't met.

func (WorkflowValidationError) Cause

func (e WorkflowValidationError) Cause() error

Cause function returns cause value.

func (WorkflowValidationError) Error

func (e WorkflowValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowValidationError) ErrorName

func (e WorkflowValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowValidationError) Field

func (e WorkflowValidationError) Field() string

Field function returns field value.

func (WorkflowValidationError) Key

func (e WorkflowValidationError) Key() bool

Key function returns key value.

func (WorkflowValidationError) Reason

func (e WorkflowValidationError) Reason() string

Reason function returns reason value.

Jump to

Keyboard shortcuts

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