Versions in this module Expand all Collapse all v1 v1.0.1 Feb 21, 2024 v1.0.0 Feb 21, 2024 Changes in this version + var DescriptionFormat_name = map[int32]string + var DescriptionFormat_value = map[string]int32 + var ExecutionMetadata_ExecutionMode_name = map[int32]string + var ExecutionMetadata_ExecutionMode_value = map[string]int32 + var ExecutionState_name = map[int32]string + var ExecutionState_value = map[string]int32 + var File_kozmoidl_admin_agent_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_cluster_assignment_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_common_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_description_entity_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_event_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_execution_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_launch_plan_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_matchable_resource_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_node_execution_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_notification_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_project_attributes_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_project_domain_attributes_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_project_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_schedule_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_signal_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_task_execution_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_task_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_version_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_workflow_attributes_proto protoreflect.FileDescriptor + var File_kozmoidl_admin_workflow_proto protoreflect.FileDescriptor + var FixedRateUnit_name = map[int32]string + var FixedRateUnit_value = map[string]int32 + var LaunchPlanState_name = map[int32]string + var LaunchPlanState_value = map[string]int32 + var MatchableResource_name = map[int32]string + var MatchableResource_value = map[string]int32 + var NamedEntityState_name = map[int32]string + var NamedEntityState_value = map[string]int32 + var PluginOverride_MissingPluginBehavior_name = map[int32]string + var PluginOverride_MissingPluginBehavior_value = map[string]int32 + var Project_ProjectState_name = map[int32]string + var Project_ProjectState_value = map[string]int32 + var Sort_Direction_name = map[int32]string + var Sort_Direction_value = map[string]int32 + var State_name = map[int32]string + var State_value = map[string]int32 + type AbortMetadata struct + Cause string + Principal string + func (*AbortMetadata) Descriptor() ([]byte, []int) + func (*AbortMetadata) ProtoMessage() + func (x *AbortMetadata) GetCause() string + func (x *AbortMetadata) GetPrincipal() string + func (x *AbortMetadata) ProtoReflect() protoreflect.Message + func (x *AbortMetadata) Reset() + func (x *AbortMetadata) String() string + type ActiveLaunchPlanListRequest struct + Domain string + Limit uint32 + Org string + Project string + SortBy *Sort + Token string + func (*ActiveLaunchPlanListRequest) Descriptor() ([]byte, []int) + func (*ActiveLaunchPlanListRequest) ProtoMessage() + func (x *ActiveLaunchPlanListRequest) GetDomain() string + func (x *ActiveLaunchPlanListRequest) GetLimit() uint32 + func (x *ActiveLaunchPlanListRequest) GetOrg() string + func (x *ActiveLaunchPlanListRequest) GetProject() string + func (x *ActiveLaunchPlanListRequest) GetSortBy() *Sort + func (x *ActiveLaunchPlanListRequest) GetToken() string + func (x *ActiveLaunchPlanListRequest) ProtoReflect() protoreflect.Message + func (x *ActiveLaunchPlanListRequest) Reset() + func (x *ActiveLaunchPlanListRequest) String() string + type ActiveLaunchPlanRequest struct + Id *NamedEntityIdentifier + func (*ActiveLaunchPlanRequest) Descriptor() ([]byte, []int) + func (*ActiveLaunchPlanRequest) ProtoMessage() + func (x *ActiveLaunchPlanRequest) GetId() *NamedEntityIdentifier + func (x *ActiveLaunchPlanRequest) ProtoReflect() protoreflect.Message + func (x *ActiveLaunchPlanRequest) Reset() + func (x *ActiveLaunchPlanRequest) String() string + type Agent struct + Name string + SupportedTaskTypes []string + func (*Agent) Descriptor() ([]byte, []int) + func (*Agent) ProtoMessage() + func (x *Agent) GetName() string + func (x *Agent) GetSupportedTaskTypes() []string + func (x *Agent) ProtoReflect() protoreflect.Message + func (x *Agent) Reset() + func (x *Agent) String() string + type Annotations struct + Values map[string]string + func (*Annotations) Descriptor() ([]byte, []int) + func (*Annotations) ProtoMessage() + func (x *Annotations) GetValues() map[string]string + func (x *Annotations) ProtoReflect() protoreflect.Message + func (x *Annotations) Reset() + func (x *Annotations) String() string + type Auth struct + AssumableIamRole string + KubernetesServiceAccount string + func (*Auth) Descriptor() ([]byte, []int) + func (*Auth) ProtoMessage() + func (x *Auth) GetAssumableIamRole() string + func (x *Auth) GetKubernetesServiceAccount() string + func (x *Auth) ProtoReflect() protoreflect.Message + func (x *Auth) Reset() + func (x *Auth) String() string + type AuthRole struct + AssumableIamRole string + KubernetesServiceAccount string + func (*AuthRole) Descriptor() ([]byte, []int) + func (*AuthRole) ProtoMessage() + func (x *AuthRole) GetAssumableIamRole() string + func (x *AuthRole) GetKubernetesServiceAccount() string + func (x *AuthRole) ProtoReflect() protoreflect.Message + func (x *AuthRole) Reset() + func (x *AuthRole) String() string + type ClusterAssignment struct + ClusterPoolName string + func (*ClusterAssignment) Descriptor() ([]byte, []int) + func (*ClusterAssignment) ProtoMessage() + func (x *ClusterAssignment) GetClusterPoolName() string + func (x *ClusterAssignment) ProtoReflect() protoreflect.Message + func (x *ClusterAssignment) Reset() + func (x *ClusterAssignment) String() string + type ClusterResourceAttributes struct + Attributes map[string]string + func (*ClusterResourceAttributes) Descriptor() ([]byte, []int) + func (*ClusterResourceAttributes) ProtoMessage() + func (x *ClusterResourceAttributes) GetAttributes() map[string]string + func (x *ClusterResourceAttributes) ProtoReflect() protoreflect.Message + func (x *ClusterResourceAttributes) Reset() + func (x *ClusterResourceAttributes) String() string + type CreateTaskRequest struct + Inputs *core.LiteralMap + OutputPrefix string + TaskExecutionMetadata *TaskExecutionMetadata + Template *core.TaskTemplate + func (*CreateTaskRequest) Descriptor() ([]byte, []int) + func (*CreateTaskRequest) ProtoMessage() + func (x *CreateTaskRequest) GetInputs() *core.LiteralMap + func (x *CreateTaskRequest) GetOutputPrefix() string + func (x *CreateTaskRequest) GetTaskExecutionMetadata() *TaskExecutionMetadata + func (x *CreateTaskRequest) GetTemplate() *core.TaskTemplate + func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message + func (x *CreateTaskRequest) Reset() + func (x *CreateTaskRequest) String() string + type CreateTaskResponse struct + Res isCreateTaskResponse_Res + func (*CreateTaskResponse) Descriptor() ([]byte, []int) + func (*CreateTaskResponse) ProtoMessage() + func (m *CreateTaskResponse) GetRes() isCreateTaskResponse_Res + func (x *CreateTaskResponse) GetResource() *Resource + func (x *CreateTaskResponse) GetResourceMeta() []byte + func (x *CreateTaskResponse) ProtoReflect() protoreflect.Message + func (x *CreateTaskResponse) Reset() + func (x *CreateTaskResponse) String() string + type CreateTaskResponse_Resource struct + Resource *Resource + type CreateTaskResponse_ResourceMeta struct + ResourceMeta []byte + type CreateWorkflowFailureReason struct + Reason isCreateWorkflowFailureReason_Reason + func (*CreateWorkflowFailureReason) Descriptor() ([]byte, []int) + func (*CreateWorkflowFailureReason) ProtoMessage() + func (m *CreateWorkflowFailureReason) GetReason() isCreateWorkflowFailureReason_Reason + func (x *CreateWorkflowFailureReason) GetExistsDifferentStructure() *WorkflowErrorExistsDifferentStructure + func (x *CreateWorkflowFailureReason) GetExistsIdenticalStructure() *WorkflowErrorExistsIdenticalStructure + func (x *CreateWorkflowFailureReason) ProtoReflect() protoreflect.Message + func (x *CreateWorkflowFailureReason) Reset() + func (x *CreateWorkflowFailureReason) String() string + type CreateWorkflowFailureReason_ExistsDifferentStructure struct + ExistsDifferentStructure *WorkflowErrorExistsDifferentStructure + type CreateWorkflowFailureReason_ExistsIdenticalStructure struct + ExistsIdenticalStructure *WorkflowErrorExistsIdenticalStructure + type CronSchedule struct + Offset string + Schedule string + func (*CronSchedule) Descriptor() ([]byte, []int) + func (*CronSchedule) ProtoMessage() + func (x *CronSchedule) GetOffset() string + func (x *CronSchedule) GetSchedule() string + func (x *CronSchedule) ProtoReflect() protoreflect.Message + func (x *CronSchedule) Reset() + func (x *CronSchedule) String() string + type DeleteTaskRequest struct + ResourceMeta []byte + TaskType string + func (*DeleteTaskRequest) Descriptor() ([]byte, []int) + func (*DeleteTaskRequest) ProtoMessage() + func (x *DeleteTaskRequest) GetResourceMeta() []byte + func (x *DeleteTaskRequest) GetTaskType() string + func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message + func (x *DeleteTaskRequest) Reset() + func (x *DeleteTaskRequest) String() string + type DeleteTaskResponse struct + func (*DeleteTaskResponse) Descriptor() ([]byte, []int) + func (*DeleteTaskResponse) ProtoMessage() + func (x *DeleteTaskResponse) ProtoReflect() protoreflect.Message + func (x *DeleteTaskResponse) Reset() + func (x *DeleteTaskResponse) String() string + type Description struct + Content isDescription_Content + Format DescriptionFormat + IconLink string + func (*Description) Descriptor() ([]byte, []int) + func (*Description) ProtoMessage() + func (m *Description) GetContent() isDescription_Content + func (x *Description) GetFormat() DescriptionFormat + func (x *Description) GetIconLink() string + func (x *Description) GetUri() string + func (x *Description) GetValue() string + func (x *Description) ProtoReflect() protoreflect.Message + func (x *Description) Reset() + func (x *Description) String() string + type DescriptionEntity struct + Id *core.Identifier + LongDescription *Description + ShortDescription string + SourceCode *SourceCode + Tags []string + func (*DescriptionEntity) Descriptor() ([]byte, []int) + func (*DescriptionEntity) ProtoMessage() + func (x *DescriptionEntity) GetId() *core.Identifier + func (x *DescriptionEntity) GetLongDescription() *Description + func (x *DescriptionEntity) GetShortDescription() string + func (x *DescriptionEntity) GetSourceCode() *SourceCode + func (x *DescriptionEntity) GetTags() []string + func (x *DescriptionEntity) ProtoReflect() protoreflect.Message + func (x *DescriptionEntity) Reset() + func (x *DescriptionEntity) String() string + type DescriptionEntityList struct + DescriptionEntities []*DescriptionEntity + Token string + func (*DescriptionEntityList) Descriptor() ([]byte, []int) + func (*DescriptionEntityList) ProtoMessage() + func (x *DescriptionEntityList) GetDescriptionEntities() []*DescriptionEntity + func (x *DescriptionEntityList) GetToken() string + func (x *DescriptionEntityList) ProtoReflect() protoreflect.Message + func (x *DescriptionEntityList) Reset() + func (x *DescriptionEntityList) String() string + type DescriptionEntityListRequest struct + Filters string + Id *NamedEntityIdentifier + Limit uint32 + ResourceType core.ResourceType + SortBy *Sort + Token string + func (*DescriptionEntityListRequest) Descriptor() ([]byte, []int) + func (*DescriptionEntityListRequest) ProtoMessage() + func (x *DescriptionEntityListRequest) GetFilters() string + func (x *DescriptionEntityListRequest) GetId() *NamedEntityIdentifier + func (x *DescriptionEntityListRequest) GetLimit() uint32 + func (x *DescriptionEntityListRequest) GetResourceType() core.ResourceType + func (x *DescriptionEntityListRequest) GetSortBy() *Sort + func (x *DescriptionEntityListRequest) GetToken() string + func (x *DescriptionEntityListRequest) ProtoReflect() protoreflect.Message + func (x *DescriptionEntityListRequest) Reset() + func (x *DescriptionEntityListRequest) String() string + type DescriptionFormat int32 + const DescriptionFormat_DESCRIPTION_FORMAT_HTML + const DescriptionFormat_DESCRIPTION_FORMAT_MARKDOWN + const DescriptionFormat_DESCRIPTION_FORMAT_RST + const DescriptionFormat_DESCRIPTION_FORMAT_UNKNOWN + func (DescriptionFormat) Descriptor() protoreflect.EnumDescriptor + func (DescriptionFormat) EnumDescriptor() ([]byte, []int) + func (DescriptionFormat) Type() protoreflect.EnumType + func (x DescriptionFormat) Enum() *DescriptionFormat + func (x DescriptionFormat) Number() protoreflect.EnumNumber + func (x DescriptionFormat) String() string + type Description_Uri struct + Uri string + type Description_Value struct + Value string + type Domain struct + Id string + Name string + func (*Domain) Descriptor() ([]byte, []int) + func (*Domain) ProtoMessage() + func (x *Domain) GetId() string + func (x *Domain) GetName() string + func (x *Domain) ProtoReflect() protoreflect.Message + func (x *Domain) Reset() + func (x *Domain) String() string + type DynamicNodeWorkflowResponse struct + CompiledWorkflow *core.CompiledWorkflowClosure + func (*DynamicNodeWorkflowResponse) Descriptor() ([]byte, []int) + func (*DynamicNodeWorkflowResponse) ProtoMessage() + func (x *DynamicNodeWorkflowResponse) GetCompiledWorkflow() *core.CompiledWorkflowClosure + func (x *DynamicNodeWorkflowResponse) ProtoReflect() protoreflect.Message + func (x *DynamicNodeWorkflowResponse) Reset() + func (x *DynamicNodeWorkflowResponse) String() string + type DynamicWorkflowNodeMetadata struct + CompiledWorkflow *core.CompiledWorkflowClosure + DynamicJobSpecUri string + Id *core.Identifier + func (*DynamicWorkflowNodeMetadata) Descriptor() ([]byte, []int) + func (*DynamicWorkflowNodeMetadata) ProtoMessage() + func (x *DynamicWorkflowNodeMetadata) GetCompiledWorkflow() *core.CompiledWorkflowClosure + func (x *DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri() string + func (x *DynamicWorkflowNodeMetadata) GetId() *core.Identifier + func (x *DynamicWorkflowNodeMetadata) ProtoReflect() protoreflect.Message + func (x *DynamicWorkflowNodeMetadata) Reset() + func (x *DynamicWorkflowNodeMetadata) String() string + type EmailMessage struct + Body string + RecipientsEmail []string + SenderEmail string + SubjectLine string + func (*EmailMessage) Descriptor() ([]byte, []int) + func (*EmailMessage) ProtoMessage() + func (x *EmailMessage) GetBody() string + func (x *EmailMessage) GetRecipientsEmail() []string + func (x *EmailMessage) GetSenderEmail() string + func (x *EmailMessage) GetSubjectLine() string + func (x *EmailMessage) ProtoReflect() protoreflect.Message + func (x *EmailMessage) Reset() + func (x *EmailMessage) String() string + type EmailNotification struct + RecipientsEmail []string + func (*EmailNotification) Descriptor() ([]byte, []int) + func (*EmailNotification) ProtoMessage() + func (x *EmailNotification) GetRecipientsEmail() []string + func (x *EmailNotification) ProtoReflect() protoreflect.Message + func (x *EmailNotification) Reset() + func (x *EmailNotification) String() string + type Envs struct + Values []*core.KeyValuePair + func (*Envs) Descriptor() ([]byte, []int) + func (*Envs) ProtoMessage() + func (x *Envs) GetValues() []*core.KeyValuePair + func (x *Envs) ProtoReflect() protoreflect.Message + func (x *Envs) Reset() + func (x *Envs) String() string + type EventErrorAlreadyInTerminalState struct + CurrentPhase string + func (*EventErrorAlreadyInTerminalState) Descriptor() ([]byte, []int) + func (*EventErrorAlreadyInTerminalState) ProtoMessage() + func (x *EventErrorAlreadyInTerminalState) GetCurrentPhase() string + func (x *EventErrorAlreadyInTerminalState) ProtoReflect() protoreflect.Message + func (x *EventErrorAlreadyInTerminalState) Reset() + func (x *EventErrorAlreadyInTerminalState) String() string + type EventErrorIncompatibleCluster struct + Cluster string + func (*EventErrorIncompatibleCluster) Descriptor() ([]byte, []int) + func (*EventErrorIncompatibleCluster) ProtoMessage() + func (x *EventErrorIncompatibleCluster) GetCluster() string + func (x *EventErrorIncompatibleCluster) ProtoReflect() protoreflect.Message + func (x *EventErrorIncompatibleCluster) Reset() + func (x *EventErrorIncompatibleCluster) String() string + type EventFailureReason struct + Reason isEventFailureReason_Reason + func (*EventFailureReason) Descriptor() ([]byte, []int) + func (*EventFailureReason) ProtoMessage() + func (m *EventFailureReason) GetReason() isEventFailureReason_Reason + func (x *EventFailureReason) GetAlreadyInTerminalState() *EventErrorAlreadyInTerminalState + func (x *EventFailureReason) GetIncompatibleCluster() *EventErrorIncompatibleCluster + func (x *EventFailureReason) ProtoReflect() protoreflect.Message + func (x *EventFailureReason) Reset() + func (x *EventFailureReason) String() string + type EventFailureReason_AlreadyInTerminalState struct + AlreadyInTerminalState *EventErrorAlreadyInTerminalState + type EventFailureReason_IncompatibleCluster struct + IncompatibleCluster *EventErrorIncompatibleCluster + type Execution struct + Closure *ExecutionClosure + Id *core.WorkflowExecutionIdentifier + Spec *ExecutionSpec + func (*Execution) Descriptor() ([]byte, []int) + func (*Execution) ProtoMessage() + func (x *Execution) GetClosure() *ExecutionClosure + func (x *Execution) GetId() *core.WorkflowExecutionIdentifier + func (x *Execution) GetSpec() *ExecutionSpec + func (x *Execution) ProtoReflect() protoreflect.Message + func (x *Execution) Reset() + func (x *Execution) String() string + type ExecutionClosure struct + ComputedInputs *core.LiteralMap + CreatedAt *timestamppb.Timestamp + Duration *durationpb.Duration + Notifications []*Notification + OutputResult isExecutionClosure_OutputResult + Phase core.WorkflowExecution_Phase + StartedAt *timestamppb.Timestamp + StateChangeDetails *ExecutionStateChangeDetails + UpdatedAt *timestamppb.Timestamp + WorkflowId *core.Identifier + func (*ExecutionClosure) Descriptor() ([]byte, []int) + func (*ExecutionClosure) ProtoMessage() + func (m *ExecutionClosure) GetOutputResult() isExecutionClosure_OutputResult + func (x *ExecutionClosure) GetAbortCause() string + func (x *ExecutionClosure) GetAbortMetadata() *AbortMetadata + func (x *ExecutionClosure) GetComputedInputs() *core.LiteralMap + func (x *ExecutionClosure) GetCreatedAt() *timestamppb.Timestamp + func (x *ExecutionClosure) GetDuration() *durationpb.Duration + func (x *ExecutionClosure) GetError() *core.ExecutionError + func (x *ExecutionClosure) GetNotifications() []*Notification + func (x *ExecutionClosure) GetOutputData() *core.LiteralMap + func (x *ExecutionClosure) GetOutputs() *LiteralMapBlob + func (x *ExecutionClosure) GetPhase() core.WorkflowExecution_Phase + func (x *ExecutionClosure) GetStartedAt() *timestamppb.Timestamp + func (x *ExecutionClosure) GetStateChangeDetails() *ExecutionStateChangeDetails + func (x *ExecutionClosure) GetUpdatedAt() *timestamppb.Timestamp + func (x *ExecutionClosure) GetWorkflowId() *core.Identifier + func (x *ExecutionClosure) ProtoReflect() protoreflect.Message + func (x *ExecutionClosure) Reset() + func (x *ExecutionClosure) String() string + type ExecutionClosure_AbortCause struct + AbortCause string + type ExecutionClosure_AbortMetadata struct + AbortMetadata *AbortMetadata + type ExecutionClosure_Error struct + Error *core.ExecutionError + type ExecutionClosure_OutputData struct + OutputData *core.LiteralMap + type ExecutionClosure_Outputs struct + Outputs *LiteralMapBlob + type ExecutionClusterLabel struct + Value string + func (*ExecutionClusterLabel) Descriptor() ([]byte, []int) + func (*ExecutionClusterLabel) ProtoMessage() + func (x *ExecutionClusterLabel) GetValue() string + func (x *ExecutionClusterLabel) ProtoReflect() protoreflect.Message + func (x *ExecutionClusterLabel) Reset() + func (x *ExecutionClusterLabel) String() string + type ExecutionCreateRequest struct + Domain string + Inputs *core.LiteralMap + Name string + Org string + Project string + Spec *ExecutionSpec + func (*ExecutionCreateRequest) Descriptor() ([]byte, []int) + func (*ExecutionCreateRequest) ProtoMessage() + func (x *ExecutionCreateRequest) GetDomain() string + func (x *ExecutionCreateRequest) GetInputs() *core.LiteralMap + func (x *ExecutionCreateRequest) GetName() string + func (x *ExecutionCreateRequest) GetOrg() string + func (x *ExecutionCreateRequest) GetProject() string + func (x *ExecutionCreateRequest) GetSpec() *ExecutionSpec + func (x *ExecutionCreateRequest) ProtoReflect() protoreflect.Message + func (x *ExecutionCreateRequest) Reset() + func (x *ExecutionCreateRequest) String() string + type ExecutionCreateResponse struct + Id *core.WorkflowExecutionIdentifier + func (*ExecutionCreateResponse) Descriptor() ([]byte, []int) + func (*ExecutionCreateResponse) ProtoMessage() + func (x *ExecutionCreateResponse) GetId() *core.WorkflowExecutionIdentifier + func (x *ExecutionCreateResponse) ProtoReflect() protoreflect.Message + func (x *ExecutionCreateResponse) Reset() + func (x *ExecutionCreateResponse) String() string + type ExecutionList struct + Executions []*Execution + Token string + func (*ExecutionList) Descriptor() ([]byte, []int) + func (*ExecutionList) ProtoMessage() + func (x *ExecutionList) GetExecutions() []*Execution + func (x *ExecutionList) GetToken() string + func (x *ExecutionList) ProtoReflect() protoreflect.Message + func (x *ExecutionList) Reset() + func (x *ExecutionList) String() string + type ExecutionMetadata struct + ArtifactIds []*core.ArtifactID + Mode ExecutionMetadata_ExecutionMode + Nesting uint32 + ParentNodeExecution *core.NodeExecutionIdentifier + Principal string + ReferenceExecution *core.WorkflowExecutionIdentifier + ScheduledAt *timestamppb.Timestamp + SystemMetadata *SystemMetadata + func (*ExecutionMetadata) Descriptor() ([]byte, []int) + func (*ExecutionMetadata) ProtoMessage() + func (x *ExecutionMetadata) GetArtifactIds() []*core.ArtifactID + func (x *ExecutionMetadata) GetMode() ExecutionMetadata_ExecutionMode + func (x *ExecutionMetadata) GetNesting() uint32 + func (x *ExecutionMetadata) GetParentNodeExecution() *core.NodeExecutionIdentifier + func (x *ExecutionMetadata) GetPrincipal() string + func (x *ExecutionMetadata) GetReferenceExecution() *core.WorkflowExecutionIdentifier + func (x *ExecutionMetadata) GetScheduledAt() *timestamppb.Timestamp + func (x *ExecutionMetadata) GetSystemMetadata() *SystemMetadata + func (x *ExecutionMetadata) ProtoReflect() protoreflect.Message + func (x *ExecutionMetadata) Reset() + func (x *ExecutionMetadata) String() string + type ExecutionMetadata_ExecutionMode int32 + const ExecutionMetadata_CHILD_WORKFLOW + const ExecutionMetadata_MANUAL + const ExecutionMetadata_RECOVERED + const ExecutionMetadata_RELAUNCH + const ExecutionMetadata_SCHEDULED + const ExecutionMetadata_SYSTEM + func (ExecutionMetadata_ExecutionMode) Descriptor() protoreflect.EnumDescriptor + func (ExecutionMetadata_ExecutionMode) EnumDescriptor() ([]byte, []int) + func (ExecutionMetadata_ExecutionMode) Type() protoreflect.EnumType + func (x ExecutionMetadata_ExecutionMode) Enum() *ExecutionMetadata_ExecutionMode + func (x ExecutionMetadata_ExecutionMode) Number() protoreflect.EnumNumber + func (x ExecutionMetadata_ExecutionMode) String() string + type ExecutionQueueAttributes struct + Tags []string + func (*ExecutionQueueAttributes) Descriptor() ([]byte, []int) + func (*ExecutionQueueAttributes) ProtoMessage() + func (x *ExecutionQueueAttributes) GetTags() []string + func (x *ExecutionQueueAttributes) ProtoReflect() protoreflect.Message + func (x *ExecutionQueueAttributes) Reset() + func (x *ExecutionQueueAttributes) String() string + type ExecutionRecoverRequest struct + Id *core.WorkflowExecutionIdentifier + Metadata *ExecutionMetadata + Name string + func (*ExecutionRecoverRequest) Descriptor() ([]byte, []int) + func (*ExecutionRecoverRequest) ProtoMessage() + func (x *ExecutionRecoverRequest) GetId() *core.WorkflowExecutionIdentifier + func (x *ExecutionRecoverRequest) GetMetadata() *ExecutionMetadata + func (x *ExecutionRecoverRequest) GetName() string + func (x *ExecutionRecoverRequest) ProtoReflect() protoreflect.Message + func (x *ExecutionRecoverRequest) Reset() + func (x *ExecutionRecoverRequest) String() string + type ExecutionRelaunchRequest struct + Id *core.WorkflowExecutionIdentifier + Name string + OverwriteCache bool + func (*ExecutionRelaunchRequest) Descriptor() ([]byte, []int) + func (*ExecutionRelaunchRequest) ProtoMessage() + func (x *ExecutionRelaunchRequest) GetId() *core.WorkflowExecutionIdentifier + func (x *ExecutionRelaunchRequest) GetName() string + func (x *ExecutionRelaunchRequest) GetOverwriteCache() bool + func (x *ExecutionRelaunchRequest) ProtoReflect() protoreflect.Message + func (x *ExecutionRelaunchRequest) Reset() + func (x *ExecutionRelaunchRequest) String() string + type ExecutionSpec struct + Annotations *Annotations + AuthRole *AuthRole + ClusterAssignment *ClusterAssignment + Envs *Envs + Inputs *core.LiteralMap + Interruptible *wrapperspb.BoolValue + Labels *Labels + LaunchPlan *core.Identifier + MaxParallelism int32 + Metadata *ExecutionMetadata + NotificationOverrides isExecutionSpec_NotificationOverrides + OverwriteCache bool + QualityOfService *core.QualityOfService + RawOutputDataConfig *RawOutputDataConfig + SecurityContext *core.SecurityContext + Tags []string + func (*ExecutionSpec) Descriptor() ([]byte, []int) + func (*ExecutionSpec) ProtoMessage() + func (m *ExecutionSpec) GetNotificationOverrides() isExecutionSpec_NotificationOverrides + func (x *ExecutionSpec) GetAnnotations() *Annotations + func (x *ExecutionSpec) GetAuthRole() *AuthRole + func (x *ExecutionSpec) GetClusterAssignment() *ClusterAssignment + func (x *ExecutionSpec) GetDisableAll() bool + func (x *ExecutionSpec) GetEnvs() *Envs + func (x *ExecutionSpec) GetInputs() *core.LiteralMap + func (x *ExecutionSpec) GetInterruptible() *wrapperspb.BoolValue + func (x *ExecutionSpec) GetLabels() *Labels + func (x *ExecutionSpec) GetLaunchPlan() *core.Identifier + func (x *ExecutionSpec) GetMaxParallelism() int32 + func (x *ExecutionSpec) GetMetadata() *ExecutionMetadata + func (x *ExecutionSpec) GetNotifications() *NotificationList + func (x *ExecutionSpec) GetOverwriteCache() bool + func (x *ExecutionSpec) GetQualityOfService() *core.QualityOfService + func (x *ExecutionSpec) GetRawOutputDataConfig() *RawOutputDataConfig + func (x *ExecutionSpec) GetSecurityContext() *core.SecurityContext + func (x *ExecutionSpec) GetTags() []string + func (x *ExecutionSpec) ProtoReflect() protoreflect.Message + func (x *ExecutionSpec) Reset() + func (x *ExecutionSpec) String() string + type ExecutionSpec_DisableAll struct + DisableAll bool + type ExecutionSpec_Notifications struct + Notifications *NotificationList + type ExecutionState int32 + const ExecutionState_EXECUTION_ACTIVE + const ExecutionState_EXECUTION_ARCHIVED + func (ExecutionState) Descriptor() protoreflect.EnumDescriptor + func (ExecutionState) EnumDescriptor() ([]byte, []int) + func (ExecutionState) Type() protoreflect.EnumType + func (x ExecutionState) Enum() *ExecutionState + func (x ExecutionState) Number() protoreflect.EnumNumber + func (x ExecutionState) String() string + type ExecutionStateChangeDetails struct + OccurredAt *timestamppb.Timestamp + Principal string + State ExecutionState + func (*ExecutionStateChangeDetails) Descriptor() ([]byte, []int) + func (*ExecutionStateChangeDetails) ProtoMessage() + func (x *ExecutionStateChangeDetails) GetOccurredAt() *timestamppb.Timestamp + func (x *ExecutionStateChangeDetails) GetPrincipal() string + func (x *ExecutionStateChangeDetails) GetState() ExecutionState + func (x *ExecutionStateChangeDetails) ProtoReflect() protoreflect.Message + func (x *ExecutionStateChangeDetails) Reset() + func (x *ExecutionStateChangeDetails) String() string + type ExecutionTerminateRequest struct + Cause string + Id *core.WorkflowExecutionIdentifier + func (*ExecutionTerminateRequest) Descriptor() ([]byte, []int) + func (*ExecutionTerminateRequest) ProtoMessage() + func (x *ExecutionTerminateRequest) GetCause() string + func (x *ExecutionTerminateRequest) GetId() *core.WorkflowExecutionIdentifier + func (x *ExecutionTerminateRequest) ProtoReflect() protoreflect.Message + func (x *ExecutionTerminateRequest) Reset() + func (x *ExecutionTerminateRequest) String() string + type ExecutionTerminateResponse struct + func (*ExecutionTerminateResponse) Descriptor() ([]byte, []int) + func (*ExecutionTerminateResponse) ProtoMessage() + func (x *ExecutionTerminateResponse) ProtoReflect() protoreflect.Message + func (x *ExecutionTerminateResponse) Reset() + func (x *ExecutionTerminateResponse) String() string + type ExecutionUpdateRequest struct + Id *core.WorkflowExecutionIdentifier + State ExecutionState + func (*ExecutionUpdateRequest) Descriptor() ([]byte, []int) + func (*ExecutionUpdateRequest) ProtoMessage() + func (x *ExecutionUpdateRequest) GetId() *core.WorkflowExecutionIdentifier + func (x *ExecutionUpdateRequest) GetState() ExecutionState + func (x *ExecutionUpdateRequest) ProtoReflect() protoreflect.Message + func (x *ExecutionUpdateRequest) Reset() + func (x *ExecutionUpdateRequest) String() string + type ExecutionUpdateResponse struct + func (*ExecutionUpdateResponse) Descriptor() ([]byte, []int) + func (*ExecutionUpdateResponse) ProtoMessage() + func (x *ExecutionUpdateResponse) ProtoReflect() protoreflect.Message + func (x *ExecutionUpdateResponse) Reset() + func (x *ExecutionUpdateResponse) String() string + type FixedRate struct + Unit FixedRateUnit + Value uint32 + func (*FixedRate) Descriptor() ([]byte, []int) + func (*FixedRate) ProtoMessage() + func (x *FixedRate) GetUnit() FixedRateUnit + func (x *FixedRate) GetValue() uint32 + func (x *FixedRate) ProtoReflect() protoreflect.Message + func (x *FixedRate) Reset() + func (x *FixedRate) String() string + type FixedRateUnit int32 + const FixedRateUnit_DAY + const FixedRateUnit_HOUR + const FixedRateUnit_MINUTE + func (FixedRateUnit) Descriptor() protoreflect.EnumDescriptor + func (FixedRateUnit) EnumDescriptor() ([]byte, []int) + func (FixedRateUnit) Type() protoreflect.EnumType + func (x FixedRateUnit) Enum() *FixedRateUnit + func (x FixedRateUnit) Number() protoreflect.EnumNumber + func (x FixedRateUnit) String() string + type GetAgentRequest struct + Name string + func (*GetAgentRequest) Descriptor() ([]byte, []int) + func (*GetAgentRequest) ProtoMessage() + func (x *GetAgentRequest) GetName() string + func (x *GetAgentRequest) ProtoReflect() protoreflect.Message + func (x *GetAgentRequest) Reset() + func (x *GetAgentRequest) String() string + type GetAgentResponse struct + Agent *Agent + func (*GetAgentResponse) Descriptor() ([]byte, []int) + func (*GetAgentResponse) ProtoMessage() + func (x *GetAgentResponse) GetAgent() *Agent + func (x *GetAgentResponse) ProtoReflect() protoreflect.Message + func (x *GetAgentResponse) Reset() + func (x *GetAgentResponse) String() string + type GetDynamicNodeWorkflowRequest struct + Id *core.NodeExecutionIdentifier + func (*GetDynamicNodeWorkflowRequest) Descriptor() ([]byte, []int) + func (*GetDynamicNodeWorkflowRequest) ProtoMessage() + func (x *GetDynamicNodeWorkflowRequest) GetId() *core.NodeExecutionIdentifier + func (x *GetDynamicNodeWorkflowRequest) ProtoReflect() protoreflect.Message + func (x *GetDynamicNodeWorkflowRequest) Reset() + func (x *GetDynamicNodeWorkflowRequest) String() string + type GetTaskLogsRequest struct + Lines uint64 + ResourceMeta []byte + TaskType string + Token string + func (*GetTaskLogsRequest) Descriptor() ([]byte, []int) + func (*GetTaskLogsRequest) ProtoMessage() + func (x *GetTaskLogsRequest) GetLines() uint64 + func (x *GetTaskLogsRequest) GetResourceMeta() []byte + func (x *GetTaskLogsRequest) GetTaskType() string + func (x *GetTaskLogsRequest) GetToken() string + func (x *GetTaskLogsRequest) ProtoReflect() protoreflect.Message + func (x *GetTaskLogsRequest) Reset() + func (x *GetTaskLogsRequest) String() string + type GetTaskLogsResponse struct + Results []string + Token string + func (*GetTaskLogsResponse) Descriptor() ([]byte, []int) + func (*GetTaskLogsResponse) ProtoMessage() + func (x *GetTaskLogsResponse) GetResults() []string + func (x *GetTaskLogsResponse) GetToken() string + func (x *GetTaskLogsResponse) ProtoReflect() protoreflect.Message + func (x *GetTaskLogsResponse) Reset() + func (x *GetTaskLogsResponse) String() string + type GetTaskMetricsRequest struct + EndTime *timestamppb.Timestamp + Queries []string + ResourceMeta []byte + StartTime *timestamppb.Timestamp + Step *durationpb.Duration + TaskType string + func (*GetTaskMetricsRequest) Descriptor() ([]byte, []int) + func (*GetTaskMetricsRequest) ProtoMessage() + func (x *GetTaskMetricsRequest) GetEndTime() *timestamppb.Timestamp + func (x *GetTaskMetricsRequest) GetQueries() []string + func (x *GetTaskMetricsRequest) GetResourceMeta() []byte + func (x *GetTaskMetricsRequest) GetStartTime() *timestamppb.Timestamp + func (x *GetTaskMetricsRequest) GetStep() *durationpb.Duration + func (x *GetTaskMetricsRequest) GetTaskType() string + func (x *GetTaskMetricsRequest) ProtoReflect() protoreflect.Message + func (x *GetTaskMetricsRequest) Reset() + func (x *GetTaskMetricsRequest) String() string + type GetTaskMetricsResponse struct + Results []*core.ExecutionMetricResult + func (*GetTaskMetricsResponse) Descriptor() ([]byte, []int) + func (*GetTaskMetricsResponse) ProtoMessage() + func (x *GetTaskMetricsResponse) GetResults() []*core.ExecutionMetricResult + func (x *GetTaskMetricsResponse) ProtoReflect() protoreflect.Message + func (x *GetTaskMetricsResponse) Reset() + func (x *GetTaskMetricsResponse) String() string + type GetTaskRequest struct + ResourceMeta []byte + TaskType string + func (*GetTaskRequest) Descriptor() ([]byte, []int) + func (*GetTaskRequest) ProtoMessage() + func (x *GetTaskRequest) GetResourceMeta() []byte + func (x *GetTaskRequest) GetTaskType() string + func (x *GetTaskRequest) ProtoReflect() protoreflect.Message + func (x *GetTaskRequest) Reset() + func (x *GetTaskRequest) String() string + type GetTaskResponse struct + LogLinks []*core.TaskLog + Resource *Resource + func (*GetTaskResponse) Descriptor() ([]byte, []int) + func (*GetTaskResponse) ProtoMessage() + func (x *GetTaskResponse) GetLogLinks() []*core.TaskLog + func (x *GetTaskResponse) GetResource() *Resource + func (x *GetTaskResponse) ProtoReflect() protoreflect.Message + func (x *GetTaskResponse) Reset() + func (x *GetTaskResponse) String() string + type GetVersionRequest struct + func (*GetVersionRequest) Descriptor() ([]byte, []int) + func (*GetVersionRequest) ProtoMessage() + func (x *GetVersionRequest) ProtoReflect() protoreflect.Message + func (x *GetVersionRequest) Reset() + func (x *GetVersionRequest) String() string + type GetVersionResponse struct + ControlPlaneVersion *Version + func (*GetVersionResponse) Descriptor() ([]byte, []int) + func (*GetVersionResponse) ProtoMessage() + func (x *GetVersionResponse) GetControlPlaneVersion() *Version + func (x *GetVersionResponse) ProtoReflect() protoreflect.Message + func (x *GetVersionResponse) Reset() + func (x *GetVersionResponse) String() string + type KozmoURLs struct + Deck string + Inputs string + Outputs string + func (*KozmoURLs) Descriptor() ([]byte, []int) + func (*KozmoURLs) ProtoMessage() + func (x *KozmoURLs) GetDeck() string + func (x *KozmoURLs) GetInputs() string + func (x *KozmoURLs) GetOutputs() string + func (x *KozmoURLs) ProtoReflect() protoreflect.Message + func (x *KozmoURLs) Reset() + func (x *KozmoURLs) String() string + type Labels struct + Values map[string]string + func (*Labels) Descriptor() ([]byte, []int) + func (*Labels) ProtoMessage() + func (x *Labels) GetValues() map[string]string + func (x *Labels) ProtoReflect() protoreflect.Message + func (x *Labels) Reset() + func (x *Labels) String() string + type LaunchPlan struct + Closure *LaunchPlanClosure + Id *core.Identifier + Spec *LaunchPlanSpec + func (*LaunchPlan) Descriptor() ([]byte, []int) + func (*LaunchPlan) ProtoMessage() + func (x *LaunchPlan) GetClosure() *LaunchPlanClosure + func (x *LaunchPlan) GetId() *core.Identifier + func (x *LaunchPlan) GetSpec() *LaunchPlanSpec + func (x *LaunchPlan) ProtoReflect() protoreflect.Message + func (x *LaunchPlan) Reset() + func (x *LaunchPlan) String() string + type LaunchPlanClosure struct + CreatedAt *timestamppb.Timestamp + ExpectedInputs *core.ParameterMap + ExpectedOutputs *core.VariableMap + State LaunchPlanState + UpdatedAt *timestamppb.Timestamp + func (*LaunchPlanClosure) Descriptor() ([]byte, []int) + func (*LaunchPlanClosure) ProtoMessage() + func (x *LaunchPlanClosure) GetCreatedAt() *timestamppb.Timestamp + func (x *LaunchPlanClosure) GetExpectedInputs() *core.ParameterMap + func (x *LaunchPlanClosure) GetExpectedOutputs() *core.VariableMap + func (x *LaunchPlanClosure) GetState() LaunchPlanState + func (x *LaunchPlanClosure) GetUpdatedAt() *timestamppb.Timestamp + func (x *LaunchPlanClosure) ProtoReflect() protoreflect.Message + func (x *LaunchPlanClosure) Reset() + func (x *LaunchPlanClosure) String() string + type LaunchPlanCreateRequest struct + Id *core.Identifier + Spec *LaunchPlanSpec + func (*LaunchPlanCreateRequest) Descriptor() ([]byte, []int) + func (*LaunchPlanCreateRequest) ProtoMessage() + func (x *LaunchPlanCreateRequest) GetId() *core.Identifier + func (x *LaunchPlanCreateRequest) GetSpec() *LaunchPlanSpec + func (x *LaunchPlanCreateRequest) ProtoReflect() protoreflect.Message + func (x *LaunchPlanCreateRequest) Reset() + func (x *LaunchPlanCreateRequest) String() string + type LaunchPlanCreateResponse struct + func (*LaunchPlanCreateResponse) Descriptor() ([]byte, []int) + func (*LaunchPlanCreateResponse) ProtoMessage() + func (x *LaunchPlanCreateResponse) ProtoReflect() protoreflect.Message + func (x *LaunchPlanCreateResponse) Reset() + func (x *LaunchPlanCreateResponse) String() string + type LaunchPlanList struct + LaunchPlans []*LaunchPlan + Token string + func (*LaunchPlanList) Descriptor() ([]byte, []int) + func (*LaunchPlanList) ProtoMessage() + func (x *LaunchPlanList) GetLaunchPlans() []*LaunchPlan + func (x *LaunchPlanList) GetToken() string + func (x *LaunchPlanList) ProtoReflect() protoreflect.Message + func (x *LaunchPlanList) Reset() + func (x *LaunchPlanList) String() string + type LaunchPlanMetadata struct + LaunchConditions *anypb.Any + Notifications []*Notification + Schedule *Schedule + func (*LaunchPlanMetadata) Descriptor() ([]byte, []int) + func (*LaunchPlanMetadata) ProtoMessage() + func (x *LaunchPlanMetadata) GetLaunchConditions() *anypb.Any + func (x *LaunchPlanMetadata) GetNotifications() []*Notification + func (x *LaunchPlanMetadata) GetSchedule() *Schedule + func (x *LaunchPlanMetadata) ProtoReflect() protoreflect.Message + func (x *LaunchPlanMetadata) Reset() + func (x *LaunchPlanMetadata) String() string + type LaunchPlanSpec struct + Annotations *Annotations + Auth *Auth + AuthRole *AuthRole + DefaultInputs *core.ParameterMap + EntityMetadata *LaunchPlanMetadata + Envs *Envs + FixedInputs *core.LiteralMap + Interruptible *wrapperspb.BoolValue + Labels *Labels + MaxParallelism int32 + OverwriteCache bool + QualityOfService *core.QualityOfService + RawOutputDataConfig *RawOutputDataConfig + Role string + SecurityContext *core.SecurityContext + WorkflowId *core.Identifier + func (*LaunchPlanSpec) Descriptor() ([]byte, []int) + func (*LaunchPlanSpec) ProtoMessage() + func (x *LaunchPlanSpec) GetAnnotations() *Annotations + func (x *LaunchPlanSpec) GetAuth() *Auth + func (x *LaunchPlanSpec) GetAuthRole() *AuthRole + func (x *LaunchPlanSpec) GetDefaultInputs() *core.ParameterMap + func (x *LaunchPlanSpec) GetEntityMetadata() *LaunchPlanMetadata + func (x *LaunchPlanSpec) GetEnvs() *Envs + func (x *LaunchPlanSpec) GetFixedInputs() *core.LiteralMap + func (x *LaunchPlanSpec) GetInterruptible() *wrapperspb.BoolValue + func (x *LaunchPlanSpec) GetLabels() *Labels + func (x *LaunchPlanSpec) GetMaxParallelism() int32 + func (x *LaunchPlanSpec) GetOverwriteCache() bool + func (x *LaunchPlanSpec) GetQualityOfService() *core.QualityOfService + func (x *LaunchPlanSpec) GetRawOutputDataConfig() *RawOutputDataConfig + func (x *LaunchPlanSpec) GetRole() string + func (x *LaunchPlanSpec) GetSecurityContext() *core.SecurityContext + func (x *LaunchPlanSpec) GetWorkflowId() *core.Identifier + func (x *LaunchPlanSpec) ProtoReflect() protoreflect.Message + func (x *LaunchPlanSpec) Reset() + func (x *LaunchPlanSpec) String() string + type LaunchPlanState int32 + const LaunchPlanState_ACTIVE + const LaunchPlanState_INACTIVE + func (LaunchPlanState) Descriptor() protoreflect.EnumDescriptor + func (LaunchPlanState) EnumDescriptor() ([]byte, []int) + func (LaunchPlanState) Type() protoreflect.EnumType + func (x LaunchPlanState) Enum() *LaunchPlanState + func (x LaunchPlanState) Number() protoreflect.EnumNumber + func (x LaunchPlanState) String() string + type LaunchPlanUpdateRequest struct + Id *core.Identifier + State LaunchPlanState + func (*LaunchPlanUpdateRequest) Descriptor() ([]byte, []int) + func (*LaunchPlanUpdateRequest) ProtoMessage() + func (x *LaunchPlanUpdateRequest) GetId() *core.Identifier + func (x *LaunchPlanUpdateRequest) GetState() LaunchPlanState + func (x *LaunchPlanUpdateRequest) ProtoReflect() protoreflect.Message + func (x *LaunchPlanUpdateRequest) Reset() + func (x *LaunchPlanUpdateRequest) String() string + type LaunchPlanUpdateResponse struct + func (*LaunchPlanUpdateResponse) Descriptor() ([]byte, []int) + func (*LaunchPlanUpdateResponse) ProtoMessage() + func (x *LaunchPlanUpdateResponse) ProtoReflect() protoreflect.Message + func (x *LaunchPlanUpdateResponse) Reset() + func (x *LaunchPlanUpdateResponse) String() string + type ListAgentsRequest struct + func (*ListAgentsRequest) Descriptor() ([]byte, []int) + func (*ListAgentsRequest) ProtoMessage() + func (x *ListAgentsRequest) ProtoReflect() protoreflect.Message + func (x *ListAgentsRequest) Reset() + func (x *ListAgentsRequest) String() string + type ListAgentsResponse struct + Agents []*Agent + func (*ListAgentsResponse) Descriptor() ([]byte, []int) + func (*ListAgentsResponse) ProtoMessage() + func (x *ListAgentsResponse) GetAgents() []*Agent + func (x *ListAgentsResponse) ProtoReflect() protoreflect.Message + func (x *ListAgentsResponse) Reset() + func (x *ListAgentsResponse) String() string + type ListMatchableAttributesRequest struct + Org string + ResourceType MatchableResource + func (*ListMatchableAttributesRequest) Descriptor() ([]byte, []int) + func (*ListMatchableAttributesRequest) ProtoMessage() + func (x *ListMatchableAttributesRequest) GetOrg() string + func (x *ListMatchableAttributesRequest) GetResourceType() MatchableResource + func (x *ListMatchableAttributesRequest) ProtoReflect() protoreflect.Message + func (x *ListMatchableAttributesRequest) Reset() + func (x *ListMatchableAttributesRequest) String() string + type ListMatchableAttributesResponse struct + Configurations []*MatchableAttributesConfiguration + func (*ListMatchableAttributesResponse) Descriptor() ([]byte, []int) + func (*ListMatchableAttributesResponse) ProtoMessage() + func (x *ListMatchableAttributesResponse) GetConfigurations() []*MatchableAttributesConfiguration + func (x *ListMatchableAttributesResponse) ProtoReflect() protoreflect.Message + func (x *ListMatchableAttributesResponse) Reset() + func (x *ListMatchableAttributesResponse) String() string + type LiteralMapBlob struct + Data isLiteralMapBlob_Data + func (*LiteralMapBlob) Descriptor() ([]byte, []int) + func (*LiteralMapBlob) ProtoMessage() + func (m *LiteralMapBlob) GetData() isLiteralMapBlob_Data + func (x *LiteralMapBlob) GetUri() string + func (x *LiteralMapBlob) GetValues() *core.LiteralMap + func (x *LiteralMapBlob) ProtoReflect() protoreflect.Message + func (x *LiteralMapBlob) Reset() + func (x *LiteralMapBlob) String() string + type LiteralMapBlob_Uri struct + Uri string + type LiteralMapBlob_Values struct + Values *core.LiteralMap + type MatchableAttributesConfiguration struct + Attributes *MatchingAttributes + Domain string + LaunchPlan string + Org string + Project string + Workflow string + func (*MatchableAttributesConfiguration) Descriptor() ([]byte, []int) + func (*MatchableAttributesConfiguration) ProtoMessage() + func (x *MatchableAttributesConfiguration) GetAttributes() *MatchingAttributes + func (x *MatchableAttributesConfiguration) GetDomain() string + func (x *MatchableAttributesConfiguration) GetLaunchPlan() string + func (x *MatchableAttributesConfiguration) GetOrg() string + func (x *MatchableAttributesConfiguration) GetProject() string + func (x *MatchableAttributesConfiguration) GetWorkflow() string + func (x *MatchableAttributesConfiguration) ProtoReflect() protoreflect.Message + func (x *MatchableAttributesConfiguration) Reset() + func (x *MatchableAttributesConfiguration) String() string + type MatchableResource int32 + const MatchableResource_CLUSTER_ASSIGNMENT + const MatchableResource_CLUSTER_RESOURCE + const MatchableResource_EXECUTION_CLUSTER_LABEL + const MatchableResource_EXECUTION_QUEUE + const MatchableResource_PLUGIN_OVERRIDE + const MatchableResource_QUALITY_OF_SERVICE_SPECIFICATION + const MatchableResource_TASK_RESOURCE + const MatchableResource_WORKFLOW_EXECUTION_CONFIG + func (MatchableResource) Descriptor() protoreflect.EnumDescriptor + func (MatchableResource) EnumDescriptor() ([]byte, []int) + func (MatchableResource) Type() protoreflect.EnumType + func (x MatchableResource) Enum() *MatchableResource + func (x MatchableResource) Number() protoreflect.EnumNumber + func (x MatchableResource) String() string + type MatchingAttributes struct + Target isMatchingAttributes_Target + func (*MatchingAttributes) Descriptor() ([]byte, []int) + func (*MatchingAttributes) ProtoMessage() + func (m *MatchingAttributes) GetTarget() isMatchingAttributes_Target + func (x *MatchingAttributes) GetClusterAssignment() *ClusterAssignment + func (x *MatchingAttributes) GetClusterResourceAttributes() *ClusterResourceAttributes + func (x *MatchingAttributes) GetExecutionClusterLabel() *ExecutionClusterLabel + func (x *MatchingAttributes) GetExecutionQueueAttributes() *ExecutionQueueAttributes + func (x *MatchingAttributes) GetPluginOverrides() *PluginOverrides + func (x *MatchingAttributes) GetQualityOfService() *core.QualityOfService + func (x *MatchingAttributes) GetTaskResourceAttributes() *TaskResourceAttributes + func (x *MatchingAttributes) GetWorkflowExecutionConfig() *WorkflowExecutionConfig + func (x *MatchingAttributes) ProtoReflect() protoreflect.Message + func (x *MatchingAttributes) Reset() + func (x *MatchingAttributes) String() string + type MatchingAttributes_ClusterAssignment struct + ClusterAssignment *ClusterAssignment + type MatchingAttributes_ClusterResourceAttributes struct + ClusterResourceAttributes *ClusterResourceAttributes + type MatchingAttributes_ExecutionClusterLabel struct + ExecutionClusterLabel *ExecutionClusterLabel + type MatchingAttributes_ExecutionQueueAttributes struct + ExecutionQueueAttributes *ExecutionQueueAttributes + type MatchingAttributes_PluginOverrides struct + PluginOverrides *PluginOverrides + type MatchingAttributes_QualityOfService struct + QualityOfService *core.QualityOfService + type MatchingAttributes_TaskResourceAttributes struct + TaskResourceAttributes *TaskResourceAttributes + type MatchingAttributes_WorkflowExecutionConfig struct + WorkflowExecutionConfig *WorkflowExecutionConfig + type NamedEntity struct + Id *NamedEntityIdentifier + Metadata *NamedEntityMetadata + ResourceType core.ResourceType + func (*NamedEntity) Descriptor() ([]byte, []int) + func (*NamedEntity) ProtoMessage() + func (x *NamedEntity) GetId() *NamedEntityIdentifier + func (x *NamedEntity) GetMetadata() *NamedEntityMetadata + func (x *NamedEntity) GetResourceType() core.ResourceType + func (x *NamedEntity) ProtoReflect() protoreflect.Message + func (x *NamedEntity) Reset() + func (x *NamedEntity) String() string + type NamedEntityGetRequest struct + Id *NamedEntityIdentifier + ResourceType core.ResourceType + func (*NamedEntityGetRequest) Descriptor() ([]byte, []int) + func (*NamedEntityGetRequest) ProtoMessage() + func (x *NamedEntityGetRequest) GetId() *NamedEntityIdentifier + func (x *NamedEntityGetRequest) GetResourceType() core.ResourceType + func (x *NamedEntityGetRequest) ProtoReflect() protoreflect.Message + func (x *NamedEntityGetRequest) Reset() + func (x *NamedEntityGetRequest) String() string + type NamedEntityIdentifier struct + Domain string + Name string + Org string + Project string + func (*NamedEntityIdentifier) Descriptor() ([]byte, []int) + func (*NamedEntityIdentifier) ProtoMessage() + func (x *NamedEntityIdentifier) GetDomain() string + func (x *NamedEntityIdentifier) GetName() string + func (x *NamedEntityIdentifier) GetOrg() string + func (x *NamedEntityIdentifier) GetProject() string + func (x *NamedEntityIdentifier) ProtoReflect() protoreflect.Message + func (x *NamedEntityIdentifier) Reset() + func (x *NamedEntityIdentifier) String() string + type NamedEntityIdentifierList struct + Entities []*NamedEntityIdentifier + Token string + func (*NamedEntityIdentifierList) Descriptor() ([]byte, []int) + func (*NamedEntityIdentifierList) ProtoMessage() + func (x *NamedEntityIdentifierList) GetEntities() []*NamedEntityIdentifier + func (x *NamedEntityIdentifierList) GetToken() string + func (x *NamedEntityIdentifierList) ProtoReflect() protoreflect.Message + func (x *NamedEntityIdentifierList) Reset() + func (x *NamedEntityIdentifierList) String() string + type NamedEntityIdentifierListRequest struct + Domain string + Filters string + Limit uint32 + Org string + Project string + SortBy *Sort + Token string + func (*NamedEntityIdentifierListRequest) Descriptor() ([]byte, []int) + func (*NamedEntityIdentifierListRequest) ProtoMessage() + func (x *NamedEntityIdentifierListRequest) GetDomain() string + func (x *NamedEntityIdentifierListRequest) GetFilters() string + func (x *NamedEntityIdentifierListRequest) GetLimit() uint32 + func (x *NamedEntityIdentifierListRequest) GetOrg() string + func (x *NamedEntityIdentifierListRequest) GetProject() string + func (x *NamedEntityIdentifierListRequest) GetSortBy() *Sort + func (x *NamedEntityIdentifierListRequest) GetToken() string + func (x *NamedEntityIdentifierListRequest) ProtoReflect() protoreflect.Message + func (x *NamedEntityIdentifierListRequest) Reset() + func (x *NamedEntityIdentifierListRequest) String() string + type NamedEntityList struct + Entities []*NamedEntity + Token string + func (*NamedEntityList) Descriptor() ([]byte, []int) + func (*NamedEntityList) ProtoMessage() + func (x *NamedEntityList) GetEntities() []*NamedEntity + func (x *NamedEntityList) GetToken() string + func (x *NamedEntityList) ProtoReflect() protoreflect.Message + func (x *NamedEntityList) Reset() + func (x *NamedEntityList) String() string + type NamedEntityListRequest struct + Domain string + Filters string + Limit uint32 + Org string + Project string + ResourceType core.ResourceType + SortBy *Sort + Token string + func (*NamedEntityListRequest) Descriptor() ([]byte, []int) + func (*NamedEntityListRequest) ProtoMessage() + func (x *NamedEntityListRequest) GetDomain() string + func (x *NamedEntityListRequest) GetFilters() string + func (x *NamedEntityListRequest) GetLimit() uint32 + func (x *NamedEntityListRequest) GetOrg() string + func (x *NamedEntityListRequest) GetProject() string + func (x *NamedEntityListRequest) GetResourceType() core.ResourceType + func (x *NamedEntityListRequest) GetSortBy() *Sort + func (x *NamedEntityListRequest) GetToken() string + func (x *NamedEntityListRequest) ProtoReflect() protoreflect.Message + func (x *NamedEntityListRequest) Reset() + func (x *NamedEntityListRequest) String() string + type NamedEntityMetadata struct + Description string + State NamedEntityState + func (*NamedEntityMetadata) Descriptor() ([]byte, []int) + func (*NamedEntityMetadata) ProtoMessage() + func (x *NamedEntityMetadata) GetDescription() string + func (x *NamedEntityMetadata) GetState() NamedEntityState + func (x *NamedEntityMetadata) ProtoReflect() protoreflect.Message + func (x *NamedEntityMetadata) Reset() + func (x *NamedEntityMetadata) String() string + type NamedEntityState int32 + const NamedEntityState_NAMED_ENTITY_ACTIVE + const NamedEntityState_NAMED_ENTITY_ARCHIVED + const NamedEntityState_SYSTEM_GENERATED + func (NamedEntityState) Descriptor() protoreflect.EnumDescriptor + func (NamedEntityState) EnumDescriptor() ([]byte, []int) + func (NamedEntityState) Type() protoreflect.EnumType + func (x NamedEntityState) Enum() *NamedEntityState + func (x NamedEntityState) Number() protoreflect.EnumNumber + func (x NamedEntityState) String() string + type NamedEntityUpdateRequest struct + Id *NamedEntityIdentifier + Metadata *NamedEntityMetadata + ResourceType core.ResourceType + func (*NamedEntityUpdateRequest) Descriptor() ([]byte, []int) + func (*NamedEntityUpdateRequest) ProtoMessage() + func (x *NamedEntityUpdateRequest) GetId() *NamedEntityIdentifier + func (x *NamedEntityUpdateRequest) GetMetadata() *NamedEntityMetadata + func (x *NamedEntityUpdateRequest) GetResourceType() core.ResourceType + func (x *NamedEntityUpdateRequest) ProtoReflect() protoreflect.Message + func (x *NamedEntityUpdateRequest) Reset() + func (x *NamedEntityUpdateRequest) String() string + type NamedEntityUpdateResponse struct + func (*NamedEntityUpdateResponse) Descriptor() ([]byte, []int) + func (*NamedEntityUpdateResponse) ProtoMessage() + func (x *NamedEntityUpdateResponse) ProtoReflect() protoreflect.Message + func (x *NamedEntityUpdateResponse) Reset() + func (x *NamedEntityUpdateResponse) String() string + type NodeExecution struct + Closure *NodeExecutionClosure + Id *core.NodeExecutionIdentifier + InputUri string + Metadata *NodeExecutionMetaData + func (*NodeExecution) Descriptor() ([]byte, []int) + func (*NodeExecution) ProtoMessage() + func (x *NodeExecution) GetClosure() *NodeExecutionClosure + func (x *NodeExecution) GetId() *core.NodeExecutionIdentifier + func (x *NodeExecution) GetInputUri() string + func (x *NodeExecution) GetMetadata() *NodeExecutionMetaData + func (x *NodeExecution) ProtoReflect() protoreflect.Message + func (x *NodeExecution) Reset() + func (x *NodeExecution) String() string + type NodeExecutionClosure struct + CreatedAt *timestamppb.Timestamp + DeckUri string + Duration *durationpb.Duration + DynamicJobSpecUri string + OutputResult isNodeExecutionClosure_OutputResult + Phase core.NodeExecution_Phase + StartedAt *timestamppb.Timestamp + TargetMetadata isNodeExecutionClosure_TargetMetadata + UpdatedAt *timestamppb.Timestamp + func (*NodeExecutionClosure) Descriptor() ([]byte, []int) + func (*NodeExecutionClosure) ProtoMessage() + func (m *NodeExecutionClosure) GetOutputResult() isNodeExecutionClosure_OutputResult + func (m *NodeExecutionClosure) GetTargetMetadata() isNodeExecutionClosure_TargetMetadata + func (x *NodeExecutionClosure) GetCreatedAt() *timestamppb.Timestamp + func (x *NodeExecutionClosure) GetDeckUri() string + func (x *NodeExecutionClosure) GetDuration() *durationpb.Duration + func (x *NodeExecutionClosure) GetDynamicJobSpecUri() string + func (x *NodeExecutionClosure) GetError() *core.ExecutionError + func (x *NodeExecutionClosure) GetOutputData() *core.LiteralMap + func (x *NodeExecutionClosure) GetOutputUri() string + func (x *NodeExecutionClosure) GetPhase() core.NodeExecution_Phase + func (x *NodeExecutionClosure) GetStartedAt() *timestamppb.Timestamp + func (x *NodeExecutionClosure) GetTaskNodeMetadata() *TaskNodeMetadata + func (x *NodeExecutionClosure) GetUpdatedAt() *timestamppb.Timestamp + func (x *NodeExecutionClosure) GetWorkflowNodeMetadata() *WorkflowNodeMetadata + func (x *NodeExecutionClosure) ProtoReflect() protoreflect.Message + func (x *NodeExecutionClosure) Reset() + func (x *NodeExecutionClosure) String() string + type NodeExecutionClosure_Error struct + Error *core.ExecutionError + type NodeExecutionClosure_OutputData struct + OutputData *core.LiteralMap + type NodeExecutionClosure_OutputUri struct + OutputUri string + type NodeExecutionClosure_TaskNodeMetadata struct + TaskNodeMetadata *TaskNodeMetadata + type NodeExecutionClosure_WorkflowNodeMetadata struct + WorkflowNodeMetadata *WorkflowNodeMetadata + type NodeExecutionEventRequest struct + Event *event.NodeExecutionEvent + RequestId string + func (*NodeExecutionEventRequest) Descriptor() ([]byte, []int) + func (*NodeExecutionEventRequest) ProtoMessage() + func (x *NodeExecutionEventRequest) GetEvent() *event.NodeExecutionEvent + func (x *NodeExecutionEventRequest) GetRequestId() string + func (x *NodeExecutionEventRequest) ProtoReflect() protoreflect.Message + func (x *NodeExecutionEventRequest) Reset() + func (x *NodeExecutionEventRequest) String() string + type NodeExecutionEventResponse struct + func (*NodeExecutionEventResponse) Descriptor() ([]byte, []int) + func (*NodeExecutionEventResponse) ProtoMessage() + func (x *NodeExecutionEventResponse) ProtoReflect() protoreflect.Message + func (x *NodeExecutionEventResponse) Reset() + func (x *NodeExecutionEventResponse) String() string + type NodeExecutionForTaskListRequest struct + Filters string + Limit uint32 + SortBy *Sort + TaskExecutionId *core.TaskExecutionIdentifier + Token string + func (*NodeExecutionForTaskListRequest) Descriptor() ([]byte, []int) + func (*NodeExecutionForTaskListRequest) ProtoMessage() + func (x *NodeExecutionForTaskListRequest) GetFilters() string + func (x *NodeExecutionForTaskListRequest) GetLimit() uint32 + func (x *NodeExecutionForTaskListRequest) GetSortBy() *Sort + func (x *NodeExecutionForTaskListRequest) GetTaskExecutionId() *core.TaskExecutionIdentifier + func (x *NodeExecutionForTaskListRequest) GetToken() string + func (x *NodeExecutionForTaskListRequest) ProtoReflect() protoreflect.Message + func (x *NodeExecutionForTaskListRequest) Reset() + func (x *NodeExecutionForTaskListRequest) String() string + type NodeExecutionGetDataRequest struct + Id *core.NodeExecutionIdentifier + func (*NodeExecutionGetDataRequest) Descriptor() ([]byte, []int) + func (*NodeExecutionGetDataRequest) ProtoMessage() + func (x *NodeExecutionGetDataRequest) GetId() *core.NodeExecutionIdentifier + func (x *NodeExecutionGetDataRequest) ProtoReflect() protoreflect.Message + func (x *NodeExecutionGetDataRequest) Reset() + func (x *NodeExecutionGetDataRequest) String() string + type NodeExecutionGetDataResponse struct + DynamicWorkflow *DynamicWorkflowNodeMetadata + FullInputs *core.LiteralMap + FullOutputs *core.LiteralMap + Inputs *UrlBlob + KozmoUrls *KozmoURLs + Outputs *UrlBlob + func (*NodeExecutionGetDataResponse) Descriptor() ([]byte, []int) + func (*NodeExecutionGetDataResponse) ProtoMessage() + func (x *NodeExecutionGetDataResponse) GetDynamicWorkflow() *DynamicWorkflowNodeMetadata + func (x *NodeExecutionGetDataResponse) GetFullInputs() *core.LiteralMap + func (x *NodeExecutionGetDataResponse) GetFullOutputs() *core.LiteralMap + func (x *NodeExecutionGetDataResponse) GetInputs() *UrlBlob + func (x *NodeExecutionGetDataResponse) GetKozmoUrls() *KozmoURLs + func (x *NodeExecutionGetDataResponse) GetOutputs() *UrlBlob + func (x *NodeExecutionGetDataResponse) ProtoReflect() protoreflect.Message + func (x *NodeExecutionGetDataResponse) Reset() + func (x *NodeExecutionGetDataResponse) String() string + type NodeExecutionGetRequest struct + Id *core.NodeExecutionIdentifier + func (*NodeExecutionGetRequest) Descriptor() ([]byte, []int) + func (*NodeExecutionGetRequest) ProtoMessage() + func (x *NodeExecutionGetRequest) GetId() *core.NodeExecutionIdentifier + func (x *NodeExecutionGetRequest) ProtoReflect() protoreflect.Message + func (x *NodeExecutionGetRequest) Reset() + func (x *NodeExecutionGetRequest) String() string + type NodeExecutionList struct + NodeExecutions []*NodeExecution + Token string + func (*NodeExecutionList) Descriptor() ([]byte, []int) + func (*NodeExecutionList) ProtoMessage() + func (x *NodeExecutionList) GetNodeExecutions() []*NodeExecution + func (x *NodeExecutionList) GetToken() string + func (x *NodeExecutionList) ProtoReflect() protoreflect.Message + func (x *NodeExecutionList) Reset() + func (x *NodeExecutionList) String() string + type NodeExecutionListRequest struct + Filters string + Limit uint32 + SortBy *Sort + Token string + UniqueParentId string + WorkflowExecutionId *core.WorkflowExecutionIdentifier + func (*NodeExecutionListRequest) Descriptor() ([]byte, []int) + func (*NodeExecutionListRequest) ProtoMessage() + func (x *NodeExecutionListRequest) GetFilters() string + func (x *NodeExecutionListRequest) GetLimit() uint32 + func (x *NodeExecutionListRequest) GetSortBy() *Sort + func (x *NodeExecutionListRequest) GetToken() string + func (x *NodeExecutionListRequest) GetUniqueParentId() string + func (x *NodeExecutionListRequest) GetWorkflowExecutionId() *core.WorkflowExecutionIdentifier + func (x *NodeExecutionListRequest) ProtoReflect() protoreflect.Message + func (x *NodeExecutionListRequest) Reset() + func (x *NodeExecutionListRequest) String() string + type NodeExecutionMetaData struct + IsArray bool + IsDynamic bool + IsParentNode bool + RetryGroup string + SpecNodeId string + func (*NodeExecutionMetaData) Descriptor() ([]byte, []int) + func (*NodeExecutionMetaData) ProtoMessage() + func (x *NodeExecutionMetaData) GetIsArray() bool + func (x *NodeExecutionMetaData) GetIsDynamic() bool + func (x *NodeExecutionMetaData) GetIsParentNode() bool + func (x *NodeExecutionMetaData) GetRetryGroup() string + func (x *NodeExecutionMetaData) GetSpecNodeId() string + func (x *NodeExecutionMetaData) ProtoReflect() protoreflect.Message + func (x *NodeExecutionMetaData) Reset() + func (x *NodeExecutionMetaData) String() string + type Notification struct + Phases []core.WorkflowExecution_Phase + Type isNotification_Type + func (*Notification) Descriptor() ([]byte, []int) + func (*Notification) ProtoMessage() + func (m *Notification) GetType() isNotification_Type + func (x *Notification) GetEmail() *EmailNotification + func (x *Notification) GetPagerDuty() *PagerDutyNotification + func (x *Notification) GetPhases() []core.WorkflowExecution_Phase + func (x *Notification) GetSlack() *SlackNotification + func (x *Notification) ProtoReflect() protoreflect.Message + func (x *Notification) Reset() + func (x *Notification) String() string + type NotificationList struct + Notifications []*Notification + func (*NotificationList) Descriptor() ([]byte, []int) + func (*NotificationList) ProtoMessage() + func (x *NotificationList) GetNotifications() []*Notification + func (x *NotificationList) ProtoReflect() protoreflect.Message + func (x *NotificationList) Reset() + func (x *NotificationList) String() string + type Notification_Email struct + Email *EmailNotification + type Notification_PagerDuty struct + PagerDuty *PagerDutyNotification + type Notification_Slack struct + Slack *SlackNotification + type ObjectGetRequest struct + Id *core.Identifier + func (*ObjectGetRequest) Descriptor() ([]byte, []int) + func (*ObjectGetRequest) ProtoMessage() + func (x *ObjectGetRequest) GetId() *core.Identifier + func (x *ObjectGetRequest) ProtoReflect() protoreflect.Message + func (x *ObjectGetRequest) Reset() + func (x *ObjectGetRequest) String() string + type PagerDutyNotification struct + RecipientsEmail []string + func (*PagerDutyNotification) Descriptor() ([]byte, []int) + func (*PagerDutyNotification) ProtoMessage() + func (x *PagerDutyNotification) GetRecipientsEmail() []string + func (x *PagerDutyNotification) ProtoReflect() protoreflect.Message + func (x *PagerDutyNotification) Reset() + func (x *PagerDutyNotification) String() string + type PluginOverride struct + MissingPluginBehavior PluginOverride_MissingPluginBehavior + PluginId []string + TaskType string + func (*PluginOverride) Descriptor() ([]byte, []int) + func (*PluginOverride) ProtoMessage() + func (x *PluginOverride) GetMissingPluginBehavior() PluginOverride_MissingPluginBehavior + func (x *PluginOverride) GetPluginId() []string + func (x *PluginOverride) GetTaskType() string + func (x *PluginOverride) ProtoReflect() protoreflect.Message + func (x *PluginOverride) Reset() + func (x *PluginOverride) String() string + type PluginOverride_MissingPluginBehavior int32 + const PluginOverride_FAIL + const PluginOverride_USE_DEFAULT + func (PluginOverride_MissingPluginBehavior) Descriptor() protoreflect.EnumDescriptor + func (PluginOverride_MissingPluginBehavior) EnumDescriptor() ([]byte, []int) + func (PluginOverride_MissingPluginBehavior) Type() protoreflect.EnumType + func (x PluginOverride_MissingPluginBehavior) Enum() *PluginOverride_MissingPluginBehavior + func (x PluginOverride_MissingPluginBehavior) Number() protoreflect.EnumNumber + func (x PluginOverride_MissingPluginBehavior) String() string + type PluginOverrides struct + Overrides []*PluginOverride + func (*PluginOverrides) Descriptor() ([]byte, []int) + func (*PluginOverrides) ProtoMessage() + func (x *PluginOverrides) GetOverrides() []*PluginOverride + func (x *PluginOverrides) ProtoReflect() protoreflect.Message + func (x *PluginOverrides) Reset() + func (x *PluginOverrides) String() string + type Project struct + Description string + Domains []*Domain + Id string + Labels *Labels + Name string + Org string + State Project_ProjectState + func (*Project) Descriptor() ([]byte, []int) + func (*Project) ProtoMessage() + func (x *Project) GetDescription() string + func (x *Project) GetDomains() []*Domain + func (x *Project) GetId() string + func (x *Project) GetLabels() *Labels + func (x *Project) GetName() string + func (x *Project) GetOrg() string + func (x *Project) GetState() Project_ProjectState + func (x *Project) ProtoReflect() protoreflect.Message + func (x *Project) Reset() + func (x *Project) String() string + type ProjectAttributes struct + MatchingAttributes *MatchingAttributes + Org string + Project string + func (*ProjectAttributes) Descriptor() ([]byte, []int) + func (*ProjectAttributes) ProtoMessage() + func (x *ProjectAttributes) GetMatchingAttributes() *MatchingAttributes + func (x *ProjectAttributes) GetOrg() string + func (x *ProjectAttributes) GetProject() string + func (x *ProjectAttributes) ProtoReflect() protoreflect.Message + func (x *ProjectAttributes) Reset() + func (x *ProjectAttributes) String() string + type ProjectAttributesDeleteRequest struct + Org string + Project string + ResourceType MatchableResource + func (*ProjectAttributesDeleteRequest) Descriptor() ([]byte, []int) + func (*ProjectAttributesDeleteRequest) ProtoMessage() + func (x *ProjectAttributesDeleteRequest) GetOrg() string + func (x *ProjectAttributesDeleteRequest) GetProject() string + func (x *ProjectAttributesDeleteRequest) GetResourceType() MatchableResource + func (x *ProjectAttributesDeleteRequest) ProtoReflect() protoreflect.Message + func (x *ProjectAttributesDeleteRequest) Reset() + func (x *ProjectAttributesDeleteRequest) String() string + type ProjectAttributesDeleteResponse struct + func (*ProjectAttributesDeleteResponse) Descriptor() ([]byte, []int) + func (*ProjectAttributesDeleteResponse) ProtoMessage() + func (x *ProjectAttributesDeleteResponse) ProtoReflect() protoreflect.Message + func (x *ProjectAttributesDeleteResponse) Reset() + func (x *ProjectAttributesDeleteResponse) String() string + type ProjectAttributesGetRequest struct + Org string + Project string + ResourceType MatchableResource + func (*ProjectAttributesGetRequest) Descriptor() ([]byte, []int) + func (*ProjectAttributesGetRequest) ProtoMessage() + func (x *ProjectAttributesGetRequest) GetOrg() string + func (x *ProjectAttributesGetRequest) GetProject() string + func (x *ProjectAttributesGetRequest) GetResourceType() MatchableResource + func (x *ProjectAttributesGetRequest) ProtoReflect() protoreflect.Message + func (x *ProjectAttributesGetRequest) Reset() + func (x *ProjectAttributesGetRequest) String() string + type ProjectAttributesGetResponse struct + Attributes *ProjectAttributes + func (*ProjectAttributesGetResponse) Descriptor() ([]byte, []int) + func (*ProjectAttributesGetResponse) ProtoMessage() + func (x *ProjectAttributesGetResponse) GetAttributes() *ProjectAttributes + func (x *ProjectAttributesGetResponse) ProtoReflect() protoreflect.Message + func (x *ProjectAttributesGetResponse) Reset() + func (x *ProjectAttributesGetResponse) String() string + type ProjectAttributesUpdateRequest struct + Attributes *ProjectAttributes + func (*ProjectAttributesUpdateRequest) Descriptor() ([]byte, []int) + func (*ProjectAttributesUpdateRequest) ProtoMessage() + func (x *ProjectAttributesUpdateRequest) GetAttributes() *ProjectAttributes + func (x *ProjectAttributesUpdateRequest) ProtoReflect() protoreflect.Message + func (x *ProjectAttributesUpdateRequest) Reset() + func (x *ProjectAttributesUpdateRequest) String() string + type ProjectAttributesUpdateResponse struct + func (*ProjectAttributesUpdateResponse) Descriptor() ([]byte, []int) + func (*ProjectAttributesUpdateResponse) ProtoMessage() + func (x *ProjectAttributesUpdateResponse) ProtoReflect() protoreflect.Message + func (x *ProjectAttributesUpdateResponse) Reset() + func (x *ProjectAttributesUpdateResponse) String() string + type ProjectDomainAttributes struct + Domain string + MatchingAttributes *MatchingAttributes + Org string + Project string + func (*ProjectDomainAttributes) Descriptor() ([]byte, []int) + func (*ProjectDomainAttributes) ProtoMessage() + func (x *ProjectDomainAttributes) GetDomain() string + func (x *ProjectDomainAttributes) GetMatchingAttributes() *MatchingAttributes + func (x *ProjectDomainAttributes) GetOrg() string + func (x *ProjectDomainAttributes) GetProject() string + func (x *ProjectDomainAttributes) ProtoReflect() protoreflect.Message + func (x *ProjectDomainAttributes) Reset() + func (x *ProjectDomainAttributes) String() string + type ProjectDomainAttributesDeleteRequest struct + Domain string + Org string + Project string + ResourceType MatchableResource + func (*ProjectDomainAttributesDeleteRequest) Descriptor() ([]byte, []int) + func (*ProjectDomainAttributesDeleteRequest) ProtoMessage() + func (x *ProjectDomainAttributesDeleteRequest) GetDomain() string + func (x *ProjectDomainAttributesDeleteRequest) GetOrg() string + func (x *ProjectDomainAttributesDeleteRequest) GetProject() string + func (x *ProjectDomainAttributesDeleteRequest) GetResourceType() MatchableResource + func (x *ProjectDomainAttributesDeleteRequest) ProtoReflect() protoreflect.Message + func (x *ProjectDomainAttributesDeleteRequest) Reset() + func (x *ProjectDomainAttributesDeleteRequest) String() string + type ProjectDomainAttributesDeleteResponse struct + func (*ProjectDomainAttributesDeleteResponse) Descriptor() ([]byte, []int) + func (*ProjectDomainAttributesDeleteResponse) ProtoMessage() + func (x *ProjectDomainAttributesDeleteResponse) ProtoReflect() protoreflect.Message + func (x *ProjectDomainAttributesDeleteResponse) Reset() + func (x *ProjectDomainAttributesDeleteResponse) String() string + type ProjectDomainAttributesGetRequest struct + Domain string + Org string + Project string + ResourceType MatchableResource + func (*ProjectDomainAttributesGetRequest) Descriptor() ([]byte, []int) + func (*ProjectDomainAttributesGetRequest) ProtoMessage() + func (x *ProjectDomainAttributesGetRequest) GetDomain() string + func (x *ProjectDomainAttributesGetRequest) GetOrg() string + func (x *ProjectDomainAttributesGetRequest) GetProject() string + func (x *ProjectDomainAttributesGetRequest) GetResourceType() MatchableResource + func (x *ProjectDomainAttributesGetRequest) ProtoReflect() protoreflect.Message + func (x *ProjectDomainAttributesGetRequest) Reset() + func (x *ProjectDomainAttributesGetRequest) String() string + type ProjectDomainAttributesGetResponse struct + Attributes *ProjectDomainAttributes + func (*ProjectDomainAttributesGetResponse) Descriptor() ([]byte, []int) + func (*ProjectDomainAttributesGetResponse) ProtoMessage() + func (x *ProjectDomainAttributesGetResponse) GetAttributes() *ProjectDomainAttributes + func (x *ProjectDomainAttributesGetResponse) ProtoReflect() protoreflect.Message + func (x *ProjectDomainAttributesGetResponse) Reset() + func (x *ProjectDomainAttributesGetResponse) String() string + type ProjectDomainAttributesUpdateRequest struct + Attributes *ProjectDomainAttributes + func (*ProjectDomainAttributesUpdateRequest) Descriptor() ([]byte, []int) + func (*ProjectDomainAttributesUpdateRequest) ProtoMessage() + func (x *ProjectDomainAttributesUpdateRequest) GetAttributes() *ProjectDomainAttributes + func (x *ProjectDomainAttributesUpdateRequest) ProtoReflect() protoreflect.Message + func (x *ProjectDomainAttributesUpdateRequest) Reset() + func (x *ProjectDomainAttributesUpdateRequest) String() string + type ProjectDomainAttributesUpdateResponse struct + func (*ProjectDomainAttributesUpdateResponse) Descriptor() ([]byte, []int) + func (*ProjectDomainAttributesUpdateResponse) ProtoMessage() + func (x *ProjectDomainAttributesUpdateResponse) ProtoReflect() protoreflect.Message + func (x *ProjectDomainAttributesUpdateResponse) Reset() + func (x *ProjectDomainAttributesUpdateResponse) String() string + type ProjectListRequest struct + Filters string + Limit uint32 + Org string + SortBy *Sort + Token string + func (*ProjectListRequest) Descriptor() ([]byte, []int) + func (*ProjectListRequest) ProtoMessage() + func (x *ProjectListRequest) GetFilters() string + func (x *ProjectListRequest) GetLimit() uint32 + func (x *ProjectListRequest) GetOrg() string + func (x *ProjectListRequest) GetSortBy() *Sort + func (x *ProjectListRequest) GetToken() string + func (x *ProjectListRequest) ProtoReflect() protoreflect.Message + func (x *ProjectListRequest) Reset() + func (x *ProjectListRequest) String() string + type ProjectRegisterRequest struct + Project *Project + func (*ProjectRegisterRequest) Descriptor() ([]byte, []int) + func (*ProjectRegisterRequest) ProtoMessage() + func (x *ProjectRegisterRequest) GetProject() *Project + func (x *ProjectRegisterRequest) ProtoReflect() protoreflect.Message + func (x *ProjectRegisterRequest) Reset() + func (x *ProjectRegisterRequest) String() string + type ProjectRegisterResponse struct + func (*ProjectRegisterResponse) Descriptor() ([]byte, []int) + func (*ProjectRegisterResponse) ProtoMessage() + func (x *ProjectRegisterResponse) ProtoReflect() protoreflect.Message + func (x *ProjectRegisterResponse) Reset() + func (x *ProjectRegisterResponse) String() string + type ProjectUpdateResponse struct + func (*ProjectUpdateResponse) Descriptor() ([]byte, []int) + func (*ProjectUpdateResponse) ProtoMessage() + func (x *ProjectUpdateResponse) ProtoReflect() protoreflect.Message + func (x *ProjectUpdateResponse) Reset() + func (x *ProjectUpdateResponse) String() string + type Project_ProjectState int32 + const Project_ACTIVE + const Project_ARCHIVED + const Project_SYSTEM_GENERATED + func (Project_ProjectState) Descriptor() protoreflect.EnumDescriptor + func (Project_ProjectState) EnumDescriptor() ([]byte, []int) + func (Project_ProjectState) Type() protoreflect.EnumType + func (x Project_ProjectState) Enum() *Project_ProjectState + func (x Project_ProjectState) Number() protoreflect.EnumNumber + func (x Project_ProjectState) String() string + type Projects struct + Projects []*Project + Token string + func (*Projects) Descriptor() ([]byte, []int) + func (*Projects) ProtoMessage() + func (x *Projects) GetProjects() []*Project + func (x *Projects) GetToken() string + func (x *Projects) ProtoReflect() protoreflect.Message + func (x *Projects) Reset() + func (x *Projects) String() string + type RawOutputDataConfig struct + OutputLocationPrefix string + func (*RawOutputDataConfig) Descriptor() ([]byte, []int) + func (*RawOutputDataConfig) ProtoMessage() + func (x *RawOutputDataConfig) GetOutputLocationPrefix() string + func (x *RawOutputDataConfig) ProtoReflect() protoreflect.Message + func (x *RawOutputDataConfig) Reset() + func (x *RawOutputDataConfig) String() string + type Reason struct + Message string + OccurredAt *timestamppb.Timestamp + func (*Reason) Descriptor() ([]byte, []int) + func (*Reason) ProtoMessage() + func (x *Reason) GetMessage() string + func (x *Reason) GetOccurredAt() *timestamppb.Timestamp + func (x *Reason) ProtoReflect() protoreflect.Message + func (x *Reason) Reset() + func (x *Reason) String() string + type Resource struct + LogLinks []*core.TaskLog + Message string + Outputs *core.LiteralMap + Phase core.TaskExecution_Phase + State State + func (*Resource) Descriptor() ([]byte, []int) + func (*Resource) ProtoMessage() + func (x *Resource) GetLogLinks() []*core.TaskLog + func (x *Resource) GetMessage() string + func (x *Resource) GetOutputs() *core.LiteralMap + func (x *Resource) GetPhase() core.TaskExecution_Phase + func (x *Resource) GetState() State + func (x *Resource) ProtoReflect() protoreflect.Message + func (x *Resource) Reset() + func (x *Resource) String() string + type ResourceListRequest struct + Filters string + Id *NamedEntityIdentifier + Limit uint32 + SortBy *Sort + Token string + func (*ResourceListRequest) Descriptor() ([]byte, []int) + func (*ResourceListRequest) ProtoMessage() + func (x *ResourceListRequest) GetFilters() string + func (x *ResourceListRequest) GetId() *NamedEntityIdentifier + func (x *ResourceListRequest) GetLimit() uint32 + func (x *ResourceListRequest) GetSortBy() *Sort + func (x *ResourceListRequest) GetToken() string + func (x *ResourceListRequest) ProtoReflect() protoreflect.Message + func (x *ResourceListRequest) Reset() + func (x *ResourceListRequest) String() string + type Schedule struct + KickoffTimeInputArg string + ScheduleExpression isSchedule_ScheduleExpression + func (*Schedule) Descriptor() ([]byte, []int) + func (*Schedule) ProtoMessage() + func (m *Schedule) GetScheduleExpression() isSchedule_ScheduleExpression + func (x *Schedule) GetCronExpression() string + func (x *Schedule) GetCronSchedule() *CronSchedule + func (x *Schedule) GetKickoffTimeInputArg() string + func (x *Schedule) GetRate() *FixedRate + func (x *Schedule) ProtoReflect() protoreflect.Message + func (x *Schedule) Reset() + func (x *Schedule) String() string + type Schedule_CronExpression struct + CronExpression string + type Schedule_CronSchedule struct + CronSchedule *CronSchedule + type Schedule_Rate struct + Rate *FixedRate + type Signal struct + Id *core.SignalIdentifier + Type *core.LiteralType + Value *core.Literal + func (*Signal) Descriptor() ([]byte, []int) + func (*Signal) ProtoMessage() + func (x *Signal) GetId() *core.SignalIdentifier + func (x *Signal) GetType() *core.LiteralType + func (x *Signal) GetValue() *core.Literal + func (x *Signal) ProtoReflect() protoreflect.Message + func (x *Signal) Reset() + func (x *Signal) String() string + type SignalGetOrCreateRequest struct + Id *core.SignalIdentifier + Type *core.LiteralType + func (*SignalGetOrCreateRequest) Descriptor() ([]byte, []int) + func (*SignalGetOrCreateRequest) ProtoMessage() + func (x *SignalGetOrCreateRequest) GetId() *core.SignalIdentifier + func (x *SignalGetOrCreateRequest) GetType() *core.LiteralType + func (x *SignalGetOrCreateRequest) ProtoReflect() protoreflect.Message + func (x *SignalGetOrCreateRequest) Reset() + func (x *SignalGetOrCreateRequest) String() string + type SignalList struct + Signals []*Signal + Token string + func (*SignalList) Descriptor() ([]byte, []int) + func (*SignalList) ProtoMessage() + func (x *SignalList) GetSignals() []*Signal + func (x *SignalList) GetToken() string + func (x *SignalList) ProtoReflect() protoreflect.Message + func (x *SignalList) Reset() + func (x *SignalList) String() string + type SignalListRequest struct + Filters string + Limit uint32 + SortBy *Sort + Token string + WorkflowExecutionId *core.WorkflowExecutionIdentifier + func (*SignalListRequest) Descriptor() ([]byte, []int) + func (*SignalListRequest) ProtoMessage() + func (x *SignalListRequest) GetFilters() string + func (x *SignalListRequest) GetLimit() uint32 + func (x *SignalListRequest) GetSortBy() *Sort + func (x *SignalListRequest) GetToken() string + func (x *SignalListRequest) GetWorkflowExecutionId() *core.WorkflowExecutionIdentifier + func (x *SignalListRequest) ProtoReflect() protoreflect.Message + func (x *SignalListRequest) Reset() + func (x *SignalListRequest) String() string + type SignalSetRequest struct + Id *core.SignalIdentifier + Value *core.Literal + func (*SignalSetRequest) Descriptor() ([]byte, []int) + func (*SignalSetRequest) ProtoMessage() + func (x *SignalSetRequest) GetId() *core.SignalIdentifier + func (x *SignalSetRequest) GetValue() *core.Literal + func (x *SignalSetRequest) ProtoReflect() protoreflect.Message + func (x *SignalSetRequest) Reset() + func (x *SignalSetRequest) String() string + type SignalSetResponse struct + func (*SignalSetResponse) Descriptor() ([]byte, []int) + func (*SignalSetResponse) ProtoMessage() + func (x *SignalSetResponse) ProtoReflect() protoreflect.Message + func (x *SignalSetResponse) Reset() + func (x *SignalSetResponse) String() string + type SlackNotification struct + RecipientsEmail []string + func (*SlackNotification) Descriptor() ([]byte, []int) + func (*SlackNotification) ProtoMessage() + func (x *SlackNotification) GetRecipientsEmail() []string + func (x *SlackNotification) ProtoReflect() protoreflect.Message + func (x *SlackNotification) Reset() + func (x *SlackNotification) String() string + type Sort struct + Direction Sort_Direction + Key string + func (*Sort) Descriptor() ([]byte, []int) + func (*Sort) ProtoMessage() + func (x *Sort) GetDirection() Sort_Direction + func (x *Sort) GetKey() string + func (x *Sort) ProtoReflect() protoreflect.Message + func (x *Sort) Reset() + func (x *Sort) String() string + type Sort_Direction int32 + const Sort_ASCENDING + const Sort_DESCENDING + func (Sort_Direction) Descriptor() protoreflect.EnumDescriptor + func (Sort_Direction) EnumDescriptor() ([]byte, []int) + func (Sort_Direction) Type() protoreflect.EnumType + func (x Sort_Direction) Enum() *Sort_Direction + func (x Sort_Direction) Number() protoreflect.EnumNumber + func (x Sort_Direction) String() string + type SourceCode struct + Link string + func (*SourceCode) Descriptor() ([]byte, []int) + func (*SourceCode) ProtoMessage() + func (x *SourceCode) GetLink() string + func (x *SourceCode) ProtoReflect() protoreflect.Message + func (x *SourceCode) Reset() + func (x *SourceCode) String() string + type State int32 + const State_PENDING + const State_PERMANENT_FAILURE + const State_RETRYABLE_FAILURE + const State_RUNNING + const State_SUCCEEDED + func (State) Descriptor() protoreflect.EnumDescriptor + func (State) EnumDescriptor() ([]byte, []int) + func (State) Type() protoreflect.EnumType + func (x State) Enum() *State + func (x State) Number() protoreflect.EnumNumber + func (x State) String() string + type SystemMetadata struct + ExecutionCluster string + Namespace string + func (*SystemMetadata) Descriptor() ([]byte, []int) + func (*SystemMetadata) ProtoMessage() + func (x *SystemMetadata) GetExecutionCluster() string + func (x *SystemMetadata) GetNamespace() string + func (x *SystemMetadata) ProtoReflect() protoreflect.Message + func (x *SystemMetadata) Reset() + func (x *SystemMetadata) String() string + type Task struct + Closure *TaskClosure + Id *core.Identifier + ShortDescription string + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (x *Task) GetClosure() *TaskClosure + func (x *Task) GetId() *core.Identifier + func (x *Task) GetShortDescription() string + func (x *Task) ProtoReflect() protoreflect.Message + func (x *Task) Reset() + func (x *Task) String() string + type TaskClosure struct + CompiledTask *core.CompiledTask + CreatedAt *timestamppb.Timestamp + func (*TaskClosure) Descriptor() ([]byte, []int) + func (*TaskClosure) ProtoMessage() + func (x *TaskClosure) GetCompiledTask() *core.CompiledTask + func (x *TaskClosure) GetCreatedAt() *timestamppb.Timestamp + func (x *TaskClosure) ProtoReflect() protoreflect.Message + func (x *TaskClosure) Reset() + func (x *TaskClosure) String() string + type TaskCreateRequest struct + Id *core.Identifier + Spec *TaskSpec + func (*TaskCreateRequest) Descriptor() ([]byte, []int) + func (*TaskCreateRequest) ProtoMessage() + func (x *TaskCreateRequest) GetId() *core.Identifier + func (x *TaskCreateRequest) GetSpec() *TaskSpec + func (x *TaskCreateRequest) ProtoReflect() protoreflect.Message + func (x *TaskCreateRequest) Reset() + func (x *TaskCreateRequest) String() string + type TaskCreateResponse struct + func (*TaskCreateResponse) Descriptor() ([]byte, []int) + func (*TaskCreateResponse) ProtoMessage() + func (x *TaskCreateResponse) ProtoReflect() protoreflect.Message + func (x *TaskCreateResponse) Reset() + func (x *TaskCreateResponse) String() string + type TaskExecution struct + Closure *TaskExecutionClosure + Id *core.TaskExecutionIdentifier + InputUri string + IsParent bool + func (*TaskExecution) Descriptor() ([]byte, []int) + func (*TaskExecution) ProtoMessage() + func (x *TaskExecution) GetClosure() *TaskExecutionClosure + func (x *TaskExecution) GetId() *core.TaskExecutionIdentifier + func (x *TaskExecution) GetInputUri() string + func (x *TaskExecution) GetIsParent() bool + func (x *TaskExecution) ProtoReflect() protoreflect.Message + func (x *TaskExecution) Reset() + func (x *TaskExecution) String() string + type TaskExecutionClosure struct + CreatedAt *timestamppb.Timestamp + CustomInfo *structpb.Struct + Duration *durationpb.Duration + EventVersion int32 + Logs []*core.TaskLog + Metadata *event.TaskExecutionMetadata + OutputResult isTaskExecutionClosure_OutputResult + Phase core.TaskExecution_Phase + Reason string + Reasons []*Reason + StartedAt *timestamppb.Timestamp + TaskType string + UpdatedAt *timestamppb.Timestamp + func (*TaskExecutionClosure) Descriptor() ([]byte, []int) + func (*TaskExecutionClosure) ProtoMessage() + func (m *TaskExecutionClosure) GetOutputResult() isTaskExecutionClosure_OutputResult + func (x *TaskExecutionClosure) GetCreatedAt() *timestamppb.Timestamp + func (x *TaskExecutionClosure) GetCustomInfo() *structpb.Struct + func (x *TaskExecutionClosure) GetDuration() *durationpb.Duration + func (x *TaskExecutionClosure) GetError() *core.ExecutionError + func (x *TaskExecutionClosure) GetEventVersion() int32 + func (x *TaskExecutionClosure) GetLogs() []*core.TaskLog + func (x *TaskExecutionClosure) GetMetadata() *event.TaskExecutionMetadata + func (x *TaskExecutionClosure) GetOutputData() *core.LiteralMap + func (x *TaskExecutionClosure) GetOutputUri() string + func (x *TaskExecutionClosure) GetPhase() core.TaskExecution_Phase + func (x *TaskExecutionClosure) GetReason() string + func (x *TaskExecutionClosure) GetReasons() []*Reason + func (x *TaskExecutionClosure) GetStartedAt() *timestamppb.Timestamp + func (x *TaskExecutionClosure) GetTaskType() string + func (x *TaskExecutionClosure) GetUpdatedAt() *timestamppb.Timestamp + func (x *TaskExecutionClosure) ProtoReflect() protoreflect.Message + func (x *TaskExecutionClosure) Reset() + func (x *TaskExecutionClosure) String() string + type TaskExecutionClosure_Error struct + Error *core.ExecutionError + type TaskExecutionClosure_OutputData struct + OutputData *core.LiteralMap + type TaskExecutionClosure_OutputUri struct + OutputUri string + type TaskExecutionEventRequest struct + Event *event.TaskExecutionEvent + RequestId string + func (*TaskExecutionEventRequest) Descriptor() ([]byte, []int) + func (*TaskExecutionEventRequest) ProtoMessage() + func (x *TaskExecutionEventRequest) GetEvent() *event.TaskExecutionEvent + func (x *TaskExecutionEventRequest) GetRequestId() string + func (x *TaskExecutionEventRequest) ProtoReflect() protoreflect.Message + func (x *TaskExecutionEventRequest) Reset() + func (x *TaskExecutionEventRequest) String() string + type TaskExecutionEventResponse struct + func (*TaskExecutionEventResponse) Descriptor() ([]byte, []int) + func (*TaskExecutionEventResponse) ProtoMessage() + func (x *TaskExecutionEventResponse) ProtoReflect() protoreflect.Message + func (x *TaskExecutionEventResponse) Reset() + func (x *TaskExecutionEventResponse) String() string + type TaskExecutionGetDataRequest struct + Id *core.TaskExecutionIdentifier + func (*TaskExecutionGetDataRequest) Descriptor() ([]byte, []int) + func (*TaskExecutionGetDataRequest) ProtoMessage() + func (x *TaskExecutionGetDataRequest) GetId() *core.TaskExecutionIdentifier + func (x *TaskExecutionGetDataRequest) ProtoReflect() protoreflect.Message + func (x *TaskExecutionGetDataRequest) Reset() + func (x *TaskExecutionGetDataRequest) String() string + type TaskExecutionGetDataResponse struct + FullInputs *core.LiteralMap + FullOutputs *core.LiteralMap + Inputs *UrlBlob + KozmoUrls *KozmoURLs + Outputs *UrlBlob + func (*TaskExecutionGetDataResponse) Descriptor() ([]byte, []int) + func (*TaskExecutionGetDataResponse) ProtoMessage() + func (x *TaskExecutionGetDataResponse) GetFullInputs() *core.LiteralMap + func (x *TaskExecutionGetDataResponse) GetFullOutputs() *core.LiteralMap + func (x *TaskExecutionGetDataResponse) GetInputs() *UrlBlob + func (x *TaskExecutionGetDataResponse) GetKozmoUrls() *KozmoURLs + func (x *TaskExecutionGetDataResponse) GetOutputs() *UrlBlob + func (x *TaskExecutionGetDataResponse) ProtoReflect() protoreflect.Message + func (x *TaskExecutionGetDataResponse) Reset() + func (x *TaskExecutionGetDataResponse) String() string + type TaskExecutionGetRequest struct + Id *core.TaskExecutionIdentifier + func (*TaskExecutionGetRequest) Descriptor() ([]byte, []int) + func (*TaskExecutionGetRequest) ProtoMessage() + func (x *TaskExecutionGetRequest) GetId() *core.TaskExecutionIdentifier + func (x *TaskExecutionGetRequest) ProtoReflect() protoreflect.Message + func (x *TaskExecutionGetRequest) Reset() + func (x *TaskExecutionGetRequest) String() string + type TaskExecutionList struct + TaskExecutions []*TaskExecution + Token string + func (*TaskExecutionList) Descriptor() ([]byte, []int) + func (*TaskExecutionList) ProtoMessage() + func (x *TaskExecutionList) GetTaskExecutions() []*TaskExecution + func (x *TaskExecutionList) GetToken() string + func (x *TaskExecutionList) ProtoReflect() protoreflect.Message + func (x *TaskExecutionList) Reset() + func (x *TaskExecutionList) String() string + type TaskExecutionListRequest struct + Filters string + Limit uint32 + NodeExecutionId *core.NodeExecutionIdentifier + SortBy *Sort + Token string + func (*TaskExecutionListRequest) Descriptor() ([]byte, []int) + func (*TaskExecutionListRequest) ProtoMessage() + func (x *TaskExecutionListRequest) GetFilters() string + func (x *TaskExecutionListRequest) GetLimit() uint32 + func (x *TaskExecutionListRequest) GetNodeExecutionId() *core.NodeExecutionIdentifier + func (x *TaskExecutionListRequest) GetSortBy() *Sort + func (x *TaskExecutionListRequest) GetToken() string + func (x *TaskExecutionListRequest) ProtoReflect() protoreflect.Message + func (x *TaskExecutionListRequest) Reset() + func (x *TaskExecutionListRequest) String() string + type TaskExecutionMetadata struct + Annotations map[string]string + EnvironmentVariables map[string]string + K8SServiceAccount string + Labels map[string]string + Namespace string + TaskExecutionId *core.TaskExecutionIdentifier + func (*TaskExecutionMetadata) Descriptor() ([]byte, []int) + func (*TaskExecutionMetadata) ProtoMessage() + func (x *TaskExecutionMetadata) GetAnnotations() map[string]string + func (x *TaskExecutionMetadata) GetEnvironmentVariables() map[string]string + func (x *TaskExecutionMetadata) GetK8SServiceAccount() string + func (x *TaskExecutionMetadata) GetLabels() map[string]string + func (x *TaskExecutionMetadata) GetNamespace() string + func (x *TaskExecutionMetadata) GetTaskExecutionId() *core.TaskExecutionIdentifier + func (x *TaskExecutionMetadata) ProtoReflect() protoreflect.Message + func (x *TaskExecutionMetadata) Reset() + func (x *TaskExecutionMetadata) String() string + type TaskList struct + Tasks []*Task + Token string + func (*TaskList) Descriptor() ([]byte, []int) + func (*TaskList) ProtoMessage() + func (x *TaskList) GetTasks() []*Task + func (x *TaskList) GetToken() string + func (x *TaskList) ProtoReflect() protoreflect.Message + func (x *TaskList) Reset() + func (x *TaskList) String() string + type TaskNodeMetadata struct + CacheStatus core.CatalogCacheStatus + CatalogKey *core.CatalogMetadata + CheckpointUri string + func (*TaskNodeMetadata) Descriptor() ([]byte, []int) + func (*TaskNodeMetadata) ProtoMessage() + func (x *TaskNodeMetadata) GetCacheStatus() core.CatalogCacheStatus + func (x *TaskNodeMetadata) GetCatalogKey() *core.CatalogMetadata + func (x *TaskNodeMetadata) GetCheckpointUri() string + func (x *TaskNodeMetadata) ProtoReflect() protoreflect.Message + func (x *TaskNodeMetadata) Reset() + func (x *TaskNodeMetadata) String() string + type TaskResourceAttributes struct + Defaults *TaskResourceSpec + Limits *TaskResourceSpec + func (*TaskResourceAttributes) Descriptor() ([]byte, []int) + func (*TaskResourceAttributes) ProtoMessage() + func (x *TaskResourceAttributes) GetDefaults() *TaskResourceSpec + func (x *TaskResourceAttributes) GetLimits() *TaskResourceSpec + func (x *TaskResourceAttributes) ProtoReflect() protoreflect.Message + func (x *TaskResourceAttributes) Reset() + func (x *TaskResourceAttributes) String() string + type TaskResourceSpec struct + Cpu string + EphemeralStorage string + Gpu string + Memory string + Storage string + func (*TaskResourceSpec) Descriptor() ([]byte, []int) + func (*TaskResourceSpec) ProtoMessage() + func (x *TaskResourceSpec) GetCpu() string + func (x *TaskResourceSpec) GetEphemeralStorage() string + func (x *TaskResourceSpec) GetGpu() string + func (x *TaskResourceSpec) GetMemory() string + func (x *TaskResourceSpec) GetStorage() string + func (x *TaskResourceSpec) ProtoReflect() protoreflect.Message + func (x *TaskResourceSpec) Reset() + func (x *TaskResourceSpec) String() string + type TaskSpec struct + Description *DescriptionEntity + Template *core.TaskTemplate + func (*TaskSpec) Descriptor() ([]byte, []int) + func (*TaskSpec) ProtoMessage() + func (x *TaskSpec) GetDescription() *DescriptionEntity + func (x *TaskSpec) GetTemplate() *core.TaskTemplate + func (x *TaskSpec) ProtoReflect() protoreflect.Message + func (x *TaskSpec) Reset() + func (x *TaskSpec) String() string + type UrlBlob struct + Bytes int64 + Url string + func (*UrlBlob) Descriptor() ([]byte, []int) + func (*UrlBlob) ProtoMessage() + func (x *UrlBlob) GetBytes() int64 + func (x *UrlBlob) GetUrl() string + func (x *UrlBlob) ProtoReflect() protoreflect.Message + func (x *UrlBlob) Reset() + func (x *UrlBlob) String() string + type Version struct + Build string + BuildTime string + Version string + func (*Version) Descriptor() ([]byte, []int) + func (*Version) ProtoMessage() + func (x *Version) GetBuild() string + func (x *Version) GetBuildTime() string + func (x *Version) GetVersion() string + func (x *Version) ProtoReflect() protoreflect.Message + func (x *Version) Reset() + func (x *Version) String() string + type Workflow struct + Closure *WorkflowClosure + Id *core.Identifier + ShortDescription string + func (*Workflow) Descriptor() ([]byte, []int) + func (*Workflow) ProtoMessage() + func (x *Workflow) GetClosure() *WorkflowClosure + func (x *Workflow) GetId() *core.Identifier + func (x *Workflow) GetShortDescription() string + func (x *Workflow) ProtoReflect() protoreflect.Message + func (x *Workflow) Reset() + func (x *Workflow) String() string + type WorkflowAttributes struct + Domain string + MatchingAttributes *MatchingAttributes + Org string + Project string + Workflow string + func (*WorkflowAttributes) Descriptor() ([]byte, []int) + func (*WorkflowAttributes) ProtoMessage() + func (x *WorkflowAttributes) GetDomain() string + func (x *WorkflowAttributes) GetMatchingAttributes() *MatchingAttributes + func (x *WorkflowAttributes) GetOrg() string + func (x *WorkflowAttributes) GetProject() string + func (x *WorkflowAttributes) GetWorkflow() string + func (x *WorkflowAttributes) ProtoReflect() protoreflect.Message + func (x *WorkflowAttributes) Reset() + func (x *WorkflowAttributes) String() string + type WorkflowAttributesDeleteRequest struct + Domain string + Org string + Project string + ResourceType MatchableResource + Workflow string + func (*WorkflowAttributesDeleteRequest) Descriptor() ([]byte, []int) + func (*WorkflowAttributesDeleteRequest) ProtoMessage() + func (x *WorkflowAttributesDeleteRequest) GetDomain() string + func (x *WorkflowAttributesDeleteRequest) GetOrg() string + func (x *WorkflowAttributesDeleteRequest) GetProject() string + func (x *WorkflowAttributesDeleteRequest) GetResourceType() MatchableResource + func (x *WorkflowAttributesDeleteRequest) GetWorkflow() string + func (x *WorkflowAttributesDeleteRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowAttributesDeleteRequest) Reset() + func (x *WorkflowAttributesDeleteRequest) String() string + type WorkflowAttributesDeleteResponse struct + func (*WorkflowAttributesDeleteResponse) Descriptor() ([]byte, []int) + func (*WorkflowAttributesDeleteResponse) ProtoMessage() + func (x *WorkflowAttributesDeleteResponse) ProtoReflect() protoreflect.Message + func (x *WorkflowAttributesDeleteResponse) Reset() + func (x *WorkflowAttributesDeleteResponse) String() string + type WorkflowAttributesGetRequest struct + Domain string + Org string + Project string + ResourceType MatchableResource + Workflow string + func (*WorkflowAttributesGetRequest) Descriptor() ([]byte, []int) + func (*WorkflowAttributesGetRequest) ProtoMessage() + func (x *WorkflowAttributesGetRequest) GetDomain() string + func (x *WorkflowAttributesGetRequest) GetOrg() string + func (x *WorkflowAttributesGetRequest) GetProject() string + func (x *WorkflowAttributesGetRequest) GetResourceType() MatchableResource + func (x *WorkflowAttributesGetRequest) GetWorkflow() string + func (x *WorkflowAttributesGetRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowAttributesGetRequest) Reset() + func (x *WorkflowAttributesGetRequest) String() string + type WorkflowAttributesGetResponse struct + Attributes *WorkflowAttributes + func (*WorkflowAttributesGetResponse) Descriptor() ([]byte, []int) + func (*WorkflowAttributesGetResponse) ProtoMessage() + func (x *WorkflowAttributesGetResponse) GetAttributes() *WorkflowAttributes + func (x *WorkflowAttributesGetResponse) ProtoReflect() protoreflect.Message + func (x *WorkflowAttributesGetResponse) Reset() + func (x *WorkflowAttributesGetResponse) String() string + type WorkflowAttributesUpdateRequest struct + Attributes *WorkflowAttributes + func (*WorkflowAttributesUpdateRequest) Descriptor() ([]byte, []int) + func (*WorkflowAttributesUpdateRequest) ProtoMessage() + func (x *WorkflowAttributesUpdateRequest) GetAttributes() *WorkflowAttributes + func (x *WorkflowAttributesUpdateRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowAttributesUpdateRequest) Reset() + func (x *WorkflowAttributesUpdateRequest) String() string + type WorkflowAttributesUpdateResponse struct + func (*WorkflowAttributesUpdateResponse) Descriptor() ([]byte, []int) + func (*WorkflowAttributesUpdateResponse) ProtoMessage() + func (x *WorkflowAttributesUpdateResponse) ProtoReflect() protoreflect.Message + func (x *WorkflowAttributesUpdateResponse) Reset() + func (x *WorkflowAttributesUpdateResponse) String() string + type WorkflowClosure struct + CompiledWorkflow *core.CompiledWorkflowClosure + CreatedAt *timestamppb.Timestamp + func (*WorkflowClosure) Descriptor() ([]byte, []int) + func (*WorkflowClosure) ProtoMessage() + func (x *WorkflowClosure) GetCompiledWorkflow() *core.CompiledWorkflowClosure + func (x *WorkflowClosure) GetCreatedAt() *timestamppb.Timestamp + func (x *WorkflowClosure) ProtoReflect() protoreflect.Message + func (x *WorkflowClosure) Reset() + func (x *WorkflowClosure) String() string + type WorkflowCreateRequest struct + Id *core.Identifier + Spec *WorkflowSpec + func (*WorkflowCreateRequest) Descriptor() ([]byte, []int) + func (*WorkflowCreateRequest) ProtoMessage() + func (x *WorkflowCreateRequest) GetId() *core.Identifier + func (x *WorkflowCreateRequest) GetSpec() *WorkflowSpec + func (x *WorkflowCreateRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowCreateRequest) Reset() + func (x *WorkflowCreateRequest) String() string + type WorkflowCreateResponse struct + func (*WorkflowCreateResponse) Descriptor() ([]byte, []int) + func (*WorkflowCreateResponse) ProtoMessage() + func (x *WorkflowCreateResponse) ProtoReflect() protoreflect.Message + func (x *WorkflowCreateResponse) Reset() + func (x *WorkflowCreateResponse) String() string + type WorkflowErrorExistsDifferentStructure struct + Id *core.Identifier + func (*WorkflowErrorExistsDifferentStructure) Descriptor() ([]byte, []int) + func (*WorkflowErrorExistsDifferentStructure) ProtoMessage() + func (x *WorkflowErrorExistsDifferentStructure) GetId() *core.Identifier + func (x *WorkflowErrorExistsDifferentStructure) ProtoReflect() protoreflect.Message + func (x *WorkflowErrorExistsDifferentStructure) Reset() + func (x *WorkflowErrorExistsDifferentStructure) String() string + type WorkflowErrorExistsIdenticalStructure struct + Id *core.Identifier + func (*WorkflowErrorExistsIdenticalStructure) Descriptor() ([]byte, []int) + func (*WorkflowErrorExistsIdenticalStructure) ProtoMessage() + func (x *WorkflowErrorExistsIdenticalStructure) GetId() *core.Identifier + func (x *WorkflowErrorExistsIdenticalStructure) ProtoReflect() protoreflect.Message + func (x *WorkflowErrorExistsIdenticalStructure) Reset() + func (x *WorkflowErrorExistsIdenticalStructure) String() string + type WorkflowExecutionConfig struct + Annotations *Annotations + Envs *Envs + Interruptible *wrapperspb.BoolValue + Labels *Labels + MaxParallelism int32 + OverwriteCache bool + RawOutputDataConfig *RawOutputDataConfig + SecurityContext *core.SecurityContext + func (*WorkflowExecutionConfig) Descriptor() ([]byte, []int) + func (*WorkflowExecutionConfig) ProtoMessage() + func (x *WorkflowExecutionConfig) GetAnnotations() *Annotations + func (x *WorkflowExecutionConfig) GetEnvs() *Envs + func (x *WorkflowExecutionConfig) GetInterruptible() *wrapperspb.BoolValue + func (x *WorkflowExecutionConfig) GetLabels() *Labels + func (x *WorkflowExecutionConfig) GetMaxParallelism() int32 + func (x *WorkflowExecutionConfig) GetOverwriteCache() bool + func (x *WorkflowExecutionConfig) GetRawOutputDataConfig() *RawOutputDataConfig + func (x *WorkflowExecutionConfig) GetSecurityContext() *core.SecurityContext + func (x *WorkflowExecutionConfig) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionConfig) Reset() + func (x *WorkflowExecutionConfig) String() string + type WorkflowExecutionEventRequest struct + Event *event.WorkflowExecutionEvent + RequestId string + func (*WorkflowExecutionEventRequest) Descriptor() ([]byte, []int) + func (*WorkflowExecutionEventRequest) ProtoMessage() + func (x *WorkflowExecutionEventRequest) GetEvent() *event.WorkflowExecutionEvent + func (x *WorkflowExecutionEventRequest) GetRequestId() string + func (x *WorkflowExecutionEventRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionEventRequest) Reset() + func (x *WorkflowExecutionEventRequest) String() string + type WorkflowExecutionEventResponse struct + func (*WorkflowExecutionEventResponse) Descriptor() ([]byte, []int) + func (*WorkflowExecutionEventResponse) ProtoMessage() + func (x *WorkflowExecutionEventResponse) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionEventResponse) Reset() + func (x *WorkflowExecutionEventResponse) String() string + type WorkflowExecutionGetDataRequest struct + Id *core.WorkflowExecutionIdentifier + func (*WorkflowExecutionGetDataRequest) Descriptor() ([]byte, []int) + func (*WorkflowExecutionGetDataRequest) ProtoMessage() + func (x *WorkflowExecutionGetDataRequest) GetId() *core.WorkflowExecutionIdentifier + func (x *WorkflowExecutionGetDataRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionGetDataRequest) Reset() + func (x *WorkflowExecutionGetDataRequest) String() string + type WorkflowExecutionGetDataResponse struct + FullInputs *core.LiteralMap + FullOutputs *core.LiteralMap + Inputs *UrlBlob + Outputs *UrlBlob + func (*WorkflowExecutionGetDataResponse) Descriptor() ([]byte, []int) + func (*WorkflowExecutionGetDataResponse) ProtoMessage() + func (x *WorkflowExecutionGetDataResponse) GetFullInputs() *core.LiteralMap + func (x *WorkflowExecutionGetDataResponse) GetFullOutputs() *core.LiteralMap + func (x *WorkflowExecutionGetDataResponse) GetInputs() *UrlBlob + func (x *WorkflowExecutionGetDataResponse) GetOutputs() *UrlBlob + func (x *WorkflowExecutionGetDataResponse) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionGetDataResponse) Reset() + func (x *WorkflowExecutionGetDataResponse) String() string + type WorkflowExecutionGetMetricsRequest struct + Depth int32 + Id *core.WorkflowExecutionIdentifier + func (*WorkflowExecutionGetMetricsRequest) Descriptor() ([]byte, []int) + func (*WorkflowExecutionGetMetricsRequest) ProtoMessage() + func (x *WorkflowExecutionGetMetricsRequest) GetDepth() int32 + func (x *WorkflowExecutionGetMetricsRequest) GetId() *core.WorkflowExecutionIdentifier + func (x *WorkflowExecutionGetMetricsRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionGetMetricsRequest) Reset() + func (x *WorkflowExecutionGetMetricsRequest) String() string + type WorkflowExecutionGetMetricsResponse struct + Span *core.Span + func (*WorkflowExecutionGetMetricsResponse) Descriptor() ([]byte, []int) + func (*WorkflowExecutionGetMetricsResponse) ProtoMessage() + func (x *WorkflowExecutionGetMetricsResponse) GetSpan() *core.Span + func (x *WorkflowExecutionGetMetricsResponse) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionGetMetricsResponse) Reset() + func (x *WorkflowExecutionGetMetricsResponse) String() string + type WorkflowExecutionGetRequest struct + Id *core.WorkflowExecutionIdentifier + func (*WorkflowExecutionGetRequest) Descriptor() ([]byte, []int) + func (*WorkflowExecutionGetRequest) ProtoMessage() + func (x *WorkflowExecutionGetRequest) GetId() *core.WorkflowExecutionIdentifier + func (x *WorkflowExecutionGetRequest) ProtoReflect() protoreflect.Message + func (x *WorkflowExecutionGetRequest) Reset() + func (x *WorkflowExecutionGetRequest) String() string + type WorkflowList struct + Token string + Workflows []*Workflow + func (*WorkflowList) Descriptor() ([]byte, []int) + func (*WorkflowList) ProtoMessage() + func (x *WorkflowList) GetToken() string + func (x *WorkflowList) GetWorkflows() []*Workflow + func (x *WorkflowList) ProtoReflect() protoreflect.Message + func (x *WorkflowList) Reset() + func (x *WorkflowList) String() string + type WorkflowNodeMetadata struct + ExecutionId *core.WorkflowExecutionIdentifier + func (*WorkflowNodeMetadata) Descriptor() ([]byte, []int) + func (*WorkflowNodeMetadata) ProtoMessage() + func (x *WorkflowNodeMetadata) GetExecutionId() *core.WorkflowExecutionIdentifier + func (x *WorkflowNodeMetadata) ProtoReflect() protoreflect.Message + func (x *WorkflowNodeMetadata) Reset() + func (x *WorkflowNodeMetadata) String() string + type WorkflowSpec struct + Description *DescriptionEntity + SubWorkflows []*core.WorkflowTemplate + Template *core.WorkflowTemplate + func (*WorkflowSpec) Descriptor() ([]byte, []int) + func (*WorkflowSpec) ProtoMessage() + func (x *WorkflowSpec) GetDescription() *DescriptionEntity + func (x *WorkflowSpec) GetSubWorkflows() []*core.WorkflowTemplate + func (x *WorkflowSpec) GetTemplate() *core.WorkflowTemplate + func (x *WorkflowSpec) ProtoReflect() protoreflect.Message + func (x *WorkflowSpec) Reset() + func (x *WorkflowSpec) String() string
Go to main page