workflow

package
v0.0.0-...-52a6fbd Latest Latest
Warning

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

 Go to latest Published: May 9, 2026 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var File_temporal_api_next_workflow_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CallbackInfo 

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 

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

Deprecated: Use CallbackInfo.ProtoReflect.Descriptor instead.

func (*CallbackInfo) GetAttempt 

func (x *CallbackInfo) GetAttempt() int32

func (*CallbackInfo) GetBlockedReason 

func (x *CallbackInfo) GetBlockedReason() string

func (*CallbackInfo) GetCallback 

func (x *CallbackInfo) GetCallback() *v1.Callback

func (*CallbackInfo) GetLastAttemptCompleteTime 

func (x *CallbackInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp

func (*CallbackInfo) GetLastAttemptFailure 

func (x *CallbackInfo) GetLastAttemptFailure() *v15.Failure

func (*CallbackInfo) GetNextAttemptScheduleTime 

func (x *CallbackInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp

func (*CallbackInfo) GetRegistrationTime 

func (x *CallbackInfo) GetRegistrationTime() *timestamppb.Timestamp

func (*CallbackInfo) GetState 

func (x *CallbackInfo) GetState() v11.CallbackState

func (*CallbackInfo) GetTrigger 

func (x *CallbackInfo) GetTrigger() *CallbackInfo_Trigger

func (*CallbackInfo) ProtoMessage 

func (*CallbackInfo) ProtoMessage()

func (*CallbackInfo) ProtoReflect 

func (x *CallbackInfo) ProtoReflect() protoreflect.Message

func (*CallbackInfo) Reset 

func (x *CallbackInfo) Reset()

func (*CallbackInfo) String 

func (x *CallbackInfo) String() string

type CallbackInfo_Trigger 

type CallbackInfo_Trigger struct {

	// Types that are valid to be assigned to Variant:
	//
	//	*CallbackInfo_Trigger_WorkflowClosed
	Variant isCallbackInfo_Trigger_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*CallbackInfo_Trigger) Descriptor deprecated 

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

Deprecated: Use CallbackInfo_Trigger.ProtoReflect.Descriptor instead.

func (*CallbackInfo_Trigger) GetVariant 

func (x *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant

func (*CallbackInfo_Trigger) GetWorkflowClosed 

func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed

func (*CallbackInfo_Trigger) ProtoMessage 

func (*CallbackInfo_Trigger) ProtoMessage()

func (*CallbackInfo_Trigger) ProtoReflect 

func (x *CallbackInfo_Trigger) ProtoReflect() protoreflect.Message

func (*CallbackInfo_Trigger) Reset 

func (x *CallbackInfo_Trigger) Reset()

func (*CallbackInfo_Trigger) String 

func (x *CallbackInfo_Trigger) String() string

type CallbackInfo_Trigger_WorkflowClosed 

type CallbackInfo_Trigger_WorkflowClosed struct {
	WorkflowClosed *CallbackInfo_WorkflowClosed `protobuf:"bytes,1,opt,name=workflow_closed,json=workflowClosed,proto3,oneof"`
}

type CallbackInfo_WorkflowClosed 

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

Trigger for when the workflow is closed.

func (*CallbackInfo_WorkflowClosed) Descriptor deprecated 

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

Deprecated: Use CallbackInfo_WorkflowClosed.ProtoReflect.Descriptor instead.

func (*CallbackInfo_WorkflowClosed) ProtoMessage 

func (*CallbackInfo_WorkflowClosed) ProtoMessage()

func (*CallbackInfo_WorkflowClosed) ProtoReflect 

func (x *CallbackInfo_WorkflowClosed) ProtoReflect() protoreflect.Message

func (*CallbackInfo_WorkflowClosed) Reset 

func (x *CallbackInfo_WorkflowClosed) Reset()

func (*CallbackInfo_WorkflowClosed) String 

func (x *CallbackInfo_WorkflowClosed) String() string

type DeploymentTransition 

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 

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

Deprecated: Use DeploymentTransition.ProtoReflect.Descriptor instead.

func (*DeploymentTransition) GetDeployment 

func (x *DeploymentTransition) GetDeployment() *v12.Deployment

func (*DeploymentTransition) ProtoMessage 

func (*DeploymentTransition) ProtoMessage()

func (*DeploymentTransition) ProtoReflect 

func (x *DeploymentTransition) ProtoReflect() protoreflect.Message

func (*DeploymentTransition) Reset 

func (x *DeploymentTransition) Reset()

func (*DeploymentTransition) String 

func (x *DeploymentTransition) String() string

type DeploymentVersionTransition 

type DeploymentVersionTransition struct {

	// Deprecated. Use `deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api_next/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 

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

Deprecated: Use DeploymentVersionTransition.ProtoReflect.Descriptor instead.

func (*DeploymentVersionTransition) GetDeploymentVersion 

func (x *DeploymentVersionTransition) GetDeploymentVersion() *v12.WorkerDeploymentVersion

func (*DeploymentVersionTransition) GetVersion deprecated 

func (x *DeploymentVersionTransition) GetVersion() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*DeploymentVersionTransition) ProtoMessage 

func (*DeploymentVersionTransition) ProtoMessage()

func (*DeploymentVersionTransition) ProtoReflect 

func (x *DeploymentVersionTransition) ProtoReflect() protoreflect.Message

func (*DeploymentVersionTransition) Reset 

func (x *DeploymentVersionTransition) Reset()

func (*DeploymentVersionTransition) String 

func (x *DeploymentVersionTransition) 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    *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 

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) GetPriority 

func (x *NewWorkflowExecutionInfo) GetPriority() *v1.Priority

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() *v13.TaskQueue

func (*NewWorkflowExecutionInfo) GetUserMetadata 

func (x *NewWorkflowExecutionInfo) GetUserMetadata() *v14.UserMetadata

func (*NewWorkflowExecutionInfo) GetVersioningOverride 

func (x *NewWorkflowExecutionInfo) GetVersioningOverride() *VersioningOverride

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 

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 

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

Deprecated: Use NexusOperationCancellationInfo.ProtoReflect.Descriptor instead.

func (*NexusOperationCancellationInfo) GetAttempt 

func (x *NexusOperationCancellationInfo) GetAttempt() int32

func (*NexusOperationCancellationInfo) GetBlockedReason 

func (x *NexusOperationCancellationInfo) GetBlockedReason() string

func (*NexusOperationCancellationInfo) GetLastAttemptCompleteTime 

func (x *NexusOperationCancellationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp

func (*NexusOperationCancellationInfo) GetLastAttemptFailure 

func (x *NexusOperationCancellationInfo) GetLastAttemptFailure() *v15.Failure

func (*NexusOperationCancellationInfo) GetNextAttemptScheduleTime 

func (x *NexusOperationCancellationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp

func (*NexusOperationCancellationInfo) GetRequestedTime 

func (x *NexusOperationCancellationInfo) GetRequestedTime() *timestamppb.Timestamp

func (*NexusOperationCancellationInfo) GetState 

func (x *NexusOperationCancellationInfo) GetState() v11.NexusOperationCancellationState

func (*NexusOperationCancellationInfo) ProtoMessage 

func (*NexusOperationCancellationInfo) ProtoMessage()

func (*NexusOperationCancellationInfo) ProtoReflect 

func (x *NexusOperationCancellationInfo) ProtoReflect() protoreflect.Message

func (*NexusOperationCancellationInfo) Reset 

func (x *NexusOperationCancellationInfo) Reset()

func (*NexusOperationCancellationInfo) String 

func (x *NexusOperationCancellationInfo) String() string

type OnConflictOptions 

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 

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

Deprecated: Use OnConflictOptions.ProtoReflect.Descriptor instead.

func (*OnConflictOptions) GetAttachCompletionCallbacks 

func (x *OnConflictOptions) GetAttachCompletionCallbacks() bool
func (x *OnConflictOptions) GetAttachLinks() bool

func (*OnConflictOptions) GetAttachRequestId 

func (x *OnConflictOptions) GetAttachRequestId() bool

func (*OnConflictOptions) ProtoMessage 

func (*OnConflictOptions) ProtoMessage()

func (*OnConflictOptions) ProtoReflect 

func (x *OnConflictOptions) ProtoReflect() protoreflect.Message

func (*OnConflictOptions) Reset 

func (x *OnConflictOptions) Reset()

func (*OnConflictOptions) String 

func (x *OnConflictOptions) 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        *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_next/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_next/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_next/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) GetActivityId 

func (x *PendingActivityInfo) GetActivityId() string

func (*PendingActivityInfo) GetActivityOptions 

func (x *PendingActivityInfo) GetActivityOptions() *v16.ActivityOptions

func (*PendingActivityInfo) GetActivityType 

func (x *PendingActivityInfo) GetActivityType() *v1.ActivityType

func (*PendingActivityInfo) GetAssignedBuildId 

func (x *PendingActivityInfo) GetAssignedBuildId() isPendingActivityInfo_AssignedBuildId

func (*PendingActivityInfo) GetAttempt 

func (x *PendingActivityInfo) GetAttempt() int32

func (*PendingActivityInfo) GetCurrentRetryInterval 

func (x *PendingActivityInfo) GetCurrentRetryInterval() *durationpb.Duration

func (*PendingActivityInfo) GetExpirationTime 

func (x *PendingActivityInfo) GetExpirationTime() *timestamppb.Timestamp

func (*PendingActivityInfo) GetHeartbeatDetails 

func (x *PendingActivityInfo) GetHeartbeatDetails() *v1.Payloads

func (*PendingActivityInfo) GetLastAttemptCompleteTime 

func (x *PendingActivityInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp

func (*PendingActivityInfo) GetLastDeployment deprecated 

func (x *PendingActivityInfo) GetLastDeployment() *v12.Deployment

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*PendingActivityInfo) GetLastDeploymentVersion 

func (x *PendingActivityInfo) GetLastDeploymentVersion() *v12.WorkerDeploymentVersion

func (*PendingActivityInfo) GetLastFailure 

func (x *PendingActivityInfo) GetLastFailure() *v15.Failure

func (*PendingActivityInfo) GetLastHeartbeatTime 

func (x *PendingActivityInfo) GetLastHeartbeatTime() *timestamppb.Timestamp

func (*PendingActivityInfo) GetLastIndependentlyAssignedBuildId deprecated 

func (x *PendingActivityInfo) GetLastIndependentlyAssignedBuildId() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*PendingActivityInfo) GetLastStartedTime 

func (x *PendingActivityInfo) GetLastStartedTime() *timestamppb.Timestamp

func (*PendingActivityInfo) GetLastWorkerDeploymentVersion deprecated 

func (x *PendingActivityInfo) GetLastWorkerDeploymentVersion() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*PendingActivityInfo) GetLastWorkerIdentity 

func (x *PendingActivityInfo) GetLastWorkerIdentity() string

func (*PendingActivityInfo) GetLastWorkerVersionStamp deprecated 

func (x *PendingActivityInfo) GetLastWorkerVersionStamp() *v1.WorkerVersionStamp

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*PendingActivityInfo) GetMaximumAttempts 

