workflow

package
v1.62.13 Latest Latest
Warning

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

Go to latest
Published: May 28, 2026 License: MIT Imports: 18 Imported by: 64

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

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_workflow_v1_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CallbackInfo added in v1.27.0

type CallbackInfo struct {

	// Information on how this callback should be invoked (e.g. its URL and type).
	Callback *v1.Callback `protobuf:"bytes,1,opt,name=callback,proto3" json:"callback,omitempty"`
	// Trigger for this callback.
	Trigger *CallbackInfo_Trigger `protobuf:"bytes,2,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// The time when the callback was registered.
	RegistrationTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=registration_time,json=registrationTime,proto3" json:"registration_time,omitempty"`
	State            v11.CallbackState      `protobuf:"varint,4,opt,name=state,proto3,enum=temporal.api.enums.v1.CallbackState" json:"state,omitempty"`
	// The number of attempts made to deliver the callback.
	// This number represents a minimum bound since the attempt is incremented after the callback request completes.
	Attempt int32 `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// The time when the last attempt completed.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// The last attempt's failure, if any.
	LastAttemptFailure *v15.Failure `protobuf:"bytes,7,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
	// The time when the next attempt is scheduled.
	NextAttemptScheduleTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// If the state is BLOCKED, blocked reason provides additional information.
	BlockedReason string `protobuf:"bytes,9,opt,name=blocked_reason,json=blockedReason,proto3" json:"blocked_reason,omitempty"`
	// contains filtered or unexported fields
}

CallbackInfo contains the state of an attached workflow callback.

func (*CallbackInfo) Descriptor deprecated added in v1.27.0

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

Deprecated: Use CallbackInfo.ProtoReflect.Descriptor instead.

func (*CallbackInfo) Equal added in v1.27.0

func (this *CallbackInfo) Equal(that interface{}) bool

Equal returns whether two CallbackInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CallbackInfo) GetAttempt added in v1.27.0

func (x *CallbackInfo) GetAttempt() int32

func (*CallbackInfo) GetBlockedReason added in v1.42.0

func (x *CallbackInfo) GetBlockedReason() string

func (*CallbackInfo) GetCallback added in v1.27.0

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

func (*CallbackInfo) GetLastAttemptCompleteTime added in v1.27.0

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

func (*CallbackInfo) GetLastAttemptFailure added in v1.27.0

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

func (*CallbackInfo) GetNextAttemptScheduleTime added in v1.27.0

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

func (*CallbackInfo) GetRegistrationTime added in v1.27.0

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

func (*CallbackInfo) GetState added in v1.27.0

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

func (*CallbackInfo) GetTrigger added in v1.27.0

func (x *CallbackInfo) GetTrigger() *CallbackInfo_Trigger

func (*CallbackInfo) Marshal added in v1.27.0

func (val *CallbackInfo) Marshal() ([]byte, error)

Marshal an object of type CallbackInfo to the protobuf v3 wire format

func (*CallbackInfo) ProtoMessage added in v1.27.0

func (*CallbackInfo) ProtoMessage()

func (*CallbackInfo) ProtoReflect added in v1.27.0

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

func (*CallbackInfo) Reset added in v1.27.0

func (x *CallbackInfo) Reset()

func (*CallbackInfo) Size added in v1.27.0

func (val *CallbackInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CallbackInfo) String added in v1.27.0

func (x *CallbackInfo) String() string

func (*CallbackInfo) Unmarshal added in v1.27.0

func (val *CallbackInfo) Unmarshal(buf []byte) error

Unmarshal an object of type CallbackInfo from the protobuf v3 wire format

type CallbackInfo_Trigger added in v1.27.0

type CallbackInfo_Trigger struct {

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

func (*CallbackInfo_Trigger) Descriptor deprecated added in v1.27.0

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

Deprecated: Use CallbackInfo_Trigger.ProtoReflect.Descriptor instead.

func (*CallbackInfo_Trigger) GetUpdateWorkflowExecutionCompleted added in v1.62.13

func (x *CallbackInfo_Trigger) GetUpdateWorkflowExecutionCompleted() *CallbackInfo_UpdateWorkflowExecutionCompleted

func (*CallbackInfo_Trigger) GetVariant added in v1.27.0

func (x *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant

func (*CallbackInfo_Trigger) GetWorkflowClosed added in v1.27.0

func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed

func (*CallbackInfo_Trigger) ProtoMessage added in v1.27.0

func (*CallbackInfo_Trigger) ProtoMessage()

func (*CallbackInfo_Trigger) ProtoReflect added in v1.27.0

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

func (*CallbackInfo_Trigger) Reset added in v1.27.0

func (x *CallbackInfo_Trigger) Reset()

func (*CallbackInfo_Trigger) String added in v1.27.0

func (x *CallbackInfo_Trigger) String() string

type CallbackInfo_Trigger_UpdateWorkflowExecutionCompleted added in v1.62.13

type CallbackInfo_Trigger_UpdateWorkflowExecutionCompleted struct {
	UpdateWorkflowExecutionCompleted *CallbackInfo_UpdateWorkflowExecutionCompleted `protobuf:"bytes,2,opt,name=update_workflow_execution_completed,json=updateWorkflowExecutionCompleted,proto3,oneof"`
}

type CallbackInfo_Trigger_WorkflowClosed added in v1.27.0

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

type CallbackInfo_UpdateWorkflowExecutionCompleted added in v1.62.13

type CallbackInfo_UpdateWorkflowExecutionCompleted struct {
	UpdateId string `protobuf:"bytes,1,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
	// contains filtered or unexported fields
}

Trigger for when a workflow update is completed.

func (*CallbackInfo_UpdateWorkflowExecutionCompleted) Descriptor deprecated added in v1.62.13

Deprecated: Use CallbackInfo_UpdateWorkflowExecutionCompleted.ProtoReflect.Descriptor instead.

func (*CallbackInfo_UpdateWorkflowExecutionCompleted) GetUpdateId added in v1.62.13

func (*CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoMessage added in v1.62.13

func (*CallbackInfo_UpdateWorkflowExecutionCompleted) ProtoReflect added in v1.62.13

func (*CallbackInfo_UpdateWorkflowExecutionCompleted) Reset added in v1.62.13

func (*CallbackInfo_UpdateWorkflowExecutionCompleted) String added in v1.62.13

type CallbackInfo_WorkflowClosed added in v1.27.0

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

Trigger for when the workflow is closed.

func (*CallbackInfo_WorkflowClosed) Descriptor deprecated added in v1.27.0

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

Deprecated: Use CallbackInfo_WorkflowClosed.ProtoReflect.Descriptor instead.

func (*CallbackInfo_WorkflowClosed) ProtoMessage added in v1.27.0

func (*CallbackInfo_WorkflowClosed) ProtoMessage()

func (*CallbackInfo_WorkflowClosed) ProtoReflect added in v1.27.0

func (*CallbackInfo_WorkflowClosed) Reset added in v1.27.0

func (x *CallbackInfo_WorkflowClosed) Reset()

func (*CallbackInfo_WorkflowClosed) String added in v1.27.0

func (x *CallbackInfo_WorkflowClosed) String() string

type DeploymentTransition added in v1.43.0

type DeploymentTransition struct {

	// The target deployment of the transition. Null means a so-far-versioned workflow is
	// transitioning to unversioned workers.
	Deployment *v12.Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// contains filtered or unexported fields
}

Holds information about ongoing transition of a workflow execution from one deployment to another. Deprecated. Use DeploymentVersionTransition.

func (*DeploymentTransition) Descriptor deprecated added in v1.43.0

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

Deprecated: Use DeploymentTransition.ProtoReflect.Descriptor instead.

func (*DeploymentTransition) Equal added in v1.43.0

func (this *DeploymentTransition) Equal(that interface{}) bool

Equal returns whether two DeploymentTransition values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeploymentTransition) GetDeployment added in v1.43.0

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

func (*DeploymentTransition) Marshal added in v1.43.0

func (val *DeploymentTransition) Marshal() ([]byte, error)

Marshal an object of type DeploymentTransition to the protobuf v3 wire format

func (*DeploymentTransition) ProtoMessage added in v1.43.0

func (*DeploymentTransition) ProtoMessage()

func (*DeploymentTransition) ProtoReflect added in v1.43.0

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

func (*DeploymentTransition) Reset added in v1.43.0

func (x *DeploymentTransition) Reset()

func (*DeploymentTransition) Size added in v1.43.0

func (val *DeploymentTransition) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeploymentTransition) String added in v1.43.0

func (x *DeploymentTransition) String() string

func (*DeploymentTransition) Unmarshal added in v1.43.0

func (val *DeploymentTransition) Unmarshal(buf []byte) error

Unmarshal an object of type DeploymentTransition from the protobuf v3 wire format

type DeploymentVersionTransition added in v1.44.0

type DeploymentVersionTransition struct {

	// Deprecated. Use `deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// The target Version of the transition.
	// If nil, a so-far-versioned workflow is transitioning to unversioned workers.
	DeploymentVersion *v12.WorkerDeploymentVersion `protobuf:"bytes,2,opt,name=deployment_version,json=deploymentVersion,proto3" json:"deployment_version,omitempty"`
	// contains filtered or unexported fields
}

Holds information about ongoing transition of a workflow execution from one worker deployment version to another. Experimental. Might change in the future.

func (*DeploymentVersionTransition) Descriptor deprecated added in v1.44.0

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

Deprecated: Use DeploymentVersionTransition.ProtoReflect.Descriptor instead.

func (*DeploymentVersionTransition) Equal added in v1.44.0

func (this *DeploymentVersionTransition) Equal(that interface{}) bool

Equal returns whether two DeploymentVersionTransition values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeploymentVersionTransition) GetDeploymentVersion added in v1.49.1

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

func (*DeploymentVersionTransition) GetVersion deprecated added in v1.44.0

func (x *DeploymentVersionTransition) GetVersion() string

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

func (*DeploymentVersionTransition) Marshal added in v1.44.0

func (val *DeploymentVersionTransition) Marshal() ([]byte, error)

Marshal an object of type DeploymentVersionTransition to the protobuf v3 wire format

func (*DeploymentVersionTransition) ProtoMessage added in v1.44.0

func (*DeploymentVersionTransition) ProtoMessage()

func (*DeploymentVersionTransition) ProtoReflect added in v1.44.0

func (*DeploymentVersionTransition) Reset added in v1.44.0

func (x *DeploymentVersionTransition) Reset()

func (*DeploymentVersionTransition) Size added in v1.44.0

func (val *DeploymentVersionTransition) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeploymentVersionTransition) String added in v1.44.0

func (x *DeploymentVersionTransition) String() string

func (*DeploymentVersionTransition) Unmarshal added in v1.44.0

func (val *DeploymentVersionTransition) Unmarshal(buf []byte) error

Unmarshal an object of type DeploymentVersionTransition from the protobuf v3 wire format

type NewWorkflowExecutionInfo added in v1.8.0

