kitchensink

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ParentClosePolicy_name = map[int32]string{
		0: "PARENT_CLOSE_POLICY_UNSPECIFIED",
		1: "PARENT_CLOSE_POLICY_TERMINATE",
		2: "PARENT_CLOSE_POLICY_ABANDON",
		3: "PARENT_CLOSE_POLICY_REQUEST_CANCEL",
	}
	ParentClosePolicy_value = map[string]int32{
		"PARENT_CLOSE_POLICY_UNSPECIFIED":    0,
		"PARENT_CLOSE_POLICY_TERMINATE":      1,
		"PARENT_CLOSE_POLICY_ABANDON":        2,
		"PARENT_CLOSE_POLICY_REQUEST_CANCEL": 3,
	}
)

Enum value maps for ParentClosePolicy.

View Source 
var (
	VersioningIntent_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "COMPATIBLE",
		2: "DEFAULT",
	}
	VersioningIntent_value = map[string]int32{
		"UNSPECIFIED": 0,
		"COMPATIBLE":  1,
		"DEFAULT":     2,
	}
)

Enum value maps for VersioningIntent.

View Source 
var (
	ChildWorkflowCancellationType_name = map[int32]string{
		0: "CHILD_WF_ABANDON",
		1: "CHILD_WF_TRY_CANCEL",
		2: "CHILD_WF_WAIT_CANCELLATION_COMPLETED",
		3: "CHILD_WF_WAIT_CANCELLATION_REQUESTED",
	}
	ChildWorkflowCancellationType_value = map[string]int32{
		"CHILD_WF_ABANDON":                     0,
		"CHILD_WF_TRY_CANCEL":                  1,
		"CHILD_WF_WAIT_CANCELLATION_COMPLETED": 2,
		"CHILD_WF_WAIT_CANCELLATION_REQUESTED": 3,
	}
)

Enum value maps for ChildWorkflowCancellationType.

View Source 
var (
	ActivityCancellationType_name = map[int32]string{
		0: "TRY_CANCEL",
		1: "WAIT_CANCELLATION_COMPLETED",
		2: "ABANDON",
	}
	ActivityCancellationType_value = map[string]int32{
		"TRY_CANCEL":                  0,
		"WAIT_CANCELLATION_COMPLETED": 1,
		"ABANDON":                     2,
	}
)

Enum value maps for ActivityCancellationType.

View Source 
var File_kitchen_sink_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Action 