func (x *PendingActivityInfo) GetMaximumAttempts() int32

func (*PendingActivityInfo) GetNextAttemptScheduleTime 

func (x *PendingActivityInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp

func (*PendingActivityInfo) GetPauseInfo 

func (x *PendingActivityInfo) GetPauseInfo() *PendingActivityInfo_PauseInfo

func (*PendingActivityInfo) GetPaused 

func (x *PendingActivityInfo) GetPaused() bool

func (*PendingActivityInfo) GetPriority 

func (x *PendingActivityInfo) GetPriority() *v1.Priority

func (*PendingActivityInfo) GetScheduledTime 

func (x *PendingActivityInfo) GetScheduledTime() *timestamppb.Timestamp

func (*PendingActivityInfo) GetState 

func (x *PendingActivityInfo) GetState() v11.PendingActivityState

func (*PendingActivityInfo) GetUseWorkflowBuildId deprecated 

func (x *PendingActivityInfo) GetUseWorkflowBuildId() *emptypb.Empty

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

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 

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_next/workflow/v1/message.proto.
	LastIndependentlyAssignedBuildId string `protobuf:"bytes,14,opt,name=last_independently_assigned_build_id,json=lastIndependentlyAssignedBuildId,proto3,oneof"`
}

type PendingActivityInfo_PauseInfo 

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 

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