type NewWorkflowExecutionInfo struct {
	WorkflowId   string           `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType *v1.WorkflowType `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    *v13.TaskQueue   `protobuf:"bytes,3,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Serialized arguments to the workflow.
	Input *v1.Payloads `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new.
	WorkflowExecutionTimeout *durationpb.Duration `` /* 135-byte string literal not displayed */
	// Timeout of a single workflow run.
	WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 178-byte string literal not displayed */
	// The retry policy for the workflow. Will never exceed `workflow_execution_timeout`.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,9,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// See https://docs.temporal.io/docs/content/what-is-a-temporal-cron-job/
	CronSchedule     string               `protobuf:"bytes,10,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Memo             *v1.Memo             `protobuf:"bytes,11,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v1.SearchAttributes `protobuf:"bytes,12,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Header           *v1.Header           `protobuf:"bytes,13,opt,name=header,proto3" json:"header,omitempty"`
	// Metadata on the workflow if it is started. This is carried over to the WorkflowExecutionConfig
	// for use by user interfaces to display the fixed as-of-start summary and details of the
	// workflow.
	UserMetadata *v14.UserMetadata `protobuf:"bytes,14,opt,name=user_metadata,json=userMetadata,proto3" json:"user_metadata,omitempty"`
	// If set, takes precedence over the Versioning Behavior sent by the SDK on Workflow Task completion.
	// To unset the override after the workflow is running, use UpdateWorkflowExecutionOptions.
	VersioningOverride *VersioningOverride `protobuf:"bytes,15,opt,name=versioning_override,json=versioningOverride,proto3" json:"versioning_override,omitempty"`
	// Priority metadata
	Priority *v1.Priority `protobuf:"bytes,16,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

NewWorkflowExecutionInfo is a shared message that encapsulates all the required arguments to starting a workflow in different contexts.

func (*NewWorkflowExecutionInfo) Descriptor deprecated added in v1.8.0

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

Deprecated: Use NewWorkflowExecutionInfo.ProtoReflect.Descriptor instead.

func (*NewWorkflowExecutionInfo) Equal added in v1.8.0

func (this *NewWorkflowExecutionInfo) Equal(that interface{}) bool

Equal returns whether two NewWorkflowExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NewWorkflowExecutionInfo) GetCronSchedule added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetCronSchedule() string

func (*NewWorkflowExecutionInfo) GetHeader added in v1.8.0

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

func (*NewWorkflowExecutionInfo) GetInput added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetInput() *v1.Payloads

func (*NewWorkflowExecutionInfo) GetMemo added in v1.8.0

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

func (*NewWorkflowExecutionInfo) GetPriority added in v1.46.0

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

func (*NewWorkflowExecutionInfo) GetRetryPolicy added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetRetryPolicy() *v1.RetryPolicy

func (*NewWorkflowExecutionInfo) GetSearchAttributes added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes

func (*NewWorkflowExecutionInfo) GetTaskQueue added in v1.8.0

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

func (*NewWorkflowExecutionInfo) GetUserMetadata added in v1.34.0

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

func (*NewWorkflowExecutionInfo) GetVersioningOverride added in v1.43.0

func (x *NewWorkflowExecutionInfo) GetVersioningOverride() *VersioningOverride

func (*NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout() *durationpb.Duration

func (*NewWorkflowExecutionInfo) GetWorkflowId added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetWorkflowId() string

func (*NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

func (*NewWorkflowExecutionInfo) GetWorkflowRunTimeout added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetWorkflowRunTimeout() *durationpb.Duration

func (*NewWorkflowExecutionInfo) GetWorkflowTaskTimeout added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetWorkflowTaskTimeout() *durationpb.Duration

func (*NewWorkflowExecutionInfo) GetWorkflowType added in v1.8.0

func (x *NewWorkflowExecutionInfo) GetWorkflowType() *v1.WorkflowType

func (*NewWorkflowExecutionInfo) Marshal added in v1.8.0

func (val *NewWorkflowExecutionInfo) Marshal() ([]byte, error)

Marshal an object of type NewWorkflowExecutionInfo to the protobuf v3 wire format

func (*NewWorkflowExecutionInfo) ProtoMessage added in v1.8.0

func (*NewWorkflowExecutionInfo) ProtoMessage()

func (*NewWorkflowExecutionInfo) ProtoReflect added in v1.26.1

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

func (*NewWorkflowExecutionInfo) Reset added in v1.8.0

func (x *NewWorkflowExecutionInfo) Reset()

func (*NewWorkflowExecutionInfo) Size added in v1.8.0

func (val *NewWorkflowExecutionInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NewWorkflowExecutionInfo) String added in v1.8.0

func (x *NewWorkflowExecutionInfo) String() string

func (*NewWorkflowExecutionInfo) Unmarshal added in v1.8.0

func (val *NewWorkflowExecutionInfo) Unmarshal(buf []byte) error

Unmarshal an object of type NewWorkflowExecutionInfo from the protobuf v3 wire format

type NexusOperationCancellationInfo added in v1.32.1

type NexusOperationCancellationInfo struct {

	// The time when cancellation was requested.
	RequestedTime *timestamppb.Timestamp              `protobuf:"bytes,1,opt,name=requested_time,json=requestedTime,proto3" json:"requested_time,omitempty"`
	State         v11.NexusOperationCancellationState `protobuf:"varint,2,opt,name=state,proto3,enum=temporal.api.enums.v1.NexusOperationCancellationState" json:"state,omitempty"`
	// The number of attempts made to deliver the cancel operation request.
	// This number represents a minimum bound since the attempt is incremented after the request completes.
	Attempt int32 `protobuf:"varint,3,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// The time when the last attempt completed.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// The last attempt's failure, if any.
	LastAttemptFailure *v15.Failure `protobuf:"bytes,5,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
	// The time when the next attempt is scheduled.
	NextAttemptScheduleTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// If the state is BLOCKED, blocked reason provides additional information.
	BlockedReason string `protobuf:"bytes,7,opt,name=blocked_reason,json=blockedReason,proto3" json:"blocked_reason,omitempty"`
	// contains filtered or unexported fields
}

NexusOperationCancellationInfo contains the state of a nexus operation cancellation.

func (*NexusOperationCancellationInfo) Descriptor deprecated added in v1.32.1

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

Deprecated: Use NexusOperationCancellationInfo.ProtoReflect.Descriptor instead.

func (*NexusOperationCancellationInfo) Equal added in v1.32.1

func (this *NexusOperationCancellationInfo) Equal(that interface{}) bool

Equal returns whether two NexusOperationCancellationInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*NexusOperationCancellationInfo) GetAttempt added in v1.32.1

func (x *NexusOperationCancellationInfo) GetAttempt() int32

func (*NexusOperationCancellationInfo) GetBlockedReason added in v1.42.0

func (x *NexusOperationCancellationInfo) GetBlockedReason() string

func (*NexusOperationCancellationInfo) GetLastAttemptCompleteTime added in v1.32.1

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

func (*NexusOperationCancellationInfo) GetLastAttemptFailure added in v1.32.1

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

func (*NexusOperationCancellationInfo) GetNextAttemptScheduleTime added in v1.32.1

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

func (*NexusOperationCancellationInfo) GetRequestedTime added in v1.32.1

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

func (*NexusOperationCancellationInfo) GetState added in v1.32.1

func (*NexusOperationCancellationInfo) Marshal added in v1.32.1

func (val *NexusOperationCancellationInfo) Marshal() ([]byte, error)

Marshal an object of type NexusOperationCancellationInfo to the protobuf v3 wire format

func (*NexusOperationCancellationInfo) ProtoMessage added in v1.32.1

func (*NexusOperationCancellationInfo) ProtoMessage()

func (*NexusOperationCancellationInfo) ProtoReflect added in v1.32.1

func (*NexusOperationCancellationInfo) Reset added in v1.32.1

func (x *NexusOperationCancellationInfo) Reset()

func (*NexusOperationCancellationInfo) Size added in v1.32.1

func (val *NexusOperationCancellationInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*NexusOperationCancellationInfo) String added in v1.32.1

func (*NexusOperationCancellationInfo) Unmarshal added in v1.32.1

func (val *NexusOperationCancellationInfo) Unmarshal(buf []byte) error

Unmarshal an object of type NexusOperationCancellationInfo from the protobuf v3 wire format

type OnConflictOptions added in v1.44.0

type OnConflictOptions struct {

	// Attaches the request ID to the running workflow.
	AttachRequestId bool `protobuf:"varint,1,opt,name=attach_request_id,json=attachRequestId,proto3" json:"attach_request_id,omitempty"`
	// Attaches the completion callbacks to the running workflow.
	AttachCompletionCallbacks bool `` /* 139-byte string literal not displayed */
	// Attaches the links to the WorkflowExecutionOptionsUpdatedEvent history event.
	AttachLinks bool `protobuf:"varint,3,opt,name=attach_links,json=attachLinks,proto3" json:"attach_links,omitempty"`
	// contains filtered or unexported fields
}

When StartWorkflowExecution uses the conflict policy WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING and there is already an existing running workflow, OnConflictOptions defines actions to be taken on the existing running workflow. In this case, it will create a WorkflowExecutionOptionsUpdatedEvent history event in the running workflow with the changes requested in this object.

func (*OnConflictOptions) Descriptor deprecated added in v1.44.0

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

Deprecated: Use OnConflictOptions.ProtoReflect.Descriptor instead.

func (*OnConflictOptions) Equal added in v1.44.0

func (this *OnConflictOptions) Equal(that interface{}) bool

Equal returns whether two OnConflictOptions values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*OnConflictOptions) GetAttachCompletionCallbacks added in v1.44.0

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

func (*OnConflictOptions) GetAttachRequestId added in v1.44.0

func (x *OnConflictOptions) GetAttachRequestId() bool

func (*OnConflictOptions) Marshal added in v1.44.0

func (val *OnConflictOptions) Marshal() ([]byte, error)

Marshal an object of type OnConflictOptions to the protobuf v3 wire format

func (*OnConflictOptions) ProtoMessage added in v1.44.0

func (*OnConflictOptions) ProtoMessage()

func (*OnConflictOptions) ProtoReflect added in v1.44.0

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

func (*OnConflictOptions) Reset added in v1.44.0

func (x *OnConflictOptions) Reset()

func (*OnConflictOptions) Size added in v1.44.0

func (val *OnConflictOptions) Size() int

Size returns the size of the object, in bytes, once serialized

func (*OnConflictOptions) String added in v1.44.0

func (x *OnConflictOptions) String() string

func (*OnConflictOptions) Unmarshal added in v1.44.0

func (val *OnConflictOptions) Unmarshal(buf []byte) error

Unmarshal an object of type OnConflictOptions from the protobuf v3 wire format

type PendingActivityInfo

type PendingActivityInfo struct {
	ActivityId         string                   `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	ActivityType       *v1.ActivityType         `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	State              v11.PendingActivityState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingActivityState" json:"state,omitempty"`
	HeartbeatDetails   *v1.Payloads             `protobuf:"bytes,4,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	LastHeartbeatTime  *timestamppb.Timestamp   `protobuf:"bytes,5,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
	LastStartedTime    *timestamppb.Timestamp   `protobuf:"bytes,6,opt,name=last_started_time,json=lastStartedTime,proto3" json:"last_started_time,omitempty"`
	Attempt            int32                    `protobuf:"varint,7,opt,name=attempt,proto3" json:"attempt,omitempty"`
	MaximumAttempts    int32                    `protobuf:"varint,8,opt,name=maximum_attempts,json=maximumAttempts,proto3" json:"maximum_attempts,omitempty"`
	ScheduledTime      *timestamppb.Timestamp   `protobuf:"bytes,9,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	ExpirationTime     *timestamppb.Timestamp   `protobuf:"bytes,10,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	LastFailure        *v15.Failure             `protobuf:"bytes,11,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity string                   `protobuf:"bytes,12,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
	// Absence of `assigned_build_id` generally means this task is on an "unversioned" task queue.
	// In rare cases, it can also mean that the task queue is versioned but we failed to write activity's
	// independently-assigned build ID to the database. This case heals automatically once the task is dispatched.
	// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	//
	// Types that are valid to be assigned to AssignedBuildId:
	//
	//	*PendingActivityInfo_UseWorkflowBuildId
	//	*PendingActivityInfo_LastIndependentlyAssignedBuildId
	AssignedBuildId isPendingActivityInfo_AssignedBuildId `protobuf_oneof:"assigned_build_id"`
	// Deprecated. The version stamp of the worker to whom this activity was most recently dispatched
	// This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	LastWorkerVersionStamp *v1.WorkerVersionStamp `` /* 132-byte string literal not displayed */
	// The time activity will wait until the next retry.
	// If activity is currently running it will be next retry interval if activity failed.
	// If activity is currently waiting it will be current retry interval.
	// If there will be no retry it will be null.
	CurrentRetryInterval *durationpb.Duration `protobuf:"bytes,16,opt,name=current_retry_interval,json=currentRetryInterval,proto3" json:"current_retry_interval,omitempty"`
	// The time when the last activity attempt was completed. If activity has not been completed yet then it will be null.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
	// Next time when activity will be scheduled.
	// If activity is currently scheduled or started it will be null.
	NextAttemptScheduleTime *timestamppb.Timestamp `` /* 135-byte string literal not displayed */
	// Indicates if activity is paused.
	Paused bool `protobuf:"varint,19,opt,name=paused,proto3" json:"paused,omitempty"`
	// The deployment this activity was dispatched to most recently. Present only if the activity
	// was dispatched to a versioned worker.
	// Deprecated. Use `last_deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	LastDeployment *v12.Deployment `protobuf:"bytes,20,opt,name=last_deployment,json=lastDeployment,proto3" json:"last_deployment,omitempty"`
	// The Worker Deployment Version this activity was dispatched to most recently.
	// Deprecated. Use `last_deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	LastWorkerDeploymentVersion string `` /* 147-byte string literal not displayed */
	// The Worker Deployment Version this activity was dispatched to most recently.
	// If nil, the activity has not yet been dispatched or was last dispatched to an unversioned worker.
	LastDeploymentVersion *v12.WorkerDeploymentVersion `` /* 127-byte string literal not displayed */
	// Priority metadata. If this message is not present, or any fields are not
	// present, they inherit the values from the workflow.
	Priority  *v1.Priority                   `protobuf:"bytes,22,opt,name=priority,proto3" json:"priority,omitempty"`
	PauseInfo *PendingActivityInfo_PauseInfo `protobuf:"bytes,23,opt,name=pause_info,json=pauseInfo,proto3" json:"pause_info,omitempty"`
	// Current activity options. May be different from the one used to start the activity.
	ActivityOptions *v16.ActivityOptions `protobuf:"bytes,24,opt,name=activity_options,json=activityOptions,proto3" json:"activity_options,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingActivityInfo) Descriptor deprecated

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

Deprecated: Use PendingActivityInfo.ProtoReflect.Descriptor instead.

func (*PendingActivityInfo) Equal

func (this *PendingActivityInfo) Equal(that interface{}) bool

Equal returns whether two PendingActivityInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PendingActivityInfo) GetActivityId

func (x *PendingActivityInfo) GetActivityId() string

func (*PendingActivityInfo) GetActivityOptions added in v1.49.1

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

func (*PendingActivityInfo) GetActivityType

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

func (*PendingActivityInfo) GetAssignedBuildId added in v1.32.0

func (x *PendingActivityInfo) GetAssignedBuildId() isPendingActivityInfo_AssignedBuildId

func (*PendingActivityInfo) GetAttempt

func (x *PendingActivityInfo) GetAttempt() int32

func (*PendingActivityInfo) GetCurrentRetryInterval added in v1.40.0

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

func (*PendingActivityInfo) GetExpirationTime added in v0.28.0

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

func (*PendingActivityInfo) GetHeartbeatDetails

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

func (*PendingActivityInfo) GetLastAttemptCompleteTime added in v1.40.0

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

func (*PendingActivityInfo) GetLastDeployment deprecated added in v1.43.0

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

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

func (*PendingActivityInfo) GetLastDeploymentVersion added in v1.49.1

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

func (*PendingActivityInfo) GetLastFailure

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

func (*PendingActivityInfo) GetLastHeartbeatTime added in v0.28.0

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

func (*PendingActivityInfo) GetLastIndependentlyAssignedBuildId deprecated added in v1.32.0

func (x *PendingActivityInfo) GetLastIndependentlyAssignedBuildId() string

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

func (*PendingActivityInfo) GetLastStartedTime added in v0.28.0

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

func (*PendingActivityInfo) GetLastWorkerDeploymentVersion deprecated added in v1.44.0

func (x *PendingActivityInfo) GetLastWorkerDeploymentVersion() string

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

func (*PendingActivityInfo) GetLastWorkerIdentity

func (x *PendingActivityInfo) GetLastWorkerIdentity() string

func (*PendingActivityInfo) GetLastWorkerVersionStamp deprecated added in v1.32.0

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

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

func (*PendingActivityInfo) GetMaximumAttempts

func (x *PendingActivityInfo) GetMaximumAttempts() int32

func (*PendingActivityInfo) GetNextAttemptScheduleTime added in v1.40.0

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

func (*PendingActivityInfo) GetPauseInfo added in v1.48.0

func (*PendingActivityInfo) GetPaused added in v1.41.0

func (x *PendingActivityInfo) GetPaused() bool

func (*PendingActivityInfo) GetPriority added in v1.46.0

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

func (*PendingActivityInfo) GetScheduledTime added in v0.28.0

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

func (*PendingActivityInfo) GetState

func (*PendingActivityInfo) GetUseWorkflowBuildId deprecated added in v1.32.0

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

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

func (*PendingActivityInfo) Marshal

func (val *PendingActivityInfo) Marshal() ([]byte, error)

Marshal an object of type PendingActivityInfo to the protobuf v3 wire format

func (*PendingActivityInfo) ProtoMessage

func (*PendingActivityInfo) ProtoMessage()

func (*PendingActivityInfo) ProtoReflect added in v1.26.1

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

func (*PendingActivityInfo) Reset

func (x *PendingActivityInfo) Reset()

func (*PendingActivityInfo) Size

func (val *PendingActivityInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PendingActivityInfo) String

func (x *PendingActivityInfo) String() string

func (*PendingActivityInfo) Unmarshal

func (val *PendingActivityInfo) Unmarshal(buf []byte) error

Unmarshal an object of type PendingActivityInfo from the protobuf v3 wire format

type PendingActivityInfo_LastIndependentlyAssignedBuildId added in v1.32.0

type PendingActivityInfo_LastIndependentlyAssignedBuildId struct {
	// Deprecated. This means the activity is independently versioned and not bound to the build ID of its workflow.
	// The activity will use the build id in this field instead.
	// If the task fails and is scheduled again, the assigned build ID may change according to the latest versioning
	// rules.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	LastIndependentlyAssignedBuildId string `protobuf:"bytes,14,opt,name=last_independently_assigned_build_id,json=lastIndependentlyAssignedBuildId,proto3,oneof"`
}

type PendingActivityInfo_PauseInfo added in v1.48.0

type PendingActivityInfo_PauseInfo struct {

	// The time when the activity was paused.
	PauseTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=pause_time,json=pauseTime,proto3" json:"pause_time,omitempty"`
	// Types that are valid to be assigned to PausedBy:
	//
	//	*PendingActivityInfo_PauseInfo_Manual_
	//	*PendingActivityInfo_PauseInfo_Rule_
	PausedBy isPendingActivityInfo_PauseInfo_PausedBy `protobuf_oneof:"paused_by"`
	// contains filtered or unexported fields
}

