Documentation ¶
Index ¶
- Variables
- type AcceptWorkflowUpdateCommandAttributes
- func (*AcceptWorkflowUpdateCommandAttributes) Descriptor() ([]byte, []int)
- func (this *AcceptWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
- func (m *AcceptWorkflowUpdateCommandAttributes) GetInput() *v14.Input
- func (m *AcceptWorkflowUpdateCommandAttributes) GetMeta() *v14.Meta
- func (this *AcceptWorkflowUpdateCommandAttributes) GoString() string
- func (m *AcceptWorkflowUpdateCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *AcceptWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *AcceptWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AcceptWorkflowUpdateCommandAttributes) ProtoMessage()
- func (m *AcceptWorkflowUpdateCommandAttributes) Reset()
- func (m *AcceptWorkflowUpdateCommandAttributes) Size() (n int)
- func (this *AcceptWorkflowUpdateCommandAttributes) String() string
- func (m *AcceptWorkflowUpdateCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *AcceptWorkflowUpdateCommandAttributes) XXX_DiscardUnknown()
- func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Merge(src proto.Message)
- func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Size() int
- func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Unmarshal(b []byte) error
- type CancelTimerCommandAttributes
- func (*CancelTimerCommandAttributes) Descriptor() ([]byte, []int)
- func (this *CancelTimerCommandAttributes) Equal(that interface{}) bool
- func (m *CancelTimerCommandAttributes) GetTimerId() string
- func (this *CancelTimerCommandAttributes) GoString() string
- func (m *CancelTimerCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *CancelTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelTimerCommandAttributes) ProtoMessage()
- func (m *CancelTimerCommandAttributes) Reset()
- func (m *CancelTimerCommandAttributes) Size() (n int)
- func (this *CancelTimerCommandAttributes) String() string
- func (m *CancelTimerCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *CancelTimerCommandAttributes) XXX_DiscardUnknown()
- func (m *CancelTimerCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelTimerCommandAttributes) XXX_Merge(src proto.Message)
- func (m *CancelTimerCommandAttributes) XXX_Size() int
- func (m *CancelTimerCommandAttributes) XXX_Unmarshal(b []byte) error
- type CancelWorkflowExecutionCommandAttributes
- func (*CancelWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
- func (this *CancelWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (m *CancelWorkflowExecutionCommandAttributes) GetDetails() *v1.Payloads
- func (this *CancelWorkflowExecutionCommandAttributes) GoString() string
- func (m *CancelWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *CancelWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *CancelWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CancelWorkflowExecutionCommandAttributes) ProtoMessage()
- func (m *CancelWorkflowExecutionCommandAttributes) Reset()
- func (m *CancelWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *CancelWorkflowExecutionCommandAttributes) String() string
- func (m *CancelWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *CancelWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
- func (m *CancelWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CancelWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
- func (m *CancelWorkflowExecutionCommandAttributes) XXX_Size() int
- func (m *CancelWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
- type Command
- func (*Command) Descriptor() ([]byte, []int)
- func (this *Command) Equal(that interface{}) bool
- func (m *Command) GetAcceptWorkflowUpdateCommandAttributes() *AcceptWorkflowUpdateCommandAttributes
- func (m *Command) GetAttributes() isCommand_Attributes
- func (m *Command) GetCancelTimerCommandAttributes() *CancelTimerCommandAttributes
- func (m *Command) GetCancelWorkflowExecutionCommandAttributes() *CancelWorkflowExecutionCommandAttributes
- func (m *Command) GetCommandType() v13.CommandType
- func (m *Command) GetCompleteWorkflowExecutionCommandAttributes() *CompleteWorkflowExecutionCommandAttributes
- func (m *Command) GetCompleteWorkflowUpdateCommandAttributes() *CompleteWorkflowUpdateCommandAttributes
- func (m *Command) GetContinueAsNewWorkflowExecutionCommandAttributes() *ContinueAsNewWorkflowExecutionCommandAttributes
- func (m *Command) GetFailWorkflowExecutionCommandAttributes() *FailWorkflowExecutionCommandAttributes
- func (m *Command) GetModifyWorkflowPropertiesCommandAttributes() *ModifyWorkflowPropertiesCommandAttributes
- func (m *Command) GetRecordMarkerCommandAttributes() *RecordMarkerCommandAttributes
- func (m *Command) GetRejectWorkflowUpdateCommandAttributes() *RejectWorkflowUpdateCommandAttributes
- func (m *Command) GetRequestCancelActivityTaskCommandAttributes() *RequestCancelActivityTaskCommandAttributes
- func (m *Command) GetRequestCancelExternalWorkflowExecutionCommandAttributes() *RequestCancelExternalWorkflowExecutionCommandAttributes
- func (m *Command) GetScheduleActivityTaskCommandAttributes() *ScheduleActivityTaskCommandAttributes
- func (m *Command) GetSignalExternalWorkflowExecutionCommandAttributes() *SignalExternalWorkflowExecutionCommandAttributes
- func (m *Command) GetStartChildWorkflowExecutionCommandAttributes() *StartChildWorkflowExecutionCommandAttributes
- func (m *Command) GetStartTimerCommandAttributes() *StartTimerCommandAttributes
- func (m *Command) GetUpsertWorkflowSearchAttributesCommandAttributes() *UpsertWorkflowSearchAttributesCommandAttributes
- func (this *Command) GoString() string
- func (m *Command) Marshal() (dAtA []byte, err error)
- func (m *Command) MarshalTo(dAtA []byte) (int, error)
- func (m *Command) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Command) ProtoMessage()
- func (m *Command) Reset()
- func (m *Command) Size() (n int)
- func (this *Command) String() string
- func (m *Command) Unmarshal(dAtA []byte) error
- func (m *Command) XXX_DiscardUnknown()
- func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Command) XXX_Merge(src proto.Message)
- func (*Command) XXX_OneofWrappers() []interface{}
- func (m *Command) XXX_Size() int
- func (m *Command) XXX_Unmarshal(b []byte) error
- type Command_AcceptWorkflowUpdateCommandAttributes
- func (this *Command_AcceptWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
- func (this *Command_AcceptWorkflowUpdateCommandAttributes) GoString() string
- func (m *Command_AcceptWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_AcceptWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_AcceptWorkflowUpdateCommandAttributes) Size() (n int)
- func (this *Command_AcceptWorkflowUpdateCommandAttributes) String() string
- type Command_CancelTimerCommandAttributes
- func (this *Command_CancelTimerCommandAttributes) Equal(that interface{}) bool
- func (this *Command_CancelTimerCommandAttributes) GoString() string
- func (m *Command_CancelTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_CancelTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_CancelTimerCommandAttributes) Size() (n int)
- func (this *Command_CancelTimerCommandAttributes) String() string
- type Command_CancelWorkflowExecutionCommandAttributes
- func (this *Command_CancelWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (this *Command_CancelWorkflowExecutionCommandAttributes) GoString() string
- func (m *Command_CancelWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_CancelWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_CancelWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *Command_CancelWorkflowExecutionCommandAttributes) String() string
- type Command_CompleteWorkflowExecutionCommandAttributes
- func (this *Command_CompleteWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (this *Command_CompleteWorkflowExecutionCommandAttributes) GoString() string
- func (m *Command_CompleteWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_CompleteWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_CompleteWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *Command_CompleteWorkflowExecutionCommandAttributes) String() string
- type Command_CompleteWorkflowUpdateCommandAttributes
- func (this *Command_CompleteWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
- func (this *Command_CompleteWorkflowUpdateCommandAttributes) GoString() string
- func (m *Command_CompleteWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_CompleteWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_CompleteWorkflowUpdateCommandAttributes) Size() (n int)
- func (this *Command_CompleteWorkflowUpdateCommandAttributes) String() string
- type Command_ContinueAsNewWorkflowExecutionCommandAttributes
- func (this *Command_ContinueAsNewWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (this *Command_ContinueAsNewWorkflowExecutionCommandAttributes) GoString() string
- func (m *Command_ContinueAsNewWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_ContinueAsNewWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_ContinueAsNewWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *Command_ContinueAsNewWorkflowExecutionCommandAttributes) String() string
- type Command_FailWorkflowExecutionCommandAttributes
- func (this *Command_FailWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (this *Command_FailWorkflowExecutionCommandAttributes) GoString() string
- func (m *Command_FailWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_FailWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_FailWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *Command_FailWorkflowExecutionCommandAttributes) String() string
- type Command_ModifyWorkflowPropertiesCommandAttributes
- func (this *Command_ModifyWorkflowPropertiesCommandAttributes) Equal(that interface{}) bool
- func (this *Command_ModifyWorkflowPropertiesCommandAttributes) GoString() string
- func (m *Command_ModifyWorkflowPropertiesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_ModifyWorkflowPropertiesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_ModifyWorkflowPropertiesCommandAttributes) Size() (n int)
- func (this *Command_ModifyWorkflowPropertiesCommandAttributes) String() string
- type Command_RecordMarkerCommandAttributes
- func (this *Command_RecordMarkerCommandAttributes) Equal(that interface{}) bool
- func (this *Command_RecordMarkerCommandAttributes) GoString() string
- func (m *Command_RecordMarkerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_RecordMarkerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_RecordMarkerCommandAttributes) Size() (n int)
- func (this *Command_RecordMarkerCommandAttributes) String() string
- type Command_RejectWorkflowUpdateCommandAttributes
- func (this *Command_RejectWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
- func (this *Command_RejectWorkflowUpdateCommandAttributes) GoString() string
- func (m *Command_RejectWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_RejectWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_RejectWorkflowUpdateCommandAttributes) Size() (n int)
- func (this *Command_RejectWorkflowUpdateCommandAttributes) String() string
- type Command_RequestCancelActivityTaskCommandAttributes
- func (this *Command_RequestCancelActivityTaskCommandAttributes) Equal(that interface{}) bool
- func (this *Command_RequestCancelActivityTaskCommandAttributes) GoString() string
- func (m *Command_RequestCancelActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_RequestCancelActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_RequestCancelActivityTaskCommandAttributes) Size() (n int)
- func (this *Command_RequestCancelActivityTaskCommandAttributes) String() string
- type Command_RequestCancelExternalWorkflowExecutionCommandAttributes
- func (this *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (this *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) GoString() string
- func (m *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) String() string
- type Command_ScheduleActivityTaskCommandAttributes
- func (this *Command_ScheduleActivityTaskCommandAttributes) Equal(that interface{}) bool
- func (this *Command_ScheduleActivityTaskCommandAttributes) GoString() string
- func (m *Command_ScheduleActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_ScheduleActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_ScheduleActivityTaskCommandAttributes) Size() (n int)
- func (this *Command_ScheduleActivityTaskCommandAttributes) String() string
- type Command_SignalExternalWorkflowExecutionCommandAttributes
- func (this *Command_SignalExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (this *Command_SignalExternalWorkflowExecutionCommandAttributes) GoString() string
- func (m *Command_SignalExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_SignalExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_SignalExternalWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *Command_SignalExternalWorkflowExecutionCommandAttributes) String() string
- type Command_StartChildWorkflowExecutionCommandAttributes
- func (this *Command_StartChildWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (this *Command_StartChildWorkflowExecutionCommandAttributes) GoString() string
- func (m *Command_StartChildWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_StartChildWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_StartChildWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *Command_StartChildWorkflowExecutionCommandAttributes) String() string
- type Command_StartTimerCommandAttributes
- func (this *Command_StartTimerCommandAttributes) Equal(that interface{}) bool
- func (this *Command_StartTimerCommandAttributes) GoString() string
- func (m *Command_StartTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_StartTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_StartTimerCommandAttributes) Size() (n int)
- func (this *Command_StartTimerCommandAttributes) String() string
- type Command_UpsertWorkflowSearchAttributesCommandAttributes
- func (this *Command_UpsertWorkflowSearchAttributesCommandAttributes) Equal(that interface{}) bool
- func (this *Command_UpsertWorkflowSearchAttributesCommandAttributes) GoString() string
- func (m *Command_UpsertWorkflowSearchAttributesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *Command_UpsertWorkflowSearchAttributesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (m *Command_UpsertWorkflowSearchAttributesCommandAttributes) Size() (n int)
- func (this *Command_UpsertWorkflowSearchAttributesCommandAttributes) String() string
- type CompleteWorkflowExecutionCommandAttributes
- func (*CompleteWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
- func (this *CompleteWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (m *CompleteWorkflowExecutionCommandAttributes) GetResult() *v1.Payloads
- func (this *CompleteWorkflowExecutionCommandAttributes) GoString() string
- func (m *CompleteWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *CompleteWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *CompleteWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CompleteWorkflowExecutionCommandAttributes) ProtoMessage()
- func (m *CompleteWorkflowExecutionCommandAttributes) Reset()
- func (m *CompleteWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *CompleteWorkflowExecutionCommandAttributes) String() string
- func (m *CompleteWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *CompleteWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
- func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
- func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Size() int
- func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
- type CompleteWorkflowUpdateCommandAttributes
- func (*CompleteWorkflowUpdateCommandAttributes) Descriptor() ([]byte, []int)
- func (this *CompleteWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
- func (m *CompleteWorkflowUpdateCommandAttributes) GetMeta() *v14.Meta
- func (m *CompleteWorkflowUpdateCommandAttributes) GetOutput() *v14.Output
- func (this *CompleteWorkflowUpdateCommandAttributes) GoString() string
- func (m *CompleteWorkflowUpdateCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *CompleteWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *CompleteWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CompleteWorkflowUpdateCommandAttributes) ProtoMessage()
- func (m *CompleteWorkflowUpdateCommandAttributes) Reset()
- func (m *CompleteWorkflowUpdateCommandAttributes) Size() (n int)
- func (this *CompleteWorkflowUpdateCommandAttributes) String() string
- func (m *CompleteWorkflowUpdateCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *CompleteWorkflowUpdateCommandAttributes) XXX_DiscardUnknown()
- func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Merge(src proto.Message)
- func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Size() int
- func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Unmarshal(b []byte) error
- type ContinueAsNewWorkflowExecutionCommandAttributes
- func (*ContinueAsNewWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
- func (this *ContinueAsNewWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetBackoffStartInterval() *time.Duration
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetCronSchedule() string
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetFailure() *v12.Failure
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetHeader() *v1.Header
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetInitiator() v13.ContinueAsNewInitiator
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetLastCompletionResult() *v1.Payloads
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetMemo() *v1.Memo
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetRetryPolicy() *v1.RetryPolicy
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetSearchAttributes() *v1.SearchAttributes
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetTaskQueue() *v11.TaskQueue
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout() *time.Duration
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout() *time.Duration
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowType() *v1.WorkflowType
- func (this *ContinueAsNewWorkflowExecutionCommandAttributes) GoString() string
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoMessage()
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Reset()
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *ContinueAsNewWorkflowExecutionCommandAttributes) String() string
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Size() int
- func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
- type FailWorkflowExecutionCommandAttributes
- func (*FailWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
- func (this *FailWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (m *FailWorkflowExecutionCommandAttributes) GetFailure() *v12.Failure
- func (this *FailWorkflowExecutionCommandAttributes) GoString() string
- func (m *FailWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *FailWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *FailWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*FailWorkflowExecutionCommandAttributes) ProtoMessage()
- func (m *FailWorkflowExecutionCommandAttributes) Reset()
- func (m *FailWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *FailWorkflowExecutionCommandAttributes) String() string
- func (m *FailWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *FailWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
- func (m *FailWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FailWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
- func (m *FailWorkflowExecutionCommandAttributes) XXX_Size() int
- func (m *FailWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
- type ModifyWorkflowPropertiesCommandAttributes
- func (*ModifyWorkflowPropertiesCommandAttributes) Descriptor() ([]byte, []int)
- func (this *ModifyWorkflowPropertiesCommandAttributes) Equal(that interface{}) bool
- func (m *ModifyWorkflowPropertiesCommandAttributes) GetUpsertedMemo() *v1.Memo
- func (this *ModifyWorkflowPropertiesCommandAttributes) GoString() string
- func (m *ModifyWorkflowPropertiesCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *ModifyWorkflowPropertiesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *ModifyWorkflowPropertiesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ModifyWorkflowPropertiesCommandAttributes) ProtoMessage()
- func (m *ModifyWorkflowPropertiesCommandAttributes) Reset()
- func (m *ModifyWorkflowPropertiesCommandAttributes) Size() (n int)
- func (this *ModifyWorkflowPropertiesCommandAttributes) String() string
- func (m *ModifyWorkflowPropertiesCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_DiscardUnknown()
- func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Merge(src proto.Message)
- func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Size() int
- func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Unmarshal(b []byte) error
- type RecordMarkerCommandAttributes
- func (*RecordMarkerCommandAttributes) Descriptor() ([]byte, []int)
- func (this *RecordMarkerCommandAttributes) Equal(that interface{}) bool
- func (m *RecordMarkerCommandAttributes) GetDetails() map[string]*v1.Payloads
- func (m *RecordMarkerCommandAttributes) GetFailure() *v12.Failure
- func (m *RecordMarkerCommandAttributes) GetHeader() *v1.Header
- func (m *RecordMarkerCommandAttributes) GetMarkerName() string
- func (this *RecordMarkerCommandAttributes) GoString() string
- func (m *RecordMarkerCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *RecordMarkerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *RecordMarkerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecordMarkerCommandAttributes) ProtoMessage()
- func (m *RecordMarkerCommandAttributes) Reset()
- func (m *RecordMarkerCommandAttributes) Size() (n int)
- func (this *RecordMarkerCommandAttributes) String() string
- func (m *RecordMarkerCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *RecordMarkerCommandAttributes) XXX_DiscardUnknown()
- func (m *RecordMarkerCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordMarkerCommandAttributes) XXX_Merge(src proto.Message)
- func (m *RecordMarkerCommandAttributes) XXX_Size() int
- func (m *RecordMarkerCommandAttributes) XXX_Unmarshal(b []byte) error
- type RejectWorkflowUpdateCommandAttributes
- func (*RejectWorkflowUpdateCommandAttributes) Descriptor() ([]byte, []int)
- func (this *RejectWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
- func (m *RejectWorkflowUpdateCommandAttributes) GetFailure() *v12.Failure
- func (m *RejectWorkflowUpdateCommandAttributes) GetMeta() *v14.Meta
- func (this *RejectWorkflowUpdateCommandAttributes) GoString() string
- func (m *RejectWorkflowUpdateCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *RejectWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *RejectWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RejectWorkflowUpdateCommandAttributes) ProtoMessage()
- func (m *RejectWorkflowUpdateCommandAttributes) Reset()
- func (m *RejectWorkflowUpdateCommandAttributes) Size() (n int)
- func (this *RejectWorkflowUpdateCommandAttributes) String() string
- func (m *RejectWorkflowUpdateCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *RejectWorkflowUpdateCommandAttributes) XXX_DiscardUnknown()
- func (m *RejectWorkflowUpdateCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RejectWorkflowUpdateCommandAttributes) XXX_Merge(src proto.Message)
- func (m *RejectWorkflowUpdateCommandAttributes) XXX_Size() int
- func (m *RejectWorkflowUpdateCommandAttributes) XXX_Unmarshal(b []byte) error
- type RequestCancelActivityTaskCommandAttributes
- func (*RequestCancelActivityTaskCommandAttributes) Descriptor() ([]byte, []int)
- func (this *RequestCancelActivityTaskCommandAttributes) Equal(that interface{}) bool
- func (m *RequestCancelActivityTaskCommandAttributes) GetScheduledEventId() int64
- func (this *RequestCancelActivityTaskCommandAttributes) GoString() string
- func (m *RequestCancelActivityTaskCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *RequestCancelActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *RequestCancelActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequestCancelActivityTaskCommandAttributes) ProtoMessage()
- func (m *RequestCancelActivityTaskCommandAttributes) Reset()
- func (m *RequestCancelActivityTaskCommandAttributes) Size() (n int)
- func (this *RequestCancelActivityTaskCommandAttributes) String() string
- func (m *RequestCancelActivityTaskCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *RequestCancelActivityTaskCommandAttributes) XXX_DiscardUnknown()
- func (m *RequestCancelActivityTaskCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestCancelActivityTaskCommandAttributes) XXX_Merge(src proto.Message)
- func (m *RequestCancelActivityTaskCommandAttributes) XXX_Size() int
- func (m *RequestCancelActivityTaskCommandAttributes) XXX_Unmarshal(b []byte) error
- type RequestCancelExternalWorkflowExecutionCommandAttributes
- func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
- func (this *RequestCancelExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly() bool
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetControl() string
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetNamespace() string
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetReason() string
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetRunId() string
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetWorkflowId() string
- func (this *RequestCancelExternalWorkflowExecutionCommandAttributes) GoString() string
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoMessage()
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Reset()
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *RequestCancelExternalWorkflowExecutionCommandAttributes) String() string
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Size() int
- func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
- type ScheduleActivityTaskCommandAttributes
- func (*ScheduleActivityTaskCommandAttributes) Descriptor() ([]byte, []int)
- func (this *ScheduleActivityTaskCommandAttributes) Equal(that interface{}) bool
- func (m *ScheduleActivityTaskCommandAttributes) GetActivityId() string
- func (m *ScheduleActivityTaskCommandAttributes) GetActivityType() *v1.ActivityType
- func (m *ScheduleActivityTaskCommandAttributes) GetHeader() *v1.Header
- func (m *ScheduleActivityTaskCommandAttributes) GetHeartbeatTimeout() *time.Duration
- func (m *ScheduleActivityTaskCommandAttributes) GetInput() *v1.Payloads
- func (m *ScheduleActivityTaskCommandAttributes) GetRequestEagerExecution() bool
- func (m *ScheduleActivityTaskCommandAttributes) GetRetryPolicy() *v1.RetryPolicy
- func (m *ScheduleActivityTaskCommandAttributes) GetScheduleToCloseTimeout() *time.Duration
- func (m *ScheduleActivityTaskCommandAttributes) GetScheduleToStartTimeout() *time.Duration
- func (m *ScheduleActivityTaskCommandAttributes) GetStartToCloseTimeout() *time.Duration
- func (m *ScheduleActivityTaskCommandAttributes) GetTaskQueue() *v11.TaskQueue
- func (this *ScheduleActivityTaskCommandAttributes) GoString() string
- func (m *ScheduleActivityTaskCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *ScheduleActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *ScheduleActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ScheduleActivityTaskCommandAttributes) ProtoMessage()
- func (m *ScheduleActivityTaskCommandAttributes) Reset()
- func (m *ScheduleActivityTaskCommandAttributes) Size() (n int)
- func (this *ScheduleActivityTaskCommandAttributes) String() string
- func (m *ScheduleActivityTaskCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *ScheduleActivityTaskCommandAttributes) XXX_DiscardUnknown()
- func (m *ScheduleActivityTaskCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScheduleActivityTaskCommandAttributes) XXX_Merge(src proto.Message)
- func (m *ScheduleActivityTaskCommandAttributes) XXX_Size() int
- func (m *ScheduleActivityTaskCommandAttributes) XXX_Unmarshal(b []byte) error
- type SignalExternalWorkflowExecutionCommandAttributes
- func (*SignalExternalWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
- func (this *SignalExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (m *SignalExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly() bool
- func (m *SignalExternalWorkflowExecutionCommandAttributes) GetControl() string
- func (m *SignalExternalWorkflowExecutionCommandAttributes) GetExecution() *v1.WorkflowExecution
- func (m *SignalExternalWorkflowExecutionCommandAttributes) GetHeader() *v1.Header
- func (m *SignalExternalWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads
- func (m *SignalExternalWorkflowExecutionCommandAttributes) GetNamespace() string
- func (m *SignalExternalWorkflowExecutionCommandAttributes) GetSignalName() string
- func (this *SignalExternalWorkflowExecutionCommandAttributes) GoString() string
- func (m *SignalExternalWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *SignalExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *SignalExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoMessage()
- func (m *SignalExternalWorkflowExecutionCommandAttributes) Reset()
- func (m *SignalExternalWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *SignalExternalWorkflowExecutionCommandAttributes) String() string
- func (m *SignalExternalWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
- func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
- func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Size() int
- func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
- type StartChildWorkflowExecutionCommandAttributes
- func (*StartChildWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
- func (this *StartChildWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
- func (m *StartChildWorkflowExecutionCommandAttributes) GetControl() string
- func (m *StartChildWorkflowExecutionCommandAttributes) GetCronSchedule() string
- func (m *StartChildWorkflowExecutionCommandAttributes) GetHeader() *v1.Header
- func (m *StartChildWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads
- func (m *StartChildWorkflowExecutionCommandAttributes) GetMemo() *v1.Memo
- func (m *StartChildWorkflowExecutionCommandAttributes) GetNamespace() string
- func (m *StartChildWorkflowExecutionCommandAttributes) GetParentClosePolicy() v13.ParentClosePolicy
- func (m *StartChildWorkflowExecutionCommandAttributes) GetRetryPolicy() *v1.RetryPolicy
- func (m *StartChildWorkflowExecutionCommandAttributes) GetSearchAttributes() *v1.SearchAttributes
- func (m *StartChildWorkflowExecutionCommandAttributes) GetTaskQueue() *v11.TaskQueue
- func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowExecutionTimeout() *time.Duration
- func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowId() string
- func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowIdReusePolicy() v13.WorkflowIdReusePolicy
- func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout() *time.Duration
- func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout() *time.Duration
- func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowType() *v1.WorkflowType
- func (this *StartChildWorkflowExecutionCommandAttributes) GoString() string
- func (m *StartChildWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *StartChildWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *StartChildWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartChildWorkflowExecutionCommandAttributes) ProtoMessage()
- func (m *StartChildWorkflowExecutionCommandAttributes) Reset()
- func (m *StartChildWorkflowExecutionCommandAttributes) Size() (n int)
- func (this *StartChildWorkflowExecutionCommandAttributes) String() string
- func (m *StartChildWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *StartChildWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
- func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
- func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Size() int
- func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
- type StartTimerCommandAttributes
- func (*StartTimerCommandAttributes) Descriptor() ([]byte, []int)
- func (this *StartTimerCommandAttributes) Equal(that interface{}) bool
- func (m *StartTimerCommandAttributes) GetStartToFireTimeout() *time.Duration
- func (m *StartTimerCommandAttributes) GetTimerId() string
- func (this *StartTimerCommandAttributes) GoString() string
- func (m *StartTimerCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *StartTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *StartTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartTimerCommandAttributes) ProtoMessage()
- func (m *StartTimerCommandAttributes) Reset()
- func (m *StartTimerCommandAttributes) Size() (n int)
- func (this *StartTimerCommandAttributes) String() string
- func (m *StartTimerCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *StartTimerCommandAttributes) XXX_DiscardUnknown()
- func (m *StartTimerCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartTimerCommandAttributes) XXX_Merge(src proto.Message)
- func (m *StartTimerCommandAttributes) XXX_Size() int
- func (m *StartTimerCommandAttributes) XXX_Unmarshal(b []byte) error
- type UpsertWorkflowSearchAttributesCommandAttributes
- func (*UpsertWorkflowSearchAttributesCommandAttributes) Descriptor() ([]byte, []int)
- func (this *UpsertWorkflowSearchAttributesCommandAttributes) Equal(that interface{}) bool
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) GetSearchAttributes() *v1.SearchAttributes
- func (this *UpsertWorkflowSearchAttributesCommandAttributes) GoString() string
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) Marshal() (dAtA []byte, err error)
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoMessage()
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) Reset()
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) Size() (n int)
- func (this *UpsertWorkflowSearchAttributesCommandAttributes) String() string
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) Unmarshal(dAtA []byte) error
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_DiscardUnknown()
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Merge(src proto.Message)
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Size() int
- func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type AcceptWorkflowUpdateCommandAttributes ¶ added in v1.10.0
type AcceptWorkflowUpdateCommandAttributes struct { Meta *v14.Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` Input *v14.Input `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"` }
func (*AcceptWorkflowUpdateCommandAttributes) Descriptor ¶ added in v1.10.0
func (*AcceptWorkflowUpdateCommandAttributes) Descriptor() ([]byte, []int)
func (*AcceptWorkflowUpdateCommandAttributes) Equal ¶ added in v1.10.0
func (this *AcceptWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
func (*AcceptWorkflowUpdateCommandAttributes) GetInput ¶ added in v1.13.0
func (m *AcceptWorkflowUpdateCommandAttributes) GetInput() *v14.Input
func (*AcceptWorkflowUpdateCommandAttributes) GetMeta ¶ added in v1.13.0
func (m *AcceptWorkflowUpdateCommandAttributes) GetMeta() *v14.Meta
func (*AcceptWorkflowUpdateCommandAttributes) GoString ¶ added in v1.10.0
func (this *AcceptWorkflowUpdateCommandAttributes) GoString() string
func (*AcceptWorkflowUpdateCommandAttributes) Marshal ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) Marshal() (dAtA []byte, err error)
func (*AcceptWorkflowUpdateCommandAttributes) MarshalTo ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*AcceptWorkflowUpdateCommandAttributes) MarshalToSizedBuffer ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AcceptWorkflowUpdateCommandAttributes) ProtoMessage ¶ added in v1.10.0
func (*AcceptWorkflowUpdateCommandAttributes) ProtoMessage()
func (*AcceptWorkflowUpdateCommandAttributes) Reset ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) Reset()
func (*AcceptWorkflowUpdateCommandAttributes) Size ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) Size() (n int)
func (*AcceptWorkflowUpdateCommandAttributes) String ¶ added in v1.10.0
func (this *AcceptWorkflowUpdateCommandAttributes) String() string
func (*AcceptWorkflowUpdateCommandAttributes) Unmarshal ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) Unmarshal(dAtA []byte) error
func (*AcceptWorkflowUpdateCommandAttributes) XXX_DiscardUnknown ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) XXX_DiscardUnknown()
func (*AcceptWorkflowUpdateCommandAttributes) XXX_Marshal ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AcceptWorkflowUpdateCommandAttributes) XXX_Merge ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Merge(src proto.Message)
func (*AcceptWorkflowUpdateCommandAttributes) XXX_Size ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Size() int
func (*AcceptWorkflowUpdateCommandAttributes) XXX_Unmarshal ¶ added in v1.10.0
func (m *AcceptWorkflowUpdateCommandAttributes) XXX_Unmarshal(b []byte) error
type CancelTimerCommandAttributes ¶
type CancelTimerCommandAttributes struct { // The same timer id from the start timer command TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"` }
func (*CancelTimerCommandAttributes) Descriptor ¶
func (*CancelTimerCommandAttributes) Descriptor() ([]byte, []int)
func (*CancelTimerCommandAttributes) Equal ¶
func (this *CancelTimerCommandAttributes) Equal(that interface{}) bool
func (*CancelTimerCommandAttributes) GetTimerId ¶
func (m *CancelTimerCommandAttributes) GetTimerId() string
func (*CancelTimerCommandAttributes) GoString ¶
func (this *CancelTimerCommandAttributes) GoString() string
func (*CancelTimerCommandAttributes) Marshal ¶
func (m *CancelTimerCommandAttributes) Marshal() (dAtA []byte, err error)
func (*CancelTimerCommandAttributes) MarshalTo ¶
func (m *CancelTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*CancelTimerCommandAttributes) MarshalToSizedBuffer ¶
func (m *CancelTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CancelTimerCommandAttributes) ProtoMessage ¶
func (*CancelTimerCommandAttributes) ProtoMessage()
func (*CancelTimerCommandAttributes) Reset ¶
func (m *CancelTimerCommandAttributes) Reset()
func (*CancelTimerCommandAttributes) Size ¶
func (m *CancelTimerCommandAttributes) Size() (n int)
func (*CancelTimerCommandAttributes) String ¶
func (this *CancelTimerCommandAttributes) String() string
func (*CancelTimerCommandAttributes) Unmarshal ¶
func (m *CancelTimerCommandAttributes) Unmarshal(dAtA []byte) error
func (*CancelTimerCommandAttributes) XXX_DiscardUnknown ¶
func (m *CancelTimerCommandAttributes) XXX_DiscardUnknown()
func (*CancelTimerCommandAttributes) XXX_Marshal ¶
func (m *CancelTimerCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancelTimerCommandAttributes) XXX_Merge ¶
func (m *CancelTimerCommandAttributes) XXX_Merge(src proto.Message)
func (*CancelTimerCommandAttributes) XXX_Size ¶
func (m *CancelTimerCommandAttributes) XXX_Size() int
func (*CancelTimerCommandAttributes) XXX_Unmarshal ¶
func (m *CancelTimerCommandAttributes) XXX_Unmarshal(b []byte) error
type CancelWorkflowExecutionCommandAttributes ¶
type CancelWorkflowExecutionCommandAttributes struct {
Details *v1.Payloads `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
}
func (*CancelWorkflowExecutionCommandAttributes) Descriptor ¶
func (*CancelWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
func (*CancelWorkflowExecutionCommandAttributes) Equal ¶
func (this *CancelWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*CancelWorkflowExecutionCommandAttributes) GetDetails ¶
func (m *CancelWorkflowExecutionCommandAttributes) GetDetails() *v1.Payloads
func (*CancelWorkflowExecutionCommandAttributes) GoString ¶
func (this *CancelWorkflowExecutionCommandAttributes) GoString() string
func (*CancelWorkflowExecutionCommandAttributes) Marshal ¶
func (m *CancelWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
func (*CancelWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *CancelWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*CancelWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *CancelWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CancelWorkflowExecutionCommandAttributes) ProtoMessage ¶
func (*CancelWorkflowExecutionCommandAttributes) ProtoMessage()
func (*CancelWorkflowExecutionCommandAttributes) Reset ¶
func (m *CancelWorkflowExecutionCommandAttributes) Reset()
func (*CancelWorkflowExecutionCommandAttributes) Size ¶
func (m *CancelWorkflowExecutionCommandAttributes) Size() (n int)
func (*CancelWorkflowExecutionCommandAttributes) String ¶
func (this *CancelWorkflowExecutionCommandAttributes) String() string
func (*CancelWorkflowExecutionCommandAttributes) Unmarshal ¶
func (m *CancelWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
func (*CancelWorkflowExecutionCommandAttributes) XXX_DiscardUnknown ¶
func (m *CancelWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
func (*CancelWorkflowExecutionCommandAttributes) XXX_Marshal ¶
func (m *CancelWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CancelWorkflowExecutionCommandAttributes) XXX_Merge ¶
func (m *CancelWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
func (*CancelWorkflowExecutionCommandAttributes) XXX_Size ¶
func (m *CancelWorkflowExecutionCommandAttributes) XXX_Size() int
func (*CancelWorkflowExecutionCommandAttributes) XXX_Unmarshal ¶
func (m *CancelWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
type Command ¶
type Command struct { CommandType v13.CommandType `` /* 134-byte string literal not displayed */ // Types that are valid to be assigned to Attributes: // *Command_ScheduleActivityTaskCommandAttributes // *Command_StartTimerCommandAttributes // *Command_CompleteWorkflowExecutionCommandAttributes // *Command_FailWorkflowExecutionCommandAttributes // *Command_RequestCancelActivityTaskCommandAttributes // *Command_CancelTimerCommandAttributes // *Command_CancelWorkflowExecutionCommandAttributes // *Command_RequestCancelExternalWorkflowExecutionCommandAttributes // *Command_RecordMarkerCommandAttributes // *Command_ContinueAsNewWorkflowExecutionCommandAttributes // *Command_StartChildWorkflowExecutionCommandAttributes // *Command_SignalExternalWorkflowExecutionCommandAttributes // *Command_UpsertWorkflowSearchAttributesCommandAttributes // *Command_AcceptWorkflowUpdateCommandAttributes // *Command_CompleteWorkflowUpdateCommandAttributes // *Command_ModifyWorkflowPropertiesCommandAttributes // *Command_RejectWorkflowUpdateCommandAttributes Attributes isCommand_Attributes `protobuf_oneof:"attributes"` }
func (*Command) Descriptor ¶
func (*Command) GetAcceptWorkflowUpdateCommandAttributes ¶ added in v1.10.0
func (m *Command) GetAcceptWorkflowUpdateCommandAttributes() *AcceptWorkflowUpdateCommandAttributes
func (*Command) GetAttributes ¶
func (m *Command) GetAttributes() isCommand_Attributes
func (*Command) GetCancelTimerCommandAttributes ¶
func (m *Command) GetCancelTimerCommandAttributes() *CancelTimerCommandAttributes
func (*Command) GetCancelWorkflowExecutionCommandAttributes ¶
func (m *Command) GetCancelWorkflowExecutionCommandAttributes() *CancelWorkflowExecutionCommandAttributes
func (*Command) GetCommandType ¶
func (m *Command) GetCommandType() v13.CommandType
func (*Command) GetCompleteWorkflowExecutionCommandAttributes ¶
func (m *Command) GetCompleteWorkflowExecutionCommandAttributes() *CompleteWorkflowExecutionCommandAttributes
func (*Command) GetCompleteWorkflowUpdateCommandAttributes ¶ added in v1.10.0
func (m *Command) GetCompleteWorkflowUpdateCommandAttributes() *CompleteWorkflowUpdateCommandAttributes
func (*Command) GetContinueAsNewWorkflowExecutionCommandAttributes ¶
func (m *Command) GetContinueAsNewWorkflowExecutionCommandAttributes() *ContinueAsNewWorkflowExecutionCommandAttributes
func (*Command) GetFailWorkflowExecutionCommandAttributes ¶
func (m *Command) GetFailWorkflowExecutionCommandAttributes() *FailWorkflowExecutionCommandAttributes
func (*Command) GetModifyWorkflowPropertiesCommandAttributes ¶ added in v1.12.0
func (m *Command) GetModifyWorkflowPropertiesCommandAttributes() *ModifyWorkflowPropertiesCommandAttributes
func (*Command) GetRecordMarkerCommandAttributes ¶
func (m *Command) GetRecordMarkerCommandAttributes() *RecordMarkerCommandAttributes
func (*Command) GetRejectWorkflowUpdateCommandAttributes ¶ added in v1.13.0
func (m *Command) GetRejectWorkflowUpdateCommandAttributes() *RejectWorkflowUpdateCommandAttributes
func (*Command) GetRequestCancelActivityTaskCommandAttributes ¶
func (m *Command) GetRequestCancelActivityTaskCommandAttributes() *RequestCancelActivityTaskCommandAttributes
func (*Command) GetRequestCancelExternalWorkflowExecutionCommandAttributes ¶
func (m *Command) GetRequestCancelExternalWorkflowExecutionCommandAttributes() *RequestCancelExternalWorkflowExecutionCommandAttributes
func (*Command) GetScheduleActivityTaskCommandAttributes ¶
func (m *Command) GetScheduleActivityTaskCommandAttributes() *ScheduleActivityTaskCommandAttributes
func (*Command) GetSignalExternalWorkflowExecutionCommandAttributes ¶
func (m *Command) GetSignalExternalWorkflowExecutionCommandAttributes() *SignalExternalWorkflowExecutionCommandAttributes
func (*Command) GetStartChildWorkflowExecutionCommandAttributes ¶
func (m *Command) GetStartChildWorkflowExecutionCommandAttributes() *StartChildWorkflowExecutionCommandAttributes
func (*Command) GetStartTimerCommandAttributes ¶
func (m *Command) GetStartTimerCommandAttributes() *StartTimerCommandAttributes
func (*Command) GetUpsertWorkflowSearchAttributesCommandAttributes ¶
func (m *Command) GetUpsertWorkflowSearchAttributesCommandAttributes() *UpsertWorkflowSearchAttributesCommandAttributes
func (*Command) MarshalToSizedBuffer ¶
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
func (*Command) XXX_DiscardUnknown ¶
func (m *Command) XXX_DiscardUnknown()
func (*Command) XXX_Marshal ¶
func (*Command) XXX_OneofWrappers ¶
func (*Command) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Command) XXX_Unmarshal ¶
type Command_AcceptWorkflowUpdateCommandAttributes ¶ added in v1.10.0
type Command_AcceptWorkflowUpdateCommandAttributes struct {
AcceptWorkflowUpdateCommandAttributes *AcceptWorkflowUpdateCommandAttributes `` /* 185-byte string literal not displayed */
}
func (*Command_AcceptWorkflowUpdateCommandAttributes) Equal ¶ added in v1.10.0
func (this *Command_AcceptWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
func (*Command_AcceptWorkflowUpdateCommandAttributes) GoString ¶ added in v1.10.0
func (this *Command_AcceptWorkflowUpdateCommandAttributes) GoString() string
func (*Command_AcceptWorkflowUpdateCommandAttributes) MarshalTo ¶ added in v1.10.0
func (m *Command_AcceptWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_AcceptWorkflowUpdateCommandAttributes) MarshalToSizedBuffer ¶ added in v1.10.0
func (m *Command_AcceptWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_AcceptWorkflowUpdateCommandAttributes) Size ¶ added in v1.10.0
func (m *Command_AcceptWorkflowUpdateCommandAttributes) Size() (n int)
func (*Command_AcceptWorkflowUpdateCommandAttributes) String ¶ added in v1.10.0
func (this *Command_AcceptWorkflowUpdateCommandAttributes) String() string
type Command_CancelTimerCommandAttributes ¶
type Command_CancelTimerCommandAttributes struct {
CancelTimerCommandAttributes *CancelTimerCommandAttributes `` /* 155-byte string literal not displayed */
}
func (*Command_CancelTimerCommandAttributes) Equal ¶
func (this *Command_CancelTimerCommandAttributes) Equal(that interface{}) bool
func (*Command_CancelTimerCommandAttributes) GoString ¶
func (this *Command_CancelTimerCommandAttributes) GoString() string
func (*Command_CancelTimerCommandAttributes) MarshalTo ¶
func (m *Command_CancelTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_CancelTimerCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_CancelTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_CancelTimerCommandAttributes) Size ¶
func (m *Command_CancelTimerCommandAttributes) Size() (n int)
func (*Command_CancelTimerCommandAttributes) String ¶
func (this *Command_CancelTimerCommandAttributes) String() string
type Command_CancelWorkflowExecutionCommandAttributes ¶
type Command_CancelWorkflowExecutionCommandAttributes struct {
CancelWorkflowExecutionCommandAttributes *CancelWorkflowExecutionCommandAttributes `` /* 193-byte string literal not displayed */
}
func (*Command_CancelWorkflowExecutionCommandAttributes) Equal ¶
func (this *Command_CancelWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*Command_CancelWorkflowExecutionCommandAttributes) GoString ¶
func (this *Command_CancelWorkflowExecutionCommandAttributes) GoString() string
func (*Command_CancelWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *Command_CancelWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_CancelWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_CancelWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_CancelWorkflowExecutionCommandAttributes) Size ¶
func (m *Command_CancelWorkflowExecutionCommandAttributes) Size() (n int)
func (*Command_CancelWorkflowExecutionCommandAttributes) String ¶
func (this *Command_CancelWorkflowExecutionCommandAttributes) String() string
type Command_CompleteWorkflowExecutionCommandAttributes ¶
type Command_CompleteWorkflowExecutionCommandAttributes struct {
CompleteWorkflowExecutionCommandAttributes *CompleteWorkflowExecutionCommandAttributes `` /* 199-byte string literal not displayed */
}
func (*Command_CompleteWorkflowExecutionCommandAttributes) Equal ¶
func (this *Command_CompleteWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*Command_CompleteWorkflowExecutionCommandAttributes) GoString ¶
func (this *Command_CompleteWorkflowExecutionCommandAttributes) GoString() string
func (*Command_CompleteWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *Command_CompleteWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_CompleteWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_CompleteWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_CompleteWorkflowExecutionCommandAttributes) Size ¶
func (m *Command_CompleteWorkflowExecutionCommandAttributes) Size() (n int)
func (*Command_CompleteWorkflowExecutionCommandAttributes) String ¶
func (this *Command_CompleteWorkflowExecutionCommandAttributes) String() string
type Command_CompleteWorkflowUpdateCommandAttributes ¶ added in v1.10.0
type Command_CompleteWorkflowUpdateCommandAttributes struct {
CompleteWorkflowUpdateCommandAttributes *CompleteWorkflowUpdateCommandAttributes `` /* 191-byte string literal not displayed */
}
func (*Command_CompleteWorkflowUpdateCommandAttributes) Equal ¶ added in v1.10.0
func (this *Command_CompleteWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
func (*Command_CompleteWorkflowUpdateCommandAttributes) GoString ¶ added in v1.10.0
func (this *Command_CompleteWorkflowUpdateCommandAttributes) GoString() string
func (*Command_CompleteWorkflowUpdateCommandAttributes) MarshalTo ¶ added in v1.10.0
func (m *Command_CompleteWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_CompleteWorkflowUpdateCommandAttributes) MarshalToSizedBuffer ¶ added in v1.10.0
func (m *Command_CompleteWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_CompleteWorkflowUpdateCommandAttributes) Size ¶ added in v1.10.0
func (m *Command_CompleteWorkflowUpdateCommandAttributes) Size() (n int)
func (*Command_CompleteWorkflowUpdateCommandAttributes) String ¶ added in v1.10.0
func (this *Command_CompleteWorkflowUpdateCommandAttributes) String() string
type Command_ContinueAsNewWorkflowExecutionCommandAttributes ¶
type Command_ContinueAsNewWorkflowExecutionCommandAttributes struct {
ContinueAsNewWorkflowExecutionCommandAttributes *ContinueAsNewWorkflowExecutionCommandAttributes `` /* 219-byte string literal not displayed */
}
func (*Command_ContinueAsNewWorkflowExecutionCommandAttributes) Equal ¶
func (this *Command_ContinueAsNewWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*Command_ContinueAsNewWorkflowExecutionCommandAttributes) GoString ¶
func (this *Command_ContinueAsNewWorkflowExecutionCommandAttributes) GoString() string
func (*Command_ContinueAsNewWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *Command_ContinueAsNewWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_ContinueAsNewWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_ContinueAsNewWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_ContinueAsNewWorkflowExecutionCommandAttributes) Size ¶
func (m *Command_ContinueAsNewWorkflowExecutionCommandAttributes) Size() (n int)
func (*Command_ContinueAsNewWorkflowExecutionCommandAttributes) String ¶
func (this *Command_ContinueAsNewWorkflowExecutionCommandAttributes) String() string
type Command_FailWorkflowExecutionCommandAttributes ¶
type Command_FailWorkflowExecutionCommandAttributes struct {
FailWorkflowExecutionCommandAttributes *FailWorkflowExecutionCommandAttributes `` /* 187-byte string literal not displayed */
}
func (*Command_FailWorkflowExecutionCommandAttributes) Equal ¶
func (this *Command_FailWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*Command_FailWorkflowExecutionCommandAttributes) GoString ¶
func (this *Command_FailWorkflowExecutionCommandAttributes) GoString() string
func (*Command_FailWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *Command_FailWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_FailWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_FailWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_FailWorkflowExecutionCommandAttributes) Size ¶
func (m *Command_FailWorkflowExecutionCommandAttributes) Size() (n int)
func (*Command_FailWorkflowExecutionCommandAttributes) String ¶
func (this *Command_FailWorkflowExecutionCommandAttributes) String() string
type Command_ModifyWorkflowPropertiesCommandAttributes ¶ added in v1.12.0
type Command_ModifyWorkflowPropertiesCommandAttributes struct {
ModifyWorkflowPropertiesCommandAttributes *ModifyWorkflowPropertiesCommandAttributes `` /* 197-byte string literal not displayed */
}
func (*Command_ModifyWorkflowPropertiesCommandAttributes) Equal ¶ added in v1.12.0
func (this *Command_ModifyWorkflowPropertiesCommandAttributes) Equal(that interface{}) bool
func (*Command_ModifyWorkflowPropertiesCommandAttributes) GoString ¶ added in v1.12.0
func (this *Command_ModifyWorkflowPropertiesCommandAttributes) GoString() string
func (*Command_ModifyWorkflowPropertiesCommandAttributes) MarshalTo ¶ added in v1.12.0
func (m *Command_ModifyWorkflowPropertiesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_ModifyWorkflowPropertiesCommandAttributes) MarshalToSizedBuffer ¶ added in v1.12.0
func (m *Command_ModifyWorkflowPropertiesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_ModifyWorkflowPropertiesCommandAttributes) Size ¶ added in v1.12.0
func (m *Command_ModifyWorkflowPropertiesCommandAttributes) Size() (n int)
func (*Command_ModifyWorkflowPropertiesCommandAttributes) String ¶ added in v1.12.0
func (this *Command_ModifyWorkflowPropertiesCommandAttributes) String() string
type Command_RecordMarkerCommandAttributes ¶
type Command_RecordMarkerCommandAttributes struct {
RecordMarkerCommandAttributes *RecordMarkerCommandAttributes `` /* 159-byte string literal not displayed */
}
func (*Command_RecordMarkerCommandAttributes) Equal ¶
func (this *Command_RecordMarkerCommandAttributes) Equal(that interface{}) bool
func (*Command_RecordMarkerCommandAttributes) GoString ¶
func (this *Command_RecordMarkerCommandAttributes) GoString() string
func (*Command_RecordMarkerCommandAttributes) MarshalTo ¶
func (m *Command_RecordMarkerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_RecordMarkerCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_RecordMarkerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_RecordMarkerCommandAttributes) Size ¶
func (m *Command_RecordMarkerCommandAttributes) Size() (n int)
func (*Command_RecordMarkerCommandAttributes) String ¶
func (this *Command_RecordMarkerCommandAttributes) String() string
type Command_RejectWorkflowUpdateCommandAttributes ¶ added in v1.13.0
type Command_RejectWorkflowUpdateCommandAttributes struct {
RejectWorkflowUpdateCommandAttributes *RejectWorkflowUpdateCommandAttributes `` /* 185-byte string literal not displayed */
}
func (*Command_RejectWorkflowUpdateCommandAttributes) Equal ¶ added in v1.13.0
func (this *Command_RejectWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
func (*Command_RejectWorkflowUpdateCommandAttributes) GoString ¶ added in v1.13.0
func (this *Command_RejectWorkflowUpdateCommandAttributes) GoString() string
func (*Command_RejectWorkflowUpdateCommandAttributes) MarshalTo ¶ added in v1.13.0
func (m *Command_RejectWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_RejectWorkflowUpdateCommandAttributes) MarshalToSizedBuffer ¶ added in v1.13.0
func (m *Command_RejectWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_RejectWorkflowUpdateCommandAttributes) Size ¶ added in v1.13.0
func (m *Command_RejectWorkflowUpdateCommandAttributes) Size() (n int)
func (*Command_RejectWorkflowUpdateCommandAttributes) String ¶ added in v1.13.0
func (this *Command_RejectWorkflowUpdateCommandAttributes) String() string
type Command_RequestCancelActivityTaskCommandAttributes ¶
type Command_RequestCancelActivityTaskCommandAttributes struct {
RequestCancelActivityTaskCommandAttributes *RequestCancelActivityTaskCommandAttributes `` /* 201-byte string literal not displayed */
}
func (*Command_RequestCancelActivityTaskCommandAttributes) Equal ¶
func (this *Command_RequestCancelActivityTaskCommandAttributes) Equal(that interface{}) bool
func (*Command_RequestCancelActivityTaskCommandAttributes) GoString ¶
func (this *Command_RequestCancelActivityTaskCommandAttributes) GoString() string
func (*Command_RequestCancelActivityTaskCommandAttributes) MarshalTo ¶
func (m *Command_RequestCancelActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_RequestCancelActivityTaskCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_RequestCancelActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_RequestCancelActivityTaskCommandAttributes) Size ¶
func (m *Command_RequestCancelActivityTaskCommandAttributes) Size() (n int)
func (*Command_RequestCancelActivityTaskCommandAttributes) String ¶
func (this *Command_RequestCancelActivityTaskCommandAttributes) String() string
type Command_RequestCancelExternalWorkflowExecutionCommandAttributes ¶
type Command_RequestCancelExternalWorkflowExecutionCommandAttributes struct {
RequestCancelExternalWorkflowExecutionCommandAttributes *RequestCancelExternalWorkflowExecutionCommandAttributes `` /* 242-byte string literal not displayed */
}
func (*Command_RequestCancelExternalWorkflowExecutionCommandAttributes) Equal ¶
func (this *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*Command_RequestCancelExternalWorkflowExecutionCommandAttributes) GoString ¶
func (this *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) GoString() string
func (*Command_RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_RequestCancelExternalWorkflowExecutionCommandAttributes) Size ¶
func (m *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) Size() (n int)
func (*Command_RequestCancelExternalWorkflowExecutionCommandAttributes) String ¶
func (this *Command_RequestCancelExternalWorkflowExecutionCommandAttributes) String() string
type Command_ScheduleActivityTaskCommandAttributes ¶
type Command_ScheduleActivityTaskCommandAttributes struct {
ScheduleActivityTaskCommandAttributes *ScheduleActivityTaskCommandAttributes `` /* 184-byte string literal not displayed */
}
func (*Command_ScheduleActivityTaskCommandAttributes) Equal ¶
func (this *Command_ScheduleActivityTaskCommandAttributes) Equal(that interface{}) bool
func (*Command_ScheduleActivityTaskCommandAttributes) GoString ¶
func (this *Command_ScheduleActivityTaskCommandAttributes) GoString() string
func (*Command_ScheduleActivityTaskCommandAttributes) MarshalTo ¶
func (m *Command_ScheduleActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_ScheduleActivityTaskCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_ScheduleActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_ScheduleActivityTaskCommandAttributes) Size ¶
func (m *Command_ScheduleActivityTaskCommandAttributes) Size() (n int)
func (*Command_ScheduleActivityTaskCommandAttributes) String ¶
func (this *Command_ScheduleActivityTaskCommandAttributes) String() string
type Command_SignalExternalWorkflowExecutionCommandAttributes ¶
type Command_SignalExternalWorkflowExecutionCommandAttributes struct {
SignalExternalWorkflowExecutionCommandAttributes *SignalExternalWorkflowExecutionCommandAttributes `` /* 220-byte string literal not displayed */
}
func (*Command_SignalExternalWorkflowExecutionCommandAttributes) Equal ¶
func (this *Command_SignalExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*Command_SignalExternalWorkflowExecutionCommandAttributes) GoString ¶
func (this *Command_SignalExternalWorkflowExecutionCommandAttributes) GoString() string
func (*Command_SignalExternalWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *Command_SignalExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_SignalExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_SignalExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_SignalExternalWorkflowExecutionCommandAttributes) Size ¶
func (m *Command_SignalExternalWorkflowExecutionCommandAttributes) Size() (n int)
func (*Command_SignalExternalWorkflowExecutionCommandAttributes) String ¶
func (this *Command_SignalExternalWorkflowExecutionCommandAttributes) String() string
type Command_StartChildWorkflowExecutionCommandAttributes ¶
type Command_StartChildWorkflowExecutionCommandAttributes struct {
StartChildWorkflowExecutionCommandAttributes *StartChildWorkflowExecutionCommandAttributes `` /* 208-byte string literal not displayed */
}
func (*Command_StartChildWorkflowExecutionCommandAttributes) Equal ¶
func (this *Command_StartChildWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*Command_StartChildWorkflowExecutionCommandAttributes) GoString ¶
func (this *Command_StartChildWorkflowExecutionCommandAttributes) GoString() string
func (*Command_StartChildWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *Command_StartChildWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_StartChildWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_StartChildWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_StartChildWorkflowExecutionCommandAttributes) Size ¶
func (m *Command_StartChildWorkflowExecutionCommandAttributes) Size() (n int)
func (*Command_StartChildWorkflowExecutionCommandAttributes) String ¶
func (this *Command_StartChildWorkflowExecutionCommandAttributes) String() string
type Command_StartTimerCommandAttributes ¶
type Command_StartTimerCommandAttributes struct {
StartTimerCommandAttributes *StartTimerCommandAttributes `` /* 152-byte string literal not displayed */
}
func (*Command_StartTimerCommandAttributes) Equal ¶
func (this *Command_StartTimerCommandAttributes) Equal(that interface{}) bool
func (*Command_StartTimerCommandAttributes) GoString ¶
func (this *Command_StartTimerCommandAttributes) GoString() string
func (*Command_StartTimerCommandAttributes) MarshalTo ¶
func (m *Command_StartTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_StartTimerCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_StartTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_StartTimerCommandAttributes) Size ¶
func (m *Command_StartTimerCommandAttributes) Size() (n int)
func (*Command_StartTimerCommandAttributes) String ¶
func (this *Command_StartTimerCommandAttributes) String() string
type Command_UpsertWorkflowSearchAttributesCommandAttributes ¶
type Command_UpsertWorkflowSearchAttributesCommandAttributes struct {
UpsertWorkflowSearchAttributesCommandAttributes *UpsertWorkflowSearchAttributesCommandAttributes `` /* 217-byte string literal not displayed */
}
func (*Command_UpsertWorkflowSearchAttributesCommandAttributes) Equal ¶
func (this *Command_UpsertWorkflowSearchAttributesCommandAttributes) Equal(that interface{}) bool
func (*Command_UpsertWorkflowSearchAttributesCommandAttributes) GoString ¶
func (this *Command_UpsertWorkflowSearchAttributesCommandAttributes) GoString() string
func (*Command_UpsertWorkflowSearchAttributesCommandAttributes) MarshalTo ¶
func (m *Command_UpsertWorkflowSearchAttributesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*Command_UpsertWorkflowSearchAttributesCommandAttributes) MarshalToSizedBuffer ¶
func (m *Command_UpsertWorkflowSearchAttributesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Command_UpsertWorkflowSearchAttributesCommandAttributes) Size ¶
func (m *Command_UpsertWorkflowSearchAttributesCommandAttributes) Size() (n int)
func (*Command_UpsertWorkflowSearchAttributesCommandAttributes) String ¶
func (this *Command_UpsertWorkflowSearchAttributesCommandAttributes) String() string
type CompleteWorkflowExecutionCommandAttributes ¶
type CompleteWorkflowExecutionCommandAttributes struct {
Result *v1.Payloads `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}
func (*CompleteWorkflowExecutionCommandAttributes) Descriptor ¶
func (*CompleteWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
func (*CompleteWorkflowExecutionCommandAttributes) Equal ¶
func (this *CompleteWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*CompleteWorkflowExecutionCommandAttributes) GetResult ¶
func (m *CompleteWorkflowExecutionCommandAttributes) GetResult() *v1.Payloads
func (*CompleteWorkflowExecutionCommandAttributes) GoString ¶
func (this *CompleteWorkflowExecutionCommandAttributes) GoString() string
func (*CompleteWorkflowExecutionCommandAttributes) Marshal ¶
func (m *CompleteWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
func (*CompleteWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *CompleteWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*CompleteWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *CompleteWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CompleteWorkflowExecutionCommandAttributes) ProtoMessage ¶
func (*CompleteWorkflowExecutionCommandAttributes) ProtoMessage()
func (*CompleteWorkflowExecutionCommandAttributes) Reset ¶
func (m *CompleteWorkflowExecutionCommandAttributes) Reset()
func (*CompleteWorkflowExecutionCommandAttributes) Size ¶
func (m *CompleteWorkflowExecutionCommandAttributes) Size() (n int)
func (*CompleteWorkflowExecutionCommandAttributes) String ¶
func (this *CompleteWorkflowExecutionCommandAttributes) String() string
func (*CompleteWorkflowExecutionCommandAttributes) Unmarshal ¶
func (m *CompleteWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
func (*CompleteWorkflowExecutionCommandAttributes) XXX_DiscardUnknown ¶
func (m *CompleteWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
func (*CompleteWorkflowExecutionCommandAttributes) XXX_Marshal ¶
func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CompleteWorkflowExecutionCommandAttributes) XXX_Merge ¶
func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
func (*CompleteWorkflowExecutionCommandAttributes) XXX_Size ¶
func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Size() int
func (*CompleteWorkflowExecutionCommandAttributes) XXX_Unmarshal ¶
func (m *CompleteWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
type CompleteWorkflowUpdateCommandAttributes ¶ added in v1.10.0
type CompleteWorkflowUpdateCommandAttributes struct { Meta *v14.Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` Output *v14.Output `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"` }
func (*CompleteWorkflowUpdateCommandAttributes) Descriptor ¶ added in v1.10.0
func (*CompleteWorkflowUpdateCommandAttributes) Descriptor() ([]byte, []int)
func (*CompleteWorkflowUpdateCommandAttributes) Equal ¶ added in v1.10.0
func (this *CompleteWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
func (*CompleteWorkflowUpdateCommandAttributes) GetMeta ¶ added in v1.13.0
func (m *CompleteWorkflowUpdateCommandAttributes) GetMeta() *v14.Meta
func (*CompleteWorkflowUpdateCommandAttributes) GetOutput ¶ added in v1.13.0
func (m *CompleteWorkflowUpdateCommandAttributes) GetOutput() *v14.Output
func (*CompleteWorkflowUpdateCommandAttributes) GoString ¶ added in v1.10.0
func (this *CompleteWorkflowUpdateCommandAttributes) GoString() string
func (*CompleteWorkflowUpdateCommandAttributes) Marshal ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) Marshal() (dAtA []byte, err error)
func (*CompleteWorkflowUpdateCommandAttributes) MarshalTo ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*CompleteWorkflowUpdateCommandAttributes) MarshalToSizedBuffer ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CompleteWorkflowUpdateCommandAttributes) ProtoMessage ¶ added in v1.10.0
func (*CompleteWorkflowUpdateCommandAttributes) ProtoMessage()
func (*CompleteWorkflowUpdateCommandAttributes) Reset ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) Reset()
func (*CompleteWorkflowUpdateCommandAttributes) Size ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) Size() (n int)
func (*CompleteWorkflowUpdateCommandAttributes) String ¶ added in v1.10.0
func (this *CompleteWorkflowUpdateCommandAttributes) String() string
func (*CompleteWorkflowUpdateCommandAttributes) Unmarshal ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) Unmarshal(dAtA []byte) error
func (*CompleteWorkflowUpdateCommandAttributes) XXX_DiscardUnknown ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) XXX_DiscardUnknown()
func (*CompleteWorkflowUpdateCommandAttributes) XXX_Marshal ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CompleteWorkflowUpdateCommandAttributes) XXX_Merge ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Merge(src proto.Message)
func (*CompleteWorkflowUpdateCommandAttributes) XXX_Size ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Size() int
func (*CompleteWorkflowUpdateCommandAttributes) XXX_Unmarshal ¶ added in v1.10.0
func (m *CompleteWorkflowUpdateCommandAttributes) XXX_Unmarshal(b []byte) error
type ContinueAsNewWorkflowExecutionCommandAttributes ¶
type ContinueAsNewWorkflowExecutionCommandAttributes struct { WorkflowType *v1.WorkflowType `protobuf:"bytes,1,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` TaskQueue *v11.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` Input *v1.Payloads `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"` // Timeout of a single workflow run. WorkflowRunTimeout *time.Duration `` /* 129-byte string literal not displayed */ // Timeout of a single workflow task. WorkflowTaskTimeout *time.Duration `` /* 132-byte string literal not displayed */ // How long the workflow start will be delayed - not really a "backoff" in the traditional sense. BackoffStartInterval *time.Duration `` /* 135-byte string literal not displayed */ RetryPolicy *v1.RetryPolicy `protobuf:"bytes,7,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` // Should be removed Initiator v13.ContinueAsNewInitiator `protobuf:"varint,8,opt,name=initiator,proto3,enum=temporal.api.enums.v1.ContinueAsNewInitiator" json:"initiator,omitempty"` // Should be removed Failure *v12.Failure `protobuf:"bytes,9,opt,name=failure,proto3" json:"failure,omitempty"` // Should be removed LastCompletionResult *v1.Payloads `protobuf:"bytes,10,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"` // Should be removed. Not necessarily unused but unclear and not exposed by SDKs. CronSchedule string `protobuf:"bytes,11,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"` Header *v1.Header `protobuf:"bytes,12,opt,name=header,proto3" json:"header,omitempty"` Memo *v1.Memo `protobuf:"bytes,13,opt,name=memo,proto3" json:"memo,omitempty"` SearchAttributes *v1.SearchAttributes `protobuf:"bytes,14,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"` }
func (*ContinueAsNewWorkflowExecutionCommandAttributes) Descriptor ¶
func (*ContinueAsNewWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
func (*ContinueAsNewWorkflowExecutionCommandAttributes) Equal ¶
func (this *ContinueAsNewWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetBackoffStartInterval ¶ added in v0.28.0
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetBackoffStartInterval() *time.Duration
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetCronSchedule ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetCronSchedule() string
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetFailure ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetFailure() *v12.Failure
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetHeader ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetHeader() *v1.Header
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetInitiator ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetInitiator() v13.ContinueAsNewInitiator
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetInput ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetLastCompletionResult ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetLastCompletionResult() *v1.Payloads
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetMemo ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetMemo() *v1.Memo
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetRetryPolicy ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetRetryPolicy() *v1.RetryPolicy
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetSearchAttributes ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetSearchAttributes() *v1.SearchAttributes
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetTaskQueue ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetTaskQueue() *v11.TaskQueue
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout ¶ added in v0.28.0
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout() *time.Duration
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout ¶ added in v0.28.0
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout() *time.Duration
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowType ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) GetWorkflowType() *v1.WorkflowType
func (*ContinueAsNewWorkflowExecutionCommandAttributes) GoString ¶
func (this *ContinueAsNewWorkflowExecutionCommandAttributes) GoString() string
func (*ContinueAsNewWorkflowExecutionCommandAttributes) Marshal ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
func (*ContinueAsNewWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*ContinueAsNewWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoMessage ¶
func (*ContinueAsNewWorkflowExecutionCommandAttributes) ProtoMessage()
func (*ContinueAsNewWorkflowExecutionCommandAttributes) Reset ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Reset()
func (*ContinueAsNewWorkflowExecutionCommandAttributes) Size ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Size() (n int)
func (*ContinueAsNewWorkflowExecutionCommandAttributes) String ¶
func (this *ContinueAsNewWorkflowExecutionCommandAttributes) String() string
func (*ContinueAsNewWorkflowExecutionCommandAttributes) Unmarshal ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
func (*ContinueAsNewWorkflowExecutionCommandAttributes) XXX_DiscardUnknown ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
func (*ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Marshal ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Merge ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
func (*ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Size ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Size() int
func (*ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Unmarshal ¶
func (m *ContinueAsNewWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
type FailWorkflowExecutionCommandAttributes ¶
type FailWorkflowExecutionCommandAttributes struct {
Failure *v12.Failure `protobuf:"bytes,1,opt,name=failure,proto3" json:"failure,omitempty"`
}
func (*FailWorkflowExecutionCommandAttributes) Descriptor ¶
func (*FailWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
func (*FailWorkflowExecutionCommandAttributes) Equal ¶
func (this *FailWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*FailWorkflowExecutionCommandAttributes) GetFailure ¶
func (m *FailWorkflowExecutionCommandAttributes) GetFailure() *v12.Failure
func (*FailWorkflowExecutionCommandAttributes) GoString ¶
func (this *FailWorkflowExecutionCommandAttributes) GoString() string
func (*FailWorkflowExecutionCommandAttributes) Marshal ¶
func (m *FailWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
func (*FailWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *FailWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*FailWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *FailWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FailWorkflowExecutionCommandAttributes) ProtoMessage ¶
func (*FailWorkflowExecutionCommandAttributes) ProtoMessage()
func (*FailWorkflowExecutionCommandAttributes) Reset ¶
func (m *FailWorkflowExecutionCommandAttributes) Reset()
func (*FailWorkflowExecutionCommandAttributes) Size ¶
func (m *FailWorkflowExecutionCommandAttributes) Size() (n int)
func (*FailWorkflowExecutionCommandAttributes) String ¶
func (this *FailWorkflowExecutionCommandAttributes) String() string
func (*FailWorkflowExecutionCommandAttributes) Unmarshal ¶
func (m *FailWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
func (*FailWorkflowExecutionCommandAttributes) XXX_DiscardUnknown ¶
func (m *FailWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
func (*FailWorkflowExecutionCommandAttributes) XXX_Marshal ¶
func (m *FailWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FailWorkflowExecutionCommandAttributes) XXX_Merge ¶
func (m *FailWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
func (*FailWorkflowExecutionCommandAttributes) XXX_Size ¶
func (m *FailWorkflowExecutionCommandAttributes) XXX_Size() int
func (*FailWorkflowExecutionCommandAttributes) XXX_Unmarshal ¶
func (m *FailWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
type ModifyWorkflowPropertiesCommandAttributes ¶ added in v1.12.0
type ModifyWorkflowPropertiesCommandAttributes struct { // If set, 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"` }
func (*ModifyWorkflowPropertiesCommandAttributes) Descriptor ¶ added in v1.12.0
func (*ModifyWorkflowPropertiesCommandAttributes) Descriptor() ([]byte, []int)
func (*ModifyWorkflowPropertiesCommandAttributes) Equal ¶ added in v1.12.0
func (this *ModifyWorkflowPropertiesCommandAttributes) Equal(that interface{}) bool
func (*ModifyWorkflowPropertiesCommandAttributes) GetUpsertedMemo ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) GetUpsertedMemo() *v1.Memo
func (*ModifyWorkflowPropertiesCommandAttributes) GoString ¶ added in v1.12.0
func (this *ModifyWorkflowPropertiesCommandAttributes) GoString() string
func (*ModifyWorkflowPropertiesCommandAttributes) Marshal ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) Marshal() (dAtA []byte, err error)
func (*ModifyWorkflowPropertiesCommandAttributes) MarshalTo ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*ModifyWorkflowPropertiesCommandAttributes) MarshalToSizedBuffer ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ModifyWorkflowPropertiesCommandAttributes) ProtoMessage ¶ added in v1.12.0
func (*ModifyWorkflowPropertiesCommandAttributes) ProtoMessage()
func (*ModifyWorkflowPropertiesCommandAttributes) Reset ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) Reset()
func (*ModifyWorkflowPropertiesCommandAttributes) Size ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) Size() (n int)
func (*ModifyWorkflowPropertiesCommandAttributes) String ¶ added in v1.12.0
func (this *ModifyWorkflowPropertiesCommandAttributes) String() string
func (*ModifyWorkflowPropertiesCommandAttributes) Unmarshal ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) Unmarshal(dAtA []byte) error
func (*ModifyWorkflowPropertiesCommandAttributes) XXX_DiscardUnknown ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_DiscardUnknown()
func (*ModifyWorkflowPropertiesCommandAttributes) XXX_Marshal ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ModifyWorkflowPropertiesCommandAttributes) XXX_Merge ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Merge(src proto.Message)
func (*ModifyWorkflowPropertiesCommandAttributes) XXX_Size ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Size() int
func (*ModifyWorkflowPropertiesCommandAttributes) XXX_Unmarshal ¶ added in v1.12.0
func (m *ModifyWorkflowPropertiesCommandAttributes) XXX_Unmarshal(b []byte) error
type RecordMarkerCommandAttributes ¶
type RecordMarkerCommandAttributes struct { MarkerName string `protobuf:"bytes,1,opt,name=marker_name,json=markerName,proto3" json:"marker_name,omitempty"` Details map[string]*v1.Payloads `` /* 155-byte string literal not displayed */ Header *v1.Header `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"` Failure *v12.Failure `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"` }
func (*RecordMarkerCommandAttributes) Descriptor ¶
func (*RecordMarkerCommandAttributes) Descriptor() ([]byte, []int)
func (*RecordMarkerCommandAttributes) Equal ¶
func (this *RecordMarkerCommandAttributes) Equal(that interface{}) bool
func (*RecordMarkerCommandAttributes) GetDetails ¶
func (m *RecordMarkerCommandAttributes) GetDetails() map[string]*v1.Payloads
func (*RecordMarkerCommandAttributes) GetFailure ¶
func (m *RecordMarkerCommandAttributes) GetFailure() *v12.Failure
func (*RecordMarkerCommandAttributes) GetHeader ¶
func (m *RecordMarkerCommandAttributes) GetHeader() *v1.Header
func (*RecordMarkerCommandAttributes) GetMarkerName ¶
func (m *RecordMarkerCommandAttributes) GetMarkerName() string
func (*RecordMarkerCommandAttributes) GoString ¶
func (this *RecordMarkerCommandAttributes) GoString() string
func (*RecordMarkerCommandAttributes) Marshal ¶
func (m *RecordMarkerCommandAttributes) Marshal() (dAtA []byte, err error)
func (*RecordMarkerCommandAttributes) MarshalTo ¶
func (m *RecordMarkerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*RecordMarkerCommandAttributes) MarshalToSizedBuffer ¶
func (m *RecordMarkerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RecordMarkerCommandAttributes) ProtoMessage ¶
func (*RecordMarkerCommandAttributes) ProtoMessage()
func (*RecordMarkerCommandAttributes) Reset ¶
func (m *RecordMarkerCommandAttributes) Reset()
func (*RecordMarkerCommandAttributes) Size ¶
func (m *RecordMarkerCommandAttributes) Size() (n int)
func (*RecordMarkerCommandAttributes) String ¶
func (this *RecordMarkerCommandAttributes) String() string
func (*RecordMarkerCommandAttributes) Unmarshal ¶
func (m *RecordMarkerCommandAttributes) Unmarshal(dAtA []byte) error
func (*RecordMarkerCommandAttributes) XXX_DiscardUnknown ¶
func (m *RecordMarkerCommandAttributes) XXX_DiscardUnknown()
func (*RecordMarkerCommandAttributes) XXX_Marshal ¶
func (m *RecordMarkerCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordMarkerCommandAttributes) XXX_Merge ¶
func (m *RecordMarkerCommandAttributes) XXX_Merge(src proto.Message)
func (*RecordMarkerCommandAttributes) XXX_Size ¶
func (m *RecordMarkerCommandAttributes) XXX_Size() int
func (*RecordMarkerCommandAttributes) XXX_Unmarshal ¶
func (m *RecordMarkerCommandAttributes) XXX_Unmarshal(b []byte) error
type RejectWorkflowUpdateCommandAttributes ¶ added in v1.13.0
type RejectWorkflowUpdateCommandAttributes struct { Meta *v14.Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` Failure *v12.Failure `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"` }
func (*RejectWorkflowUpdateCommandAttributes) Descriptor ¶ added in v1.13.0
func (*RejectWorkflowUpdateCommandAttributes) Descriptor() ([]byte, []int)
func (*RejectWorkflowUpdateCommandAttributes) Equal ¶ added in v1.13.0
func (this *RejectWorkflowUpdateCommandAttributes) Equal(that interface{}) bool
func (*RejectWorkflowUpdateCommandAttributes) GetFailure ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) GetFailure() *v12.Failure
func (*RejectWorkflowUpdateCommandAttributes) GetMeta ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) GetMeta() *v14.Meta
func (*RejectWorkflowUpdateCommandAttributes) GoString ¶ added in v1.13.0
func (this *RejectWorkflowUpdateCommandAttributes) GoString() string
func (*RejectWorkflowUpdateCommandAttributes) Marshal ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) Marshal() (dAtA []byte, err error)
func (*RejectWorkflowUpdateCommandAttributes) MarshalTo ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*RejectWorkflowUpdateCommandAttributes) MarshalToSizedBuffer ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RejectWorkflowUpdateCommandAttributes) ProtoMessage ¶ added in v1.13.0
func (*RejectWorkflowUpdateCommandAttributes) ProtoMessage()
func (*RejectWorkflowUpdateCommandAttributes) Reset ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) Reset()
func (*RejectWorkflowUpdateCommandAttributes) Size ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) Size() (n int)
func (*RejectWorkflowUpdateCommandAttributes) String ¶ added in v1.13.0
func (this *RejectWorkflowUpdateCommandAttributes) String() string
func (*RejectWorkflowUpdateCommandAttributes) Unmarshal ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) Unmarshal(dAtA []byte) error
func (*RejectWorkflowUpdateCommandAttributes) XXX_DiscardUnknown ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) XXX_DiscardUnknown()
func (*RejectWorkflowUpdateCommandAttributes) XXX_Marshal ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RejectWorkflowUpdateCommandAttributes) XXX_Merge ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) XXX_Merge(src proto.Message)
func (*RejectWorkflowUpdateCommandAttributes) XXX_Size ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) XXX_Size() int
func (*RejectWorkflowUpdateCommandAttributes) XXX_Unmarshal ¶ added in v1.13.0
func (m *RejectWorkflowUpdateCommandAttributes) XXX_Unmarshal(b []byte) error
type RequestCancelActivityTaskCommandAttributes ¶
type RequestCancelActivityTaskCommandAttributes struct { // The `ACTIVITY_TASK_SCHEDULED` event id for the activity being cancelled. ScheduledEventId int64 `protobuf:"varint,1,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"` }
func (*RequestCancelActivityTaskCommandAttributes) Descriptor ¶
func (*RequestCancelActivityTaskCommandAttributes) Descriptor() ([]byte, []int)
func (*RequestCancelActivityTaskCommandAttributes) Equal ¶
func (this *RequestCancelActivityTaskCommandAttributes) Equal(that interface{}) bool
func (*RequestCancelActivityTaskCommandAttributes) GetScheduledEventId ¶
func (m *RequestCancelActivityTaskCommandAttributes) GetScheduledEventId() int64
func (*RequestCancelActivityTaskCommandAttributes) GoString ¶
func (this *RequestCancelActivityTaskCommandAttributes) GoString() string
func (*RequestCancelActivityTaskCommandAttributes) Marshal ¶
func (m *RequestCancelActivityTaskCommandAttributes) Marshal() (dAtA []byte, err error)
func (*RequestCancelActivityTaskCommandAttributes) MarshalTo ¶
func (m *RequestCancelActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*RequestCancelActivityTaskCommandAttributes) MarshalToSizedBuffer ¶
func (m *RequestCancelActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequestCancelActivityTaskCommandAttributes) ProtoMessage ¶
func (*RequestCancelActivityTaskCommandAttributes) ProtoMessage()
func (*RequestCancelActivityTaskCommandAttributes) Reset ¶
func (m *RequestCancelActivityTaskCommandAttributes) Reset()
func (*RequestCancelActivityTaskCommandAttributes) Size ¶
func (m *RequestCancelActivityTaskCommandAttributes) Size() (n int)
func (*RequestCancelActivityTaskCommandAttributes) String ¶
func (this *RequestCancelActivityTaskCommandAttributes) String() string
func (*RequestCancelActivityTaskCommandAttributes) Unmarshal ¶
func (m *RequestCancelActivityTaskCommandAttributes) Unmarshal(dAtA []byte) error
func (*RequestCancelActivityTaskCommandAttributes) XXX_DiscardUnknown ¶
func (m *RequestCancelActivityTaskCommandAttributes) XXX_DiscardUnknown()
func (*RequestCancelActivityTaskCommandAttributes) XXX_Marshal ¶
func (m *RequestCancelActivityTaskCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestCancelActivityTaskCommandAttributes) XXX_Merge ¶
func (m *RequestCancelActivityTaskCommandAttributes) XXX_Merge(src proto.Message)
func (*RequestCancelActivityTaskCommandAttributes) XXX_Size ¶
func (m *RequestCancelActivityTaskCommandAttributes) XXX_Size() int
func (*RequestCancelActivityTaskCommandAttributes) XXX_Unmarshal ¶
func (m *RequestCancelActivityTaskCommandAttributes) XXX_Unmarshal(b []byte) error
type RequestCancelExternalWorkflowExecutionCommandAttributes ¶
type RequestCancelExternalWorkflowExecutionCommandAttributes struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"` RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` // Deprecated. Control string `protobuf:"bytes,4,opt,name=control,proto3" json:"control,omitempty"` // Set this to true if the workflow being cancelled is a child of the workflow originating this // command. The request will be rejected if it is set to true and the target workflow is *not* // a child of the requesting workflow. ChildWorkflowOnly bool `protobuf:"varint,5,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"` // Reason for requesting the cancellation Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` }
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Descriptor ¶
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Equal ¶
func (this *RequestCancelExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly() bool
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetControl ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetControl() string
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetNamespace ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetNamespace() string
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetReason ¶ added in v1.8.0
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetReason() string
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetRunId ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetRunId() string
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GetWorkflowId ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) GetWorkflowId() string
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) GoString ¶
func (this *RequestCancelExternalWorkflowExecutionCommandAttributes) GoString() string
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Marshal ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoMessage ¶
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) ProtoMessage()
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Reset ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Reset()
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Size ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Size() (n int)
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) String ¶
func (this *RequestCancelExternalWorkflowExecutionCommandAttributes) String() string
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) Unmarshal ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_DiscardUnknown ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Marshal ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Merge ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Size ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Size() int
func (*RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Unmarshal ¶
func (m *RequestCancelExternalWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
type ScheduleActivityTaskCommandAttributes ¶
type ScheduleActivityTaskCommandAttributes struct { ActivityId string `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"` ActivityType *v1.ActivityType `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"` TaskQueue *v11.TaskQueue `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` Header *v1.Header `protobuf:"bytes,5,opt,name=header,proto3" json:"header,omitempty"` Input *v1.Payloads `protobuf:"bytes,6,opt,name=input,proto3" json:"input,omitempty"` // Indicates how long the caller is willing to wait for activity completion. The "schedule" time // is when the activity is initially scheduled, not when the most recent retry is scheduled. // Limits how long retries will be attempted. Either this or `start_to_close_timeout` must be // specified. When not specified, defaults to the workflow execution timeout. // // (-- api-linter: core::0140::prepositions=disabled // aip.dev/not-precedent: "to" is used to indicate interval. --) ScheduleToCloseTimeout *time.Duration `` /* 143-byte string literal not displayed */ // Limits the time an activity task can stay in a task queue before a worker picks it up. The // "schedule" time is when the most recent retry is scheduled. This timeout should usually not // be set: it's useful in specific scenarios like worker-specific task queues. 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 that is not // specified. More info: // https://docs.temporal.io/docs/content/what-is-a-schedule-to-start-timeout/ // // (-- api-linter: core::0140::prepositions=disabled // aip.dev/not-precedent: "to" is used to indicate interval. --) ScheduleToStartTimeout *time.Duration `` /* 143-byte string literal not displayed */ // Maximum time an activity is allowed to execute after being picked up by a worker. This // timeout is always retryable. Either this or `schedule_to_close_timeout` must be specified. // // (-- api-linter: core::0140::prepositions=disabled // aip.dev/not-precedent: "to" is used to indicate interval. --) StartToCloseTimeout *time.Duration `` /* 134-byte string literal not displayed */ // Maximum permitted time between successful worker heartbeats. HeartbeatTimeout *time.Duration `protobuf:"bytes,10,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3,stdduration" json:"heartbeat_timeout,omitempty"` // Activities are provided by a default retry policy which is controlled through the service's // dynamic configuration. Retries will be attempted until `schedule_to_close_timeout` has // elapsed. To disable retries set retry_policy.maximum_attempts to 1. RetryPolicy *v1.RetryPolicy `protobuf:"bytes,11,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` // Request to start the activity directly bypassing matching service and worker polling // The slot for executing the activity should be reserved when setting this field to true. RequestEagerExecution bool `` /* 128-byte string literal not displayed */ }
func (*ScheduleActivityTaskCommandAttributes) Descriptor ¶
func (*ScheduleActivityTaskCommandAttributes) Descriptor() ([]byte, []int)
func (*ScheduleActivityTaskCommandAttributes) Equal ¶
func (this *ScheduleActivityTaskCommandAttributes) Equal(that interface{}) bool
func (*ScheduleActivityTaskCommandAttributes) GetActivityId ¶
func (m *ScheduleActivityTaskCommandAttributes) GetActivityId() string
func (*ScheduleActivityTaskCommandAttributes) GetActivityType ¶
func (m *ScheduleActivityTaskCommandAttributes) GetActivityType() *v1.ActivityType
func (*ScheduleActivityTaskCommandAttributes) GetHeader ¶
func (m *ScheduleActivityTaskCommandAttributes) GetHeader() *v1.Header
func (*ScheduleActivityTaskCommandAttributes) GetHeartbeatTimeout ¶ added in v0.28.0
func (m *ScheduleActivityTaskCommandAttributes) GetHeartbeatTimeout() *time.Duration
func (*ScheduleActivityTaskCommandAttributes) GetInput ¶
func (m *ScheduleActivityTaskCommandAttributes) GetInput() *v1.Payloads
func (*ScheduleActivityTaskCommandAttributes) GetRequestEagerExecution ¶ added in v1.8.0
func (m *ScheduleActivityTaskCommandAttributes) GetRequestEagerExecution() bool
func (*ScheduleActivityTaskCommandAttributes) GetRetryPolicy ¶
func (m *ScheduleActivityTaskCommandAttributes) GetRetryPolicy() *v1.RetryPolicy
func (*ScheduleActivityTaskCommandAttributes) GetScheduleToCloseTimeout ¶ added in v0.28.0
func (m *ScheduleActivityTaskCommandAttributes) GetScheduleToCloseTimeout() *time.Duration
func (*ScheduleActivityTaskCommandAttributes) GetScheduleToStartTimeout ¶ added in v0.28.0
func (m *ScheduleActivityTaskCommandAttributes) GetScheduleToStartTimeout() *time.Duration
func (*ScheduleActivityTaskCommandAttributes) GetStartToCloseTimeout ¶ added in v0.28.0
func (m *ScheduleActivityTaskCommandAttributes) GetStartToCloseTimeout() *time.Duration
func (*ScheduleActivityTaskCommandAttributes) GetTaskQueue ¶
func (m *ScheduleActivityTaskCommandAttributes) GetTaskQueue() *v11.TaskQueue
func (*ScheduleActivityTaskCommandAttributes) GoString ¶
func (this *ScheduleActivityTaskCommandAttributes) GoString() string
func (*ScheduleActivityTaskCommandAttributes) Marshal ¶
func (m *ScheduleActivityTaskCommandAttributes) Marshal() (dAtA []byte, err error)
func (*ScheduleActivityTaskCommandAttributes) MarshalTo ¶
func (m *ScheduleActivityTaskCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*ScheduleActivityTaskCommandAttributes) MarshalToSizedBuffer ¶
func (m *ScheduleActivityTaskCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ScheduleActivityTaskCommandAttributes) ProtoMessage ¶
func (*ScheduleActivityTaskCommandAttributes) ProtoMessage()
func (*ScheduleActivityTaskCommandAttributes) Reset ¶
func (m *ScheduleActivityTaskCommandAttributes) Reset()
func (*ScheduleActivityTaskCommandAttributes) Size ¶
func (m *ScheduleActivityTaskCommandAttributes) Size() (n int)
func (*ScheduleActivityTaskCommandAttributes) String ¶
func (this *ScheduleActivityTaskCommandAttributes) String() string
func (*ScheduleActivityTaskCommandAttributes) Unmarshal ¶
func (m *ScheduleActivityTaskCommandAttributes) Unmarshal(dAtA []byte) error
func (*ScheduleActivityTaskCommandAttributes) XXX_DiscardUnknown ¶
func (m *ScheduleActivityTaskCommandAttributes) XXX_DiscardUnknown()
func (*ScheduleActivityTaskCommandAttributes) XXX_Marshal ¶
func (m *ScheduleActivityTaskCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScheduleActivityTaskCommandAttributes) XXX_Merge ¶
func (m *ScheduleActivityTaskCommandAttributes) XXX_Merge(src proto.Message)
func (*ScheduleActivityTaskCommandAttributes) XXX_Size ¶
func (m *ScheduleActivityTaskCommandAttributes) XXX_Size() int
func (*ScheduleActivityTaskCommandAttributes) XXX_Unmarshal ¶
func (m *ScheduleActivityTaskCommandAttributes) XXX_Unmarshal(b []byte) error
type SignalExternalWorkflowExecutionCommandAttributes ¶
type SignalExternalWorkflowExecutionCommandAttributes struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Execution *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"` // The workflow author-defined name of the signal to send to the workflow. SignalName string `protobuf:"bytes,3,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"` // Serialized value(s) to provide with the signal. Input *v1.Payloads `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"` // Deprecated Control string `protobuf:"bytes,5,opt,name=control,proto3" json:"control,omitempty"` // Set this to true if the workflow being cancelled is a child of the workflow originating this // command. The request will be rejected if it is set to true and the target workflow is *not* // a child of the requesting workflow. ChildWorkflowOnly bool `protobuf:"varint,6,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"` // Headers that are passed by the workflow that is sending a signal to the external // workflow that is receiving this signal. Header *v1.Header `protobuf:"bytes,7,opt,name=header,proto3" json:"header,omitempty"` }
func (*SignalExternalWorkflowExecutionCommandAttributes) Descriptor ¶
func (*SignalExternalWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
func (*SignalExternalWorkflowExecutionCommandAttributes) Equal ¶
func (this *SignalExternalWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*SignalExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) GetChildWorkflowOnly() bool
func (*SignalExternalWorkflowExecutionCommandAttributes) GetControl ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) GetControl() string
func (*SignalExternalWorkflowExecutionCommandAttributes) GetExecution ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) GetExecution() *v1.WorkflowExecution
func (*SignalExternalWorkflowExecutionCommandAttributes) GetHeader ¶ added in v1.6.0
func (m *SignalExternalWorkflowExecutionCommandAttributes) GetHeader() *v1.Header
func (*SignalExternalWorkflowExecutionCommandAttributes) GetInput ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads
func (*SignalExternalWorkflowExecutionCommandAttributes) GetNamespace ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) GetNamespace() string
func (*SignalExternalWorkflowExecutionCommandAttributes) GetSignalName ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) GetSignalName() string
func (*SignalExternalWorkflowExecutionCommandAttributes) GoString ¶
func (this *SignalExternalWorkflowExecutionCommandAttributes) GoString() string
func (*SignalExternalWorkflowExecutionCommandAttributes) Marshal ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
func (*SignalExternalWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*SignalExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoMessage ¶
func (*SignalExternalWorkflowExecutionCommandAttributes) ProtoMessage()
func (*SignalExternalWorkflowExecutionCommandAttributes) Reset ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) Reset()
func (*SignalExternalWorkflowExecutionCommandAttributes) Size ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) Size() (n int)
func (*SignalExternalWorkflowExecutionCommandAttributes) String ¶
func (this *SignalExternalWorkflowExecutionCommandAttributes) String() string
func (*SignalExternalWorkflowExecutionCommandAttributes) Unmarshal ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
func (*SignalExternalWorkflowExecutionCommandAttributes) XXX_DiscardUnknown ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
func (*SignalExternalWorkflowExecutionCommandAttributes) XXX_Marshal ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SignalExternalWorkflowExecutionCommandAttributes) XXX_Merge ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
func (*SignalExternalWorkflowExecutionCommandAttributes) XXX_Size ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Size() int
func (*SignalExternalWorkflowExecutionCommandAttributes) XXX_Unmarshal ¶
func (m *SignalExternalWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
type StartChildWorkflowExecutionCommandAttributes ¶
type StartChildWorkflowExecutionCommandAttributes struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"` WorkflowType *v1.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"` TaskQueue *v11.TaskQueue `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"` Input *v1.Payloads `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"` // Total workflow execution timeout including retries and continue as new. WorkflowExecutionTimeout *time.Duration `` /* 147-byte string literal not displayed */ // Timeout of a single workflow run. WorkflowRunTimeout *time.Duration `` /* 129-byte string literal not displayed */ // Timeout of a single workflow task. WorkflowTaskTimeout *time.Duration `` /* 132-byte string literal not displayed */ // Default: PARENT_CLOSE_POLICY_TERMINATE. ParentClosePolicy v13.ParentClosePolicy `` /* 160-byte string literal not displayed */ Control string `protobuf:"bytes,10,opt,name=control,proto3" json:"control,omitempty"` // Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE. WorkflowIdReusePolicy v13.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */ RetryPolicy *v1.RetryPolicy `protobuf:"bytes,12,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"` // Establish a cron schedule for the child workflow. CronSchedule string `protobuf:"bytes,13,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"` Header *v1.Header `protobuf:"bytes,14,opt,name=header,proto3" json:"header,omitempty"` Memo *v1.Memo `protobuf:"bytes,15,opt,name=memo,proto3" json:"memo,omitempty"` SearchAttributes *v1.SearchAttributes `protobuf:"bytes,16,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"` }
func (*StartChildWorkflowExecutionCommandAttributes) Descriptor ¶
func (*StartChildWorkflowExecutionCommandAttributes) Descriptor() ([]byte, []int)
func (*StartChildWorkflowExecutionCommandAttributes) Equal ¶
func (this *StartChildWorkflowExecutionCommandAttributes) Equal(that interface{}) bool
func (*StartChildWorkflowExecutionCommandAttributes) GetControl ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetControl() string
func (*StartChildWorkflowExecutionCommandAttributes) GetCronSchedule ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetCronSchedule() string
func (*StartChildWorkflowExecutionCommandAttributes) GetHeader ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetHeader() *v1.Header
func (*StartChildWorkflowExecutionCommandAttributes) GetInput ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetInput() *v1.Payloads
func (*StartChildWorkflowExecutionCommandAttributes) GetMemo ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetMemo() *v1.Memo
func (*StartChildWorkflowExecutionCommandAttributes) GetNamespace ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetNamespace() string
func (*StartChildWorkflowExecutionCommandAttributes) GetParentClosePolicy ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetParentClosePolicy() v13.ParentClosePolicy
func (*StartChildWorkflowExecutionCommandAttributes) GetRetryPolicy ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetRetryPolicy() *v1.RetryPolicy
func (*StartChildWorkflowExecutionCommandAttributes) GetSearchAttributes ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetSearchAttributes() *v1.SearchAttributes
func (*StartChildWorkflowExecutionCommandAttributes) GetTaskQueue ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetTaskQueue() *v11.TaskQueue
func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowExecutionTimeout ¶ added in v0.28.0
func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowExecutionTimeout() *time.Duration
func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowId ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowId() string
func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowIdReusePolicy ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowIdReusePolicy() v13.WorkflowIdReusePolicy
func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout ¶ added in v0.28.0
func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowRunTimeout() *time.Duration
func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout ¶ added in v0.28.0
func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowTaskTimeout() *time.Duration
func (*StartChildWorkflowExecutionCommandAttributes) GetWorkflowType ¶
func (m *StartChildWorkflowExecutionCommandAttributes) GetWorkflowType() *v1.WorkflowType
func (*StartChildWorkflowExecutionCommandAttributes) GoString ¶
func (this *StartChildWorkflowExecutionCommandAttributes) GoString() string
func (*StartChildWorkflowExecutionCommandAttributes) Marshal ¶
func (m *StartChildWorkflowExecutionCommandAttributes) Marshal() (dAtA []byte, err error)
func (*StartChildWorkflowExecutionCommandAttributes) MarshalTo ¶
func (m *StartChildWorkflowExecutionCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*StartChildWorkflowExecutionCommandAttributes) MarshalToSizedBuffer ¶
func (m *StartChildWorkflowExecutionCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StartChildWorkflowExecutionCommandAttributes) ProtoMessage ¶
func (*StartChildWorkflowExecutionCommandAttributes) ProtoMessage()
func (*StartChildWorkflowExecutionCommandAttributes) Reset ¶
func (m *StartChildWorkflowExecutionCommandAttributes) Reset()
func (*StartChildWorkflowExecutionCommandAttributes) Size ¶
func (m *StartChildWorkflowExecutionCommandAttributes) Size() (n int)
func (*StartChildWorkflowExecutionCommandAttributes) String ¶
func (this *StartChildWorkflowExecutionCommandAttributes) String() string
func (*StartChildWorkflowExecutionCommandAttributes) Unmarshal ¶
func (m *StartChildWorkflowExecutionCommandAttributes) Unmarshal(dAtA []byte) error
func (*StartChildWorkflowExecutionCommandAttributes) XXX_DiscardUnknown ¶
func (m *StartChildWorkflowExecutionCommandAttributes) XXX_DiscardUnknown()
func (*StartChildWorkflowExecutionCommandAttributes) XXX_Marshal ¶
func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartChildWorkflowExecutionCommandAttributes) XXX_Merge ¶
func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Merge(src proto.Message)
func (*StartChildWorkflowExecutionCommandAttributes) XXX_Size ¶
func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Size() int
func (*StartChildWorkflowExecutionCommandAttributes) XXX_Unmarshal ¶
func (m *StartChildWorkflowExecutionCommandAttributes) XXX_Unmarshal(b []byte) error
type StartTimerCommandAttributes ¶
type StartTimerCommandAttributes struct { // An id for the timer, currently live timers must have different ids. Typically autogenerated // by the SDK. TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"` // How long until the timer fires, producing a `TIMER_FIRED` event. // // (-- api-linter: core::0140::prepositions=disabled // aip.dev/not-precedent: "to" is used to indicate interval. --) StartToFireTimeout *time.Duration `` /* 131-byte string literal not displayed */ }
func (*StartTimerCommandAttributes) Descriptor ¶
func (*StartTimerCommandAttributes) Descriptor() ([]byte, []int)
func (*StartTimerCommandAttributes) Equal ¶
func (this *StartTimerCommandAttributes) Equal(that interface{}) bool
func (*StartTimerCommandAttributes) GetStartToFireTimeout ¶ added in v0.28.0
func (m *StartTimerCommandAttributes) GetStartToFireTimeout() *time.Duration
func (*StartTimerCommandAttributes) GetTimerId ¶
func (m *StartTimerCommandAttributes) GetTimerId() string
func (*StartTimerCommandAttributes) GoString ¶
func (this *StartTimerCommandAttributes) GoString() string
func (*StartTimerCommandAttributes) Marshal ¶
func (m *StartTimerCommandAttributes) Marshal() (dAtA []byte, err error)
func (*StartTimerCommandAttributes) MarshalTo ¶
func (m *StartTimerCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*StartTimerCommandAttributes) MarshalToSizedBuffer ¶
func (m *StartTimerCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StartTimerCommandAttributes) ProtoMessage ¶
func (*StartTimerCommandAttributes) ProtoMessage()
func (*StartTimerCommandAttributes) Reset ¶
func (m *StartTimerCommandAttributes) Reset()
func (*StartTimerCommandAttributes) Size ¶
func (m *StartTimerCommandAttributes) Size() (n int)
func (*StartTimerCommandAttributes) String ¶
func (this *StartTimerCommandAttributes) String() string
func (*StartTimerCommandAttributes) Unmarshal ¶
func (m *StartTimerCommandAttributes) Unmarshal(dAtA []byte) error
func (*StartTimerCommandAttributes) XXX_DiscardUnknown ¶
func (m *StartTimerCommandAttributes) XXX_DiscardUnknown()
func (*StartTimerCommandAttributes) XXX_Marshal ¶
func (m *StartTimerCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartTimerCommandAttributes) XXX_Merge ¶
func (m *StartTimerCommandAttributes) XXX_Merge(src proto.Message)
func (*StartTimerCommandAttributes) XXX_Size ¶
func (m *StartTimerCommandAttributes) XXX_Size() int
func (*StartTimerCommandAttributes) XXX_Unmarshal ¶
func (m *StartTimerCommandAttributes) XXX_Unmarshal(b []byte) error
type UpsertWorkflowSearchAttributesCommandAttributes ¶
type UpsertWorkflowSearchAttributesCommandAttributes struct {
SearchAttributes *v1.SearchAttributes `protobuf:"bytes,1,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
}
func (*UpsertWorkflowSearchAttributesCommandAttributes) Descriptor ¶
func (*UpsertWorkflowSearchAttributesCommandAttributes) Descriptor() ([]byte, []int)
func (*UpsertWorkflowSearchAttributesCommandAttributes) Equal ¶
func (this *UpsertWorkflowSearchAttributesCommandAttributes) Equal(that interface{}) bool
func (*UpsertWorkflowSearchAttributesCommandAttributes) GetSearchAttributes ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) GetSearchAttributes() *v1.SearchAttributes
func (*UpsertWorkflowSearchAttributesCommandAttributes) GoString ¶
func (this *UpsertWorkflowSearchAttributesCommandAttributes) GoString() string
func (*UpsertWorkflowSearchAttributesCommandAttributes) Marshal ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) Marshal() (dAtA []byte, err error)
func (*UpsertWorkflowSearchAttributesCommandAttributes) MarshalTo ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) MarshalTo(dAtA []byte) (int, error)
func (*UpsertWorkflowSearchAttributesCommandAttributes) MarshalToSizedBuffer ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoMessage ¶
func (*UpsertWorkflowSearchAttributesCommandAttributes) ProtoMessage()
func (*UpsertWorkflowSearchAttributesCommandAttributes) Reset ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) Reset()
func (*UpsertWorkflowSearchAttributesCommandAttributes) Size ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) Size() (n int)
func (*UpsertWorkflowSearchAttributesCommandAttributes) String ¶
func (this *UpsertWorkflowSearchAttributesCommandAttributes) String() string
func (*UpsertWorkflowSearchAttributesCommandAttributes) Unmarshal ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) Unmarshal(dAtA []byte) error
func (*UpsertWorkflowSearchAttributesCommandAttributes) XXX_DiscardUnknown ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_DiscardUnknown()
func (*UpsertWorkflowSearchAttributesCommandAttributes) XXX_Marshal ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpsertWorkflowSearchAttributesCommandAttributes) XXX_Merge ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Merge(src proto.Message)
func (*UpsertWorkflowSearchAttributesCommandAttributes) XXX_Size ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Size() int
func (*UpsertWorkflowSearchAttributesCommandAttributes) XXX_Unmarshal ¶
func (m *UpsertWorkflowSearchAttributesCommandAttributes) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.