Deprecated: Use PendingActivityInfo_PauseInfo.ProtoReflect.Descriptor instead.

func (*PendingActivityInfo_PauseInfo) GetManual 

func (x *PendingActivityInfo_PauseInfo) GetManual() *PendingActivityInfo_PauseInfo_Manual

func (*PendingActivityInfo_PauseInfo) GetPauseTime 

func (x *PendingActivityInfo_PauseInfo) GetPauseTime() *timestamppb.Timestamp

func (*PendingActivityInfo_PauseInfo) GetPausedBy 

func (x *PendingActivityInfo_PauseInfo) GetPausedBy() isPendingActivityInfo_PauseInfo_PausedBy

func (*PendingActivityInfo_PauseInfo) GetRule 

func (x *PendingActivityInfo_PauseInfo) GetRule() *PendingActivityInfo_PauseInfo_Rule

func (*PendingActivityInfo_PauseInfo) ProtoMessage 

func (*PendingActivityInfo_PauseInfo) ProtoMessage()

func (*PendingActivityInfo_PauseInfo) ProtoReflect 

func (x *PendingActivityInfo_PauseInfo) ProtoReflect() protoreflect.Message

func (*PendingActivityInfo_PauseInfo) Reset 

func (x *PendingActivityInfo_PauseInfo) Reset()

func (*PendingActivityInfo_PauseInfo) String 

func (x *PendingActivityInfo_PauseInfo) String() string

type PendingActivityInfo_PauseInfo_Manual 

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 

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

Deprecated: Use PendingActivityInfo_PauseInfo_Manual.ProtoReflect.Descriptor instead.

func (*PendingActivityInfo_PauseInfo_Manual) GetIdentity 

func (x *PendingActivityInfo_PauseInfo_Manual) GetIdentity() string

func (*PendingActivityInfo_PauseInfo_Manual) GetReason 

func (x *PendingActivityInfo_PauseInfo_Manual) GetReason() string

