workflow

package
v1.43.1 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2025 License: MIT Imports: 14 Imported by: 53

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

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
	Variant isCallbackInfo_Trigger_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use CallbackInfo_Trigger.ProtoReflect.Descriptor instead.

func (*CallbackInfo_Trigger) GetVariant added in v1.27.0 

func (x *CallbackInfo_Trigger) GetVariant() isCallbackInfo_Trigger_Variant

func (*CallbackInfo_Trigger) GetWorkflowClosed added in v1.27.0 

func (x *CallbackInfo_Trigger) GetWorkflowClosed() *CallbackInfo_WorkflowClosed

func (*CallbackInfo_Trigger) ProtoMessage added in v1.27.0 

func (*CallbackInfo_Trigger) ProtoMessage()

func (*CallbackInfo_Trigger) ProtoReflect added in v1.27.0 

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

func (*CallbackInfo_Trigger) Reset added in v1.27.0 

func (x *CallbackInfo_Trigger) Reset()

func (*CallbackInfo_Trigger) String added in v1.27.0 

func (x *CallbackInfo_Trigger) String() string

type CallbackInfo_Trigger_WorkflowClosed added in v1.27.0 

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

type CallbackInfo_WorkflowClosed added in v1.27.0 

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

Trigger for when the workflow is closed.

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

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

Deprecated: Use CallbackInfo_WorkflowClosed.ProtoReflect.Descriptor instead.

func (*CallbackInfo_WorkflowClosed) ProtoMessage added in v1.27.0 

func (*CallbackInfo_WorkflowClosed) ProtoMessage()

func (*CallbackInfo_WorkflowClosed) ProtoReflect added in v1.27.0 

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

func (*CallbackInfo_WorkflowClosed) Reset added in v1.27.0 

func (x *CallbackInfo_WorkflowClosed) Reset()

func (*CallbackInfo_WorkflowClosed) String added in v1.27.0 

func (x *CallbackInfo_WorkflowClosed) String() string

type DeploymentTransition added in v1.43.0 

type DeploymentTransition struct {

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

Holds information about ongoing transition of a workflow execution from one deployment to another. Experimental. Deployment transition is experimental and might change in the future.

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 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"`
	// 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) GetRetryPolicy added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) GetSearchAttributes added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) GetTaskQueue added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) GetUserMetadata added in v1.34.0 

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

func (*NewWorkflowExecutionInfo) GetVersioningOverride added in v1.43.0 

func (x *NewWorkflowExecutionInfo) GetVersioningOverride() *VersioningOverride

func (*NewWorkflowExecutionInfo) GetWorkflowExecutionTimeout added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) GetWorkflowId added in v1.8.0 

func (x *NewWorkflowExecutionInfo) GetWorkflowId() string

func (*NewWorkflowExecutionInfo) GetWorkflowIdReusePolicy added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) GetWorkflowRunTimeout added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) GetWorkflowTaskTimeout added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) GetWorkflowType added in v1.8.0 

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

func (*NewWorkflowExecutionInfo) Marshal added in v1.8.0 

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

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

func (*NewWorkflowExecutionInfo) ProtoMessage added in v1.8.0 

func (*NewWorkflowExecutionInfo) ProtoMessage()

func (*NewWorkflowExecutionInfo) ProtoReflect added in v1.26.1 

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

func (*NewWorkflowExecutionInfo) Reset added in v1.8.0 

func (x *NewWorkflowExecutionInfo) Reset()

func (*NewWorkflowExecutionInfo) Size added in v1.8.0 

func (val *NewWorkflowExecutionInfo) Size() int

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

func (*NewWorkflowExecutionInfo) String added in v1.8.0 

func (x *NewWorkflowExecutionInfo) String() string

func (*NewWorkflowExecutionInfo) Unmarshal added in v1.8.0 

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

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

type NexusOperationCancellationInfo added in v1.32.1 