type Action struct {

	// Types that are assignable to Variant:
	//
	//	*Action_Timer
	//	*Action_ExecActivity
	//	*Action_ExecChildWorkflow
	//	*Action_AwaitWorkflowState
	//	*Action_SendSignal
	//	*Action_CancelWorkflow
	//	*Action_SetPatchMarker
	//	*Action_UpsertSearchAttributes
	//	*Action_UpsertMemo
	//	*Action_SetWorkflowState
	//	*Action_ReturnResult
	//	*Action_ReturnError
	//	*Action_ContinueAsNew
	//	*Action_NestedActionSet
	Variant isAction_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated 

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

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetAwaitWorkflowState 

func (x *Action) GetAwaitWorkflowState() *AwaitWorkflowState

func (*Action) GetCancelWorkflow 

func (x *Action) GetCancelWorkflow() *CancelWorkflowAction

func (*Action) GetContinueAsNew 

func (x *Action) GetContinueAsNew() *ContinueAsNewAction

func (*Action) GetExecActivity 

func (x *Action) GetExecActivity() *ExecuteActivityAction

func (*Action) GetExecChildWorkflow 

func (x *Action) GetExecChildWorkflow() *ExecuteChildWorkflowAction

func (*Action) GetNestedActionSet 

func (x *Action) GetNestedActionSet() *ActionSet

func (*Action) GetReturnError 

func (x *Action) GetReturnError() *ReturnErrorAction

func (*Action) GetReturnResult 

func (x *Action) GetReturnResult() *ReturnResultAction

func (*Action) GetSendSignal 

func (x *Action) GetSendSignal() *SendSignalAction

func (*Action) GetSetPatchMarker 

func (x *Action) GetSetPatchMarker() *SetPatchMarkerAction

func (*Action) GetSetWorkflowState 

func (x *Action) GetSetWorkflowState() *WorkflowState

func (*Action) GetTimer 

func (x *Action) GetTimer() *TimerAction

func (*Action) GetUpsertMemo 

func (x *Action) GetUpsertMemo() *UpsertMemoAction

func (*Action) GetUpsertSearchAttributes 

func (x *Action) GetUpsertSearchAttributes() *UpsertSearchAttributesAction

func (*Action) GetVariant 

func (m *Action) GetVariant() isAction_Variant

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

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

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type ActionSet 

type ActionSet struct {
	Actions    []*Action `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"`
	Concurrent bool      `protobuf:"varint,2,opt,name=concurrent,proto3" json:"concurrent,omitempty"`
	// contains filtered or unexported fields
}

A set of actions to execute concurrently or sequentially. It is necessary to be able to represent sequential execution without multiple 1-size action sets, as that implies the receipt of a signal between each of those sets, which may not be desired.

All actions are handled before proceeding to the next action set, unless one of those actions would cause the workflow to complete/fail/CAN.

func NoOpSingleActivityActionSet 

func NoOpSingleActivityActionSet() *ActionSet

func (*ActionSet) Descriptor deprecated 

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

Deprecated: Use ActionSet.ProtoReflect.Descriptor instead.

func (*ActionSet) GetActions 

func (x *ActionSet) GetActions() []*Action

func (*ActionSet) GetConcurrent 

func (x *ActionSet) GetConcurrent() bool

func (*ActionSet) ProtoMessage 

func (*ActionSet) ProtoMessage()

func (*ActionSet) ProtoReflect 

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

func (*ActionSet) Reset 

func (x *ActionSet) Reset()

func (*ActionSet) String 

func (x *ActionSet) String() string

type Action_AwaitWorkflowState 

type Action_AwaitWorkflowState struct {
	AwaitWorkflowState *AwaitWorkflowState `protobuf:"bytes,4,opt,name=await_workflow_state,json=awaitWorkflowState,proto3,oneof"`
}

type Action_CancelWorkflow 

type Action_CancelWorkflow struct {
	CancelWorkflow *CancelWorkflowAction `protobuf:"bytes,6,opt,name=cancel_workflow,json=cancelWorkflow,proto3,oneof"`
}

type Action_ContinueAsNew 

type Action_ContinueAsNew struct {
	ContinueAsNew *ContinueAsNewAction `protobuf:"bytes,13,opt,name=continue_as_new,json=continueAsNew,proto3,oneof"`
}

type Action_ExecActivity 

type Action_ExecActivity struct {
	ExecActivity *ExecuteActivityAction `protobuf:"bytes,2,opt,name=exec_activity,json=execActivity,proto3,oneof"`
}

type Action_ExecChildWorkflow 

type Action_ExecChildWorkflow struct {
	ExecChildWorkflow *ExecuteChildWorkflowAction `protobuf:"bytes,3,opt,name=exec_child_workflow,json=execChildWorkflow,proto3,oneof"`
}

type Action_NestedActionSet 

type Action_NestedActionSet struct {
	NestedActionSet *ActionSet `protobuf:"bytes,14,opt,name=nested_action_set,json=nestedActionSet,proto3,oneof"`
}

type Action_ReturnError 

type Action_ReturnError struct {
	ReturnError *ReturnErrorAction `protobuf:"bytes,12,opt,name=return_error,json=returnError,proto3,oneof"`
}

type Action_ReturnResult 

type Action_ReturnResult struct {
	ReturnResult *ReturnResultAction `protobuf:"bytes,11,opt,name=return_result,json=returnResult,proto3,oneof"`
}

type Action_SendSignal 

type Action_SendSignal struct {
	SendSignal *SendSignalAction `protobuf:"bytes,5,opt,name=send_signal,json=sendSignal,proto3,oneof"`
}

type Action_SetPatchMarker 

type Action_SetPatchMarker struct {
	SetPatchMarker *SetPatchMarkerAction `protobuf:"bytes,7,opt,name=set_patch_marker,json=setPatchMarker,proto3,oneof"`
}

type Action_SetWorkflowState 

type Action_SetWorkflowState struct {
	SetWorkflowState *WorkflowState `protobuf:"bytes,10,opt,name=set_workflow_state,json=setWorkflowState,proto3,oneof"`
}

type Action_Timer 

type Action_Timer struct {
	Timer *TimerAction `protobuf:"bytes,1,opt,name=timer,proto3,oneof"`
}

type Action_UpsertMemo 

type Action_UpsertMemo struct {
	UpsertMemo *UpsertMemoAction `protobuf:"bytes,9,opt,name=upsert_memo,json=upsertMemo,proto3,oneof"`
}

type Action_UpsertSearchAttributes 

type Action_UpsertSearchAttributes struct {
	UpsertSearchAttributes *UpsertSearchAttributesAction `protobuf:"bytes,8,opt,name=upsert_search_attributes,json=upsertSearchAttributes,proto3,oneof"`
}

type ActivityCancellationType 

type ActivityCancellationType int32
const (
	// Initiate a cancellation request and immediately report cancellation to the workflow.
	ActivityCancellationType_TRY_CANCEL ActivityCancellationType = 0
	// Wait for activity cancellation completion. Note that activity must heartbeat to receive a
	// cancellation notification. This can block the cancellation for a long time if activity
	// doesn't heartbeat or chooses to ignore the cancellation request.
	ActivityCancellationType_WAIT_CANCELLATION_COMPLETED ActivityCancellationType = 1
	// Do not request cancellation of the activity and immediately report cancellation to the
	// workflow
	ActivityCancellationType_ABANDON ActivityCancellationType = 2
)

func (ActivityCancellationType) Descriptor 

func (ActivityCancellationType) Descriptor() protoreflect.EnumDescriptor

func (ActivityCancellationType) Enum 

func (x ActivityCancellationType) Enum() *ActivityCancellationType

func (ActivityCancellationType) EnumDescriptor deprecated 

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

Deprecated: Use ActivityCancellationType.Descriptor instead.

func (ActivityCancellationType) Number 

func (x ActivityCancellationType) Number() protoreflect.EnumNumber

func (ActivityCancellationType) String 

func (x ActivityCancellationType) String() string

func (ActivityCancellationType) Type 

func (ActivityCancellationType) Type() protoreflect.EnumType

type AwaitWorkflowState 

type AwaitWorkflowState struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Wait for the workflow state to have a matching k/v entry

func (*AwaitWorkflowState) Descriptor deprecated 

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

Deprecated: Use AwaitWorkflowState.ProtoReflect.Descriptor instead.

func (*AwaitWorkflowState) GetKey 

func (x *AwaitWorkflowState) GetKey() string

func (*AwaitWorkflowState) GetValue 

func (x *AwaitWorkflowState) GetValue() string

func (*AwaitWorkflowState) ProtoMessage 

func (*AwaitWorkflowState) ProtoMessage()

func (*AwaitWorkflowState) ProtoReflect 

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

func (*AwaitWorkflowState) Reset 

func (x *AwaitWorkflowState) Reset()

func (*AwaitWorkflowState) String 

func (x *AwaitWorkflowState) String() string

type AwaitableChoice 

type AwaitableChoice struct {

	// Types that are assignable to Condition:
	//
	//	*AwaitableChoice_WaitFinish
	//	*AwaitableChoice_Abandon
	//	*AwaitableChoice_CancelBeforeStarted
	//	*AwaitableChoice_CancelAfterStarted
	//	*AwaitableChoice_CancelAfterCompleted
	Condition isAwaitableChoice_Condition `protobuf_oneof:"condition"`
	// contains filtered or unexported fields
}

All await commands will have this available as a field. If it is set, the command should be either awaited upon, cancelled, or abandoned at the specified juncture (if possible, not all command types will be cancellable at all stages. Is is up to the generator to produce valid conditions).

func (*AwaitableChoice) Descriptor deprecated 

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

Deprecated: Use AwaitableChoice.ProtoReflect.Descriptor instead.

func (*AwaitableChoice) GetAbandon 

func (x *AwaitableChoice) GetAbandon() *emptypb.Empty

func (*AwaitableChoice) GetCancelAfterCompleted 

func (x *AwaitableChoice) GetCancelAfterCompleted() *emptypb.Empty

func (*AwaitableChoice) GetCancelAfterStarted 

func (x *AwaitableChoice) GetCancelAfterStarted() *emptypb.Empty

func (*AwaitableChoice) GetCancelBeforeStarted 

func (x *AwaitableChoice) GetCancelBeforeStarted() *emptypb.Empty

func (*AwaitableChoice) GetCondition 

func (m *AwaitableChoice) GetCondition() isAwaitableChoice_Condition

func (*AwaitableChoice) GetWaitFinish 

func (x *AwaitableChoice) GetWaitFinish() *emptypb.Empty

func (*AwaitableChoice) ProtoMessage 

func (*AwaitableChoice) ProtoMessage()

func (*AwaitableChoice) ProtoReflect 

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

func (*AwaitableChoice) Reset 

func (x *AwaitableChoice) Reset()

func (*AwaitableChoice) String 

func (x *AwaitableChoice) String() string

type AwaitableChoice_Abandon 

type AwaitableChoice_Abandon struct {
	// Call the command API but immediately move on. IE: Don't await on it at all.
	Abandon *emptypb.Empty `protobuf:"bytes,2,opt,name=abandon,proto3,oneof"`
}

type AwaitableChoice_CancelAfterCompleted 

type AwaitableChoice_CancelAfterCompleted struct {
	// Cancel the command after it's already completed.
	CancelAfterCompleted *emptypb.Empty `protobuf:"bytes,5,opt,name=cancel_after_completed,json=cancelAfterCompleted,proto3,oneof"`
}

type AwaitableChoice_CancelAfterStarted 

type AwaitableChoice_CancelAfterStarted struct {
	// Cancel the command after it's been started. Not all SDKs will know when a command is started
	// and in those cases they should issue the cancellation in the next workflow task after
	// creating the command.
	CancelAfterStarted *emptypb.Empty `protobuf:"bytes,4,opt,name=cancel_after_started,json=cancelAfterStarted,proto3,oneof"`
}

type AwaitableChoice_CancelBeforeStarted 

type AwaitableChoice_CancelBeforeStarted struct {
	// Cancel the command before it's begun - IE: Cancel it immediately after starting it with
	// no await, within the same workflow task.
	CancelBeforeStarted *emptypb.Empty `protobuf:"bytes,3,opt,name=cancel_before_started,json=cancelBeforeStarted,proto3,oneof"`
}

type AwaitableChoice_WaitFinish 

type AwaitableChoice_WaitFinish struct {
	// Wait for the command to finish. This is the default.
	WaitFinish *emptypb.Empty `protobuf:"bytes,1,opt,name=wait_finish,json=waitFinish,proto3,oneof"`
}

type CancelWorkflowAction 

type CancelWorkflowAction 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"`
	// contains filtered or unexported fields
}

Cancel an external workflow (may be a child)

func (*CancelWorkflowAction) Descriptor deprecated 

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

Deprecated: Use CancelWorkflowAction.ProtoReflect.Descriptor instead.

func (*CancelWorkflowAction) GetRunId 

func (x *CancelWorkflowAction) GetRunId() string

func (*CancelWorkflowAction) GetWorkflowId 