func (*PendingActivityInfo_PauseInfo_Manual) ProtoMessage 

func (*PendingActivityInfo_PauseInfo_Manual) ProtoMessage()

func (*PendingActivityInfo_PauseInfo_Manual) ProtoReflect 

func (x *PendingActivityInfo_PauseInfo_Manual) ProtoReflect() protoreflect.Message

func (*PendingActivityInfo_PauseInfo_Manual) Reset 

func (x *PendingActivityInfo_PauseInfo_Manual) Reset()

func (*PendingActivityInfo_PauseInfo_Manual) String 

func (x *PendingActivityInfo_PauseInfo_Manual) String() string

type PendingActivityInfo_PauseInfo_Manual_ 

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 

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 

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

Deprecated: Use PendingActivityInfo_PauseInfo_Rule.ProtoReflect.Descriptor instead.

func (*PendingActivityInfo_PauseInfo_Rule) GetIdentity 

func (x *PendingActivityInfo_PauseInfo_Rule) GetIdentity() string

func (*PendingActivityInfo_PauseInfo_Rule) GetReason 

func (x *PendingActivityInfo_PauseInfo_Rule) GetReason() string

func (*PendingActivityInfo_PauseInfo_Rule) GetRuleId 

func (x *PendingActivityInfo_PauseInfo_Rule) GetRuleId() string

func (*PendingActivityInfo_PauseInfo_Rule) ProtoMessage 

func (*PendingActivityInfo_PauseInfo_Rule) ProtoMessage()

func (*PendingActivityInfo_PauseInfo_Rule) ProtoReflect 

func (x *PendingActivityInfo_PauseInfo_Rule) ProtoReflect() protoreflect.Message

func (*PendingActivityInfo_PauseInfo_Rule) Reset 

func (x *PendingActivityInfo_PauseInfo_Rule) Reset()

func (*PendingActivityInfo_PauseInfo_Rule) String 

func (x *PendingActivityInfo_PauseInfo_Rule) String() string

type PendingActivityInfo_PauseInfo_Rule_ 

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 

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_next/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) 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 

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_next/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 

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

Deprecated: Use PendingNexusOperationInfo.ProtoReflect.Descriptor instead.

func (*PendingNexusOperationInfo) GetAttempt 

func (x *PendingNexusOperationInfo) GetAttempt() int32

func (*PendingNexusOperationInfo) GetBlockedReason 

func (x *PendingNexusOperationInfo) GetBlockedReason() string

func (*PendingNexusOperationInfo) GetCancellationInfo 

func (x *PendingNexusOperationInfo) GetCancellationInfo() *NexusOperationCancellationInfo

func (*PendingNexusOperationInfo) GetEndpoint 

func (x *PendingNexusOperationInfo) GetEndpoint() string

func (*PendingNexusOperationInfo) GetLastAttemptCompleteTime 

func (x *PendingNexusOperationInfo) GetLastAttemptCompleteTime() *timestamppb.Timestamp

func (*PendingNexusOperationInfo) GetLastAttemptFailure 

func (x *PendingNexusOperationInfo) GetLastAttemptFailure() *v15.Failure

func (*PendingNexusOperationInfo) GetNextAttemptScheduleTime 

func (x *PendingNexusOperationInfo) GetNextAttemptScheduleTime() *timestamppb.Timestamp

func (*PendingNexusOperationInfo) GetOperation 

func (x *PendingNexusOperationInfo) GetOperation() string

func (*PendingNexusOperationInfo) GetOperationId deprecated 

func (x *PendingNexusOperationInfo) GetOperationId() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*PendingNexusOperationInfo) GetOperationToken 

func (x *PendingNexusOperationInfo) GetOperationToken() string

func (*PendingNexusOperationInfo) GetScheduleToCloseTimeout 

func (x *PendingNexusOperationInfo) GetScheduleToCloseTimeout() *durationpb.Duration

func (*PendingNexusOperationInfo) GetScheduleToStartTimeout 

func (x *PendingNexusOperationInfo) GetScheduleToStartTimeout() *durationpb.Duration

func (*PendingNexusOperationInfo) GetScheduledEventId 

func (x *PendingNexusOperationInfo) GetScheduledEventId() int64

func (*PendingNexusOperationInfo) GetScheduledTime 

func (x *PendingNexusOperationInfo) GetScheduledTime() *timestamppb.Timestamp

func (*PendingNexusOperationInfo) GetService 

func (x *PendingNexusOperationInfo) GetService() string

func (*PendingNexusOperationInfo) GetStartToCloseTimeout 

func (x *PendingNexusOperationInfo) GetStartToCloseTimeout() *durationpb.Duration

func (*PendingNexusOperationInfo) GetState 

func (x *PendingNexusOperationInfo) GetState() v11.PendingNexusOperationState

func (*PendingNexusOperationInfo) ProtoMessage 