func (*PendingActivityInfo_PauseInfo) Descriptor deprecated added in v1.48.0

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

Deprecated: Use PendingActivityInfo_PauseInfo.ProtoReflect.Descriptor instead.

func (*PendingActivityInfo_PauseInfo) GetManual added in v1.48.0

func (*PendingActivityInfo_PauseInfo) GetPauseTime added in v1.48.0

func (*PendingActivityInfo_PauseInfo) GetPausedBy added in v1.48.0

func (x *PendingActivityInfo_PauseInfo) GetPausedBy() isPendingActivityInfo_PauseInfo_PausedBy

func (*PendingActivityInfo_PauseInfo) GetRule added in v1.49.0

func (*PendingActivityInfo_PauseInfo) ProtoMessage added in v1.48.0

func (*PendingActivityInfo_PauseInfo) ProtoMessage()

func (*PendingActivityInfo_PauseInfo) ProtoReflect added in v1.48.0

func (*PendingActivityInfo_PauseInfo) Reset added in v1.48.0

func (x *PendingActivityInfo_PauseInfo) Reset()

func (*PendingActivityInfo_PauseInfo) String added in v1.48.0

type PendingActivityInfo_PauseInfo_Manual added in v1.48.0

type PendingActivityInfo_PauseInfo_Manual struct {

	// The identity of the actor that paused the activity.
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// Reason for pausing the activity.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingActivityInfo_PauseInfo_Manual) Descriptor deprecated added in v1.48.0

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

Deprecated: Use PendingActivityInfo_PauseInfo_Manual.ProtoReflect.Descriptor instead.

func (*PendingActivityInfo_PauseInfo_Manual) GetIdentity added in v1.48.0

func (*PendingActivityInfo_PauseInfo_Manual) GetReason added in v1.48.0

func (*PendingActivityInfo_PauseInfo_Manual) ProtoMessage added in v1.48.0

func (*PendingActivityInfo_PauseInfo_Manual) ProtoMessage()

func (*PendingActivityInfo_PauseInfo_Manual) ProtoReflect added in v1.48.0

func (*PendingActivityInfo_PauseInfo_Manual) Reset added in v1.48.0

func (*PendingActivityInfo_PauseInfo_Manual) String added in v1.48.0

type PendingActivityInfo_PauseInfo_Manual_ added in v1.48.0

type PendingActivityInfo_PauseInfo_Manual_ struct {
	// activity was paused by the manual intervention
	Manual *PendingActivityInfo_PauseInfo_Manual `protobuf:"bytes,2,opt,name=manual,proto3,oneof"`
}

type PendingActivityInfo_PauseInfo_Rule added in v1.49.0

type PendingActivityInfo_PauseInfo_Rule struct {

	// The rule that paused the activity.
	RuleId string `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	// The identity of the actor that created the rule.
	Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// Reason why rule was created. Populated from rule description.
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingActivityInfo_PauseInfo_Rule) Descriptor deprecated added in v1.49.0

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

Deprecated: Use PendingActivityInfo_PauseInfo_Rule.ProtoReflect.Descriptor instead.

func (*PendingActivityInfo_PauseInfo_Rule) GetIdentity added in v1.49.0

func (x *PendingActivityInfo_PauseInfo_Rule) GetIdentity() string

func (*PendingActivityInfo_PauseInfo_Rule) GetReason added in v1.49.0

func (*PendingActivityInfo_PauseInfo_Rule) GetRuleId added in v1.49.0

func (*PendingActivityInfo_PauseInfo_Rule) ProtoMessage added in v1.49.0

func (*PendingActivityInfo_PauseInfo_Rule) ProtoMessage()

func (*PendingActivityInfo_PauseInfo_Rule) ProtoReflect added in v1.49.0

func (*PendingActivityInfo_PauseInfo_Rule) Reset added in v1.49.0

func (*PendingActivityInfo_PauseInfo_Rule) String added in v1.49.0

type PendingActivityInfo_PauseInfo_Rule_ added in v1.49.0

type PendingActivityInfo_PauseInfo_Rule_ struct {
	// activity was paused by the rule
	Rule *PendingActivityInfo_PauseInfo_Rule `protobuf:"bytes,4,opt,name=rule,proto3,oneof"`
}

type PendingActivityInfo_UseWorkflowBuildId added in v1.32.0

type PendingActivityInfo_UseWorkflowBuildId struct {
	// Deprecated. When present, it means this activity is assigned to the build ID of its workflow.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	UseWorkflowBuildId *emptypb.Empty `protobuf:"bytes,13,opt,name=use_workflow_build_id,json=useWorkflowBuildId,proto3,oneof"`
}

type PendingChildExecutionInfo

type PendingChildExecutionInfo struct {
	WorkflowId       string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId            string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	WorkflowTypeName string `protobuf:"bytes,3,opt,name=workflow_type_name,json=workflowTypeName,proto3" json:"workflow_type_name,omitempty"`
	InitiatedId      int64  `protobuf:"varint,4,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
	// Default: PARENT_CLOSE_POLICY_TERMINATE.
	ParentClosePolicy v11.ParentClosePolicy `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PendingChildExecutionInfo) Descriptor deprecated

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

Deprecated: Use PendingChildExecutionInfo.ProtoReflect.Descriptor instead.

func (*PendingChildExecutionInfo) Equal

func (this *PendingChildExecutionInfo) Equal(that interface{}) bool

Equal returns whether two PendingChildExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PendingChildExecutionInfo) GetInitiatedId

func (x *PendingChildExecutionInfo) GetInitiatedId() int64

func (*PendingChildExecutionInfo) GetParentClosePolicy

func (x *PendingChildExecutionInfo) GetParentClosePolicy() v11.ParentClosePolicy

func (*PendingChildExecutionInfo) GetRunId

func (x *PendingChildExecutionInfo) GetRunId() string

func (*PendingChildExecutionInfo) GetWorkflowId

func (x *PendingChildExecutionInfo) GetWorkflowId() string

func (*PendingChildExecutionInfo) GetWorkflowTypeName

func (x *PendingChildExecutionInfo) GetWorkflowTypeName() string

func (*PendingChildExecutionInfo) Marshal

func (val *PendingChildExecutionInfo) Marshal() ([]byte, error)

Marshal an object of type PendingChildExecutionInfo to the protobuf v3 wire format

func (*PendingChildExecutionInfo) ProtoMessage

func (*PendingChildExecutionInfo) ProtoMessage()

func (*PendingChildExecutionInfo) ProtoReflect added in v1.26.1

func (*PendingChildExecutionInfo) Reset

func (x *PendingChildExecutionInfo) Reset()

func (*PendingChildExecutionInfo) Size

func (val *PendingChildExecutionInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PendingChildExecutionInfo) String

func (x *PendingChildExecutionInfo) String() string

func (*PendingChildExecutionInfo) Unmarshal

func (val *PendingChildExecutionInfo) Unmarshal(buf []byte) error

Unmarshal an object of type PendingChildExecutionInfo from the protobuf v3 wire format

type PendingNexusOperationInfo added in v1.32.1

type PendingNexusOperationInfo struct {

	// Endpoint name.
	// Resolved to a URL via the cluster's endpoint registry.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Service name.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// Operation name.
	Operation string `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	// Operation ID. Only set for asynchronous operations after a successful StartOperation call.
	//
	// Deprecated. Renamed to operation_token.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	OperationId string `protobuf:"bytes,4,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	// Schedule-to-close timeout for this operation.
	// This is the only timeout settable by a workflow.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// The time when the operation was scheduled.
	ScheduledTime *timestamppb.Timestamp         `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	State         v11.PendingNexusOperationState `protobuf:"varint,7,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingNexusOperationState" json:"state,omitempty"`
	// The number of attempts made to deliver the start operation request.
	// This number is approximate, it is incremented when a task is added to the history queue.
	// In practice, there could be more attempts if a task is executed but fails to commit, or less attempts if a task
	// was never executed.
	Attempt int32 `protobuf:"varint,8,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// The time when the last attempt completed.
	LastAttemptCompleteTime *timestamppb.Timestamp `` /* 134-byte string literal not displayed */
	// The last attempt's failure, if any.
	LastAttemptFailure *v15.Failure `protobuf:"bytes,10,opt,name=last_attempt_failure,json=lastAttemptFailure,proto3" json:"last_attempt_failure,omitempty"`
	// The time when the next attempt is scheduled.
	NextAttemptScheduleTime *timestamppb.Timestamp          `` /* 135-byte string literal not displayed */
	CancellationInfo        *NexusOperationCancellationInfo `protobuf:"bytes,12,opt,name=cancellation_info,json=cancellationInfo,proto3" json:"cancellation_info,omitempty"`
	// The event ID of the NexusOperationScheduled event. Can be used to correlate an operation in the
	// DescribeWorkflowExecution response with workflow history.
	ScheduledEventId int64 `protobuf:"varint,13,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	// If the state is BLOCKED, blocked reason provides additional information.
	BlockedReason string `protobuf:"bytes,14,opt,name=blocked_reason,json=blockedReason,proto3" json:"blocked_reason,omitempty"`
	// Operation token. Only set for asynchronous operations after a successful StartOperation call.
	OperationToken string `protobuf:"bytes,15,opt,name=operation_token,json=operationToken,proto3" json:"operation_token,omitempty"`
	// Schedule-to-start timeout for this operation.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 132-byte string literal not displayed */
	// Start-to-close timeout for this operation.
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout *durationpb.Duration `protobuf:"bytes,17,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	// contains filtered or unexported fields
}

PendingNexusOperationInfo contains the state of a pending Nexus operation.

func (*PendingNexusOperationInfo) Descriptor deprecated added in v1.32.1

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

Deprecated: Use PendingNexusOperationInfo.ProtoReflect.Descriptor instead.

func (*PendingNexusOperationInfo) Equal added in v1.32.1

func (this *PendingNexusOperationInfo) Equal(that interface{}) bool

Equal returns whether two PendingNexusOperationInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PendingNexusOperationInfo) GetAttempt added in v1.32.1