func (x *CancelWorkflowAction) GetWorkflowId() string

func (*CancelWorkflowAction) ProtoMessage 

func (*CancelWorkflowAction) ProtoMessage()

func (*CancelWorkflowAction) ProtoReflect 

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

func (*CancelWorkflowAction) Reset 

func (x *CancelWorkflowAction) Reset()

func (*CancelWorkflowAction) String 

func (x *CancelWorkflowAction) String() string

type ChildWorkflowCancellationType 

type ChildWorkflowCancellationType int32

Controls at which point to report back to lang when a child workflow is cancelled 

const (
	// Do not request cancellation of the child workflow if already scheduled
	ChildWorkflowCancellationType_CHILD_WF_ABANDON ChildWorkflowCancellationType = 0
	// Initiate a cancellation request and immediately report cancellation to the parent.
	ChildWorkflowCancellationType_CHILD_WF_TRY_CANCEL ChildWorkflowCancellationType = 1
	// Wait for child cancellation completion.
	ChildWorkflowCancellationType_CHILD_WF_WAIT_CANCELLATION_COMPLETED ChildWorkflowCancellationType = 2
	// Request cancellation of the child and wait for confirmation that the request was received.
	ChildWorkflowCancellationType_CHILD_WF_WAIT_CANCELLATION_REQUESTED ChildWorkflowCancellationType = 3
)

func (ChildWorkflowCancellationType) Descriptor 

func (ChildWorkflowCancellationType) Descriptor() protoreflect.EnumDescriptor

func (ChildWorkflowCancellationType) Enum 

func (x ChildWorkflowCancellationType) Enum() *ChildWorkflowCancellationType

func (ChildWorkflowCancellationType) EnumDescriptor deprecated 

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

Deprecated: Use ChildWorkflowCancellationType.Descriptor instead.

func (ChildWorkflowCancellationType) Number 

func (x ChildWorkflowCancellationType) Number() protoreflect.EnumNumber

func (ChildWorkflowCancellationType) String 

func (x ChildWorkflowCancellationType) String() string

func (ChildWorkflowCancellationType) Type 

func (ChildWorkflowCancellationType) Type() protoreflect.EnumType

type ClientAction 

type ClientAction struct {

	// Types that are assignable to Variant:
	//
	//	*ClientAction_DoSignal
	//	*ClientAction_DoQuery
	//	*ClientAction_DoUpdate
	//	*ClientAction_NestedActions
	Variant isClientAction_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*ClientAction) Descriptor deprecated 

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

Deprecated: Use ClientAction.ProtoReflect.Descriptor instead.

func (*ClientAction) GetDoQuery 

func (x *ClientAction) GetDoQuery() *DoQuery

func (*ClientAction) GetDoSignal 

func (x *ClientAction) GetDoSignal() *DoSignal

func (*ClientAction) GetDoUpdate 

func (x *ClientAction) GetDoUpdate() *DoUpdate

func (*ClientAction) GetNestedActions 

func (x *ClientAction) GetNestedActions() *ClientActionSet

func (*ClientAction) GetVariant 

func (m *ClientAction) GetVariant() isClientAction_Variant

func (*ClientAction) ProtoMessage 

func (*ClientAction) ProtoMessage()

func (*ClientAction) ProtoReflect 

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

func (*ClientAction) Reset 

func (x *ClientAction) Reset()

func (*ClientAction) String 

func (x *ClientAction) String() string

type ClientActionSet 

type ClientActionSet struct {
	Actions    []*ClientAction `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"`
	Concurrent bool            `protobuf:"varint,2,opt,name=concurrent,proto3" json:"concurrent,omitempty"`
	// Wait the specified amount of time at the end of the action set before proceeding to the next
	// (if there is one, if not, ignored).
	WaitAtEnd *durationpb.Duration `protobuf:"bytes,3,opt,name=wait_at_end,json=waitAtEnd,proto3" json:"wait_at_end,omitempty"`
	// contains filtered or unexported fields
}

A set of client actions to execute.

func (*ClientActionSet) Descriptor deprecated 

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

Deprecated: Use ClientActionSet.ProtoReflect.Descriptor instead.

func (*ClientActionSet) GetActions 

func (x *ClientActionSet) GetActions() []*ClientAction

func (*ClientActionSet) GetConcurrent 

func (x *ClientActionSet) GetConcurrent() bool

func (*ClientActionSet) GetWaitAtEnd 

func (x *ClientActionSet) GetWaitAtEnd() *durationpb.Duration

func (*ClientActionSet) ProtoMessage 

func (*ClientActionSet) ProtoMessage()

func (*ClientActionSet) ProtoReflect 

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

func (*ClientActionSet) Reset 

func (x *ClientActionSet) Reset()

func (*ClientActionSet) String 

func (x *ClientActionSet) String() string

type ClientAction_DoQuery 

type ClientAction_DoQuery struct {
	DoQuery *DoQuery `protobuf:"bytes,2,opt,name=do_query,json=doQuery,proto3,oneof"`
}

type ClientAction_DoSignal 

type ClientAction_DoSignal struct {
	DoSignal *DoSignal `protobuf:"bytes,1,opt,name=do_signal,json=doSignal,proto3,oneof"`
}

type ClientAction_DoUpdate 

type ClientAction_DoUpdate struct {
	DoUpdate *DoUpdate `protobuf:"bytes,3,opt,name=do_update,json=doUpdate,proto3,oneof"`
}

type ClientAction_NestedActions 

type ClientAction_NestedActions struct {
	NestedActions *ClientActionSet `protobuf:"bytes,4,opt,name=nested_actions,json=nestedActions,proto3,oneof"`
}

type ClientActionsExecutor 

type ClientActionsExecutor struct {
	Client     client.Client
	WorkflowID string
	RunID      string
}

func (*ClientActionsExecutor) ExecuteClientSequence 

func (e *ClientActionsExecutor) ExecuteClientSequence(ctx context.Context, clientSeq *ClientSequence) error

type ClientSequence 

type ClientSequence struct {
	ActionSets []*ClientActionSet `protobuf:"bytes,1,rep,name=action_sets,json=actionSets,proto3" json:"action_sets,omitempty"`
	// contains filtered or unexported fields
}

All the client actions that will be taken over the course of this test

func (*ClientSequence) Descriptor deprecated 

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

Deprecated: Use ClientSequence.ProtoReflect.Descriptor instead.

func (*ClientSequence) GetActionSets 

func (x *ClientSequence) GetActionSets() []*ClientActionSet

func (*ClientSequence) ProtoMessage 

func (*ClientSequence) ProtoMessage()

func (*ClientSequence) ProtoReflect 

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

func (*ClientSequence) Reset 

func (x *ClientSequence) Reset()

func (*ClientSequence) String 

func (x *ClientSequence) String() string

type ContinueAsNewAction 