func (*PendingNexusOperationInfo) ProtoMessage()

func (*PendingNexusOperationInfo) ProtoReflect 

func (x *PendingNexusOperationInfo) ProtoReflect() protoreflect.Message

func (*PendingNexusOperationInfo) Reset 

func (x *PendingNexusOperationInfo) Reset()

func (*PendingNexusOperationInfo) String 

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 PostResetOperation 

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 

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

Deprecated: Use PostResetOperation.ProtoReflect.Descriptor instead.

func (*PostResetOperation) GetSignalWorkflow 

func (x *PostResetOperation) GetSignalWorkflow() *PostResetOperation_SignalWorkflow

func (*PostResetOperation) GetUpdateWorkflowOptions 

func (x *PostResetOperation) GetUpdateWorkflowOptions() *PostResetOperation_UpdateWorkflowOptions

func (*PostResetOperation) GetVariant 

func (x *PostResetOperation) GetVariant() isPostResetOperation_Variant

func (*PostResetOperation) ProtoMessage 

func (*PostResetOperation) ProtoMessage()

func (*PostResetOperation) ProtoReflect 

func (x *PostResetOperation) ProtoReflect() protoreflect.Message

func (*PostResetOperation) Reset 

func (x *PostResetOperation) Reset()

func (*PostResetOperation) String 

func (x *PostResetOperation) String() string

type PostResetOperation_SignalWorkflow 

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 

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

Deprecated: Use PostResetOperation_SignalWorkflow.ProtoReflect.Descriptor instead.

func (*PostResetOperation_SignalWorkflow) GetHeader 

func (x *PostResetOperation_SignalWorkflow) GetHeader() *v1.Header

func (*PostResetOperation_SignalWorkflow) GetInput 

func (x *PostResetOperation_SignalWorkflow) GetInput() *v1.Payloads
func (x *PostResetOperation_SignalWorkflow) GetLinks() []*v1.Link

func (*PostResetOperation_SignalWorkflow) GetSignalName 

func (x *PostResetOperation_SignalWorkflow) GetSignalName() string

func (*PostResetOperation_SignalWorkflow) ProtoMessage 

func (*PostResetOperation_SignalWorkflow) ProtoMessage()

func (*PostResetOperation_SignalWorkflow) ProtoReflect 

func (x *PostResetOperation_SignalWorkflow) ProtoReflect() protoreflect.Message

func (*PostResetOperation_SignalWorkflow) Reset 

func (x *PostResetOperation_SignalWorkflow) Reset()

func (*PostResetOperation_SignalWorkflow) String 

func (x *PostResetOperation_SignalWorkflow) String() string

type PostResetOperation_SignalWorkflow_ 

type PostResetOperation_SignalWorkflow_ struct {
	SignalWorkflow *PostResetOperation_SignalWorkflow `protobuf:"bytes,1,opt,name=signal_workflow,json=signalWorkflow,proto3,oneof"`
}

type PostResetOperation_UpdateWorkflowOptions 

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 

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

Deprecated: Use PostResetOperation_UpdateWorkflowOptions.ProtoReflect.Descriptor instead.

func (*PostResetOperation_UpdateWorkflowOptions) GetUpdateMask 

func (x *PostResetOperation_UpdateWorkflowOptions) GetUpdateMask() *fieldmaskpb.FieldMask

func (*PostResetOperation_UpdateWorkflowOptions) GetWorkflowExecutionOptions 

func (x *PostResetOperation_UpdateWorkflowOptions) GetWorkflowExecutionOptions() *WorkflowExecutionOptions

func (*PostResetOperation_UpdateWorkflowOptions) ProtoMessage 

func (*PostResetOperation_UpdateWorkflowOptions) ProtoMessage()

func (*PostResetOperation_UpdateWorkflowOptions) ProtoReflect 

func (x *PostResetOperation_UpdateWorkflowOptions) ProtoReflect() protoreflect.Message

func (*PostResetOperation_UpdateWorkflowOptions) Reset 

func (x *PostResetOperation_UpdateWorkflowOptions) Reset()

func (*PostResetOperation_UpdateWorkflowOptions) String 

func (x *PostResetOperation_UpdateWorkflowOptions) String() string

type PostResetOperation_UpdateWorkflowOptions_ 

type PostResetOperation_UpdateWorkflowOptions_ struct {
	UpdateWorkflowOptions *PostResetOperation_UpdateWorkflowOptions `protobuf:"bytes,2,opt,name=update_workflow_options,json=updateWorkflowOptions,proto3,oneof"`
}

type RequestIdInfo 

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 

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

Deprecated: Use RequestIdInfo.ProtoReflect.Descriptor instead.

func (*RequestIdInfo) GetBuffered 

func (x *RequestIdInfo) GetBuffered() bool

func (*RequestIdInfo) GetEventId 