func (x *PendingNexusOperationInfo) GetAttempt() int32

func (*PendingNexusOperationInfo) GetBlockedReason added in v1.42.0

func (x *PendingNexusOperationInfo) GetBlockedReason() string

func (*PendingNexusOperationInfo) GetCancellationInfo added in v1.32.1

func (*PendingNexusOperationInfo) GetEndpoint added in v1.33.0

func (x *PendingNexusOperationInfo) GetEndpoint() string

func (*PendingNexusOperationInfo) GetLastAttemptCompleteTime added in v1.32.1

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

func (*PendingNexusOperationInfo) GetLastAttemptFailure added in v1.32.1

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

func (*PendingNexusOperationInfo) GetNextAttemptScheduleTime added in v1.32.1

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

func (*PendingNexusOperationInfo) GetOperation added in v1.32.1

func (x *PendingNexusOperationInfo) GetOperation() string

func (*PendingNexusOperationInfo) GetOperationId deprecated added in v1.32.1

func (x *PendingNexusOperationInfo) GetOperationId() string

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

func (*PendingNexusOperationInfo) GetOperationToken added in v1.44.0

func (x *PendingNexusOperationInfo) GetOperationToken() string

func (*PendingNexusOperationInfo) GetScheduleToCloseTimeout added in v1.32.1

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

func (*PendingNexusOperationInfo) GetScheduleToStartTimeout added in v1.61.0

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

func (*PendingNexusOperationInfo) GetScheduledEventId added in v1.36.0

func (x *PendingNexusOperationInfo) GetScheduledEventId() int64

func (*PendingNexusOperationInfo) GetScheduledTime added in v1.32.1

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

func (*PendingNexusOperationInfo) GetService added in v1.32.1

func (x *PendingNexusOperationInfo) GetService() string

func (*PendingNexusOperationInfo) GetStartToCloseTimeout added in v1.61.0

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

func (*PendingNexusOperationInfo) GetState added in v1.32.1

func (*PendingNexusOperationInfo) Marshal added in v1.32.1

func (val *PendingNexusOperationInfo) Marshal() ([]byte, error)

Marshal an object of type PendingNexusOperationInfo to the protobuf v3 wire format

func (*PendingNexusOperationInfo) ProtoMessage added in v1.32.1

func (*PendingNexusOperationInfo) ProtoMessage()

func (*PendingNexusOperationInfo) ProtoReflect added in v1.32.1

func (*PendingNexusOperationInfo) Reset added in v1.32.1

func (x *PendingNexusOperationInfo) Reset()

func (*PendingNexusOperationInfo) Size added in v1.32.1

func (val *PendingNexusOperationInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PendingNexusOperationInfo) String added in v1.32.1

func (x *PendingNexusOperationInfo) String() string

func (*PendingNexusOperationInfo) Unmarshal added in v1.32.1

func (val *PendingNexusOperationInfo) Unmarshal(buf []byte) error

Unmarshal an object of type PendingNexusOperationInfo from the protobuf v3 wire format

type PendingWorkflowTaskInfo added in v1.8.0

type PendingWorkflowTaskInfo struct {
	State         v11.PendingWorkflowTaskState `protobuf:"varint,1,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingWorkflowTaskState" json:"state,omitempty"`
	ScheduledTime *timestamppb.Timestamp       `protobuf:"bytes,2,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	// original_scheduled_time is the scheduled time of the first workflow task during workflow task heartbeat.
	// Heartbeat workflow task is done by RespondWorkflowTaskComplete with ForceCreateNewWorkflowTask == true and no command
	// In this case, OriginalScheduledTime won't change. Then when current time - original_scheduled_time exceeds
	// some threshold, the workflow task will be forced timeout.
	OriginalScheduledTime *timestamppb.Timestamp `` /* 126-byte string literal not displayed */
	StartedTime           *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
	Attempt               int32                  `protobuf:"varint,5,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// contains filtered or unexported fields
}

func (*PendingWorkflowTaskInfo) Descriptor deprecated added in v1.8.0

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

Deprecated: Use PendingWorkflowTaskInfo.ProtoReflect.Descriptor instead.

func (*PendingWorkflowTaskInfo) Equal added in v1.8.0

func (this *PendingWorkflowTaskInfo) Equal(that interface{}) bool

Equal returns whether two PendingWorkflowTaskInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PendingWorkflowTaskInfo) GetAttempt added in v1.8.0

func (x *PendingWorkflowTaskInfo) GetAttempt() int32

func (*PendingWorkflowTaskInfo) GetOriginalScheduledTime added in v1.8.0

func (x *PendingWorkflowTaskInfo) GetOriginalScheduledTime() *timestamppb.Timestamp

func (*PendingWorkflowTaskInfo) GetScheduledTime added in v1.8.0

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

func (*PendingWorkflowTaskInfo) GetStartedTime added in v1.8.0

func (x *PendingWorkflowTaskInfo) GetStartedTime() *timestamppb.Timestamp

func (*PendingWorkflowTaskInfo) GetState added in v1.8.0

func (*PendingWorkflowTaskInfo) Marshal added in v1.8.0

func (val *PendingWorkflowTaskInfo) Marshal() ([]byte, error)

Marshal an object of type PendingWorkflowTaskInfo to the protobuf v3 wire format

func (*PendingWorkflowTaskInfo) ProtoMessage added in v1.8.0

func (*PendingWorkflowTaskInfo) ProtoMessage()

func (*PendingWorkflowTaskInfo) ProtoReflect added in v1.26.1

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

func (*PendingWorkflowTaskInfo) Reset added in v1.8.0

func (x *PendingWorkflowTaskInfo) Reset()

func (*PendingWorkflowTaskInfo) Size added in v1.8.0

func (val *PendingWorkflowTaskInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PendingWorkflowTaskInfo) String added in v1.8.0

func (x *PendingWorkflowTaskInfo) String() string

func (*PendingWorkflowTaskInfo) Unmarshal added in v1.8.0

func (val *PendingWorkflowTaskInfo) Unmarshal(buf []byte) error

Unmarshal an object of type PendingWorkflowTaskInfo from the protobuf v3 wire format

type PostResetOperation added in v1.49.1

type PostResetOperation struct {

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

PostResetOperation represents an operation to be performed on the new workflow execution after a workflow reset.

func (*PostResetOperation) Descriptor deprecated added in v1.49.1

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

Deprecated: Use PostResetOperation.ProtoReflect.Descriptor instead.

func (*PostResetOperation) Equal added in v1.49.1

func (this *PostResetOperation) Equal(that interface{}) bool

Equal returns whether two PostResetOperation values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PostResetOperation) GetSignalWorkflow added in v1.49.1

func (x *PostResetOperation) GetSignalWorkflow() *PostResetOperation_SignalWorkflow

func (*PostResetOperation) GetUpdateWorkflowOptions added in v1.49.1

func (x *PostResetOperation) GetUpdateWorkflowOptions() *PostResetOperation_UpdateWorkflowOptions

func (*PostResetOperation) GetVariant added in v1.49.1

func (x *PostResetOperation) GetVariant() isPostResetOperation_Variant

func (*PostResetOperation) Marshal added in v1.49.1

func (val *PostResetOperation) Marshal() ([]byte, error)

Marshal an object of type PostResetOperation to the protobuf v3 wire format

func (*PostResetOperation) ProtoMessage added in v1.49.1

func (*PostResetOperation) ProtoMessage()

func (*PostResetOperation) ProtoReflect added in v1.49.1

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

func (*PostResetOperation) Reset added in v1.49.1

func (x *PostResetOperation) Reset()

func (*PostResetOperation) Size added in v1.49.1

func (val *PostResetOperation) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PostResetOperation) String added in v1.49.1

func (x *PostResetOperation) String() string

func (*PostResetOperation) Unmarshal added in v1.49.1

func (val *PostResetOperation) Unmarshal(buf []byte) error

Unmarshal an object of type PostResetOperation from the protobuf v3 wire format

type PostResetOperation_SignalWorkflow added in v1.49.1

