command

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2021 License: MIT Imports: 15 Imported by: 12

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type CancelTimerCommandAttributes 

type CancelTimerCommandAttributes struct {
	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
	Attributes isCommand_Attributes `protobuf_oneof:"attributes"`
}

func (*Command) Descriptor 

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

func (*Command) Equal 

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

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) GetContinueAsNewWorkflowExecutionCommandAttributes 

func (m *Command) GetContinueAsNewWorkflowExecutionCommandAttributes() *ContinueAsNewWorkflowExecutionCommandAttributes

func (*Command) GetFailWorkflowExecutionCommandAttributes 

func (m *Command) GetFailWorkflowExecutionCommandAttributes() *FailWorkflowExecutionCommandAttributes

func (*Command) GetRecordMarkerCommandAttributes 

func (m *Command) GetRecordMarkerCommandAttributes() *RecordMarkerCommandAttributes

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) GoString 

func (this *Command) GoString() string

func (*Command) Marshal 

func (m *Command) Marshal() (dAtA []byte, err error)

func (*Command) MarshalTo 

func (m *Command) MarshalTo(dAtA []byte) (int, error)

func (*Command) MarshalToSizedBuffer 

func (m *Command) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

func (m *Command) Size() (n int)

func (*Command) String 

func (this *Command) String() string

func (*Command) Unmarshal 

func (m *Command) Unmarshal(dAtA []byte) error

func (*Command) XXX_DiscardUnknown 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal 

func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command) XXX_Merge 

func (m *Command) XXX_Merge(src proto.Message)

func (*Command) XXX_OneofWrappers 

func (*Command) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Command) XXX_Size 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal 

func (m *Command) XXX_Unmarshal(b []byte) error

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_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_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_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 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"`
	// workflow_execution_timeout is omitted as it shouldn'be overridden from within a workflow.
	// 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 */
	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"`
	Initiator            v13.ContinueAsNewInitiator `protobuf:"varint,8,opt,name=initiator,proto3,enum=temporal.api.enums.v1.ContinueAsNewInitiator" json:"initiator,omitempty"`
	Failure              *v12.Failure               `protobuf:"bytes,9,opt,name=failure,proto3" json:"failure,omitempty"`
	LastCompletionResult *v1.Payloads               `protobuf:"bytes,10,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"`
	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 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 RequestCancelActivityTaskCommandAttributes 

type RequestCancelActivityTaskCommandAttributes struct {
	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"`
	Control           string `protobuf:"bytes,4,opt,name=control,proto3" json:"control,omitempty"`
	ChildWorkflowOnly bool   `protobuf:"varint,5,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,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) 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"`
	Namespace    string           `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,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"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	// Indicates how long the caller is willing to wait for an activity completion.
	// Limits for how long retries are happening. Either this or start_to_close_timeout_seconds must be specified.
	// When not specified defaults to the workflow execution timeout.
	ScheduleToCloseTimeout *time.Duration `` /* 143-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	// Limits time an activity task can stay in a task queue before a worker picks it up.
	// This timeout is always non retryable as all a retry would achieve is to put it back into the same queue.
	// Defaults to schedule_to_close_timeout_seconds or workflow execution timeout if not specified.
	ScheduleToStartTimeout *time.Duration `` /* 143-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	// Maximum time an activity is allowed to execute after a pick up by a worker.
	// This timeout is always retryable. Either this or schedule_to_close_timeout_seconds must be specified.
	StartToCloseTimeout *time.Duration `` /* 134-byte string literal not displayed */
	// Maximum 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 controlled through the service dynamic configuration.
	// Retries are happening up to schedule_to_close_timeout.
	// To disable retries set retry_policy.maximum_attempts to 1.
	RetryPolicy *v1.RetryPolicy `protobuf:"bytes,11,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
}

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) GetNamespace 

func (m *ScheduleActivityTaskCommandAttributes) GetNamespace() string

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"`
	SignalName        string                `protobuf:"bytes,3,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	Input             *v1.Payloads          `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	Control           string                `protobuf:"bytes,5,opt,name=control,proto3" json:"control,omitempty"`
	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"`
	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 {
	TimerId string `protobuf:"bytes,1,opt,name=timer_id,json=timerId,proto3" json:"timer_id,omitempty"`
	// (-- 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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