Documentation
¶
Index ¶
- Variables
- type CallbackInfo
- func (*CallbackInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CallbackInfo) GetAttempt() int32
- func (x *CallbackInfo) GetCallback() *v1.Callback
- func (x *CallbackInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
- func (x *CallbackInfo) GetLastAttemptFailure() *v14.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 (*CallbackInfo) ProtoMessage()
- func (x *CallbackInfo) ProtoReflect() protoreflect.Message
- func (x *CallbackInfo) Reset()
- func (x *CallbackInfo) String() string
- type CallbackInfo_Trigger
- func (*CallbackInfo_Trigger) Descriptor() ([]byte, []int)deprecated
- func (m *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant
- func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed
- func (*CallbackInfo_Trigger) ProtoMessage()
- func (x *CallbackInfo_Trigger) ProtoReflect() protoreflect.Message
- func (x *CallbackInfo_Trigger) Reset()
- func (x *CallbackInfo_Trigger) String() string
- type CallbackInfo_Trigger_WorkflowClosed
- type CallbackInfo_WorkflowClosed
- type NewWorkflowExecutionInfo
- func (*NewWorkflowExecutionInfo) Descriptor() ([]byte, []int)deprecated
- 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) GetRetryPolicy() *v1.RetryPolicy
- func (x *NewWorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes
- func (x *NewWorkflowExecutionInfo) GetTaskQueue() *v12.TaskQueue
- func (x *NewWorkflowExecutionInfo) GetUserMetadata() *v13.UserMetadata
- 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 (*NewWorkflowExecutionInfo) ProtoMessage()
- func (x *NewWorkflowExecutionInfo) ProtoReflect() protoreflect.Message
- func (x *NewWorkflowExecutionInfo) Reset()
- func (x *NewWorkflowExecutionInfo) String() string
- type NexusOperationCancellationInfo
- func (*NexusOperationCancellationInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NexusOperationCancellationInfo) GetAttempt() int32
- func (x *NexusOperationCancellationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
- func (x *NexusOperationCancellationInfo) GetLastAttemptFailure() *v14.Failure
- func (x *NexusOperationCancellationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
- func (x *NexusOperationCancellationInfo) GetRequestedTime() *timestamppb.Timestamp
- func (x *NexusOperationCancellationInfo) GetState() v11.NexusOperationCancellationState
- func (*NexusOperationCancellationInfo) ProtoMessage()
- func (x *NexusOperationCancellationInfo) ProtoReflect() protoreflect.Message
- func (x *NexusOperationCancellationInfo) Reset()
- func (x *NexusOperationCancellationInfo) String() string
- type PendingActivityInfo
- func (*PendingActivityInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PendingActivityInfo) GetActivityId() string
- func (x *PendingActivityInfo) GetActivityType() *v1.ActivityType
- func (m *PendingActivityInfo) GetAssignedBuildId() isPendingActivityInfo_AssignedBuildId
- func (x *PendingActivityInfo) GetAttempt() int32
- func (x *PendingActivityInfo) GetExpirationTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetHeartbeatDetails() *v1.Payloads
- func (x *PendingActivityInfo) GetLastFailure() *v14.Failure
- func (x *PendingActivityInfo) GetLastHeartbeatTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetLastIndependentlyAssignedBuildId() string
- func (x *PendingActivityInfo) GetLastStartedTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetLastWorkerIdentity() string
- func (x *PendingActivityInfo) GetLastWorkerVersionStamp() *v1.WorkerVersionStamp
- func (x *PendingActivityInfo) GetMaximumAttempts() int32
- func (x *PendingActivityInfo) GetScheduledTime() *timestamppb.Timestamp
- func (x *PendingActivityInfo) GetState() v11.PendingActivityState
- func (x *PendingActivityInfo) GetUseWorkflowBuildId() *emptypb.Empty
- func (*PendingActivityInfo) ProtoMessage()
- func (x *PendingActivityInfo) ProtoReflect() protoreflect.Message
- func (x *PendingActivityInfo) Reset()
- func (x *PendingActivityInfo) String() string
- type PendingActivityInfo_LastIndependentlyAssignedBuildId
- type PendingActivityInfo_UseWorkflowBuildId
- type PendingChildExecutionInfo
- func (*PendingChildExecutionInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*PendingChildExecutionInfo) ProtoMessage()
- func (x *PendingChildExecutionInfo) ProtoReflect() protoreflect.Message
- func (x *PendingChildExecutionInfo) Reset()
- func (x *PendingChildExecutionInfo) String() string
- type PendingNexusOperationInfo
- func (*PendingNexusOperationInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PendingNexusOperationInfo) GetAttempt() int32
- func (x *PendingNexusOperationInfo) GetCancellationInfo() *NexusOperationCancellationInfo
- func (x *PendingNexusOperationInfo) GetEndpoint() string
- func (x *PendingNexusOperationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
- func (x *PendingNexusOperationInfo) GetLastAttemptFailure() *v14.Failure
- func (x *PendingNexusOperationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
- func (x *PendingNexusOperationInfo) GetOperation() string
- func (x *PendingNexusOperationInfo) GetOperationId() string
- func (x *PendingNexusOperationInfo) GetScheduleToCloseTimeout() *durationpb.Duration
- func (x *PendingNexusOperationInfo) GetScheduledTime() *timestamppb.Timestamp
- func (x *PendingNexusOperationInfo) GetService() string
- func (x *PendingNexusOperationInfo) GetState() v11.PendingNexusOperationState
- func (*PendingNexusOperationInfo) ProtoMessage()
- func (x *PendingNexusOperationInfo) ProtoReflect() protoreflect.Message
- func (x *PendingNexusOperationInfo) Reset()
- func (x *PendingNexusOperationInfo) String() string
- type PendingWorkflowTaskInfo
- func (*PendingWorkflowTaskInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*PendingWorkflowTaskInfo) ProtoMessage()
- func (x *PendingWorkflowTaskInfo) ProtoReflect() protoreflect.Message
- func (x *PendingWorkflowTaskInfo) Reset()
- func (x *PendingWorkflowTaskInfo) String() string
- type ResetPointInfo
- func (*ResetPointInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ResetPointInfo) GetBinaryChecksum() string
- 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 (*ResetPointInfo) ProtoMessage()
- func (x *ResetPointInfo) ProtoReflect() protoreflect.Message
- func (x *ResetPointInfo) Reset()
- func (x *ResetPointInfo) String() string
- type ResetPoints
- type WorkflowExecutionConfig
- func (*WorkflowExecutionConfig) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout() *durationpb.Duration
- func (x *WorkflowExecutionConfig) GetTaskQueue() *v12.TaskQueue
- func (x *WorkflowExecutionConfig) GetUserMetadata() *v13.UserMetadata
- func (x *WorkflowExecutionConfig) GetWorkflowExecutionTimeout() *durationpb.Duration
- func (x *WorkflowExecutionConfig) GetWorkflowRunTimeout() *durationpb.Duration
- func (*WorkflowExecutionConfig) ProtoMessage()
- func (x *WorkflowExecutionConfig) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionConfig) Reset()
- func (x *WorkflowExecutionConfig) String() string
- type WorkflowExecutionInfo
- func (*WorkflowExecutionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *WorkflowExecutionInfo) GetAssignedBuildId() string
- 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) GetHistoryLength() int64
- func (x *WorkflowExecutionInfo) GetHistorySizeBytes() int64
- func (x *WorkflowExecutionInfo) GetInheritedBuildId() string
- func (x *WorkflowExecutionInfo) GetMemo() *v1.Memo
- func (x *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v1.WorkerVersionStamp
- func (x *WorkflowExecutionInfo) GetParentExecution() *v1.WorkflowExecution
- func (x *WorkflowExecutionInfo) GetParentNamespaceId() string
- 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 (*WorkflowExecutionInfo) ProtoMessage()
- func (x *WorkflowExecutionInfo) ProtoReflect() protoreflect.Message
- func (x *WorkflowExecutionInfo) Reset()
- func (x *WorkflowExecutionInfo) String() string
Constants ¶
This section is empty.
Variables ¶
var File_temporal_api_workflow_v1_message_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CallbackInfo ¶ added in v4.11.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 *v14.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 */
// contains filtered or unexported fields
}
CallbackInfo contains the state of an attached workflow callback.
func (*CallbackInfo) Descriptor
deprecated
added in
v4.11.0
func (*CallbackInfo) Descriptor() ([]byte, []int)
Deprecated: Use CallbackInfo.ProtoReflect.Descriptor instead.
func (*CallbackInfo) GetAttempt ¶ added in v4.11.0
func (x *CallbackInfo) GetAttempt() int32
func (*CallbackInfo) GetCallback ¶ added in v4.11.0
func (x *CallbackInfo) GetCallback() *v1.Callback
func (*CallbackInfo) GetLastAttemptCompleteTime ¶ added in v4.11.0
func (x *CallbackInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
func (*CallbackInfo) GetLastAttemptFailure ¶ added in v4.11.0
func (x *CallbackInfo) GetLastAttemptFailure() *v14.Failure
func (*CallbackInfo) GetNextAttemptScheduleTime ¶ added in v4.11.0
func (x *CallbackInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
func (*CallbackInfo) GetRegistrationTime ¶ added in v4.11.0
func (x *CallbackInfo) GetRegistrationTime() *timestamppb.Timestamp
func (*CallbackInfo) GetState ¶ added in v4.11.0
func (x *CallbackInfo) GetState() v11.CallbackState
func (*CallbackInfo) GetTrigger ¶ added in v4.11.0
func (x *CallbackInfo) GetTrigger() *CallbackInfo_Trigger
func (*CallbackInfo) ProtoMessage ¶ added in v4.11.0
func (*CallbackInfo) ProtoMessage()
func (*CallbackInfo) ProtoReflect ¶ added in v4.11.0
func (x *CallbackInfo) ProtoReflect() protoreflect.Message
func (*CallbackInfo) Reset ¶ added in v4.11.0
func (x *CallbackInfo) Reset()
func (*CallbackInfo) String ¶ added in v4.11.0
func (x *CallbackInfo) String() string
type CallbackInfo_Trigger ¶ added in v4.11.0
type CallbackInfo_Trigger struct {
// Types that are assignable to Variant:
//
// *CallbackInfo_Trigger_WorkflowClosed
Variant isCallbackInfo_Trigger_Variant `protobuf_oneof:"variant"`
// contains filtered or unexported fields
}
func (*CallbackInfo_Trigger) Descriptor
deprecated
added in
v4.11.0
func (*CallbackInfo_Trigger) Descriptor() ([]byte, []int)
Deprecated: Use CallbackInfo_Trigger.ProtoReflect.Descriptor instead.
func (*CallbackInfo_Trigger) GetVariant ¶ added in v4.11.0
func (m *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant
func (*CallbackInfo_Trigger) GetWorkflowClosed ¶ added in v4.11.0
func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed
func (*CallbackInfo_Trigger) ProtoMessage ¶ added in v4.11.0
func (*CallbackInfo_Trigger) ProtoMessage()
func (*CallbackInfo_Trigger) ProtoReflect ¶ added in v4.11.0
func (x *CallbackInfo_Trigger) ProtoReflect() protoreflect.Message
func (*CallbackInfo_Trigger) Reset ¶ added in v4.11.0
func (x *CallbackInfo_Trigger) Reset()
func (*CallbackInfo_Trigger) String ¶ added in v4.11.0
func (x *CallbackInfo_Trigger) String() string
type CallbackInfo_Trigger_WorkflowClosed ¶ added in v4.11.0
type CallbackInfo_Trigger_WorkflowClosed struct {
WorkflowClosed *CallbackInfo_WorkflowClosed `protobuf:"bytes,1,opt,name=workflow_closed,json=workflowClosed,proto3,oneof"`
}
type CallbackInfo_WorkflowClosed ¶ added in v4.11.0
type CallbackInfo_WorkflowClosed struct {
// contains filtered or unexported fields
}
Trigger for when the workflow is closed.
func (*CallbackInfo_WorkflowClosed) Descriptor
deprecated
added in
v4.11.0
func (*CallbackInfo_WorkflowClosed) Descriptor() ([]byte, []int)
Deprecated: Use CallbackInfo_WorkflowClosed.ProtoReflect.Descriptor instead.
func (*CallbackInfo_WorkflowClosed) ProtoMessage ¶ added in v4.11.0
func (*CallbackInfo_WorkflowClosed) ProtoMessage()
func (*CallbackInfo_WorkflowClosed) ProtoReflect ¶ added in v4.11.0
func (x *CallbackInfo_WorkflowClosed) ProtoReflect() protoreflect.Message
func (*CallbackInfo_WorkflowClosed) Reset ¶ added in v4.11.0
func (x *CallbackInfo_WorkflowClosed) Reset()
func (*CallbackInfo_WorkflowClosed) String ¶ added in v4.11.0
func (x *CallbackInfo_WorkflowClosed) String() string
type NewWorkflowExecutionInfo ¶
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 *v12.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 *v13.UserMetadata `protobuf:"bytes,14,opt,name=user_metadata,json=userMetadata,proto3" json:"user_metadata,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
func (*NewWorkflowExecutionInfo) Descriptor() ([]byte, []int)
Deprecated: Use NewWorkflowExecutionInfo.ProtoReflect.Descriptor instead.
func (*NewWorkflowExecutionInfo) GetCronSchedule ¶
func (x *NewWorkflowExecutionInfo) GetCronSchedule() string
func (*NewWorkflowExecutionInfo) GetHeader ¶
func (x *NewWorkflowExecutionInfo) GetHeader() *v1.Header
func (*NewWorkflowExecutionInfo) GetInput ¶
func (x *NewWorkflowExecutionInfo) GetInput() *v1.Payloads
func (*NewWorkflowExecutionInfo) GetMemo ¶
func (x *NewWorkflowExecutionInfo) GetMemo() *v1.Memo
func (*NewWorkflowExecutionInfo) GetRetryPolicy ¶
func (x *NewWorkflowExecutionInfo) GetRetryPolicy() *v1.RetryPolicy
func (*NewWorkflowExecutionInfo) GetSearchAttributes ¶
func (x *NewWorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes
func (*NewWorkflowExecutionInfo) GetTaskQueue ¶
func (x *NewWorkflowExecutionInfo) GetTaskQueue() *v12.TaskQueue
func (*NewWorkflowExecutionInfo) GetUserMetadata ¶ added in v4.13.0
func (x *NewWorkflowExecutionInfo) GetUserMetadata() *v13.UserMetadata
func (*NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout ¶
func (x *NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout() *durationpb.Duration
func (*NewWorkflowExecutionInfo) GetWorkflowId ¶
func (x *NewWorkflowExecutionInfo) GetWorkflowId() string
func (*NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy ¶
func (x *NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy
func (*NewWorkflowExecutionInfo) GetWorkflowRunTimeout ¶
func (x *NewWorkflowExecutionInfo) GetWorkflowRunTimeout() *durationpb.Duration
func (*NewWorkflowExecutionInfo) GetWorkflowTaskTimeout ¶
func (x *NewWorkflowExecutionInfo) GetWorkflowTaskTimeout() *durationpb.Duration
func (*NewWorkflowExecutionInfo) GetWorkflowType ¶
func (x *NewWorkflowExecutionInfo) GetWorkflowType() *v1.WorkflowType
func (*NewWorkflowExecutionInfo) ProtoMessage ¶
func (*NewWorkflowExecutionInfo) ProtoMessage()
func (*NewWorkflowExecutionInfo) ProtoReflect ¶
func (x *NewWorkflowExecutionInfo) ProtoReflect() protoreflect.Message
func (*NewWorkflowExecutionInfo) Reset ¶
func (x *NewWorkflowExecutionInfo) Reset()
func (*NewWorkflowExecutionInfo) String ¶
func (x *NewWorkflowExecutionInfo) String() string
type NexusOperationCancellationInfo ¶ added in v4.13.0
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 *v14.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 */
// contains filtered or unexported fields
}
NexusOperationCancellationInfo contains the state of a nexus operation cancellation.
func (*NexusOperationCancellationInfo) Descriptor
deprecated
added in
v4.13.0
func (*NexusOperationCancellationInfo) Descriptor() ([]byte, []int)
Deprecated: Use NexusOperationCancellationInfo.ProtoReflect.Descriptor instead.
func (*NexusOperationCancellationInfo) GetAttempt ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) GetAttempt() int32
func (*NexusOperationCancellationInfo) GetLastAttemptCompleteTime ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
func (*NexusOperationCancellationInfo) GetLastAttemptFailure ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) GetLastAttemptFailure() *v14.Failure
func (*NexusOperationCancellationInfo) GetNextAttemptScheduleTime ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
func (*NexusOperationCancellationInfo) GetRequestedTime ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) GetRequestedTime() *timestamppb.Timestamp
func (*NexusOperationCancellationInfo) GetState ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) GetState() v11.NexusOperationCancellationState
func (*NexusOperationCancellationInfo) ProtoMessage ¶ added in v4.13.0
func (*NexusOperationCancellationInfo) ProtoMessage()
func (*NexusOperationCancellationInfo) ProtoReflect ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) ProtoReflect() protoreflect.Message
func (*NexusOperationCancellationInfo) Reset ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) Reset()
func (*NexusOperationCancellationInfo) String ¶ added in v4.13.0
func (x *NexusOperationCancellationInfo) String() string
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 *v14.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.
//
// Types that are assignable to AssignedBuildId:
//
// *PendingActivityInfo_UseWorkflowBuildId
// *PendingActivityInfo_LastIndependentlyAssignedBuildId
AssignedBuildId isPendingActivityInfo_AssignedBuildId `protobuf_oneof:"assigned_build_id"`
// The version stamp of the worker to whom this activity was most recently dispatched
LastWorkerVersionStamp *v1.WorkerVersionStamp `` /* 132-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*PendingActivityInfo) Descriptor
deprecated
func (*PendingActivityInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingActivityInfo.ProtoReflect.Descriptor instead.
func (*PendingActivityInfo) GetActivityId ¶
func (x *PendingActivityInfo) GetActivityId() string
func (*PendingActivityInfo) GetActivityType ¶
func (x *PendingActivityInfo) GetActivityType() *v1.ActivityType
func (*PendingActivityInfo) GetAssignedBuildId ¶ added in v4.13.0
func (m *PendingActivityInfo) GetAssignedBuildId() isPendingActivityInfo_AssignedBuildId
func (*PendingActivityInfo) GetAttempt ¶
func (x *PendingActivityInfo) GetAttempt() int32
func (*PendingActivityInfo) GetExpirationTime ¶
func (x *PendingActivityInfo) GetExpirationTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetHeartbeatDetails ¶
func (x *PendingActivityInfo) GetHeartbeatDetails() *v1.Payloads
func (*PendingActivityInfo) GetLastFailure ¶
func (x *PendingActivityInfo) GetLastFailure() *v14.Failure
func (*PendingActivityInfo) GetLastHeartbeatTime ¶
func (x *PendingActivityInfo) GetLastHeartbeatTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetLastIndependentlyAssignedBuildId ¶ added in v4.13.0
func (x *PendingActivityInfo) GetLastIndependentlyAssignedBuildId() string
func (*PendingActivityInfo) GetLastStartedTime ¶
func (x *PendingActivityInfo) GetLastStartedTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetLastWorkerIdentity ¶
func (x *PendingActivityInfo) GetLastWorkerIdentity() string
func (*PendingActivityInfo) GetLastWorkerVersionStamp ¶ added in v4.13.0
func (x *PendingActivityInfo) GetLastWorkerVersionStamp() *v1.WorkerVersionStamp
func (*PendingActivityInfo) GetMaximumAttempts ¶
func (x *PendingActivityInfo) GetMaximumAttempts() int32
func (*PendingActivityInfo) GetScheduledTime ¶
func (x *PendingActivityInfo) GetScheduledTime() *timestamppb.Timestamp
func (*PendingActivityInfo) GetState ¶
func (x *PendingActivityInfo) GetState() v11.PendingActivityState
func (*PendingActivityInfo) GetUseWorkflowBuildId ¶ added in v4.13.0
func (x *PendingActivityInfo) GetUseWorkflowBuildId() *emptypb.Empty
func (*PendingActivityInfo) ProtoMessage ¶
func (*PendingActivityInfo) ProtoMessage()
func (*PendingActivityInfo) ProtoReflect ¶
func (x *PendingActivityInfo) ProtoReflect() protoreflect.Message
func (*PendingActivityInfo) Reset ¶
func (x *PendingActivityInfo) Reset()
func (*PendingActivityInfo) String ¶
func (x *PendingActivityInfo) String() string
type PendingActivityInfo_LastIndependentlyAssignedBuildId ¶ added in v4.13.0
type PendingActivityInfo_LastIndependentlyAssignedBuildId struct {
// 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.
LastIndependentlyAssignedBuildId string `protobuf:"bytes,14,opt,name=last_independently_assigned_build_id,json=lastIndependentlyAssignedBuildId,proto3,oneof"`
}
type PendingActivityInfo_UseWorkflowBuildId ¶ added in v4.13.0
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) 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) ProtoMessage ¶
func (*PendingChildExecutionInfo) ProtoMessage()
func (*PendingChildExecutionInfo) ProtoReflect ¶
func (x *PendingChildExecutionInfo) ProtoReflect() protoreflect.Message
func (*PendingChildExecutionInfo) Reset ¶
func (x *PendingChildExecutionInfo) Reset()
func (*PendingChildExecutionInfo) String ¶
func (x *PendingChildExecutionInfo) String() string
type PendingNexusOperationInfo ¶ added in v4.13.0
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.
OperationId string `protobuf:"bytes,4,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
// Schedule-to-close timeout for this operation.
// This is the only timeout settable by a workflow.
// (-- api-linter: core::0140::prepositions=disabled
//
// aip.dev/not-precedent: "to" is used to indicate interval. --)
ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
// The time when the operation was scheduled.
ScheduledTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
State v11.PendingNexusOperationState `protobuf:"varint,7,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingNexusOperationState" json:"state,omitempty"`
// The number of attempts made to deliver the start operation request.
// This number represents a minimum bound since the attempt is incremented after the request completes.
Attempt int32 `protobuf:"varint,8,opt,name=attempt,proto3" json:"attempt,omitempty"`
// The time when the last attempt completed.
LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
// The last attempt's failure, if any.
LastAttemptFailure *v14.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"`
// contains filtered or unexported fields
}
PendingNexusOperationInfo contains the state of a pending Nexus operation.
func (*PendingNexusOperationInfo) Descriptor
deprecated
added in
v4.13.0
func (*PendingNexusOperationInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingNexusOperationInfo.ProtoReflect.Descriptor instead.
func (*PendingNexusOperationInfo) GetAttempt ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetAttempt() int32
func (*PendingNexusOperationInfo) GetCancellationInfo ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetCancellationInfo() *NexusOperationCancellationInfo
func (*PendingNexusOperationInfo) GetEndpoint ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetEndpoint() string
func (*PendingNexusOperationInfo) GetLastAttemptCompleteTime ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp
func (*PendingNexusOperationInfo) GetLastAttemptFailure ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetLastAttemptFailure() *v14.Failure
func (*PendingNexusOperationInfo) GetNextAttemptScheduleTime ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp
func (*PendingNexusOperationInfo) GetOperation ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetOperation() string
func (*PendingNexusOperationInfo) GetOperationId ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetOperationId() string
func (*PendingNexusOperationInfo) GetScheduleToCloseTimeout ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetScheduleToCloseTimeout() *durationpb.Duration
func (*PendingNexusOperationInfo) GetScheduledTime ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetScheduledTime() *timestamppb.Timestamp
func (*PendingNexusOperationInfo) GetService ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetService() string
func (*PendingNexusOperationInfo) GetState ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) GetState() v11.PendingNexusOperationState
func (*PendingNexusOperationInfo) ProtoMessage ¶ added in v4.13.0
func (*PendingNexusOperationInfo) ProtoMessage()
func (*PendingNexusOperationInfo) ProtoReflect ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) ProtoReflect() protoreflect.Message
func (*PendingNexusOperationInfo) Reset ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) Reset()
func (*PendingNexusOperationInfo) String ¶ added in v4.13.0
func (x *PendingNexusOperationInfo) String() string
type PendingWorkflowTaskInfo ¶
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
func (*PendingWorkflowTaskInfo) Descriptor() ([]byte, []int)
Deprecated: Use PendingWorkflowTaskInfo.ProtoReflect.Descriptor instead.
func (*PendingWorkflowTaskInfo) GetAttempt ¶
func (x *PendingWorkflowTaskInfo) GetAttempt() int32
func (*PendingWorkflowTaskInfo) GetOriginalScheduledTime ¶
func (x *PendingWorkflowTaskInfo) GetOriginalScheduledTime() *timestamppb.Timestamp
func (*PendingWorkflowTaskInfo) GetScheduledTime ¶
func (x *PendingWorkflowTaskInfo) GetScheduledTime() *timestamppb.Timestamp
func (*PendingWorkflowTaskInfo) GetStartedTime ¶
func (x *PendingWorkflowTaskInfo) GetStartedTime() *timestamppb.Timestamp
func (*PendingWorkflowTaskInfo) GetState ¶
func (x *PendingWorkflowTaskInfo) GetState() v11.PendingWorkflowTaskState
func (*PendingWorkflowTaskInfo) ProtoMessage ¶
func (*PendingWorkflowTaskInfo) ProtoMessage()
func (*PendingWorkflowTaskInfo) ProtoReflect ¶
func (x *PendingWorkflowTaskInfo) ProtoReflect() protoreflect.Message
func (*PendingWorkflowTaskInfo) Reset ¶
func (x *PendingWorkflowTaskInfo) Reset()
func (*PendingWorkflowTaskInfo) String ¶
func (x *PendingWorkflowTaskInfo) String() string
type ResetPointInfo ¶
type ResetPointInfo struct {
// Worker build id.
BuildId string `protobuf:"bytes,7,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
// A worker binary version identifier (deprecated).
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) GetBinaryChecksum ¶
func (x *ResetPointInfo) GetBinaryChecksum() string
func (*ResetPointInfo) GetBuildId ¶ added in v4.11.0
func (x *ResetPointInfo) GetBuildId() string
func (*ResetPointInfo) GetCreateTime ¶
func (x *ResetPointInfo) GetCreateTime() *timestamppb.Timestamp
func (*ResetPointInfo) GetExpireTime ¶
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) ProtoMessage ¶
func (*ResetPointInfo) ProtoMessage()
func (*ResetPointInfo) ProtoReflect ¶
func (x *ResetPointInfo) ProtoReflect() protoreflect.Message
func (*ResetPointInfo) Reset ¶
func (x *ResetPointInfo) Reset()
func (*ResetPointInfo) String ¶
func (x *ResetPointInfo) String() string
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) GetPoints ¶
func (x *ResetPoints) GetPoints() []*ResetPointInfo
func (*ResetPoints) ProtoMessage ¶
func (*ResetPoints) ProtoMessage()
func (*ResetPoints) ProtoReflect ¶
func (x *ResetPoints) ProtoReflect() protoreflect.Message
func (*ResetPoints) Reset ¶
func (x *ResetPoints) Reset()
func (*ResetPoints) String ¶
func (x *ResetPoints) String() string
type WorkflowExecutionConfig ¶
type WorkflowExecutionConfig struct {
TaskQueue *v12.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 *v13.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) GetDefaultWorkflowTaskTimeout ¶
func (x *WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout() *durationpb.Duration
func (*WorkflowExecutionConfig) GetTaskQueue ¶
func (x *WorkflowExecutionConfig) GetTaskQueue() *v12.TaskQueue
func (*WorkflowExecutionConfig) GetUserMetadata ¶ added in v4.13.0
func (x *WorkflowExecutionConfig) GetUserMetadata() *v13.UserMetadata
func (*WorkflowExecutionConfig) GetWorkflowExecutionTimeout ¶
func (x *WorkflowExecutionConfig) GetWorkflowExecutionTimeout() *durationpb.Duration
func (*WorkflowExecutionConfig) GetWorkflowRunTimeout ¶
func (x *WorkflowExecutionConfig) GetWorkflowRunTimeout() *durationpb.Duration
func (*WorkflowExecutionConfig) ProtoMessage ¶
func (*WorkflowExecutionConfig) ProtoMessage()
func (*WorkflowExecutionConfig) ProtoReflect ¶
func (x *WorkflowExecutionConfig) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionConfig) Reset ¶
func (x *WorkflowExecutionConfig) Reset()
func (*WorkflowExecutionConfig) String ¶
func (x *WorkflowExecutionConfig) String() string
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
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.
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.
InheritedBuildId string `protobuf:"bytes,20,opt,name=inherited_build_id,json=inheritedBuildId,proto3" json:"inherited_build_id,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowExecutionInfo) Descriptor
deprecated
func (*WorkflowExecutionInfo) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowExecutionInfo.ProtoReflect.Descriptor instead.
func (*WorkflowExecutionInfo) GetAssignedBuildId ¶ added in v4.13.0
func (x *WorkflowExecutionInfo) GetAssignedBuildId() string
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 v4.13.0
func (x *WorkflowExecutionInfo) GetExecutionDuration() *durationpb.Duration
func (*WorkflowExecutionInfo) GetExecutionTime ¶
func (x *WorkflowExecutionInfo) GetExecutionTime() *timestamppb.Timestamp
func (*WorkflowExecutionInfo) GetHistoryLength ¶
func (x *WorkflowExecutionInfo) GetHistoryLength() int64
func (*WorkflowExecutionInfo) GetHistorySizeBytes ¶
func (x *WorkflowExecutionInfo) GetHistorySizeBytes() int64
func (*WorkflowExecutionInfo) GetInheritedBuildId ¶ added in v4.13.0
func (x *WorkflowExecutionInfo) GetInheritedBuildId() string
func (*WorkflowExecutionInfo) GetMemo ¶
func (x *WorkflowExecutionInfo) GetMemo() *v1.Memo
func (*WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp ¶
func (x *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v1.WorkerVersionStamp
func (*WorkflowExecutionInfo) GetParentExecution ¶
func (x *WorkflowExecutionInfo) GetParentExecution() *v1.WorkflowExecution
func (*WorkflowExecutionInfo) GetParentNamespaceId ¶
func (x *WorkflowExecutionInfo) GetParentNamespaceId() string
func (*WorkflowExecutionInfo) GetRootExecution ¶ added in v4.13.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 ¶
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) ProtoMessage ¶
func (*WorkflowExecutionInfo) ProtoMessage()
func (*WorkflowExecutionInfo) ProtoReflect ¶
func (x *WorkflowExecutionInfo) ProtoReflect() protoreflect.Message
func (*WorkflowExecutionInfo) Reset ¶
func (x *WorkflowExecutionInfo) Reset()
func (*WorkflowExecutionInfo) String ¶
func (x *WorkflowExecutionInfo) String() string