type PostResetOperation_SignalWorkflow struct {

	// The workflow author-defined name of the signal to send to the workflow.
	SignalName string `protobuf:"bytes,1,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	// Serialized value(s) to provide with the signal.
	Input *v1.Payloads `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// Headers that are passed with the signal to the processing workflow.
	Header *v1.Header `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
	// Links to be associated with the WorkflowExecutionSignaled event.
	Links []*v1.Link `protobuf:"bytes,4,rep,name=links,proto3" json:"links,omitempty"`
	// contains filtered or unexported fields
}

SignalWorkflow represents sending a signal after a workflow reset. Keep the parameter in sync with temporal.api.workflowservice.v1.SignalWorkflowExecutionRequest.

func (*PostResetOperation_SignalWorkflow) Descriptor deprecated added in v1.49.1

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

Deprecated: Use PostResetOperation_SignalWorkflow.ProtoReflect.Descriptor instead.

func (*PostResetOperation_SignalWorkflow) GetHeader added in v1.49.1

func (*PostResetOperation_SignalWorkflow) GetInput added in v1.49.1

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

func (*PostResetOperation_SignalWorkflow) GetSignalName added in v1.49.1

func (x *PostResetOperation_SignalWorkflow) GetSignalName() string

func (*PostResetOperation_SignalWorkflow) ProtoMessage added in v1.49.1

func (*PostResetOperation_SignalWorkflow) ProtoMessage()

func (*PostResetOperation_SignalWorkflow) ProtoReflect added in v1.49.1

func (*PostResetOperation_SignalWorkflow) Reset added in v1.49.1

func (*PostResetOperation_SignalWorkflow) String added in v1.49.1

type PostResetOperation_SignalWorkflow_ added in v1.49.1

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

type PostResetOperation_UpdateWorkflowOptions added in v1.49.1

type PostResetOperation_UpdateWorkflowOptions struct {

	// Update Workflow options that were originally specified via StartWorkflowExecution. Partial updates are accepted and controlled by update_mask.
	WorkflowExecutionOptions *WorkflowExecutionOptions `` /* 135-byte string literal not displayed */
	// Controls which fields from `workflow_execution_options` will be applied.
	// To unset a field, set it to null and use the update mask to indicate that it should be mutated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

UpdateWorkflowOptions represents updating workflow execution options after a workflow reset. Keep the parameters in sync with temporal.api.workflowservice.v1.UpdateWorkflowExecutionOptionsRequest.

func (*PostResetOperation_UpdateWorkflowOptions) Descriptor deprecated added in v1.49.1

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

Deprecated: Use PostResetOperation_UpdateWorkflowOptions.ProtoReflect.Descriptor instead.

func (*PostResetOperation_UpdateWorkflowOptions) GetUpdateMask added in v1.49.1

func (*PostResetOperation_UpdateWorkflowOptions) GetWorkflowExecutionOptions added in v1.49.1

func (x *PostResetOperation_UpdateWorkflowOptions) GetWorkflowExecutionOptions() *WorkflowExecutionOptions

func (*PostResetOperation_UpdateWorkflowOptions) ProtoMessage added in v1.49.1

func (*PostResetOperation_UpdateWorkflowOptions) ProtoReflect added in v1.49.1

func (*PostResetOperation_UpdateWorkflowOptions) Reset added in v1.49.1

func (*PostResetOperation_UpdateWorkflowOptions) String added in v1.49.1

type PostResetOperation_UpdateWorkflowOptions_ added in v1.49.1

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

type RequestIdInfo added in v1.49.0

type RequestIdInfo struct {

	// The event type of the history event generated by the request.
	EventType v11.EventType `` /* 126-byte string literal not displayed */
	// The event id of the history event generated by the request. It's possible the event ID is not
	// known (unflushed buffered event). In this case, the value will be zero or a negative value,
	// representing an invalid ID.
	EventId int64 `protobuf:"varint,2,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// Indicate if the request is still buffered. If so, the event ID is not known and its value
	// will be an invalid event ID.
	Buffered bool `protobuf:"varint,3,opt,name=buffered,proto3" json:"buffered,omitempty"`
	// contains filtered or unexported fields
}

RequestIdInfo contains details of a request ID.

func (*RequestIdInfo) Descriptor deprecated added in v1.49.0

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

Deprecated: Use RequestIdInfo.ProtoReflect.Descriptor instead.

func (*RequestIdInfo) Equal added in v1.49.0

func (this *RequestIdInfo) Equal(that interface{}) bool

Equal returns whether two RequestIdInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RequestIdInfo) GetBuffered added in v1.49.0

func (x *RequestIdInfo) GetBuffered() bool

func (*RequestIdInfo) GetEventId added in v1.49.0

func (x *RequestIdInfo) GetEventId() int64

func (*RequestIdInfo) GetEventType added in v1.49.0

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

func (*RequestIdInfo) Marshal added in v1.49.0

func (val *RequestIdInfo) Marshal() ([]byte, error)

Marshal an object of type RequestIdInfo to the protobuf v3 wire format

func (*RequestIdInfo) ProtoMessage added in v1.49.0

func (*RequestIdInfo) ProtoMessage()

func (*RequestIdInfo) ProtoReflect added in v1.49.0

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

func (*RequestIdInfo) Reset added in v1.49.0

func (x *RequestIdInfo) Reset()

func (*RequestIdInfo) Size added in v1.49.0

func (val *RequestIdInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RequestIdInfo) String added in v1.49.0

func (x *RequestIdInfo) String() string

func (*RequestIdInfo) Unmarshal added in v1.49.0

func (val *RequestIdInfo) Unmarshal(buf []byte) error

Unmarshal an object of type RequestIdInfo from the protobuf v3 wire format

type ResetPointInfo

type ResetPointInfo struct {

	// Worker build id.
	BuildId string `protobuf:"bytes,7,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Deprecated. A worker binary version identifier.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	BinaryChecksum string `protobuf:"bytes,1,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
	// The first run ID in the execution chain that was touched by this worker build.
	RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Event ID of the first WorkflowTaskCompleted event processed by this worker build.
	FirstWorkflowTaskCompletedId int64                  `` /* 152-byte string literal not displayed */
	CreateTime                   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// (-- api-linter: core::0214::resource-expiry=disabled
	//
	//	aip.dev/not-precedent: TTL is not defined for ResetPointInfo. --)
	//
	// The time that the run is deleted due to retention.
	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
	// false if the reset point has pending childWFs/reqCancels/signalExternals.
	Resettable bool `protobuf:"varint,6,opt,name=resettable,proto3" json:"resettable,omitempty"`
	// contains filtered or unexported fields
}

ResetPointInfo records the workflow event id that is the first one processed by a given build id or binary checksum. A new reset point will be created if either build id or binary checksum changes (although in general only one or the other will be used at a time).

func (*ResetPointInfo) Descriptor deprecated

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

Deprecated: Use ResetPointInfo.ProtoReflect.Descriptor instead.

func (*ResetPointInfo) Equal

func (this *ResetPointInfo) Equal(that interface{}) bool

Equal returns whether two ResetPointInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ResetPointInfo) GetBinaryChecksum deprecated

func (x *ResetPointInfo) GetBinaryChecksum() string

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

func (*ResetPointInfo) GetBuildId added in v1.26.2

func (x *ResetPointInfo) GetBuildId() string

func (*ResetPointInfo) GetCreateTime added in v0.28.0

func (x *ResetPointInfo) GetCreateTime() *timestamppb.Timestamp

func (*ResetPointInfo) GetExpireTime added in v0.28.0

func (x *ResetPointInfo) GetExpireTime() *timestamppb.Timestamp

func (*ResetPointInfo) GetFirstWorkflowTaskCompletedId

func (x *ResetPointInfo) GetFirstWorkflowTaskCompletedId() int64

func (*ResetPointInfo) GetResettable

func (x *ResetPointInfo) GetResettable() bool

func (*ResetPointInfo) GetRunId

func (x *ResetPointInfo) GetRunId() string

func (*ResetPointInfo) Marshal

func (val *ResetPointInfo) Marshal() ([]byte, error)

Marshal an object of type ResetPointInfo to the protobuf v3 wire format

func (*ResetPointInfo) ProtoMessage

func (*ResetPointInfo) ProtoMessage()

func (*ResetPointInfo) ProtoReflect added in v1.26.1

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

func (*ResetPointInfo) Reset

func (x *ResetPointInfo) Reset()

func (*ResetPointInfo) Size

func (val *ResetPointInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ResetPointInfo) String

func (x *ResetPointInfo) String() string

func (*ResetPointInfo) Unmarshal

func (val *ResetPointInfo) Unmarshal(buf []byte) error

Unmarshal an object of type ResetPointInfo from the protobuf v3 wire format

type ResetPoints

type ResetPoints struct {
	Points []*ResetPointInfo `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetPoints) Descriptor deprecated

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

Deprecated: Use ResetPoints.ProtoReflect.Descriptor instead.

func (*ResetPoints) Equal

func (this *ResetPoints) Equal(that interface{}) bool

Equal returns whether two ResetPoints values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ResetPoints) GetPoints

func (x *ResetPoints) GetPoints() []*ResetPointInfo

func (*ResetPoints) Marshal

func (val *ResetPoints) Marshal() ([]byte, error)

Marshal an object of type ResetPoints to the protobuf v3 wire format

func (*ResetPoints) ProtoMessage

func (*ResetPoints) ProtoMessage()

func (*ResetPoints) ProtoReflect added in v1.26.1

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

func (*ResetPoints) Reset

func (x *ResetPoints) Reset()

func (*ResetPoints) Size

func (val *ResetPoints) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ResetPoints) String

func (x *ResetPoints) String() string

func (*ResetPoints) Unmarshal

func (val *ResetPoints) Unmarshal(buf []byte) error

Unmarshal an object of type ResetPoints from the protobuf v3 wire format

type TimeSkippingConfig added in v1.62.8

type TimeSkippingConfig struct {

	// Enables or disables time skipping for this workflow execution.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Optional bound that limits the gap between the virtual time of this execution and wall-clock time.
	// Once the bound is reached, time skipping is automatically disabled,
	// but can be re-enabled by setting `enabled` to true via UpdateWorkflowExecutionOptions.
	// This bound cannot be set to a value smaller than the execution's currently skipped duration.
	//
	// This is useful in testing scenarios where a workflow is expected to receive
	// signals, updates, or other external events while timers are in progress.
	//
	// Types that are valid to be assigned to Bound:
	//
	//	*TimeSkippingConfig_MaxSkippedDuration
	//	*TimeSkippingConfig_MaxElapsedDuration
	Bound isTimeSkippingConfig_Bound `protobuf_oneof:"bound"`
	// contains filtered or unexported fields
}

Configuration for time skipping during a workflow execution. When enabled, virtual time advances automatically whenever there is no in-flight work. In-flight work includes activities, child workflows, Nexus operations, signal/cancel external workflow operations, and possibly other features added in the future. User timers are not classified as in-flight work and will be skipped over. When time advances, it skips to the earlier of the next user timer or the configured bound, if either exists.

Propagation behavior of time skipping: The enabled flag, bound fields, and accumulated skipped duration are propagated to related executions as follows: (1) Child workflows and continue-as-new: both the configuration and the accumulated skipped duration are

inherited from the current execution. The configured bound is shared between the inherited skipped
duration and any additional duration skipped by the new run.

(2) Retry and cron: the configuration and accumulated skipped duration are inherited as recorded when the

current workflow started; the accumulated skipped duration of the current run is not propagated.

(3) Reset: the new run retains the time-skipping configuration of the current execution. Because reset replays

all events up to the reset point and re-applies any UpdateWorkflowExecutionOptions changes made after that
point, the resulting run ends up with the same final time-skipping configuration as the previous run.

func (*TimeSkippingConfig) Descriptor deprecated added in v1.62.8

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

Deprecated: Use TimeSkippingConfig.ProtoReflect.Descriptor instead.

func (*TimeSkippingConfig) Equal added in v1.62.8

func (this *TimeSkippingConfig) Equal(that interface{}) bool

Equal returns whether two TimeSkippingConfig values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*TimeSkippingConfig) GetBound added in v1.62.8

func (x *TimeSkippingConfig) GetBound() isTimeSkippingConfig_Bound

func (*TimeSkippingConfig) GetEnabled added in v1.62.8

func (x *TimeSkippingConfig) GetEnabled() bool

func (*TimeSkippingConfig) GetMaxElapsedDuration added in v1.62.8

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

func (*TimeSkippingConfig) GetMaxSkippedDuration added in v1.62.8

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

func (*TimeSkippingConfig) Marshal added in v1.62.8

func (val *TimeSkippingConfig) Marshal() ([]byte, error)

Marshal an object of type TimeSkippingConfig to the protobuf v3 wire format

func (*TimeSkippingConfig) ProtoMessage added in v1.62.8

func (*TimeSkippingConfig) ProtoMessage()

func (*TimeSkippingConfig) ProtoReflect added in v1.62.8

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

func (*TimeSkippingConfig) Reset added in v1.62.8

func (x *TimeSkippingConfig) Reset()

func (*TimeSkippingConfig) Size added in v1.62.8

func (val *TimeSkippingConfig) Size() int

Size returns the size of the object, in bytes, once serialized

func (*TimeSkippingConfig) String added in v1.62.8

func (x *TimeSkippingConfig) String() string

func (*TimeSkippingConfig) Unmarshal added in v1.62.8

func (val *TimeSkippingConfig) Unmarshal(buf []byte) error

Unmarshal an object of type TimeSkippingConfig from the protobuf v3 wire format

type TimeSkippingConfig_MaxElapsedDuration added in v1.62.8

type TimeSkippingConfig_MaxElapsedDuration struct {
	// Maximum elapsed time since time skipping was enabled.
	// This includes both skipped time and real time elapsing.
	// (-- api-linter: core::0142::time-field-names=disabled --)
	MaxElapsedDuration *durationpb.Duration `protobuf:"bytes,5,opt,name=max_elapsed_duration,json=maxElapsedDuration,proto3,oneof"`
}

type TimeSkippingConfig_MaxSkippedDuration added in v1.62.8

type TimeSkippingConfig_MaxSkippedDuration struct {
	// Maximum total virtual time that can be skipped.
	MaxSkippedDuration *durationpb.Duration `protobuf:"bytes,4,opt,name=max_skipped_duration,json=maxSkippedDuration,proto3,oneof"`
}

type VersioningOverride added in v1.43.0

type VersioningOverride struct {

	// Indicates whether to override the workflow to be AutoUpgrade or Pinned.
	//
	// Types that are valid to be assigned to Override:
	//
	//	*VersioningOverride_Pinned
	//	*VersioningOverride_AutoUpgrade
	Override isVersioningOverride_Override `protobuf_oneof:"override"`
	// Required.
	// Deprecated. Use `override`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	Behavior v11.VersioningBehavior `protobuf:"varint,1,opt,name=behavior,proto3,enum=temporal.api.enums.v1.VersioningBehavior" json:"behavior,omitempty"`
	// Required if behavior is `PINNED`. Must be null if behavior is `AUTO_UPGRADE`.
	// Identifies the worker deployment to pin the workflow to.
	// Deprecated. Use `override.pinned.version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	Deployment *v12.Deployment `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// Required if behavior is `PINNED`. Must be absent if behavior is not `PINNED`.
	// Identifies the worker deployment version to pin the workflow to, in the format
	// "<deployment_name>.<build_id>".
	// Deprecated. Use `override.pinned.version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	PinnedVersion string `protobuf:"bytes,9,opt,name=pinned_version,json=pinnedVersion,proto3" json:"pinned_version,omitempty"`
	// contains filtered or unexported fields
}