type ContinueAsNewAction struct {

	// The identifier the lang-specific sdk uses to execute workflow code
	WorkflowType string `protobuf:"bytes,1,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	// Task queue for the new workflow execution
	TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Inputs to the workflow code. Should be specified. Will not re-use old arguments, as that
	// typically wouldn't make any sense.
	Arguments []*v1.Payload `protobuf:"bytes,3,rep,name=arguments,proto3" json:"arguments,omitempty"`
	// Timeout for a single run of the new workflow. Will not re-use current workflow's value.
	WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,4,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// Timeout of a single workflow task. Will not re-use current workflow's value.
	WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,5,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// If set, the new workflow will have this memo. If unset, re-uses the current workflow's memo
	Memo map[string]*v1.Payload `` /* 149-byte string literal not displayed */
	// If set, the new workflow will have these headers. Will *not* re-use current workflow's
	// headers otherwise.
	Headers map[string]*v1.Payload `` /* 155-byte string literal not displayed */
	// If set, the new workflow will have these search attributes. If unset, re-uses the current
	// workflow's search attributes.
	SearchAttributes map[string]*v1.Payload `` /* 197-byte string literal not displayed */
	// If set, the new workflow will have this retry policy. If unset, re-uses the current
	// workflow's retry policy.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,9,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Whether the continued workflow should run on a worker with a compatible build id or not.
	VersioningIntent VersioningIntent `` /* 160-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ContinueAsNewAction) Descriptor deprecated 

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

Deprecated: Use ContinueAsNewAction.ProtoReflect.Descriptor instead.

func (*ContinueAsNewAction) GetArguments 

func (x *ContinueAsNewAction) GetArguments() []*v1.Payload

func (*ContinueAsNewAction) GetHeaders 

func (x *ContinueAsNewAction) GetHeaders() map[string]*v1.Payload

func (*ContinueAsNewAction) GetMemo 

func (x *ContinueAsNewAction) GetMemo() map[string]*v1.Payload

func (*ContinueAsNewAction) GetRetryPolicy 

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

func (*ContinueAsNewAction) GetSearchAttributes 

func (x *ContinueAsNewAction) GetSearchAttributes() map[string]*v1.Payload

func (*ContinueAsNewAction) GetTaskQueue 

func (x *ContinueAsNewAction) GetTaskQueue() string

func (*ContinueAsNewAction) GetVersioningIntent 

func (x *ContinueAsNewAction) GetVersioningIntent() VersioningIntent

func (*ContinueAsNewAction) GetWorkflowRunTimeout 

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

func (*ContinueAsNewAction) GetWorkflowTaskTimeout 

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

func (*ContinueAsNewAction) GetWorkflowType 

func (x *ContinueAsNewAction) GetWorkflowType() string

func (*ContinueAsNewAction) ProtoMessage 

func (*ContinueAsNewAction) ProtoMessage()

func (*ContinueAsNewAction) ProtoReflect 

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

func (*ContinueAsNewAction) Reset 

func (x *ContinueAsNewAction) Reset()

func (*ContinueAsNewAction) String 

func (x *ContinueAsNewAction) String() string

type DoActionsUpdate 

type DoActionsUpdate struct {

	// Types that are assignable to Variant:
	//
	//	*DoActionsUpdate_DoActions
	//	*DoActionsUpdate_RejectMe
	Variant isDoActionsUpdate_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*DoActionsUpdate) Descriptor deprecated 

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

Deprecated: Use DoActionsUpdate.ProtoReflect.Descriptor instead.

func (*DoActionsUpdate) GetDoActions 

func (x *DoActionsUpdate) GetDoActions() *ActionSet

func (*DoActionsUpdate) GetRejectMe 

func (x *DoActionsUpdate) GetRejectMe() *emptypb.Empty

func (*DoActionsUpdate) GetVariant 

func (m *DoActionsUpdate) GetVariant() isDoActionsUpdate_Variant

func (*DoActionsUpdate) ProtoMessage 

func (*DoActionsUpdate) ProtoMessage()

func (*DoActionsUpdate) ProtoReflect 

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

func (*DoActionsUpdate) Reset 

func (x *DoActionsUpdate) Reset()

func (*DoActionsUpdate) String 

func (x *DoActionsUpdate) String() string

type DoActionsUpdate_DoActions 

type DoActionsUpdate_DoActions struct {
	// Do same thing signal handler would do when given the provided action set. The handler should
	// return the `WorkflowState` when done with all the provided actions. You may also include a
	// `ReturnErrorAction` or `ContinueAsNewAction` in the set to exit the handler in those ways.
	DoActions *ActionSet `protobuf:"bytes,1,opt,name=do_actions,json=doActions,proto3,oneof"`
}

type DoActionsUpdate_RejectMe 

type DoActionsUpdate_RejectMe struct {
	// The validator should reject the update
	RejectMe *emptypb.Empty `protobuf:"bytes,2,opt,name=reject_me,json=rejectMe,proto3,oneof"`
}

type DoQuery 

type DoQuery struct {

	// Types that are assignable to Variant:
	//
	//	*DoQuery_ReportState
	//	*DoQuery_Custom
	Variant isDoQuery_Variant `protobuf_oneof:"variant"`
	// If set, the client should expect the query to fail
	FailureExpected bool `protobuf:"varint,10,opt,name=failure_expected,json=failureExpected,proto3" json:"failure_expected,omitempty"`
	// contains filtered or unexported fields
}

func (*DoQuery) Descriptor deprecated 

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

Deprecated: Use DoQuery.ProtoReflect.Descriptor instead.

func (*DoQuery) GetCustom 

func (x *DoQuery) GetCustom() *HandlerInvocation

func (*DoQuery) GetFailureExpected 

func (x *DoQuery) GetFailureExpected() bool

func (*DoQuery) GetReportState 

func (x *DoQuery) GetReportState() *v1.Payloads

func (*DoQuery) GetVariant 

func (m *DoQuery) GetVariant() isDoQuery_Variant

func (*DoQuery) ProtoMessage 

func (*DoQuery) ProtoMessage()

func (*DoQuery) ProtoReflect 

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

func (*DoQuery) Reset 

func (x *DoQuery) Reset()

func (*DoQuery) String 

func (x *DoQuery) String() string

type DoQuery_Custom 

type DoQuery_Custom struct {
	// Send an arbitrary query
	Custom *HandlerInvocation `protobuf:"bytes,2,opt,name=custom,proto3,oneof"`
}

type DoQuery_ReportState 

type DoQuery_ReportState struct {
	// A query must exist named `report_state` which returns the `WorkflowState` message. The input
	// is pointless and only exists to allow testing of variably-sized query args.
	ReportState *v1.Payloads `protobuf:"bytes,1,opt,name=report_state,json=reportState,proto3,oneof"`
}

type DoSignal 

type DoSignal struct {

	// Types that are assignable to Variant:
	//
	//	*DoSignal_DoSignalActions_
	//	*DoSignal_Custom
	Variant isDoSignal_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*DoSignal) Descriptor deprecated 

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

Deprecated: Use DoSignal.ProtoReflect.Descriptor instead.

func (*DoSignal) GetCustom 

func (x *DoSignal) GetCustom() *HandlerInvocation

func (*DoSignal) GetDoSignalActions 

func (x *DoSignal) GetDoSignalActions() *DoSignal_DoSignalActions

func (*DoSignal) GetVariant 

func (m *DoSignal) GetVariant() isDoSignal_Variant

func (*DoSignal) ProtoMessage 

func (*DoSignal) ProtoMessage()

func (*DoSignal) ProtoReflect 

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

func (*DoSignal) Reset 

func (x *DoSignal) Reset()

func (*DoSignal) String 

func (x *DoSignal) String() string

type DoSignal_Custom 

type DoSignal_Custom struct {
	// Send an arbitrary signal
	Custom *HandlerInvocation `protobuf:"bytes,2,opt,name=custom,proto3,oneof"`
}

type DoSignal_DoSignalActions 

type DoSignal_DoSignalActions struct {

	// Types that are assignable to Variant:
	//
	//	*DoSignal_DoSignalActions_DoActions
	//	*DoSignal_DoSignalActions_DoActionsInMain
	Variant isDoSignal_DoSignalActions_Variant `protobuf_oneof:"variant"`
	// contains filtered or unexported fields
}

func (*DoSignal_DoSignalActions) Descriptor deprecated 

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

Deprecated: Use DoSignal_DoSignalActions.ProtoReflect.Descriptor instead.

func (*DoSignal_DoSignalActions) GetDoActions 

func (x *DoSignal_DoSignalActions) GetDoActions() *ActionSet

func (*DoSignal_DoSignalActions) GetDoActionsInMain 

func (x *DoSignal_DoSignalActions) GetDoActionsInMain() *ActionSet

func (*DoSignal_DoSignalActions) GetVariant 

func (m *DoSignal_DoSignalActions) GetVariant() isDoSignal_DoSignalActions_Variant

func (*DoSignal_DoSignalActions) ProtoMessage 

func (*DoSignal_DoSignalActions) ProtoMessage()

func (*DoSignal_DoSignalActions) ProtoReflect 

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

func (*DoSignal_DoSignalActions) Reset 

func (x *DoSignal_DoSignalActions) Reset()

func (*DoSignal_DoSignalActions) String 

func (x *DoSignal_DoSignalActions) String() string

type DoSignal_DoSignalActions_ 

type DoSignal_DoSignalActions_ struct {
	// A signal handler must exist named `do_actions_signal` which is responsible for handling the
	// DoSignalActions message. See it's doc for details.
	DoSignalActions *DoSignal_DoSignalActions `protobuf:"bytes,1,opt,name=do_signal_actions,json=doSignalActions,proto3,oneof"`
}

type DoSignal_DoSignalActions_DoActions 

type DoSignal_DoSignalActions_DoActions struct {
	// Execute the action set in the handler. Since Go doesn't have explicit signal handlers it
	// should instead run the actions in a goroutine for both of these variants, as the
	// distinction doesn't really matter there.
	DoActions *ActionSet `protobuf:"bytes,1,opt,name=do_actions,json=doActions,proto3,oneof"`
}

type DoSignal_DoSignalActions_DoActionsInMain 

type DoSignal_DoSignalActions_DoActionsInMain struct {
	// Pipe the actions back to the main workflow function via a queue or similar mechanism, where
	// they will then be run.
	DoActionsInMain *ActionSet `protobuf:"bytes,2,opt,name=do_actions_in_main,json=doActionsInMain,proto3,oneof"`
}

type DoUpdate 

type DoUpdate struct {

	// Types that are assignable to Variant:
	//
	//	*DoUpdate_DoActions
	//	*DoUpdate_Custom
	Variant isDoUpdate_Variant `protobuf_oneof:"variant"`
	// If set, the client should expect the update to fail
	FailureExpected bool `protobuf:"varint,10,opt,name=failure_expected,json=failureExpected,proto3" json:"failure_expected,omitempty"`
	// contains filtered or unexported fields
}

func (*DoUpdate) Descriptor deprecated 

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

Deprecated: Use DoUpdate.ProtoReflect.Descriptor instead.

func (*DoUpdate) GetCustom 

func (x *DoUpdate) GetCustom() *HandlerInvocation

func (*DoUpdate) GetDoActions 

func (x *DoUpdate) GetDoActions() *DoActionsUpdate

func (*DoUpdate) GetFailureExpected 

func (x *DoUpdate) GetFailureExpected() bool

func (*DoUpdate) GetVariant 

func (m *DoUpdate) GetVariant() isDoUpdate_Variant

func (*DoUpdate) ProtoMessage 

func (*DoUpdate) ProtoMessage()

func (*DoUpdate) ProtoReflect 

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

func (*DoUpdate) Reset 

func (x *DoUpdate) Reset()

func (*DoUpdate) String 

func (x *DoUpdate) String() string

type DoUpdate_Custom 

type DoUpdate_Custom struct {
	// Send an arbitrary update request
	Custom *HandlerInvocation `protobuf:"bytes,2,opt,name=custom,proto3,oneof"`
}

type DoUpdate_DoActions 

type DoUpdate_DoActions struct {
	// An update must exist named `do_actions_update` which handles the `DoActionsUpdate` message.
	// See message doc for what it should do.
	DoActions *DoActionsUpdate `protobuf:"bytes,1,opt,name=do_actions,json=doActions,proto3,oneof"`
}

type ExecuteActivityAction 

type ExecuteActivityAction struct {

	// Types that are assignable to ActivityType:
	//
	//	*ExecuteActivityAction_Generic
	//	*ExecuteActivityAction_Delay
	//	*ExecuteActivityAction_Noop
	ActivityType isExecuteActivityAction_ActivityType `protobuf_oneof:"activity_type"`
	// The name of the task queue to place this activity request in
	TaskQueue string                 `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Headers   map[string]*v1.Payload `` /* 155-byte string literal not displayed */
	// Indicates how long the caller is willing to wait for an activity completion. Limits how long
	// retries will be attempted. Either this or start_to_close_timeout_seconds must be specified.
	// When not specified defaults to the workflow execution timeout.
	ScheduleToCloseTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// Limits time an activity task can stay in a task queue before a worker picks it up. This
	// timeout is always non retryable as all a retry would achieve is to put it back into the same
	// queue. Defaults to schedule_to_close_timeout or workflow execution timeout if not specified.
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	// Maximum time an activity is allowed to execute after a pick up by a worker. This timeout is
	// always retryable. Either this or schedule_to_close_timeout must be specified.
	StartToCloseTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	// Maximum time allowed between successful worker heartbeats.
	HeartbeatTimeout *durationpb.Duration `protobuf:"bytes,9,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"`
	// Activities are provided by a default retry policy controlled through the service dynamic
	// configuration. Retries are happening up to schedule_to_close_timeout. To disable retries set
	// retry_policy.maximum_attempts to 1.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,10,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// Whether or not this activity will be a local activity
	//
	// Types that are assignable to Locality:
	//
	//	*ExecuteActivityAction_IsLocal
	//	*ExecuteActivityAction_Remote
	Locality        isExecuteActivityAction_Locality `protobuf_oneof:"locality"`
	AwaitableChoice *AwaitableChoice                 `protobuf:"bytes,13,opt,name=awaitable_choice,json=awaitableChoice,proto3" json:"awaitable_choice,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteActivityAction) Descriptor deprecated 

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

Deprecated: Use ExecuteActivityAction.ProtoReflect.Descriptor instead.

func (*ExecuteActivityAction) GetActivityType 

func (m *ExecuteActivityAction) GetActivityType() isExecuteActivityAction_ActivityType

func (*ExecuteActivityAction) GetAwaitableChoice 

func (x *ExecuteActivityAction) GetAwaitableChoice() *AwaitableChoice

func (*ExecuteActivityAction) GetDelay 

func (x *ExecuteActivityAction) GetDelay() *durationpb.Duration

func (*ExecuteActivityAction) GetGeneric 

func (x *ExecuteActivityAction) GetGeneric() *ExecuteActivityAction_GenericActivity

func (*ExecuteActivityAction) GetHeaders 

func (x *ExecuteActivityAction) GetHeaders() map[string]*v1.Payload

func (*ExecuteActivityAction) GetHeartbeatTimeout 

func (x *ExecuteActivityAction) GetHeartbeatTimeout() *durationpb.Duration

func (*ExecuteActivityAction) GetIsLocal 

func (x *ExecuteActivityAction) GetIsLocal() *emptypb.Empty

func (*ExecuteActivityAction) GetLocality 

func (m *ExecuteActivityAction) GetLocality() isExecuteActivityAction_Locality

func (*ExecuteActivityAction) GetNoop 

func (x *ExecuteActivityAction) GetNoop() *emptypb.Empty

func (*ExecuteActivityAction) GetRemote 

func (x *ExecuteActivityAction) GetRemote() *RemoteActivityOptions

func (*ExecuteActivityAction) GetRetryPolicy 

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

func (*ExecuteActivityAction) GetScheduleToCloseTimeout 

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

func (*ExecuteActivityAction) GetScheduleToStartTimeout 

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

func (*ExecuteActivityAction) GetStartToCloseTimeout 

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

func (*ExecuteActivityAction) GetTaskQueue 

func (x *ExecuteActivityAction) GetTaskQueue() string

func (*ExecuteActivityAction) ProtoMessage 

func (*ExecuteActivityAction) ProtoMessage()

func (*ExecuteActivityAction) ProtoReflect 

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

func (*ExecuteActivityAction) Reset 

func (x *ExecuteActivityAction) Reset()

func (*ExecuteActivityAction) String 

func (x *ExecuteActivityAction) String() string

type ExecuteActivityAction_Delay 

type ExecuteActivityAction_Delay struct {
	// There must be an activity named `delay` which accepts some kind of duration and waits
	// for that long
	Delay *durationpb.Duration `protobuf:"bytes,2,opt,name=delay,proto3,oneof"`
}

type ExecuteActivityAction_Generic 

type ExecuteActivityAction_Generic struct {
	Generic *ExecuteActivityAction_GenericActivity `protobuf:"bytes,1,opt,name=generic,proto3,oneof"`
}

type ExecuteActivityAction_GenericActivity 

type ExecuteActivityAction_GenericActivity struct {
	Type      string        `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Arguments []*v1.Payload `protobuf:"bytes,2,rep,name=arguments,proto3" json:"arguments,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteActivityAction_GenericActivity) Descriptor deprecated 

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

Deprecated: Use ExecuteActivityAction_GenericActivity.ProtoReflect.Descriptor instead.

func (*ExecuteActivityAction_GenericActivity) GetArguments 

func (x *ExecuteActivityAction_GenericActivity) GetArguments() []*v1.Payload

func (*ExecuteActivityAction_GenericActivity) GetType 

func (x *ExecuteActivityAction_GenericActivity) GetType() string

func (*ExecuteActivityAction_GenericActivity) ProtoMessage 

func (*ExecuteActivityAction_GenericActivity) ProtoMessage()

func (*ExecuteActivityAction_GenericActivity) ProtoReflect 

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

func (*ExecuteActivityAction_GenericActivity) Reset 

func (x *ExecuteActivityAction_GenericActivity) Reset()

func (*ExecuteActivityAction_GenericActivity) String 

func (x *ExecuteActivityAction_GenericActivity) String() string

type ExecuteActivityAction_IsLocal 

type ExecuteActivityAction_IsLocal struct {
	IsLocal *emptypb.Empty `protobuf:"bytes,11,opt,name=is_local,json=isLocal,proto3,oneof"`
}

type ExecuteActivityAction_Noop 

type ExecuteActivityAction_Noop struct {
	// There must be an activity named `noop` which does nothing
	Noop *emptypb.Empty `protobuf:"bytes,3,opt,name=noop,proto3,oneof"`
}

type ExecuteActivityAction_Remote 

type ExecuteActivityAction_Remote struct {
	Remote *RemoteActivityOptions `protobuf:"bytes,12,opt,name=remote,proto3,oneof"`
}

type ExecuteChildWorkflowAction 

type ExecuteChildWorkflowAction struct {
	Namespace    string        `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId   string        `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType string        `protobuf:"bytes,4,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    string        `protobuf:"bytes,5,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Input        []*v1.Payload `protobuf:"bytes,6,rep,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,8,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,9,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// Default: PARENT_CLOSE_POLICY_TERMINATE.
	ParentClosePolicy ParentClosePolicy `` /* 166-byte string literal not displayed */
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */
	RetryPolicy           *v1.RetryPolicy           `protobuf:"bytes,13,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	CronSchedule          string                    `protobuf:"bytes,14,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	// Header fields
	Headers map[string]*v1.Payload `` /* 156-byte string literal not displayed */
	// Memo fields
	Memo map[string]*v1.Payload `` /* 150-byte string literal not displayed */
	// Search attributes
	SearchAttributes map[string]*v1.Payload `` /* 198-byte string literal not displayed */
	// Defines behaviour of the underlying workflow when child workflow cancellation has been requested.
	CancellationType ChildWorkflowCancellationType `` /* 173-byte string literal not displayed */
	// Whether this child should run on a worker with a compatible build id or not.
	VersioningIntent VersioningIntent `` /* 160-byte string literal not displayed */
	AwaitableChoice  *AwaitableChoice `protobuf:"bytes,20,opt,name=awaitable_choice,json=awaitableChoice,proto3" json:"awaitable_choice,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteChildWorkflowAction) Descriptor deprecated 

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

Deprecated: Use ExecuteChildWorkflowAction.ProtoReflect.Descriptor instead.

func (*ExecuteChildWorkflowAction) GetAwaitableChoice 

func (x *ExecuteChildWorkflowAction) GetAwaitableChoice() *AwaitableChoice

func (*ExecuteChildWorkflowAction) GetCancellationType 

func (x *ExecuteChildWorkflowAction) GetCancellationType() ChildWorkflowCancellationType

func (*ExecuteChildWorkflowAction) GetCronSchedule 

func (x *ExecuteChildWorkflowAction) GetCronSchedule() string

func (*ExecuteChildWorkflowAction) GetHeaders 

func (x *ExecuteChildWorkflowAction) GetHeaders() map[string]*v1.Payload

func (*ExecuteChildWorkflowAction) GetInput 

func (x *ExecuteChildWorkflowAction) GetInput() []*v1.Payload

func (*ExecuteChildWorkflowAction) GetMemo 

func (x *ExecuteChildWorkflowAction) GetMemo() map[string]*v1.Payload

func (*ExecuteChildWorkflowAction) GetNamespace 

func (x *ExecuteChildWorkflowAction) GetNamespace() string

func (*ExecuteChildWorkflowAction) GetParentClosePolicy 

func (x *ExecuteChildWorkflowAction) GetParentClosePolicy() ParentClosePolicy

func (*ExecuteChildWorkflowAction) GetRetryPolicy 

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

func (*ExecuteChildWorkflowAction) GetSearchAttributes 

func (x *ExecuteChildWorkflowAction) GetSearchAttributes() map[string]*v1.Payload

func (*ExecuteChildWorkflowAction) GetTaskQueue 

func (x *ExecuteChildWorkflowAction) GetTaskQueue() string

func (*ExecuteChildWorkflowAction) GetVersioningIntent 

func (x *ExecuteChildWorkflowAction) GetVersioningIntent() VersioningIntent

func (*ExecuteChildWorkflowAction) GetWorkflowExecutionTimeout 

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

func (*ExecuteChildWorkflowAction) GetWorkflowId 

func (x *ExecuteChildWorkflowAction) GetWorkflowId() string

func (*ExecuteChildWorkflowAction) GetWorkflowIdReusePolicy 

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

func (*ExecuteChildWorkflowAction) GetWorkflowRunTimeout 

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

func (*ExecuteChildWorkflowAction) GetWorkflowTaskTimeout 

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

func (*ExecuteChildWorkflowAction) GetWorkflowType 

func (x *ExecuteChildWorkflowAction) GetWorkflowType() string

func (*ExecuteChildWorkflowAction) ProtoMessage 

func (*ExecuteChildWorkflowAction) ProtoMessage()

func (*ExecuteChildWorkflowAction) ProtoReflect 

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

func (*ExecuteChildWorkflowAction) Reset 

func (x *ExecuteChildWorkflowAction) Reset()

func (*ExecuteChildWorkflowAction) String 

func (x *ExecuteChildWorkflowAction) String() string

type HandlerInvocation 

type HandlerInvocation struct {
	Name string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args []*v1.Payload `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*HandlerInvocation) Descriptor deprecated 

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

