Documentation
¶
Overview ¶
Code generated by protoc-gen-go-helpers. DO NOT EDIT.
Index ¶
- Variables
- type CallbackInfo
- func (*CallbackInfo) Descriptor() ([]byte, []int)deprecated
- func (this *CallbackInfo) Equal(that interface{}) bool
- func (x *CallbackInfo) GetAttempt() int32
- func (x *CallbackInfo) GetBlockedReason() string
- func (x *CallbackInfo) GetCallback() *v1.Callback
- func (x *CallbackInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
- func (x *CallbackInfo) GetLastAttemptFailure() *v15.Failure
- func (x *CallbackInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
- func (x *CallbackInfo) GetRegistrationTime() *timestamppb.Timestamp
- func (x *CallbackInfo) GetState() v11.CallbackState
- func (x *CallbackInfo) GetTrigger() *CallbackInfo_Trigger
- func (val *CallbackInfo) Marshal() ([]byte, error)
- func (*CallbackInfo) ProtoMessage()
- func (x *CallbackInfo) ProtoReflect() protoreflect.Message
- func (x *CallbackInfo) Reset()
- func (val *CallbackInfo) Size() int
- func (x *CallbackInfo) String() string
- func (val *CallbackInfo) Unmarshal(buf []byte) error
- type CallbackInfo_Trigger
- func (*CallbackInfo_Trigger) Descriptor() ([]byte, []int)deprecated
- func (x *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant
- func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed
- func (*CallbackInfo_Trigger) ProtoMessage()
- func (x *CallbackInfo_Trigger) ProtoReflect() protoreflect.Message
- func (x *CallbackInfo_Trigger) Reset()
- func (x *CallbackInfo_Trigger) String() string
- type CallbackInfo_Trigger_WorkflowClosed
- type CallbackInfo_WorkflowClosed
- type DeploymentTransition
- func (*DeploymentTransition) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentTransition) Equal(that interface{}) bool
- func (x *DeploymentTransition) GetDeployment() *v12.Deployment
- func (val *DeploymentTransition) Marshal() ([]byte, error)
- func (*DeploymentTransition) ProtoMessage()
- func (x *DeploymentTransition) ProtoReflect() protoreflect.Message
- func (x *DeploymentTransition) Reset()
- func (val *DeploymentTransition) Size() int
- func (x *DeploymentTransition) String() string
- func (val *DeploymentTransition) Unmarshal(buf []byte) error
- type DeploymentVersionTransition
- func (*DeploymentVersionTransition) Descriptor() ([]byte, []int)deprecated
- func (this *DeploymentVersionTransition) Equal(that interface{}) bool
- func (x *DeploymentVersionTransition) GetDeploymentVersion() *v12.WorkerDeploymentVersion
- func (x *DeploymentVersionTransition) GetVersion() stringdeprecated
- func (val *DeploymentVersionTransition) Marshal() ([]byte, error)
- func (*DeploymentVersionTransition) ProtoMessage()
- func (x *DeploymentVersionTransition) ProtoReflect() protoreflect.Message
- func (x *DeploymentVersionTransition) Reset()
- func (val *DeploymentVersionTransition) Size() int
- func (x *DeploymentVersionTransition) String() string
- func (val *DeploymentVersionTransition) Unmarshal(buf []byte) error
- type NewWorkflowExecutionInfo
- func (*NewWorkflowExecutionInfo) Descriptor() ([]byte, []int)deprecated
- func (this *NewWorkflowExecutionInfo) Equal(that interface{}) bool
- func (x *NewWorkflowExecutionInfo) GetCronSchedule() string
- func (x *NewWorkflowExecutionInfo) GetHeader() *v1.Header
- func (x *NewWorkflowExecutionInfo) GetInput() *v1.Payloads
- func (x *NewWorkflowExecutionInfo) GetMemo() *v1.Memo
- func (x *NewWorkflowExecutionInfo) GetPriority() *v1.Priority
- func (x *NewWorkflowExecutionInfo) GetRetryPolicy() *v1.RetryPolicy
- func (x *NewWorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes
- func (x *NewWorkflowExecutionInfo) GetTaskQueue() *v13.TaskQueue
- func (x *NewWorkflowExecutionInfo) GetUserMetadata() *v14.UserMetadata
- func (x *NewWorkflowExecutionInfo) GetVersioningOverride() *VersioningOverride
- func (x *NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout() *durationpb.Duration
- func (x *NewWorkflowExecutionInfo) GetWorkflowId() string
- func (x *NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy
- func (x *NewWorkflowExecutionInfo) GetWorkflowRunTimeout() *durationpb.Duration
- func (x *NewWorkflowExecutionInfo) GetWorkflowTaskTimeout() *durationpb.Duration
- func (x *NewWorkflowExecutionInfo) GetWorkflowType() *v1.WorkflowType
- func (val *NewWorkflowExecutionInfo) Marshal() ([]byte, error)
- func (*NewWorkflowExecutionInfo) ProtoMessage()
- func (x *NewWorkflowExecutionInfo) ProtoReflect() protoreflect.Message
- func (x *NewWorkflowExecutionInfo) Reset()
- func (val *NewWorkflowExecutionInfo) Size() int
- func (x *NewWorkflowExecutionInfo) String() string
- func (val *NewWorkflowExecutionInfo) Unmarshal(buf []byte) error
- type NexusOperationCancellationInfo
- func (*NexusOperationCancellationInfo) Descriptor() ([]byte, []int)deprecated
- func (this *NexusOperationCancellationInfo) Equal(that interface{}) bool
- func (x *NexusOperationCancellationInfo) GetAttempt() int32
- func (x *NexusOperationCancellationInfo) GetBlockedReason() string
- func (x *NexusOperationCancellationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
- func (x *NexusOperationCancellationInfo) GetLastAttemptFailure() *v15.Failure
- func (x *NexusOperationCancellationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
- func (x *NexusOperationCancellationInfo) GetRequestedTime() *timestamppb.Timestamp
- func (x *NexusOperationCancellationInfo) GetState() v11.NexusOperationCancellationState
- func (val *NexusOperationCancellationInfo) Marshal() ([]byte, error)
- func (*NexusOperationCancellationInfo) ProtoMessage()
- func (x *NexusOperationCancellationInfo) ProtoReflect() protoreflect.Message
- func (x *NexusOperationCancellationInfo) Reset()
- func (val *NexusOperationCancellationInfo) Size() int
- func (x *NexusOperationCancellationInfo) String() string
- func (val *NexusOperationCancellationInfo) Unmarshal(buf []byte) error
- type OnConflictOptions
- func (*OnConflictOptions) Descriptor() ([]byte, []int)deprecated
- func (this *OnConflictOptions) Equal(that interface{}) bool
- func (x *OnConflictOptions) GetAttachCompletionCallbacks() bool
- func (x *OnConflictOptions) GetAttachLinks() bool
- func (x *OnConflictOptions) GetAttachRequestId() bool
- func (val *OnConflictOptions) Marshal() ([]byte, error)
- func (*OnConflictOptions) ProtoMessage()
- func (x *OnConflictOptions) ProtoReflect() protoreflect.Message
- func (x *OnConflictOptions) Reset()
- func (val *OnConflictOptions) Size() int
- func (x *OnConflictOptions) String() string
- func (val *OnConflictOptions) Unmarshal(buf []byte) error
- type PendingActivityInfo
- func (*PendingActivityInfo) Descriptor() ([]byte, []int)deprecated
- func (this *PendingActivityInfo) Equal(that interface{}) bool
- func (x *PendingActivityInfo) GetActivityId() string
- func (x *PendingActivityInfo) GetActivityOptions() *v16.ActivityOptions
- func (x *PendingActivityInfo) GetActivityType() *v1.ActivityType
- func (x *PendingActivityInfo) GetAssignedBuildId() isPendingActivityInfo_AssignedBuildId
- func (x *PendingActivityInfo) GetAttempt() int32
- func (x *PendingActivityInfo) GetCurrentRetryInterval() *durationpb.Duration
- func (x *PendingActivityInfo) GetExpirationTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetHeartbeatDetails() *v1.Payloads
- func (x *PendingActivityInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetLastDeployment() *v12.Deploymentdeprecated
- func (x *PendingActivityInfo) GetLastDeploymentVersion() *v12.WorkerDeploymentVersion
- func (x *PendingActivityInfo) GetLastFailure() *v15.Failure
- func (x *PendingActivityInfo) GetLastHeartbeatTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetLastIndependentlyAssignedBuildId() stringdeprecated
- func (x *PendingActivityInfo) GetLastStartedTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetLastWorkerDeploymentVersion() stringdeprecated
- func (x *PendingActivityInfo) GetLastWorkerIdentity() string
- func (x *PendingActivityInfo) GetLastWorkerVersionStamp() *v1.WorkerVersionStampdeprecated
- func (x *PendingActivityInfo) GetMaximumAttempts() int32
- func (x *PendingActivityInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetPauseInfo() *PendingActivityInfo_PauseInfo
- func (x *PendingActivityInfo) GetPaused() bool
- func (x *PendingActivityInfo) GetPriority() *v1.Priority
- func (x *PendingActivityInfo) GetScheduledTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetState() v11.PendingActivityState
- func (x *PendingActivityInfo) GetUseWorkflowBuildId() *emptypb.Emptydeprecated
- func (val *PendingActivityInfo) Marshal() ([]byte, error)
- func (*PendingActivityInfo) ProtoMessage()
- func (x *PendingActivityInfo) ProtoReflect() protoreflect.Message
- func (x *PendingActivityInfo) Reset()
- func (val *PendingActivityInfo) Size() int
- func (x *PendingActivityInfo) String() string
- func (val *PendingActivityInfo) Unmarshal(buf []byte) error
- type PendingActivityInfo_LastIndependentlyAssignedBuildId
- type PendingActivityInfo_PauseInfo
- func (*PendingActivityInfo_PauseInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PendingActivityInfo_PauseInfo) GetManual() *PendingActivityInfo_PauseInfo_Manual
- func (x *PendingActivityInfo_PauseInfo) GetPauseTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo_PauseInfo) GetPausedBy() isPendingActivityInfo_PauseInfo_PausedBy
- func (x *PendingActivityInfo_PauseInfo) GetRule() *PendingActivityInfo_PauseInfo_Rule
- func (*PendingActivityInfo_PauseInfo) ProtoMessage()
- func (x *PendingActivityInfo_PauseInfo) ProtoReflect() protoreflect.Message
- func (x *PendingActivityInfo_PauseInfo) Reset()
- func (x *PendingActivityInfo_PauseInfo) String() string
- type PendingActivityInfo_PauseInfo_Manual
- func (*PendingActivityInfo_PauseInfo_Manual) Descriptor() ([]byte, []int)deprecated
- func (x *PendingActivityInfo_PauseInfo_Manual) GetIdentity() string
- func (x *PendingActivityInfo_PauseInfo_Manual) GetReason() string
- func (*PendingActivityInfo_PauseInfo_Manual) ProtoMessage()
- func (x *PendingActivityInfo_PauseInfo_Manual) ProtoReflect() protoreflect.Message
- func (x *PendingActivityInfo_PauseInfo_Manual) Reset()
- func (x *PendingActivityInfo_PauseInfo_Manual) String() string
- type PendingActivityInfo_PauseInfo_Manual_
- type PendingActivityInfo_PauseInfo_Rule
- func (*PendingActivityInfo_PauseInfo_Rule) Descriptor() ([]byte, []int)deprecated
- func (x *PendingActivityInfo_PauseInfo_Rule) GetIdentity() string
- func (x *PendingActivityInfo_PauseInfo_Rule) GetReason() string
- func (x *PendingActivityInfo_PauseInfo_Rule) GetRuleId() string
- func (*PendingActivityInfo_PauseInfo_Rule) ProtoMessage()
- func (x *PendingActivityInfo_PauseInfo_Rule) ProtoReflect() protoreflect.Message
- func (x *PendingActivityInfo_PauseInfo_Rule) Reset()
- func (x *PendingActivityInfo_PauseInfo_Rule) String() string
- type PendingActivityInfo_PauseInfo_Rule_
- type PendingActivityInfo_UseWorkflowBuildId
- type PendingChildExecutionInfo
- func (*PendingChildExecutionInfo) Descriptor() ([]byte, []int)deprecated
- func (this *PendingChildExecutionInfo) Equal(that interface{}) bool
- func (x *PendingChildExecutionInfo) GetInitiatedId() int64
- func (x *PendingChildExecutionInfo) GetParentClosePolicy() v11.ParentClosePolicy
- func (x *PendingChildExecutionInfo) GetRunId() string
- func (x *PendingChildExecutionInfo) GetWorkflowId() string
- func (x *PendingChildExecutionInfo) GetWorkflowTypeName() string
- func (val *PendingChildExecutionInfo) Marshal() ([]byte, error)
- func (*PendingChildExecutionInfo) ProtoMessage()
- func (x *PendingChildExecutionInfo) ProtoReflect() protoreflect.Message
- func (x *PendingChildExecutionInfo) Reset()
- func (val *PendingChildExecutionInfo) Size() int
- func (x *PendingChildExecutionInfo) String() string
- func (val *PendingChildExecutionInfo) Unmarshal(buf []byte) error
- type PendingNexusOperationInfo
- func (*PendingNexusOperationInfo) Descriptor() ([]byte, []int)deprecated
- func (this *PendingNexusOperationInfo) Equal(that interface{}) bool
- func (x *PendingNexusOperationInfo) GetAttempt() int32
- func (x *PendingNexusOperationInfo) GetBlockedReason() string
- func (x *PendingNexusOperationInfo) GetCancellationInfo() *NexusOperationCancellationInfo
- func (x *PendingNexusOperationInfo) GetEndpoint() string
- func (x *PendingNexusOperationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
- func (x *PendingNexusOperationInfo) GetLastAttemptFailure() *v15.Failure
- func (x *PendingNexusOperationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
- func (x *PendingNexusOperationInfo) GetOperation() string
- func (x *PendingNexusOperationInfo) GetOperationId() stringdeprecated
- func (x *PendingNexusOperationInfo) GetOperationToken() string
- func (x *PendingNexusOperationInfo) GetScheduleToCloseTimeout() *durationpb.Duration
- func (x *PendingNexusOperationInfo) GetScheduledEventId() int64
- func (x *PendingNexusOperationInfo) GetScheduledTime() *timestamppb.Timestamp
- func (x *PendingNexusOperationInfo) GetService() string
- func (x *PendingNexusOperationInfo) GetState() v11.PendingNexusOperationState
- func (val *PendingNexusOperationInfo) Marshal() ([]byte, error)
- func (*PendingNexusOperationInfo) ProtoMessage()
- func (x *PendingNexusOperationInfo) ProtoReflect() protoreflect.Message
- func (x *PendingNexusOperationInfo) Reset()
- func (val *PendingNexusOperationInfo) Size() int
- func (x *PendingNexusOperationInfo) String() string
- func (val *PendingNexusOperationInfo) Unmarshal(buf []byte) error
- type PendingWorkflowTaskInfo
- func (*PendingWorkflowTaskInfo) Descriptor() ([]byte, []int)deprecated
- func (this *PendingWorkflowTaskInfo) Equal(that interface{}) bool
- func (x *PendingWorkflowTaskInfo) GetAttempt() int32
- func (x *PendingWorkflowTaskInfo) GetOriginalScheduledTime() *timestamppb.Timestamp
- func (x *PendingWorkflowTaskInfo) GetScheduledTime() *timestamppb.Timestamp
- func (x *PendingWorkflowTaskInfo) GetStartedTime() *timestamppb.Timestamp
- func (x *PendingWorkflowTaskInfo) GetState() v11.PendingWorkflowTaskState
- func (val *PendingWorkflowTaskInfo) Marshal() ([]byte, error)
- func (*PendingWorkflowTaskInfo) ProtoMessage()
- func (x *PendingWorkflowTaskInfo) ProtoReflect() protoreflect.Message
- func (x *PendingWorkflowTaskInfo) Reset()
- func (val *PendingWorkflowTaskInfo) Size() int
- func (x *PendingWorkflowTaskInfo) String() string
- func (val *PendingWorkflowTaskInfo) Unmarshal(buf []byte) error
- type PostResetOperation
- func (*PostResetOperation) Descriptor() ([]byte, []int)deprecated
- func (this *PostResetOperation) Equal(that interface{}) bool
- func (x *PostResetOperation) GetSignalWorkflow() *PostResetOperation_SignalWorkflow
- func (x *PostResetOperation) GetUpdateWorkflowOptions() *PostResetOperation_UpdateWorkflowOptions
- func (x *PostResetOperation) GetVariant() isPostResetOperation_Variant
- func (val *PostResetOperation) Marshal() ([]byte, error)
- func (*PostResetOperation) ProtoMessage()
- func (x *PostResetOperation) ProtoReflect() protoreflect.Message
- func (x *PostResetOperation) Reset()
- func (val *PostResetOperation) Size() int
- func (x *PostResetOperation) String() string
- func (val *PostResetOperation) Unmarshal(buf []byte) error
- type PostResetOperation_SignalWorkflow
- func (*PostResetOperation_SignalWorkflow) Descriptor() ([]byte, []int)deprecated
- func (x *PostResetOperation_SignalWorkflow) GetHeader() *v1.Header
- func (x *PostResetOperation_SignalWorkflow) GetInput() *v1.Payloads
- func (x *PostResetOperation_SignalWorkflow) GetLinks() []*v1.Link
- func (x *PostResetOperation_SignalWorkflow) GetSignalName() string
- func (*PostResetOperation_SignalWorkflow) ProtoMessage()
- func (x *PostResetOperation_SignalWorkflow) ProtoReflect() protoreflect.Message
- func (x *PostResetOperation_SignalWorkflow) Reset()
- func (x *PostResetOperation_SignalWorkflow) String() string
- type PostResetOperation_SignalWorkflow_
- type PostResetOperation_UpdateWorkflowOptions
- func (*PostResetOperation_UpdateWorkflowOptions) Descriptor() ([]byte, []int)deprecated
- func (x *PostResetOperation_UpdateWorkflowOptions) GetUpdateMask() *fieldmaskpb.FieldMask
- func (x *PostResetOperation_UpdateWorkflowOptions) GetWorkflowExecutionOptions() *WorkflowExecutionOptions
- func (*PostResetOperation_UpdateWorkflowOptions) ProtoMessage()
- func (x *PostResetOperation_UpdateWorkflowOptions) ProtoReflect() protoreflect.Message
- func (x *PostResetOperation_UpdateWorkflowOptions) Reset()
- func (x *PostResetOperation_UpdateWorkflowOptions) String() string
- type PostResetOperation_UpdateWorkflowOptions_
- type RequestIdInfo
- func (*RequestIdInfo) Descriptor() ([]byte, []int)deprecated
- func (this *RequestIdInfo) Equal(that interface{}) bool
- func (x *RequestIdInfo) GetBuffered() bool
- func (x *RequestIdInfo) GetEventId() int64
- func (x *RequestIdInfo) GetEventType() v11.EventType
- func (val *RequestIdInfo) Marshal() ([]byte, error)
- func (*RequestIdInfo) ProtoMessage()
- func (x *RequestIdInfo) ProtoReflect() protoreflect.Message
- func (x *RequestIdInfo) Reset()
- func (val *RequestIdInfo) Size() int
- func (x *RequestIdInfo) String() string
- func (val *RequestIdInfo) Unmarshal(buf []byte) error
- type ResetPointInfo
- func (*ResetPointInfo) Descriptor() ([]byte, []int)deprecated
- func (this *ResetPointInfo) Equal(that interface{}) bool
- func (x *ResetPointInfo) GetBinaryChecksum() stringdeprecated
- func (x *ResetPointInfo) GetBuildId() string
- func (x *ResetPointInfo) GetCreateTime() *timestamppb.Timestamp
- func (x *ResetPointInfo) GetExpireTime() *timestamppb.Timestamp
- func (x *ResetPointInfo) GetFirstWorkflowTaskCompletedId() int64
- func (x *ResetPointInfo) GetResettable() bool
- func (x *ResetPointInfo) GetRunId() string
- func (val *ResetPointInfo) Marshal() ([]byte, error)
- func (*ResetPointInfo) ProtoMessage()
- func (x *ResetPointInfo) ProtoReflect() protoreflect.Message
- func (x *ResetPointInfo) Reset()
- func (val *ResetPointInfo) Size() int
- func (x *ResetPointInfo) String() string
- func (val *ResetPointInfo) Unmarshal(buf []byte) error
- type ResetPoints
- func (*ResetPoints) Descriptor() ([]byte, []int)deprecated
- func (this *ResetPoints) Equal(that interface{}) bool
- func (x *ResetPoints) GetPoints() []*ResetPointInfo
- func (val *ResetPoints) Marshal() ([]byte, error)
- func (*ResetPoints) ProtoMessage()
- func (x *ResetPoints) ProtoReflect() protoreflect.Message
- func (x *ResetPoints) Reset()
- func (val *ResetPoints) Size() int
- func (x *ResetPoints) String() string
- func (val *ResetPoints) Unmarshal(buf []byte) error
- type VersioningOverride
- func (*VersioningOverride) Descriptor() ([]byte, []int)deprecated
- func (this *VersioningOverride) Equal(that interface{}) bool
- func (x *VersioningOverride) GetAutoUpgrade() bool
- func (x *VersioningOverride) GetBehavior() v11.VersioningBehaviordeprecated
- func (x *VersioningOverride) GetDeployment() *v12.Deploymentdeprecated
- func (x *VersioningOverride) GetOverride() isVersioningOverride_Override
- func (x *VersioningOverride) GetPinned() *VersioningOverride_PinnedOverride
- func (x *VersioningOverride) GetPinnedVersion() stringdeprecated
- func (val *VersioningOverride) Marshal() ([]byte, error)
- func (*VersioningOverride) ProtoMessage()
- func (x *VersioningOverride) ProtoReflect() protoreflect.Message
- func (x *VersioningOverride) Reset()
- func (val *VersioningOverride) Size() int
- func (x *VersioningOverride) String() string
- func (val *VersioningOverride) Unmarshal(buf []byte) error
- type VersioningOverride_AutoUpgrade
- type VersioningOverride_Pinned
- type VersioningOverride_PinnedOverride
- func (*VersioningOverride_PinnedOverride) Descriptor() ([]byte, []int)deprecated
- func (x *VersioningOverride_PinnedOverride) GetBehavior() VersioningOverride_PinnedOverrideBehavior
- func (x *VersioningOverride_PinnedOverride) GetVersion() *v12.WorkerDeploymentVersion
- func (*VersioningOverride_PinnedOverride) ProtoMessage()
- func (x *VersioningOverride_PinnedOverride) ProtoReflect() protoreflect.Message
- func (x *VersioningOverride_PinnedOverride) Reset()
- func (x *VersioningOverride_PinnedOverride) String() string
- type VersioningOverride_PinnedOverrideBehavior
- func (VersioningOverride_PinnedOverrideBehavior) Descriptor() protoreflect.EnumDescriptor
- func (x VersioningOverride_PinnedOverrideBehavior) Enum() *VersioningOverride_PinnedOverrideBehavior
- func (VersioningOverride_PinnedOverrideBehavior) EnumDescriptor() ([]byte, []int)deprecated
- func (x VersioningOverride_PinnedOverrideBehavior) Number() protoreflect.EnumNumber
- func (x VersioningOverride_PinnedOverrideBehavior) String() string
- func (VersioningOverride_PinnedOverrideBehavior) Type() protoreflect.EnumType
- type WorkflowExecutionConfig
- func (*WorkflowExecutionConfig) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionConfig) Equal(that interface{}) bool
- func (x *WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout() *durationpb.Duration
- func (x *WorkflowExecutionConfig) GetTaskQueue() *v13.TaskQueue
- func (x *WorkflowExecutionConfig) GetUserMetadata() *v14.UserMetadata
- func (x *WorkflowExecutionConfig) GetWorkflowExecutionTimeout() *durationpb.Duration
- func (x *WorkflowExecutionConfig) GetWorkflowRunTimeout() *durationpb.Duration
- func (val *WorkflowExecutionConfig) Marshal() ([]byte, error)
- func (*WorkflowExecutionConfig) ProtoMessage()
- func (x *WorkflowExecutionConfig) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionConfig) Reset()
- func (val *WorkflowExecutionConfig) Size() int
- func (x *WorkflowExecutionConfig) String() string
- func (val *WorkflowExecutionConfig) Unmarshal(buf []byte) error
- type WorkflowExecutionExtendedInfo
- func (*WorkflowExecutionExtendedInfo) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionExtendedInfo) Equal(that interface{}) bool
- func (x *WorkflowExecutionExtendedInfo) GetCancelRequested() bool
- func (x *WorkflowExecutionExtendedInfo) GetExecutionExpirationTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionExtendedInfo) GetLastResetTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionExtendedInfo) GetOriginalStartTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionExtendedInfo) GetPauseInfo() *WorkflowExecutionPauseInfo
- func (x *WorkflowExecutionExtendedInfo) GetRequestIdInfos() map[string]*RequestIdInfo
- func (x *WorkflowExecutionExtendedInfo) GetResetRunId() string
- func (x *WorkflowExecutionExtendedInfo) GetRunExpirationTime() *timestamppb.Timestamp
- func (val *WorkflowExecutionExtendedInfo) Marshal() ([]byte, error)
- func (*WorkflowExecutionExtendedInfo) ProtoMessage()
- func (x *WorkflowExecutionExtendedInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionExtendedInfo) Reset()
- func (val *WorkflowExecutionExtendedInfo) Size() int
- func (x *WorkflowExecutionExtendedInfo) String() string
- func (val *WorkflowExecutionExtendedInfo) Unmarshal(buf []byte) error
- type WorkflowExecutionInfo
- func (*WorkflowExecutionInfo) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionInfo) Equal(that interface{}) bool
- func (x *WorkflowExecutionInfo) GetAssignedBuildId() stringdeprecated
- func (x *WorkflowExecutionInfo) GetAutoResetPoints() *ResetPoints
- func (x *WorkflowExecutionInfo) GetCloseTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionInfo) GetExecution() *v1.WorkflowExecution
- func (x *WorkflowExecutionInfo) GetExecutionDuration() *durationpb.Duration
- func (x *WorkflowExecutionInfo) GetExecutionTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionInfo) GetExternalPayloadCount() int64
- func (x *WorkflowExecutionInfo) GetExternalPayloadSizeBytes() int64
- func (x *WorkflowExecutionInfo) GetFirstRunId() string
- func (x *WorkflowExecutionInfo) GetHistoryLength() int64
- func (x *WorkflowExecutionInfo) GetHistorySizeBytes() int64
- func (x *WorkflowExecutionInfo) GetInheritedBuildId() stringdeprecated
- func (x *WorkflowExecutionInfo) GetMemo() *v1.Memo
- func (x *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v1.WorkerVersionStampdeprecated
- func (x *WorkflowExecutionInfo) GetParentExecution() *v1.WorkflowExecution
- func (x *WorkflowExecutionInfo) GetParentNamespaceId() string
- func (x *WorkflowExecutionInfo) GetPriority() *v1.Priority
- func (x *WorkflowExecutionInfo) GetRootExecution() *v1.WorkflowExecution
- func (x *WorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes
- func (x *WorkflowExecutionInfo) GetStartTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionInfo) GetStateTransitionCount() int64
- func (x *WorkflowExecutionInfo) GetStatus() v11.WorkflowExecutionStatus
- func (x *WorkflowExecutionInfo) GetTaskQueue() string
- func (x *WorkflowExecutionInfo) GetType() *v1.WorkflowType
- func (x *WorkflowExecutionInfo) GetVersioningInfo() *WorkflowExecutionVersioningInfo
- func (x *WorkflowExecutionInfo) GetWorkerDeploymentName() string
- func (val *WorkflowExecutionInfo) Marshal() ([]byte, error)
- func (*WorkflowExecutionInfo) ProtoMessage()
- func (x *WorkflowExecutionInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionInfo) Reset()
- func (val *WorkflowExecutionInfo) Size() int
- func (x *WorkflowExecutionInfo) String() string
- func (val *WorkflowExecutionInfo) Unmarshal(buf []byte) error
- type WorkflowExecutionOptions
- func (*WorkflowExecutionOptions) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionOptions) Equal(that interface{}) bool
- func (x *WorkflowExecutionOptions) GetPriority() *v1.Priority
- func (x *WorkflowExecutionOptions) GetVersioningOverride() *VersioningOverride
- func (val *WorkflowExecutionOptions) Marshal() ([]byte, error)
- func (*WorkflowExecutionOptions) ProtoMessage()
- func (x *WorkflowExecutionOptions) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionOptions) Reset()
- func (val *WorkflowExecutionOptions) Size() int
- func (x *WorkflowExecutionOptions) String() string
- func (val *WorkflowExecutionOptions) Unmarshal(buf []byte) error
- type WorkflowExecutionPauseInfo
- func (*WorkflowExecutionPauseInfo) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionPauseInfo) Equal(that interface{}) bool
- func (x *WorkflowExecutionPauseInfo) GetIdentity() string
- func (x *WorkflowExecutionPauseInfo) GetPausedTime() *timestamppb.Timestamp
- func (x *WorkflowExecutionPauseInfo) GetReason() string
- func (val *WorkflowExecutionPauseInfo) Marshal() ([]byte, error)
- func (*WorkflowExecutionPauseInfo) ProtoMessage()
- func (x *WorkflowExecutionPauseInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionPauseInfo) Reset()
- func (val *WorkflowExecutionPauseInfo) Size() int
- func (x *WorkflowExecutionPauseInfo) String() string
- func (val *WorkflowExecutionPauseInfo) Unmarshal(buf []byte) error
- type WorkflowExecutionVersioningInfo
- func (*WorkflowExecutionVersioningInfo) Descriptor() ([]byte, []int)deprecated
- func (this *WorkflowExecutionVersioningInfo) Equal(that interface{}) bool
- func (x *WorkflowExecutionVersioningInfo) GetBehavior() v11.VersioningBehavior
- func (x *WorkflowExecutionVersioningInfo) GetDeployment() *v12.Deploymentdeprecated
- func (x *WorkflowExecutionVersioningInfo) GetDeploymentTransition() *DeploymentTransitiondeprecated
- func (x *WorkflowExecutionVersioningInfo) GetDeploymentVersion() *v12.WorkerDeploymentVersion
- func (x *WorkflowExecutionVersioningInfo) GetRevisionNumber() int64
- func (x *WorkflowExecutionVersioningInfo) GetVersion() stringdeprecated
- func (x *WorkflowExecutionVersioningInfo) GetVersionTransition() *DeploymentVersionTransition
- func (x *WorkflowExecutionVersioningInfo) GetVersioningOverride() *VersioningOverride
- func (val *WorkflowExecutionVersioningInfo) Marshal() ([]byte, error)
- func (*WorkflowExecutionVersioningInfo) ProtoMessage()
- func (x *WorkflowExecutionVersioningInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionVersioningInfo) Reset()
- func (val *WorkflowExecutionVersioningInfo) Size() int
- func (x *WorkflowExecutionVersioningInfo) String() string
- func (val *WorkflowExecutionVersioningInfo) Unmarshal(buf []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( VersioningOverride_PinnedOverrideBehavior_name = map[int32]string{ 0: "PINNED_OVERRIDE_BEHAVIOR_UNSPECIFIED", 1: "PINNED_OVERRIDE_BEHAVIOR_PINNED", } VersioningOverride_PinnedOverrideBehavior_value = map[string]int32{ "PINNED_OVERRIDE_BEHAVIOR_UNSPECIFIED": 0, "PINNED_OVERRIDE_BEHAVIOR_PINNED": 1, } )
Enum value maps for VersioningOverride_PinnedOverrideBehavior.
var File_temporal_api_workflow_v1_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CallbackInfo ¶ added in v1.27.0
type CallbackInfo struct {
// Information on how this callback should be invoked (e.g. its URL and type).
Callback *v1.Callback `protobuf:"bytes,1,opt,name=callback,proto3" json:"callback,omitempty"`
// Trigger for this callback.
Trigger *CallbackInfo_Trigger `protobuf:"bytes,2,opt,name=trigger,proto3" json:"trigger,omitempty"`
// The time when the callback was registered.
RegistrationTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=registration_time,json=registrationTime,proto3" json:"registration_time,omitempty"`
State v11.CallbackState `protobuf:"varint,4,opt,name=state,proto3,enum=temporal.api.enums.v1.CallbackState" json:"state,omitempty"`
// The number of attempts made to deliver the callback.
// This number represents a minimum bound since the attempt is incremented after the callback request completes.
Attempt int32 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
// The time when the last attempt completed.
LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
// The last attempt's failure, if any.
LastAttemptFailure *v15.Failure `protobuf:"bytes,7,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
// The time when the next attempt is scheduled.
NextAttemptScheduleTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
// If the state is BLOCKED, blocked reason provides additional information.
BlockedReason string `protobuf:"bytes,9,opt,name=blocked_reason,json=blockedReason,proto3" json:"blocked_reason,omitempty"`
// contains filtered or unexported fields
}
CallbackInfo contains the state of an attached workflow callback.
func (*CallbackInfo) Descriptor
deprecated
added in
v1.27.0
func (*CallbackInfo) Descriptor() ([]byte, []int)
Deprecated: Use CallbackInfo.ProtoReflect.Descriptor instead.
func (*CallbackInfo) Equal ¶ added in v1.27.0
func (this *CallbackInfo) Equal(that interface{}) bool
Equal returns whether two CallbackInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*CallbackInfo) GetAttempt ¶ added in v1.27.0
func (x *CallbackInfo) GetAttempt() int32
func (*CallbackInfo) GetBlockedReason ¶ added in v1.42.0
func (x *CallbackInfo) GetBlockedReason() string
func (*CallbackInfo) GetCallback ¶ added in v1.27.0
func (x *CallbackInfo) GetCallback() *v1.Callback
func (*CallbackInfo) GetLastAttemptCompleteTime ¶ added in v1.27.0
func (x *CallbackInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
func (*CallbackInfo) GetLastAttemptFailure ¶ added in v1.27.0
func (x *CallbackInfo) GetLastAttemptFailure() *v15.Failure
func (*CallbackInfo) GetNextAttemptScheduleTime ¶ added in v1.27.0
func (x *CallbackInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
func (*CallbackInfo) GetRegistrationTime ¶ added in v1.27.0
func (x *CallbackInfo) GetRegistrationTime() *timestamppb.Timestamp
func (*CallbackInfo) GetState ¶ added in v1.27.0
func (x *CallbackInfo) GetState() v11.CallbackState
func (*CallbackInfo) GetTrigger ¶ added in v1.27.0
func (x *CallbackInfo) GetTrigger() *CallbackInfo_Trigger
func (*CallbackInfo) Marshal ¶ added in v1.27.0
func (val *CallbackInfo) Marshal() ([]byte, error)
Marshal an object of type CallbackInfo to the protobuf v3 wire format
func (*CallbackInfo) ProtoMessage ¶ added in v1.27.0
func (*CallbackInfo) ProtoMessage()
func (*CallbackInfo) ProtoReflect ¶ added in v1.27.0
func (x *CallbackInfo) ProtoReflect() protoreflect.Message
func (*CallbackInfo) Reset ¶ added in v1.27.0
func (x *CallbackInfo) Reset()
func (*CallbackInfo) Size ¶ added in v1.27.0
func (val *CallbackInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*CallbackInfo) String ¶ added in v1.27.0
func (x *CallbackInfo) String() string
func (*CallbackInfo) Unmarshal ¶ added in v1.27.0
func (val *CallbackInfo) Unmarshal(buf []byte) error
Unmarshal an object of type CallbackInfo from the protobuf v3 wire format
type CallbackInfo_Trigger ¶ added in v1.27.0
type CallbackInfo_Trigger struct {
// Types that are valid to be assigned to Variant:
//
// *CallbackInfo_Trigger_WorkflowClosed
Variant isCallbackInfo_Trigger_Variant `protobuf_oneof:"variant"`
// contains filtered or unexported fields
}
func (*CallbackInfo_Trigger) Descriptor
deprecated
added in
v1.27.0
func (*CallbackInfo_Trigger) Descriptor() ([]byte, []int)
Deprecated: Use CallbackInfo_Trigger.ProtoReflect.Descriptor instead.
func (*CallbackInfo_Trigger) GetVariant ¶ added in v1.27.0
func (x *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant
func (*CallbackInfo_Trigger) GetWorkflowClosed ¶ added in v1.27.0
func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed
func (*CallbackInfo_Trigger) ProtoMessage ¶ added in v1.27.0
func (*CallbackInfo_Trigger) ProtoMessage()
func (*CallbackInfo_Trigger) ProtoReflect ¶ added in v1.27.0
func (x *CallbackInfo_Trigger) ProtoReflect() protoreflect.Message
func (*CallbackInfo_Trigger) Reset ¶ added in v1.27.0
func (x *CallbackInfo_Trigger) Reset()
func (*CallbackInfo_Trigger) String ¶ added in v1.27.0
func (x *CallbackInfo_Trigger) String() string
type CallbackInfo_Trigger_WorkflowClosed ¶ added in v1.27.0
type CallbackInfo_Trigger_WorkflowClosed struct {
WorkflowClosed *CallbackInfo_WorkflowClosed `protobuf:"bytes,1,opt,name=workflow_closed,json=workflowClosed,proto3,oneof"`
}
type CallbackInfo_WorkflowClosed ¶ added in v1.27.0
type CallbackInfo_WorkflowClosed struct {
// contains filtered or unexported fields
}
Trigger for when the workflow is closed.
func (*CallbackInfo_WorkflowClosed) Descriptor
deprecated
added in
v1.27.0
func (*CallbackInfo_WorkflowClosed) Descriptor() ([]byte, []int)
Deprecated: Use CallbackInfo_WorkflowClosed.ProtoReflect.Descriptor instead.
func (*CallbackInfo_WorkflowClosed) ProtoMessage ¶ added in v1.27.0
func (*CallbackInfo_WorkflowClosed) ProtoMessage()
func (*CallbackInfo_WorkflowClosed) ProtoReflect ¶ added in v1.27.0
func (x *CallbackInfo_WorkflowClosed) ProtoReflect() protoreflect.Message
func (*CallbackInfo_WorkflowClosed) Reset ¶ added in v1.27.0
func (x *CallbackInfo_WorkflowClosed) Reset()
func (*CallbackInfo_WorkflowClosed) String ¶ added in v1.27.0
func (x *CallbackInfo_WorkflowClosed) String() string
type DeploymentTransition ¶ added in v1.43.0
type DeploymentTransition struct {
// The target deployment of the transition. Null means a so-far-versioned workflow is
// transitioning to unversioned workers.
Deployment *v12.Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"`
// contains filtered or unexported fields
}
Holds information about ongoing transition of a workflow execution from one deployment to another. Deprecated. Use DeploymentVersionTransition.
func (*DeploymentTransition) Descriptor
deprecated
added in
v1.43.0
func (*DeploymentTransition) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentTransition.ProtoReflect.Descriptor instead.
func (*DeploymentTransition) Equal ¶ added in v1.43.0
func (this *DeploymentTransition) Equal(that interface{}) bool
Equal returns whether two DeploymentTransition values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*DeploymentTransition) GetDeployment ¶ added in v1.43.0
func (x *DeploymentTransition) GetDeployment() *v12.Deployment
func (*DeploymentTransition) Marshal ¶ added in v1.43.0
func (val *DeploymentTransition) Marshal() ([]byte, error)
Marshal an object of type DeploymentTransition to the protobuf v3 wire format
func (*DeploymentTransition) ProtoMessage ¶ added in v1.43.0
func (*DeploymentTransition) ProtoMessage()
func (*DeploymentTransition) ProtoReflect ¶ added in v1.43.0
func (x *DeploymentTransition) ProtoReflect() protoreflect.Message
func (*DeploymentTransition) Reset ¶ added in v1.43.0
func (x *DeploymentTransition) Reset()
func (*DeploymentTransition) Size ¶ added in v1.43.0
func (val *DeploymentTransition) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentTransition) String ¶ added in v1.43.0
func (x *DeploymentTransition) String() string
func (*DeploymentTransition) Unmarshal ¶ added in v1.43.0
func (val *DeploymentTransition) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentTransition from the protobuf v3 wire format
type DeploymentVersionTransition ¶ added in v1.44.0
type DeploymentVersionTransition struct {
// Deprecated. Use `deployment_version`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
// The target Version of the transition.
// If nil, a so-far-versioned workflow is transitioning to unversioned workers.
DeploymentVersion *v12.WorkerDeploymentVersion `protobuf:"bytes,2,opt,name=deployment_version,json=deploymentVersion,proto3" json:"deployment_version,omitempty"`
// contains filtered or unexported fields
}
Holds information about ongoing transition of a workflow execution from one worker deployment version to another. Experimental. Might change in the future.
func (*DeploymentVersionTransition) Descriptor
deprecated
added in
v1.44.0
func (*DeploymentVersionTransition) Descriptor() ([]byte, []int)
Deprecated: Use DeploymentVersionTransition.ProtoReflect.Descriptor instead.
func (*DeploymentVersionTransition) Equal ¶ added in v1.44.0
func (this *DeploymentVersionTransition) Equal(that interface{}) bool
Equal returns whether two DeploymentVersionTransition values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*DeploymentVersionTransition) GetDeploymentVersion ¶ added in v1.49.1
func (x *DeploymentVersionTransition) GetDeploymentVersion() *v12.WorkerDeploymentVersion
func (*DeploymentVersionTransition) GetVersion
deprecated
added in
v1.44.0
func (x *DeploymentVersionTransition) GetVersion() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*DeploymentVersionTransition) Marshal ¶ added in v1.44.0
func (val *DeploymentVersionTransition) Marshal() ([]byte, error)
Marshal an object of type DeploymentVersionTransition to the protobuf v3 wire format
func (*DeploymentVersionTransition) ProtoMessage ¶ added in v1.44.0
func (*DeploymentVersionTransition) ProtoMessage()
func (*DeploymentVersionTransition) ProtoReflect ¶ added in v1.44.0
func (x *DeploymentVersionTransition) ProtoReflect() protoreflect.Message
func (*DeploymentVersionTransition) Reset ¶ added in v1.44.0
func (x *DeploymentVersionTransition) Reset()
func (*DeploymentVersionTransition) Size ¶ added in v1.44.0
func (val *DeploymentVersionTransition) Size() int
Size returns the size of the object, in bytes, once serialized
func (*DeploymentVersionTransition) String ¶ added in v1.44.0
func (x *DeploymentVersionTransition) String() string
func (*DeploymentVersionTransition) Unmarshal ¶ added in v1.44.0
func (val *DeploymentVersionTransition) Unmarshal(buf []byte) error
Unmarshal an object of type DeploymentVersionTransition from the protobuf v3 wire format
type NewWorkflowExecutionInfo ¶ added in v1.8.0
type NewWorkflowExecutionInfo struct {
WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
WorkflowType *v1.WorkflowType `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
TaskQueue *v13.TaskQueue `protobuf:"bytes,3,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
// Serialized arguments to the workflow.
Input *v1.Payloads `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
// Total workflow execution timeout including retries and continue as new.
WorkflowExecutionTimeout *durationpb.Duration `` /* 135-byte string literal not displayed */
// Timeout of a single workflow run.
WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
// Timeout of a single workflow task.
WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 178-byte string literal not displayed */
// The retry policy for the workflow. Will never exceed `workflow_execution_timeout`.
RetryPolicy *v1.RetryPolicy `protobuf:"bytes,9,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
// See https://docs.temporal.io/docs/content/what-is-a-temporal-cron-job/
CronSchedule string `protobuf:"bytes,10,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
Memo *v1.Memo `protobuf:"bytes,11,opt,name=memo,proto3" json:"memo,omitempty"`
SearchAttributes *v1.SearchAttributes `protobuf:"bytes,12,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
Header *v1.Header `protobuf:"bytes,13,opt,name=header,proto3" json:"header,omitempty"`
// Metadata on the workflow if it is started. This is carried over to the WorkflowExecutionConfig
// for use by user interfaces to display the fixed as-of-start summary and details of the
// workflow.
UserMetadata *v14.UserMetadata `protobuf:"bytes,14,opt,name=user_metadata,json=userMetadata,proto3" json:"user_metadata,omitempty"`
// If set, takes precedence over the Versioning Behavior sent by the SDK on Workflow Task completion.
// To unset the override after the workflow is running, use UpdateWorkflowExecutionOptions.
VersioningOverride *VersioningOverride `protobuf:"bytes,15,opt,name=versioning_override,json=versioningOverride,proto3" json:"versioning_override,omitempty"`
// Priority metadata
Priority *v1.Priority `protobuf:"bytes,16,opt,name=priority,proto3" json:"priority,omitempty"`
// contains filtered or unexported fields
}
NewWorkflowExecutionInfo is a shared message that encapsulates all the required arguments to starting a workflow in different contexts.
func (*NewWorkflowExecutionInfo) Descriptor
deprecated
added in
v1.8.0
func (*NewWorkflowExecutionInfo) Descriptor() ([]byte, []int)
Deprecated: Use NewWorkflowExecutionInfo.ProtoReflect.Descriptor instead.
func (*NewWorkflowExecutionInfo) Equal ¶ added in v1.8.0
func (this *NewWorkflowExecutionInfo) Equal(that interface{}) bool
Equal returns whether two NewWorkflowExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*NewWorkflowExecutionInfo) GetCronSchedule ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetCronSchedule() string
func (*NewWorkflowExecutionInfo) GetHeader ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetHeader() *v1.Header
func (*NewWorkflowExecutionInfo) GetInput ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetInput() *v1.Payloads
func (*NewWorkflowExecutionInfo) GetMemo ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetMemo() *v1.Memo
func (*NewWorkflowExecutionInfo) GetPriority ¶ added in v1.46.0
func (x *NewWorkflowExecutionInfo) GetPriority() *v1.Priority
func (*NewWorkflowExecutionInfo) GetRetryPolicy ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetRetryPolicy() *v1.RetryPolicy
func (*NewWorkflowExecutionInfo) GetSearchAttributes ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes
func (*NewWorkflowExecutionInfo) GetTaskQueue ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetTaskQueue() *v13.TaskQueue
func (*NewWorkflowExecutionInfo) GetUserMetadata ¶ added in v1.34.0
func (x *NewWorkflowExecutionInfo) GetUserMetadata() *v14.UserMetadata
func (*NewWorkflowExecutionInfo) GetVersioningOverride ¶ added in v1.43.0
func (x *NewWorkflowExecutionInfo) GetVersioningOverride() *VersioningOverride
func (*NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout() *durationpb.Duration
func (*NewWorkflowExecutionInfo) GetWorkflowId ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetWorkflowId() string
func (*NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy
func (*NewWorkflowExecutionInfo) GetWorkflowRunTimeout ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetWorkflowRunTimeout() *durationpb.Duration
func (*NewWorkflowExecutionInfo) GetWorkflowTaskTimeout ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetWorkflowTaskTimeout() *durationpb.Duration
func (*NewWorkflowExecutionInfo) GetWorkflowType ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) GetWorkflowType() *v1.WorkflowType
func (*NewWorkflowExecutionInfo) Marshal ¶ added in v1.8.0
func (val *NewWorkflowExecutionInfo) Marshal() ([]byte, error)
Marshal an object of type NewWorkflowExecutionInfo to the protobuf v3 wire format
func (*NewWorkflowExecutionInfo) ProtoMessage ¶ added in v1.8.0
func (*NewWorkflowExecutionInfo) ProtoMessage()
func (*NewWorkflowExecutionInfo) ProtoReflect ¶ added in v1.26.1
func (x *NewWorkflowExecutionInfo) ProtoReflect() protoreflect.Message
func (*NewWorkflowExecutionInfo) Reset ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) Reset()
func (*NewWorkflowExecutionInfo) Size ¶ added in v1.8.0
func (val *NewWorkflowExecutionInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*NewWorkflowExecutionInfo) String ¶ added in v1.8.0
func (x *NewWorkflowExecutionInfo) String() string
func (*NewWorkflowExecutionInfo) Unmarshal ¶ added in v1.8.0
func (val *NewWorkflowExecutionInfo) Unmarshal(buf []byte) error
Unmarshal an object of type NewWorkflowExecutionInfo from the protobuf v3 wire format
type NexusOperationCancellationInfo ¶ added in v1.32.1
type NexusOperationCancellationInfo struct {
// The time when cancellation was requested.
RequestedTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=requested_time,json=requestedTime,proto3" json:"requested_time,omitempty"`
State v11.NexusOperationCancellationState `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.api.enums.v1.NexusOperationCancellationState" json:"state,omitempty"`
// The number of attempts made to deliver the cancel operation request.
// This number represents a minimum bound since the attempt is incremented after the request completes.
Attempt int32 `protobuf:"varint,3,opt,name=attempt,proto3" json:"attempt,omitempty"`
// The time when the last attempt completed.
LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
// The last attempt's failure, if any.
LastAttemptFailure *v15.Failure `protobuf:"bytes,5,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
// The time when the next attempt is scheduled.
NextAttemptScheduleTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
// If the state is BLOCKED, blocked reason provides additional information.
BlockedReason string `protobuf:"bytes,7,opt,name=blocked_reason,json=blockedReason,proto3" json:"blocked_reason,omitempty"`
// contains filtered or unexported fields
}
NexusOperationCancellationInfo contains the state of a nexus operation cancellation.
func (*NexusOperationCancellationInfo) Descriptor
deprecated
added in
v1.32.1
func (*NexusOperationCancellationInfo) Descriptor() ([]byte, []int)
Deprecated: Use NexusOperationCancellationInfo.ProtoReflect.Descriptor instead.
func (*NexusOperationCancellationInfo) Equal ¶ added in v1.32.1
func (this *NexusOperationCancellationInfo) Equal(that interface{}) bool
Equal returns whether two NexusOperationCancellationInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*NexusOperationCancellationInfo) GetAttempt ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) GetAttempt() int32
func (*NexusOperationCancellationInfo) GetBlockedReason ¶ added in v1.42.0
func (x *NexusOperationCancellationInfo) GetBlockedReason() string
func (*NexusOperationCancellationInfo) GetLastAttemptCompleteTime ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
func (*NexusOperationCancellationInfo) GetLastAttemptFailure ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) GetLastAttemptFailure() *v15.Failure
func (*NexusOperationCancellationInfo) GetNextAttemptScheduleTime ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
func (*NexusOperationCancellationInfo) GetRequestedTime ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) GetRequestedTime() *timestamppb.Timestamp
func (*NexusOperationCancellationInfo) GetState ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) GetState() v11.NexusOperationCancellationState
func (*NexusOperationCancellationInfo) Marshal ¶ added in v1.32.1
func (val *NexusOperationCancellationInfo) Marshal() ([]byte, error)
Marshal an object of type NexusOperationCancellationInfo to the protobuf v3 wire format
func (*NexusOperationCancellationInfo) ProtoMessage ¶ added in v1.32.1
func (*NexusOperationCancellationInfo) ProtoMessage()
func (*NexusOperationCancellationInfo) ProtoReflect ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) ProtoReflect() protoreflect.Message
func (*NexusOperationCancellationInfo) Reset ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) Reset()
func (*NexusOperationCancellationInfo) Size ¶ added in v1.32.1
func (val *NexusOperationCancellationInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*NexusOperationCancellationInfo) String ¶ added in v1.32.1
func (x *NexusOperationCancellationInfo) String() string
func (*NexusOperationCancellationInfo) Unmarshal ¶ added in v1.32.1
func (val *NexusOperationCancellationInfo) Unmarshal(buf []byte) error
Unmarshal an object of type NexusOperationCancellationInfo from the protobuf v3 wire format
type OnConflictOptions ¶ added in v1.44.0
type OnConflictOptions struct {
// Attaches the request ID to the running workflow.
AttachRequestId bool `protobuf:"varint,1,opt,name=attach_request_id,json=attachRequestId,proto3" json:"attach_request_id,omitempty"`
// Attaches the completion callbacks to the running workflow.
AttachCompletionCallbacks bool `` /* 139-byte string literal not displayed */
// Attaches the links to the WorkflowExecutionOptionsUpdatedEvent history event.
AttachLinks bool `protobuf:"varint,3,opt,name=attach_links,json=attachLinks,proto3" json:"attach_links,omitempty"`
// contains filtered or unexported fields
}
When StartWorkflowExecution uses the conflict policy WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING and there is already an existing running workflow, OnConflictOptions defines actions to be taken on the existing running workflow. In this case, it will create a WorkflowExecutionOptionsUpdatedEvent history event in the running workflow with the changes requested in this object.
func (*OnConflictOptions) Descriptor
deprecated
added in
v1.44.0
func (*OnConflictOptions) Descriptor() ([]byte, []int)
Deprecated: Use OnConflictOptions.ProtoReflect.Descriptor instead.
func (*OnConflictOptions) Equal ¶ added in v1.44.0
func (this *OnConflictOptions) Equal(that interface{}) bool
Equal returns whether two OnConflictOptions values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*OnConflictOptions) GetAttachCompletionCallbacks ¶ added in v1.44.0
func (x *OnConflictOptions) GetAttachCompletionCallbacks() bool
func (*OnConflictOptions) GetAttachLinks ¶ added in v1.44.0
func (x *OnConflictOptions) GetAttachLinks() bool
func (*OnConflictOptions) GetAttachRequestId ¶ added in v1.44.0
func (x *OnConflictOptions) GetAttachRequestId() bool
func (*OnConflictOptions) Marshal ¶ added in v1.44.0
func (val *OnConflictOptions) Marshal() ([]byte, error)
Marshal an object of type OnConflictOptions to the protobuf v3 wire format
func (*OnConflictOptions) ProtoMessage ¶ added in v1.44.0
func (*OnConflictOptions) ProtoMessage()
func (*OnConflictOptions) ProtoReflect ¶ added in v1.44.0
func (x *OnConflictOptions) ProtoReflect() protoreflect.Message
func (*OnConflictOptions) Reset ¶ added in v1.44.0
func (x *OnConflictOptions) Reset()
func (*OnConflictOptions) Size ¶ added in v1.44.0
func (val *OnConflictOptions) Size() int
Size returns the size of the object, in bytes, once serialized
func (*OnConflictOptions) String ¶ added in v1.44.0
func (x *OnConflictOptions) String() string
func (*OnConflictOptions) Unmarshal ¶ added in v1.44.0
func (val *OnConflictOptions) Unmarshal(buf []byte) error
Unmarshal an object of type OnConflictOptions from the protobuf v3 wire format
type PendingActivityInfo ¶
type PendingActivityInfo struct {
ActivityId string `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
ActivityType *v1.ActivityType `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
State v11.PendingActivityState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingActivityState" json:"state,omitempty"`
HeartbeatDetails *v1.Payloads `protobuf:"bytes,4,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
LastHeartbeatTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
LastStartedTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_started_time,json=lastStartedTime,proto3" json:"last_started_time,omitempty"`
Attempt int32 `protobuf:"varint,7,opt,name=attempt,proto3" json:"attempt,omitempty"`
MaximumAttempts int32 `protobuf:"varint,8,opt,name=maximum_attempts,json=maximumAttempts,proto3" json:"maximum_attempts,omitempty"`
ScheduledTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
LastFailure *v15.Failure `protobuf:"bytes,11,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
LastWorkerIdentity string `protobuf:"bytes,12,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
// Absence of `assigned_build_id` generally means this task is on an "unversioned" task queue.
// In rare cases, it can also mean that the task queue is versioned but we failed to write activity's
// independently-assigned build ID to the database. This case heals automatically once the task is dispatched.
// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
//
// Types that are valid to be assigned to AssignedBuildId:
//
// *PendingActivityInfo_UseWorkflowBuildId
// *PendingActivityInfo_LastIndependentlyAssignedBuildId
AssignedBuildId isPendingActivityInfo_AssignedBuildId `protobuf_oneof:"assigned_build_id"`
// Deprecated. The version stamp of the worker to whom this activity was most recently dispatched
// This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
LastWorkerVersionStamp *v1.WorkerVersionStamp `` /* 132-byte string literal not displayed */
// The time activity will wait until the next retry.
// If activity is currently running it will be next retry interval if activity failed.
// If activity is currently waiting it will be current retry interval.
// If there will be no retry it will be null.
CurrentRetryInterval *durationpb.Duration `protobuf:"bytes,16,opt,name=current_retry_interval,json=currentRetryInterval,proto3" json:"current_retry_interval,omitempty"`
// The time when the last activity attempt was completed. If activity has not been completed yet then it will be null.
LastAttemptCompleteTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
// Next time when activity will be scheduled.
// If activity is currently scheduled or started it will be null.
NextAttemptScheduleTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
// Indicates if activity is paused.
Paused bool `protobuf:"varint,19,opt,name=paused,proto3" json:"paused,omitempty"`
// The deployment this activity was dispatched to most recently. Present only if the activity
// was dispatched to a versioned worker.
// Deprecated. Use `last_deployment_version`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
LastDeployment *v12.Deployment `protobuf:"bytes,20,opt,name=last_deployment,json=lastDeployment,proto3" json:"last_deployment,omitempty"`
// The Worker Deployment Version this activity was dispatched to most recently.
// Deprecated. Use `last_deployment_version`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
LastWorkerDeploymentVersion string `` /* 147-byte string literal not displayed */
// The Worker Deployment Version this activity was dispatched to most recently.
// If nil, the activity has not yet been dispatched or was last dispatched to an unversioned worker.
LastDeploymentVersion *v12.WorkerDeploymentVersion `` /* 127-byte string literal not displayed */
// Priority metadata. If this message is not present, or any fields are not
// present, they inherit the values from the workflow.
Priority *v1.Priority `protobuf:"bytes,22,opt,name=priority,proto3" json:"priority,omitempty"`
PauseInfo *PendingActivityInfo_PauseInfo `protobuf:"bytes,23,opt,name=pause_info,json=pauseInfo,proto3" json:"pause_info,omitempty"`
// Current activity options. May be different from the one used to start the activity.
ActivityOptions *v16.ActivityOptions `protobuf:"bytes,24,opt,name=activity_options,json=activityOptions,proto3" json:"activity_options,omitempty"`
// contains filtered or unexported fields
}
func (*PendingActivityInfo) Descriptor
deprecated
func (*PendingActivityInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingActivityInfo.ProtoReflect.Descriptor instead.
func (*PendingActivityInfo) Equal ¶
func (this *PendingActivityInfo) Equal(that interface{}) bool
Equal returns whether two PendingActivityInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*PendingActivityInfo) GetActivityId ¶
func (x *PendingActivityInfo) GetActivityId() string
func (*PendingActivityInfo) GetActivityOptions ¶ added in v1.49.1
func (x *PendingActivityInfo) GetActivityOptions() *v16.ActivityOptions
func (*PendingActivityInfo) GetActivityType ¶
func (x *PendingActivityInfo) GetActivityType() *v1.ActivityType
func (*PendingActivityInfo) GetAssignedBuildId ¶ added in v1.32.0
func (x *PendingActivityInfo) GetAssignedBuildId() isPendingActivityInfo_AssignedBuildId
func (*PendingActivityInfo) GetAttempt ¶
func (x *PendingActivityInfo) GetAttempt() int32
func (*PendingActivityInfo) GetCurrentRetryInterval ¶ added in v1.40.0
func (x *PendingActivityInfo) GetCurrentRetryInterval() *durationpb.Duration
func (*PendingActivityInfo) GetExpirationTime ¶ added in v0.28.0
func (x *PendingActivityInfo) GetExpirationTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetHeartbeatDetails ¶
func (x *PendingActivityInfo) GetHeartbeatDetails() *v1.Payloads
func (*PendingActivityInfo) GetLastAttemptCompleteTime ¶ added in v1.40.0
func (x *PendingActivityInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetLastDeployment
deprecated
added in
v1.43.0
func (x *PendingActivityInfo) GetLastDeployment() *v12.Deployment
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*PendingActivityInfo) GetLastDeploymentVersion ¶ added in v1.49.1
func (x *PendingActivityInfo) GetLastDeploymentVersion() *v12.WorkerDeploymentVersion
func (*PendingActivityInfo) GetLastFailure ¶
func (x *PendingActivityInfo) GetLastFailure() *v15.Failure
func (*PendingActivityInfo) GetLastHeartbeatTime ¶ added in v0.28.0
func (x *PendingActivityInfo) GetLastHeartbeatTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetLastIndependentlyAssignedBuildId
deprecated
added in
v1.32.0
func (x *PendingActivityInfo) GetLastIndependentlyAssignedBuildId() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*PendingActivityInfo) GetLastStartedTime ¶ added in v0.28.0
func (x *PendingActivityInfo) GetLastStartedTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetLastWorkerDeploymentVersion
deprecated
added in
v1.44.0
func (x *PendingActivityInfo) GetLastWorkerDeploymentVersion() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*PendingActivityInfo) GetLastWorkerIdentity ¶
func (x *PendingActivityInfo) GetLastWorkerIdentity() string
func (*PendingActivityInfo) GetLastWorkerVersionStamp
deprecated
added in
v1.32.0
func (x *PendingActivityInfo) GetLastWorkerVersionStamp() *v1.WorkerVersionStamp
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*PendingActivityInfo) GetMaximumAttempts ¶
func (x *PendingActivityInfo) GetMaximumAttempts() int32
func (*PendingActivityInfo) GetNextAttemptScheduleTime ¶ added in v1.40.0
func (x *PendingActivityInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetPauseInfo ¶ added in v1.48.0
func (x *PendingActivityInfo) GetPauseInfo() *PendingActivityInfo_PauseInfo
func (*PendingActivityInfo) GetPaused ¶ added in v1.41.0
func (x *PendingActivityInfo) GetPaused() bool
func (*PendingActivityInfo) GetPriority ¶ added in v1.46.0
func (x *PendingActivityInfo) GetPriority() *v1.Priority
func (*PendingActivityInfo) GetScheduledTime ¶ added in v0.28.0
func (x *PendingActivityInfo) GetScheduledTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetState ¶
func (x *PendingActivityInfo) GetState() v11.PendingActivityState
func (*PendingActivityInfo) GetUseWorkflowBuildId
deprecated
added in
v1.32.0
func (x *PendingActivityInfo) GetUseWorkflowBuildId() *emptypb.Empty
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*PendingActivityInfo) Marshal ¶
func (val *PendingActivityInfo) Marshal() ([]byte, error)
Marshal an object of type PendingActivityInfo to the protobuf v3 wire format
func (*PendingActivityInfo) ProtoMessage ¶
func (*PendingActivityInfo) ProtoMessage()
func (*PendingActivityInfo) ProtoReflect ¶ added in v1.26.1
func (x *PendingActivityInfo) ProtoReflect() protoreflect.Message
func (*PendingActivityInfo) Reset ¶
func (x *PendingActivityInfo) Reset()
func (*PendingActivityInfo) Size ¶
func (val *PendingActivityInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*PendingActivityInfo) String ¶
func (x *PendingActivityInfo) String() string
func (*PendingActivityInfo) Unmarshal ¶
func (val *PendingActivityInfo) Unmarshal(buf []byte) error
Unmarshal an object of type PendingActivityInfo from the protobuf v3 wire format
type PendingActivityInfo_LastIndependentlyAssignedBuildId ¶ added in v1.32.0
type PendingActivityInfo_LastIndependentlyAssignedBuildId struct {
// Deprecated. This means the activity is independently versioned and not bound to the build ID of its workflow.
// The activity will use the build id in this field instead.
// If the task fails and is scheduled again, the assigned build ID may change according to the latest versioning
// rules.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
LastIndependentlyAssignedBuildId string `protobuf:"bytes,14,opt,name=last_independently_assigned_build_id,json=lastIndependentlyAssignedBuildId,proto3,oneof"`
}
type PendingActivityInfo_PauseInfo ¶ added in v1.48.0
type PendingActivityInfo_PauseInfo struct {
// The time when the activity was paused.
PauseTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=pause_time,json=pauseTime,proto3" json:"pause_time,omitempty"`
// Types that are valid to be assigned to PausedBy:
//
// *PendingActivityInfo_PauseInfo_Manual_
// *PendingActivityInfo_PauseInfo_Rule_
PausedBy isPendingActivityInfo_PauseInfo_PausedBy `protobuf_oneof:"paused_by"`
// contains filtered or unexported fields
}
func (*PendingActivityInfo_PauseInfo) Descriptor
deprecated
added in
v1.48.0
func (*PendingActivityInfo_PauseInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingActivityInfo_PauseInfo.ProtoReflect.Descriptor instead.
func (*PendingActivityInfo_PauseInfo) GetManual ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo) GetManual() *PendingActivityInfo_PauseInfo_Manual
func (*PendingActivityInfo_PauseInfo) GetPauseTime ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo) GetPauseTime() *timestamppb.Timestamp
func (*PendingActivityInfo_PauseInfo) GetPausedBy ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo) GetPausedBy() isPendingActivityInfo_PauseInfo_PausedBy
func (*PendingActivityInfo_PauseInfo) GetRule ¶ added in v1.49.0
func (x *PendingActivityInfo_PauseInfo) GetRule() *PendingActivityInfo_PauseInfo_Rule
func (*PendingActivityInfo_PauseInfo) ProtoMessage ¶ added in v1.48.0
func (*PendingActivityInfo_PauseInfo) ProtoMessage()
func (*PendingActivityInfo_PauseInfo) ProtoReflect ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo) ProtoReflect() protoreflect.Message
func (*PendingActivityInfo_PauseInfo) Reset ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo) Reset()
func (*PendingActivityInfo_PauseInfo) String ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo) String() string
type PendingActivityInfo_PauseInfo_Manual ¶ added in v1.48.0
type PendingActivityInfo_PauseInfo_Manual struct {
// The identity of the actor that paused the activity.
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
// Reason for pausing the activity.
Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*PendingActivityInfo_PauseInfo_Manual) Descriptor
deprecated
added in
v1.48.0
func (*PendingActivityInfo_PauseInfo_Manual) Descriptor() ([]byte, []int)
Deprecated: Use PendingActivityInfo_PauseInfo_Manual.ProtoReflect.Descriptor instead.
func (*PendingActivityInfo_PauseInfo_Manual) GetIdentity ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo_Manual) GetIdentity() string
func (*PendingActivityInfo_PauseInfo_Manual) GetReason ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo_Manual) GetReason() string
func (*PendingActivityInfo_PauseInfo_Manual) ProtoMessage ¶ added in v1.48.0
func (*PendingActivityInfo_PauseInfo_Manual) ProtoMessage()
func (*PendingActivityInfo_PauseInfo_Manual) ProtoReflect ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo_Manual) ProtoReflect() protoreflect.Message
func (*PendingActivityInfo_PauseInfo_Manual) Reset ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo_Manual) Reset()
func (*PendingActivityInfo_PauseInfo_Manual) String ¶ added in v1.48.0
func (x *PendingActivityInfo_PauseInfo_Manual) String() string
type PendingActivityInfo_PauseInfo_Manual_ ¶ added in v1.48.0
type PendingActivityInfo_PauseInfo_Manual_ struct {
// activity was paused by the manual intervention
Manual *PendingActivityInfo_PauseInfo_Manual `protobuf:"bytes,2,opt,name=manual,proto3,oneof"`
}
type PendingActivityInfo_PauseInfo_Rule ¶ added in v1.49.0
type PendingActivityInfo_PauseInfo_Rule struct {
// The rule that paused the activity.
RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
// The identity of the actor that created the rule.
Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
// Reason why rule was created. Populated from rule description.
Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*PendingActivityInfo_PauseInfo_Rule) Descriptor
deprecated
added in
v1.49.0
func (*PendingActivityInfo_PauseInfo_Rule) Descriptor() ([]byte, []int)
Deprecated: Use PendingActivityInfo_PauseInfo_Rule.ProtoReflect.Descriptor instead.
func (*PendingActivityInfo_PauseInfo_Rule) GetIdentity ¶ added in v1.49.0
func (x *PendingActivityInfo_PauseInfo_Rule) GetIdentity() string
func (*PendingActivityInfo_PauseInfo_Rule) GetReason ¶ added in v1.49.0
func (x *PendingActivityInfo_PauseInfo_Rule) GetReason() string
func (*PendingActivityInfo_PauseInfo_Rule) GetRuleId ¶ added in v1.49.0
func (x *PendingActivityInfo_PauseInfo_Rule) GetRuleId() string
func (*PendingActivityInfo_PauseInfo_Rule) ProtoMessage ¶ added in v1.49.0
func (*PendingActivityInfo_PauseInfo_Rule) ProtoMessage()
func (*PendingActivityInfo_PauseInfo_Rule) ProtoReflect ¶ added in v1.49.0
func (x *PendingActivityInfo_PauseInfo_Rule) ProtoReflect() protoreflect.Message
func (*PendingActivityInfo_PauseInfo_Rule) Reset ¶ added in v1.49.0
func (x *PendingActivityInfo_PauseInfo_Rule) Reset()
func (*PendingActivityInfo_PauseInfo_Rule) String ¶ added in v1.49.0
func (x *PendingActivityInfo_PauseInfo_Rule) String() string
type PendingActivityInfo_PauseInfo_Rule_ ¶ added in v1.49.0
type PendingActivityInfo_PauseInfo_Rule_ struct {
// activity was paused by the rule
Rule *PendingActivityInfo_PauseInfo_Rule `protobuf:"bytes,4,opt,name=rule,proto3,oneof"`
}
type PendingActivityInfo_UseWorkflowBuildId ¶ added in v1.32.0
type PendingActivityInfo_UseWorkflowBuildId struct {
// Deprecated. When present, it means this activity is assigned to the build ID of its workflow.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
UseWorkflowBuildId *emptypb.Empty `protobuf:"bytes,13,opt,name=use_workflow_build_id,json=useWorkflowBuildId,proto3,oneof"`
}
type PendingChildExecutionInfo ¶
type PendingChildExecutionInfo struct {
WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
WorkflowTypeName string `protobuf:"bytes,3,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
InitiatedId int64 `protobuf:"varint,4,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
// Default: PARENT_CLOSE_POLICY_TERMINATE.
ParentClosePolicy v11.ParentClosePolicy `` /* 160-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*PendingChildExecutionInfo) Descriptor
deprecated
func (*PendingChildExecutionInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingChildExecutionInfo.ProtoReflect.Descriptor instead.
func (*PendingChildExecutionInfo) Equal ¶
func (this *PendingChildExecutionInfo) Equal(that interface{}) bool
Equal returns whether two PendingChildExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*PendingChildExecutionInfo) GetInitiatedId ¶
func (x *PendingChildExecutionInfo) GetInitiatedId() int64
func (*PendingChildExecutionInfo) GetParentClosePolicy ¶
func (x *PendingChildExecutionInfo) GetParentClosePolicy() v11.ParentClosePolicy
func (*PendingChildExecutionInfo) GetRunId ¶
func (x *PendingChildExecutionInfo) GetRunId() string
func (*PendingChildExecutionInfo) GetWorkflowId ¶
func (x *PendingChildExecutionInfo) GetWorkflowId() string
func (*PendingChildExecutionInfo) GetWorkflowTypeName ¶
func (x *PendingChildExecutionInfo) GetWorkflowTypeName() string
func (*PendingChildExecutionInfo) Marshal ¶
func (val *PendingChildExecutionInfo) Marshal() ([]byte, error)
Marshal an object of type PendingChildExecutionInfo to the protobuf v3 wire format
func (*PendingChildExecutionInfo) ProtoMessage ¶
func (*PendingChildExecutionInfo) ProtoMessage()
func (*PendingChildExecutionInfo) ProtoReflect ¶ added in v1.26.1
func (x *PendingChildExecutionInfo) ProtoReflect() protoreflect.Message
func (*PendingChildExecutionInfo) Reset ¶
func (x *PendingChildExecutionInfo) Reset()
func (*PendingChildExecutionInfo) Size ¶
func (val *PendingChildExecutionInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*PendingChildExecutionInfo) String ¶
func (x *PendingChildExecutionInfo) String() string
func (*PendingChildExecutionInfo) Unmarshal ¶
func (val *PendingChildExecutionInfo) Unmarshal(buf []byte) error
Unmarshal an object of type PendingChildExecutionInfo from the protobuf v3 wire format
type PendingNexusOperationInfo ¶ added in v1.32.1
type PendingNexusOperationInfo struct {
// Endpoint name.
// Resolved to a URL via the cluster's endpoint registry.
Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
// Service name.
Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
// Operation name.
Operation string `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
// Operation ID. Only set for asynchronous operations after a successful StartOperation call.
//
// Deprecated. Renamed to operation_token.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
OperationId string `protobuf:"bytes,4,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
// Schedule-to-close timeout for this operation.
// This is the only timeout settable by a workflow.
// (-- api-linter: core::0140::prepositions=disabled
//
// aip.dev/not-precedent: "to" is used to indicate interval. --)
ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
// The time when the operation was scheduled.
ScheduledTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
State v11.PendingNexusOperationState `protobuf:"varint,7,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingNexusOperationState" json:"state,omitempty"`
// The number of attempts made to deliver the start operation request.
// This number represents a minimum bound since the attempt is incremented after the request completes.
Attempt int32 `protobuf:"varint,8,opt,name=attempt,proto3" json:"attempt,omitempty"`
// The time when the last attempt completed.
LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
// The last attempt's failure, if any.
LastAttemptFailure *v15.Failure `protobuf:"bytes,10,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
// The time when the next attempt is scheduled.
NextAttemptScheduleTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
CancellationInfo *NexusOperationCancellationInfo `protobuf:"bytes,12,opt,name=cancellation_info,json=cancellationInfo,proto3" json:"cancellation_info,omitempty"`
// The event ID of the NexusOperationScheduled event. Can be used to correlate an operation in the
// DescribeWorkflowExecution response with workflow history.
ScheduledEventId int64 `protobuf:"varint,13,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
// If the state is BLOCKED, blocked reason provides additional information.
BlockedReason string `protobuf:"bytes,14,opt,name=blocked_reason,json=blockedReason,proto3" json:"blocked_reason,omitempty"`
// Operation token. Only set for asynchronous operations after a successful StartOperation call.
OperationToken string `protobuf:"bytes,15,opt,name=operation_token,json=operationToken,proto3" json:"operation_token,omitempty"`
// contains filtered or unexported fields
}
PendingNexusOperationInfo contains the state of a pending Nexus operation.
func (*PendingNexusOperationInfo) Descriptor
deprecated
added in
v1.32.1
func (*PendingNexusOperationInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingNexusOperationInfo.ProtoReflect.Descriptor instead.
func (*PendingNexusOperationInfo) Equal ¶ added in v1.32.1
func (this *PendingNexusOperationInfo) Equal(that interface{}) bool
Equal returns whether two PendingNexusOperationInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*PendingNexusOperationInfo) GetAttempt ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetAttempt() int32
func (*PendingNexusOperationInfo) GetBlockedReason ¶ added in v1.42.0
func (x *PendingNexusOperationInfo) GetBlockedReason() string
func (*PendingNexusOperationInfo) GetCancellationInfo ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetCancellationInfo() *NexusOperationCancellationInfo
func (*PendingNexusOperationInfo) GetEndpoint ¶ added in v1.33.0
func (x *PendingNexusOperationInfo) GetEndpoint() string
func (*PendingNexusOperationInfo) GetLastAttemptCompleteTime ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
func (*PendingNexusOperationInfo) GetLastAttemptFailure ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetLastAttemptFailure() *v15.Failure
func (*PendingNexusOperationInfo) GetNextAttemptScheduleTime ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
func (*PendingNexusOperationInfo) GetOperation ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetOperation() string
func (*PendingNexusOperationInfo) GetOperationId
deprecated
added in
v1.32.1
func (x *PendingNexusOperationInfo) GetOperationId() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*PendingNexusOperationInfo) GetOperationToken ¶ added in v1.44.0
func (x *PendingNexusOperationInfo) GetOperationToken() string
func (*PendingNexusOperationInfo) GetScheduleToCloseTimeout ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetScheduleToCloseTimeout() *durationpb.Duration
func (*PendingNexusOperationInfo) GetScheduledEventId ¶ added in v1.36.0
func (x *PendingNexusOperationInfo) GetScheduledEventId() int64
func (*PendingNexusOperationInfo) GetScheduledTime ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetScheduledTime() *timestamppb.Timestamp
func (*PendingNexusOperationInfo) GetService ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetService() string
func (*PendingNexusOperationInfo) GetState ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) GetState() v11.PendingNexusOperationState
func (*PendingNexusOperationInfo) Marshal ¶ added in v1.32.1
func (val *PendingNexusOperationInfo) Marshal() ([]byte, error)
Marshal an object of type PendingNexusOperationInfo to the protobuf v3 wire format
func (*PendingNexusOperationInfo) ProtoMessage ¶ added in v1.32.1
func (*PendingNexusOperationInfo) ProtoMessage()
func (*PendingNexusOperationInfo) ProtoReflect ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) ProtoReflect() protoreflect.Message
func (*PendingNexusOperationInfo) Reset ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) Reset()
func (*PendingNexusOperationInfo) Size ¶ added in v1.32.1
func (val *PendingNexusOperationInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*PendingNexusOperationInfo) String ¶ added in v1.32.1
func (x *PendingNexusOperationInfo) String() string
func (*PendingNexusOperationInfo) Unmarshal ¶ added in v1.32.1
func (val *PendingNexusOperationInfo) Unmarshal(buf []byte) error
Unmarshal an object of type PendingNexusOperationInfo from the protobuf v3 wire format
type PendingWorkflowTaskInfo ¶ added in v1.8.0
type PendingWorkflowTaskInfo struct {
State v11.PendingWorkflowTaskState `protobuf:"varint,1,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingWorkflowTaskState" json:"state,omitempty"`
ScheduledTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
// original_scheduled_time is the scheduled time of the first workflow task during workflow task heartbeat.
// Heartbeat workflow task is done by RespondWorkflowTaskComplete with ForceCreateNewWorkflowTask == true and no command
// In this case, OriginalScheduledTime won't change. Then when current time - original_scheduled_time exceeds
// some threshold, the workflow task will be forced timeout.
OriginalScheduledTime *timestamppb.Timestamp `` /* 126-byte string literal not displayed */
StartedTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
Attempt int32 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
// contains filtered or unexported fields
}
func (*PendingWorkflowTaskInfo) Descriptor
deprecated
added in
v1.8.0
func (*PendingWorkflowTaskInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingWorkflowTaskInfo.ProtoReflect.Descriptor instead.
func (*PendingWorkflowTaskInfo) Equal ¶ added in v1.8.0
func (this *PendingWorkflowTaskInfo) Equal(that interface{}) bool
Equal returns whether two PendingWorkflowTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*PendingWorkflowTaskInfo) GetAttempt ¶ added in v1.8.0
func (x *PendingWorkflowTaskInfo) GetAttempt() int32
func (*PendingWorkflowTaskInfo) GetOriginalScheduledTime ¶ added in v1.8.0
func (x *PendingWorkflowTaskInfo) GetOriginalScheduledTime() *timestamppb.Timestamp
func (*PendingWorkflowTaskInfo) GetScheduledTime ¶ added in v1.8.0
func (x *PendingWorkflowTaskInfo) GetScheduledTime() *timestamppb.Timestamp
func (*PendingWorkflowTaskInfo) GetStartedTime ¶ added in v1.8.0
func (x *PendingWorkflowTaskInfo) GetStartedTime() *timestamppb.Timestamp
func (*PendingWorkflowTaskInfo) GetState ¶ added in v1.8.0
func (x *PendingWorkflowTaskInfo) GetState() v11.PendingWorkflowTaskState
func (*PendingWorkflowTaskInfo) Marshal ¶ added in v1.8.0
func (val *PendingWorkflowTaskInfo) Marshal() ([]byte, error)
Marshal an object of type PendingWorkflowTaskInfo to the protobuf v3 wire format
func (*PendingWorkflowTaskInfo) ProtoMessage ¶ added in v1.8.0
func (*PendingWorkflowTaskInfo) ProtoMessage()
func (*PendingWorkflowTaskInfo) ProtoReflect ¶ added in v1.26.1
func (x *PendingWorkflowTaskInfo) ProtoReflect() protoreflect.Message
func (*PendingWorkflowTaskInfo) Reset ¶ added in v1.8.0
func (x *PendingWorkflowTaskInfo) Reset()
func (*PendingWorkflowTaskInfo) Size ¶ added in v1.8.0
func (val *PendingWorkflowTaskInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*PendingWorkflowTaskInfo) String ¶ added in v1.8.0
func (x *PendingWorkflowTaskInfo) String() string
func (*PendingWorkflowTaskInfo) Unmarshal ¶ added in v1.8.0
func (val *PendingWorkflowTaskInfo) Unmarshal(buf []byte) error
Unmarshal an object of type PendingWorkflowTaskInfo from the protobuf v3 wire format
type PostResetOperation ¶ added in v1.49.1
type PostResetOperation struct {
// Types that are valid to be assigned to Variant:
//
// *PostResetOperation_SignalWorkflow_
// *PostResetOperation_UpdateWorkflowOptions_
Variant isPostResetOperation_Variant `protobuf_oneof:"variant"`
// contains filtered or unexported fields
}
PostResetOperation represents an operation to be performed on the new workflow execution after a workflow reset.
func (*PostResetOperation) Descriptor
deprecated
added in
v1.49.1
func (*PostResetOperation) Descriptor() ([]byte, []int)
Deprecated: Use PostResetOperation.ProtoReflect.Descriptor instead.
func (*PostResetOperation) Equal ¶ added in v1.49.1
func (this *PostResetOperation) Equal(that interface{}) bool
Equal returns whether two PostResetOperation values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*PostResetOperation) GetSignalWorkflow ¶ added in v1.49.1
func (x *PostResetOperation) GetSignalWorkflow() *PostResetOperation_SignalWorkflow
func (*PostResetOperation) GetUpdateWorkflowOptions ¶ added in v1.49.1
func (x *PostResetOperation) GetUpdateWorkflowOptions() *PostResetOperation_UpdateWorkflowOptions
func (*PostResetOperation) GetVariant ¶ added in v1.49.1
func (x *PostResetOperation) GetVariant() isPostResetOperation_Variant
func (*PostResetOperation) Marshal ¶ added in v1.49.1
func (val *PostResetOperation) Marshal() ([]byte, error)
Marshal an object of type PostResetOperation to the protobuf v3 wire format
func (*PostResetOperation) ProtoMessage ¶ added in v1.49.1
func (*PostResetOperation) ProtoMessage()
func (*PostResetOperation) ProtoReflect ¶ added in v1.49.1
func (x *PostResetOperation) ProtoReflect() protoreflect.Message
func (*PostResetOperation) Reset ¶ added in v1.49.1
func (x *PostResetOperation) Reset()
func (*PostResetOperation) Size ¶ added in v1.49.1
func (val *PostResetOperation) Size() int
Size returns the size of the object, in bytes, once serialized
func (*PostResetOperation) String ¶ added in v1.49.1
func (x *PostResetOperation) String() string
func (*PostResetOperation) Unmarshal ¶ added in v1.49.1
func (val *PostResetOperation) Unmarshal(buf []byte) error
Unmarshal an object of type PostResetOperation from the protobuf v3 wire format
type PostResetOperation_SignalWorkflow ¶ added in v1.49.1
type PostResetOperation_SignalWorkflow struct {
// The workflow author-defined name of the signal to send to the workflow.
SignalName string `protobuf:"bytes,1,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
// Serialized value(s) to provide with the signal.
Input *v1.Payloads `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
// Headers that are passed with the signal to the processing workflow.
Header *v1.Header `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
// Links to be associated with the WorkflowExecutionSignaled event.
Links []*v1.Link `protobuf:"bytes,4,rep,name=links,proto3" json:"links,omitempty"`
// contains filtered or unexported fields
}
SignalWorkflow represents sending a signal after a workflow reset. Keep the parameter in sync with temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest.
func (*PostResetOperation_SignalWorkflow) Descriptor
deprecated
added in
v1.49.1
func (*PostResetOperation_SignalWorkflow) Descriptor() ([]byte, []int)
Deprecated: Use PostResetOperation_SignalWorkflow.ProtoReflect.Descriptor instead.
func (*PostResetOperation_SignalWorkflow) GetHeader ¶ added in v1.49.1
func (x *PostResetOperation_SignalWorkflow) GetHeader() *v1.Header
func (*PostResetOperation_SignalWorkflow) GetInput ¶ added in v1.49.1
func (x *PostResetOperation_SignalWorkflow) GetInput() *v1.Payloads
func (*PostResetOperation_SignalWorkflow) GetLinks ¶ added in v1.49.1
func (x *PostResetOperation_SignalWorkflow) GetLinks() []*v1.Link
func (*PostResetOperation_SignalWorkflow) GetSignalName ¶ added in v1.49.1
func (x *PostResetOperation_SignalWorkflow) GetSignalName() string
func (*PostResetOperation_SignalWorkflow) ProtoMessage ¶ added in v1.49.1
func (*PostResetOperation_SignalWorkflow) ProtoMessage()
func (*PostResetOperation_SignalWorkflow) ProtoReflect ¶ added in v1.49.1
func (x *PostResetOperation_SignalWorkflow) ProtoReflect() protoreflect.Message
func (*PostResetOperation_SignalWorkflow) Reset ¶ added in v1.49.1
func (x *PostResetOperation_SignalWorkflow) Reset()
func (*PostResetOperation_SignalWorkflow) String ¶ added in v1.49.1
func (x *PostResetOperation_SignalWorkflow) String() string
type PostResetOperation_SignalWorkflow_ ¶ added in v1.49.1
type PostResetOperation_SignalWorkflow_ struct {
SignalWorkflow *PostResetOperation_SignalWorkflow `protobuf:"bytes,1,opt,name=signal_workflow,json=signalWorkflow,proto3,oneof"`
}
type PostResetOperation_UpdateWorkflowOptions ¶ added in v1.49.1
type PostResetOperation_UpdateWorkflowOptions struct {
// Update Workflow options that were originally specified via StartWorkflowExecution. Partial updates are accepted and controlled by update_mask.
WorkflowExecutionOptions *WorkflowExecutionOptions `` /* 135-byte string literal not displayed */
// Controls which fields from `workflow_execution_options` will be applied.
// To unset a field, set it to null and use the update mask to indicate that it should be mutated.
UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
// contains filtered or unexported fields
}
UpdateWorkflowOptions represents updating workflow execution options after a workflow reset. Keep the parameters in sync with temporal.api.workflowservice.v1.UpdateWorkflowExecutionOptionsRequest.
func (*PostResetOperation_UpdateWorkflowOptions) Descriptor
deprecated
added in
v1.49.1
func (*PostResetOperation_UpdateWorkflowOptions) Descriptor() ([]byte, []int)
Deprecated: Use PostResetOperation_UpdateWorkflowOptions.ProtoReflect.Descriptor instead.
func (*PostResetOperation_UpdateWorkflowOptions) GetUpdateMask ¶ added in v1.49.1
func (x *PostResetOperation_UpdateWorkflowOptions) GetUpdateMask() *fieldmaskpb.FieldMask
func (*PostResetOperation_UpdateWorkflowOptions) GetWorkflowExecutionOptions ¶ added in v1.49.1
func (x *PostResetOperation_UpdateWorkflowOptions) GetWorkflowExecutionOptions() *WorkflowExecutionOptions
func (*PostResetOperation_UpdateWorkflowOptions) ProtoMessage ¶ added in v1.49.1
func (*PostResetOperation_UpdateWorkflowOptions) ProtoMessage()
func (*PostResetOperation_UpdateWorkflowOptions) ProtoReflect ¶ added in v1.49.1
func (x *PostResetOperation_UpdateWorkflowOptions) ProtoReflect() protoreflect.Message
func (*PostResetOperation_UpdateWorkflowOptions) Reset ¶ added in v1.49.1
func (x *PostResetOperation_UpdateWorkflowOptions) Reset()
func (*PostResetOperation_UpdateWorkflowOptions) String ¶ added in v1.49.1
func (x *PostResetOperation_UpdateWorkflowOptions) String() string
type PostResetOperation_UpdateWorkflowOptions_ ¶ added in v1.49.1
type PostResetOperation_UpdateWorkflowOptions_ struct {
UpdateWorkflowOptions *PostResetOperation_UpdateWorkflowOptions `protobuf:"bytes,2,opt,name=update_workflow_options,json=updateWorkflowOptions,proto3,oneof"`
}
type RequestIdInfo ¶ added in v1.49.0
type RequestIdInfo struct {
// The event type of the history event generated by the request.
EventType v11.EventType `` /* 126-byte string literal not displayed */
// The event id of the history event generated by the request. It's possible the event ID is not
// known (unflushed buffered event). In this case, the value will be zero or a negative value,
// representing an invalid ID.
EventId int64 `protobuf:"varint,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
// Indicate if the request is still buffered. If so, the event ID is not known and its value
// will be an invalid event ID.
Buffered bool `protobuf:"varint,3,opt,name=buffered,proto3" json:"buffered,omitempty"`
// contains filtered or unexported fields
}
RequestIdInfo contains details of a request ID.
func (*RequestIdInfo) Descriptor
deprecated
added in
v1.49.0
func (*RequestIdInfo) Descriptor() ([]byte, []int)
Deprecated: Use RequestIdInfo.ProtoReflect.Descriptor instead.
func (*RequestIdInfo) Equal ¶ added in v1.49.0
func (this *RequestIdInfo) Equal(that interface{}) bool
Equal returns whether two RequestIdInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*RequestIdInfo) GetBuffered ¶ added in v1.49.0
func (x *RequestIdInfo) GetBuffered() bool
func (*RequestIdInfo) GetEventId ¶ added in v1.49.0
func (x *RequestIdInfo) GetEventId() int64
func (*RequestIdInfo) GetEventType ¶ added in v1.49.0
func (x *RequestIdInfo) GetEventType() v11.EventType
func (*RequestIdInfo) Marshal ¶ added in v1.49.0
func (val *RequestIdInfo) Marshal() ([]byte, error)
Marshal an object of type RequestIdInfo to the protobuf v3 wire format
func (*RequestIdInfo) ProtoMessage ¶ added in v1.49.0
func (*RequestIdInfo) ProtoMessage()
func (*RequestIdInfo) ProtoReflect ¶ added in v1.49.0
func (x *RequestIdInfo) ProtoReflect() protoreflect.Message
func (*RequestIdInfo) Reset ¶ added in v1.49.0
func (x *RequestIdInfo) Reset()
func (*RequestIdInfo) Size ¶ added in v1.49.0
func (val *RequestIdInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*RequestIdInfo) String ¶ added in v1.49.0
func (x *RequestIdInfo) String() string
func (*RequestIdInfo) Unmarshal ¶ added in v1.49.0
func (val *RequestIdInfo) Unmarshal(buf []byte) error
Unmarshal an object of type RequestIdInfo from the protobuf v3 wire format
type ResetPointInfo ¶
type ResetPointInfo struct {
// Worker build id.
BuildId string `protobuf:"bytes,7,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
// Deprecated. A worker binary version identifier.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
BinaryChecksum string `protobuf:"bytes,1,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
// The first run ID in the execution chain that was touched by this worker build.
RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
// Event ID of the first WorkflowTaskCompleted event processed by this worker build.
FirstWorkflowTaskCompletedId int64 `` /* 152-byte string literal not displayed */
CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
// (-- api-linter: core::0214::resource-expiry=disabled
//
// aip.dev/not-precedent: TTL is not defined for ResetPointInfo. --)
//
// The time that the run is deleted due to retention.
ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
// false if the reset point has pending childWFs/reqCancels/signalExternals.
Resettable bool `protobuf:"varint,6,opt,name=resettable,proto3" json:"resettable,omitempty"`
// contains filtered or unexported fields
}
ResetPointInfo records the workflow event id that is the first one processed by a given build id or binary checksum. A new reset point will be created if either build id or binary checksum changes (although in general only one or the other will be used at a time).
func (*ResetPointInfo) Descriptor
deprecated
func (*ResetPointInfo) Descriptor() ([]byte, []int)
Deprecated: Use ResetPointInfo.ProtoReflect.Descriptor instead.
func (*ResetPointInfo) Equal ¶
func (this *ResetPointInfo) Equal(that interface{}) bool
Equal returns whether two ResetPointInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ResetPointInfo) GetBinaryChecksum
deprecated
func (x *ResetPointInfo) GetBinaryChecksum() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*ResetPointInfo) GetBuildId ¶ added in v1.26.2
func (x *ResetPointInfo) GetBuildId() string
func (*ResetPointInfo) GetCreateTime ¶ added in v0.28.0
func (x *ResetPointInfo) GetCreateTime() *timestamppb.Timestamp
func (*ResetPointInfo) GetExpireTime ¶ added in v0.28.0
func (x *ResetPointInfo) GetExpireTime() *timestamppb.Timestamp
func (*ResetPointInfo) GetFirstWorkflowTaskCompletedId ¶
func (x *ResetPointInfo) GetFirstWorkflowTaskCompletedId() int64
func (*ResetPointInfo) GetResettable ¶
func (x *ResetPointInfo) GetResettable() bool
func (*ResetPointInfo) GetRunId ¶
func (x *ResetPointInfo) GetRunId() string
func (*ResetPointInfo) Marshal ¶
func (val *ResetPointInfo) Marshal() ([]byte, error)
Marshal an object of type ResetPointInfo to the protobuf v3 wire format
func (*ResetPointInfo) ProtoMessage ¶
func (*ResetPointInfo) ProtoMessage()
func (*ResetPointInfo) ProtoReflect ¶ added in v1.26.1
func (x *ResetPointInfo) ProtoReflect() protoreflect.Message
func (*ResetPointInfo) Reset ¶
func (x *ResetPointInfo) Reset()
func (*ResetPointInfo) Size ¶
func (val *ResetPointInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ResetPointInfo) String ¶
func (x *ResetPointInfo) String() string
func (*ResetPointInfo) Unmarshal ¶
func (val *ResetPointInfo) Unmarshal(buf []byte) error
Unmarshal an object of type ResetPointInfo from the protobuf v3 wire format
type ResetPoints ¶
type ResetPoints struct {
Points []*ResetPointInfo `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
// contains filtered or unexported fields
}
func (*ResetPoints) Descriptor
deprecated
func (*ResetPoints) Descriptor() ([]byte, []int)
Deprecated: Use ResetPoints.ProtoReflect.Descriptor instead.
func (*ResetPoints) Equal ¶
func (this *ResetPoints) Equal(that interface{}) bool
Equal returns whether two ResetPoints values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*ResetPoints) GetPoints ¶
func (x *ResetPoints) GetPoints() []*ResetPointInfo
func (*ResetPoints) Marshal ¶
func (val *ResetPoints) Marshal() ([]byte, error)
Marshal an object of type ResetPoints to the protobuf v3 wire format
func (*ResetPoints) ProtoMessage ¶
func (*ResetPoints) ProtoMessage()
func (*ResetPoints) ProtoReflect ¶ added in v1.26.1
func (x *ResetPoints) ProtoReflect() protoreflect.Message
func (*ResetPoints) Reset ¶
func (x *ResetPoints) Reset()
func (*ResetPoints) Size ¶
func (val *ResetPoints) Size() int
Size returns the size of the object, in bytes, once serialized
func (*ResetPoints) String ¶
func (x *ResetPoints) String() string
func (*ResetPoints) Unmarshal ¶
func (val *ResetPoints) Unmarshal(buf []byte) error
Unmarshal an object of type ResetPoints from the protobuf v3 wire format
type VersioningOverride ¶ added in v1.43.0
type VersioningOverride struct {
// Indicates whether to override the workflow to be AutoUpgrade or Pinned.
//
// Types that are valid to be assigned to Override:
//
// *VersioningOverride_Pinned
// *VersioningOverride_AutoUpgrade
Override isVersioningOverride_Override `protobuf_oneof:"override"`
// Required.
// Deprecated. Use `override`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
Behavior v11.VersioningBehavior `protobuf:"varint,1,opt,name=behavior,proto3,enum=temporal.api.enums.v1.VersioningBehavior" json:"behavior,omitempty"`
// Required if behavior is `PINNED`. Must be null if behavior is `AUTO_UPGRADE`.
// Identifies the worker deployment to pin the workflow to.
// Deprecated. Use `override.pinned.version`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
Deployment *v12.Deployment `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
// Required if behavior is `PINNED`. Must be absent if behavior is not `PINNED`.
// Identifies the worker deployment version to pin the workflow to, in the format
// "<deployment_name>.<build_id>".
// Deprecated. Use `override.pinned.version`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
PinnedVersion string `protobuf:"bytes,9,opt,name=pinned_version,json=pinnedVersion,proto3" json:"pinned_version,omitempty"`
// contains filtered or unexported fields
}
Used to override the versioning behavior (and pinned deployment version, if applicable) of a specific workflow execution. If set, this override takes precedence over worker-sent values. See `WorkflowExecutionInfo.VersioningInfo` for more information.
To remove the override, call `UpdateWorkflowExecutionOptions` with a null `VersioningOverride`, and use the `update_mask` to indicate that it should be mutated.
Pinned behavior overrides are automatically inherited by child workflows, workflow retries, continue-as-new workflows, and cron workflows.
func (*VersioningOverride) Descriptor
deprecated
added in
v1.43.0
func (*VersioningOverride) Descriptor() ([]byte, []int)
Deprecated: Use VersioningOverride.ProtoReflect.Descriptor instead.
func (*VersioningOverride) Equal ¶ added in v1.43.0
func (this *VersioningOverride) Equal(that interface{}) bool
Equal returns whether two VersioningOverride values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*VersioningOverride) GetAutoUpgrade ¶ added in v1.49.1
func (x *VersioningOverride) GetAutoUpgrade() bool
func (*VersioningOverride) GetBehavior
deprecated
added in
v1.43.0
func (x *VersioningOverride) GetBehavior() v11.VersioningBehavior
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*VersioningOverride) GetDeployment
deprecated
added in
v1.43.0
func (x *VersioningOverride) GetDeployment() *v12.Deployment
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*VersioningOverride) GetOverride ¶ added in v1.49.1
func (x *VersioningOverride) GetOverride() isVersioningOverride_Override
func (*VersioningOverride) GetPinned ¶ added in v1.49.1
func (x *VersioningOverride) GetPinned() *VersioningOverride_PinnedOverride
func (*VersioningOverride) GetPinnedVersion
deprecated
added in
v1.44.0
func (x *VersioningOverride) GetPinnedVersion() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*VersioningOverride) Marshal ¶ added in v1.43.0
func (val *VersioningOverride) Marshal() ([]byte, error)
Marshal an object of type VersioningOverride to the protobuf v3 wire format
func (*VersioningOverride) ProtoMessage ¶ added in v1.43.0
func (*VersioningOverride) ProtoMessage()
func (*VersioningOverride) ProtoReflect ¶ added in v1.43.0
func (x *VersioningOverride) ProtoReflect() protoreflect.Message
func (*VersioningOverride) Reset ¶ added in v1.43.0
func (x *VersioningOverride) Reset()
func (*VersioningOverride) Size ¶ added in v1.43.0
func (val *VersioningOverride) Size() int
Size returns the size of the object, in bytes, once serialized
func (*VersioningOverride) String ¶ added in v1.43.0
func (x *VersioningOverride) String() string
func (*VersioningOverride) Unmarshal ¶ added in v1.43.0
func (val *VersioningOverride) Unmarshal(buf []byte) error
Unmarshal an object of type VersioningOverride from the protobuf v3 wire format
type VersioningOverride_AutoUpgrade ¶ added in v1.49.1
type VersioningOverride_AutoUpgrade struct {
// Override the workflow to have AutoUpgrade behavior.
AutoUpgrade bool `protobuf:"varint,4,opt,name=auto_upgrade,json=autoUpgrade,proto3,oneof"`
}
type VersioningOverride_Pinned ¶ added in v1.49.1
type VersioningOverride_Pinned struct {
// Override the workflow to have Pinned behavior.
Pinned *VersioningOverride_PinnedOverride `protobuf:"bytes,3,opt,name=pinned,proto3,oneof"`
}
type VersioningOverride_PinnedOverride ¶ added in v1.49.1
type VersioningOverride_PinnedOverride struct {
// Defaults to PINNED_OVERRIDE_BEHAVIOR_UNSPECIFIED.
// See `PinnedOverrideBehavior` for details.
Behavior VersioningOverride_PinnedOverrideBehavior `` /* 142-byte string literal not displayed */
// Specifies the Worker Deployment Version to pin this workflow to.
// Required if the target workflow is not already pinned to a version.
//
// If omitted and the target workflow is already pinned, the effective
// pinned version will be the existing pinned version.
//
// If omitted and the target workflow is not pinned, the override request
// will be rejected with a PreconditionFailed error.
Version *v12.WorkerDeploymentVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*VersioningOverride_PinnedOverride) Descriptor
deprecated
added in
v1.49.1
func (*VersioningOverride_PinnedOverride) Descriptor() ([]byte, []int)
Deprecated: Use VersioningOverride_PinnedOverride.ProtoReflect.Descriptor instead.
func (*VersioningOverride_PinnedOverride) GetBehavior ¶ added in v1.49.1
func (x *VersioningOverride_PinnedOverride) GetBehavior() VersioningOverride_PinnedOverrideBehavior
func (*VersioningOverride_PinnedOverride) GetVersion ¶ added in v1.49.1
func (x *VersioningOverride_PinnedOverride) GetVersion() *v12.WorkerDeploymentVersion
func (*VersioningOverride_PinnedOverride) ProtoMessage ¶ added in v1.49.1
func (*VersioningOverride_PinnedOverride) ProtoMessage()
func (*VersioningOverride_PinnedOverride) ProtoReflect ¶ added in v1.49.1
func (x *VersioningOverride_PinnedOverride) ProtoReflect() protoreflect.Message
func (*VersioningOverride_PinnedOverride) Reset ¶ added in v1.49.1
func (x *VersioningOverride_PinnedOverride) Reset()
func (*VersioningOverride_PinnedOverride) String ¶ added in v1.49.1
func (x *VersioningOverride_PinnedOverride) String() string
type VersioningOverride_PinnedOverrideBehavior ¶ added in v1.49.1
type VersioningOverride_PinnedOverrideBehavior int32
const ( VersioningOverride_PINNED_OVERRIDE_BEHAVIOR_UNSPECIFIED VersioningOverride_PinnedOverrideBehavior = 0 VersioningOverride_PINNED_OVERRIDE_BEHAVIOR_PINNED VersioningOverride_PinnedOverrideBehavior = 1 )
func (VersioningOverride_PinnedOverrideBehavior) Descriptor ¶ added in v1.49.1
func (VersioningOverride_PinnedOverrideBehavior) Descriptor() protoreflect.EnumDescriptor
func (VersioningOverride_PinnedOverrideBehavior) EnumDescriptor
deprecated
added in
v1.49.1
func (VersioningOverride_PinnedOverrideBehavior) EnumDescriptor() ([]byte, []int)
Deprecated: Use VersioningOverride_PinnedOverrideBehavior.Descriptor instead.
func (VersioningOverride_PinnedOverrideBehavior) Number ¶ added in v1.49.1
func (x VersioningOverride_PinnedOverrideBehavior) Number() protoreflect.EnumNumber
func (VersioningOverride_PinnedOverrideBehavior) String ¶ added in v1.49.1
func (x VersioningOverride_PinnedOverrideBehavior) String() string
func (VersioningOverride_PinnedOverrideBehavior) Type ¶ added in v1.49.1
func (VersioningOverride_PinnedOverrideBehavior) Type() protoreflect.EnumType
type WorkflowExecutionConfig ¶
type WorkflowExecutionConfig struct {
TaskQueue *v13.TaskQueue `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
WorkflowExecutionTimeout *durationpb.Duration `` /* 135-byte string literal not displayed */
WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,3,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
DefaultWorkflowTaskTimeout *durationpb.Duration `` /* 143-byte string literal not displayed */
// User metadata provided on start workflow.
UserMetadata *v14.UserMetadata `protobuf:"bytes,5,opt,name=user_metadata,json=userMetadata,proto3" json:"user_metadata,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowExecutionConfig) Descriptor
deprecated
func (*WorkflowExecutionConfig) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionConfig.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionConfig) Equal ¶
func (this *WorkflowExecutionConfig) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionConfig values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout() *durationpb.Duration
func (*WorkflowExecutionConfig) GetTaskQueue ¶
func (x *WorkflowExecutionConfig) GetTaskQueue() *v13.TaskQueue
func (*WorkflowExecutionConfig) GetUserMetadata ¶ added in v1.34.0
func (x *WorkflowExecutionConfig) GetUserMetadata() *v14.UserMetadata
func (*WorkflowExecutionConfig) GetWorkflowExecutionTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionConfig) GetWorkflowExecutionTimeout() *durationpb.Duration
func (*WorkflowExecutionConfig) GetWorkflowRunTimeout ¶ added in v0.28.0
func (x *WorkflowExecutionConfig) GetWorkflowRunTimeout() *durationpb.Duration
func (*WorkflowExecutionConfig) Marshal ¶
func (val *WorkflowExecutionConfig) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionConfig to the protobuf v3 wire format
func (*WorkflowExecutionConfig) ProtoMessage ¶
func (*WorkflowExecutionConfig) ProtoMessage()
func (*WorkflowExecutionConfig) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionConfig) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionConfig) Reset ¶
func (x *WorkflowExecutionConfig) Reset()
func (*WorkflowExecutionConfig) Size ¶
func (val *WorkflowExecutionConfig) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionConfig) String ¶
func (x *WorkflowExecutionConfig) String() string
func (*WorkflowExecutionConfig) Unmarshal ¶
func (val *WorkflowExecutionConfig) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionConfig from the protobuf v3 wire format
type WorkflowExecutionExtendedInfo ¶ added in v1.43.1
type WorkflowExecutionExtendedInfo struct {
// Workflow execution expiration time is defined as workflow start time plus expiration timeout.
// Workflow start time may change after workflow reset.
ExecutionExpirationTime *timestamppb.Timestamp `` /* 132-byte string literal not displayed */
// Workflow run expiration time is defined as current workflow run start time plus workflow run timeout.
RunExpirationTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=run_expiration_time,json=runExpirationTime,proto3" json:"run_expiration_time,omitempty"`
// indicates if the workflow received a cancel request
CancelRequested bool `protobuf:"varint,3,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
// Last workflow reset time. Nil if the workflow was never reset.
LastResetTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_reset_time,json=lastResetTime,proto3" json:"last_reset_time,omitempty"`
// Original workflow start time.
OriginalStartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=original_start_time,json=originalStartTime,proto3" json:"original_start_time,omitempty"`
// Reset Run ID points to the new run when this execution is reset. If the execution is reset multiple times, it points to the latest run.
ResetRunId string `protobuf:"bytes,6,opt,name=reset_run_id,json=resetRunId,proto3" json:"reset_run_id,omitempty"`
// Request ID information (eg: history event information associated with the request ID).
// Note: It only contains request IDs from StartWorkflowExecution requests, including indirect
// calls (eg: if SignalWithStartWorkflowExecution starts a new workflow, then the request ID is
// used in the StartWorkflowExecution request).
RequestIdInfos map[string]*RequestIdInfo `` /* 179-byte string literal not displayed */
// Information about the workflow execution pause operation.
PauseInfo *WorkflowExecutionPauseInfo `protobuf:"bytes,8,opt,name=pause_info,json=pauseInfo,proto3" json:"pause_info,omitempty"`
// contains filtered or unexported fields
}
Holds all the extra information about workflow execution that is not part of Visibility.
func (*WorkflowExecutionExtendedInfo) Descriptor
deprecated
added in
v1.43.1
func (*WorkflowExecutionExtendedInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionExtendedInfo.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionExtendedInfo) Equal ¶ added in v1.43.1
func (this *WorkflowExecutionExtendedInfo) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionExtendedInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionExtendedInfo) GetCancelRequested ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) GetCancelRequested() bool
func (*WorkflowExecutionExtendedInfo) GetExecutionExpirationTime ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) GetExecutionExpirationTime() *timestamppb.Timestamp
func (*WorkflowExecutionExtendedInfo) GetLastResetTime ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) GetLastResetTime() *timestamppb.Timestamp
func (*WorkflowExecutionExtendedInfo) GetOriginalStartTime ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) GetOriginalStartTime() *timestamppb.Timestamp
func (*WorkflowExecutionExtendedInfo) GetPauseInfo ¶ added in v1.59.0
func (x *WorkflowExecutionExtendedInfo) GetPauseInfo() *WorkflowExecutionPauseInfo
func (*WorkflowExecutionExtendedInfo) GetRequestIdInfos ¶ added in v1.49.0
func (x *WorkflowExecutionExtendedInfo) GetRequestIdInfos() map[string]*RequestIdInfo
func (*WorkflowExecutionExtendedInfo) GetResetRunId ¶ added in v1.47.0
func (x *WorkflowExecutionExtendedInfo) GetResetRunId() string
func (*WorkflowExecutionExtendedInfo) GetRunExpirationTime ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) GetRunExpirationTime() *timestamppb.Timestamp
func (*WorkflowExecutionExtendedInfo) Marshal ¶ added in v1.43.1
func (val *WorkflowExecutionExtendedInfo) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionExtendedInfo to the protobuf v3 wire format
func (*WorkflowExecutionExtendedInfo) ProtoMessage ¶ added in v1.43.1
func (*WorkflowExecutionExtendedInfo) ProtoMessage()
func (*WorkflowExecutionExtendedInfo) ProtoReflect ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionExtendedInfo) Reset ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) Reset()
func (*WorkflowExecutionExtendedInfo) Size ¶ added in v1.43.1
func (val *WorkflowExecutionExtendedInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionExtendedInfo) String ¶ added in v1.43.1
func (x *WorkflowExecutionExtendedInfo) String() string
func (*WorkflowExecutionExtendedInfo) Unmarshal ¶ added in v1.43.1
func (val *WorkflowExecutionExtendedInfo) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionExtendedInfo from the protobuf v3 wire format
type WorkflowExecutionInfo ¶
type WorkflowExecutionInfo struct {
Execution *v1.WorkflowExecution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
Type *v1.WorkflowType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
CloseTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
Status v11.WorkflowExecutionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
HistoryLength int64 `protobuf:"varint,6,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
ParentNamespaceId string `protobuf:"bytes,7,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
ParentExecution *v1.WorkflowExecution `protobuf:"bytes,8,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
ExecutionTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
Memo *v1.Memo `protobuf:"bytes,10,opt,name=memo,proto3" json:"memo,omitempty"`
SearchAttributes *v1.SearchAttributes `protobuf:"bytes,11,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
AutoResetPoints *ResetPoints `protobuf:"bytes,12,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
TaskQueue string `protobuf:"bytes,13,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
StateTransitionCount int64 `protobuf:"varint,14,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
HistorySizeBytes int64 `protobuf:"varint,15,opt,name=history_size_bytes,json=historySizeBytes,proto3" json:"history_size_bytes,omitempty"`
// If set, the most recent worker version stamp that appeared in a workflow task completion
// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
MostRecentWorkerVersionStamp *v1.WorkerVersionStamp `` /* 152-byte string literal not displayed */
// Workflow execution duration is defined as difference between close time and execution time.
// This field is only populated if the workflow is closed.
ExecutionDuration *durationpb.Duration `protobuf:"bytes,17,opt,name=execution_duration,json=executionDuration,proto3" json:"execution_duration,omitempty"`
// Contains information about the root workflow execution.
// The root workflow execution is defined as follows:
// 1. A workflow without parent workflow is its own root workflow.
// 2. A workflow that has a parent workflow has the same root workflow as its parent workflow.
// Note: workflows continued as new or reseted may or may not have parents, check examples below.
//
// Examples:
//
// Scenario 1: Workflow W1 starts child workflow W2, and W2 starts child workflow W3.
// - The root workflow of all three workflows is W1.
// Scenario 2: Workflow W1 starts child workflow W2, and W2 continued as new W3.
// - The root workflow of all three workflows is W1.
// Scenario 3: Workflow W1 continued as new W2.
// - The root workflow of W1 is W1 and the root workflow of W2 is W2.
// Scenario 4: Workflow W1 starts child workflow W2, and W2 is reseted, creating W3
// - The root workflow of all three workflows is W1.
// Scenario 5: Workflow W1 is reseted, creating W2.
// - The root workflow of W1 is W1 and the root workflow of W2 is W2.
RootExecution *v1.WorkflowExecution `protobuf:"bytes,18,opt,name=root_execution,json=rootExecution,proto3" json:"root_execution,omitempty"`
// The currently assigned build ID for this execution. Presence of this value means worker versioning is used
// for this execution. Assigned build ID is selected based on Worker Versioning Assignment Rules
// when the first workflow task of the execution is scheduled. If the first workflow task fails and is scheduled
// again, the assigned build ID may change according to the latest versioning rules.
// Assigned build ID can also change in the middle of a execution if Compatible Redirect Rules are applied to
// this execution.
// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
AssignedBuildId string `protobuf:"bytes,19,opt,name=assigned_build_id,json=assignedBuildId,proto3" json:"assigned_build_id,omitempty"`
// Build ID inherited from a previous/parent execution. If present, assigned_build_id will be set to this, instead
// of using the assignment rules.
// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
InheritedBuildId string `protobuf:"bytes,20,opt,name=inherited_build_id,json=inheritedBuildId,proto3" json:"inherited_build_id,omitempty"`
// The first run ID in the execution chain.
// Executions created via the following operations are considered to be in the same chain
// - ContinueAsNew
// - Workflow Retry
// - Workflow Reset
// - Cron Schedule
FirstRunId string `protobuf:"bytes,21,opt,name=first_run_id,json=firstRunId,proto3" json:"first_run_id,omitempty"`
// Absent value means the workflow execution is not versioned. When present, the execution might
// be versioned or unversioned, depending on `versioning_info.behavior` and `versioning_info.versioning_override`.
// Experimental. Versioning info is experimental and might change in the future.
VersioningInfo *WorkflowExecutionVersioningInfo `protobuf:"bytes,22,opt,name=versioning_info,json=versioningInfo,proto3" json:"versioning_info,omitempty"`
// The name of Worker Deployment that completed the most recent workflow task.
// Experimental. Worker Deployments are experimental and might change in the future.
WorkerDeploymentName string `protobuf:"bytes,23,opt,name=worker_deployment_name,json=workerDeploymentName,proto3" json:"worker_deployment_name,omitempty"`
// Priority metadata
Priority *v1.Priority `protobuf:"bytes,24,opt,name=priority,proto3" json:"priority,omitempty"`
// Total size in bytes of all external payloads referenced in workflow history.
ExternalPayloadSizeBytes int64 `` /* 139-byte string literal not displayed */
// Count of external payloads referenced in workflow history.
ExternalPayloadCount int64 `protobuf:"varint,26,opt,name=external_payload_count,json=externalPayloadCount,proto3" json:"external_payload_count,omitempty"`
// contains filtered or unexported fields
}
Hold basic information about a workflow execution. This structure is a part of visibility, and thus contain a limited subset of information.
func (*WorkflowExecutionInfo) Descriptor
deprecated
func (*WorkflowExecutionInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionInfo.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionInfo) Equal ¶
func (this *WorkflowExecutionInfo) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionInfo) GetAssignedBuildId
deprecated
added in
v1.32.0
func (x *WorkflowExecutionInfo) GetAssignedBuildId() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*WorkflowExecutionInfo) GetAutoResetPoints ¶
func (x *WorkflowExecutionInfo) GetAutoResetPoints() *ResetPoints
func (*WorkflowExecutionInfo) GetCloseTime ¶
func (x *WorkflowExecutionInfo) GetCloseTime() *timestamppb.Timestamp
func (*WorkflowExecutionInfo) GetExecution ¶
func (x *WorkflowExecutionInfo) GetExecution() *v1.WorkflowExecution
func (*WorkflowExecutionInfo) GetExecutionDuration ¶ added in v1.32.0
func (x *WorkflowExecutionInfo) GetExecutionDuration() *durationpb.Duration
func (*WorkflowExecutionInfo) GetExecutionTime ¶
func (x *WorkflowExecutionInfo) GetExecutionTime() *timestamppb.Timestamp
func (*WorkflowExecutionInfo) GetExternalPayloadCount ¶ added in v1.60.0
func (x *WorkflowExecutionInfo) GetExternalPayloadCount() int64
func (*WorkflowExecutionInfo) GetExternalPayloadSizeBytes ¶ added in v1.60.0
func (x *WorkflowExecutionInfo) GetExternalPayloadSizeBytes() int64
func (*WorkflowExecutionInfo) GetFirstRunId ¶ added in v1.37.0
func (x *WorkflowExecutionInfo) GetFirstRunId() string
func (*WorkflowExecutionInfo) GetHistoryLength ¶
func (x *WorkflowExecutionInfo) GetHistoryLength() int64
func (*WorkflowExecutionInfo) GetHistorySizeBytes ¶ added in v1.13.0
func (x *WorkflowExecutionInfo) GetHistorySizeBytes() int64
func (*WorkflowExecutionInfo) GetInheritedBuildId
deprecated
added in
v1.32.0
func (x *WorkflowExecutionInfo) GetInheritedBuildId() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*WorkflowExecutionInfo) GetMemo ¶
func (x *WorkflowExecutionInfo) GetMemo() *v1.Memo
func (*WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp
deprecated
added in
v1.19.0
func (x *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v1.WorkerVersionStamp
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*WorkflowExecutionInfo) GetParentExecution ¶
func (x *WorkflowExecutionInfo) GetParentExecution() *v1.WorkflowExecution
func (*WorkflowExecutionInfo) GetParentNamespaceId ¶
func (x *WorkflowExecutionInfo) GetParentNamespaceId() string
func (*WorkflowExecutionInfo) GetPriority ¶ added in v1.46.0
func (x *WorkflowExecutionInfo) GetPriority() *v1.Priority
func (*WorkflowExecutionInfo) GetRootExecution ¶ added in v1.32.0
func (x *WorkflowExecutionInfo) GetRootExecution() *v1.WorkflowExecution
func (*WorkflowExecutionInfo) GetSearchAttributes ¶
func (x *WorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes
func (*WorkflowExecutionInfo) GetStartTime ¶
func (x *WorkflowExecutionInfo) GetStartTime() *timestamppb.Timestamp
func (*WorkflowExecutionInfo) GetStateTransitionCount ¶ added in v1.5.0
func (x *WorkflowExecutionInfo) GetStateTransitionCount() int64
func (*WorkflowExecutionInfo) GetStatus ¶
func (x *WorkflowExecutionInfo) GetStatus() v11.WorkflowExecutionStatus
func (*WorkflowExecutionInfo) GetTaskQueue ¶
func (x *WorkflowExecutionInfo) GetTaskQueue() string
func (*WorkflowExecutionInfo) GetType ¶
func (x *WorkflowExecutionInfo) GetType() *v1.WorkflowType
func (*WorkflowExecutionInfo) GetVersioningInfo ¶ added in v1.43.0
func (x *WorkflowExecutionInfo) GetVersioningInfo() *WorkflowExecutionVersioningInfo
func (*WorkflowExecutionInfo) GetWorkerDeploymentName ¶ added in v1.44.0
func (x *WorkflowExecutionInfo) GetWorkerDeploymentName() string
func (*WorkflowExecutionInfo) Marshal ¶
func (val *WorkflowExecutionInfo) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionInfo to the protobuf v3 wire format
func (*WorkflowExecutionInfo) ProtoMessage ¶
func (*WorkflowExecutionInfo) ProtoMessage()
func (*WorkflowExecutionInfo) ProtoReflect ¶ added in v1.26.1
func (x *WorkflowExecutionInfo) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionInfo) Reset ¶
func (x *WorkflowExecutionInfo) Reset()
func (*WorkflowExecutionInfo) Size ¶
func (val *WorkflowExecutionInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionInfo) String ¶
func (x *WorkflowExecutionInfo) String() string
func (*WorkflowExecutionInfo) Unmarshal ¶
func (val *WorkflowExecutionInfo) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionInfo from the protobuf v3 wire format
type WorkflowExecutionOptions ¶ added in v1.43.0
type WorkflowExecutionOptions struct {
// If set, takes precedence over the Versioning Behavior sent by the SDK on Workflow Task completion.
VersioningOverride *VersioningOverride `protobuf:"bytes,1,opt,name=versioning_override,json=versioningOverride,proto3" json:"versioning_override,omitempty"`
// If set, overrides the workflow's priority sent by the SDK.
Priority *v1.Priority `protobuf:"bytes,2,opt,name=priority,proto3" json:"priority,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowExecutionOptions) Descriptor
deprecated
added in
v1.43.0
func (*WorkflowExecutionOptions) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionOptions.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionOptions) Equal ¶ added in v1.43.0
func (this *WorkflowExecutionOptions) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionOptions values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionOptions) GetPriority ¶ added in v1.60.0
func (x *WorkflowExecutionOptions) GetPriority() *v1.Priority
func (*WorkflowExecutionOptions) GetVersioningOverride ¶ added in v1.43.0
func (x *WorkflowExecutionOptions) GetVersioningOverride() *VersioningOverride
func (*WorkflowExecutionOptions) Marshal ¶ added in v1.43.0
func (val *WorkflowExecutionOptions) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionOptions to the protobuf v3 wire format
func (*WorkflowExecutionOptions) ProtoMessage ¶ added in v1.43.0
func (*WorkflowExecutionOptions) ProtoMessage()
func (*WorkflowExecutionOptions) ProtoReflect ¶ added in v1.43.0
func (x *WorkflowExecutionOptions) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionOptions) Reset ¶ added in v1.43.0
func (x *WorkflowExecutionOptions) Reset()
func (*WorkflowExecutionOptions) Size ¶ added in v1.43.0
func (val *WorkflowExecutionOptions) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionOptions) String ¶ added in v1.43.0
func (x *WorkflowExecutionOptions) String() string
func (*WorkflowExecutionOptions) Unmarshal ¶ added in v1.43.0
func (val *WorkflowExecutionOptions) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionOptions from the protobuf v3 wire format
type WorkflowExecutionPauseInfo ¶ added in v1.59.0
type WorkflowExecutionPauseInfo struct {
// The identity of the client who paused the workflow execution.
Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
// The time when the workflow execution was paused.
PausedTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=paused_time,json=pausedTime,proto3" json:"paused_time,omitempty"`
// The reason for pausing the workflow execution.
Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
WorkflowExecutionPauseInfo contains the information about a workflow execution pause.
func (*WorkflowExecutionPauseInfo) Descriptor
deprecated
added in
v1.59.0
func (*WorkflowExecutionPauseInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionPauseInfo.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionPauseInfo) Equal ¶ added in v1.59.0
func (this *WorkflowExecutionPauseInfo) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionPauseInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionPauseInfo) GetIdentity ¶ added in v1.59.0
func (x *WorkflowExecutionPauseInfo) GetIdentity() string
func (*WorkflowExecutionPauseInfo) GetPausedTime ¶ added in v1.59.0
func (x *WorkflowExecutionPauseInfo) GetPausedTime() *timestamppb.Timestamp
func (*WorkflowExecutionPauseInfo) GetReason ¶ added in v1.59.0
func (x *WorkflowExecutionPauseInfo) GetReason() string
func (*WorkflowExecutionPauseInfo) Marshal ¶ added in v1.59.0
func (val *WorkflowExecutionPauseInfo) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionPauseInfo to the protobuf v3 wire format
func (*WorkflowExecutionPauseInfo) ProtoMessage ¶ added in v1.59.0
func (*WorkflowExecutionPauseInfo) ProtoMessage()
func (*WorkflowExecutionPauseInfo) ProtoReflect ¶ added in v1.59.0
func (x *WorkflowExecutionPauseInfo) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionPauseInfo) Reset ¶ added in v1.59.0
func (x *WorkflowExecutionPauseInfo) Reset()
func (*WorkflowExecutionPauseInfo) Size ¶ added in v1.59.0
func (val *WorkflowExecutionPauseInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionPauseInfo) String ¶ added in v1.59.0
func (x *WorkflowExecutionPauseInfo) String() string
func (*WorkflowExecutionPauseInfo) Unmarshal ¶ added in v1.59.0
func (val *WorkflowExecutionPauseInfo) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionPauseInfo from the protobuf v3 wire format
type WorkflowExecutionVersioningInfo ¶ added in v1.43.0
type WorkflowExecutionVersioningInfo struct {
// Versioning behavior determines how the server should treat this execution when workers are
// upgraded. When present it means this workflow execution is versioned; UNSPECIFIED means
// unversioned. See the comments in `VersioningBehavior` enum for more info about different
// behaviors.
//
// Child workflows or CaN executions **inherit** their parent/previous run's effective Versioning
// Behavior and Version (except when the new execution runs on a task queue not belonging to the
// same deployment version as the parent/previous run's task queue). The first workflow task will
// be dispatched according to the inherited behavior (or to the current version of the task-queue's
// deployment in the case of AutoUpgrade.) After completion of their first workflow task the
// Deployment Version and Behavior of the execution will update according to configuration on the worker.
//
// Note that `behavior` is overridden by `versioning_override` if the latter is present.
Behavior v11.VersioningBehavior `protobuf:"varint,1,opt,name=behavior,proto3,enum=temporal.api.enums.v1.VersioningBehavior" json:"behavior,omitempty"`
// The worker deployment that completed the last workflow task of this workflow execution. Must
// be present if `behavior` is set. Absent value means no workflow task is completed, or the
// last workflow task was completed by an unversioned worker. Unversioned workers may still send
// a deployment value which will be stored here, so the right way to check if an execution is
// versioned if an execution is versioned or not is via the `behavior` field.
// Note that `deployment` is overridden by `versioning_override` if the latter is present.
// Deprecated. Use `deployment_version`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
Deployment *v12.Deployment `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
// Deprecated. Use `deployment_version`.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
// The Worker Deployment Version that completed the last workflow task of this workflow execution.
// An absent value means no workflow task is completed, or the workflow is unversioned.
// If present, and `behavior` is UNSPECIFIED, the last task of this workflow execution was completed
// by a worker that is not using versioning but _is_ passing Deployment Name and Build ID.
//
// Child workflows or CaN executions **inherit** their parent/previous run's effective Versioning
// Behavior and Version (except when the new execution runs on a task queue not belonging to the
// same deployment version as the parent/previous run's task queue). The first workflow task will
// be dispatched according to the inherited behavior (or to the current version of the task-queue's
// deployment in the case of AutoUpgrade.) After completion of their first workflow task the
// Deployment Version and Behavior of the execution will update according to configuration on the worker.
//
// Note that if `versioning_override.behavior` is PINNED then `versioning_override.pinned_version`
// will override this value.
DeploymentVersion *v12.WorkerDeploymentVersion `protobuf:"bytes,7,opt,name=deployment_version,json=deploymentVersion,proto3" json:"deployment_version,omitempty"`
// Present if user has set an execution-specific versioning override. This override takes
// precedence over SDK-sent `behavior` (and `version` when override is PINNED). An
// override can be set when starting a new execution, as well as afterwards by calling the
// `UpdateWorkflowExecutionOptions` API.
// Pinned overrides are automatically inherited by child workflows, continue-as-new workflows,
// workflow retries, and cron workflows.
VersioningOverride *VersioningOverride `protobuf:"bytes,3,opt,name=versioning_override,json=versioningOverride,proto3" json:"versioning_override,omitempty"`
// When present, indicates the workflow is transitioning to a different deployment. Can
// indicate one of the following transitions: unversioned -> versioned, versioned -> versioned
// on a different deployment, or versioned -> unversioned.
// Not applicable to workflows with PINNED behavior.
// When a workflow with AUTO_UPGRADE behavior creates a new workflow task, it will automatically
// start a transition to the task queue's current deployment if the task queue's current
// deployment is different from the workflow's deployment.
// If the AUTO_UPGRADE workflow is stuck due to backlogged activity or workflow tasks, those
// tasks will be redirected to the task queue's current deployment. As soon as a poller from
// that deployment is available to receive the task, the workflow will automatically start a
// transition to that deployment and continue execution there.
// A deployment transition can only exist while there is a pending or started workflow task.
// Once the pending workflow task completes on the transition's target deployment, the
// transition completes and the workflow's `deployment` and `behavior` fields are updated per
// the worker's task completion response.
// Pending activities will not start new attempts during a transition. Once the transition is
// completed, pending activities will start their next attempt on the new deployment.
// Deprecated. Use version_transition.
//
// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
DeploymentTransition *DeploymentTransition `protobuf:"bytes,4,opt,name=deployment_transition,json=deploymentTransition,proto3" json:"deployment_transition,omitempty"`
// When present, indicates the workflow is transitioning to a different deployment version
// (which may belong to the same deployment name or another). Can indicate one of the following
// transitions: unversioned -> versioned, versioned -> versioned
// on a different deployment version, or versioned -> unversioned.
// Not applicable to workflows with PINNED behavior.
// When a workflow with AUTO_UPGRADE behavior creates a new workflow task, it will automatically
// start a transition to the task queue's current version if the task queue's current version is
// different from the workflow's current deployment version.
// If the AUTO_UPGRADE workflow is stuck due to backlogged activity or workflow tasks, those
// tasks will be redirected to the task queue's current version. As soon as a poller from
// that deployment version is available to receive the task, the workflow will automatically
// start a transition to that version and continue execution there.
// A version transition can only exist while there is a pending or started workflow task.
// Once the pending workflow task completes on the transition's target version, the
// transition completes and the workflow's `behavior`, and `deployment_version` fields are updated per the
// worker's task completion response.
// Pending activities will not start new attempts during a transition. Once the transition is
// completed, pending activities will start their next attempt on the new version.
VersionTransition *DeploymentVersionTransition `protobuf:"bytes,6,opt,name=version_transition,json=versionTransition,proto3" json:"version_transition,omitempty"`
// Monotonic counter reflecting the latest routing decision for this workflow execution.
// Used for staleness detection between history and matching when dispatching tasks to workers.
// Incremented when a workflow execution routes to a new deployment version, which happens
// when a worker of the new deployment version completes a workflow task.
// Note: Pinned tasks and sticky tasks send a value of 0 for this field since these tasks do not
// face the problem of inconsistent dispatching that arises from eventual consistency between
// task queues and their partitions.
RevisionNumber int64 `protobuf:"varint,8,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
// contains filtered or unexported fields
}
Holds all the information about worker versioning for a particular workflow execution. Experimental. Versioning info is experimental and might change in the future.
func (*WorkflowExecutionVersioningInfo) Descriptor
deprecated
added in
v1.43.0
func (*WorkflowExecutionVersioningInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionVersioningInfo.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionVersioningInfo) Equal ¶ added in v1.43.0
func (this *WorkflowExecutionVersioningInfo) Equal(that interface{}) bool
Equal returns whether two WorkflowExecutionVersioningInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal
func (*WorkflowExecutionVersioningInfo) GetBehavior ¶ added in v1.43.0
func (x *WorkflowExecutionVersioningInfo) GetBehavior() v11.VersioningBehavior
func (*WorkflowExecutionVersioningInfo) GetDeployment
deprecated
added in
v1.43.0
func (x *WorkflowExecutionVersioningInfo) GetDeployment() *v12.Deployment
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*WorkflowExecutionVersioningInfo) GetDeploymentTransition
deprecated
added in
v1.43.0
func (x *WorkflowExecutionVersioningInfo) GetDeploymentTransition() *DeploymentTransition
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*WorkflowExecutionVersioningInfo) GetDeploymentVersion ¶ added in v1.49.1
func (x *WorkflowExecutionVersioningInfo) GetDeploymentVersion() *v12.WorkerDeploymentVersion
func (*WorkflowExecutionVersioningInfo) GetRevisionNumber ¶ added in v1.57.0
func (x *WorkflowExecutionVersioningInfo) GetRevisionNumber() int64
func (*WorkflowExecutionVersioningInfo) GetVersion
deprecated
added in
v1.44.0
func (x *WorkflowExecutionVersioningInfo) GetVersion() string
Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
func (*WorkflowExecutionVersioningInfo) GetVersionTransition ¶ added in v1.44.0
func (x *WorkflowExecutionVersioningInfo) GetVersionTransition() *DeploymentVersionTransition
func (*WorkflowExecutionVersioningInfo) GetVersioningOverride ¶ added in v1.43.0
func (x *WorkflowExecutionVersioningInfo) GetVersioningOverride() *VersioningOverride
func (*WorkflowExecutionVersioningInfo) Marshal ¶ added in v1.43.0
func (val *WorkflowExecutionVersioningInfo) Marshal() ([]byte, error)
Marshal an object of type WorkflowExecutionVersioningInfo to the protobuf v3 wire format
func (*WorkflowExecutionVersioningInfo) ProtoMessage ¶ added in v1.43.0
func (*WorkflowExecutionVersioningInfo) ProtoMessage()
func (*WorkflowExecutionVersioningInfo) ProtoReflect ¶ added in v1.43.0
func (x *WorkflowExecutionVersioningInfo) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionVersioningInfo) Reset ¶ added in v1.43.0
func (x *WorkflowExecutionVersioningInfo) Reset()
func (*WorkflowExecutionVersioningInfo) Size ¶ added in v1.43.0
func (val *WorkflowExecutionVersioningInfo) Size() int
Size returns the size of the object, in bytes, once serialized
func (*WorkflowExecutionVersioningInfo) String ¶ added in v1.43.0
func (x *WorkflowExecutionVersioningInfo) String() string
func (*WorkflowExecutionVersioningInfo) Unmarshal ¶ added in v1.43.0
func (val *WorkflowExecutionVersioningInfo) Unmarshal(buf []byte) error
Unmarshal an object of type WorkflowExecutionVersioningInfo from the protobuf v3 wire format