func (x *RequestIdInfo) GetEventId() int64

func (*RequestIdInfo) GetEventType 

func (x *RequestIdInfo) GetEventType() v11.EventType

func (*RequestIdInfo) ProtoMessage 

func (*RequestIdInfo) ProtoMessage()

func (*RequestIdInfo) ProtoReflect 

func (x *RequestIdInfo) ProtoReflect() protoreflect.Message

func (*RequestIdInfo) Reset 

func (x *RequestIdInfo) Reset()

func (*RequestIdInfo) String 

func (x *RequestIdInfo) 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"`
	// Deprecated. A worker binary version identifier.
	//
	// Deprecated: Marked as deprecated in temporal/api_next/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) GetBinaryChecksum deprecated 

func (x *ResetPointInfo) GetBinaryChecksum() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*ResetPointInfo) GetBuildId 

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 TimeSkippingConfig 

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 

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

Deprecated: Use TimeSkippingConfig.ProtoReflect.Descriptor instead.

func (*TimeSkippingConfig) GetBound 

func (x *TimeSkippingConfig) GetBound() isTimeSkippingConfig_Bound

func (*TimeSkippingConfig) GetEnabled 

func (x *TimeSkippingConfig) GetEnabled() bool

func (*TimeSkippingConfig) GetMaxElapsedDuration 

func (x *TimeSkippingConfig) GetMaxElapsedDuration() *durationpb.Duration

func (*TimeSkippingConfig) GetMaxSkippedDuration 

func (x *TimeSkippingConfig) GetMaxSkippedDuration() *durationpb.Duration

func (*TimeSkippingConfig) ProtoMessage 

func (*TimeSkippingConfig) ProtoMessage()

func (*TimeSkippingConfig) ProtoReflect 

func (x *TimeSkippingConfig) ProtoReflect() protoreflect.Message

func (*TimeSkippingConfig) Reset 

func (x *TimeSkippingConfig) Reset()

func (*TimeSkippingConfig) String 

func (x *TimeSkippingConfig) String() string

type TimeSkippingConfig_MaxElapsedDuration 

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 

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 

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_next/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_next/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_next/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 

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

Deprecated: Use VersioningOverride.ProtoReflect.Descriptor instead.

func (*VersioningOverride) GetAutoUpgrade 

func (x *VersioningOverride) GetAutoUpgrade() bool

func (*VersioningOverride) GetBehavior deprecated 

func (x *VersioningOverride) GetBehavior() v11.VersioningBehavior

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*VersioningOverride) GetDeployment deprecated 

func (x *VersioningOverride) GetDeployment() *v12.Deployment

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*VersioningOverride) GetOverride 

func (x *VersioningOverride) GetOverride() isVersioningOverride_Override

func (*VersioningOverride) GetPinned 

func (x *VersioningOverride) GetPinned() *VersioningOverride_PinnedOverride

func (*VersioningOverride) GetPinnedVersion deprecated 

func (x *VersioningOverride) GetPinnedVersion() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*VersioningOverride) ProtoMessage 

func (*VersioningOverride) ProtoMessage()

func (*VersioningOverride) ProtoReflect 

func (x *VersioningOverride) ProtoReflect() protoreflect.Message

func (*VersioningOverride) Reset 

func (x *VersioningOverride) Reset()

func (*VersioningOverride) String 

func (x *VersioningOverride) String() string

type VersioningOverride_AutoUpgrade 

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 

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 

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 

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

Deprecated: Use VersioningOverride_PinnedOverride.ProtoReflect.Descriptor instead.

func (*VersioningOverride_PinnedOverride) GetBehavior 

func (x *VersioningOverride_PinnedOverride) GetBehavior() VersioningOverride_PinnedOverrideBehavior

func (*VersioningOverride_PinnedOverride) GetVersion 

func (x *VersioningOverride_PinnedOverride) GetVersion() *v12.WorkerDeploymentVersion

func (*VersioningOverride_PinnedOverride) ProtoMessage 

func (*VersioningOverride_PinnedOverride) ProtoMessage()

func (*VersioningOverride_PinnedOverride) ProtoReflect 

func (x *VersioningOverride_PinnedOverride) ProtoReflect() protoreflect.Message

func (*VersioningOverride_PinnedOverride) Reset 

func (x *VersioningOverride_PinnedOverride) Reset()

func (*VersioningOverride_PinnedOverride) String 

func (x *VersioningOverride_PinnedOverride) String() string

type VersioningOverride_PinnedOverrideBehavior 

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 

func (VersioningOverride_PinnedOverrideBehavior) Descriptor() protoreflect.EnumDescriptor

func (VersioningOverride_PinnedOverrideBehavior) Enum 

func (x VersioningOverride_PinnedOverrideBehavior) Enum() *VersioningOverride_PinnedOverrideBehavior

func (VersioningOverride_PinnedOverrideBehavior) EnumDescriptor deprecated 

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