type NexusOperationCancellationInfo struct {

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

NexusOperationCancellationInfo contains the state of a nexus operation cancellation.

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

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

Deprecated: Use NexusOperationCancellationInfo.ProtoReflect.Descriptor instead.

func (*NexusOperationCancellationInfo) Equal added in v1.32.1 

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

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

func (*NexusOperationCancellationInfo) GetAttempt added in v1.32.1 

func (x *NexusOperationCancellationInfo) GetAttempt() int32

func (*NexusOperationCancellationInfo) GetBlockedReason added in v1.42.0 

func (x *NexusOperationCancellationInfo) GetBlockedReason() string

func (*NexusOperationCancellationInfo) GetLastAttemptCompleteTime added in v1.32.1 

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

func (*NexusOperationCancellationInfo) GetLastAttemptFailure added in v1.32.1 

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

func (*NexusOperationCancellationInfo) GetNextAttemptScheduleTime added in v1.32.1 

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

func (*NexusOperationCancellationInfo) GetRequestedTime added in v1.32.1 

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

func (*NexusOperationCancellationInfo) GetState added in v1.32.1 

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

func (*NexusOperationCancellationInfo) Marshal added in v1.32.1 

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

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

func (*NexusOperationCancellationInfo) ProtoMessage added in v1.32.1 

func (*NexusOperationCancellationInfo) ProtoMessage()

func (*NexusOperationCancellationInfo) ProtoReflect added in v1.32.1 

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

func (*NexusOperationCancellationInfo) Reset added in v1.32.1 

func (x *NexusOperationCancellationInfo) Reset()

func (*NexusOperationCancellationInfo) Size added in v1.32.1 

func (val *NexusOperationCancellationInfo) Size() int

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

func (*NexusOperationCancellationInfo) String added in v1.32.1 

func (x *NexusOperationCancellationInfo) String() string

func (*NexusOperationCancellationInfo) Unmarshal added in v1.32.1 

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

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

type 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"`
	// The version stamp of the worker to whom this activity was most recently dispatched
	// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	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.
	LastDeployment *v12.Deployment `protobuf:"bytes,20,opt,name=last_deployment,json=lastDeployment,proto3" json:"last_deployment,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) 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 added in v1.43.0 

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

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 added in v1.32.0 

func (x *PendingActivityInfo) GetLastIndependentlyAssignedBuildId() string

func (*PendingActivityInfo) GetLastStartedTime added in v0.28.0 

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

func (*PendingActivityInfo) GetLastWorkerIdentity 

func (x *PendingActivityInfo) GetLastWorkerIdentity() string

func (*PendingActivityInfo) GetLastWorkerVersionStamp added in v1.32.0 

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

func (*PendingActivityInfo) GetMaximumAttempts 

func (x *PendingActivityInfo) GetMaximumAttempts() int32

func (*PendingActivityInfo) GetNextAttemptScheduleTime added in v1.40.0 

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

func (*PendingActivityInfo) GetPaused added in v1.41.0 

func (x *PendingActivityInfo) GetPaused() bool

func (*PendingActivityInfo) GetScheduledTime added in v0.28.0 

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

func (*PendingActivityInfo) GetState 

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

func (*PendingActivityInfo) GetUseWorkflowBuildId added in v1.32.0 

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

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 {
	// This means the activity is independently versioned and not bound to the build ID of its workflow.
	// The activity will use the build id in this field instead.
	// If the task fails and is scheduled again, the assigned build ID may change according to the latest versioning
	// rules.
	LastIndependentlyAssignedBuildId string `protobuf:"bytes,14,opt,name=last_independently_assigned_build_id,json=lastIndependentlyAssignedBuildId,proto3,oneof"`
}

type PendingActivityInfo_UseWorkflowBuildId added in v1.32.0 

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

type PendingChildExecutionInfo 

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

func (*PendingChildExecutionInfo) Descriptor deprecated 

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

Deprecated: Use PendingChildExecutionInfo.ProtoReflect.Descriptor instead.

func (*PendingChildExecutionInfo) Equal 

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

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

func (*PendingChildExecutionInfo) GetInitiatedId 

func (x *PendingChildExecutionInfo) GetInitiatedId() int64

func (*PendingChildExecutionInfo) GetParentClosePolicy 

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

func (*PendingChildExecutionInfo) GetRunId 

func (x *PendingChildExecutionInfo) GetRunId() string

func (*PendingChildExecutionInfo) GetWorkflowId 

func (x *PendingChildExecutionInfo) GetWorkflowId() string

func (*PendingChildExecutionInfo) GetWorkflowTypeName 

func (x *PendingChildExecutionInfo) GetWorkflowTypeName() string

func (*PendingChildExecutionInfo) Marshal 

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

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

func (*PendingChildExecutionInfo) ProtoMessage 

func (*PendingChildExecutionInfo) ProtoMessage()

func (*PendingChildExecutionInfo) ProtoReflect added in v1.26.1 

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

func (*PendingChildExecutionInfo) Reset 

func (x *PendingChildExecutionInfo) Reset()

func (*PendingChildExecutionInfo) Size 

func (val *PendingChildExecutionInfo) Size() int

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

func (*PendingChildExecutionInfo) String 

func (x *PendingChildExecutionInfo) String() string

func (*PendingChildExecutionInfo) Unmarshal 

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

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

type PendingNexusOperationInfo added in v1.32.1 

type PendingNexusOperationInfo struct {

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

PendingNexusOperationInfo contains the state of a pending Nexus operation.

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

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

Deprecated: Use PendingNexusOperationInfo.ProtoReflect.Descriptor instead.

func (*PendingNexusOperationInfo) Equal added in v1.32.1 

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

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

func (*PendingNexusOperationInfo) GetAttempt added in v1.32.1 

func (x *PendingNexusOperationInfo) GetAttempt() int32

func (*PendingNexusOperationInfo) GetBlockedReason added in v1.42.0 

func (x *PendingNexusOperationInfo) GetBlockedReason() string

func (*PendingNexusOperationInfo) GetCancellationInfo added in v1.32.1 

func (x *PendingNexusOperationInfo) GetCancellationInfo() *NexusOperationCancellationInfo

func (*PendingNexusOperationInfo) GetEndpoint added in v1.33.0 

func (x *PendingNexusOperationInfo) GetEndpoint() string

func (*PendingNexusOperationInfo) GetLastAttemptCompleteTime added in v1.32.1 

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

func (*PendingNexusOperationInfo) GetLastAttemptFailure added in v1.32.1 

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

func (*PendingNexusOperationInfo) GetNextAttemptScheduleTime added in v1.32.1 

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

func (*PendingNexusOperationInfo) GetOperation added in v1.32.1 

func (x *PendingNexusOperationInfo) GetOperation() string

func (*PendingNexusOperationInfo) GetOperationId added in v1.32.1 

func (x *PendingNexusOperationInfo) GetOperationId() string

func (*PendingNexusOperationInfo) GetScheduleToCloseTimeout added in v1.32.1 

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

func (*PendingNexusOperationInfo) GetScheduledEventId added in v1.36.0 

func (x *PendingNexusOperationInfo) GetScheduledEventId() int64

func (*PendingNexusOperationInfo) GetScheduledTime added in v1.32.1 

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

func (*PendingNexusOperationInfo) GetService added in v1.32.1 

func (x *PendingNexusOperationInfo) GetService() string

func (*PendingNexusOperationInfo) GetState added in v1.32.1 

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

func (*PendingNexusOperationInfo) Marshal added in v1.32.1 

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

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

func (*PendingNexusOperationInfo) ProtoMessage added in v1.32.1 

func (*PendingNexusOperationInfo) ProtoMessage()

func (*PendingNexusOperationInfo) ProtoReflect added in v1.32.1 

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

func (*PendingNexusOperationInfo) Reset added in v1.32.1 

func (x *PendingNexusOperationInfo) Reset()

func (*PendingNexusOperationInfo) Size added in v1.32.1 

func (val *PendingNexusOperationInfo) Size() int

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

func (*PendingNexusOperationInfo) String added in v1.32.1 

func (x *PendingNexusOperationInfo) String() string

func (*PendingNexusOperationInfo) Unmarshal added in v1.32.1 

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

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

type PendingWorkflowTaskInfo added in v1.8.0 

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

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

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

Deprecated: Use PendingWorkflowTaskInfo.ProtoReflect.Descriptor instead.

func (*PendingWorkflowTaskInfo) Equal added in v1.8.0 

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

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

func (*PendingWorkflowTaskInfo) GetAttempt added in v1.8.0 

func (x *PendingWorkflowTaskInfo) GetAttempt() int32

func (*PendingWorkflowTaskInfo) GetOriginalScheduledTime added in v1.8.0 

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

func (*PendingWorkflowTaskInfo) GetScheduledTime added in v1.8.0 

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

func (*PendingWorkflowTaskInfo) GetStartedTime added in v1.8.0 

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

func (*PendingWorkflowTaskInfo) GetState added in v1.8.0 

func (x *PendingWorkflowTaskInfo) GetState() v11.PendingWorkflowTaskState

func (*PendingWorkflowTaskInfo) Marshal added in v1.8.0 

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

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

func (*PendingWorkflowTaskInfo) ProtoMessage added in v1.8.0 

func (*PendingWorkflowTaskInfo) ProtoMessage()

func (*PendingWorkflowTaskInfo) ProtoReflect added in v1.26.1 

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

func (*PendingWorkflowTaskInfo) Reset added in v1.8.0 

func (x *PendingWorkflowTaskInfo) Reset()

func (*PendingWorkflowTaskInfo) Size added in v1.8.0 

func (val *PendingWorkflowTaskInfo) Size() int

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

func (*PendingWorkflowTaskInfo) String added in v1.8.0 

func (x *PendingWorkflowTaskInfo) String() string

func (*PendingWorkflowTaskInfo) Unmarshal added in v1.8.0 

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

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

type ResetPointInfo 

type ResetPointInfo struct {

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

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

func (*ResetPointInfo) Descriptor deprecated 

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

Deprecated: Use ResetPointInfo.ProtoReflect.Descriptor instead.

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

func (x *ResetPointInfo) GetBinaryChecksum() string

func (*ResetPointInfo) GetBuildId added in v1.26.2 

func (x *ResetPointInfo) GetBuildId() string

func (*ResetPointInfo) GetCreateTime added in v0.28.0 

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

func (*ResetPointInfo) GetExpireTime added in v0.28.0 

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

func (*ResetPointInfo) GetFirstWorkflowTaskCompletedId 

func (x *ResetPointInfo) GetFirstWorkflowTaskCompletedId() int64

func (*ResetPointInfo) GetResettable 

func (x *ResetPointInfo) GetResettable() bool

func (*ResetPointInfo) GetRunId 

func (x *ResetPointInfo) GetRunId() string

func (*ResetPointInfo) Marshal 

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

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

func (*ResetPointInfo) ProtoMessage 

func (*ResetPointInfo) ProtoMessage()

func (*ResetPointInfo) ProtoReflect added in v1.26.1 

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

func (*ResetPointInfo) Reset 

func (x *ResetPointInfo) Reset()

func (*ResetPointInfo) Size 

func (val *ResetPointInfo) Size() int

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

func (*ResetPointInfo) String 

func (x *ResetPointInfo) String() string

func (*ResetPointInfo) Unmarshal 

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

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

type ResetPoints 

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

func (*ResetPoints) Descriptor deprecated 

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

Deprecated: Use ResetPoints.ProtoReflect.Descriptor instead.

func (*ResetPoints) Equal 

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

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

func (*ResetPoints) GetPoints 

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

func (*ResetPoints) Marshal 

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

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

func (*ResetPoints) ProtoMessage 

func (*ResetPoints) ProtoMessage()

func (*ResetPoints) ProtoReflect added in v1.26.1 

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

func (*ResetPoints) Reset 

func (x *ResetPoints) Reset()

func (*ResetPoints) Size 

func (val *ResetPoints) Size() int

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

func (*ResetPoints) String 

func (x *ResetPoints) String() string

func (*ResetPoints) Unmarshal 

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

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

type VersioningOverride added in v1.43.0 

type VersioningOverride struct {

	// Required.
	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.
	Deployment *v12.Deployment `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// contains filtered or unexported fields
}