Deprecated: Use HandlerInvocation.ProtoReflect.Descriptor instead.

func (*HandlerInvocation) GetArgs 

func (x *HandlerInvocation) GetArgs() []*v1.Payload

func (*HandlerInvocation) GetName 

func (x *HandlerInvocation) GetName() string

func (*HandlerInvocation) ProtoMessage 

func (*HandlerInvocation) ProtoMessage()

func (*HandlerInvocation) ProtoReflect 

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

func (*HandlerInvocation) Reset 

func (x *HandlerInvocation) Reset()

func (*HandlerInvocation) String 

func (x *HandlerInvocation) String() string

type ParentClosePolicy 

type ParentClosePolicy int32

Used by the service to determine the fate of a child workflow in case its parent is closed. 

const (
	// Let's the server set the default.
	ParentClosePolicy_PARENT_CLOSE_POLICY_UNSPECIFIED ParentClosePolicy = 0
	// Terminate means terminating the child workflow.
	ParentClosePolicy_PARENT_CLOSE_POLICY_TERMINATE ParentClosePolicy = 1
	// Abandon means not doing anything on the child workflow.
	ParentClosePolicy_PARENT_CLOSE_POLICY_ABANDON ParentClosePolicy = 2
	// Cancel means requesting cancellation on the child workflow.
	ParentClosePolicy_PARENT_CLOSE_POLICY_REQUEST_CANCEL ParentClosePolicy = 3
)