Used to override the versioning behavior (and pinned deployment version, if applicable) of a specific workflow execution. If set, this override takes precedence over worker-sent values. See `WorkflowExecutionInfo.VersioningInfo` for more information.

To remove the override, call `UpdateWorkflowExecutionOptions` with a null `VersioningOverride`, and use the `update_mask` to indicate that it should be mutated.

Pinned behavior overrides are automatically inherited by child workflows, workflow retries, continue-as-new workflows, and cron workflows.

func (*VersioningOverride) Descriptor deprecated added in v1.43.0

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

Deprecated: Use VersioningOverride.ProtoReflect.Descriptor instead.

func (*VersioningOverride) Equal added in v1.43.0

func (this *VersioningOverride) Equal(that interface{}) bool

Equal returns whether two VersioningOverride values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*VersioningOverride) GetAutoUpgrade added in v1.49.1

func (x *VersioningOverride) GetAutoUpgrade() bool

func (*VersioningOverride) GetBehavior deprecated added in v1.43.0

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

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

func (*VersioningOverride) GetDeployment deprecated added in v1.43.0

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

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

func (*VersioningOverride) GetOverride added in v1.49.1

func (x *VersioningOverride) GetOverride() isVersioningOverride_Override

func (*VersioningOverride) GetPinned added in v1.49.1

func (*VersioningOverride) GetPinnedVersion deprecated added in v1.44.0

func (x *VersioningOverride) GetPinnedVersion() string

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

func (*VersioningOverride) Marshal added in v1.43.0

func (val *VersioningOverride) Marshal() ([]byte, error)

Marshal an object of type VersioningOverride to the protobuf v3 wire format

func (*VersioningOverride) ProtoMessage added in v1.43.0

func (*VersioningOverride) ProtoMessage()

func (*VersioningOverride) ProtoReflect added in v1.43.0

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

func (*VersioningOverride) Reset added in v1.43.0

func (x *VersioningOverride) Reset()

func (*VersioningOverride) Size added in v1.43.0

func (val *VersioningOverride) Size() int

Size returns the size of the object, in bytes, once serialized

func (*VersioningOverride) String added in v1.43.0

func (x *VersioningOverride) String() string

func (*VersioningOverride) Unmarshal added in v1.43.0

func (val *VersioningOverride) Unmarshal(buf []byte) error

Unmarshal an object of type VersioningOverride from the protobuf v3 wire format

type VersioningOverride_AutoUpgrade added in v1.49.1

type VersioningOverride_AutoUpgrade struct {
	// Override the workflow to have AutoUpgrade behavior.
	AutoUpgrade bool `protobuf:"varint,4,opt,name=auto_upgrade,json=autoUpgrade,proto3,oneof"`
}

type VersioningOverride_Pinned added in v1.49.1

type VersioningOverride_Pinned struct {
	// Override the workflow to have Pinned behavior.
	Pinned *VersioningOverride_PinnedOverride `protobuf:"bytes,3,opt,name=pinned,proto3,oneof"`
}

type VersioningOverride_PinnedOverride added in v1.49.1

type VersioningOverride_PinnedOverride struct {

	// Defaults to PINNED_OVERRIDE_BEHAVIOR_UNSPECIFIED.
	// See `PinnedOverrideBehavior` for details.
	Behavior VersioningOverride_PinnedOverrideBehavior `` /* 142-byte string literal not displayed */
	// Specifies the Worker Deployment Version to pin this workflow to.
	// Required if the target workflow is not already pinned to a version.
	//
	// If omitted and the target workflow is already pinned, the effective
	// pinned version will be the existing pinned version.
	//
	// If omitted and the target workflow is not pinned, the override request
	// will be rejected with a PreconditionFailed error.
	Version *v12.WorkerDeploymentVersion `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersioningOverride_PinnedOverride) Descriptor deprecated added in v1.49.1

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

Deprecated: Use VersioningOverride_PinnedOverride.ProtoReflect.Descriptor instead.

func (*VersioningOverride_PinnedOverride) GetBehavior added in v1.49.1

func (*VersioningOverride_PinnedOverride) GetVersion added in v1.49.1

func (*VersioningOverride_PinnedOverride) ProtoMessage added in v1.49.1

func (*VersioningOverride_PinnedOverride) ProtoMessage()

func (*VersioningOverride_PinnedOverride) ProtoReflect added in v1.49.1

func (*VersioningOverride_PinnedOverride) Reset added in v1.49.1

func (*VersioningOverride_PinnedOverride) String added in v1.49.1

type VersioningOverride_PinnedOverrideBehavior added in v1.49.1

type VersioningOverride_PinnedOverrideBehavior int32
const (
	VersioningOverride_PINNED_OVERRIDE_BEHAVIOR_UNSPECIFIED VersioningOverride_PinnedOverrideBehavior = 0
	VersioningOverride_PINNED_OVERRIDE_BEHAVIOR_PINNED      VersioningOverride_PinnedOverrideBehavior = 1
)

func (VersioningOverride_PinnedOverrideBehavior) Descriptor added in v1.49.1

func (VersioningOverride_PinnedOverrideBehavior) Enum added in v1.49.1

func (VersioningOverride_PinnedOverrideBehavior) EnumDescriptor deprecated added in v1.49.1

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

Deprecated: Use VersioningOverride_PinnedOverrideBehavior.Descriptor instead.

func (VersioningOverride_PinnedOverrideBehavior) Number added in v1.49.1

func (VersioningOverride_PinnedOverrideBehavior) String added in v1.49.1

func (VersioningOverride_PinnedOverrideBehavior) Type added in v1.49.1

type WorkflowExecutionConfig

type WorkflowExecutionConfig struct {
	TaskQueue                  *v13.TaskQueue       `protobuf:"bytes,1,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	WorkflowExecutionTimeout   *durationpb.Duration `` /* 135-byte string literal not displayed */
	WorkflowRunTimeout         *durationpb.Duration `protobuf:"bytes,3,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	DefaultWorkflowTaskTimeout *durationpb.Duration `` /* 143-byte string literal not displayed */
	// User metadata provided on start workflow.
	UserMetadata *v14.UserMetadata `protobuf:"bytes,5,opt,name=user_metadata,json=userMetadata,proto3" json:"user_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowExecutionConfig) Descriptor deprecated

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

Deprecated: Use WorkflowExecutionConfig.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionConfig) Equal

func (this *WorkflowExecutionConfig) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionConfig values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionConfig) GetDefaultWorkflowTaskTimeout added in v0.28.0

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

func (*WorkflowExecutionConfig) GetTaskQueue

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

func (*WorkflowExecutionConfig) GetUserMetadata added in v1.34.0

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

func (*WorkflowExecutionConfig) GetWorkflowExecutionTimeout added in v0.28.0

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

func (*WorkflowExecutionConfig) GetWorkflowRunTimeout added in v0.28.0

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

func (*WorkflowExecutionConfig) Marshal

func (val *WorkflowExecutionConfig) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionConfig to the protobuf v3 wire format

func (*WorkflowExecutionConfig) ProtoMessage

func (*WorkflowExecutionConfig) ProtoMessage()

func (*WorkflowExecutionConfig) ProtoReflect added in v1.26.1

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

func (*WorkflowExecutionConfig) Reset

func (x *WorkflowExecutionConfig) Reset()

func (*WorkflowExecutionConfig) Size

func (val *WorkflowExecutionConfig) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionConfig) String

func (x *WorkflowExecutionConfig) String() string

func (*WorkflowExecutionConfig) Unmarshal

func (val *WorkflowExecutionConfig) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionConfig from the protobuf v3 wire format

type WorkflowExecutionExtendedInfo added in v1.43.1

type WorkflowExecutionExtendedInfo struct {

	// Workflow execution expiration time is defined as workflow start time plus expiration timeout.
	// Workflow start time may change after workflow reset.
	ExecutionExpirationTime *timestamppb.Timestamp `` /* 132-byte string literal not displayed */
	// Workflow run expiration time is defined as current workflow run start time plus workflow run timeout.
	RunExpirationTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=run_expiration_time,json=runExpirationTime,proto3" json:"run_expiration_time,omitempty"`
	// indicates if the workflow received a cancel request
	CancelRequested bool `protobuf:"varint,3,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
	// Last workflow reset time. Nil if the workflow was never reset.
	LastResetTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_reset_time,json=lastResetTime,proto3" json:"last_reset_time,omitempty"`
	// Original workflow start time.
	OriginalStartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=original_start_time,json=originalStartTime,proto3" json:"original_start_time,omitempty"`
	// Reset Run ID points to the new run when this execution is reset. If the execution is reset multiple times, it points to the latest run.
	ResetRunId string `protobuf:"bytes,6,opt,name=reset_run_id,json=resetRunId,proto3" json:"reset_run_id,omitempty"`
	// Request ID information (eg: history event information associated with the request ID).
	// Note: It only contains request IDs from StartWorkflowExecution requests, including indirect
	// calls (eg: if SignalWithStartWorkflowExecution starts a new workflow, then the request ID is
	// used in the StartWorkflowExecution request).
	RequestIdInfos map[string]*RequestIdInfo `` /* 179-byte string literal not displayed */
	// Information about the workflow execution pause operation.
	PauseInfo *WorkflowExecutionPauseInfo `protobuf:"bytes,8,opt,name=pause_info,json=pauseInfo,proto3" json:"pause_info,omitempty"`
	// contains filtered or unexported fields
}

Holds all the extra information about workflow execution that is not part of Visibility.

func (*WorkflowExecutionExtendedInfo) Descriptor deprecated added in v1.43.1

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

Deprecated: Use WorkflowExecutionExtendedInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionExtendedInfo) Equal added in v1.43.1

func (this *WorkflowExecutionExtendedInfo) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionExtendedInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionExtendedInfo) GetCancelRequested added in v1.43.1

func (x *WorkflowExecutionExtendedInfo) GetCancelRequested() bool

func (*WorkflowExecutionExtendedInfo) GetExecutionExpirationTime added in v1.43.1

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

func (*WorkflowExecutionExtendedInfo) GetLastResetTime added in v1.43.1

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

func (*WorkflowExecutionExtendedInfo) GetOriginalStartTime added in v1.43.1

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

func (*WorkflowExecutionExtendedInfo) GetPauseInfo added in v1.59.0

func (*WorkflowExecutionExtendedInfo) GetRequestIdInfos added in v1.49.0

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

