Documentation ¶
Index ¶
- Variables
- type Action
- func (*Action) Descriptor() ([]byte, []int)deprecated
- func (x *Action) GetAwaitWorkflowState() *AwaitWorkflowState
- func (x *Action) GetCancelWorkflow() *CancelWorkflowAction
- func (x *Action) GetContinueAsNew() *ContinueAsNewAction
- func (x *Action) GetExecActivity() *ExecuteActivityAction
- func (x *Action) GetExecChildWorkflow() *ExecuteChildWorkflowAction
- func (x *Action) GetNestedActionSet() *ActionSet
- func (x *Action) GetReturnError() *ReturnErrorAction
- func (x *Action) GetReturnResult() *ReturnResultAction
- func (x *Action) GetSendSignal() *SendSignalAction
- func (x *Action) GetSetPatchMarker() *SetPatchMarkerAction
- func (x *Action) GetSetWorkflowState() *WorkflowState
- func (x *Action) GetTimer() *TimerAction
- func (x *Action) GetUpsertMemo() *UpsertMemoAction
- func (x *Action) GetUpsertSearchAttributes() *UpsertSearchAttributesAction
- func (m *Action) GetVariant() isAction_Variant
- func (*Action) ProtoMessage()
- func (x *Action) ProtoReflect() protoreflect.Message
- func (x *Action) Reset()
- func (x *Action) String() string
- type ActionSet
- type Action_AwaitWorkflowState
- type Action_CancelWorkflow
- type Action_ContinueAsNew
- type Action_ExecActivity
- type Action_ExecChildWorkflow
- type Action_NestedActionSet
- type Action_ReturnError
- type Action_ReturnResult
- type Action_SendSignal
- type Action_SetPatchMarker
- type Action_SetWorkflowState
- type Action_Timer
- type Action_UpsertMemo
- type Action_UpsertSearchAttributes
- type ActivityCancellationType
- func (ActivityCancellationType) Descriptor() protoreflect.EnumDescriptor
- func (x ActivityCancellationType) Enum() *ActivityCancellationType
- func (ActivityCancellationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ActivityCancellationType) Number() protoreflect.EnumNumber
- func (x ActivityCancellationType) String() string
- func (ActivityCancellationType) Type() protoreflect.EnumType
- type AwaitWorkflowState
- func (*AwaitWorkflowState) Descriptor() ([]byte, []int)deprecated
- func (x *AwaitWorkflowState) GetKey() string
- func (x *AwaitWorkflowState) GetValue() string
- func (*AwaitWorkflowState) ProtoMessage()
- func (x *AwaitWorkflowState) ProtoReflect() protoreflect.Message
- func (x *AwaitWorkflowState) Reset()
- func (x *AwaitWorkflowState) String() string
- type AwaitableChoice
- func (*AwaitableChoice) Descriptor() ([]byte, []int)deprecated
- func (x *AwaitableChoice) GetAbandon() *emptypb.Empty
- func (x *AwaitableChoice) GetCancelAfterCompleted() *emptypb.Empty
- func (x *AwaitableChoice) GetCancelAfterStarted() *emptypb.Empty
- func (x *AwaitableChoice) GetCancelBeforeStarted() *emptypb.Empty
- func (m *AwaitableChoice) GetCondition() isAwaitableChoice_Condition
- func (x *AwaitableChoice) GetWaitFinish() *emptypb.Empty
- func (*AwaitableChoice) ProtoMessage()
- func (x *AwaitableChoice) ProtoReflect() protoreflect.Message
- func (x *AwaitableChoice) Reset()
- func (x *AwaitableChoice) String() string
- type AwaitableChoice_Abandon
- type AwaitableChoice_CancelAfterCompleted
- type AwaitableChoice_CancelAfterStarted
- type AwaitableChoice_CancelBeforeStarted
- type AwaitableChoice_WaitFinish
- type CancelWorkflowAction
- func (*CancelWorkflowAction) Descriptor() ([]byte, []int)deprecated
- func (x *CancelWorkflowAction) GetRunId() string
- func (x *CancelWorkflowAction) GetWorkflowId() string
- func (*CancelWorkflowAction) ProtoMessage()
- func (x *CancelWorkflowAction) ProtoReflect() protoreflect.Message
- func (x *CancelWorkflowAction) Reset()
- func (x *CancelWorkflowAction) String() string
- type ChildWorkflowCancellationType
- func (ChildWorkflowCancellationType) Descriptor() protoreflect.EnumDescriptor
- func (x ChildWorkflowCancellationType) Enum() *ChildWorkflowCancellationType
- func (ChildWorkflowCancellationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ChildWorkflowCancellationType) Number() protoreflect.EnumNumber
- func (x ChildWorkflowCancellationType) String() string
- func (ChildWorkflowCancellationType) Type() protoreflect.EnumType
- type ClientAction
- func (*ClientAction) Descriptor() ([]byte, []int)deprecated
- func (x *ClientAction) GetDoQuery() *DoQuery
- func (x *ClientAction) GetDoSignal() *DoSignal
- func (x *ClientAction) GetDoUpdate() *DoUpdate
- func (x *ClientAction) GetNestedActions() *ClientActionSet
- func (m *ClientAction) GetVariant() isClientAction_Variant
- func (*ClientAction) ProtoMessage()
- func (x *ClientAction) ProtoReflect() protoreflect.Message
- func (x *ClientAction) Reset()
- func (x *ClientAction) String() string
- type ClientActionSet
- func (*ClientActionSet) Descriptor() ([]byte, []int)deprecated
- func (x *ClientActionSet) GetActions() []*ClientAction
- func (x *ClientActionSet) GetConcurrent() bool
- func (x *ClientActionSet) GetWaitAtEnd() *durationpb.Duration
- func (x *ClientActionSet) GetWaitForCurrentRunToFinishAtEnd() bool
- func (*ClientActionSet) ProtoMessage()
- func (x *ClientActionSet) ProtoReflect() protoreflect.Message
- func (x *ClientActionSet) Reset()
- func (x *ClientActionSet) String() string
- type ClientAction_DoQuery
- type ClientAction_DoSignal
- type ClientAction_DoUpdate
- type ClientAction_NestedActions
- type ClientActionsExecutor
- type ClientSequence
- type ContinueAsNewAction
- func (*ContinueAsNewAction) Descriptor() ([]byte, []int)deprecated
- func (x *ContinueAsNewAction) GetArguments() []*v1.Payload
- func (x *ContinueAsNewAction) GetHeaders() map[string]*v1.Payload
- func (x *ContinueAsNewAction) GetMemo() map[string]*v1.Payload
- func (x *ContinueAsNewAction) GetRetryPolicy() *v1.RetryPolicy
- func (x *ContinueAsNewAction) GetSearchAttributes() map[string]*v1.Payload
- func (x *ContinueAsNewAction) GetTaskQueue() string
- func (x *ContinueAsNewAction) GetVersioningIntent() VersioningIntent
- func (x *ContinueAsNewAction) GetWorkflowRunTimeout() *durationpb.Duration
- func (x *ContinueAsNewAction) GetWorkflowTaskTimeout() *durationpb.Duration
- func (x *ContinueAsNewAction) GetWorkflowType() string
- func (*ContinueAsNewAction) ProtoMessage()
- func (x *ContinueAsNewAction) ProtoReflect() protoreflect.Message
- func (x *ContinueAsNewAction) Reset()
- func (x *ContinueAsNewAction) String() string
- type DoActionsUpdate
- func (*DoActionsUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *DoActionsUpdate) GetDoActions() *ActionSet
- func (x *DoActionsUpdate) GetRejectMe() *emptypb.Empty
- func (m *DoActionsUpdate) GetVariant() isDoActionsUpdate_Variant
- func (*DoActionsUpdate) ProtoMessage()
- func (x *DoActionsUpdate) ProtoReflect() protoreflect.Message
- func (x *DoActionsUpdate) Reset()
- func (x *DoActionsUpdate) String() string
- type DoActionsUpdate_DoActions
- type DoActionsUpdate_RejectMe
- type DoQuery
- func (*DoQuery) Descriptor() ([]byte, []int)deprecated
- func (x *DoQuery) GetCustom() *HandlerInvocation
- func (x *DoQuery) GetFailureExpected() bool
- func (x *DoQuery) GetReportState() *v1.Payloads
- func (m *DoQuery) GetVariant() isDoQuery_Variant
- func (*DoQuery) ProtoMessage()
- func (x *DoQuery) ProtoReflect() protoreflect.Message
- func (x *DoQuery) Reset()
- func (x *DoQuery) String() string
- type DoQuery_Custom
- type DoQuery_ReportState
- type DoSignal
- func (*DoSignal) Descriptor() ([]byte, []int)deprecated
- func (x *DoSignal) GetCustom() *HandlerInvocation
- func (x *DoSignal) GetDoSignalActions() *DoSignal_DoSignalActions
- func (m *DoSignal) GetVariant() isDoSignal_Variant
- func (x *DoSignal) GetWithStart() bool
- func (*DoSignal) ProtoMessage()
- func (x *DoSignal) ProtoReflect() protoreflect.Message
- func (x *DoSignal) Reset()
- func (x *DoSignal) String() string
- type DoSignal_Custom
- type DoSignal_DoSignalActions
- func (*DoSignal_DoSignalActions) Descriptor() ([]byte, []int)deprecated
- func (x *DoSignal_DoSignalActions) GetDoActions() *ActionSet
- func (x *DoSignal_DoSignalActions) GetDoActionsInMain() *ActionSet
- func (m *DoSignal_DoSignalActions) GetVariant() isDoSignal_DoSignalActions_Variant
- func (*DoSignal_DoSignalActions) ProtoMessage()
- func (x *DoSignal_DoSignalActions) ProtoReflect() protoreflect.Message
- func (x *DoSignal_DoSignalActions) Reset()
- func (x *DoSignal_DoSignalActions) String() string
- type DoSignal_DoSignalActions_
- type DoSignal_DoSignalActions_DoActions
- type DoSignal_DoSignalActions_DoActionsInMain
- type DoUpdate
- func (*DoUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *DoUpdate) GetCustom() *HandlerInvocation
- func (x *DoUpdate) GetDoActions() *DoActionsUpdate
- func (x *DoUpdate) GetFailureExpected() bool
- func (m *DoUpdate) GetVariant() isDoUpdate_Variant
- func (x *DoUpdate) GetWithStart() bool
- func (*DoUpdate) ProtoMessage()
- func (x *DoUpdate) ProtoReflect() protoreflect.Message
- func (x *DoUpdate) Reset()
- func (x *DoUpdate) String() string
- type DoUpdate_Custom
- type DoUpdate_DoActions
- type ExecuteActivityAction
- func (*ExecuteActivityAction) Descriptor() ([]byte, []int)deprecated
- func (m *ExecuteActivityAction) GetActivityType() isExecuteActivityAction_ActivityType
- func (x *ExecuteActivityAction) GetAwaitableChoice() *AwaitableChoice
- func (x *ExecuteActivityAction) GetDelay() *durationpb.Duration
- func (x *ExecuteActivityAction) GetGeneric() *ExecuteActivityAction_GenericActivity
- func (x *ExecuteActivityAction) GetHeaders() map[string]*v1.Payload
- func (x *ExecuteActivityAction) GetHeartbeatTimeout() *durationpb.Duration
- func (x *ExecuteActivityAction) GetIsLocal() *emptypb.Empty
- func (m *ExecuteActivityAction) GetLocality() isExecuteActivityAction_Locality
- func (x *ExecuteActivityAction) GetNoop() *emptypb.Empty
- func (x *ExecuteActivityAction) GetRemote() *RemoteActivityOptions
- func (x *ExecuteActivityAction) GetResources() *ExecuteActivityAction_ResourcesActivity
- func (x *ExecuteActivityAction) GetRetryPolicy() *v1.RetryPolicy
- func (x *ExecuteActivityAction) GetScheduleToCloseTimeout() *durationpb.Duration
- func (x *ExecuteActivityAction) GetScheduleToStartTimeout() *durationpb.Duration
- func (x *ExecuteActivityAction) GetStartToCloseTimeout() *durationpb.Duration
- func (x *ExecuteActivityAction) GetTaskQueue() string
- func (*ExecuteActivityAction) ProtoMessage()
- func (x *ExecuteActivityAction) ProtoReflect() protoreflect.Message
- func (x *ExecuteActivityAction) Reset()
- func (x *ExecuteActivityAction) String() string
- type ExecuteActivityAction_Delay
- type ExecuteActivityAction_Generic
- type ExecuteActivityAction_GenericActivity
- func (*ExecuteActivityAction_GenericActivity) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteActivityAction_GenericActivity) GetArguments() []*v1.Payload
- func (x *ExecuteActivityAction_GenericActivity) GetType() string
- func (*ExecuteActivityAction_GenericActivity) ProtoMessage()
- func (x *ExecuteActivityAction_GenericActivity) ProtoReflect() protoreflect.Message
- func (x *ExecuteActivityAction_GenericActivity) Reset()
- func (x *ExecuteActivityAction_GenericActivity) String() string
- type ExecuteActivityAction_IsLocal
- type ExecuteActivityAction_Noop
- type ExecuteActivityAction_Remote
- type ExecuteActivityAction_Resources
- type ExecuteActivityAction_ResourcesActivity
- func (*ExecuteActivityAction_ResourcesActivity) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteActivityAction_ResourcesActivity) GetBytesToAllocate() uint64
- func (x *ExecuteActivityAction_ResourcesActivity) GetCpuYieldEveryNIterations() uint32
- func (x *ExecuteActivityAction_ResourcesActivity) GetCpuYieldForMs() uint32
- func (x *ExecuteActivityAction_ResourcesActivity) GetRunFor() *durationpb.Duration
- func (*ExecuteActivityAction_ResourcesActivity) ProtoMessage()
- func (x *ExecuteActivityAction_ResourcesActivity) ProtoReflect() protoreflect.Message
- func (x *ExecuteActivityAction_ResourcesActivity) Reset()
- func (x *ExecuteActivityAction_ResourcesActivity) String() string
- type ExecuteChildWorkflowAction
- func (*ExecuteChildWorkflowAction) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteChildWorkflowAction) GetAwaitableChoice() *AwaitableChoice
- func (x *ExecuteChildWorkflowAction) GetCancellationType() ChildWorkflowCancellationType
- func (x *ExecuteChildWorkflowAction) GetCronSchedule() string
- func (x *ExecuteChildWorkflowAction) GetHeaders() map[string]*v1.Payload
- func (x *ExecuteChildWorkflowAction) GetInput() []*v1.Payload
- func (x *ExecuteChildWorkflowAction) GetMemo() map[string]*v1.Payload
- func (x *ExecuteChildWorkflowAction) GetNamespace() string
- func (x *ExecuteChildWorkflowAction) GetParentClosePolicy() ParentClosePolicy
- func (x *ExecuteChildWorkflowAction) GetRetryPolicy() *v1.RetryPolicy
- func (x *ExecuteChildWorkflowAction) GetSearchAttributes() map[string]*v1.Payload
- func (x *ExecuteChildWorkflowAction) GetTaskQueue() string
- func (x *ExecuteChildWorkflowAction) GetVersioningIntent() VersioningIntent
- func (x *ExecuteChildWorkflowAction) GetWorkflowExecutionTimeout() *durationpb.Duration
- func (x *ExecuteChildWorkflowAction) GetWorkflowId() string
- func (x *ExecuteChildWorkflowAction) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy
- func (x *ExecuteChildWorkflowAction) GetWorkflowRunTimeout() *durationpb.Duration
- func (x *ExecuteChildWorkflowAction) GetWorkflowTaskTimeout() *durationpb.Duration
- func (x *ExecuteChildWorkflowAction) GetWorkflowType() string
- func (*ExecuteChildWorkflowAction) ProtoMessage()
- func (x *ExecuteChildWorkflowAction) ProtoReflect() protoreflect.Message
- func (x *ExecuteChildWorkflowAction) Reset()
- func (x *ExecuteChildWorkflowAction) String() string
- type HandlerInvocation
- func (*HandlerInvocation) Descriptor() ([]byte, []int)deprecated
- func (x *HandlerInvocation) GetArgs() []*v1.Payload
- func (x *HandlerInvocation) GetName() string
- func (*HandlerInvocation) ProtoMessage()
- func (x *HandlerInvocation) ProtoReflect() protoreflect.Message
- func (x *HandlerInvocation) Reset()
- func (x *HandlerInvocation) String() string
- type ParentClosePolicy
- func (ParentClosePolicy) Descriptor() protoreflect.EnumDescriptor
- func (x ParentClosePolicy) Enum() *ParentClosePolicy
- func (ParentClosePolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x ParentClosePolicy) Number() protoreflect.EnumNumber
- func (x ParentClosePolicy) String() string
- func (ParentClosePolicy) Type() protoreflect.EnumType
- type RemoteActivityOptions
- func (*RemoteActivityOptions) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteActivityOptions) GetCancellationType() ActivityCancellationType
- func (x *RemoteActivityOptions) GetDoNotEagerlyExecute() bool
- func (x *RemoteActivityOptions) GetVersioningIntent() VersioningIntent
- func (*RemoteActivityOptions) ProtoMessage()
- func (x *RemoteActivityOptions) ProtoReflect() protoreflect.Message
- func (x *RemoteActivityOptions) Reset()
- func (x *RemoteActivityOptions) String() string
- type ReturnErrorAction
- func (*ReturnErrorAction) Descriptor() ([]byte, []int)deprecated
- func (x *ReturnErrorAction) GetFailure() *v12.Failure
- func (*ReturnErrorAction) ProtoMessage()
- func (x *ReturnErrorAction) ProtoReflect() protoreflect.Message
- func (x *ReturnErrorAction) Reset()
- func (x *ReturnErrorAction) String() string
- type ReturnResultAction
- func (*ReturnResultAction) Descriptor() ([]byte, []int)deprecated
- func (x *ReturnResultAction) GetReturnThis() *v1.Payload
- func (*ReturnResultAction) ProtoMessage()
- func (x *ReturnResultAction) ProtoReflect() protoreflect.Message
- func (x *ReturnResultAction) Reset()
- func (x *ReturnResultAction) String() string
- type SendSignalAction
- func (*SendSignalAction) Descriptor() ([]byte, []int)deprecated
- func (x *SendSignalAction) GetArgs() []*v1.Payload
- func (x *SendSignalAction) GetAwaitableChoice() *AwaitableChoice
- func (x *SendSignalAction) GetHeaders() map[string]*v1.Payload
- func (x *SendSignalAction) GetRunId() string
- func (x *SendSignalAction) GetSignalName() string
- func (x *SendSignalAction) GetWorkflowId() string
- func (*SendSignalAction) ProtoMessage()
- func (x *SendSignalAction) ProtoReflect() protoreflect.Message
- func (x *SendSignalAction) Reset()
- func (x *SendSignalAction) String() string
- type SetPatchMarkerAction
- func (*SetPatchMarkerAction) Descriptor() ([]byte, []int)deprecated
- func (x *SetPatchMarkerAction) GetDeprecated() bool
- func (x *SetPatchMarkerAction) GetInnerAction() *Action
- func (x *SetPatchMarkerAction) GetPatchId() string
- func (*SetPatchMarkerAction) ProtoMessage()
- func (x *SetPatchMarkerAction) ProtoReflect() protoreflect.Message
- func (x *SetPatchMarkerAction) Reset()
- func (x *SetPatchMarkerAction) String() string
- type TestInput
- func (*TestInput) Descriptor() ([]byte, []int)deprecated
- func (x *TestInput) GetClientSequence() *ClientSequence
- func (x *TestInput) GetWithStartAction() *WithStartClientAction
- func (x *TestInput) GetWorkflowInput() *WorkflowInput
- func (*TestInput) ProtoMessage()
- func (x *TestInput) ProtoReflect() protoreflect.Message
- func (x *TestInput) Reset()
- func (x *TestInput) String() string
- type TimerAction
- func (*TimerAction) Descriptor() ([]byte, []int)deprecated
- func (x *TimerAction) GetAwaitableChoice() *AwaitableChoice
- func (x *TimerAction) GetMilliseconds() uint64
- func (*TimerAction) ProtoMessage()
- func (x *TimerAction) ProtoReflect() protoreflect.Message
- func (x *TimerAction) Reset()
- func (x *TimerAction) String() string
- type UpsertMemoAction
- type UpsertSearchAttributesAction
- func (*UpsertSearchAttributesAction) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertSearchAttributesAction) GetSearchAttributes() map[string]*v1.Payload
- func (*UpsertSearchAttributesAction) ProtoMessage()
- func (x *UpsertSearchAttributesAction) ProtoReflect() protoreflect.Message
- func (x *UpsertSearchAttributesAction) Reset()
- func (x *UpsertSearchAttributesAction) String() string
- type VersioningIntent
- func (VersioningIntent) Descriptor() protoreflect.EnumDescriptor
- func (x VersioningIntent) Enum() *VersioningIntent
- func (VersioningIntent) EnumDescriptor() ([]byte, []int)deprecated
- func (x VersioningIntent) Number() protoreflect.EnumNumber
- func (x VersioningIntent) String() string
- func (VersioningIntent) Type() protoreflect.EnumType
- type WithStartClientAction
- func (*WithStartClientAction) Descriptor() ([]byte, []int)deprecated
- func (x *WithStartClientAction) GetDoSignal() *DoSignal
- func (x *WithStartClientAction) GetDoUpdate() *DoUpdate
- func (m *WithStartClientAction) GetVariant() isWithStartClientAction_Variant
- func (*WithStartClientAction) ProtoMessage()
- func (x *WithStartClientAction) ProtoReflect() protoreflect.Message
- func (x *WithStartClientAction) Reset()
- func (x *WithStartClientAction) String() string
- type WithStartClientAction_DoSignal
- type WithStartClientAction_DoUpdate
- type WorkflowInput
- type WorkflowState
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
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.
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) 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 (*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
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) GetActions ¶
func (*ActionSet) GetConcurrent ¶
func (*ActionSet) ProtoMessage ¶
func (*ActionSet) ProtoMessage()
func (*ActionSet) ProtoReflect ¶
func (x *ActionSet) ProtoReflect() protoreflect.Message
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_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 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"` // If set, the client should wait for the current run to end before proceeding (IE: the workflow // is going to continue-as-new). WaitForCurrentRunToFinishAtEnd bool `` /* 164-byte string literal not displayed */ // 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) GetWaitForCurrentRunToFinishAtEnd ¶
func (x *ClientActionSet) GetWaitForCurrentRunToFinishAtEnd() bool
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 WorkflowOptions client.StartWorkflowOptions WorkflowType string WorkflowInput *WorkflowInput Handle client.WorkflowRun // contains filtered or unexported fields }
func (*ClientActionsExecutor) ExecuteClientSequence ¶
func (e *ClientActionsExecutor) ExecuteClientSequence(ctx context.Context, clientSeq *ClientSequence) error
func (*ClientActionsExecutor) Start ¶
func (e *ClientActionsExecutor) Start( ctx context.Context, withStartAction *WithStartClientAction, ) 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 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) GetCustom ¶
func (x *DoQuery) GetCustom() *HandlerInvocation
func (*DoQuery) GetFailureExpected ¶
func (*DoQuery) GetReportState ¶
func (*DoQuery) GetVariant ¶
func (m *DoQuery) GetVariant() isDoQuery_Variant
func (*DoQuery) ProtoMessage ¶
func (*DoQuery) ProtoMessage()
func (*DoQuery) ProtoReflect ¶
func (x *DoQuery) ProtoReflect() protoreflect.Message
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"` // If set, the Signal is a Signal-with-Start. WithStart bool `protobuf:"varint,3,opt,name=with_start,json=withStart,proto3" json:"with_start,omitempty"` // contains filtered or unexported fields }
func (*DoSignal) Descriptor
deprecated
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) GetWithStart ¶
func (*DoSignal) ProtoMessage ¶
func (*DoSignal) ProtoMessage()
func (*DoSignal) ProtoReflect ¶
func (x *DoSignal) ProtoReflect() protoreflect.Message
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 Update is an Update-with-Start. WithStart bool `protobuf:"varint,3,opt,name=with_start,json=withStart,proto3" json:"with_start,omitempty"` // 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) GetCustom ¶
func (x *DoUpdate) GetCustom() *HandlerInvocation
func (*DoUpdate) GetDoActions ¶
func (x *DoUpdate) GetDoActions() *DoActionsUpdate
func (*DoUpdate) GetFailureExpected ¶
func (*DoUpdate) GetVariant ¶
func (m *DoUpdate) GetVariant() isDoUpdate_Variant
func (*DoUpdate) GetWithStart ¶
func (*DoUpdate) ProtoMessage ¶
func (*DoUpdate) ProtoMessage()
func (*DoUpdate) ProtoReflect ¶
func (x *DoUpdate) ProtoReflect() protoreflect.Message
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 // *ExecuteActivityAction_Resources 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) GetResources ¶
func (x *ExecuteActivityAction) GetResources() *ExecuteActivityAction_ResourcesActivity
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_Remote ¶
type ExecuteActivityAction_Remote struct {
Remote *RemoteActivityOptions `protobuf:"bytes,12,opt,name=remote,proto3,oneof"`
}
type ExecuteActivityAction_Resources ¶
type ExecuteActivityAction_Resources struct { // There must be an activity named `resources` which accepts the ResourcesActivity message as input Resources *ExecuteActivityAction_ResourcesActivity `protobuf:"bytes,14,opt,name=resources,proto3,oneof"` }
type ExecuteActivityAction_ResourcesActivity ¶
type ExecuteActivityAction_ResourcesActivity struct { RunFor *durationpb.Duration `protobuf:"bytes,1,opt,name=run_for,json=runFor,proto3" json:"run_for,omitempty"` BytesToAllocate uint64 `protobuf:"varint,2,opt,name=bytes_to_allocate,json=bytesToAllocate,proto3" json:"bytes_to_allocate,omitempty"` CpuYieldEveryNIterations uint32 `` /* 140-byte string literal not displayed */ CpuYieldForMs uint32 `protobuf:"varint,4,opt,name=cpu_yield_for_ms,json=cpuYieldForMs,proto3" json:"cpu_yield_for_ms,omitempty"` // contains filtered or unexported fields }
func (*ExecuteActivityAction_ResourcesActivity) Descriptor
deprecated
func (*ExecuteActivityAction_ResourcesActivity) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteActivityAction_ResourcesActivity.ProtoReflect.Descriptor instead.
func (*ExecuteActivityAction_ResourcesActivity) GetBytesToAllocate ¶
func (x *ExecuteActivityAction_ResourcesActivity) GetBytesToAllocate() uint64
func (*ExecuteActivityAction_ResourcesActivity) GetCpuYieldEveryNIterations ¶
func (x *ExecuteActivityAction_ResourcesActivity) GetCpuYieldEveryNIterations() uint32
func (*ExecuteActivityAction_ResourcesActivity) GetCpuYieldForMs ¶
func (x *ExecuteActivityAction_ResourcesActivity) GetCpuYieldForMs() uint32
func (*ExecuteActivityAction_ResourcesActivity) GetRunFor ¶
func (x *ExecuteActivityAction_ResourcesActivity) GetRunFor() *durationpb.Duration
func (*ExecuteActivityAction_ResourcesActivity) ProtoMessage ¶
func (*ExecuteActivityAction_ResourcesActivity) ProtoMessage()
func (*ExecuteActivityAction_ResourcesActivity) ProtoReflect ¶
func (x *ExecuteActivityAction_ResourcesActivity) ProtoReflect() protoreflect.Message
func (*ExecuteActivityAction_ResourcesActivity) Reset ¶
func (x *ExecuteActivityAction_ResourcesActivity) Reset()
func (*ExecuteActivityAction_ResourcesActivity) String ¶
func (x *ExecuteActivityAction_ResourcesActivity) String() string
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"` WithStartAction *WithStartClientAction `protobuf:"bytes,3,opt,name=with_start_action,json=withStartAction,proto3" json:"with_start_action,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) GetClientSequence ¶
func (x *TestInput) GetClientSequence() *ClientSequence
func (*TestInput) GetWithStartAction ¶
func (x *TestInput) GetWithStartAction() *WithStartClientAction
func (*TestInput) GetWorkflowInput ¶
func (x *TestInput) GetWorkflowInput() *WorkflowInput
func (*TestInput) ProtoMessage ¶
func (*TestInput) ProtoMessage()
func (*TestInput) ProtoReflect ¶
func (x *TestInput) ProtoReflect() protoreflect.Message
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 WithStartClientAction ¶
type WithStartClientAction struct { // Types that are assignable to Variant: // // *WithStartClientAction_DoSignal // *WithStartClientAction_DoUpdate Variant isWithStartClientAction_Variant `protobuf_oneof:"variant"` // contains filtered or unexported fields }
func (*WithStartClientAction) Descriptor
deprecated
func (*WithStartClientAction) Descriptor() ([]byte, []int)
Deprecated: Use WithStartClientAction.ProtoReflect.Descriptor instead.
func (*WithStartClientAction) GetDoSignal ¶
func (x *WithStartClientAction) GetDoSignal() *DoSignal
func (*WithStartClientAction) GetDoUpdate ¶
func (x *WithStartClientAction) GetDoUpdate() *DoUpdate
func (*WithStartClientAction) GetVariant ¶
func (m *WithStartClientAction) GetVariant() isWithStartClientAction_Variant
func (*WithStartClientAction) ProtoMessage ¶
func (*WithStartClientAction) ProtoMessage()
func (*WithStartClientAction) ProtoReflect ¶
func (x *WithStartClientAction) ProtoReflect() protoreflect.Message
func (*WithStartClientAction) Reset ¶
func (x *WithStartClientAction) Reset()
func (*WithStartClientAction) String ¶
func (x *WithStartClientAction) String() string
type WithStartClientAction_DoSignal ¶
type WithStartClientAction_DoSignal struct {
DoSignal *DoSignal `protobuf:"bytes,1,opt,name=do_signal,json=doSignal,proto3,oneof"`
}
type WithStartClientAction_DoUpdate ¶
type WithStartClientAction_DoUpdate struct {
DoUpdate *DoUpdate `protobuf:"bytes,2,opt,name=do_update,json=doUpdate,proto3,oneof"`
}
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