func (ParentClosePolicy) Descriptor 

func (ParentClosePolicy) Descriptor() protoreflect.EnumDescriptor

func (ParentClosePolicy) Enum 

func (x ParentClosePolicy) Enum() *ParentClosePolicy

func (ParentClosePolicy) EnumDescriptor deprecated 

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

Deprecated: Use ParentClosePolicy.Descriptor instead.

func (ParentClosePolicy) Number 

func (x ParentClosePolicy) Number() protoreflect.EnumNumber

func (ParentClosePolicy) String 

func (x ParentClosePolicy) String() string

func (ParentClosePolicy) Type 

func (ParentClosePolicy) Type() protoreflect.EnumType

type RemoteActivityOptions 

type RemoteActivityOptions struct {

	// Defines how the workflow will wait (or not) for cancellation of the activity to be confirmed
	CancellationType ActivityCancellationType `` /* 167-byte string literal not displayed */
	// If set, the worker will not tell the service that it can immediately start executing this
	// activity. When unset/default, workers will always attempt to do so if activity execution
	// slots are available.
	DoNotEagerlyExecute bool `protobuf:"varint,2,opt,name=do_not_eagerly_execute,json=doNotEagerlyExecute,proto3" json:"do_not_eagerly_execute,omitempty"`
	// Whether this activity should run on a worker with a compatible build id or not.
	VersioningIntent VersioningIntent `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RemoteActivityOptions) Descriptor deprecated 

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

Deprecated: Use RemoteActivityOptions.ProtoReflect.Descriptor instead.

func (*RemoteActivityOptions) GetCancellationType 

func (x *RemoteActivityOptions) GetCancellationType() ActivityCancellationType

func (*RemoteActivityOptions) GetDoNotEagerlyExecute 

func (x *RemoteActivityOptions) GetDoNotEagerlyExecute() bool

func (*RemoteActivityOptions) GetVersioningIntent 

func (x *RemoteActivityOptions) GetVersioningIntent() VersioningIntent

func (*RemoteActivityOptions) ProtoMessage 

func (*RemoteActivityOptions) ProtoMessage()

func (*RemoteActivityOptions) ProtoReflect 

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

func (*RemoteActivityOptions) Reset 

func (x *RemoteActivityOptions) Reset()

func (*RemoteActivityOptions) String 

func (x *RemoteActivityOptions) String() string

type ReturnErrorAction 

type ReturnErrorAction struct {
	Failure *v12.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

func (*ReturnErrorAction) Descriptor deprecated 

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

Deprecated: Use ReturnErrorAction.ProtoReflect.Descriptor instead.

func (*ReturnErrorAction) GetFailure 

func (x *ReturnErrorAction) GetFailure() *v12.Failure

func (*ReturnErrorAction) ProtoMessage 

func (*ReturnErrorAction) ProtoMessage()

func (*ReturnErrorAction) ProtoReflect 

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

func (*ReturnErrorAction) Reset 

func (x *ReturnErrorAction) Reset()

func (*ReturnErrorAction) String 

func (x *ReturnErrorAction) String() string

type ReturnResultAction 

type ReturnResultAction struct {
	ReturnThis *v1.Payload `protobuf:"bytes,1,opt,name=return_this,json=returnThis,proto3" json:"return_this,omitempty"`
	// contains filtered or unexported fields
}

func (*ReturnResultAction) Descriptor deprecated 

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

Deprecated: Use ReturnResultAction.ProtoReflect.Descriptor instead.

func (*ReturnResultAction) GetReturnThis 

func (x *ReturnResultAction) GetReturnThis() *v1.Payload

func (*ReturnResultAction) ProtoMessage 

func (*ReturnResultAction) ProtoMessage()

func (*ReturnResultAction) ProtoReflect 

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

func (*ReturnResultAction) Reset 

func (x *ReturnResultAction) Reset()

func (*ReturnResultAction) String 

func (x *ReturnResultAction) String() string

type SendSignalAction 

type SendSignalAction struct {

	// What workflow is being targeted
	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"`
	// Name of the signal handler
	SignalName string `protobuf:"bytes,3,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	// Arguments for the handler
	Args []*v1.Payload `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	// Headers to attach to the signal
	Headers         map[string]*v1.Payload `` /* 155-byte string literal not displayed */
	AwaitableChoice *AwaitableChoice       `protobuf:"bytes,6,opt,name=awaitable_choice,json=awaitableChoice,proto3" json:"awaitable_choice,omitempty"`
	// contains filtered or unexported fields
}