func (*WorkflowExecutionExtendedInfo) GetResetRunId added in v1.47.0

func (x *WorkflowExecutionExtendedInfo) GetResetRunId() string

func (*WorkflowExecutionExtendedInfo) GetRunExpirationTime added in v1.43.1

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

func (*WorkflowExecutionExtendedInfo) Marshal added in v1.43.1

func (val *WorkflowExecutionExtendedInfo) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionExtendedInfo to the protobuf v3 wire format

func (*WorkflowExecutionExtendedInfo) ProtoMessage added in v1.43.1

func (*WorkflowExecutionExtendedInfo) ProtoMessage()

func (*WorkflowExecutionExtendedInfo) ProtoReflect added in v1.43.1

func (*WorkflowExecutionExtendedInfo) Reset added in v1.43.1

func (x *WorkflowExecutionExtendedInfo) Reset()

func (*WorkflowExecutionExtendedInfo) Size added in v1.43.1

func (val *WorkflowExecutionExtendedInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionExtendedInfo) String added in v1.43.1

func (*WorkflowExecutionExtendedInfo) Unmarshal added in v1.43.1

func (val *WorkflowExecutionExtendedInfo) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionExtendedInfo from the protobuf v3 wire format

type WorkflowExecutionInfo

type WorkflowExecutionInfo struct {
	Execution            *v1.WorkflowExecution       `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Type                 *v1.WorkflowType            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	StartTime            *timestamppb.Timestamp      `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	CloseTime            *timestamppb.Timestamp      `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	Status               v11.WorkflowExecutionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	HistoryLength        int64                       `protobuf:"varint,6,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	ParentNamespaceId    string                      `protobuf:"bytes,7,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentExecution      *v1.WorkflowExecution       `protobuf:"bytes,8,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
	ExecutionTime        *timestamppb.Timestamp      `protobuf:"bytes,9,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	Memo                 *v1.Memo                    `protobuf:"bytes,10,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes     *v1.SearchAttributes        `protobuf:"bytes,11,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	AutoResetPoints      *ResetPoints                `protobuf:"bytes,12,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	TaskQueue            string                      `protobuf:"bytes,13,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StateTransitionCount int64                       `protobuf:"varint,14,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	HistorySizeBytes     int64                       `protobuf:"varint,15,opt,name=history_size_bytes,json=historySizeBytes,proto3" json:"history_size_bytes,omitempty"`
	// If set, the most recent worker version stamp that appeared in a workflow task completion
	// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	MostRecentWorkerVersionStamp *v1.WorkerVersionStamp `` /* 152-byte string literal not displayed */
	// Workflow execution duration is defined as difference between close time and execution time.
	// This field is only populated if the workflow is closed.
	ExecutionDuration *durationpb.Duration `protobuf:"bytes,17,opt,name=execution_duration,json=executionDuration,proto3" json:"execution_duration,omitempty"`
	// Contains information about the root workflow execution.
	// The root workflow execution is defined as follows:
	// 1. A workflow without parent workflow is its own root workflow.
	// 2. A workflow that has a parent workflow has the same root workflow as its parent workflow.
	// Note: workflows continued as new or reseted may or may not have parents, check examples below.
	//
	// Examples:
	//
	//	Scenario 1: Workflow W1 starts child workflow W2, and W2 starts child workflow W3.
	//	  - The root workflow of all three workflows is W1.
	//	Scenario 2: Workflow W1 starts child workflow W2, and W2 continued as new W3.
	//	  - The root workflow of all three workflows is W1.
	//	Scenario 3: Workflow W1 continued as new W2.
	//	  - The root workflow of W1 is W1 and the root workflow of W2 is W2.
	//	Scenario 4: Workflow W1 starts child workflow W2, and W2 is reseted, creating W3
	//	  - The root workflow of all three workflows is W1.
	//	Scenario 5: Workflow W1 is reseted, creating W2.
	//	  - The root workflow of W1 is W1 and the root workflow of W2 is W2.
	RootExecution *v1.WorkflowExecution `protobuf:"bytes,18,opt,name=root_execution,json=rootExecution,proto3" json:"root_execution,omitempty"`
	// The currently assigned build ID for this execution. Presence of this value means worker versioning is used
	// for this execution. Assigned build ID is selected based on Worker Versioning Assignment Rules
	// when the first workflow task of the execution is scheduled. If the first workflow task fails and is scheduled
	// again, the assigned build ID may change according to the latest versioning rules.
	// Assigned build ID can also change in the middle of a execution if Compatible Redirect Rules are applied to
	// this execution.
	// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	AssignedBuildId string `protobuf:"bytes,19,opt,name=assigned_build_id,json=assignedBuildId,proto3" json:"assigned_build_id,omitempty"`
	// Build ID inherited from a previous/parent execution. If present, assigned_build_id will be set to this, instead
	// of using the assignment rules.
	// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	InheritedBuildId string `protobuf:"bytes,20,opt,name=inherited_build_id,json=inheritedBuildId,proto3" json:"inherited_build_id,omitempty"`
	// The first run ID in the execution chain.
	// Executions created via the following operations are considered to be in the same chain
	// - ContinueAsNew
	// - Workflow Retry
	// - Workflow Reset
	// - Cron Schedule
	FirstRunId string `protobuf:"bytes,21,opt,name=first_run_id,json=firstRunId,proto3" json:"first_run_id,omitempty"`
	// Absent value means the workflow execution is not versioned. When present, the execution might
	// be versioned or unversioned, depending on `versioning_info.behavior` and `versioning_info.versioning_override`.
	// Experimental. Versioning info is experimental and might change in the future.
	VersioningInfo *WorkflowExecutionVersioningInfo `protobuf:"bytes,22,opt,name=versioning_info,json=versioningInfo,proto3" json:"versioning_info,omitempty"`
	// The name of Worker Deployment that completed the most recent workflow task.
	WorkerDeploymentName string `protobuf:"bytes,23,opt,name=worker_deployment_name,json=workerDeploymentName,proto3" json:"worker_deployment_name,omitempty"`
	// Priority metadata
	Priority *v1.Priority `protobuf:"bytes,24,opt,name=priority,proto3" json:"priority,omitempty"`
	// Total size in bytes of all external payloads referenced in workflow history.
	ExternalPayloadSizeBytes int64 `` /* 139-byte string literal not displayed */
	// Count of external payloads referenced in workflow history.
	ExternalPayloadCount int64 `protobuf:"varint,26,opt,name=external_payload_count,json=externalPayloadCount,proto3" json:"external_payload_count,omitempty"`
	// contains filtered or unexported fields
}

Hold basic information about a workflow execution. This structure is a part of visibility, and thus contain a limited subset of information.

func (*WorkflowExecutionInfo) Descriptor deprecated

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

Deprecated: Use WorkflowExecutionInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionInfo) Equal

func (this *WorkflowExecutionInfo) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionInfo) GetAssignedBuildId deprecated added in v1.32.0

func (x *WorkflowExecutionInfo) GetAssignedBuildId() string

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

func (*WorkflowExecutionInfo) GetAutoResetPoints

func (x *WorkflowExecutionInfo) GetAutoResetPoints() *ResetPoints

func (*WorkflowExecutionInfo) GetCloseTime

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

func (*WorkflowExecutionInfo) GetExecution

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

func (*WorkflowExecutionInfo) GetExecutionDuration added in v1.32.0

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

func (*WorkflowExecutionInfo) GetExecutionTime

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

func (*WorkflowExecutionInfo) GetExternalPayloadCount added in v1.60.0

func (x *WorkflowExecutionInfo) GetExternalPayloadCount() int64

func (*WorkflowExecutionInfo) GetExternalPayloadSizeBytes added in v1.60.0

func (x *WorkflowExecutionInfo) GetExternalPayloadSizeBytes() int64

func (*WorkflowExecutionInfo) GetFirstRunId added in v1.37.0

func (x *WorkflowExecutionInfo) GetFirstRunId() string

func (*WorkflowExecutionInfo) GetHistoryLength

func (x *WorkflowExecutionInfo) GetHistoryLength() int64

func (*WorkflowExecutionInfo) GetHistorySizeBytes added in v1.13.0

func (x *WorkflowExecutionInfo) GetHistorySizeBytes() int64

func (*WorkflowExecutionInfo) GetInheritedBuildId deprecated added in v1.32.0

func (x *WorkflowExecutionInfo) GetInheritedBuildId() string

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

func (*WorkflowExecutionInfo) GetMemo

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

func (*WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp deprecated added in v1.19.0

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

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

func (*WorkflowExecutionInfo) GetParentExecution

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

func (*WorkflowExecutionInfo) GetParentNamespaceId

func (x *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetPriority added in v1.46.0

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

func (*WorkflowExecutionInfo) GetRootExecution added in v1.32.0

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

func (*WorkflowExecutionInfo) GetSearchAttributes

func (x *WorkflowExecutionInfo) GetSearchAttributes() *v1.SearchAttributes

func (*WorkflowExecutionInfo) GetStartTime

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

func (*WorkflowExecutionInfo) GetStateTransitionCount added in v1.5.0

func (x *WorkflowExecutionInfo) GetStateTransitionCount() int64

func (*WorkflowExecutionInfo) GetStatus

func (*WorkflowExecutionInfo) GetTaskQueue

func (x *WorkflowExecutionInfo) GetTaskQueue() string

func (*WorkflowExecutionInfo) GetType

func (x *WorkflowExecutionInfo) GetType() *v1.WorkflowType

func (*WorkflowExecutionInfo) GetVersioningInfo added in v1.43.0

func (*WorkflowExecutionInfo) GetWorkerDeploymentName added in v1.44.0

func (x *WorkflowExecutionInfo) GetWorkerDeploymentName() string

func (*WorkflowExecutionInfo) Marshal

func (val *WorkflowExecutionInfo) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionInfo to the protobuf v3 wire format

func (*WorkflowExecutionInfo) ProtoMessage

func (*WorkflowExecutionInfo) ProtoMessage()

func (*WorkflowExecutionInfo) ProtoReflect added in v1.26.1

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

func (*WorkflowExecutionInfo) Reset

func (x *WorkflowExecutionInfo) Reset()

func (*WorkflowExecutionInfo) Size

func (val *WorkflowExecutionInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionInfo) String

func (x *WorkflowExecutionInfo) String() string

func (*WorkflowExecutionInfo) Unmarshal

func (val *WorkflowExecutionInfo) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionInfo from the protobuf v3 wire format

type WorkflowExecutionOptions added in v1.43.0

type WorkflowExecutionOptions struct {

	// If set, takes precedence over the Versioning Behavior sent by the SDK on Workflow Task completion.
	VersioningOverride *VersioningOverride `protobuf:"bytes,1,opt,name=versioning_override,json=versioningOverride,proto3" json:"versioning_override,omitempty"`
	// If set, overrides the workflow's priority sent by the SDK.
	Priority *v1.Priority `protobuf:"bytes,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// Time-skipping configuration for this workflow execution.
	// If not set, the time-skipping configuration is not updated by this request;
	// the existing configuration is preserved.
	TimeSkippingConfig *TimeSkippingConfig `protobuf:"bytes,3,opt,name=time_skipping_config,json=timeSkippingConfig,proto3" json:"time_skipping_config,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowExecutionOptions) Descriptor deprecated added in v1.43.0

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

Deprecated: Use WorkflowExecutionOptions.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionOptions) Equal added in v1.43.0

func (this *WorkflowExecutionOptions) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionOptions values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionOptions) GetPriority added in v1.60.0

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

func (*WorkflowExecutionOptions) GetTimeSkippingConfig added in v1.62.8

func (x *WorkflowExecutionOptions) GetTimeSkippingConfig() *TimeSkippingConfig

func (*WorkflowExecutionOptions) GetVersioningOverride added in v1.43.0

func (x *WorkflowExecutionOptions) GetVersioningOverride() *VersioningOverride

func (*WorkflowExecutionOptions) Marshal added in v1.43.0

func (val *WorkflowExecutionOptions) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionOptions to the protobuf v3 wire format

func (*WorkflowExecutionOptions) ProtoMessage added in v1.43.0

func (*WorkflowExecutionOptions) ProtoMessage()

func (*WorkflowExecutionOptions) ProtoReflect added in v1.43.0

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

func (*WorkflowExecutionOptions) Reset added in v1.43.0

func (x *WorkflowExecutionOptions) Reset()

func (*WorkflowExecutionOptions) Size added in v1.43.0

func (val *WorkflowExecutionOptions) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionOptions) String added in v1.43.0

func (x *WorkflowExecutionOptions) String() string

func (*WorkflowExecutionOptions) Unmarshal added in v1.43.0

func (val *WorkflowExecutionOptions) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionOptions from the protobuf v3 wire format

type WorkflowExecutionPauseInfo added in v1.59.0

type WorkflowExecutionPauseInfo struct {

	// The identity of the client who paused the workflow execution.
	Identity string `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	// The time when the workflow execution was paused.
	PausedTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=paused_time,json=pausedTime,proto3" json:"paused_time,omitempty"`
	// The reason for pausing the workflow execution.
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

WorkflowExecutionPauseInfo contains the information about a workflow execution pause.

func (*WorkflowExecutionPauseInfo) Descriptor deprecated added in v1.59.0

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

Deprecated: Use WorkflowExecutionPauseInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionPauseInfo) Equal added in v1.59.0