Deprecated: Use VersioningOverride_PinnedOverrideBehavior.Descriptor instead.

func (VersioningOverride_PinnedOverrideBehavior) Number 

func (x VersioningOverride_PinnedOverrideBehavior) Number() protoreflect.EnumNumber

func (VersioningOverride_PinnedOverrideBehavior) String 

func (x VersioningOverride_PinnedOverrideBehavior) String() string

func (VersioningOverride_PinnedOverrideBehavior) Type 

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) GetDefaultWorkflowTaskTimeout 

func (x *WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout() *durationpb.Duration

func (*WorkflowExecutionConfig) GetTaskQueue 

func (x *WorkflowExecutionConfig) GetTaskQueue() *v13.TaskQueue

func (*WorkflowExecutionConfig) GetUserMetadata 

func (x *WorkflowExecutionConfig) GetUserMetadata() *v14.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 WorkflowExecutionExtendedInfo 

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 

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

Deprecated: Use WorkflowExecutionExtendedInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionExtendedInfo) GetCancelRequested 

func (x *WorkflowExecutionExtendedInfo) GetCancelRequested() bool

func (*WorkflowExecutionExtendedInfo) GetExecutionExpirationTime 

func (x *WorkflowExecutionExtendedInfo) GetExecutionExpirationTime() *timestamppb.Timestamp

func (*WorkflowExecutionExtendedInfo) GetLastResetTime 

func (x *WorkflowExecutionExtendedInfo) GetLastResetTime() *timestamppb.Timestamp

func (*WorkflowExecutionExtendedInfo) GetOriginalStartTime 

func (x *WorkflowExecutionExtendedInfo) GetOriginalStartTime() *timestamppb.Timestamp

func (*WorkflowExecutionExtendedInfo) GetPauseInfo 

func (x *WorkflowExecutionExtendedInfo) GetPauseInfo() *WorkflowExecutionPauseInfo

func (*WorkflowExecutionExtendedInfo) GetRequestIdInfos 

func (x *WorkflowExecutionExtendedInfo) GetRequestIdInfos() map[string]*RequestIdInfo

func (*WorkflowExecutionExtendedInfo) GetResetRunId 

func (x *WorkflowExecutionExtendedInfo) GetResetRunId() string

func (*WorkflowExecutionExtendedInfo) GetRunExpirationTime 

func (x *WorkflowExecutionExtendedInfo) GetRunExpirationTime() *timestamppb.Timestamp

func (*WorkflowExecutionExtendedInfo) ProtoMessage 

func (*WorkflowExecutionExtendedInfo) ProtoMessage()

func (*WorkflowExecutionExtendedInfo) ProtoReflect 

func (x *WorkflowExecutionExtendedInfo) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionExtendedInfo) Reset 

func (x *WorkflowExecutionExtendedInfo) Reset()

func (*WorkflowExecutionExtendedInfo) String 

func (x *WorkflowExecutionExtendedInfo) 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
	// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	//
	// Deprecated: Marked as deprecated in temporal/api_next/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_next/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_next/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) GetAssignedBuildId deprecated 

func (x *WorkflowExecutionInfo) GetAssignedBuildId() string

Deprecated: Marked as deprecated in temporal/api_next/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 

func (x *WorkflowExecutionInfo) GetExecutionDuration() *durationpb.Duration

func (*WorkflowExecutionInfo) GetExecutionTime 

func (x *WorkflowExecutionInfo) GetExecutionTime() *timestamppb.Timestamp

func (*WorkflowExecutionInfo) GetExternalPayloadCount 

func (x *WorkflowExecutionInfo) GetExternalPayloadCount() int64

func (*WorkflowExecutionInfo) GetExternalPayloadSizeBytes 

func (x *WorkflowExecutionInfo) GetExternalPayloadSizeBytes() int64

func (*WorkflowExecutionInfo) GetFirstRunId 

func (x *WorkflowExecutionInfo) GetFirstRunId() string

func (*WorkflowExecutionInfo) GetHistoryLength 

func (x *WorkflowExecutionInfo) GetHistoryLength() int64

func (*WorkflowExecutionInfo) GetHistorySizeBytes 

func (x *WorkflowExecutionInfo) GetHistorySizeBytes() int64

func (*WorkflowExecutionInfo) GetInheritedBuildId deprecated 

func (x *WorkflowExecutionInfo) GetInheritedBuildId() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*WorkflowExecutionInfo) GetMemo 

func (x *WorkflowExecutionInfo) GetMemo() *v1.Memo