func (*SendSignalAction) Descriptor deprecated 

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

Deprecated: Use SendSignalAction.ProtoReflect.Descriptor instead.

func (*SendSignalAction) GetArgs 

func (x *SendSignalAction) GetArgs() []*v1.Payload

func (*SendSignalAction) GetAwaitableChoice 

func (x *SendSignalAction) GetAwaitableChoice() *AwaitableChoice

func (*SendSignalAction) GetHeaders 

func (x *SendSignalAction) GetHeaders() map[string]*v1.Payload

func (*SendSignalAction) GetRunId 

func (x *SendSignalAction) GetRunId() string

func (*SendSignalAction) GetSignalName 

func (x *SendSignalAction) GetSignalName() string

func (*SendSignalAction) GetWorkflowId 

func (x *SendSignalAction) GetWorkflowId() string

func (*SendSignalAction) ProtoMessage 

func (*SendSignalAction) ProtoMessage()

func (*SendSignalAction) ProtoReflect 

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

func (*SendSignalAction) Reset 

func (x *SendSignalAction) Reset()

func (*SendSignalAction) String 

func (x *SendSignalAction) String() string

type SetPatchMarkerAction 

type SetPatchMarkerAction struct {

	// A user-chosen identifier for this patch. If the same identifier is used in multiple places in
	// the code, those places are considered to be versioned as one unit. IE: The check call will
	// return the same result for all of them
	PatchId string `protobuf:"bytes,1,opt,name=patch_id,json=patchId,proto3" json:"patch_id,omitempty"`
	// TODO Not sure how we could use this in these tests
	// Can be set to true to indicate that branches using this change are being removed, and all
	// future worker deployments will only have the "with change" code in them.
	Deprecated bool `protobuf:"varint,2,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	// Perform this action behind the if guard
	InnerAction *Action `protobuf:"bytes,3,opt,name=inner_action,json=innerAction,proto3" json:"inner_action,omitempty"`
	// contains filtered or unexported fields
}

patched or getVersion API For getVersion SDKs, use `DEFAULT_VERSION, 1` as the numeric arguments,

func (*SetPatchMarkerAction) Descriptor deprecated 

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

Deprecated: Use SetPatchMarkerAction.ProtoReflect.Descriptor instead.

func (*SetPatchMarkerAction) GetDeprecated 

func (x *SetPatchMarkerAction) GetDeprecated() bool

func (*SetPatchMarkerAction) GetInnerAction 

func (x *SetPatchMarkerAction) GetInnerAction() *Action

func (*SetPatchMarkerAction) GetPatchId 

func (x *SetPatchMarkerAction) GetPatchId() string

func (*SetPatchMarkerAction) ProtoMessage 

func (*SetPatchMarkerAction) ProtoMessage()

func (*SetPatchMarkerAction) ProtoReflect 

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

func (*SetPatchMarkerAction) Reset 

func (x *SetPatchMarkerAction) Reset()

func (*SetPatchMarkerAction) String 

func (x *SetPatchMarkerAction) String() string

type TestInput 

type TestInput struct {
	WorkflowInput  *WorkflowInput  `protobuf:"bytes,1,opt,name=workflow_input,json=workflowInput,proto3" json:"workflow_input,omitempty"`
	ClientSequence *ClientSequence `protobuf:"bytes,2,opt,name=client_sequence,json=clientSequence,proto3" json:"client_sequence,omitempty"`
	// contains filtered or unexported fields
}

The input to the test overall. A copy of this constitutes everything that is needed to reproduce the test.

func (*TestInput) Descriptor deprecated 

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

Deprecated: Use TestInput.ProtoReflect.Descriptor instead.

func (*TestInput) GetClientSequence 

func (x *TestInput) GetClientSequence() *ClientSequence

func (*TestInput) GetWorkflowInput 

func (x *TestInput) GetWorkflowInput() *WorkflowInput

func (*TestInput) ProtoMessage 

func (*TestInput) ProtoMessage()

func (*TestInput) ProtoReflect 

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

func (*TestInput) Reset 

func (x *TestInput) Reset()

func (*TestInput) String 

func (x *TestInput) String() string

type TimerAction 

type TimerAction struct {
	Milliseconds    uint64           `protobuf:"varint,1,opt,name=milliseconds,proto3" json:"milliseconds,omitempty"`
	AwaitableChoice *AwaitableChoice `protobuf:"bytes,2,opt,name=awaitable_choice,json=awaitableChoice,proto3" json:"awaitable_choice,omitempty"`
	// contains filtered or unexported fields
}

func (*TimerAction) Descriptor deprecated 

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

Deprecated: Use TimerAction.ProtoReflect.Descriptor instead.

func (*TimerAction) GetAwaitableChoice 

func (x *TimerAction) GetAwaitableChoice() *AwaitableChoice

func (*TimerAction) GetMilliseconds 

func (x *TimerAction) GetMilliseconds() uint64

func (*TimerAction) ProtoMessage 

func (*TimerAction) ProtoMessage()

func (*TimerAction) ProtoReflect 

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

func (*TimerAction) Reset 

func (x *TimerAction) Reset()

func (*TimerAction) String 

func (x *TimerAction) String() string

type UpsertMemoAction 

type UpsertMemoAction struct {

	// Update the workflow memo with the provided values. The values will be merged with
	// the existing memo. If the user wants to delete values, a default/empty Payload should be
	// used as the value for the key being deleted.
	UpsertedMemo *v1.Memo `protobuf:"bytes,1,opt,name=upserted_memo,json=upsertedMemo,proto3" json:"upserted_memo,omitempty"`
	// contains filtered or unexported fields
}

func (*UpsertMemoAction) Descriptor deprecated 

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

Deprecated: Use UpsertMemoAction.ProtoReflect.Descriptor instead.

func (*UpsertMemoAction) GetUpsertedMemo 

func (x *UpsertMemoAction) GetUpsertedMemo() *v1.Memo

func (*UpsertMemoAction) ProtoMessage 

func (*UpsertMemoAction) ProtoMessage()

func (*UpsertMemoAction) ProtoReflect 

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

func (*UpsertMemoAction) Reset 

func (x *UpsertMemoAction) Reset()

func (*UpsertMemoAction) String 

func (x *UpsertMemoAction) String() string

type UpsertSearchAttributesAction 

type UpsertSearchAttributesAction struct {

	// SearchAttributes fields - equivalent to indexed_fields on api. Key = search index, Value =
	// value
	SearchAttributes map[string]*v1.Payload `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpsertSearchAttributesAction) Descriptor deprecated 

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