Used to override the versioning behavior and deployment of a specific workflow execution. If set, takes precedence over the 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.

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) GetBehavior added in v1.43.0 

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

func (*VersioningOverride) GetDeployment added in v1.43.0 

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

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 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"`
	// 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) GetRunExpirationTime added in v1.43.1 

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

func (*WorkflowExecutionExtendedInfo) Marshal added in v1.43.1 

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

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

func (*WorkflowExecutionExtendedInfo) ProtoMessage added in v1.43.1 

func (*WorkflowExecutionExtendedInfo) ProtoMessage()

func (*WorkflowExecutionExtendedInfo) ProtoReflect added in v1.43.1 

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

func (*WorkflowExecutionExtendedInfo) Reset added in v1.43.1 

func (x *WorkflowExecutionExtendedInfo) Reset()

func (*WorkflowExecutionExtendedInfo) Size added in v1.43.1 

func (val *WorkflowExecutionExtendedInfo) Size() int

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

func (*WorkflowExecutionExtendedInfo) String added in v1.43.1 

func (x *WorkflowExecutionExtendedInfo) String() string

func (*WorkflowExecutionExtendedInfo) Unmarshal added in v1.43.1 

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

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

type WorkflowExecutionInfo 

type WorkflowExecutionInfo struct {
	Execution            *v1.WorkflowExecution       `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Type                 *v1.WorkflowType            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	StartTime            *timestamppb.Timestamp      `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	CloseTime            *timestamppb.Timestamp      `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	Status               v11.WorkflowExecutionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	HistoryLength        int64                       `protobuf:"varint,6,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	ParentNamespaceId    string                      `protobuf:"bytes,7,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentExecution      *v1.WorkflowExecution       `protobuf:"bytes,8,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
	ExecutionTime        *timestamppb.Timestamp      `protobuf:"bytes,9,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	Memo                 *v1.Memo                    `protobuf:"bytes,10,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes     *v1.SearchAttributes        `protobuf:"bytes,11,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	AutoResetPoints      *ResetPoints                `protobuf:"bytes,12,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
	TaskQueue            string                      `protobuf:"bytes,13,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StateTransitionCount int64                       `protobuf:"varint,14,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	HistorySizeBytes     int64                       `protobuf:"varint,15,opt,name=history_size_bytes,json=historySizeBytes,proto3" json:"history_size_bytes,omitempty"`
	// If set, the most recent worker version stamp that appeared in a workflow task completion
	// Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]
	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]
	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]
	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"`
	// 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 added in v1.32.0 

