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) GetUpdateWorkflowExecutionCompleted() *CallbackInfo_UpdateWorkflowExecutionCompleted
- 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_UpdateWorkflowExecutionCompleted
- type CallbackInfo_Trigger_WorkflowClosed
- type CallbackInfo_UpdateWorkflowExecutionCompleted
- func (*CallbackInfo_UpdateWorkflowExecutionCompleted) Descriptor() ([]byte, []int)deprecated
- func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) GetUpdateId() string
- func (*CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoMessage()
- func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoReflect() protoreflect.Message
- func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) Reset()
- func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) String() string
- 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) GetScheduleToStartTimeout() *durationpb.Duration
- func (x *PendingNexusOperationInfo) GetScheduledEventId() int64
- func (x *PendingNexusOperationInfo) GetScheduledTime() *timestamppb.Timestamp
- func (x *PendingNexusOperationInfo) GetService() string
- func (x *PendingNexusOperationInfo) GetStartToCloseTimeout() *durationpb.Duration
- 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 TimeSkippingConfig
- func (*TimeSkippingConfig) Descriptor() ([]byte, []int)deprecated
- func (this *TimeSkippingConfig) Equal(that interface{}) bool
- func (x *TimeSkippingConfig) GetBound() isTimeSkippingConfig_Bound
- func (x *TimeSkippingConfig) GetEnabled() bool
- func (x *TimeSkippingConfig) GetMaxElapsedDuration() *durationpb.Duration
- func (x *TimeSkippingConfig) GetMaxSkippedDuration() *durationpb.Duration
- func (val *TimeSkippingConfig) Marshal() ([]byte, error)
- func (*TimeSkippingConfig) ProtoMessage()
- func (x *TimeSkippingConfig) ProtoReflect() protoreflect.Message
- func (x *TimeSkippingConfig) Reset()
- func (val *TimeSkippingConfig) Size() int
- func (x *TimeSkippingConfig) String() string
- func (val *TimeSkippingConfig) Unmarshal(buf []byte) error
- type TimeSkippingConfig_MaxElapsedDuration
- type TimeSkippingConfig_MaxSkippedDuration
- 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) GetTimeSkippingConfig() *TimeSkippingConfig
- 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) GetContinueAsNewInitialVersioningBehavior() v11.ContinueAsNewVersioningBehavior
- 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
// *CallbackInfo_Trigger_UpdateWorkflowExecutionCompleted
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) GetUpdateWorkflowExecutionCompleted ¶ added in v1.62.13
func (x *CallbackInfo_Trigger) GetUpdateWorkflowExecutionCompleted() *CallbackInfo_UpdateWorkflowExecutionCompleted
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_UpdateWorkflowExecutionCompleted ¶ added in v1.62.13
type CallbackInfo_Trigger_UpdateWorkflowExecutionCompleted struct {
UpdateWorkflowExecutionCompleted *CallbackInfo_UpdateWorkflowExecutionCompleted `protobuf:"bytes,2,opt,name=update_workflow_execution_completed,json=updateWorkflowExecutionCompleted,proto3,oneof"`
}
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_UpdateWorkflowExecutionCompleted ¶ added in v1.62.13
type CallbackInfo_UpdateWorkflowExecutionCompleted struct {
UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
// contains filtered or unexported fields
}
Trigger for when a workflow update is completed.
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) Descriptor
deprecated
added in
v1.62.13
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) Descriptor() ([]byte, []int)
Deprecated: Use CallbackInfo_UpdateWorkflowExecutionCompleted.ProtoReflect.Descriptor instead.
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) GetUpdateId ¶ added in v1.62.13
func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) GetUpdateId() string
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoMessage ¶ added in v1.62.13
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoMessage()
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoReflect ¶ added in v1.62.13
func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoReflect() protoreflect.Message
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) Reset ¶ added in v1.62.13
func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) Reset()
func (*CallbackInfo_UpdateWorkflowExecutionCompleted) String ¶ added in v1.62.13
func (x *CallbackInfo_UpdateWorkflowExecutionCompleted) String() string
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 is approximate, it is incremented when a task is added to the history queue.
// In practice, there could be more attempts if a task is executed but fails to commit, or less attempts if a task
// was never executed.
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"`
// Schedule-to-start timeout for this operation.
// (-- api-linter: core::0140::prepositions=disabled
//
// aip.dev/not-precedent: "to" is used to indicate interval. --)
ScheduleToStartTimeout *durationpb.Duration `` /* 132-byte string literal not displayed */
// Start-to-close timeout for this operation.
// (-- api-linter: core::0140::prepositions=disabled
//
// aip.dev/not-precedent: "to" is used to indicate interval. --)
StartToCloseTimeout *durationpb.Duration `protobuf:"bytes,17,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,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) GetScheduleToStartTimeout ¶ added in v1.61.0
func (x *PendingNexusOperationInfo) GetScheduleToStartTimeout() *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) GetStartToCloseTimeout ¶ added in v1.61.0
func (x *PendingNexusOperationInfo) GetStartToCloseTimeout() *durationpb.Duration
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 TimeSkippingConfig ¶ added in v1.62.8
type TimeSkippingConfig struct {
// Enables or disables time skipping for this workflow execution.
Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
// Optional bound that limits the gap between the virtual time of this execution and wall-clock time.
// Once the bound is reached, time skipping is automatically disabled,
// but can be re-enabled by setting `enabled` to true via UpdateWorkflowExecutionOptions.
// This bound cannot be set to a value smaller than the execution's currently skipped duration.
//
// This is useful in testing scenarios where a workflow is expected to receive
// signals, updates, or other external events while timers are in progress.
//
// Types that are valid to be assigned to Bound:
//
// *TimeSkippingConfig_MaxSkippedDuration
// *TimeSkippingConfig_MaxElapsedDuration
Bound isTimeSkippingConfig_Bound `protobuf_oneof:"bound"`
// contains filtered or unexported fields
}
Configuration for time skipping during a workflow execution. When enabled, virtual time advances automatically whenever there is no in-flight work. In-flight work includes activities, child workflows, Nexus operations, signal/cancel external workflow operations, and possibly other features added in the future. User timers are not classified as in-flight work and will be skipped over. When time advances, it skips to the earlier of the next user timer or the configured bound, if either exists.
Propagation behavior of time skipping: The enabled flag, bound fields, and accumulated skipped duration are propagated to related executions as follows: (1) Child workflows and continue-as-new: both the configuration and the accumulated skipped duration are
inherited from the current execution. The configured bound is shared between the inherited skipped duration and any additional duration skipped by the new run.
(2) Retry and cron: the configuration and accumulated skipped duration are inherited as recorded when the
current workflow started; the accumulated skipped duration of the current run is not propagated.
(3) Reset: the new run retains the time-skipping configuration of the current execution. Because reset replays
all events up to the reset point and re-applies any UpdateWorkflowExecutionOptions changes made after that point, the resulting run ends up with the same final time-skipping configuration as the previous run.
func (*TimeSkippingConfig) Descriptor
deprecated
added in
v1.62.8
func (*TimeSkippingConfig) Descriptor() ([]byte, []int)
Deprecated: Use TimeSkippingConfig.ProtoReflect.Descriptor instead.
func (*TimeSkippingConfig) Equal ¶ added in v1.62.8
func (this *TimeSkippingConfig) Equal(that interface{}) bool
Equal returns whether two TimeSkippingConfig 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 (*TimeSkippingConfig) GetBound ¶ added in v1.62.8
func (x *TimeSkippingConfig) GetBound() isTimeSkippingConfig_Bound
func (*TimeSkippingConfig) GetEnabled ¶ added in v1.62.8
func (x *TimeSkippingConfig) GetEnabled() bool
func (*TimeSkippingConfig) GetMaxElapsedDuration ¶ added in v1.62.8
func (x *TimeSkippingConfig) GetMaxElapsedDuration() *durationpb.Duration
func (*TimeSkippingConfig) GetMaxSkippedDuration ¶ added in v1.62.8
func (x *TimeSkippingConfig) GetMaxSkippedDuration() *durationpb.Duration
func (*TimeSkippingConfig) Marshal ¶ added in v1.62.8
func (val *TimeSkippingConfig) Marshal() ([]byte, error)
Marshal an object of type TimeSkippingConfig to the protobuf v3 wire format
func (*TimeSkippingConfig) ProtoMessage ¶ added in v1.62.8
func (*TimeSkippingConfig) ProtoMessage()
func (*TimeSkippingConfig) ProtoReflect ¶ added in v1.62.8
func (x *TimeSkippingConfig) ProtoReflect() protoreflect.Message
func (*TimeSkippingConfig) Reset ¶ added in v1.62.8
func (x *TimeSkippingConfig) Reset()
func (*TimeSkippingConfig) Size ¶ added in v1.62.8
func (val *TimeSkippingConfig) Size() int
Size returns the size of the object, in bytes, once serialized
func (*TimeSkippingConfig) String ¶ added in v1.62.8
func (x *TimeSkippingConfig) String() string
func (*TimeSkippingConfig) Unmarshal ¶ added in v1.62.8
func (val *TimeSkippingConfig) Unmarshal(buf []byte) error
Unmarshal an object of type TimeSkippingConfig from the protobuf v3 wire format
type TimeSkippingConfig_MaxElapsedDuration ¶ added in v1.62.8
type TimeSkippingConfig_MaxElapsedDuration struct {
// Maximum elapsed time since time skipping was enabled.
// This includes both skipped time and real time elapsing.
// (-- api-linter: core::0142::time-field-names=disabled --)
MaxElapsedDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=max_elapsed_duration,json=maxElapsedDuration,proto3,oneof"`
}
type TimeSkippingConfig_MaxSkippedDuration ¶ added in v1.62.8
type TimeSkippingConfig_MaxSkippedDuration struct {
// Maximum total virtual time that can be skipped.
MaxSkippedDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=max_skipped_duration,json=maxSkippedDuration,proto3,oneof"`
}
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.
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"`
// Time-skipping configuration for this workflow execution.
// If not set, the time-skipping configuration is not updated by this request;
// the existing configuration is preserved.
TimeSkippingConfig *TimeSkippingConfig `protobuf:"bytes,3,opt,name=time_skipping_config,json=timeSkippingConfig,proto3" json:"time_skipping_config,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) GetTimeSkippingConfig ¶ added in v1.62.8
func (x *WorkflowExecutionOptions) GetTimeSkippingConfig() *TimeSkippingConfig
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"`
// Experimental.
// If this workflow is the result of a continue-as-new, this field is set to the initial_versioning_behavior
// specified in that command.
// Only used for the initial task of this run and the initial task of any retries of this run.
// Not passed to children or to future continue-as-new.
//
// Note: In the first release of Upgrade-on-CaN, when the only ContinueAsNewVersioningBehavior was AutoUpgrade,
// a non-empty InheritedAutoUpgradeInfo meant that the workflow should start as AutoUpgrade. So for compatibility
// with ContinueAsNew history commands generated during that time, know that an UNSPECIFIED value here is equivalent
// to ContinueAsNewVersioningBehaviorAutoUpgrade if the behavior of the workflow is AutoUpgrade.
ContinueAsNewInitialVersioningBehavior v11.ContinueAsNewVersioningBehavior `` /* 243-byte string literal not displayed */
// 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) GetContinueAsNewInitialVersioningBehavior ¶ added in v1.62.8
func (x *WorkflowExecutionVersioningInfo) GetContinueAsNewInitialVersioningBehavior() v11.ContinueAsNewVersioningBehavior
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