Deprecated: Use UpsertSearchAttributesAction.ProtoReflect.Descriptor instead.

func (*UpsertSearchAttributesAction) GetSearchAttributes 

func (x *UpsertSearchAttributesAction) GetSearchAttributes() map[string]*v1.Payload

func (*UpsertSearchAttributesAction) ProtoMessage 

func (*UpsertSearchAttributesAction) ProtoMessage()

func (*UpsertSearchAttributesAction) ProtoReflect 

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

func (*UpsertSearchAttributesAction) Reset 

func (x *UpsertSearchAttributesAction) Reset()

func (*UpsertSearchAttributesAction) String 

func (x *UpsertSearchAttributesAction) String() string

type VersioningIntent 

type VersioningIntent int32

An indication of user's intent concerning what Build ID versioning approach should be used for a specific command 

const (
	// Indicates that core should choose the most sensible default behavior for the type of
	// command, accounting for whether the command will be run on the same task queue as the current
	// worker.
	VersioningIntent_UNSPECIFIED VersioningIntent = 0
	// Indicates that the command should run on a worker with compatible version if possible. It may
	// not be possible if the target task queue does not also have knowledge of the current worker's
	// build ID.
	VersioningIntent_COMPATIBLE VersioningIntent = 1
	// Indicates that the command should run on the target task queue's current overall-default
	// build ID.
	VersioningIntent_DEFAULT VersioningIntent = 2
)

func (VersioningIntent) Descriptor 

func (VersioningIntent) Descriptor() protoreflect.EnumDescriptor

func (VersioningIntent) Enum 

func (x VersioningIntent) Enum() *VersioningIntent

func (VersioningIntent) EnumDescriptor deprecated 

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

Deprecated: Use VersioningIntent.Descriptor instead.

func (VersioningIntent) Number 

func (x VersioningIntent) Number() protoreflect.EnumNumber

func (VersioningIntent) String 

func (x VersioningIntent) String() string

func (VersioningIntent) Type 

func (VersioningIntent) Type() protoreflect.EnumType

type WorkflowInput 

type WorkflowInput struct {
	InitialActions []*ActionSet `protobuf:"bytes,1,rep,name=initial_actions,json=initialActions,proto3" json:"initial_actions,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowInput) Descriptor deprecated 

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

Deprecated: Use WorkflowInput.ProtoReflect.Descriptor instead.

func (*WorkflowInput) GetInitialActions 

func (x *WorkflowInput) GetInitialActions() []*ActionSet

func (*WorkflowInput) ProtoMessage 

func (*WorkflowInput) ProtoMessage()

func (*WorkflowInput) ProtoReflect 

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

func (*WorkflowInput) Reset 

func (x *WorkflowInput) Reset()

func (*WorkflowInput) String 

func (x *WorkflowInput) String() string

type WorkflowState 

type WorkflowState struct {
	Kvs map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

Each workflow must maintain an instance of this state

func (*WorkflowState) Descriptor deprecated 

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

Deprecated: Use WorkflowState.ProtoReflect.Descriptor instead.

func (*WorkflowState) GetKvs 

func (x *WorkflowState) GetKvs() map[string]string

func (*WorkflowState) ProtoMessage 

func (*WorkflowState) ProtoMessage()

func (*WorkflowState) ProtoReflect 

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

func (*WorkflowState) Reset 

func (x *WorkflowState) Reset()

func (*WorkflowState) String 

func (x *WorkflowState) String() string

Source Files

View all Source files

Directories

Path Synopsis
temporal
api/common/v1
api/enums/v1
api/failure/v1

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.