func (x *WorkflowExecutionInfo) GetAssignedBuildId() string

func (*WorkflowExecutionInfo) GetAutoResetPoints 

func (x *WorkflowExecutionInfo) GetAutoResetPoints() *ResetPoints

func (*WorkflowExecutionInfo) GetCloseTime 

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

func (*WorkflowExecutionInfo) GetExecution 

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

func (*WorkflowExecutionInfo) GetExecutionDuration added in v1.32.0 

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

func (*WorkflowExecutionInfo) GetExecutionTime 

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

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 added in v1.32.0 

func (x *WorkflowExecutionInfo) GetInheritedBuildId() string

func (*WorkflowExecutionInfo) GetMemo 

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

func (*WorkflowExecutionInfo) GetMostRecentWorkerVersionStamp added in v1.19.0 

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

func (*WorkflowExecutionInfo) GetParentExecution 

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

func (*WorkflowExecutionInfo) GetParentNamespaceId 

func (x *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetRootExecution added in v1.32.0 

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

func (*WorkflowExecutionInfo) GetSearchAttributes 

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

func (*WorkflowExecutionInfo) GetStartTime 

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

func (*WorkflowExecutionInfo) GetStateTransitionCount added in v1.5.0 

func (x *WorkflowExecutionInfo) GetStateTransitionCount() int64

func (*WorkflowExecutionInfo) GetStatus 

func (x *WorkflowExecutionInfo) GetStatus() v11.WorkflowExecutionStatus

func (*WorkflowExecutionInfo) GetTaskQueue 

func (x *WorkflowExecutionInfo) GetTaskQueue() string

func (*WorkflowExecutionInfo) GetType 

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

func (*WorkflowExecutionInfo) GetVersioningInfo added in v1.43.0 

func (x *WorkflowExecutionInfo) GetVersioningInfo() *WorkflowExecutionVersioningInfo

func (*WorkflowExecutionInfo) 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"`
	// 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) 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 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.
	// This field is first set after an execution completes its first workflow task on a versioned
	// worker, and set again on completion of every subsequent workflow task.
	// 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.
	Deployment *v12.Deployment `protobuf:"bytes,2,opt,name=deployment,proto3" json:"deployment,omitempty"`
	// Present if user has set an execution-specific versioning override. This override takes
	// precedence over SDK-sent `behavior` (and `deployment` when override is PINNED). An override
	// can be set when starting a new execution, as well as afterwards by calling the
	// `UpdateWorkflowExecutionOptions` API.
	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.
	DeploymentTransition *DeploymentTransition `protobuf:"bytes,4,opt,name=deployment_transition,json=deploymentTransition,proto3" json:"deployment_transition,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

Deprecated: Use WorkflowExecutionVersioningInfo.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionVersioningInfo) Equal added in v1.43.0 

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

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

func (*WorkflowExecutionVersioningInfo) GetBehavior added in v1.43.0 

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

func (*WorkflowExecutionVersioningInfo) GetDeployment added in v1.43.0 

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

func (*WorkflowExecutionVersioningInfo) GetDeploymentTransition added in v1.43.0 

func (x *WorkflowExecutionVersioningInfo) GetDeploymentTransition() *DeploymentTransition

func (*WorkflowExecutionVersioningInfo) GetVersioningOverride added in v1.43.0 

func (x *WorkflowExecutionVersioningInfo) GetVersioningOverride() *VersioningOverride

func (*WorkflowExecutionVersioningInfo) Marshal added in v1.43.0 

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

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

func (*WorkflowExecutionVersioningInfo) ProtoMessage added in v1.43.0 

func (*WorkflowExecutionVersioningInfo) ProtoMessage()

func (*WorkflowExecutionVersioningInfo) ProtoReflect added in v1.43.0 

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

func (*WorkflowExecutionVersioningInfo) Reset added in v1.43.0 

func (x *WorkflowExecutionVersioningInfo) Reset()

func (*WorkflowExecutionVersioningInfo) Size added in v1.43.0 

func (val *WorkflowExecutionVersioningInfo) Size() int

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

func (*WorkflowExecutionVersioningInfo) String added in v1.43.0 

func (x *WorkflowExecutionVersioningInfo) String() string

func (*WorkflowExecutionVersioningInfo) Unmarshal added in v1.43.0 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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