func (*WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp deprecated 

func (x *WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp() *v1.WorkerVersionStamp

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*WorkflowExecutionInfo) GetParentExecution 

func (x *WorkflowExecutionInfo) GetParentExecution() *v1.WorkflowExecution

func (*WorkflowExecutionInfo) GetParentNamespaceId 

func (x *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetPriority 

func (x *WorkflowExecutionInfo) GetPriority() *v1.Priority

func (*WorkflowExecutionInfo) GetRootExecution 

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) GetVersioningInfo 

func (x *WorkflowExecutionInfo) GetVersioningInfo() *WorkflowExecutionVersioningInfo

func (*WorkflowExecutionInfo) GetWorkerDeploymentName 

func (x *WorkflowExecutionInfo) GetWorkerDeploymentName() string

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

type WorkflowExecutionOptions 

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 

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

Deprecated: Use WorkflowExecutionOptions.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionOptions) GetPriority 

func (x *WorkflowExecutionOptions) GetPriority() *v1.Priority

func (*WorkflowExecutionOptions) GetTimeSkippingConfig 

func (x *WorkflowExecutionOptions) GetTimeSkippingConfig() *TimeSkippingConfig

func (*WorkflowExecutionOptions) GetVersioningOverride 

func (x *WorkflowExecutionOptions) GetVersioningOverride() *VersioningOverride

func (*WorkflowExecutionOptions) ProtoMessage 

func (*WorkflowExecutionOptions) ProtoMessage()

func (*WorkflowExecutionOptions) ProtoReflect 

func (x *WorkflowExecutionOptions) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionOptions) Reset 

func (x *WorkflowExecutionOptions) Reset()

func (*WorkflowExecutionOptions) String 

func (x *WorkflowExecutionOptions) String() string

type WorkflowExecutionPauseInfo 

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 

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

Deprecated: Use WorkflowExecutionPauseInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionPauseInfo) GetIdentity 

func (x *WorkflowExecutionPauseInfo) GetIdentity() string

func (*WorkflowExecutionPauseInfo) GetPausedTime 

func (x *WorkflowExecutionPauseInfo) GetPausedTime() *timestamppb.Timestamp

func (*WorkflowExecutionPauseInfo) GetReason 

func (x *WorkflowExecutionPauseInfo) GetReason() string

func (*WorkflowExecutionPauseInfo) ProtoMessage 

func (*WorkflowExecutionPauseInfo) ProtoMessage()

func (*WorkflowExecutionPauseInfo) ProtoReflect 

func (x *WorkflowExecutionPauseInfo) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionPauseInfo) Reset 

func (x *WorkflowExecutionPauseInfo) Reset()

func (*WorkflowExecutionPauseInfo) String 

func (x *WorkflowExecutionPauseInfo) String() string

type WorkflowExecutionVersioningInfo 

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_next/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_next/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_next/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 

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

Deprecated: Use WorkflowExecutionVersioningInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionVersioningInfo) GetBehavior 

func (x *WorkflowExecutionVersioningInfo) GetBehavior() v11.VersioningBehavior

func (*WorkflowExecutionVersioningInfo) GetContinueAsNewInitialVersioningBehavior 

func (x *WorkflowExecutionVersioningInfo) GetContinueAsNewInitialVersioningBehavior() v11.ContinueAsNewVersioningBehavior

func (*WorkflowExecutionVersioningInfo) GetDeployment deprecated 

func (x *WorkflowExecutionVersioningInfo) GetDeployment() *v12.Deployment

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*WorkflowExecutionVersioningInfo) GetDeploymentTransition deprecated 

func (x *WorkflowExecutionVersioningInfo) GetDeploymentTransition() *DeploymentTransition

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*WorkflowExecutionVersioningInfo) GetDeploymentVersion 

func (x *WorkflowExecutionVersioningInfo) GetDeploymentVersion() *v12.WorkerDeploymentVersion

func (*WorkflowExecutionVersioningInfo) GetRevisionNumber 

func (x *WorkflowExecutionVersioningInfo) GetRevisionNumber() int64

func (*WorkflowExecutionVersioningInfo) GetVersion deprecated 

func (x *WorkflowExecutionVersioningInfo) GetVersion() string

Deprecated: Marked as deprecated in temporal/api_next/workflow/v1/message.proto.

func (*WorkflowExecutionVersioningInfo) GetVersionTransition 

func (x *WorkflowExecutionVersioningInfo) GetVersionTransition() *DeploymentVersionTransition

func (*WorkflowExecutionVersioningInfo) GetVersioningOverride 

func (x *WorkflowExecutionVersioningInfo) GetVersioningOverride() *VersioningOverride

func (*WorkflowExecutionVersioningInfo) ProtoMessage 

func (*WorkflowExecutionVersioningInfo) ProtoMessage()

func (*WorkflowExecutionVersioningInfo) ProtoReflect 

func (x *WorkflowExecutionVersioningInfo) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionVersioningInfo) Reset 

func (x *WorkflowExecutionVersioningInfo) Reset()

func (*WorkflowExecutionVersioningInfo) String 

func (x *WorkflowExecutionVersioningInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.