func (this *WorkflowExecutionPauseInfo) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionPauseInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionPauseInfo) GetIdentity added in v1.59.0

func (x *WorkflowExecutionPauseInfo) GetIdentity() string

func (*WorkflowExecutionPauseInfo) GetPausedTime added in v1.59.0

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

func (*WorkflowExecutionPauseInfo) GetReason added in v1.59.0

func (x *WorkflowExecutionPauseInfo) GetReason() string

func (*WorkflowExecutionPauseInfo) Marshal added in v1.59.0

func (val *WorkflowExecutionPauseInfo) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionPauseInfo to the protobuf v3 wire format

func (*WorkflowExecutionPauseInfo) ProtoMessage added in v1.59.0

func (*WorkflowExecutionPauseInfo) ProtoMessage()

func (*WorkflowExecutionPauseInfo) ProtoReflect added in v1.59.0

func (*WorkflowExecutionPauseInfo) Reset added in v1.59.0

func (x *WorkflowExecutionPauseInfo) Reset()

func (*WorkflowExecutionPauseInfo) Size added in v1.59.0

func (val *WorkflowExecutionPauseInfo) Size() int

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionPauseInfo) String added in v1.59.0

func (x *WorkflowExecutionPauseInfo) String() string

func (*WorkflowExecutionPauseInfo) Unmarshal added in v1.59.0

func (val *WorkflowExecutionPauseInfo) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionPauseInfo from the protobuf v3 wire format

type WorkflowExecutionVersioningInfo added in v1.43.0

type WorkflowExecutionVersioningInfo struct {

	// Versioning behavior determines how the server should treat this execution when workers are
	// upgraded. When present it means this workflow execution is versioned; UNSPECIFIED means
	// unversioned. See the comments in `VersioningBehavior` enum for more info about different
	// behaviors.
	//
	// Child workflows or CaN executions **inherit** their parent/previous run's effective Versioning
	// Behavior and Version (except when the new execution runs on a task queue not belonging to the
	// same deployment version as the parent/previous run's task queue). The first workflow task will
	// be dispatched according to the inherited behavior (or to the current version of the task-queue's
	// deployment in the case of AutoUpgrade.) After completion of their first workflow task the
	// Deployment Version and Behavior of the execution will update according to configuration on the worker.
	//
	// Note that `behavior` is overridden by `versioning_override` if the latter is present.
	Behavior v11.VersioningBehavior `protobuf:"varint,1,opt,name=behavior,proto3,enum=temporal.api.enums.v1.VersioningBehavior" json:"behavior,omitempty"`
	// The worker deployment that completed the last workflow task of this workflow execution. Must
	// be present if `behavior` is set. Absent value means no workflow task is completed, or the
	// last workflow task was completed by an unversioned worker. Unversioned workers may still send
	// a deployment value which will be stored here, so the right way to check if an execution is
	// versioned if an execution is versioned or not is via the `behavior` field.
	// Note that `deployment` is overridden by `versioning_override` if the latter is present.
	// Deprecated. Use `deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	Deployment *v12.Deployment `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// Deprecated. Use `deployment_version`.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// The Worker Deployment Version that completed the last workflow task of this workflow execution.
	// An absent value means no workflow task is completed, or the workflow is unversioned.
	// If present, and `behavior` is UNSPECIFIED, the last task of this workflow execution was completed
	// by a worker that is not using versioning but _is_ passing Deployment Name and Build ID.
	//
	// Child workflows or CaN executions **inherit** their parent/previous run's effective Versioning
	// Behavior and Version (except when the new execution runs on a task queue not belonging to the
	// same deployment version as the parent/previous run's task queue). The first workflow task will
	// be dispatched according to the inherited behavior (or to the current version of the task-queue's
	// deployment in the case of AutoUpgrade.) After completion of their first workflow task the
	// Deployment Version and Behavior of the execution will update according to configuration on the worker.
	//
	// Note that if `versioning_override.behavior` is PINNED then `versioning_override.pinned_version`
	// will override this value.
	DeploymentVersion *v12.WorkerDeploymentVersion `protobuf:"bytes,7,opt,name=deployment_version,json=deploymentVersion,proto3" json:"deployment_version,omitempty"`
	// Present if user has set an execution-specific versioning override. This override takes
	// precedence over SDK-sent `behavior` (and `version` when override is PINNED). An
	// override can be set when starting a new execution, as well as afterwards by calling the
	// `UpdateWorkflowExecutionOptions` API.
	// Pinned overrides are automatically inherited by child workflows, continue-as-new workflows,
	// workflow retries, and cron workflows.
	VersioningOverride *VersioningOverride `protobuf:"bytes,3,opt,name=versioning_override,json=versioningOverride,proto3" json:"versioning_override,omitempty"`
	// When present, indicates the workflow is transitioning to a different deployment. Can
	// indicate one of the following transitions: unversioned -> versioned, versioned -> versioned
	// on a different deployment, or versioned -> unversioned.
	// Not applicable to workflows with PINNED behavior.
	// When a workflow with AUTO_UPGRADE behavior creates a new workflow task, it will automatically
	// start a transition to the task queue's current deployment if the task queue's current
	// deployment is different from the workflow's deployment.
	// If the AUTO_UPGRADE workflow is stuck due to backlogged activity or workflow tasks, those
	// tasks will be redirected to the task queue's current deployment. As soon as a poller from
	// that deployment is available to receive the task, the workflow will automatically start a
	// transition to that deployment and continue execution there.
	// A deployment transition can only exist while there is a pending or started workflow task.
	// Once the pending workflow task completes on the transition's target deployment, the
	// transition completes and the workflow's `deployment` and `behavior` fields are updated per
	// the worker's task completion response.
	// Pending activities will not start new attempts during a transition. Once the transition is
	// completed, pending activities will start their next attempt on the new deployment.
	// Deprecated. Use version_transition.
	//
	// Deprecated: Marked as deprecated in temporal/api/workflow/v1/message.proto.
	DeploymentTransition *DeploymentTransition `protobuf:"bytes,4,opt,name=deployment_transition,json=deploymentTransition,proto3" json:"deployment_transition,omitempty"`
	// When present, indicates the workflow is transitioning to a different deployment version
	// (which may belong to the same deployment name or another). Can indicate one of the following
	// transitions: unversioned -> versioned, versioned -> versioned
	// on a different deployment version, or versioned -> unversioned.
	// Not applicable to workflows with PINNED behavior.
	// When a workflow with AUTO_UPGRADE behavior creates a new workflow task, it will automatically
	// start a transition to the task queue's current version if the task queue's current version is
	// different from the workflow's current deployment version.
	// If the AUTO_UPGRADE workflow is stuck due to backlogged activity or workflow tasks, those
	// tasks will be redirected to the task queue's current version. As soon as a poller from
	// that deployment version is available to receive the task, the workflow will automatically
	// start a transition to that version and continue execution there.
	// A version transition can only exist while there is a pending or started workflow task.
	// Once the pending workflow task completes on the transition's target version, the
	// transition completes and the workflow's `behavior`, and `deployment_version` fields are updated per the
	// worker's task completion response.
	// Pending activities will not start new attempts during a transition. Once the transition is
	// completed, pending activities will start their next attempt on the new version.
	VersionTransition *DeploymentVersionTransition `protobuf:"bytes,6,opt,name=version_transition,json=versionTransition,proto3" json:"version_transition,omitempty"`
	// Monotonic counter reflecting the latest routing decision for this workflow execution.
	// Used for staleness detection between history and matching when dispatching tasks to workers.
	// Incremented when a workflow execution routes to a new deployment version, which happens
	// when a worker of the new deployment version completes a workflow task.
	// Note: Pinned tasks and sticky tasks send a value of 0 for this field since these tasks do not
	// face the problem of inconsistent dispatching that arises from eventual consistency between
	// task queues and their partitions.
	RevisionNumber int64 `protobuf:"varint,8,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
	// Experimental.
	// If this workflow is the result of a continue-as-new, this field is set to the initial_versioning_behavior
	// specified in that command.
	// Only used for the initial task of this run and the initial task of any retries of this run.
	// Not passed to children or to future continue-as-new.
	//
	// Note: In the first release of Upgrade-on-CaN, when the only ContinueAsNewVersioningBehavior was AutoUpgrade,
	// a non-empty InheritedAutoUpgradeInfo meant that the workflow should start as AutoUpgrade. So for compatibility
	// with ContinueAsNew history commands generated during that time, know that an UNSPECIFIED value here is equivalent
	// to ContinueAsNewVersioningBehaviorAutoUpgrade if the behavior of the workflow is AutoUpgrade.
	ContinueAsNewInitialVersioningBehavior v11.ContinueAsNewVersioningBehavior `` /* 243-byte string literal not displayed */
	// contains filtered or unexported fields
}

Holds all the information about worker versioning for a particular workflow execution. Experimental. Versioning info is experimental and might change in the future.

func (*WorkflowExecutionVersioningInfo) Descriptor deprecated added in v1.43.0

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

Deprecated: Use WorkflowExecutionVersioningInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionVersioningInfo) Equal added in v1.43.0

func (this *WorkflowExecutionVersioningInfo) Equal(that interface{}) bool

Equal returns whether two WorkflowExecutionVersioningInfo values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*WorkflowExecutionVersioningInfo) GetBehavior added in v1.43.0

func (*WorkflowExecutionVersioningInfo) GetContinueAsNewInitialVersioningBehavior added in v1.62.8

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

func (*WorkflowExecutionVersioningInfo) GetDeployment deprecated added in v1.43.0

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

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

func (*WorkflowExecutionVersioningInfo) GetDeploymentTransition deprecated added in v1.43.0

func (x *WorkflowExecutionVersioningInfo) GetDeploymentTransition() *DeploymentTransition

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

func (*WorkflowExecutionVersioningInfo) GetDeploymentVersion added in v1.49.1

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

func (*WorkflowExecutionVersioningInfo) GetRevisionNumber added in v1.57.0

func (x *WorkflowExecutionVersioningInfo) GetRevisionNumber() int64

func (*WorkflowExecutionVersioningInfo) GetVersion deprecated added in v1.44.0

func (x *WorkflowExecutionVersioningInfo) GetVersion() string

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

func (*WorkflowExecutionVersioningInfo) GetVersionTransition added in v1.44.0

func (*WorkflowExecutionVersioningInfo) GetVersioningOverride added in v1.43.0

func (x *WorkflowExecutionVersioningInfo) GetVersioningOverride() *VersioningOverride

func (*WorkflowExecutionVersioningInfo) Marshal added in v1.43.0

func (val *WorkflowExecutionVersioningInfo) Marshal() ([]byte, error)

Marshal an object of type WorkflowExecutionVersioningInfo to the protobuf v3 wire format

func (*WorkflowExecutionVersioningInfo) ProtoMessage added in v1.43.0

func (*WorkflowExecutionVersioningInfo) ProtoMessage()

func (*WorkflowExecutionVersioningInfo) ProtoReflect added in v1.43.0

func (*WorkflowExecutionVersioningInfo) Reset added in v1.43.0

func (*WorkflowExecutionVersioningInfo) Size added in v1.43.0

Size returns the size of the object, in bytes, once serialized

func (*WorkflowExecutionVersioningInfo) String added in v1.43.0

func (*WorkflowExecutionVersioningInfo) Unmarshal added in v1.43.0

func (val *WorkflowExecutionVersioningInfo) Unmarshal(buf []byte) error

Unmarshal an object of type WorkflowExecutionVersioningInfo from the protobuf v3 wire format

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL