historyservice

package
v1.22.2 Latest Latest
Warning

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

Go to latest
Published: Nov 13, 2023 License: MIT Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterHistoryServiceServer

func RegisterHistoryServiceServer(s *grpc.Server, srv HistoryServiceServer)

Types

type CloseShardRequest

type CloseShardRequest struct {
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
}

func (*CloseShardRequest) Descriptor

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

func (*CloseShardRequest) Equal

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

func (*CloseShardRequest) GetShardId

func (m *CloseShardRequest) GetShardId() int32

func (*CloseShardRequest) GoString

func (this *CloseShardRequest) GoString() string

func (*CloseShardRequest) Marshal

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

func (*CloseShardRequest) MarshalTo

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

func (*CloseShardRequest) MarshalToSizedBuffer

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

func (*CloseShardRequest) ProtoMessage

func (*CloseShardRequest) ProtoMessage()

func (*CloseShardRequest) Reset

func (m *CloseShardRequest) Reset()

func (*CloseShardRequest) Size

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

func (*CloseShardRequest) String

func (this *CloseShardRequest) String() string

func (*CloseShardRequest) Unmarshal

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

func (*CloseShardRequest) XXX_DiscardUnknown

func (m *CloseShardRequest) XXX_DiscardUnknown()

func (*CloseShardRequest) XXX_Marshal

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

func (*CloseShardRequest) XXX_Merge

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

func (*CloseShardRequest) XXX_Size

func (m *CloseShardRequest) XXX_Size() int

func (*CloseShardRequest) XXX_Unmarshal

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

type CloseShardResponse

type CloseShardResponse struct {
}

func (*CloseShardResponse) Descriptor

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

func (*CloseShardResponse) Equal

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

func (*CloseShardResponse) GoString

func (this *CloseShardResponse) GoString() string

func (*CloseShardResponse) Marshal

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

func (*CloseShardResponse) MarshalTo

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

func (*CloseShardResponse) MarshalToSizedBuffer

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

func (*CloseShardResponse) ProtoMessage

func (*CloseShardResponse) ProtoMessage()

func (*CloseShardResponse) Reset

func (m *CloseShardResponse) Reset()

func (*CloseShardResponse) Size

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

func (*CloseShardResponse) String

func (this *CloseShardResponse) String() string

func (*CloseShardResponse) Unmarshal

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

func (*CloseShardResponse) XXX_DiscardUnknown

func (m *CloseShardResponse) XXX_DiscardUnknown()

func (*CloseShardResponse) XXX_Marshal

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

func (*CloseShardResponse) XXX_Merge

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

func (*CloseShardResponse) XXX_Size

func (m *CloseShardResponse) XXX_Size() int

func (*CloseShardResponse) XXX_Unmarshal

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

type DeleteWorkflowExecutionRequest added in v1.15.0

type DeleteWorkflowExecutionRequest struct {
	NamespaceId        string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution  *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	WorkflowVersion    int64                  `protobuf:"varint,3,opt,name=workflow_version,json=workflowVersion,proto3" json:"workflow_version,omitempty"`
	ClosedWorkflowOnly bool                   `protobuf:"varint,4,opt,name=closed_workflow_only,json=closedWorkflowOnly,proto3" json:"closed_workflow_only,omitempty"`
}

func (*DeleteWorkflowExecutionRequest) Descriptor added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) Equal added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) GetClosedWorkflowOnly added in v1.17.3

func (m *DeleteWorkflowExecutionRequest) GetClosedWorkflowOnly() bool

func (*DeleteWorkflowExecutionRequest) GetNamespaceId added in v1.15.0

func (m *DeleteWorkflowExecutionRequest) GetNamespaceId() string

func (*DeleteWorkflowExecutionRequest) GetWorkflowExecution added in v1.15.0

func (m *DeleteWorkflowExecutionRequest) GetWorkflowExecution() *v14.WorkflowExecution

func (*DeleteWorkflowExecutionRequest) GetWorkflowVersion added in v1.17.3

func (m *DeleteWorkflowExecutionRequest) GetWorkflowVersion() int64

func (*DeleteWorkflowExecutionRequest) GoString added in v1.15.0

func (this *DeleteWorkflowExecutionRequest) GoString() string

func (*DeleteWorkflowExecutionRequest) Marshal added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) MarshalTo added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) MarshalToSizedBuffer added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) ProtoMessage added in v1.15.0

func (*DeleteWorkflowExecutionRequest) ProtoMessage()

func (*DeleteWorkflowExecutionRequest) Reset added in v1.15.0

func (m *DeleteWorkflowExecutionRequest) Reset()

func (*DeleteWorkflowExecutionRequest) Size added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) String added in v1.15.0

func (this *DeleteWorkflowExecutionRequest) String() string

func (*DeleteWorkflowExecutionRequest) Unmarshal added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) XXX_DiscardUnknown added in v1.15.0

func (m *DeleteWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*DeleteWorkflowExecutionRequest) XXX_Marshal added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) XXX_Merge added in v1.15.0

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

func (*DeleteWorkflowExecutionRequest) XXX_Size added in v1.15.0

func (m *DeleteWorkflowExecutionRequest) XXX_Size() int

func (*DeleteWorkflowExecutionRequest) XXX_Unmarshal added in v1.15.0

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

type DeleteWorkflowExecutionResponse added in v1.15.0

type DeleteWorkflowExecutionResponse struct {
}

func (*DeleteWorkflowExecutionResponse) Descriptor added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) Equal added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) GoString added in v1.15.0

func (this *DeleteWorkflowExecutionResponse) GoString() string

func (*DeleteWorkflowExecutionResponse) Marshal added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) MarshalTo added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) MarshalToSizedBuffer added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) ProtoMessage added in v1.15.0

func (*DeleteWorkflowExecutionResponse) ProtoMessage()

func (*DeleteWorkflowExecutionResponse) Reset added in v1.15.0

func (*DeleteWorkflowExecutionResponse) Size added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) String added in v1.15.0

func (this *DeleteWorkflowExecutionResponse) String() string

func (*DeleteWorkflowExecutionResponse) Unmarshal added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) XXX_DiscardUnknown added in v1.15.0

func (m *DeleteWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*DeleteWorkflowExecutionResponse) XXX_Marshal added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) XXX_Merge added in v1.15.0

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

func (*DeleteWorkflowExecutionResponse) XXX_Size added in v1.15.0

func (m *DeleteWorkflowExecutionResponse) XXX_Size() int

func (*DeleteWorkflowExecutionResponse) XXX_Unmarshal added in v1.15.0

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

type DeleteWorkflowVisibilityRecordRequest added in v1.17.0

type DeleteWorkflowVisibilityRecordRequest struct {
	NamespaceId       string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution         *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	WorkflowStartTime *time.Time             `protobuf:"bytes,3,opt,name=workflow_start_time,json=workflowStartTime,proto3,stdtime" json:"workflow_start_time,omitempty"`
	WorkflowCloseTime *time.Time             `protobuf:"bytes,4,opt,name=workflow_close_time,json=workflowCloseTime,proto3,stdtime" json:"workflow_close_time,omitempty"`
}

func (*DeleteWorkflowVisibilityRecordRequest) Descriptor added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordRequest) Equal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordRequest) GetExecution added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) GetNamespaceId added in v1.17.0

func (m *DeleteWorkflowVisibilityRecordRequest) GetNamespaceId() string

func (*DeleteWorkflowVisibilityRecordRequest) GetWorkflowCloseTime added in v1.17.0

func (m *DeleteWorkflowVisibilityRecordRequest) GetWorkflowCloseTime() *time.Time

func (*DeleteWorkflowVisibilityRecordRequest) GetWorkflowStartTime added in v1.17.0

func (m *DeleteWorkflowVisibilityRecordRequest) GetWorkflowStartTime() *time.Time

func (*DeleteWorkflowVisibilityRecordRequest) GoString added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) Marshal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordRequest) MarshalTo added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordRequest) MarshalToSizedBuffer added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordRequest) ProtoMessage added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) ProtoMessage()

func (*DeleteWorkflowVisibilityRecordRequest) Reset added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) Size added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) String added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) Unmarshal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordRequest) XXX_DiscardUnknown added in v1.17.0

func (m *DeleteWorkflowVisibilityRecordRequest) XXX_DiscardUnknown()

func (*DeleteWorkflowVisibilityRecordRequest) XXX_Marshal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordRequest) XXX_Merge added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) XXX_Size added in v1.17.0

func (*DeleteWorkflowVisibilityRecordRequest) XXX_Unmarshal added in v1.17.0

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

type DeleteWorkflowVisibilityRecordResponse added in v1.17.0

type DeleteWorkflowVisibilityRecordResponse struct {
}

func (*DeleteWorkflowVisibilityRecordResponse) Descriptor added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordResponse) Equal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordResponse) GoString added in v1.17.0

func (*DeleteWorkflowVisibilityRecordResponse) Marshal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordResponse) MarshalTo added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordResponse) MarshalToSizedBuffer added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordResponse) ProtoMessage added in v1.17.0

func (*DeleteWorkflowVisibilityRecordResponse) Reset added in v1.17.0

func (*DeleteWorkflowVisibilityRecordResponse) Size added in v1.17.0

func (*DeleteWorkflowVisibilityRecordResponse) String added in v1.17.0

func (*DeleteWorkflowVisibilityRecordResponse) Unmarshal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordResponse) XXX_DiscardUnknown added in v1.17.0

func (m *DeleteWorkflowVisibilityRecordResponse) XXX_DiscardUnknown()

func (*DeleteWorkflowVisibilityRecordResponse) XXX_Marshal added in v1.17.0

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

func (*DeleteWorkflowVisibilityRecordResponse) XXX_Merge added in v1.17.0

func (*DeleteWorkflowVisibilityRecordResponse) XXX_Size added in v1.17.0

func (*DeleteWorkflowVisibilityRecordResponse) XXX_Unmarshal added in v1.17.0

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

type DescribeHistoryHostRequest

type DescribeHistoryHostRequest struct {
	//ip:port
	HostAddress       string                 `protobuf:"bytes,1,opt,name=host_address,json=hostAddress,proto3" json:"host_address,omitempty"`
	ShardId           int32                  `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	NamespaceId       string                 `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution *v14.WorkflowExecution `protobuf:"bytes,4,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
}

At least one of the parameters needs to be provided.

func (*DescribeHistoryHostRequest) Descriptor

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

func (*DescribeHistoryHostRequest) Equal

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

func (*DescribeHistoryHostRequest) GetHostAddress

func (m *DescribeHistoryHostRequest) GetHostAddress() string

func (*DescribeHistoryHostRequest) GetNamespaceId added in v0.28.0

func (m *DescribeHistoryHostRequest) GetNamespaceId() string

func (*DescribeHistoryHostRequest) GetShardId added in v0.28.0

func (m *DescribeHistoryHostRequest) GetShardId() int32

func (*DescribeHistoryHostRequest) GetWorkflowExecution added in v0.28.0

func (m *DescribeHistoryHostRequest) GetWorkflowExecution() *v14.WorkflowExecution

func (*DescribeHistoryHostRequest) GoString

func (this *DescribeHistoryHostRequest) GoString() string

func (*DescribeHistoryHostRequest) Marshal

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

func (*DescribeHistoryHostRequest) MarshalTo

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

func (*DescribeHistoryHostRequest) MarshalToSizedBuffer

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

func (*DescribeHistoryHostRequest) ProtoMessage

func (*DescribeHistoryHostRequest) ProtoMessage()

func (*DescribeHistoryHostRequest) Reset

func (m *DescribeHistoryHostRequest) Reset()

func (*DescribeHistoryHostRequest) Size

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

func (*DescribeHistoryHostRequest) String

func (this *DescribeHistoryHostRequest) String() string

func (*DescribeHistoryHostRequest) Unmarshal

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

func (*DescribeHistoryHostRequest) XXX_DiscardUnknown

func (m *DescribeHistoryHostRequest) XXX_DiscardUnknown()

func (*DescribeHistoryHostRequest) XXX_Marshal

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

func (*DescribeHistoryHostRequest) XXX_Merge

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

func (*DescribeHistoryHostRequest) XXX_Size

func (m *DescribeHistoryHostRequest) XXX_Size() int

func (*DescribeHistoryHostRequest) XXX_Unmarshal

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

type DescribeHistoryHostResponse

type DescribeHistoryHostResponse struct {
	ShardsNumber   int32                    `protobuf:"varint,1,opt,name=shards_number,json=shardsNumber,proto3" json:"shards_number,omitempty"`
	ShardIds       []int32                  `protobuf:"varint,2,rep,packed,name=shard_ids,json=shardIds,proto3" json:"shard_ids,omitempty"`
	NamespaceCache *v114.NamespaceCacheInfo `protobuf:"bytes,3,opt,name=namespace_cache,json=namespaceCache,proto3" json:"namespace_cache,omitempty"`
	Address        string                   `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
}

func (*DescribeHistoryHostResponse) Descriptor

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

func (*DescribeHistoryHostResponse) Equal

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

func (*DescribeHistoryHostResponse) GetAddress

func (m *DescribeHistoryHostResponse) GetAddress() string

func (*DescribeHistoryHostResponse) GetNamespaceCache

func (m *DescribeHistoryHostResponse) GetNamespaceCache() *v114.NamespaceCacheInfo

func (*DescribeHistoryHostResponse) GetShardIds

func (m *DescribeHistoryHostResponse) GetShardIds() []int32

func (*DescribeHistoryHostResponse) GetShardsNumber added in v0.28.0

func (m *DescribeHistoryHostResponse) GetShardsNumber() int32

func (*DescribeHistoryHostResponse) GoString

func (this *DescribeHistoryHostResponse) GoString() string

func (*DescribeHistoryHostResponse) Marshal

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

func (*DescribeHistoryHostResponse) MarshalTo

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

func (*DescribeHistoryHostResponse) MarshalToSizedBuffer

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

func (*DescribeHistoryHostResponse) ProtoMessage

func (*DescribeHistoryHostResponse) ProtoMessage()

func (*DescribeHistoryHostResponse) Reset

func (m *DescribeHistoryHostResponse) Reset()

func (*DescribeHistoryHostResponse) Size

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

func (*DescribeHistoryHostResponse) String

func (this *DescribeHistoryHostResponse) String() string

func (*DescribeHistoryHostResponse) Unmarshal

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

func (*DescribeHistoryHostResponse) XXX_DiscardUnknown

func (m *DescribeHistoryHostResponse) XXX_DiscardUnknown()

func (*DescribeHistoryHostResponse) XXX_Marshal

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

func (*DescribeHistoryHostResponse) XXX_Merge

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

func (*DescribeHistoryHostResponse) XXX_Size

func (m *DescribeHistoryHostResponse) XXX_Size() int

func (*DescribeHistoryHostResponse) XXX_Unmarshal

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

type DescribeMutableStateRequest

type DescribeMutableStateRequest struct {
	NamespaceId string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution   *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*DescribeMutableStateRequest) Descriptor

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

func (*DescribeMutableStateRequest) Equal

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

func (*DescribeMutableStateRequest) GetExecution

func (*DescribeMutableStateRequest) GetNamespaceId

func (m *DescribeMutableStateRequest) GetNamespaceId() string

func (*DescribeMutableStateRequest) GoString

func (this *DescribeMutableStateRequest) GoString() string

func (*DescribeMutableStateRequest) Marshal

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

func (*DescribeMutableStateRequest) MarshalTo

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

func (*DescribeMutableStateRequest) MarshalToSizedBuffer

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

func (*DescribeMutableStateRequest) ProtoMessage

func (*DescribeMutableStateRequest) ProtoMessage()

func (*DescribeMutableStateRequest) Reset

func (m *DescribeMutableStateRequest) Reset()

func (*DescribeMutableStateRequest) Size

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

func (*DescribeMutableStateRequest) String

func (this *DescribeMutableStateRequest) String() string

func (*DescribeMutableStateRequest) Unmarshal

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

func (*DescribeMutableStateRequest) XXX_DiscardUnknown

func (m *DescribeMutableStateRequest) XXX_DiscardUnknown()

func (*DescribeMutableStateRequest) XXX_Marshal

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

func (*DescribeMutableStateRequest) XXX_Merge

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

func (*DescribeMutableStateRequest) XXX_Size

func (m *DescribeMutableStateRequest) XXX_Size() int

func (*DescribeMutableStateRequest) XXX_Unmarshal

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

type DescribeMutableStateResponse

type DescribeMutableStateResponse struct {
	CacheMutableState    *v113.WorkflowMutableState `protobuf:"bytes,1,opt,name=cache_mutable_state,json=cacheMutableState,proto3" json:"cache_mutable_state,omitempty"`
	DatabaseMutableState *v113.WorkflowMutableState `protobuf:"bytes,2,opt,name=database_mutable_state,json=databaseMutableState,proto3" json:"database_mutable_state,omitempty"`
}

func (*DescribeMutableStateResponse) Descriptor

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

func (*DescribeMutableStateResponse) Equal

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

func (*DescribeMutableStateResponse) GetCacheMutableState added in v0.28.0

func (m *DescribeMutableStateResponse) GetCacheMutableState() *v113.WorkflowMutableState

func (*DescribeMutableStateResponse) GetDatabaseMutableState added in v0.28.0

func (m *DescribeMutableStateResponse) GetDatabaseMutableState() *v113.WorkflowMutableState

func (*DescribeMutableStateResponse) GoString

func (this *DescribeMutableStateResponse) GoString() string

func (*DescribeMutableStateResponse) Marshal

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

func (*DescribeMutableStateResponse) MarshalTo

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

func (*DescribeMutableStateResponse) MarshalToSizedBuffer

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

func (*DescribeMutableStateResponse) ProtoMessage

func (*DescribeMutableStateResponse) ProtoMessage()

func (*DescribeMutableStateResponse) Reset

func (m *DescribeMutableStateResponse) Reset()

func (*DescribeMutableStateResponse) Size

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

func (*DescribeMutableStateResponse) String

func (this *DescribeMutableStateResponse) String() string

func (*DescribeMutableStateResponse) Unmarshal

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

func (*DescribeMutableStateResponse) XXX_DiscardUnknown

func (m *DescribeMutableStateResponse) XXX_DiscardUnknown()

func (*DescribeMutableStateResponse) XXX_Marshal

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

func (*DescribeMutableStateResponse) XXX_Merge

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

func (*DescribeMutableStateResponse) XXX_Size

func (m *DescribeMutableStateResponse) XXX_Size() int

func (*DescribeMutableStateResponse) XXX_Unmarshal

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

type DescribeWorkflowExecutionRequest

type DescribeWorkflowExecutionRequest struct {
	NamespaceId string                               `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Request     *v1.DescribeWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
}

func (*DescribeWorkflowExecutionRequest) Descriptor

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

func (*DescribeWorkflowExecutionRequest) Equal

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

func (*DescribeWorkflowExecutionRequest) GetNamespaceId

func (m *DescribeWorkflowExecutionRequest) GetNamespaceId() string

func (*DescribeWorkflowExecutionRequest) GetRequest

func (*DescribeWorkflowExecutionRequest) GoString

func (this *DescribeWorkflowExecutionRequest) GoString() string

func (*DescribeWorkflowExecutionRequest) Marshal

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

func (*DescribeWorkflowExecutionRequest) MarshalTo

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

func (*DescribeWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*DescribeWorkflowExecutionRequest) ProtoMessage

func (*DescribeWorkflowExecutionRequest) ProtoMessage()

func (*DescribeWorkflowExecutionRequest) Reset

func (*DescribeWorkflowExecutionRequest) Size

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

func (*DescribeWorkflowExecutionRequest) String

func (*DescribeWorkflowExecutionRequest) Unmarshal

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

func (*DescribeWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *DescribeWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionRequest) XXX_Marshal

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

func (*DescribeWorkflowExecutionRequest) XXX_Merge

func (*DescribeWorkflowExecutionRequest) XXX_Size

func (m *DescribeWorkflowExecutionRequest) XXX_Size() int

func (*DescribeWorkflowExecutionRequest) XXX_Unmarshal

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

type DescribeWorkflowExecutionResponse

type DescribeWorkflowExecutionResponse struct {
	ExecutionConfig       *v112.WorkflowExecutionConfig     `protobuf:"bytes,1,opt,name=execution_config,json=executionConfig,proto3" json:"execution_config,omitempty"`
	WorkflowExecutionInfo *v112.WorkflowExecutionInfo       `` /* 126-byte string literal not displayed */
	PendingActivities     []*v112.PendingActivityInfo       `protobuf:"bytes,3,rep,name=pending_activities,json=pendingActivities,proto3" json:"pending_activities,omitempty"`
	PendingChildren       []*v112.PendingChildExecutionInfo `protobuf:"bytes,4,rep,name=pending_children,json=pendingChildren,proto3" json:"pending_children,omitempty"`
	PendingWorkflowTask   *v112.PendingWorkflowTaskInfo     `protobuf:"bytes,5,opt,name=pending_workflow_task,json=pendingWorkflowTask,proto3" json:"pending_workflow_task,omitempty"`
}

func (*DescribeWorkflowExecutionResponse) Descriptor

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

func (*DescribeWorkflowExecutionResponse) Equal

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

func (*DescribeWorkflowExecutionResponse) GetExecutionConfig

func (*DescribeWorkflowExecutionResponse) GetPendingActivities

func (m *DescribeWorkflowExecutionResponse) GetPendingActivities() []*v112.PendingActivityInfo

func (*DescribeWorkflowExecutionResponse) GetPendingChildren

func (*DescribeWorkflowExecutionResponse) GetPendingWorkflowTask added in v1.15.0

func (m *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v112.PendingWorkflowTaskInfo

func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo

func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *v112.WorkflowExecutionInfo

func (*DescribeWorkflowExecutionResponse) GoString

func (this *DescribeWorkflowExecutionResponse) GoString() string

func (*DescribeWorkflowExecutionResponse) Marshal

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

func (*DescribeWorkflowExecutionResponse) MarshalTo

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

func (*DescribeWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*DescribeWorkflowExecutionResponse) ProtoMessage

func (*DescribeWorkflowExecutionResponse) ProtoMessage()

func (*DescribeWorkflowExecutionResponse) Reset

func (*DescribeWorkflowExecutionResponse) Size

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

func (*DescribeWorkflowExecutionResponse) String

func (*DescribeWorkflowExecutionResponse) Unmarshal

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

func (*DescribeWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionResponse) XXX_Marshal

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

func (*DescribeWorkflowExecutionResponse) XXX_Merge

func (*DescribeWorkflowExecutionResponse) XXX_Size

func (m *DescribeWorkflowExecutionResponse) XXX_Size() int

func (*DescribeWorkflowExecutionResponse) XXX_Unmarshal

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

type GenerateLastHistoryReplicationTasksRequest added in v1.14.0

type GenerateLastHistoryReplicationTasksRequest struct {
	NamespaceId string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution   *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*GenerateLastHistoryReplicationTasksRequest) Descriptor added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) Equal added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksRequest) GetExecution added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) GetNamespaceId added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) GoString added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) Marshal added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksRequest) MarshalTo added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksRequest) MarshalToSizedBuffer added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksRequest) ProtoMessage added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) Reset added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) Size added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) String added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) Unmarshal added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) XXX_DiscardUnknown added in v1.14.0

func (m *GenerateLastHistoryReplicationTasksRequest) XXX_DiscardUnknown()

func (*GenerateLastHistoryReplicationTasksRequest) XXX_Marshal added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksRequest) XXX_Merge added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) XXX_Size added in v1.14.0

func (*GenerateLastHistoryReplicationTasksRequest) XXX_Unmarshal added in v1.14.0

type GenerateLastHistoryReplicationTasksResponse added in v1.14.0

type GenerateLastHistoryReplicationTasksResponse struct {
	StateTransitionCount int64 `protobuf:"varint,1,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	HistoryLength        int64 `protobuf:"varint,2,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
}

func (*GenerateLastHistoryReplicationTasksResponse) Descriptor added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) Equal added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksResponse) GetHistoryLength added in v1.22.1

func (m *GenerateLastHistoryReplicationTasksResponse) GetHistoryLength() int64

func (*GenerateLastHistoryReplicationTasksResponse) GetStateTransitionCount added in v1.21.0

func (m *GenerateLastHistoryReplicationTasksResponse) GetStateTransitionCount() int64

func (*GenerateLastHistoryReplicationTasksResponse) GoString added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) Marshal added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksResponse) MarshalTo added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) MarshalToSizedBuffer added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksResponse) ProtoMessage added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) Reset added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) Size added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) String added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) Unmarshal added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) XXX_DiscardUnknown added in v1.14.0

func (m *GenerateLastHistoryReplicationTasksResponse) XXX_DiscardUnknown()

func (*GenerateLastHistoryReplicationTasksResponse) XXX_Marshal added in v1.14.0

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

func (*GenerateLastHistoryReplicationTasksResponse) XXX_Merge added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) XXX_Size added in v1.14.0

func (*GenerateLastHistoryReplicationTasksResponse) XXX_Unmarshal added in v1.14.0

type GetDLQMessagesRequest

type GetDLQMessagesRequest struct {
	Type                  v17.DeadLetterQueueType `protobuf:"varint,1,opt,name=type,proto3,enum=temporal.server.api.enums.v1.DeadLetterQueueType" json:"type,omitempty"`
	ShardId               int32                   `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SourceCluster         string                  `protobuf:"bytes,3,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	InclusiveEndMessageId int64                   `` /* 129-byte string literal not displayed */
	MaximumPageSize       int32                   `protobuf:"varint,5,opt,name=maximum_page_size,json=maximumPageSize,proto3" json:"maximum_page_size,omitempty"`
	NextPageToken         []byte                  `protobuf:"bytes,6,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*GetDLQMessagesRequest) Descriptor

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

func (*GetDLQMessagesRequest) Equal

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

func (*GetDLQMessagesRequest) GetInclusiveEndMessageId

func (m *GetDLQMessagesRequest) GetInclusiveEndMessageId() int64

func (*GetDLQMessagesRequest) GetMaximumPageSize

func (m *GetDLQMessagesRequest) GetMaximumPageSize() int32

func (*GetDLQMessagesRequest) GetNextPageToken

func (m *GetDLQMessagesRequest) GetNextPageToken() []byte

func (*GetDLQMessagesRequest) GetShardId

func (m *GetDLQMessagesRequest) GetShardId() int32

func (*GetDLQMessagesRequest) GetSourceCluster

func (m *GetDLQMessagesRequest) GetSourceCluster() string

func (*GetDLQMessagesRequest) GetType

func (*GetDLQMessagesRequest) GoString

func (this *GetDLQMessagesRequest) GoString() string

func (*GetDLQMessagesRequest) Marshal

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

func (*GetDLQMessagesRequest) MarshalTo

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

func (*GetDLQMessagesRequest) MarshalToSizedBuffer

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

func (*GetDLQMessagesRequest) ProtoMessage

func (*GetDLQMessagesRequest) ProtoMessage()

func (*GetDLQMessagesRequest) Reset

func (m *GetDLQMessagesRequest) Reset()

func (*GetDLQMessagesRequest) Size

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

func (*GetDLQMessagesRequest) String

func (this *GetDLQMessagesRequest) String() string

func (*GetDLQMessagesRequest) Unmarshal

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

func (*GetDLQMessagesRequest) XXX_DiscardUnknown

func (m *GetDLQMessagesRequest) XXX_DiscardUnknown()

func (*GetDLQMessagesRequest) XXX_Marshal

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

func (*GetDLQMessagesRequest) XXX_Merge

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

func (*GetDLQMessagesRequest) XXX_Size

func (m *GetDLQMessagesRequest) XXX_Size() int

func (*GetDLQMessagesRequest) XXX_Unmarshal

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

type GetDLQMessagesResponse

type GetDLQMessagesResponse struct {
	Type                 v17.DeadLetterQueueType     `protobuf:"varint,1,opt,name=type,proto3,enum=temporal.server.api.enums.v1.DeadLetterQueueType" json:"type,omitempty"`
	ReplicationTasks     []*v115.ReplicationTask     `protobuf:"bytes,2,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
	NextPageToken        []byte                      `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	ReplicationTasksInfo []*v115.ReplicationTaskInfo `protobuf:"bytes,4,rep,name=replication_tasks_info,json=replicationTasksInfo,proto3" json:"replication_tasks_info,omitempty"`
}

func (*GetDLQMessagesResponse) Descriptor

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

func (*GetDLQMessagesResponse) Equal

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

func (*GetDLQMessagesResponse) GetNextPageToken

func (m *GetDLQMessagesResponse) GetNextPageToken() []byte

func (*GetDLQMessagesResponse) GetReplicationTasks

func (m *GetDLQMessagesResponse) GetReplicationTasks() []*v115.ReplicationTask

func (*GetDLQMessagesResponse) GetReplicationTasksInfo added in v1.21.0

func (m *GetDLQMessagesResponse) GetReplicationTasksInfo() []*v115.ReplicationTaskInfo

func (*GetDLQMessagesResponse) GetType

func (*GetDLQMessagesResponse) GoString

func (this *GetDLQMessagesResponse) GoString() string

func (*GetDLQMessagesResponse) Marshal

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

func (*GetDLQMessagesResponse) MarshalTo

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

func (*GetDLQMessagesResponse) MarshalToSizedBuffer

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

func (*GetDLQMessagesResponse) ProtoMessage

func (*GetDLQMessagesResponse) ProtoMessage()

func (*GetDLQMessagesResponse) Reset

func (m *GetDLQMessagesResponse) Reset()

func (*GetDLQMessagesResponse) Size

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

func (*GetDLQMessagesResponse) String

func (this *GetDLQMessagesResponse) String() string

func (*GetDLQMessagesResponse) Unmarshal

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

func (*GetDLQMessagesResponse) XXX_DiscardUnknown

func (m *GetDLQMessagesResponse) XXX_DiscardUnknown()

func (*GetDLQMessagesResponse) XXX_Marshal

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

func (*GetDLQMessagesResponse) XXX_Merge

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

func (*GetDLQMessagesResponse) XXX_Size

func (m *GetDLQMessagesResponse) XXX_Size() int

func (*GetDLQMessagesResponse) XXX_Unmarshal

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

type GetDLQReplicationMessagesRequest

type GetDLQReplicationMessagesRequest struct {
	TaskInfos []*v115.ReplicationTaskInfo `protobuf:"bytes,1,rep,name=task_infos,json=taskInfos,proto3" json:"task_infos,omitempty"`
}

func (*GetDLQReplicationMessagesRequest) Descriptor

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

func (*GetDLQReplicationMessagesRequest) Equal

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

func (*GetDLQReplicationMessagesRequest) GetTaskInfos

func (*GetDLQReplicationMessagesRequest) GoString

func (this *GetDLQReplicationMessagesRequest) GoString() string

func (*GetDLQReplicationMessagesRequest) Marshal

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

func (*GetDLQReplicationMessagesRequest) MarshalTo

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

func (*GetDLQReplicationMessagesRequest) MarshalToSizedBuffer

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

func (*GetDLQReplicationMessagesRequest) ProtoMessage

func (*GetDLQReplicationMessagesRequest) ProtoMessage()

func (*GetDLQReplicationMessagesRequest) Reset

func (*GetDLQReplicationMessagesRequest) Size

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

func (*GetDLQReplicationMessagesRequest) String

func (*GetDLQReplicationMessagesRequest) Unmarshal

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

func (*GetDLQReplicationMessagesRequest) XXX_DiscardUnknown

func (m *GetDLQReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetDLQReplicationMessagesRequest) XXX_Marshal

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

func (*GetDLQReplicationMessagesRequest) XXX_Merge

func (*GetDLQReplicationMessagesRequest) XXX_Size

func (m *GetDLQReplicationMessagesRequest) XXX_Size() int

func (*GetDLQReplicationMessagesRequest) XXX_Unmarshal

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

type GetDLQReplicationMessagesResponse

type GetDLQReplicationMessagesResponse struct {
	ReplicationTasks []*v115.ReplicationTask `protobuf:"bytes,1,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
}

func (*GetDLQReplicationMessagesResponse) Descriptor

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

func (*GetDLQReplicationMessagesResponse) Equal

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

func (*GetDLQReplicationMessagesResponse) GetReplicationTasks

func (m *GetDLQReplicationMessagesResponse) GetReplicationTasks() []*v115.ReplicationTask

func (*GetDLQReplicationMessagesResponse) GoString

func (this *GetDLQReplicationMessagesResponse) GoString() string

func (*GetDLQReplicationMessagesResponse) Marshal

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

func (*GetDLQReplicationMessagesResponse) MarshalTo

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

func (*GetDLQReplicationMessagesResponse) MarshalToSizedBuffer

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

func (*GetDLQReplicationMessagesResponse) ProtoMessage

func (*GetDLQReplicationMessagesResponse) ProtoMessage()

func (*GetDLQReplicationMessagesResponse) Reset

func (*GetDLQReplicationMessagesResponse) Size

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

func (*GetDLQReplicationMessagesResponse) String

func (*GetDLQReplicationMessagesResponse) Unmarshal

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

func (*GetDLQReplicationMessagesResponse) XXX_DiscardUnknown

func (m *GetDLQReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetDLQReplicationMessagesResponse) XXX_Marshal

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

func (*GetDLQReplicationMessagesResponse) XXX_Merge

func (*GetDLQReplicationMessagesResponse) XXX_Size

func (m *GetDLQReplicationMessagesResponse) XXX_Size() int

func (*GetDLQReplicationMessagesResponse) XXX_Unmarshal

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

type GetMutableStateRequest

type GetMutableStateRequest struct {
	NamespaceId         string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution           *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	ExpectedNextEventId int64                  `protobuf:"varint,3,opt,name=expected_next_event_id,json=expectedNextEventId,proto3" json:"expected_next_event_id,omitempty"`
	CurrentBranchToken  []byte                 `protobuf:"bytes,4,opt,name=current_branch_token,json=currentBranchToken,proto3" json:"current_branch_token,omitempty"`
}

func (*GetMutableStateRequest) Descriptor

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

func (*GetMutableStateRequest) Equal

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

func (*GetMutableStateRequest) GetCurrentBranchToken

func (m *GetMutableStateRequest) GetCurrentBranchToken() []byte

func (*GetMutableStateRequest) GetExecution

func (m *GetMutableStateRequest) GetExecution() *v14.WorkflowExecution

func (*GetMutableStateRequest) GetExpectedNextEventId

func (m *GetMutableStateRequest) GetExpectedNextEventId() int64

func (*GetMutableStateRequest) GetNamespaceId

func (m *GetMutableStateRequest) GetNamespaceId() string

func (*GetMutableStateRequest) GoString

func (this *GetMutableStateRequest) GoString() string

func (*GetMutableStateRequest) Marshal

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

func (*GetMutableStateRequest) MarshalTo

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

func (*GetMutableStateRequest) MarshalToSizedBuffer

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

func (*GetMutableStateRequest) ProtoMessage

func (*GetMutableStateRequest) ProtoMessage()

func (*GetMutableStateRequest) Reset

func (m *GetMutableStateRequest) Reset()

func (*GetMutableStateRequest) Size

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

func (*GetMutableStateRequest) String

func (this *GetMutableStateRequest) String() string

func (*GetMutableStateRequest) Unmarshal

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

func (*GetMutableStateRequest) XXX_DiscardUnknown

func (m *GetMutableStateRequest) XXX_DiscardUnknown()

func (*GetMutableStateRequest) XXX_Marshal

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

func (*GetMutableStateRequest) XXX_Merge

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

func (*GetMutableStateRequest) XXX_Size

func (m *GetMutableStateRequest) XXX_Size() int

func (*GetMutableStateRequest) XXX_Unmarshal

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

type GetMutableStateResponse

type GetMutableStateResponse struct {
	Execution              *v14.WorkflowExecution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	WorkflowType           *v14.WorkflowType      `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	NextEventId            int64                  `protobuf:"varint,3,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	PreviousStartedEventId int64                  `` /* 132-byte string literal not displayed */
	LastFirstEventId       int64                  `protobuf:"varint,5,opt,name=last_first_event_id,json=lastFirstEventId,proto3" json:"last_first_event_id,omitempty"`
	TaskQueue              *v16.TaskQueue         `protobuf:"bytes,6,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StickyTaskQueue        *v16.TaskQueue         `protobuf:"bytes,7,opt,name=sticky_task_queue,json=stickyTaskQueue,proto3" json:"sticky_task_queue,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	StickyTaskQueueScheduleToStartTimeout *time.Duration              `` /* 195-byte string literal not displayed */
	CurrentBranchToken                    []byte                      `protobuf:"bytes,13,opt,name=current_branch_token,json=currentBranchToken,proto3" json:"current_branch_token,omitempty"`
	WorkflowState                         v17.WorkflowExecutionState  `` /* 159-byte string literal not displayed */
	WorkflowStatus                        v12.WorkflowExecutionStatus `` /* 156-byte string literal not displayed */
	VersionHistories                      *v18.VersionHistories       `protobuf:"bytes,17,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	IsStickyTaskQueueEnabled              bool                        `` /* 141-byte string literal not displayed */
	LastFirstEventTxnId                   int64                       `` /* 126-byte string literal not displayed */
	FirstExecutionRunId                   string                      `protobuf:"bytes,20,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	// If using build-id based versioning: version stamp of last worker to complete a workflow
	// task for this workflow.
	WorkerVersionStamp *v14.WorkerVersionStamp `protobuf:"bytes,21,opt,name=worker_version_stamp,json=workerVersionStamp,proto3" json:"worker_version_stamp,omitempty"`
}

func (*GetMutableStateResponse) Descriptor

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

func (*GetMutableStateResponse) Equal

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

func (*GetMutableStateResponse) GetCurrentBranchToken

func (m *GetMutableStateResponse) GetCurrentBranchToken() []byte

func (*GetMutableStateResponse) GetExecution

func (m *GetMutableStateResponse) GetExecution() *v14.WorkflowExecution

func (*GetMutableStateResponse) GetFirstExecutionRunId added in v1.17.0

func (m *GetMutableStateResponse) GetFirstExecutionRunId() string

func (*GetMutableStateResponse) GetIsStickyTaskQueueEnabled

func (m *GetMutableStateResponse) GetIsStickyTaskQueueEnabled() bool

func (*GetMutableStateResponse) GetLastFirstEventId

func (m *GetMutableStateResponse) GetLastFirstEventId() int64

func (*GetMutableStateResponse) GetLastFirstEventTxnId added in v1.9.0

func (m *GetMutableStateResponse) GetLastFirstEventTxnId() int64

func (*GetMutableStateResponse) GetNextEventId

func (m *GetMutableStateResponse) GetNextEventId() int64

func (*GetMutableStateResponse) GetPreviousStartedEventId

func (m *GetMutableStateResponse) GetPreviousStartedEventId() int64

func (*GetMutableStateResponse) GetStickyTaskQueue

func (m *GetMutableStateResponse) GetStickyTaskQueue() *v16.TaskQueue

func (*GetMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout

func (m *GetMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout() *time.Duration

func (*GetMutableStateResponse) GetTaskQueue

func (m *GetMutableStateResponse) GetTaskQueue() *v16.TaskQueue

func (*GetMutableStateResponse) GetVersionHistories

func (m *GetMutableStateResponse) GetVersionHistories() *v18.VersionHistories

func (*GetMutableStateResponse) GetWorkerVersionStamp added in v1.21.0

func (m *GetMutableStateResponse) GetWorkerVersionStamp() *v14.WorkerVersionStamp

func (*GetMutableStateResponse) GetWorkflowState

func (m *GetMutableStateResponse) GetWorkflowState() v17.WorkflowExecutionState

func (*GetMutableStateResponse) GetWorkflowStatus

func (m *GetMutableStateResponse) GetWorkflowStatus() v12.WorkflowExecutionStatus

func (*GetMutableStateResponse) GetWorkflowType

func (m *GetMutableStateResponse) GetWorkflowType() *v14.WorkflowType

func (*GetMutableStateResponse) GoString

func (this *GetMutableStateResponse) GoString() string

func (*GetMutableStateResponse) Marshal

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

func (*GetMutableStateResponse) MarshalTo

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

func (*GetMutableStateResponse) MarshalToSizedBuffer

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

func (*GetMutableStateResponse) ProtoMessage

func (*GetMutableStateResponse) ProtoMessage()

func (*GetMutableStateResponse) Reset

func (m *GetMutableStateResponse) Reset()

func (*GetMutableStateResponse) Size

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

func (*GetMutableStateResponse) String

func (this *GetMutableStateResponse) String() string

func (*GetMutableStateResponse) Unmarshal

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

func (*GetMutableStateResponse) XXX_DiscardUnknown

func (m *GetMutableStateResponse) XXX_DiscardUnknown()

func (*GetMutableStateResponse) XXX_Marshal

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

func (*GetMutableStateResponse) XXX_Merge

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

func (*GetMutableStateResponse) XXX_Size

func (m *GetMutableStateResponse) XXX_Size() int

func (*GetMutableStateResponse) XXX_Unmarshal

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

type GetReplicationMessagesRequest

type GetReplicationMessagesRequest struct {
	Tokens      []*v115.ReplicationToken `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens,omitempty"`
	ClusterName string                   `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
}

func (*GetReplicationMessagesRequest) Descriptor

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

func (*GetReplicationMessagesRequest) Equal

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

func (*GetReplicationMessagesRequest) GetClusterName

func (m *GetReplicationMessagesRequest) GetClusterName() string

func (*GetReplicationMessagesRequest) GetTokens

func (*GetReplicationMessagesRequest) GoString

func (this *GetReplicationMessagesRequest) GoString() string

func (*GetReplicationMessagesRequest) Marshal

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

func (*GetReplicationMessagesRequest) MarshalTo

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

func (*GetReplicationMessagesRequest) MarshalToSizedBuffer

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

func (*GetReplicationMessagesRequest) ProtoMessage

func (*GetReplicationMessagesRequest) ProtoMessage()

func (*GetReplicationMessagesRequest) Reset

func (m *GetReplicationMessagesRequest) Reset()

func (*GetReplicationMessagesRequest) Size

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

func (*GetReplicationMessagesRequest) String

func (this *GetReplicationMessagesRequest) String() string

func (*GetReplicationMessagesRequest) Unmarshal

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

func (*GetReplicationMessagesRequest) XXX_DiscardUnknown

func (m *GetReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetReplicationMessagesRequest) XXX_Marshal

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

func (*GetReplicationMessagesRequest) XXX_Merge

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

func (*GetReplicationMessagesRequest) XXX_Size

func (m *GetReplicationMessagesRequest) XXX_Size() int

func (*GetReplicationMessagesRequest) XXX_Unmarshal

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

type GetReplicationMessagesResponse

type GetReplicationMessagesResponse struct {
	ShardMessages map[int32]*v115.ReplicationMessages `` /* 189-byte string literal not displayed */
}

func (*GetReplicationMessagesResponse) Descriptor

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

func (*GetReplicationMessagesResponse) Equal

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

func (*GetReplicationMessagesResponse) GetShardMessages added in v0.28.0

func (m *GetReplicationMessagesResponse) GetShardMessages() map[int32]*v115.ReplicationMessages

func (*GetReplicationMessagesResponse) GoString

func (this *GetReplicationMessagesResponse) GoString() string

func (*GetReplicationMessagesResponse) Marshal

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

func (*GetReplicationMessagesResponse) MarshalTo

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

func (*GetReplicationMessagesResponse) MarshalToSizedBuffer

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

func (*GetReplicationMessagesResponse) ProtoMessage

func (*GetReplicationMessagesResponse) ProtoMessage()

func (*GetReplicationMessagesResponse) Reset

func (m *GetReplicationMessagesResponse) Reset()

func (*GetReplicationMessagesResponse) Size

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

func (*GetReplicationMessagesResponse) String

func (this *GetReplicationMessagesResponse) String() string

func (*GetReplicationMessagesResponse) Unmarshal

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

func (*GetReplicationMessagesResponse) XXX_DiscardUnknown

func (m *GetReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetReplicationMessagesResponse) XXX_Marshal

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

func (*GetReplicationMessagesResponse) XXX_Merge

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

func (*GetReplicationMessagesResponse) XXX_Size

func (m *GetReplicationMessagesResponse) XXX_Size() int

func (*GetReplicationMessagesResponse) XXX_Unmarshal

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

type GetReplicationStatusRequest added in v1.14.0

type GetReplicationStatusRequest struct {
	// Remote cluster names to query for. If omit, will return for all remote clusters.
	RemoteClusters []string `protobuf:"bytes,1,rep,name=remote_clusters,json=remoteClusters,proto3" json:"remote_clusters,omitempty"`
}

func (*GetReplicationStatusRequest) Descriptor added in v1.14.0

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

func (*GetReplicationStatusRequest) Equal added in v1.14.0

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

func (*GetReplicationStatusRequest) GetRemoteClusters added in v1.14.0

func (m *GetReplicationStatusRequest) GetRemoteClusters() []string

func (*GetReplicationStatusRequest) GoString added in v1.14.0

func (this *GetReplicationStatusRequest) GoString() string

func (*GetReplicationStatusRequest) Marshal added in v1.14.0

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

func (*GetReplicationStatusRequest) MarshalTo added in v1.14.0

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

func (*GetReplicationStatusRequest) MarshalToSizedBuffer added in v1.14.0

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

func (*GetReplicationStatusRequest) ProtoMessage added in v1.14.0

func (*GetReplicationStatusRequest) ProtoMessage()

func (*GetReplicationStatusRequest) Reset added in v1.14.0

func (m *GetReplicationStatusRequest) Reset()

func (*GetReplicationStatusRequest) Size added in v1.14.0

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

func (*GetReplicationStatusRequest) String added in v1.14.0

func (this *GetReplicationStatusRequest) String() string

func (*GetReplicationStatusRequest) Unmarshal added in v1.14.0

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

func (*GetReplicationStatusRequest) XXX_DiscardUnknown added in v1.14.0

func (m *GetReplicationStatusRequest) XXX_DiscardUnknown()

func (*GetReplicationStatusRequest) XXX_Marshal added in v1.14.0

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

func (*GetReplicationStatusRequest) XXX_Merge added in v1.14.0

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

func (*GetReplicationStatusRequest) XXX_Size added in v1.14.0

func (m *GetReplicationStatusRequest) XXX_Size() int

func (*GetReplicationStatusRequest) XXX_Unmarshal added in v1.14.0

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

type GetReplicationStatusResponse added in v1.14.0

type GetReplicationStatusResponse struct {
	Shards []*ShardReplicationStatus `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"`
}

func (*GetReplicationStatusResponse) Descriptor added in v1.14.0

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

func (*GetReplicationStatusResponse) Equal added in v1.14.0

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

func (*GetReplicationStatusResponse) GetShards added in v1.14.0

func (*GetReplicationStatusResponse) GoString added in v1.14.0

func (this *GetReplicationStatusResponse) GoString() string

func (*GetReplicationStatusResponse) Marshal added in v1.14.0

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

func (*GetReplicationStatusResponse) MarshalTo added in v1.14.0

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

func (*GetReplicationStatusResponse) MarshalToSizedBuffer added in v1.14.0

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

func (*GetReplicationStatusResponse) ProtoMessage added in v1.14.0

func (*GetReplicationStatusResponse) ProtoMessage()

func (*GetReplicationStatusResponse) Reset added in v1.14.0

func (m *GetReplicationStatusResponse) Reset()

func (*GetReplicationStatusResponse) Size added in v1.14.0

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

func (*GetReplicationStatusResponse) String added in v1.14.0

func (this *GetReplicationStatusResponse) String() string

func (*GetReplicationStatusResponse) Unmarshal added in v1.14.0

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

func (*GetReplicationStatusResponse) XXX_DiscardUnknown added in v1.14.0

func (m *GetReplicationStatusResponse) XXX_DiscardUnknown()

func (*GetReplicationStatusResponse) XXX_Marshal added in v1.14.0

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

func (*GetReplicationStatusResponse) XXX_Merge added in v1.14.0

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

func (*GetReplicationStatusResponse) XXX_Size added in v1.14.0

func (m *GetReplicationStatusResponse) XXX_Size() int

func (*GetReplicationStatusResponse) XXX_Unmarshal added in v1.14.0

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

type GetShardRequest added in v1.14.0

type GetShardRequest struct {
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
}

func (*GetShardRequest) Descriptor added in v1.14.0

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

func (*GetShardRequest) Equal added in v1.14.0

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

func (*GetShardRequest) GetShardId added in v1.14.0

func (m *GetShardRequest) GetShardId() int32

func (*GetShardRequest) GoString added in v1.14.0

func (this *GetShardRequest) GoString() string

func (*GetShardRequest) Marshal added in v1.14.0

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

func (*GetShardRequest) MarshalTo added in v1.14.0

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

func (*GetShardRequest) MarshalToSizedBuffer added in v1.14.0

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

func (*GetShardRequest) ProtoMessage added in v1.14.0

func (*GetShardRequest) ProtoMessage()

func (*GetShardRequest) Reset added in v1.14.0

func (m *GetShardRequest) Reset()

func (*GetShardRequest) Size added in v1.14.0

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

func (*GetShardRequest) String added in v1.14.0

func (this *GetShardRequest) String() string

func (*GetShardRequest) Unmarshal added in v1.14.0

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

func (*GetShardRequest) XXX_DiscardUnknown added in v1.14.0

func (m *GetShardRequest) XXX_DiscardUnknown()

func (*GetShardRequest) XXX_Marshal added in v1.14.0

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

func (*GetShardRequest) XXX_Merge added in v1.14.0

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

func (*GetShardRequest) XXX_Size added in v1.14.0

func (m *GetShardRequest) XXX_Size() int

func (*GetShardRequest) XXX_Unmarshal added in v1.14.0

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

type GetShardResponse added in v1.14.0

type GetShardResponse struct {
	ShardInfo *v113.ShardInfo `protobuf:"bytes,1,opt,name=shard_info,json=shardInfo,proto3" json:"shard_info,omitempty"`
}

func (*GetShardResponse) Descriptor added in v1.14.0

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

func (*GetShardResponse) Equal added in v1.14.0

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

func (*GetShardResponse) GetShardInfo added in v1.14.0

func (m *GetShardResponse) GetShardInfo() *v113.ShardInfo

func (*GetShardResponse) GoString added in v1.14.0

func (this *GetShardResponse) GoString() string

func (*GetShardResponse) Marshal added in v1.14.0

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

func (*GetShardResponse) MarshalTo added in v1.14.0

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

func (*GetShardResponse) MarshalToSizedBuffer added in v1.14.0

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

func (*GetShardResponse) ProtoMessage added in v1.14.0

func (*GetShardResponse) ProtoMessage()

func (*GetShardResponse) Reset added in v1.14.0

func (m *GetShardResponse) Reset()

func (*GetShardResponse) Size added in v1.14.0

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

func (*GetShardResponse) String added in v1.14.0

func (this *GetShardResponse) String() string

func (*GetShardResponse) Unmarshal added in v1.14.0

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

func (*GetShardResponse) XXX_DiscardUnknown added in v1.14.0

func (m *GetShardResponse) XXX_DiscardUnknown()

func (*GetShardResponse) XXX_Marshal added in v1.14.0

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

func (*GetShardResponse) XXX_Merge added in v1.14.0

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

func (*GetShardResponse) XXX_Size added in v1.14.0

func (m *GetShardResponse) XXX_Size() int

func (*GetShardResponse) XXX_Unmarshal added in v1.14.0

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

type HandoverNamespaceInfo added in v1.14.0

type HandoverNamespaceInfo struct {
	// max replication task id when namespace transition to Handover state
	HandoverReplicationTaskId int64 `` /* 141-byte string literal not displayed */
}

func (*HandoverNamespaceInfo) Descriptor added in v1.14.0

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

func (*HandoverNamespaceInfo) Equal added in v1.14.0

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

func (*HandoverNamespaceInfo) GetHandoverReplicationTaskId added in v1.14.0

func (m *HandoverNamespaceInfo) GetHandoverReplicationTaskId() int64

func (*HandoverNamespaceInfo) GoString added in v1.14.0

func (this *HandoverNamespaceInfo) GoString() string

func (*HandoverNamespaceInfo) Marshal added in v1.14.0

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

func (*HandoverNamespaceInfo) MarshalTo added in v1.14.0

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

func (*HandoverNamespaceInfo) MarshalToSizedBuffer added in v1.14.0

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

func (*HandoverNamespaceInfo) ProtoMessage added in v1.14.0

func (*HandoverNamespaceInfo) ProtoMessage()

func (*HandoverNamespaceInfo) Reset added in v1.14.0

func (m *HandoverNamespaceInfo) Reset()

func (*HandoverNamespaceInfo) Size added in v1.14.0

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

func (*HandoverNamespaceInfo) String added in v1.14.0

func (this *HandoverNamespaceInfo) String() string

func (*HandoverNamespaceInfo) Unmarshal added in v1.14.0

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

func (*HandoverNamespaceInfo) XXX_DiscardUnknown added in v1.14.0

func (m *HandoverNamespaceInfo) XXX_DiscardUnknown()

func (*HandoverNamespaceInfo) XXX_Marshal added in v1.14.0

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

func (*HandoverNamespaceInfo) XXX_Merge added in v1.14.0

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

func (*HandoverNamespaceInfo) XXX_Size added in v1.14.0

func (m *HandoverNamespaceInfo) XXX_Size() int

func (*HandoverNamespaceInfo) XXX_Unmarshal added in v1.14.0

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

type HistoryServiceClient

type HistoryServiceClient interface {
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first WorkflowTask for the worker to produce the
	// initial list of commands for this instance.  It will return 'WorkflowExecutionAlreadyStartedError', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(ctx context.Context, in *StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*StartWorkflowExecutionResponse, error)
	// Returns the information from mutable state of workflow execution.
	// It fails with 'EntityNotExistError' if specified workflow execution in unknown to the service.
	// It returns CurrentBranchChangedError if the workflow version branch has changed.
	GetMutableState(ctx context.Context, in *GetMutableStateRequest, opts ...grpc.CallOption) (*GetMutableStateResponse, error)
	// Returns the information from mutable state of workflow execution.
	// It fails with 'EntityNotExistError' if specified workflow execution in unknown to the service.
	// It returns CurrentBranchChangedError if the workflow version branch has changed.
	PollMutableState(ctx context.Context, in *PollMutableStateRequest, opts ...grpc.CallOption) (*PollMutableStateResponse, error)
	// Reset the sticky task queue related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	ResetStickyTaskQueue(ctx context.Context, in *ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*ResetStickyTaskQueueResponse, error)
	// RecordWorkflowTaskStarted is called by the Matchingservice before it hands a workflow task to the application worker in response to
	// a PollWorkflowTaskQueue call. It records in the history the event that the workflow task has started. It will return 'TaskAlreadyStartedError',
	// if the workflow's execution history already includes a record of the event starting.
	RecordWorkflowTaskStarted(ctx context.Context, in *RecordWorkflowTaskStartedRequest, opts ...grpc.CallOption) (*RecordWorkflowTaskStartedResponse, error)
	// RecordActivityTaskStarted is called by the Matchingservice before it hands a workflow task to the application worker in response to
	// a PollActivityTaskQueue call. It records in the history the event that the workflow task has started. It will return 'TaskAlreadyStartedError',
	// if the workflow's execution history already includes a record of the event starting.
	RecordActivityTaskStarted(ctx context.Context, in *RecordActivityTaskStartedRequest, opts ...grpc.CallOption) (*RecordActivityTaskStartedResponse, error)
	// RespondWorkflowTaskCompleted is called by application worker to complete a WorkflowTask handed as a result of
	// 'PollWorkflowTaskQueue' API call.  Completing a WorkflowTask will result in new result in new commands for the
	// workflow execution and potentially new ActivityTasks created for correspondent commands. It will also create a
	// WorkflowTaskCompleted event in the history for that session.  Use the 'taskToken' provided as response of
	// PollWorkflowTaskQueue API call for completing the WorkflowTask.
	RespondWorkflowTaskCompleted(ctx context.Context, in *RespondWorkflowTaskCompletedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by application worker to indicate failure.  This results in
	// WorkflowTaskFailedEvent written to the history and a new WorkflowTask created.  This API can be used by client to
	// either clear sticky task queue or report ny panics during WorkflowTask processing.
	RespondWorkflowTaskFailed(ctx context.Context, in *RespondWorkflowTaskFailedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskFailedResponse, error)
	// IsWorkflowTaskValid is called by matching service checking whether the workflow task is valid.
	IsWorkflowTaskValid(ctx context.Context, in *IsWorkflowTaskValidRequest, opts ...grpc.CallOption) (*IsWorkflowTaskValidResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'EntityNotExistsError' in such situations.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for heartbeating.
	RecordActivityTaskHeartbeat(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(ctx context.Context, in *RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(ctx context.Context, in *RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(ctx context.Context, in *RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledResponse, error)
	// IsActivityTaskValid is called by matching service checking whether the workflow task is valid.
	IsActivityTaskValid(ctx context.Context, in *IsActivityTaskValidRequest, opts ...grpc.CallOption) (*IsActivityTaskValidResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a workflow task being created for the execution.
	SignalWorkflowExecution(ctx context.Context, in *SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWorkflowExecutionResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is needed here. --)
	// SignalWithStartWorkflowExecution is used to ensure sending a signal event to a workflow execution.
	// If workflow is running, this results in WorkflowExecutionSignaled event recorded in the history
	// and a workflow task being created for the execution.
	// If workflow is not running or not found, it will first try start workflow with given WorkflowIdResuePolicy,
	// and record WorkflowExecutionStarted and WorkflowExecutionSignaled event in case of success.
	// It will return `WorkflowExecutionAlreadyStartedError` if start workflow failed with given policy.
	SignalWithStartWorkflowExecution(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	// RemoveSignalMutableState is used to remove a signal request Id that was previously recorded.  This is currently
	// used to clean execution info when signal workflow task finished.
	RemoveSignalMutableState(ctx context.Context, in *RemoveSignalMutableStateRequest, opts ...grpc.CallOption) (*RemoveSignalMutableStateResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(ctx context.Context, in *TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*TerminateWorkflowExecutionResponse, error)
	// DeleteWorkflowExecution asynchronously deletes a specific Workflow Execution (when WorkflowExecution.run_id is
	// provided) or the latest Workflow Execution (when WorkflowExecution.run_id is not provided). If the Workflow
	// Execution is Running, it will be terminated before deletion.
	DeleteWorkflowExecution(ctx context.Context, in *DeleteWorkflowExecutionRequest, opts ...grpc.CallOption) (*DeleteWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution by a firstEventId of a existing event batch
	// in the history and immediately terminating the current execution instance.
	// After reset, the history will grow from nextFirstEventId.
	ResetWorkflowExecution(ctx context.Context, in *ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*ResetWorkflowExecutionResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made. It fails with 'EntityNotExistsError' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*RequestCancelWorkflowExecutionResponse, error)
	// ScheduleWorkflowTask is used for creating a workflow task for already started workflow execution.  This is mainly
	// used by transfer queue processor during the processing of StartChildWorkflowExecution task, where it first starts
	// child execution without creating the workflow task and then calls this API after updating the mutable state of
	// parent execution.
	ScheduleWorkflowTask(ctx context.Context, in *ScheduleWorkflowTaskRequest, opts ...grpc.CallOption) (*ScheduleWorkflowTaskResponse, error)
	// VerifyFirstWorkflowTaskScheduled checks if workflow has its first workflow task scheduled.
	// This is only used by standby transfer start child workflow task logic to make sure parent workflow has
	// scheduled first workflow task in child after recording child started in its mutable state; otherwise,
	// during namespace failover, it's possible that none of the clusters will schedule the first workflow task.
	// NOTE: This is an experimental API. If later we found there are more verification API and there's a clear pattern
	// of how verification is done, we may unify them into one generic verfication API.
	VerifyFirstWorkflowTaskScheduled(ctx context.Context, in *VerifyFirstWorkflowTaskScheduledRequest, opts ...grpc.CallOption) (*VerifyFirstWorkflowTaskScheduledResponse, error)
	// RecordChildExecutionCompleted is used for reporting the completion of child workflow execution to parent.
	// This is mainly called by transfer queue processor during the processing of DeleteExecution task.
	RecordChildExecutionCompleted(ctx context.Context, in *RecordChildExecutionCompletedRequest, opts ...grpc.CallOption) (*RecordChildExecutionCompletedResponse, error)
	// VerifyChildExecutionCompletionRecorded checks if child completion result is recorded in parent workflow.
	// This is only used by standby transfer close execution logic to make sure parent workflow has the result
	// recorded before completing the task, otherwise during namespace failover, it's possible that none of the
	// clusters will record the child result in parent workflow.
	// NOTE: This is an experimental API. If later we found there are more verification API and there's a clear pattern
	// of how verification is done, we may unify them into one generic verfication API.
	VerifyChildExecutionCompletionRecorded(ctx context.Context, in *VerifyChildExecutionCompletionRecordedRequest, opts ...grpc.CallOption) (*VerifyChildExecutionCompletionRecordedResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(ctx context.Context, in *DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	// ReplicateEventsV2 replicates workflow history events
	ReplicateEventsV2(ctx context.Context, in *ReplicateEventsV2Request, opts ...grpc.CallOption) (*ReplicateEventsV2Response, error)
	// ReplicateWorkflowState replicates workflow state
	ReplicateWorkflowState(ctx context.Context, in *ReplicateWorkflowStateRequest, opts ...grpc.CallOption) (*ReplicateWorkflowStateResponse, error)
	// SyncShardStatus sync the status between shards.
	SyncShardStatus(ctx context.Context, in *SyncShardStatusRequest, opts ...grpc.CallOption) (*SyncShardStatusResponse, error)
	// SyncActivity sync the activity status.
	SyncActivity(ctx context.Context, in *SyncActivityRequest, opts ...grpc.CallOption) (*SyncActivityResponse, error)
	// DescribeMutableState returns information about the internal states of workflow mutable state.
	DescribeMutableState(ctx context.Context, in *DescribeMutableStateRequest, opts ...grpc.CallOption) (*DescribeMutableStateResponse, error)
	// DescribeHistoryHost returns information about the internal states of a history host.
	DescribeHistoryHost(ctx context.Context, in *DescribeHistoryHostRequest, opts ...grpc.CallOption) (*DescribeHistoryHostResponse, error)
	// CloseShard close the shard.
	CloseShard(ctx context.Context, in *CloseShardRequest, opts ...grpc.CallOption) (*CloseShardResponse, error)
	// GetShard gets the ShardInfo
	GetShard(ctx context.Context, in *GetShardRequest, opts ...grpc.CallOption) (*GetShardResponse, error)
	// RemoveTask remove task based on type, taskid, shardid.
	RemoveTask(ctx context.Context, in *RemoveTaskRequest, opts ...grpc.CallOption) (*RemoveTaskResponse, error)
	// GetReplicationMessages return replication messages based on the read level
	GetReplicationMessages(ctx context.Context, in *GetReplicationMessagesRequest, opts ...grpc.CallOption) (*GetReplicationMessagesResponse, error)
	// GetDLQReplicationMessages return replication messages based on dlq info
	GetDLQReplicationMessages(ctx context.Context, in *GetDLQReplicationMessagesRequest, opts ...grpc.CallOption) (*GetDLQReplicationMessagesResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution.
	QueryWorkflow(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)
	// ReapplyEvents applies stale events to the current workflow and current run.
	ReapplyEvents(ctx context.Context, in *ReapplyEventsRequest, opts ...grpc.CallOption) (*ReapplyEventsResponse, error)
	// GetDLQMessages returns messages from DLQ.
	GetDLQMessages(ctx context.Context, in *GetDLQMessagesRequest, opts ...grpc.CallOption) (*GetDLQMessagesResponse, error)
	// (-- api-linter: core::0165::response-message-name=disabled
	//     aip.dev/not-precedent:  --)
	// PurgeDLQMessages purges messages from DLQ.
	PurgeDLQMessages(ctx context.Context, in *PurgeDLQMessagesRequest, opts ...grpc.CallOption) (*PurgeDLQMessagesResponse, error)
	// MergeDLQMessages merges messages from DLQ.
	MergeDLQMessages(ctx context.Context, in *MergeDLQMessagesRequest, opts ...grpc.CallOption) (*MergeDLQMessagesResponse, error)
	// RefreshWorkflowTasks refreshes all tasks of a workflow.
	RefreshWorkflowTasks(ctx context.Context, in *RefreshWorkflowTasksRequest, opts ...grpc.CallOption) (*RefreshWorkflowTasksResponse, error)
	// GenerateLastHistoryReplicationTasks generate a replication task for last history event for requested workflow execution
	GenerateLastHistoryReplicationTasks(ctx context.Context, in *GenerateLastHistoryReplicationTasksRequest, opts ...grpc.CallOption) (*GenerateLastHistoryReplicationTasksResponse, error)
	GetReplicationStatus(ctx context.Context, in *GetReplicationStatusRequest, opts ...grpc.CallOption) (*GetReplicationStatusResponse, error)
	// RebuildMutableState attempts to rebuild mutable state according to persisted history events.
	RebuildMutableState(ctx context.Context, in *RebuildMutableStateRequest, opts ...grpc.CallOption) (*RebuildMutableStateResponse, error)
	// DeleteWorkflowVisibilityRecord force delete a workflow's visibility record.
	// This is used by admin delete workflow execution API to delete visibility record as frontend
	// visibility manager doesn't support write operations
	DeleteWorkflowVisibilityRecord(ctx context.Context, in *DeleteWorkflowVisibilityRecordRequest, opts ...grpc.CallOption) (*DeleteWorkflowVisibilityRecordResponse, error)
	// (-- api-linter: core::0134=disabled
	//     aip.dev/not-precedent: This service does not follow the update method API --)
	UpdateWorkflowExecution(ctx context.Context, in *UpdateWorkflowExecutionRequest, opts ...grpc.CallOption) (*UpdateWorkflowExecutionResponse, error)
	// (-- api-linter: core::0134=disabled
	//     aip.dev/not-precedent: This service does not follow the update method API --)
	PollWorkflowExecutionUpdate(ctx context.Context, in *PollWorkflowExecutionUpdateRequest, opts ...grpc.CallOption) (*PollWorkflowExecutionUpdateResponse, error)
	StreamWorkflowReplicationMessages(ctx context.Context, opts ...grpc.CallOption) (HistoryService_StreamWorkflowReplicationMessagesClient, error)
}

HistoryServiceClient is the client API for HistoryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type HistoryServiceServer

type HistoryServiceServer interface {
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first WorkflowTask for the worker to produce the
	// initial list of commands for this instance.  It will return 'WorkflowExecutionAlreadyStartedError', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)
	// Returns the information from mutable state of workflow execution.
	// It fails with 'EntityNotExistError' if specified workflow execution in unknown to the service.
	// It returns CurrentBranchChangedError if the workflow version branch has changed.
	GetMutableState(context.Context, *GetMutableStateRequest) (*GetMutableStateResponse, error)
	// Returns the information from mutable state of workflow execution.
	// It fails with 'EntityNotExistError' if specified workflow execution in unknown to the service.
	// It returns CurrentBranchChangedError if the workflow version branch has changed.
	PollMutableState(context.Context, *PollMutableStateRequest) (*PollMutableStateResponse, error)
	// Reset the sticky task queue related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	ResetStickyTaskQueue(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)
	// RecordWorkflowTaskStarted is called by the Matchingservice before it hands a workflow task to the application worker in response to
	// a PollWorkflowTaskQueue call. It records in the history the event that the workflow task has started. It will return 'TaskAlreadyStartedError',
	// if the workflow's execution history already includes a record of the event starting.
	RecordWorkflowTaskStarted(context.Context, *RecordWorkflowTaskStartedRequest) (*RecordWorkflowTaskStartedResponse, error)
	// RecordActivityTaskStarted is called by the Matchingservice before it hands a workflow task to the application worker in response to
	// a PollActivityTaskQueue call. It records in the history the event that the workflow task has started. It will return 'TaskAlreadyStartedError',
	// if the workflow's execution history already includes a record of the event starting.
	RecordActivityTaskStarted(context.Context, *RecordActivityTaskStartedRequest) (*RecordActivityTaskStartedResponse, error)
	// RespondWorkflowTaskCompleted is called by application worker to complete a WorkflowTask handed as a result of
	// 'PollWorkflowTaskQueue' API call.  Completing a WorkflowTask will result in new result in new commands for the
	// workflow execution and potentially new ActivityTasks created for correspondent commands. It will also create a
	// WorkflowTaskCompleted event in the history for that session.  Use the 'taskToken' provided as response of
	// PollWorkflowTaskQueue API call for completing the WorkflowTask.
	RespondWorkflowTaskCompleted(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by application worker to indicate failure.  This results in
	// WorkflowTaskFailedEvent written to the history and a new WorkflowTask created.  This API can be used by client to
	// either clear sticky task queue or report ny panics during WorkflowTask processing.
	RespondWorkflowTaskFailed(context.Context, *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)
	// IsWorkflowTaskValid is called by matching service checking whether the workflow task is valid.
	IsWorkflowTaskValid(context.Context, *IsWorkflowTaskValidRequest) (*IsWorkflowTaskValidResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'EntityNotExistsError' in such situations.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for heartbeating.
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'EntityNotExistsError' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)
	// IsActivityTaskValid is called by matching service checking whether the workflow task is valid.
	IsActivityTaskValid(context.Context, *IsActivityTaskValidRequest) (*IsActivityTaskValidResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a workflow task being created for the execution.
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is needed here. --)
	// SignalWithStartWorkflowExecution is used to ensure sending a signal event to a workflow execution.
	// If workflow is running, this results in WorkflowExecutionSignaled event recorded in the history
	// and a workflow task being created for the execution.
	// If workflow is not running or not found, it will first try start workflow with given WorkflowIdResuePolicy,
	// and record WorkflowExecutionStarted and WorkflowExecutionSignaled event in case of success.
	// It will return `WorkflowExecutionAlreadyStartedError` if start workflow failed with given policy.
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	// RemoveSignalMutableState is used to remove a signal request Id that was previously recorded.  This is currently
	// used to clean execution info when signal workflow task finished.
	RemoveSignalMutableState(context.Context, *RemoveSignalMutableStateRequest) (*RemoveSignalMutableStateResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)
	// DeleteWorkflowExecution asynchronously deletes a specific Workflow Execution (when WorkflowExecution.run_id is
	// provided) or the latest Workflow Execution (when WorkflowExecution.run_id is not provided). If the Workflow
	// Execution is Running, it will be terminated before deletion.
	DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution by a firstEventId of a existing event batch
	// in the history and immediately terminating the current execution instance.
	// After reset, the history will grow from nextFirstEventId.
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made. It fails with 'EntityNotExistsError' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)
	// ScheduleWorkflowTask is used for creating a workflow task for already started workflow execution.  This is mainly
	// used by transfer queue processor during the processing of StartChildWorkflowExecution task, where it first starts
	// child execution without creating the workflow task and then calls this API after updating the mutable state of
	// parent execution.
	ScheduleWorkflowTask(context.Context, *ScheduleWorkflowTaskRequest) (*ScheduleWorkflowTaskResponse, error)
	// VerifyFirstWorkflowTaskScheduled checks if workflow has its first workflow task scheduled.
	// This is only used by standby transfer start child workflow task logic to make sure parent workflow has
	// scheduled first workflow task in child after recording child started in its mutable state; otherwise,
	// during namespace failover, it's possible that none of the clusters will schedule the first workflow task.
	// NOTE: This is an experimental API. If later we found there are more verification API and there's a clear pattern
	// of how verification is done, we may unify them into one generic verfication API.
	VerifyFirstWorkflowTaskScheduled(context.Context, *VerifyFirstWorkflowTaskScheduledRequest) (*VerifyFirstWorkflowTaskScheduledResponse, error)
	// RecordChildExecutionCompleted is used for reporting the completion of child workflow execution to parent.
	// This is mainly called by transfer queue processor during the processing of DeleteExecution task.
	RecordChildExecutionCompleted(context.Context, *RecordChildExecutionCompletedRequest) (*RecordChildExecutionCompletedResponse, error)
	// VerifyChildExecutionCompletionRecorded checks if child completion result is recorded in parent workflow.
	// This is only used by standby transfer close execution logic to make sure parent workflow has the result
	// recorded before completing the task, otherwise during namespace failover, it's possible that none of the
	// clusters will record the child result in parent workflow.
	// NOTE: This is an experimental API. If later we found there are more verification API and there's a clear pattern
	// of how verification is done, we may unify them into one generic verfication API.
	VerifyChildExecutionCompletionRecorded(context.Context, *VerifyChildExecutionCompletionRecordedRequest) (*VerifyChildExecutionCompletionRecordedResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	// ReplicateEventsV2 replicates workflow history events
	ReplicateEventsV2(context.Context, *ReplicateEventsV2Request) (*ReplicateEventsV2Response, error)
	// ReplicateWorkflowState replicates workflow state
	ReplicateWorkflowState(context.Context, *ReplicateWorkflowStateRequest) (*ReplicateWorkflowStateResponse, error)
	// SyncShardStatus sync the status between shards.
	SyncShardStatus(context.Context, *SyncShardStatusRequest) (*SyncShardStatusResponse, error)
	// SyncActivity sync the activity status.
	SyncActivity(context.Context, *SyncActivityRequest) (*SyncActivityResponse, error)
	// DescribeMutableState returns information about the internal states of workflow mutable state.
	DescribeMutableState(context.Context, *DescribeMutableStateRequest) (*DescribeMutableStateResponse, error)
	// DescribeHistoryHost returns information about the internal states of a history host.
	DescribeHistoryHost(context.Context, *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)
	// CloseShard close the shard.
	CloseShard(context.Context, *CloseShardRequest) (*CloseShardResponse, error)
	// GetShard gets the ShardInfo
	GetShard(context.Context, *GetShardRequest) (*GetShardResponse, error)
	// RemoveTask remove task based on type, taskid, shardid.
	RemoveTask(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)
	// GetReplicationMessages return replication messages based on the read level
	GetReplicationMessages(context.Context, *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)
	// GetDLQReplicationMessages return replication messages based on dlq info
	GetDLQReplicationMessages(context.Context, *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution.
	QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)
	// ReapplyEvents applies stale events to the current workflow and current run.
	ReapplyEvents(context.Context, *ReapplyEventsRequest) (*ReapplyEventsResponse, error)
	// GetDLQMessages returns messages from DLQ.
	GetDLQMessages(context.Context, *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)
	// (-- api-linter: core::0165::response-message-name=disabled
	//     aip.dev/not-precedent:  --)
	// PurgeDLQMessages purges messages from DLQ.
	PurgeDLQMessages(context.Context, *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)
	// MergeDLQMessages merges messages from DLQ.
	MergeDLQMessages(context.Context, *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)
	// RefreshWorkflowTasks refreshes all tasks of a workflow.
	RefreshWorkflowTasks(context.Context, *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)
	// GenerateLastHistoryReplicationTasks generate a replication task for last history event for requested workflow execution
	GenerateLastHistoryReplicationTasks(context.Context, *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, error)
	GetReplicationStatus(context.Context, *GetReplicationStatusRequest) (*GetReplicationStatusResponse, error)
	// RebuildMutableState attempts to rebuild mutable state according to persisted history events.
	RebuildMutableState(context.Context, *RebuildMutableStateRequest) (*RebuildMutableStateResponse, error)
	// DeleteWorkflowVisibilityRecord force delete a workflow's visibility record.
	// This is used by admin delete workflow execution API to delete visibility record as frontend
	// visibility manager doesn't support write operations
	DeleteWorkflowVisibilityRecord(context.Context, *DeleteWorkflowVisibilityRecordRequest) (*DeleteWorkflowVisibilityRecordResponse, error)
	// (-- api-linter: core::0134=disabled
	//     aip.dev/not-precedent: This service does not follow the update method API --)
	UpdateWorkflowExecution(context.Context, *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error)
	// (-- api-linter: core::0134=disabled
	//     aip.dev/not-precedent: This service does not follow the update method API --)
	PollWorkflowExecutionUpdate(context.Context, *PollWorkflowExecutionUpdateRequest) (*PollWorkflowExecutionUpdateResponse, error)
	StreamWorkflowReplicationMessages(HistoryService_StreamWorkflowReplicationMessagesServer) error
}

HistoryServiceServer is the server API for HistoryService service.

type HistoryService_StreamWorkflowReplicationMessagesClient added in v1.21.0

type HistoryService_StreamWorkflowReplicationMessagesClient interface {
	Send(*StreamWorkflowReplicationMessagesRequest) error
	Recv() (*StreamWorkflowReplicationMessagesResponse, error)
	grpc.ClientStream
}

type HistoryService_StreamWorkflowReplicationMessagesServer added in v1.21.0

type HistoryService_StreamWorkflowReplicationMessagesServer interface {
	Send(*StreamWorkflowReplicationMessagesResponse) error
	Recv() (*StreamWorkflowReplicationMessagesRequest, error)
	grpc.ServerStream
}

type IsActivityTaskValidRequest added in v1.22.0

type IsActivityTaskValidRequest struct {
	NamespaceId      string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution        *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	Clock            *v15.VectorClock       `protobuf:"bytes,3,opt,name=clock,proto3" json:"clock,omitempty"`
	ScheduledEventId int64                  `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
}

func (*IsActivityTaskValidRequest) Descriptor added in v1.22.0

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

func (*IsActivityTaskValidRequest) Equal added in v1.22.0

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

func (*IsActivityTaskValidRequest) GetClock added in v1.22.0

func (*IsActivityTaskValidRequest) GetExecution added in v1.22.0

func (*IsActivityTaskValidRequest) GetNamespaceId added in v1.22.0

func (m *IsActivityTaskValidRequest) GetNamespaceId() string

func (*IsActivityTaskValidRequest) GetScheduledEventId added in v1.22.0

func (m *IsActivityTaskValidRequest) GetScheduledEventId() int64

func (*IsActivityTaskValidRequest) GoString added in v1.22.0

func (this *IsActivityTaskValidRequest) GoString() string

func (*IsActivityTaskValidRequest) Marshal added in v1.22.0

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

func (*IsActivityTaskValidRequest) MarshalTo added in v1.22.0

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

func (*IsActivityTaskValidRequest) MarshalToSizedBuffer added in v1.22.0

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

func (*IsActivityTaskValidRequest) ProtoMessage added in v1.22.0

func (*IsActivityTaskValidRequest) ProtoMessage()

func (*IsActivityTaskValidRequest) Reset added in v1.22.0

func (m *IsActivityTaskValidRequest) Reset()

func (*IsActivityTaskValidRequest) Size added in v1.22.0

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

func (*IsActivityTaskValidRequest) String added in v1.22.0

func (this *IsActivityTaskValidRequest) String() string

func (*IsActivityTaskValidRequest) Unmarshal added in v1.22.0

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

func (*IsActivityTaskValidRequest) XXX_DiscardUnknown added in v1.22.0

func (m *IsActivityTaskValidRequest) XXX_DiscardUnknown()

func (*IsActivityTaskValidRequest) XXX_Marshal added in v1.22.0

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

func (*IsActivityTaskValidRequest) XXX_Merge added in v1.22.0

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

func (*IsActivityTaskValidRequest) XXX_Size added in v1.22.0

func (m *IsActivityTaskValidRequest) XXX_Size() int

func (*IsActivityTaskValidRequest) XXX_Unmarshal added in v1.22.0

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

type IsActivityTaskValidResponse added in v1.22.0

type IsActivityTaskValidResponse struct {
	// whether matching service can call history service to start the activity task
	IsValid bool `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"`
}

func (*IsActivityTaskValidResponse) Descriptor added in v1.22.0

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

func (*IsActivityTaskValidResponse) Equal added in v1.22.0

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

func (*IsActivityTaskValidResponse) GetIsValid added in v1.22.0

func (m *IsActivityTaskValidResponse) GetIsValid() bool

func (*IsActivityTaskValidResponse) GoString added in v1.22.0

func (this *IsActivityTaskValidResponse) GoString() string

func (*IsActivityTaskValidResponse) Marshal added in v1.22.0

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

func (*IsActivityTaskValidResponse) MarshalTo added in v1.22.0

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

func (*IsActivityTaskValidResponse) MarshalToSizedBuffer added in v1.22.0

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

func (*IsActivityTaskValidResponse) ProtoMessage added in v1.22.0

func (*IsActivityTaskValidResponse) ProtoMessage()

func (*IsActivityTaskValidResponse) Reset added in v1.22.0

func (m *IsActivityTaskValidResponse) Reset()

func (*IsActivityTaskValidResponse) Size added in v1.22.0

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

func (*IsActivityTaskValidResponse) String added in v1.22.0

func (this *IsActivityTaskValidResponse) String() string

func (*IsActivityTaskValidResponse) Unmarshal added in v1.22.0

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

func (*IsActivityTaskValidResponse) XXX_DiscardUnknown added in v1.22.0

func (m *IsActivityTaskValidResponse) XXX_DiscardUnknown()

func (*IsActivityTaskValidResponse) XXX_Marshal added in v1.22.0

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

func (*IsActivityTaskValidResponse) XXX_Merge added in v1.22.0

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

func (*IsActivityTaskValidResponse) XXX_Size added in v1.22.0

func (m *IsActivityTaskValidResponse) XXX_Size() int

func (*IsActivityTaskValidResponse) XXX_Unmarshal added in v1.22.0

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

type IsWorkflowTaskValidRequest added in v1.22.0

type IsWorkflowTaskValidRequest struct {
	NamespaceId      string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution        *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	Clock            *v15.VectorClock       `protobuf:"bytes,3,opt,name=clock,proto3" json:"clock,omitempty"`
	ScheduledEventId int64                  `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
}

func (*IsWorkflowTaskValidRequest) Descriptor added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) Equal added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) GetClock added in v1.22.0

func (*IsWorkflowTaskValidRequest) GetExecution added in v1.22.0

func (*IsWorkflowTaskValidRequest) GetNamespaceId added in v1.22.0

func (m *IsWorkflowTaskValidRequest) GetNamespaceId() string

func (*IsWorkflowTaskValidRequest) GetScheduledEventId added in v1.22.0

func (m *IsWorkflowTaskValidRequest) GetScheduledEventId() int64

func (*IsWorkflowTaskValidRequest) GoString added in v1.22.0

func (this *IsWorkflowTaskValidRequest) GoString() string

func (*IsWorkflowTaskValidRequest) Marshal added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) MarshalTo added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) MarshalToSizedBuffer added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) ProtoMessage added in v1.22.0

func (*IsWorkflowTaskValidRequest) ProtoMessage()

func (*IsWorkflowTaskValidRequest) Reset added in v1.22.0

func (m *IsWorkflowTaskValidRequest) Reset()

func (*IsWorkflowTaskValidRequest) Size added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) String added in v1.22.0

func (this *IsWorkflowTaskValidRequest) String() string

func (*IsWorkflowTaskValidRequest) Unmarshal added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) XXX_DiscardUnknown added in v1.22.0

func (m *IsWorkflowTaskValidRequest) XXX_DiscardUnknown()

func (*IsWorkflowTaskValidRequest) XXX_Marshal added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) XXX_Merge added in v1.22.0

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

func (*IsWorkflowTaskValidRequest) XXX_Size added in v1.22.0

func (m *IsWorkflowTaskValidRequest) XXX_Size() int

func (*IsWorkflowTaskValidRequest) XXX_Unmarshal added in v1.22.0

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

type IsWorkflowTaskValidResponse added in v1.22.0

type IsWorkflowTaskValidResponse struct {
	// whether matching service can call history service to start the workflow task
	IsValid bool `protobuf:"varint,1,opt,name=is_valid,json=isValid,proto3" json:"is_valid,omitempty"`
}

func (*IsWorkflowTaskValidResponse) Descriptor added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) Equal added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) GetIsValid added in v1.22.0

func (m *IsWorkflowTaskValidResponse) GetIsValid() bool

func (*IsWorkflowTaskValidResponse) GoString added in v1.22.0

func (this *IsWorkflowTaskValidResponse) GoString() string

func (*IsWorkflowTaskValidResponse) Marshal added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) MarshalTo added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) MarshalToSizedBuffer added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) ProtoMessage added in v1.22.0

func (*IsWorkflowTaskValidResponse) ProtoMessage()

func (*IsWorkflowTaskValidResponse) Reset added in v1.22.0

func (m *IsWorkflowTaskValidResponse) Reset()

func (*IsWorkflowTaskValidResponse) Size added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) String added in v1.22.0

func (this *IsWorkflowTaskValidResponse) String() string

func (*IsWorkflowTaskValidResponse) Unmarshal added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) XXX_DiscardUnknown added in v1.22.0

func (m *IsWorkflowTaskValidResponse) XXX_DiscardUnknown()

func (*IsWorkflowTaskValidResponse) XXX_Marshal added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) XXX_Merge added in v1.22.0

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

func (*IsWorkflowTaskValidResponse) XXX_Size added in v1.22.0

func (m *IsWorkflowTaskValidResponse) XXX_Size() int

func (*IsWorkflowTaskValidResponse) XXX_Unmarshal added in v1.22.0

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

type MergeDLQMessagesRequest

type MergeDLQMessagesRequest struct {
	Type                  v17.DeadLetterQueueType `protobuf:"varint,1,opt,name=type,proto3,enum=temporal.server.api.enums.v1.DeadLetterQueueType" json:"type,omitempty"`
	ShardId               int32                   `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SourceCluster         string                  `protobuf:"bytes,3,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	InclusiveEndMessageId int64                   `` /* 129-byte string literal not displayed */
	MaximumPageSize       int32                   `protobuf:"varint,5,opt,name=maximum_page_size,json=maximumPageSize,proto3" json:"maximum_page_size,omitempty"`
	NextPageToken         []byte                  `protobuf:"bytes,6,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*MergeDLQMessagesRequest) Descriptor

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

func (*MergeDLQMessagesRequest) Equal

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

func (*MergeDLQMessagesRequest) GetInclusiveEndMessageId

func (m *MergeDLQMessagesRequest) GetInclusiveEndMessageId() int64

func (*MergeDLQMessagesRequest) GetMaximumPageSize

func (m *MergeDLQMessagesRequest) GetMaximumPageSize() int32

func (*MergeDLQMessagesRequest) GetNextPageToken

func (m *MergeDLQMessagesRequest) GetNextPageToken() []byte

func (*MergeDLQMessagesRequest) GetShardId

func (m *MergeDLQMessagesRequest) GetShardId() int32

func (*MergeDLQMessagesRequest) GetSourceCluster

func (m *MergeDLQMessagesRequest) GetSourceCluster() string

func (*MergeDLQMessagesRequest) GetType

func (*MergeDLQMessagesRequest) GoString

func (this *MergeDLQMessagesRequest) GoString() string

func (*MergeDLQMessagesRequest) Marshal

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

func (*MergeDLQMessagesRequest) MarshalTo

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

func (*MergeDLQMessagesRequest) MarshalToSizedBuffer

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

func (*MergeDLQMessagesRequest) ProtoMessage

func (*MergeDLQMessagesRequest) ProtoMessage()

func (*MergeDLQMessagesRequest) Reset

func (m *MergeDLQMessagesRequest) Reset()

func (*MergeDLQMessagesRequest) Size

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

func (*MergeDLQMessagesRequest) String

func (this *MergeDLQMessagesRequest) String() string

func (*MergeDLQMessagesRequest) Unmarshal

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

func (*MergeDLQMessagesRequest) XXX_DiscardUnknown

func (m *MergeDLQMessagesRequest) XXX_DiscardUnknown()

func (*MergeDLQMessagesRequest) XXX_Marshal

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

func (*MergeDLQMessagesRequest) XXX_Merge

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

func (*MergeDLQMessagesRequest) XXX_Size

func (m *MergeDLQMessagesRequest) XXX_Size() int

func (*MergeDLQMessagesRequest) XXX_Unmarshal

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

type MergeDLQMessagesResponse

type MergeDLQMessagesResponse struct {
	NextPageToken []byte `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*MergeDLQMessagesResponse) Descriptor

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

func (*MergeDLQMessagesResponse) Equal

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

func (*MergeDLQMessagesResponse) GetNextPageToken

func (m *MergeDLQMessagesResponse) GetNextPageToken() []byte

func (*MergeDLQMessagesResponse) GoString

func (this *MergeDLQMessagesResponse) GoString() string

func (*MergeDLQMessagesResponse) Marshal

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

func (*MergeDLQMessagesResponse) MarshalTo

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

func (*MergeDLQMessagesResponse) MarshalToSizedBuffer

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

func (*MergeDLQMessagesResponse) ProtoMessage

func (*MergeDLQMessagesResponse) ProtoMessage()

func (*MergeDLQMessagesResponse) Reset

func (m *MergeDLQMessagesResponse) Reset()

func (*MergeDLQMessagesResponse) Size

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

func (*MergeDLQMessagesResponse) String

func (this *MergeDLQMessagesResponse) String() string

func (*MergeDLQMessagesResponse) Unmarshal

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

func (*MergeDLQMessagesResponse) XXX_DiscardUnknown

func (m *MergeDLQMessagesResponse) XXX_DiscardUnknown()

func (*MergeDLQMessagesResponse) XXX_Marshal

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

func (*MergeDLQMessagesResponse) XXX_Merge

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

func (*MergeDLQMessagesResponse) XXX_Size

func (m *MergeDLQMessagesResponse) XXX_Size() int

func (*MergeDLQMessagesResponse) XXX_Unmarshal

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

type PollMutableStateRequest

type PollMutableStateRequest struct {
	NamespaceId         string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution           *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	ExpectedNextEventId int64                  `protobuf:"varint,3,opt,name=expected_next_event_id,json=expectedNextEventId,proto3" json:"expected_next_event_id,omitempty"`
	CurrentBranchToken  []byte                 `protobuf:"bytes,4,opt,name=current_branch_token,json=currentBranchToken,proto3" json:"current_branch_token,omitempty"`
}

func (*PollMutableStateRequest) Descriptor

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

func (*PollMutableStateRequest) Equal

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

func (*PollMutableStateRequest) GetCurrentBranchToken

func (m *PollMutableStateRequest) GetCurrentBranchToken() []byte

func (*PollMutableStateRequest) GetExecution

func (m *PollMutableStateRequest) GetExecution() *v14.WorkflowExecution

func (*PollMutableStateRequest) GetExpectedNextEventId

func (m *PollMutableStateRequest) GetExpectedNextEventId() int64

func (*PollMutableStateRequest) GetNamespaceId

func (m *PollMutableStateRequest) GetNamespaceId() string

func (*PollMutableStateRequest) GoString

func (this *PollMutableStateRequest) GoString() string

func (*PollMutableStateRequest) Marshal

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

func (*PollMutableStateRequest) MarshalTo

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

func (*PollMutableStateRequest) MarshalToSizedBuffer

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

func (*PollMutableStateRequest) ProtoMessage

func (*PollMutableStateRequest) ProtoMessage()

func (*PollMutableStateRequest) Reset

func (m *PollMutableStateRequest) Reset()

func (*PollMutableStateRequest) Size

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

func (*PollMutableStateRequest) String

func (this *PollMutableStateRequest) String() string

func (*PollMutableStateRequest) Unmarshal

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

func (*PollMutableStateRequest) XXX_DiscardUnknown

func (m *PollMutableStateRequest) XXX_DiscardUnknown()

func (*PollMutableStateRequest) XXX_Marshal

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

func (*PollMutableStateRequest) XXX_Merge

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

func (*PollMutableStateRequest) XXX_Size

func (m *PollMutableStateRequest) XXX_Size() int

func (*PollMutableStateRequest) XXX_Unmarshal

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

type PollMutableStateResponse

type PollMutableStateResponse struct {
	Execution              *v14.WorkflowExecution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	WorkflowType           *v14.WorkflowType      `protobuf:"bytes,2,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	NextEventId            int64                  `protobuf:"varint,3,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	PreviousStartedEventId int64                  `` /* 132-byte string literal not displayed */
	LastFirstEventId       int64                  `protobuf:"varint,5,opt,name=last_first_event_id,json=lastFirstEventId,proto3" json:"last_first_event_id,omitempty"`
	TaskQueue              *v16.TaskQueue         `protobuf:"bytes,6,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StickyTaskQueue        *v16.TaskQueue         `protobuf:"bytes,7,opt,name=sticky_task_queue,json=stickyTaskQueue,proto3" json:"sticky_task_queue,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	StickyTaskQueueScheduleToStartTimeout *time.Duration              `` /* 195-byte string literal not displayed */
	CurrentBranchToken                    []byte                      `protobuf:"bytes,12,opt,name=current_branch_token,json=currentBranchToken,proto3" json:"current_branch_token,omitempty"`
	VersionHistories                      *v18.VersionHistories       `protobuf:"bytes,14,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	WorkflowState                         v17.WorkflowExecutionState  `` /* 159-byte string literal not displayed */
	WorkflowStatus                        v12.WorkflowExecutionStatus `` /* 156-byte string literal not displayed */
	LastFirstEventTxnId                   int64                       `` /* 126-byte string literal not displayed */
	FirstExecutionRunId                   string                      `protobuf:"bytes,18,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
}

func (*PollMutableStateResponse) Descriptor

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

func (*PollMutableStateResponse) Equal

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

func (*PollMutableStateResponse) GetCurrentBranchToken

func (m *PollMutableStateResponse) GetCurrentBranchToken() []byte

func (*PollMutableStateResponse) GetExecution

func (m *PollMutableStateResponse) GetExecution() *v14.WorkflowExecution

func (*PollMutableStateResponse) GetFirstExecutionRunId added in v1.17.0

func (m *PollMutableStateResponse) GetFirstExecutionRunId() string

func (*PollMutableStateResponse) GetLastFirstEventId

func (m *PollMutableStateResponse) GetLastFirstEventId() int64

func (*PollMutableStateResponse) GetLastFirstEventTxnId added in v1.9.0

func (m *PollMutableStateResponse) GetLastFirstEventTxnId() int64

func (*PollMutableStateResponse) GetNextEventId

func (m *PollMutableStateResponse) GetNextEventId() int64

func (*PollMutableStateResponse) GetPreviousStartedEventId

func (m *PollMutableStateResponse) GetPreviousStartedEventId() int64

func (*PollMutableStateResponse) GetStickyTaskQueue

func (m *PollMutableStateResponse) GetStickyTaskQueue() *v16.TaskQueue

func (*PollMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout

func (m *PollMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout() *time.Duration

func (*PollMutableStateResponse) GetTaskQueue

func (m *PollMutableStateResponse) GetTaskQueue() *v16.TaskQueue

func (*PollMutableStateResponse) GetVersionHistories

func (m *PollMutableStateResponse) GetVersionHistories() *v18.VersionHistories

func (*PollMutableStateResponse) GetWorkflowState

func (m *PollMutableStateResponse) GetWorkflowState() v17.WorkflowExecutionState

func (*PollMutableStateResponse) GetWorkflowStatus

func (m *PollMutableStateResponse) GetWorkflowStatus() v12.WorkflowExecutionStatus

func (*PollMutableStateResponse) GetWorkflowType

func (m *PollMutableStateResponse) GetWorkflowType() *v14.WorkflowType

func (*PollMutableStateResponse) GoString

func (this *PollMutableStateResponse) GoString() string

func (*PollMutableStateResponse) Marshal

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

func (*PollMutableStateResponse) MarshalTo

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

func (*PollMutableStateResponse) MarshalToSizedBuffer

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

func (*PollMutableStateResponse) ProtoMessage

func (*PollMutableStateResponse) ProtoMessage()

func (*PollMutableStateResponse) Reset

func (m *PollMutableStateResponse) Reset()

func (*PollMutableStateResponse) Size

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

func (*PollMutableStateResponse) String

func (this *PollMutableStateResponse) String() string

func (*PollMutableStateResponse) Unmarshal

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

func (*PollMutableStateResponse) XXX_DiscardUnknown

func (m *PollMutableStateResponse) XXX_DiscardUnknown()

func (*PollMutableStateResponse) XXX_Marshal

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

func (*PollMutableStateResponse) XXX_Merge

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

func (*PollMutableStateResponse) XXX_Size

func (m *PollMutableStateResponse) XXX_Size() int

func (*PollMutableStateResponse) XXX_Unmarshal

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

type PollWorkflowExecutionUpdateRequest added in v1.21.0

type PollWorkflowExecutionUpdateRequest struct {
	NamespaceId string                                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Request     *v1.PollWorkflowExecutionUpdateRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
}

func (*PollWorkflowExecutionUpdateRequest) Descriptor added in v1.21.0

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

func (*PollWorkflowExecutionUpdateRequest) Equal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateRequest) GetNamespaceId added in v1.21.0

func (m *PollWorkflowExecutionUpdateRequest) GetNamespaceId() string

func (*PollWorkflowExecutionUpdateRequest) GetRequest added in v1.21.0

func (*PollWorkflowExecutionUpdateRequest) GoString added in v1.21.0

func (this *PollWorkflowExecutionUpdateRequest) GoString() string

func (*PollWorkflowExecutionUpdateRequest) Marshal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateRequest) MarshalTo added in v1.21.0

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

func (*PollWorkflowExecutionUpdateRequest) MarshalToSizedBuffer added in v1.21.0

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

func (*PollWorkflowExecutionUpdateRequest) ProtoMessage added in v1.21.0

func (*PollWorkflowExecutionUpdateRequest) ProtoMessage()

func (*PollWorkflowExecutionUpdateRequest) Reset added in v1.21.0

func (*PollWorkflowExecutionUpdateRequest) Size added in v1.21.0

func (*PollWorkflowExecutionUpdateRequest) String added in v1.21.0

func (*PollWorkflowExecutionUpdateRequest) Unmarshal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateRequest) XXX_DiscardUnknown added in v1.21.0

func (m *PollWorkflowExecutionUpdateRequest) XXX_DiscardUnknown()

func (*PollWorkflowExecutionUpdateRequest) XXX_Marshal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateRequest) XXX_Merge added in v1.21.0

func (*PollWorkflowExecutionUpdateRequest) XXX_Size added in v1.21.0

func (*PollWorkflowExecutionUpdateRequest) XXX_Unmarshal added in v1.21.0

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

type PollWorkflowExecutionUpdateResponse added in v1.21.0

type PollWorkflowExecutionUpdateResponse struct {
	Response *v1.PollWorkflowExecutionUpdateResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
}

func (*PollWorkflowExecutionUpdateResponse) Descriptor added in v1.21.0

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

func (*PollWorkflowExecutionUpdateResponse) Equal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateResponse) GetResponse added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) GoString added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) Marshal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateResponse) MarshalTo added in v1.21.0

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

func (*PollWorkflowExecutionUpdateResponse) MarshalToSizedBuffer added in v1.21.0

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

func (*PollWorkflowExecutionUpdateResponse) ProtoMessage added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) ProtoMessage()

func (*PollWorkflowExecutionUpdateResponse) Reset added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) Size added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) String added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) Unmarshal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateResponse) XXX_DiscardUnknown added in v1.21.0

func (m *PollWorkflowExecutionUpdateResponse) XXX_DiscardUnknown()

func (*PollWorkflowExecutionUpdateResponse) XXX_Marshal added in v1.21.0

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

func (*PollWorkflowExecutionUpdateResponse) XXX_Merge added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) XXX_Size added in v1.21.0

func (*PollWorkflowExecutionUpdateResponse) XXX_Unmarshal added in v1.21.0

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

type PurgeDLQMessagesRequest

type PurgeDLQMessagesRequest struct {
	Type                  v17.DeadLetterQueueType `protobuf:"varint,1,opt,name=type,proto3,enum=temporal.server.api.enums.v1.DeadLetterQueueType" json:"type,omitempty"`
	ShardId               int32                   `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	SourceCluster         string                  `protobuf:"bytes,3,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	InclusiveEndMessageId int64                   `` /* 129-byte string literal not displayed */
}

func (*PurgeDLQMessagesRequest) Descriptor

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

func (*PurgeDLQMessagesRequest) Equal

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

func (*PurgeDLQMessagesRequest) GetInclusiveEndMessageId

func (m *PurgeDLQMessagesRequest) GetInclusiveEndMessageId() int64

func (*PurgeDLQMessagesRequest) GetShardId

func (m *PurgeDLQMessagesRequest) GetShardId() int32

func (*PurgeDLQMessagesRequest) GetSourceCluster

func (m *PurgeDLQMessagesRequest) GetSourceCluster() string

func (*PurgeDLQMessagesRequest) GetType

func (*PurgeDLQMessagesRequest) GoString

func (this *PurgeDLQMessagesRequest) GoString() string

func (*PurgeDLQMessagesRequest) Marshal

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

func (*PurgeDLQMessagesRequest) MarshalTo

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

func (*PurgeDLQMessagesRequest) MarshalToSizedBuffer

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

func (*PurgeDLQMessagesRequest) ProtoMessage

func (*PurgeDLQMessagesRequest) ProtoMessage()

func (*PurgeDLQMessagesRequest) Reset

func (m *PurgeDLQMessagesRequest) Reset()

func (*PurgeDLQMessagesRequest) Size

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

func (*PurgeDLQMessagesRequest) String

func (this *PurgeDLQMessagesRequest) String() string

func (*PurgeDLQMessagesRequest) Unmarshal

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

func (*PurgeDLQMessagesRequest) XXX_DiscardUnknown

func (m *PurgeDLQMessagesRequest) XXX_DiscardUnknown()

func (*PurgeDLQMessagesRequest) XXX_Marshal

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

func (*PurgeDLQMessagesRequest) XXX_Merge

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

func (*PurgeDLQMessagesRequest) XXX_Size

func (m *PurgeDLQMessagesRequest) XXX_Size() int

func (*PurgeDLQMessagesRequest) XXX_Unmarshal

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

type PurgeDLQMessagesResponse

type PurgeDLQMessagesResponse struct {
}

func (*PurgeDLQMessagesResponse) Descriptor

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

func (*PurgeDLQMessagesResponse) Equal

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

func (*PurgeDLQMessagesResponse) GoString

func (this *PurgeDLQMessagesResponse) GoString() string

func (*PurgeDLQMessagesResponse) Marshal

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

func (*PurgeDLQMessagesResponse) MarshalTo

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

func (*PurgeDLQMessagesResponse) MarshalToSizedBuffer

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

func (*PurgeDLQMessagesResponse) ProtoMessage

func (*PurgeDLQMessagesResponse) ProtoMessage()

func (*PurgeDLQMessagesResponse) Reset

func (m *PurgeDLQMessagesResponse) Reset()

func (*PurgeDLQMessagesResponse) Size

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

func (*PurgeDLQMessagesResponse) String

func (this *PurgeDLQMessagesResponse) String() string

func (*PurgeDLQMessagesResponse) Unmarshal

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

func (*PurgeDLQMessagesResponse) XXX_DiscardUnknown

func (m *PurgeDLQMessagesResponse) XXX_DiscardUnknown()

func (*PurgeDLQMessagesResponse) XXX_Marshal

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

func (*PurgeDLQMessagesResponse) XXX_Merge

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

func (*PurgeDLQMessagesResponse) XXX_Size

func (m *PurgeDLQMessagesResponse) XXX_Size() int

func (*PurgeDLQMessagesResponse) XXX_Unmarshal

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

type QueryWorkflowRequest

type QueryWorkflowRequest struct {
	NamespaceId string                   `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Request     *v1.QueryWorkflowRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
}

func (*QueryWorkflowRequest) Descriptor

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

func (*QueryWorkflowRequest) Equal

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

func (*QueryWorkflowRequest) GetNamespaceId

func (m *QueryWorkflowRequest) GetNamespaceId() string

func (*QueryWorkflowRequest) GetRequest

func (m *QueryWorkflowRequest) GetRequest() *v1.QueryWorkflowRequest

func (*QueryWorkflowRequest) GoString

func (this *QueryWorkflowRequest) GoString() string

func (*QueryWorkflowRequest) Marshal

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

func (*QueryWorkflowRequest) MarshalTo

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

func (*QueryWorkflowRequest) MarshalToSizedBuffer

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

func (*QueryWorkflowRequest) ProtoMessage

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) Reset

func (m *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) Size

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

func (*QueryWorkflowRequest) String

func (this *QueryWorkflowRequest) String() string

func (*QueryWorkflowRequest) Unmarshal

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

func (*QueryWorkflowRequest) XXX_DiscardUnknown

func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

func (*QueryWorkflowRequest) XXX_Marshal

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

func (*QueryWorkflowRequest) XXX_Merge

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

func (*QueryWorkflowRequest) XXX_Size

func (m *QueryWorkflowRequest) XXX_Size() int

func (*QueryWorkflowRequest) XXX_Unmarshal

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

type QueryWorkflowResponse

type QueryWorkflowResponse struct {
	Response *v1.QueryWorkflowResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
}

func (*QueryWorkflowResponse) Descriptor

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

func (*QueryWorkflowResponse) Equal

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

func (*QueryWorkflowResponse) GetResponse

func (*QueryWorkflowResponse) GoString

func (this *QueryWorkflowResponse) GoString() string

func (*QueryWorkflowResponse) Marshal

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

func (*QueryWorkflowResponse) MarshalTo

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

func (*QueryWorkflowResponse) MarshalToSizedBuffer

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

func (*QueryWorkflowResponse) ProtoMessage

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) Reset

func (m *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) Size

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

func (*QueryWorkflowResponse) String

func (this *QueryWorkflowResponse) String() string

func (*QueryWorkflowResponse) Unmarshal

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

func (*QueryWorkflowResponse) XXX_DiscardUnknown

func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

func (*QueryWorkflowResponse) XXX_Marshal

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

func (*QueryWorkflowResponse) XXX_Merge

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

func (*QueryWorkflowResponse) XXX_Size

func (m *QueryWorkflowResponse) XXX_Size() int

func (*QueryWorkflowResponse) XXX_Unmarshal

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

type ReapplyEventsRequest

type ReapplyEventsRequest struct {
	NamespaceId string                     `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Request     *v116.ReapplyEventsRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
}

func (*ReapplyEventsRequest) Descriptor

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

func (*ReapplyEventsRequest) Equal

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

func (*ReapplyEventsRequest) GetNamespaceId

func (m *ReapplyEventsRequest) GetNamespaceId() string

func (*ReapplyEventsRequest) GetRequest

func (*ReapplyEventsRequest) GoString

func (this *ReapplyEventsRequest) GoString() string

func (*ReapplyEventsRequest) Marshal

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

func (*ReapplyEventsRequest) MarshalTo

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

func (*ReapplyEventsRequest) MarshalToSizedBuffer

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

func (*ReapplyEventsRequest) ProtoMessage

func (*ReapplyEventsRequest) ProtoMessage()

func (*ReapplyEventsRequest) Reset

func (m *ReapplyEventsRequest) Reset()

func (*ReapplyEventsRequest) Size

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

func (*ReapplyEventsRequest) String

func (this *ReapplyEventsRequest) String() string

func (*ReapplyEventsRequest) Unmarshal

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

func (*ReapplyEventsRequest) XXX_DiscardUnknown

func (m *ReapplyEventsRequest) XXX_DiscardUnknown()

func (*ReapplyEventsRequest) XXX_Marshal

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

func (*ReapplyEventsRequest) XXX_Merge

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

func (*ReapplyEventsRequest) XXX_Size

func (m *ReapplyEventsRequest) XXX_Size() int

func (*ReapplyEventsRequest) XXX_Unmarshal

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

type ReapplyEventsResponse

type ReapplyEventsResponse struct {
}

func (*ReapplyEventsResponse) Descriptor

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

func (*ReapplyEventsResponse) Equal

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

func (*ReapplyEventsResponse) GoString

func (this *ReapplyEventsResponse) GoString() string

func (*ReapplyEventsResponse) Marshal

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

func (*ReapplyEventsResponse) MarshalTo

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

func (*ReapplyEventsResponse) MarshalToSizedBuffer

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

func (*ReapplyEventsResponse) ProtoMessage

func (*ReapplyEventsResponse) ProtoMessage()

func (*ReapplyEventsResponse) Reset

func (m *ReapplyEventsResponse) Reset()

func (*ReapplyEventsResponse) Size

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

func (*ReapplyEventsResponse) String

func (this *ReapplyEventsResponse) String() string

func (*ReapplyEventsResponse) Unmarshal

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

func (*ReapplyEventsResponse) XXX_DiscardUnknown

func (m *ReapplyEventsResponse) XXX_DiscardUnknown()

func (*ReapplyEventsResponse) XXX_Marshal

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

func (*ReapplyEventsResponse) XXX_Merge

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

func (*ReapplyEventsResponse) XXX_Size

func (m *ReapplyEventsResponse) XXX_Size() int

func (*ReapplyEventsResponse) XXX_Unmarshal

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

type RebuildMutableStateRequest added in v1.16.0

type RebuildMutableStateRequest struct {
	NamespaceId string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution   *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*RebuildMutableStateRequest) Descriptor added in v1.16.0

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

func (*RebuildMutableStateRequest) Equal added in v1.16.0

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

func (*RebuildMutableStateRequest) GetExecution added in v1.16.0

func (*RebuildMutableStateRequest) GetNamespaceId added in v1.16.0

func (m *RebuildMutableStateRequest) GetNamespaceId() string

func (*RebuildMutableStateRequest) GoString added in v1.16.0

func (this *RebuildMutableStateRequest) GoString() string

func (*RebuildMutableStateRequest) Marshal added in v1.16.0

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

func (*RebuildMutableStateRequest) MarshalTo added in v1.16.0

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

func (*RebuildMutableStateRequest) MarshalToSizedBuffer added in v1.16.0

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

func (*RebuildMutableStateRequest) ProtoMessage added in v1.16.0

func (*RebuildMutableStateRequest) ProtoMessage()

func (*RebuildMutableStateRequest) Reset added in v1.16.0

func (m *RebuildMutableStateRequest) Reset()

func (*RebuildMutableStateRequest) Size added in v1.16.0

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

func (*RebuildMutableStateRequest) String added in v1.16.0

func (this *RebuildMutableStateRequest) String() string

func (*RebuildMutableStateRequest) Unmarshal added in v1.16.0

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

func (*RebuildMutableStateRequest) XXX_DiscardUnknown added in v1.16.0

func (m *RebuildMutableStateRequest) XXX_DiscardUnknown()

func (*RebuildMutableStateRequest) XXX_Marshal added in v1.16.0

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

func (*RebuildMutableStateRequest) XXX_Merge added in v1.16.0

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

func (*RebuildMutableStateRequest) XXX_Size added in v1.16.0

func (m *RebuildMutableStateRequest) XXX_Size() int

func (*RebuildMutableStateRequest) XXX_Unmarshal added in v1.16.0

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

type RebuildMutableStateResponse added in v1.16.0

type RebuildMutableStateResponse struct {
}

func (*RebuildMutableStateResponse) Descriptor added in v1.16.0

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

func (*RebuildMutableStateResponse) Equal added in v1.16.0

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

func (*RebuildMutableStateResponse) GoString added in v1.16.0

func (this *RebuildMutableStateResponse) GoString() string

func (*RebuildMutableStateResponse) Marshal added in v1.16.0

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

func (*RebuildMutableStateResponse) MarshalTo added in v1.16.0

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

func (*RebuildMutableStateResponse) MarshalToSizedBuffer added in v1.16.0

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

func (*RebuildMutableStateResponse) ProtoMessage added in v1.16.0

func (*RebuildMutableStateResponse) ProtoMessage()

func (*RebuildMutableStateResponse) Reset added in v1.16.0

func (m *RebuildMutableStateResponse) Reset()

func (*RebuildMutableStateResponse) Size added in v1.16.0

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

func (*RebuildMutableStateResponse) String added in v1.16.0

func (this *RebuildMutableStateResponse) String() string

func (*RebuildMutableStateResponse) Unmarshal added in v1.16.0

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

func (*RebuildMutableStateResponse) XXX_DiscardUnknown added in v1.16.0

func (m *RebuildMutableStateResponse) XXX_DiscardUnknown()

func (*RebuildMutableStateResponse) XXX_Marshal added in v1.16.0

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

func (*RebuildMutableStateResponse) XXX_Merge added in v1.16.0

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

func (*RebuildMutableStateResponse) XXX_Size added in v1.16.0

func (m *RebuildMutableStateResponse) XXX_Size() int

func (*RebuildMutableStateResponse) XXX_Unmarshal added in v1.16.0

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

type RecordActivityTaskHeartbeatRequest

type RecordActivityTaskHeartbeatRequest struct {
	NamespaceId      string                                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	HeartbeatRequest *v1.RecordActivityTaskHeartbeatRequest `protobuf:"bytes,2,opt,name=heartbeat_request,json=heartbeatRequest,proto3" json:"heartbeat_request,omitempty"`
}

func (*RecordActivityTaskHeartbeatRequest) Descriptor

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

func (*RecordActivityTaskHeartbeatRequest) Equal

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

func (*RecordActivityTaskHeartbeatRequest) GetHeartbeatRequest

func (*RecordActivityTaskHeartbeatRequest) GetNamespaceId

func (m *RecordActivityTaskHeartbeatRequest) GetNamespaceId() string

func (*RecordActivityTaskHeartbeatRequest) GoString

func (this *RecordActivityTaskHeartbeatRequest) GoString() string

func (*RecordActivityTaskHeartbeatRequest) Marshal

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

func (*RecordActivityTaskHeartbeatRequest) MarshalTo

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

func (*RecordActivityTaskHeartbeatRequest) MarshalToSizedBuffer

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

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage()

func (*RecordActivityTaskHeartbeatRequest) Reset

func (*RecordActivityTaskHeartbeatRequest) Size

func (*RecordActivityTaskHeartbeatRequest) String

func (*RecordActivityTaskHeartbeatRequest) Unmarshal

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

func (*RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown

func (m *RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatRequest) XXX_Marshal

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

func (*RecordActivityTaskHeartbeatRequest) XXX_Merge

func (*RecordActivityTaskHeartbeatRequest) XXX_Size

func (*RecordActivityTaskHeartbeatRequest) XXX_Unmarshal

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

type RecordActivityTaskHeartbeatResponse

type RecordActivityTaskHeartbeatResponse struct {
	CancelRequested bool `protobuf:"varint,1,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
}

func (*RecordActivityTaskHeartbeatResponse) Descriptor

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

func (*RecordActivityTaskHeartbeatResponse) Equal

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

func (*RecordActivityTaskHeartbeatResponse) GetCancelRequested

func (m *RecordActivityTaskHeartbeatResponse) GetCancelRequested() bool

func (*RecordActivityTaskHeartbeatResponse) GoString

func (*RecordActivityTaskHeartbeatResponse) Marshal

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

func (*RecordActivityTaskHeartbeatResponse) MarshalTo

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

func (*RecordActivityTaskHeartbeatResponse) MarshalToSizedBuffer

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

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage()

func (*RecordActivityTaskHeartbeatResponse) Reset

func (*RecordActivityTaskHeartbeatResponse) Size

func (*RecordActivityTaskHeartbeatResponse) String

func (*RecordActivityTaskHeartbeatResponse) Unmarshal

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

func (*RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown

func (m *RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatResponse) XXX_Marshal

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

func (*RecordActivityTaskHeartbeatResponse) XXX_Merge

func (*RecordActivityTaskHeartbeatResponse) XXX_Size

func (*RecordActivityTaskHeartbeatResponse) XXX_Unmarshal

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

type RecordActivityTaskStartedRequest

type RecordActivityTaskStartedRequest struct {
	NamespaceId       string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	ScheduledEventId  int64                  `protobuf:"varint,3,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	TaskId            int64                  `protobuf:"varint,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Unique id of each poll request. Used to ensure at most once delivery of tasks.
	RequestId   string                           `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	PollRequest *v1.PollActivityTaskQueueRequest `protobuf:"bytes,6,opt,name=poll_request,json=pollRequest,proto3" json:"poll_request,omitempty"`
	Clock       *v15.VectorClock                 `protobuf:"bytes,7,opt,name=clock,proto3" json:"clock,omitempty"`
}

func (*RecordActivityTaskStartedRequest) Descriptor

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

func (*RecordActivityTaskStartedRequest) Equal

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

func (*RecordActivityTaskStartedRequest) GetClock added in v1.17.0

func (*RecordActivityTaskStartedRequest) GetNamespaceId

func (m *RecordActivityTaskStartedRequest) GetNamespaceId() string

func (*RecordActivityTaskStartedRequest) GetPollRequest

func (*RecordActivityTaskStartedRequest) GetRequestId

func (m *RecordActivityTaskStartedRequest) GetRequestId() string

func (*RecordActivityTaskStartedRequest) GetScheduledEventId added in v1.17.0

func (m *RecordActivityTaskStartedRequest) GetScheduledEventId() int64

func (*RecordActivityTaskStartedRequest) GetTaskId

func (m *RecordActivityTaskStartedRequest) GetTaskId() int64

func (*RecordActivityTaskStartedRequest) GetWorkflowExecution

func (m *RecordActivityTaskStartedRequest) GetWorkflowExecution() *v14.WorkflowExecution

func (*RecordActivityTaskStartedRequest) GoString

func (this *RecordActivityTaskStartedRequest) GoString() string

func (*RecordActivityTaskStartedRequest) Marshal

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

func (*RecordActivityTaskStartedRequest) MarshalTo

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

func (*RecordActivityTaskStartedRequest) MarshalToSizedBuffer

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

func (*RecordActivityTaskStartedRequest) ProtoMessage

func (*RecordActivityTaskStartedRequest) ProtoMessage()

func (*RecordActivityTaskStartedRequest) Reset

func (*RecordActivityTaskStartedRequest) Size

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

func (*RecordActivityTaskStartedRequest) String

func (*RecordActivityTaskStartedRequest) Unmarshal

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

func (*RecordActivityTaskStartedRequest) XXX_DiscardUnknown

func (m *RecordActivityTaskStartedRequest) XXX_DiscardUnknown()

func (*RecordActivityTaskStartedRequest) XXX_Marshal

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

func (*RecordActivityTaskStartedRequest) XXX_Merge

func (*RecordActivityTaskStartedRequest) XXX_Size

func (m *RecordActivityTaskStartedRequest) XXX_Size() int

func (*RecordActivityTaskStartedRequest) XXX_Unmarshal

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

type RecordActivityTaskStartedResponse

type RecordActivityTaskStartedResponse struct {
	ScheduledEvent              *v111.HistoryEvent `protobuf:"bytes,1,opt,name=scheduled_event,json=scheduledEvent,proto3" json:"scheduled_event,omitempty"`
	StartedTime                 *time.Time         `protobuf:"bytes,2,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	Attempt                     int32              `protobuf:"varint,3,opt,name=attempt,proto3" json:"attempt,omitempty"`
	CurrentAttemptScheduledTime *time.Time         `` /* 154-byte string literal not displayed */
	HeartbeatDetails            *v14.Payloads      `protobuf:"bytes,5,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	WorkflowType                *v14.WorkflowType  `protobuf:"bytes,6,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	WorkflowNamespace           string             `protobuf:"bytes,7,opt,name=workflow_namespace,json=workflowNamespace,proto3" json:"workflow_namespace,omitempty"`
	Clock                       *v15.VectorClock   `protobuf:"bytes,8,opt,name=clock,proto3" json:"clock,omitempty"`
	Version                     int64              `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"`
}

func (*RecordActivityTaskStartedResponse) Descriptor

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

func (*RecordActivityTaskStartedResponse) Equal

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

func (*RecordActivityTaskStartedResponse) GetAttempt

func (m *RecordActivityTaskStartedResponse) GetAttempt() int32

func (*RecordActivityTaskStartedResponse) GetClock added in v1.17.0

func (*RecordActivityTaskStartedResponse) GetCurrentAttemptScheduledTime added in v0.28.0

func (m *RecordActivityTaskStartedResponse) GetCurrentAttemptScheduledTime() *time.Time

func (*RecordActivityTaskStartedResponse) GetHeartbeatDetails

func (m *RecordActivityTaskStartedResponse) GetHeartbeatDetails() *v14.Payloads

func (*RecordActivityTaskStartedResponse) GetScheduledEvent

func (m *RecordActivityTaskStartedResponse) GetScheduledEvent() *v111.HistoryEvent

func (*RecordActivityTaskStartedResponse) GetStartedTime added in v0.28.0

func (m *RecordActivityTaskStartedResponse) GetStartedTime() *time.Time

func (*RecordActivityTaskStartedResponse) GetVersion added in v1.22.0

func (m *RecordActivityTaskStartedResponse) GetVersion() int64

func (*RecordActivityTaskStartedResponse) GetWorkflowNamespace

func (m *RecordActivityTaskStartedResponse) GetWorkflowNamespace() string

func (*RecordActivityTaskStartedResponse) GetWorkflowType

func (m *RecordActivityTaskStartedResponse) GetWorkflowType() *v14.WorkflowType

func (*RecordActivityTaskStartedResponse) GoString

func (this *RecordActivityTaskStartedResponse) GoString() string

func (*RecordActivityTaskStartedResponse) Marshal

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

func (*RecordActivityTaskStartedResponse) MarshalTo

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

func (*RecordActivityTaskStartedResponse) MarshalToSizedBuffer

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

func (*RecordActivityTaskStartedResponse) ProtoMessage

func (*RecordActivityTaskStartedResponse) ProtoMessage()

func (*RecordActivityTaskStartedResponse) Reset

func (*RecordActivityTaskStartedResponse) Size

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

func (*RecordActivityTaskStartedResponse) String

func (*RecordActivityTaskStartedResponse) Unmarshal

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

func (*RecordActivityTaskStartedResponse) XXX_DiscardUnknown

func (m *RecordActivityTaskStartedResponse) XXX_DiscardUnknown()

func (*RecordActivityTaskStartedResponse) XXX_Marshal

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

func (*RecordActivityTaskStartedResponse) XXX_Merge

func (*RecordActivityTaskStartedResponse) XXX_Size

func (m *RecordActivityTaskStartedResponse) XXX_Size() int

func (*RecordActivityTaskStartedResponse) XXX_Unmarshal

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

type RecordChildExecutionCompletedRequest

type RecordChildExecutionCompletedRequest struct {
	NamespaceId            string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	ParentExecution        *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
	ParentInitiatedId      int64                  `protobuf:"varint,3,opt,name=parent_initiated_id,json=parentInitiatedId,proto3" json:"parent_initiated_id,omitempty"`
	ChildExecution         *v14.WorkflowExecution `protobuf:"bytes,4,opt,name=child_execution,json=childExecution,proto3" json:"child_execution,omitempty"`
	CompletionEvent        *v111.HistoryEvent     `protobuf:"bytes,5,opt,name=completion_event,json=completionEvent,proto3" json:"completion_event,omitempty"`
	Clock                  *v15.VectorClock       `protobuf:"bytes,6,opt,name=clock,proto3" json:"clock,omitempty"`
	ParentInitiatedVersion int64                  `` /* 130-byte string literal not displayed */
}

* RecordChildExecutionCompletedRequest is used for reporting the completion of child execution to parent workflow execution which started it. When a child execution is completed it creates this request and calls the RecordChildExecutionCompleted API with the workflowExecution of parent. It also sets the completedExecution of the child as it could potentially be different than the ChildExecutionStartedEvent of parent in the situation when child creates multiple runs through ContinueAsNew before finally completing.

func (*RecordChildExecutionCompletedRequest) Descriptor

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

func (*RecordChildExecutionCompletedRequest) Equal

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

func (*RecordChildExecutionCompletedRequest) GetChildExecution added in v1.22.0

func (*RecordChildExecutionCompletedRequest) GetClock added in v1.17.0

func (*RecordChildExecutionCompletedRequest) GetCompletionEvent

func (m *RecordChildExecutionCompletedRequest) GetCompletionEvent() *v111.HistoryEvent

func (*RecordChildExecutionCompletedRequest) GetNamespaceId

func (m *RecordChildExecutionCompletedRequest) GetNamespaceId() string

func (*RecordChildExecutionCompletedRequest) GetParentExecution added in v1.22.0

func (*RecordChildExecutionCompletedRequest) GetParentInitiatedId added in v1.17.0

func (m *RecordChildExecutionCompletedRequest) GetParentInitiatedId() int64

func (*RecordChildExecutionCompletedRequest) GetParentInitiatedVersion added in v1.17.0

func (m *RecordChildExecutionCompletedRequest) GetParentInitiatedVersion() int64

func (*RecordChildExecutionCompletedRequest) GoString

func (*RecordChildExecutionCompletedRequest) Marshal

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

func (*RecordChildExecutionCompletedRequest) MarshalTo

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

func (*RecordChildExecutionCompletedRequest) MarshalToSizedBuffer

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

func (*RecordChildExecutionCompletedRequest) ProtoMessage

func (*RecordChildExecutionCompletedRequest) ProtoMessage()

func (*RecordChildExecutionCompletedRequest) Reset

func (*RecordChildExecutionCompletedRequest) Size

func (*RecordChildExecutionCompletedRequest) String

func (*RecordChildExecutionCompletedRequest) Unmarshal

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

func (*RecordChildExecutionCompletedRequest) XXX_DiscardUnknown

func (m *RecordChildExecutionCompletedRequest) XXX_DiscardUnknown()

func (*RecordChildExecutionCompletedRequest) XXX_Marshal

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

func (*RecordChildExecutionCompletedRequest) XXX_Merge

func (*RecordChildExecutionCompletedRequest) XXX_Size

func (*RecordChildExecutionCompletedRequest) XXX_Unmarshal

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

type RecordChildExecutionCompletedResponse

type RecordChildExecutionCompletedResponse struct {
}

func (*RecordChildExecutionCompletedResponse) Descriptor

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

func (*RecordChildExecutionCompletedResponse) Equal

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

func (*RecordChildExecutionCompletedResponse) GoString

func (*RecordChildExecutionCompletedResponse) Marshal

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

func (*RecordChildExecutionCompletedResponse) MarshalTo

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

func (*RecordChildExecutionCompletedResponse) MarshalToSizedBuffer

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

func (*RecordChildExecutionCompletedResponse) ProtoMessage

func (*RecordChildExecutionCompletedResponse) ProtoMessage()

func (*RecordChildExecutionCompletedResponse) Reset

func (*RecordChildExecutionCompletedResponse) Size

func (*RecordChildExecutionCompletedResponse) String

func (*RecordChildExecutionCompletedResponse) Unmarshal

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

func (*RecordChildExecutionCompletedResponse) XXX_DiscardUnknown

func (m *RecordChildExecutionCompletedResponse) XXX_DiscardUnknown()

func (*RecordChildExecutionCompletedResponse) XXX_Marshal

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

func (*RecordChildExecutionCompletedResponse) XXX_Merge

func (*RecordChildExecutionCompletedResponse) XXX_Size

func (*RecordChildExecutionCompletedResponse) XXX_Unmarshal

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

type RecordWorkflowTaskStartedRequest

type RecordWorkflowTaskStartedRequest struct {
	NamespaceId       string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	ScheduledEventId  int64                  `protobuf:"varint,3,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	TaskId            int64                  `protobuf:"varint,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Unique id of each poll request. Used to ensure at most once delivery of tasks.
	RequestId   string                           `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	PollRequest *v1.PollWorkflowTaskQueueRequest `protobuf:"bytes,6,opt,name=poll_request,json=pollRequest,proto3" json:"poll_request,omitempty"`
	Clock       *v15.VectorClock                 `protobuf:"bytes,7,opt,name=clock,proto3" json:"clock,omitempty"`
}

func (*RecordWorkflowTaskStartedRequest) Descriptor

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

func (*RecordWorkflowTaskStartedRequest) Equal

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

func (*RecordWorkflowTaskStartedRequest) GetClock added in v1.17.0

func (*RecordWorkflowTaskStartedRequest) GetNamespaceId

func (m *RecordWorkflowTaskStartedRequest) GetNamespaceId() string

func (*RecordWorkflowTaskStartedRequest) GetPollRequest

func (*RecordWorkflowTaskStartedRequest) GetRequestId

func (m *RecordWorkflowTaskStartedRequest) GetRequestId() string

func (*RecordWorkflowTaskStartedRequest) GetScheduledEventId added in v1.17.0

func (m *RecordWorkflowTaskStartedRequest) GetScheduledEventId() int64

func (*RecordWorkflowTaskStartedRequest) GetTaskId

func (m *RecordWorkflowTaskStartedRequest) GetTaskId() int64

func (*RecordWorkflowTaskStartedRequest) GetWorkflowExecution

func (m *RecordWorkflowTaskStartedRequest) GetWorkflowExecution() *v14.WorkflowExecution

func (*RecordWorkflowTaskStartedRequest) GoString

func (this *RecordWorkflowTaskStartedRequest) GoString() string

func (*RecordWorkflowTaskStartedRequest) Marshal

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

func (*RecordWorkflowTaskStartedRequest) MarshalTo

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

func (*RecordWorkflowTaskStartedRequest) MarshalToSizedBuffer

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

func (*RecordWorkflowTaskStartedRequest) ProtoMessage

func (*RecordWorkflowTaskStartedRequest) ProtoMessage()

func (*RecordWorkflowTaskStartedRequest) Reset

func (*RecordWorkflowTaskStartedRequest) Size

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

func (*RecordWorkflowTaskStartedRequest) String

func (*RecordWorkflowTaskStartedRequest) Unmarshal

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

func (*RecordWorkflowTaskStartedRequest) XXX_DiscardUnknown

func (m *RecordWorkflowTaskStartedRequest) XXX_DiscardUnknown()

func (*RecordWorkflowTaskStartedRequest) XXX_Marshal

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

func (*RecordWorkflowTaskStartedRequest) XXX_Merge

func (*RecordWorkflowTaskStartedRequest) XXX_Size

func (m *RecordWorkflowTaskStartedRequest) XXX_Size() int

func (*RecordWorkflowTaskStartedRequest) XXX_Unmarshal

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

type RecordWorkflowTaskStartedResponse

type RecordWorkflowTaskStartedResponse struct {
	WorkflowType               *v14.WorkflowType              `protobuf:"bytes,1,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	PreviousStartedEventId     int64                          `` /* 132-byte string literal not displayed */
	ScheduledEventId           int64                          `protobuf:"varint,3,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	StartedEventId             int64                          `protobuf:"varint,4,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	NextEventId                int64                          `protobuf:"varint,5,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	Attempt                    int32                          `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
	StickyExecutionEnabled     bool                           `` /* 130-byte string literal not displayed */
	TransientWorkflowTask      *v18.TransientWorkflowTaskInfo `` /* 126-byte string literal not displayed */
	WorkflowExecutionTaskQueue *v16.TaskQueue                 `` /* 143-byte string literal not displayed */
	BranchToken                []byte                         `protobuf:"bytes,11,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	ScheduledTime              *time.Time                     `protobuf:"bytes,12,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedTime                *time.Time                     `protobuf:"bytes,13,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	Queries                    map[string]*v19.WorkflowQuery  `` /* 156-byte string literal not displayed */
	Clock                      *v15.VectorClock               `protobuf:"bytes,15,opt,name=clock,proto3" json:"clock,omitempty"`
	Messages                   []*v110.Message                `protobuf:"bytes,16,rep,name=messages,proto3" json:"messages,omitempty"`
	Version                    int64                          `protobuf:"varint,17,opt,name=version,proto3" json:"version,omitempty"`
}

func (*RecordWorkflowTaskStartedResponse) Descriptor

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

func (*RecordWorkflowTaskStartedResponse) Equal

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

func (*RecordWorkflowTaskStartedResponse) GetAttempt

func (m *RecordWorkflowTaskStartedResponse) GetAttempt() int32

func (*RecordWorkflowTaskStartedResponse) GetBranchToken

func (m *RecordWorkflowTaskStartedResponse) GetBranchToken() []byte

func (*RecordWorkflowTaskStartedResponse) GetClock added in v1.17.0

func (*RecordWorkflowTaskStartedResponse) GetMessages added in v1.20.0

func (m *RecordWorkflowTaskStartedResponse) GetMessages() []*v110.Message

func (*RecordWorkflowTaskStartedResponse) GetNextEventId

func (m *RecordWorkflowTaskStartedResponse) GetNextEventId() int64

func (*RecordWorkflowTaskStartedResponse) GetPreviousStartedEventId

func (m *RecordWorkflowTaskStartedResponse) GetPreviousStartedEventId() int64

func (*RecordWorkflowTaskStartedResponse) GetQueries

func (*RecordWorkflowTaskStartedResponse) GetScheduledEventId

func (m *RecordWorkflowTaskStartedResponse) GetScheduledEventId() int64

func (*RecordWorkflowTaskStartedResponse) GetScheduledTime added in v0.28.0

func (m *RecordWorkflowTaskStartedResponse) GetScheduledTime() *time.Time

func (*RecordWorkflowTaskStartedResponse) GetStartedEventId

func (m *RecordWorkflowTaskStartedResponse) GetStartedEventId() int64

func (*RecordWorkflowTaskStartedResponse) GetStartedTime added in v0.28.0

func (m *RecordWorkflowTaskStartedResponse) GetStartedTime() *time.Time

func (*RecordWorkflowTaskStartedResponse) GetStickyExecutionEnabled

func (m *RecordWorkflowTaskStartedResponse) GetStickyExecutionEnabled() bool

func (*RecordWorkflowTaskStartedResponse) GetTransientWorkflowTask added in v1.17.3

func (m *RecordWorkflowTaskStartedResponse) GetTransientWorkflowTask() *v18.TransientWorkflowTaskInfo

func (*RecordWorkflowTaskStartedResponse) GetVersion added in v1.22.0

func (m *RecordWorkflowTaskStartedResponse) GetVersion() int64

func (*RecordWorkflowTaskStartedResponse) GetWorkflowExecutionTaskQueue

func (m *RecordWorkflowTaskStartedResponse) GetWorkflowExecutionTaskQueue() *v16.TaskQueue

func (*RecordWorkflowTaskStartedResponse) GetWorkflowType

func (m *RecordWorkflowTaskStartedResponse) GetWorkflowType() *v14.WorkflowType

func (*RecordWorkflowTaskStartedResponse) GoString

func (this *RecordWorkflowTaskStartedResponse) GoString() string

func (*RecordWorkflowTaskStartedResponse) Marshal

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

func (*RecordWorkflowTaskStartedResponse) MarshalTo

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

func (*RecordWorkflowTaskStartedResponse) MarshalToSizedBuffer

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

func (*RecordWorkflowTaskStartedResponse) ProtoMessage

func (*RecordWorkflowTaskStartedResponse) ProtoMessage()

func (*RecordWorkflowTaskStartedResponse) Reset

func (*RecordWorkflowTaskStartedResponse) Size

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

func (*RecordWorkflowTaskStartedResponse) String

func (*RecordWorkflowTaskStartedResponse) Unmarshal

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

func (*RecordWorkflowTaskStartedResponse) XXX_DiscardUnknown

func (m *RecordWorkflowTaskStartedResponse) XXX_DiscardUnknown()

func (*RecordWorkflowTaskStartedResponse) XXX_Marshal

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

func (*RecordWorkflowTaskStartedResponse) XXX_Merge

func (*RecordWorkflowTaskStartedResponse) XXX_Size

func (m *RecordWorkflowTaskStartedResponse) XXX_Size() int

func (*RecordWorkflowTaskStartedResponse) XXX_Unmarshal

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

type RefreshWorkflowTasksRequest

type RefreshWorkflowTasksRequest struct {
	NamespaceId string                            `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Request     *v116.RefreshWorkflowTasksRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
}

func (*RefreshWorkflowTasksRequest) Descriptor

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

func (*RefreshWorkflowTasksRequest) Equal

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

func (*RefreshWorkflowTasksRequest) GetNamespaceId

func (m *RefreshWorkflowTasksRequest) GetNamespaceId() string

func (*RefreshWorkflowTasksRequest) GetRequest

func (*RefreshWorkflowTasksRequest) GoString

func (this *RefreshWorkflowTasksRequest) GoString() string

func (*RefreshWorkflowTasksRequest) Marshal

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

func (*RefreshWorkflowTasksRequest) MarshalTo

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

func (*RefreshWorkflowTasksRequest) MarshalToSizedBuffer

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

func (*RefreshWorkflowTasksRequest) ProtoMessage

func (*RefreshWorkflowTasksRequest) ProtoMessage()

func (*RefreshWorkflowTasksRequest) Reset

func (m *RefreshWorkflowTasksRequest) Reset()

func (*RefreshWorkflowTasksRequest) Size

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

func (*RefreshWorkflowTasksRequest) String

func (this *RefreshWorkflowTasksRequest) String() string

func (*RefreshWorkflowTasksRequest) Unmarshal

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

func (*RefreshWorkflowTasksRequest) XXX_DiscardUnknown

func (m *RefreshWorkflowTasksRequest) XXX_DiscardUnknown()

func (*RefreshWorkflowTasksRequest) XXX_Marshal

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

func (*RefreshWorkflowTasksRequest) XXX_Merge

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

func (*RefreshWorkflowTasksRequest) XXX_Size

func (m *RefreshWorkflowTasksRequest) XXX_Size() int

func (*RefreshWorkflowTasksRequest) XXX_Unmarshal

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

type RefreshWorkflowTasksResponse

type RefreshWorkflowTasksResponse struct {
}

func (*RefreshWorkflowTasksResponse) Descriptor

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

func (*RefreshWorkflowTasksResponse) Equal

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

func (*RefreshWorkflowTasksResponse) GoString

func (this *RefreshWorkflowTasksResponse) GoString() string

func (*RefreshWorkflowTasksResponse) Marshal

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

func (*RefreshWorkflowTasksResponse) MarshalTo

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

func (*RefreshWorkflowTasksResponse) MarshalToSizedBuffer

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

func (*RefreshWorkflowTasksResponse) ProtoMessage

func (*RefreshWorkflowTasksResponse) ProtoMessage()

func (*RefreshWorkflowTasksResponse) Reset

func (m *RefreshWorkflowTasksResponse) Reset()

func (*RefreshWorkflowTasksResponse) Size

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

func (*RefreshWorkflowTasksResponse) String

func (this *RefreshWorkflowTasksResponse) String() string

func (*RefreshWorkflowTasksResponse) Unmarshal

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

func (*RefreshWorkflowTasksResponse) XXX_DiscardUnknown

func (m *RefreshWorkflowTasksResponse) XXX_DiscardUnknown()

func (*RefreshWorkflowTasksResponse) XXX_Marshal

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

func (*RefreshWorkflowTasksResponse) XXX_Merge

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

func (*RefreshWorkflowTasksResponse) XXX_Size

func (m *RefreshWorkflowTasksResponse) XXX_Size() int

func (*RefreshWorkflowTasksResponse) XXX_Unmarshal

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

type RemoveSignalMutableStateRequest

type RemoveSignalMutableStateRequest struct {
	NamespaceId       string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	RequestId         string                 `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

func (*RemoveSignalMutableStateRequest) Descriptor

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

func (*RemoveSignalMutableStateRequest) Equal

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

func (*RemoveSignalMutableStateRequest) GetNamespaceId

func (m *RemoveSignalMutableStateRequest) GetNamespaceId() string

func (*RemoveSignalMutableStateRequest) GetRequestId

func (m *RemoveSignalMutableStateRequest) GetRequestId() string

func (*RemoveSignalMutableStateRequest) GetWorkflowExecution

func (m *RemoveSignalMutableStateRequest) GetWorkflowExecution() *v14.WorkflowExecution

func (*RemoveSignalMutableStateRequest) GoString

func (this *RemoveSignalMutableStateRequest) GoString() string

func (*RemoveSignalMutableStateRequest) Marshal

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

func (*RemoveSignalMutableStateRequest) MarshalTo

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

func (*RemoveSignalMutableStateRequest) MarshalToSizedBuffer

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

func (*RemoveSignalMutableStateRequest) ProtoMessage

func (*RemoveSignalMutableStateRequest) ProtoMessage()

func (*RemoveSignalMutableStateRequest) Reset

func (*RemoveSignalMutableStateRequest) Size

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

func (*RemoveSignalMutableStateRequest) String

func (this *RemoveSignalMutableStateRequest) String() string

func (*RemoveSignalMutableStateRequest) Unmarshal

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

func (*RemoveSignalMutableStateRequest) XXX_DiscardUnknown

func (m *RemoveSignalMutableStateRequest) XXX_DiscardUnknown()

func (*RemoveSignalMutableStateRequest) XXX_Marshal

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

func (*RemoveSignalMutableStateRequest) XXX_Merge

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

func (*RemoveSignalMutableStateRequest) XXX_Size

func (m *RemoveSignalMutableStateRequest) XXX_Size() int

func (*RemoveSignalMutableStateRequest) XXX_Unmarshal

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

type RemoveSignalMutableStateResponse

type RemoveSignalMutableStateResponse struct {
}

func (*RemoveSignalMutableStateResponse) Descriptor

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

func (*RemoveSignalMutableStateResponse) Equal

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

func (*RemoveSignalMutableStateResponse) GoString

func (this *RemoveSignalMutableStateResponse) GoString() string

func (*RemoveSignalMutableStateResponse) Marshal

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

func (*RemoveSignalMutableStateResponse) MarshalTo

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

func (*RemoveSignalMutableStateResponse) MarshalToSizedBuffer

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

func (*RemoveSignalMutableStateResponse) ProtoMessage

func (*RemoveSignalMutableStateResponse) ProtoMessage()

func (*RemoveSignalMutableStateResponse) Reset

func (*RemoveSignalMutableStateResponse) Size

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

func (*RemoveSignalMutableStateResponse) String

func (*RemoveSignalMutableStateResponse) Unmarshal

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

func (*RemoveSignalMutableStateResponse) XXX_DiscardUnknown

func (m *RemoveSignalMutableStateResponse) XXX_DiscardUnknown()

func (*RemoveSignalMutableStateResponse) XXX_Marshal

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

func (*RemoveSignalMutableStateResponse) XXX_Merge

func (*RemoveSignalMutableStateResponse) XXX_Size

func (m *RemoveSignalMutableStateResponse) XXX_Size() int

func (*RemoveSignalMutableStateResponse) XXX_Unmarshal

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

type RemoveTaskRequest

type RemoveTaskRequest struct {
	ShardId        int32            `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Category       v17.TaskCategory `protobuf:"varint,2,opt,name=category,proto3,enum=temporal.server.api.enums.v1.TaskCategory" json:"category,omitempty"`
	TaskId         int64            `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime *time.Time       `protobuf:"bytes,4,opt,name=visibility_time,json=visibilityTime,proto3,stdtime" json:"visibility_time,omitempty"`
}

func (*RemoveTaskRequest) Descriptor

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

func (*RemoveTaskRequest) Equal

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

func (*RemoveTaskRequest) GetCategory

func (m *RemoveTaskRequest) GetCategory() v17.TaskCategory

func (*RemoveTaskRequest) GetShardId

func (m *RemoveTaskRequest) GetShardId() int32

func (*RemoveTaskRequest) GetTaskId

func (m *RemoveTaskRequest) GetTaskId() int64

func (*RemoveTaskRequest) GetVisibilityTime added in v0.28.0

func (m *RemoveTaskRequest) GetVisibilityTime() *time.Time

func (*RemoveTaskRequest) GoString

func (this *RemoveTaskRequest) GoString() string

func (*RemoveTaskRequest) Marshal

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

func (*RemoveTaskRequest) MarshalTo

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

func (*RemoveTaskRequest) MarshalToSizedBuffer

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

func (*RemoveTaskRequest) ProtoMessage

func (*RemoveTaskRequest) ProtoMessage()

func (*RemoveTaskRequest) Reset

func (m *RemoveTaskRequest) Reset()

func (*RemoveTaskRequest) Size

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

func (*RemoveTaskRequest) String

func (this *RemoveTaskRequest) String() string

func (*RemoveTaskRequest) Unmarshal

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

func (*RemoveTaskRequest) XXX_DiscardUnknown

func (m *RemoveTaskRequest) XXX_DiscardUnknown()

func (*RemoveTaskRequest) XXX_Marshal

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

func (*RemoveTaskRequest) XXX_Merge

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

func (*RemoveTaskRequest) XXX_Size

func (m *RemoveTaskRequest) XXX_Size() int

func (*RemoveTaskRequest) XXX_Unmarshal

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

type RemoveTaskResponse

type RemoveTaskResponse struct {
}

func (*RemoveTaskResponse) Descriptor

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

func (*RemoveTaskResponse) Equal

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

func (*RemoveTaskResponse) GoString

func (this *RemoveTaskResponse) GoString() string

func (*RemoveTaskResponse) Marshal

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

func (*RemoveTaskResponse) MarshalTo

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

func (*RemoveTaskResponse) MarshalToSizedBuffer

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

func (*RemoveTaskResponse) ProtoMessage

func (*RemoveTaskResponse) ProtoMessage()

func (*RemoveTaskResponse) Reset

func (m *RemoveTaskResponse) Reset()

func (*RemoveTaskResponse) Size

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

func (*RemoveTaskResponse) String

func (this *RemoveTaskResponse) String() string

func (*RemoveTaskResponse) Unmarshal

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

func (*RemoveTaskResponse) XXX_DiscardUnknown

func (m *RemoveTaskResponse) XXX_DiscardUnknown()

func (*RemoveTaskResponse) XXX_Marshal

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

func (*RemoveTaskResponse) XXX_Merge

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

func (*RemoveTaskResponse) XXX_Size

func (m *RemoveTaskResponse) XXX_Size() int

func (*RemoveTaskResponse) XXX_Unmarshal

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

type ReplicateEventsV2Request

type ReplicateEventsV2Request struct {
	NamespaceId         string                    `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution   *v14.WorkflowExecution    `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	VersionHistoryItems []*v18.VersionHistoryItem `protobuf:"bytes,3,rep,name=version_history_items,json=versionHistoryItems,proto3" json:"version_history_items,omitempty"`
	Events              *v14.DataBlob             `protobuf:"bytes,4,opt,name=events,proto3" json:"events,omitempty"`
	// New run events does not need version history since there is no prior events.
	NewRunEvents      *v14.DataBlob          `protobuf:"bytes,5,opt,name=new_run_events,json=newRunEvents,proto3" json:"new_run_events,omitempty"`
	BaseExecutionInfo *v11.BaseExecutionInfo `protobuf:"bytes,6,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
}

func (*ReplicateEventsV2Request) Descriptor

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

func (*ReplicateEventsV2Request) Equal

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

func (*ReplicateEventsV2Request) GetBaseExecutionInfo added in v1.21.0

func (m *ReplicateEventsV2Request) GetBaseExecutionInfo() *v11.BaseExecutionInfo

func (*ReplicateEventsV2Request) GetEvents

func (m *ReplicateEventsV2Request) GetEvents() *v14.DataBlob

func (*ReplicateEventsV2Request) GetNamespaceId

func (m *ReplicateEventsV2Request) GetNamespaceId() string

func (*ReplicateEventsV2Request) GetNewRunEvents

func (m *ReplicateEventsV2Request) GetNewRunEvents() *v14.DataBlob

func (*ReplicateEventsV2Request) GetVersionHistoryItems

func (m *ReplicateEventsV2Request) GetVersionHistoryItems() []*v18.VersionHistoryItem

func (*ReplicateEventsV2Request) GetWorkflowExecution

func (m *ReplicateEventsV2Request) GetWorkflowExecution() *v14.WorkflowExecution

func (*ReplicateEventsV2Request) GoString

func (this *ReplicateEventsV2Request) GoString() string

func (*ReplicateEventsV2Request) Marshal

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

func (*ReplicateEventsV2Request) MarshalTo

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

func (*ReplicateEventsV2Request) MarshalToSizedBuffer

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

func (*ReplicateEventsV2Request) ProtoMessage

func (*ReplicateEventsV2Request) ProtoMessage()

func (*ReplicateEventsV2Request) Reset

func (m *ReplicateEventsV2Request) Reset()

func (*ReplicateEventsV2Request) Size

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

func (*ReplicateEventsV2Request) String

func (this *ReplicateEventsV2Request) String() string

func (*ReplicateEventsV2Request) Unmarshal

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

func (*ReplicateEventsV2Request) XXX_DiscardUnknown

func (m *ReplicateEventsV2Request) XXX_DiscardUnknown()

func (*ReplicateEventsV2Request) XXX_Marshal

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

func (*ReplicateEventsV2Request) XXX_Merge

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

func (*ReplicateEventsV2Request) XXX_Size

func (m *ReplicateEventsV2Request) XXX_Size() int

func (*ReplicateEventsV2Request) XXX_Unmarshal

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

type ReplicateEventsV2Response

type ReplicateEventsV2Response struct {
}

func (*ReplicateEventsV2Response) Descriptor

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

func (*ReplicateEventsV2Response) Equal

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

func (*ReplicateEventsV2Response) GoString

func (this *ReplicateEventsV2Response) GoString() string

func (*ReplicateEventsV2Response) Marshal

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

func (*ReplicateEventsV2Response) MarshalTo

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

func (*ReplicateEventsV2Response) MarshalToSizedBuffer

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

func (*ReplicateEventsV2Response) ProtoMessage

func (*ReplicateEventsV2Response) ProtoMessage()

func (*ReplicateEventsV2Response) Reset

func (m *ReplicateEventsV2Response) Reset()

func (*ReplicateEventsV2Response) Size

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

func (*ReplicateEventsV2Response) String

func (this *ReplicateEventsV2Response) String() string

func (*ReplicateEventsV2Response) Unmarshal

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

func (*ReplicateEventsV2Response) XXX_DiscardUnknown

func (m *ReplicateEventsV2Response) XXX_DiscardUnknown()

func (*ReplicateEventsV2Response) XXX_Marshal

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

func (*ReplicateEventsV2Response) XXX_Merge

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

func (*ReplicateEventsV2Response) XXX_Size

func (m *ReplicateEventsV2Response) XXX_Size() int

func (*ReplicateEventsV2Response) XXX_Unmarshal

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

type ReplicateWorkflowStateRequest added in v1.17.0

type ReplicateWorkflowStateRequest struct {
	WorkflowState *v113.WorkflowMutableState `protobuf:"bytes,1,opt,name=workflow_state,json=workflowState,proto3" json:"workflow_state,omitempty"`
	RemoteCluster string                     `protobuf:"bytes,2,opt,name=remote_cluster,json=remoteCluster,proto3" json:"remote_cluster,omitempty"`
	NamespaceId   string                     `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
}

func (*ReplicateWorkflowStateRequest) Descriptor added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) Equal added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) GetNamespaceId added in v1.20.0

func (m *ReplicateWorkflowStateRequest) GetNamespaceId() string

func (*ReplicateWorkflowStateRequest) GetRemoteCluster added in v1.17.0

func (m *ReplicateWorkflowStateRequest) GetRemoteCluster() string

func (*ReplicateWorkflowStateRequest) GetWorkflowState added in v1.17.0

func (*ReplicateWorkflowStateRequest) GoString added in v1.17.0

func (this *ReplicateWorkflowStateRequest) GoString() string

func (*ReplicateWorkflowStateRequest) Marshal added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) MarshalTo added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) MarshalToSizedBuffer added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) ProtoMessage added in v1.17.0

func (*ReplicateWorkflowStateRequest) ProtoMessage()

func (*ReplicateWorkflowStateRequest) Reset added in v1.17.0

func (m *ReplicateWorkflowStateRequest) Reset()

func (*ReplicateWorkflowStateRequest) Size added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) String added in v1.17.0

func (this *ReplicateWorkflowStateRequest) String() string

func (*ReplicateWorkflowStateRequest) Unmarshal added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) XXX_DiscardUnknown added in v1.17.0

func (m *ReplicateWorkflowStateRequest) XXX_DiscardUnknown()

func (*ReplicateWorkflowStateRequest) XXX_Marshal added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) XXX_Merge added in v1.17.0

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

func (*ReplicateWorkflowStateRequest) XXX_Size added in v1.17.0

func (m *ReplicateWorkflowStateRequest) XXX_Size() int

func (*ReplicateWorkflowStateRequest) XXX_Unmarshal added in v1.17.0

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

type ReplicateWorkflowStateResponse added in v1.20.0

type ReplicateWorkflowStateResponse struct {
}

func (*ReplicateWorkflowStateResponse) Descriptor added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) Equal added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) GoString added in v1.20.0

func (this *ReplicateWorkflowStateResponse) GoString() string

func (*ReplicateWorkflowStateResponse) Marshal added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) MarshalTo added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) MarshalToSizedBuffer added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) ProtoMessage added in v1.20.0

func (*ReplicateWorkflowStateResponse) ProtoMessage()

func (*ReplicateWorkflowStateResponse) Reset added in v1.20.0

func (m *ReplicateWorkflowStateResponse) Reset()

func (*ReplicateWorkflowStateResponse) Size added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) String added in v1.20.0

func (this *ReplicateWorkflowStateResponse) String() string

func (*ReplicateWorkflowStateResponse) Unmarshal added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) XXX_DiscardUnknown added in v1.20.0

func (m *ReplicateWorkflowStateResponse) XXX_DiscardUnknown()

func (*ReplicateWorkflowStateResponse) XXX_Marshal added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) XXX_Merge added in v1.20.0

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

func (*ReplicateWorkflowStateResponse) XXX_Size added in v1.20.0

func (m *ReplicateWorkflowStateResponse) XXX_Size() int

func (*ReplicateWorkflowStateResponse) XXX_Unmarshal added in v1.20.0

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

type RequestCancelWorkflowExecutionRequest

type RequestCancelWorkflowExecutionRequest struct {
	NamespaceId               string                                    `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	CancelRequest             *v1.RequestCancelWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=cancel_request,json=cancelRequest,proto3" json:"cancel_request,omitempty"`
	ExternalInitiatedEventId  int64                                     `` /* 138-byte string literal not displayed */
	ExternalWorkflowExecution *v14.WorkflowExecution                    `` /* 138-byte string literal not displayed */
	ChildWorkflowOnly         bool                                      `protobuf:"varint,5,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"`
}

func (*RequestCancelWorkflowExecutionRequest) Descriptor

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

func (*RequestCancelWorkflowExecutionRequest) Equal

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

func (*RequestCancelWorkflowExecutionRequest) GetCancelRequest

func (*RequestCancelWorkflowExecutionRequest) GetChildWorkflowOnly

func (m *RequestCancelWorkflowExecutionRequest) GetChildWorkflowOnly() bool

func (*RequestCancelWorkflowExecutionRequest) GetExternalInitiatedEventId

func (m *RequestCancelWorkflowExecutionRequest) GetExternalInitiatedEventId() int64

func (*RequestCancelWorkflowExecutionRequest) GetExternalWorkflowExecution

func (m *RequestCancelWorkflowExecutionRequest) GetExternalWorkflowExecution() *v14.WorkflowExecution

func (*RequestCancelWorkflowExecutionRequest) GetNamespaceId

func (m *RequestCancelWorkflowExecutionRequest) GetNamespaceId() string

func (*RequestCancelWorkflowExecutionRequest) GoString

func (*RequestCancelWorkflowExecutionRequest) Marshal

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

func (*RequestCancelWorkflowExecutionRequest) MarshalTo

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

func (*RequestCancelWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

func (*RequestCancelWorkflowExecutionRequest) Reset

func (*RequestCancelWorkflowExecutionRequest) Size

func (*RequestCancelWorkflowExecutionRequest) String

func (*RequestCancelWorkflowExecutionRequest) Unmarshal

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

func (*RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*RequestCancelWorkflowExecutionRequest) XXX_Marshal

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

func (*RequestCancelWorkflowExecutionRequest) XXX_Merge

func (*RequestCancelWorkflowExecutionRequest) XXX_Size

func (*RequestCancelWorkflowExecutionRequest) XXX_Unmarshal

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

type RequestCancelWorkflowExecutionResponse

type RequestCancelWorkflowExecutionResponse struct {
}

func (*RequestCancelWorkflowExecutionResponse) Descriptor

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

func (*RequestCancelWorkflowExecutionResponse) Equal

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

func (*RequestCancelWorkflowExecutionResponse) GoString

func (*RequestCancelWorkflowExecutionResponse) Marshal

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

func (*RequestCancelWorkflowExecutionResponse) MarshalTo

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

func (*RequestCancelWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*RequestCancelWorkflowExecutionResponse) ProtoMessage

func (*RequestCancelWorkflowExecutionResponse) Reset

func (*RequestCancelWorkflowExecutionResponse) Size

func (*RequestCancelWorkflowExecutionResponse) String

func (*RequestCancelWorkflowExecutionResponse) Unmarshal

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

func (*RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*RequestCancelWorkflowExecutionResponse) XXX_Marshal

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

func (*RequestCancelWorkflowExecutionResponse) XXX_Merge

func (*RequestCancelWorkflowExecutionResponse) XXX_Size

func (*RequestCancelWorkflowExecutionResponse) XXX_Unmarshal

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

type ResetStickyTaskQueueRequest

type ResetStickyTaskQueueRequest struct {
	NamespaceId string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution   *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*ResetStickyTaskQueueRequest) Descriptor

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

func (*ResetStickyTaskQueueRequest) Equal

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

func (*ResetStickyTaskQueueRequest) GetExecution

func (*ResetStickyTaskQueueRequest) GetNamespaceId

func (m *ResetStickyTaskQueueRequest) GetNamespaceId() string

func (*ResetStickyTaskQueueRequest) GoString

func (this *ResetStickyTaskQueueRequest) GoString() string

func (*ResetStickyTaskQueueRequest) Marshal

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

func (*ResetStickyTaskQueueRequest) MarshalTo

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

func (*ResetStickyTaskQueueRequest) MarshalToSizedBuffer

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

func (*ResetStickyTaskQueueRequest) ProtoMessage

func (*ResetStickyTaskQueueRequest) ProtoMessage()

func (*ResetStickyTaskQueueRequest) Reset

func (m *ResetStickyTaskQueueRequest) Reset()

func (*ResetStickyTaskQueueRequest) Size

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

func (*ResetStickyTaskQueueRequest) String

func (this *ResetStickyTaskQueueRequest) String() string

func (*ResetStickyTaskQueueRequest) Unmarshal

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

func (*ResetStickyTaskQueueRequest) XXX_DiscardUnknown

func (m *ResetStickyTaskQueueRequest) XXX_DiscardUnknown()

func (*ResetStickyTaskQueueRequest) XXX_Marshal

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

func (*ResetStickyTaskQueueRequest) XXX_Merge

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

func (*ResetStickyTaskQueueRequest) XXX_Size

func (m *ResetStickyTaskQueueRequest) XXX_Size() int

func (*ResetStickyTaskQueueRequest) XXX_Unmarshal

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

type ResetStickyTaskQueueResponse

type ResetStickyTaskQueueResponse struct {
}

func (*ResetStickyTaskQueueResponse) Descriptor

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

func (*ResetStickyTaskQueueResponse) Equal

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

func (*ResetStickyTaskQueueResponse) GoString

func (this *ResetStickyTaskQueueResponse) GoString() string

func (*ResetStickyTaskQueueResponse) Marshal

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

func (*ResetStickyTaskQueueResponse) MarshalTo

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

func (*ResetStickyTaskQueueResponse) MarshalToSizedBuffer

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

func (*ResetStickyTaskQueueResponse) ProtoMessage

func (*ResetStickyTaskQueueResponse) ProtoMessage()

func (*ResetStickyTaskQueueResponse) Reset

func (m *ResetStickyTaskQueueResponse) Reset()

func (*ResetStickyTaskQueueResponse) Size

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

func (*ResetStickyTaskQueueResponse) String

func (this *ResetStickyTaskQueueResponse) String() string

func (*ResetStickyTaskQueueResponse) Unmarshal

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

func (*ResetStickyTaskQueueResponse) XXX_DiscardUnknown

func (m *ResetStickyTaskQueueResponse) XXX_DiscardUnknown()

func (*ResetStickyTaskQueueResponse) XXX_Marshal

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

func (*ResetStickyTaskQueueResponse) XXX_Merge

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

func (*ResetStickyTaskQueueResponse) XXX_Size

func (m *ResetStickyTaskQueueResponse) XXX_Size() int

func (*ResetStickyTaskQueueResponse) XXX_Unmarshal

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

type ResetWorkflowExecutionRequest

type ResetWorkflowExecutionRequest struct {
	NamespaceId  string                            `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	ResetRequest *v1.ResetWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=reset_request,json=resetRequest,proto3" json:"reset_request,omitempty"`
}

func (*ResetWorkflowExecutionRequest) Descriptor

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

func (*ResetWorkflowExecutionRequest) Equal

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

func (*ResetWorkflowExecutionRequest) GetNamespaceId

func (m *ResetWorkflowExecutionRequest) GetNamespaceId() string

func (*ResetWorkflowExecutionRequest) GetResetRequest

func (*ResetWorkflowExecutionRequest) GoString

func (this *ResetWorkflowExecutionRequest) GoString() string

func (*ResetWorkflowExecutionRequest) Marshal

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

func (*ResetWorkflowExecutionRequest) MarshalTo

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

func (*ResetWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*ResetWorkflowExecutionRequest) ProtoMessage

func (*ResetWorkflowExecutionRequest) ProtoMessage()

func (*ResetWorkflowExecutionRequest) Reset

func (m *ResetWorkflowExecutionRequest) Reset()

func (*ResetWorkflowExecutionRequest) Size

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

func (*ResetWorkflowExecutionRequest) String

func (this *ResetWorkflowExecutionRequest) String() string

func (*ResetWorkflowExecutionRequest) Unmarshal

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

func (*ResetWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *ResetWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionRequest) XXX_Marshal

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

func (*ResetWorkflowExecutionRequest) XXX_Merge

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

func (*ResetWorkflowExecutionRequest) XXX_Size

func (m *ResetWorkflowExecutionRequest) XXX_Size() int

func (*ResetWorkflowExecutionRequest) XXX_Unmarshal

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

type ResetWorkflowExecutionResponse

type ResetWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
}

func (*ResetWorkflowExecutionResponse) Descriptor

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

func (*ResetWorkflowExecutionResponse) Equal

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

func (*ResetWorkflowExecutionResponse) GetRunId

func (m *ResetWorkflowExecutionResponse) GetRunId() string

func (*ResetWorkflowExecutionResponse) GoString

func (this *ResetWorkflowExecutionResponse) GoString() string

func (*ResetWorkflowExecutionResponse) Marshal

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

func (*ResetWorkflowExecutionResponse) MarshalTo

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

func (*ResetWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*ResetWorkflowExecutionResponse) ProtoMessage

func (*ResetWorkflowExecutionResponse) ProtoMessage()

func (*ResetWorkflowExecutionResponse) Reset

func (m *ResetWorkflowExecutionResponse) Reset()

func (*ResetWorkflowExecutionResponse) Size

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

func (*ResetWorkflowExecutionResponse) String

func (this *ResetWorkflowExecutionResponse) String() string

func (*ResetWorkflowExecutionResponse) Unmarshal

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

func (*ResetWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *ResetWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionResponse) XXX_Marshal

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

func (*ResetWorkflowExecutionResponse) XXX_Merge

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

func (*ResetWorkflowExecutionResponse) XXX_Size

func (m *ResetWorkflowExecutionResponse) XXX_Size() int

func (*ResetWorkflowExecutionResponse) XXX_Unmarshal

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

type RespondActivityTaskCanceledRequest

type RespondActivityTaskCanceledRequest struct {
	NamespaceId   string                                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	CancelRequest *v1.RespondActivityTaskCanceledRequest `protobuf:"bytes,2,opt,name=cancel_request,json=cancelRequest,proto3" json:"cancel_request,omitempty"`
}

func (*RespondActivityTaskCanceledRequest) Descriptor

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

func (*RespondActivityTaskCanceledRequest) Equal

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

func (*RespondActivityTaskCanceledRequest) GetCancelRequest

func (*RespondActivityTaskCanceledRequest) GetNamespaceId

func (m *RespondActivityTaskCanceledRequest) GetNamespaceId() string

func (*RespondActivityTaskCanceledRequest) GoString

func (this *RespondActivityTaskCanceledRequest) GoString() string

func (*RespondActivityTaskCanceledRequest) Marshal

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

func (*RespondActivityTaskCanceledRequest) MarshalTo

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

func (*RespondActivityTaskCanceledRequest) MarshalToSizedBuffer

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

func (*RespondActivityTaskCanceledRequest) ProtoMessage

func (*RespondActivityTaskCanceledRequest) ProtoMessage()

func (*RespondActivityTaskCanceledRequest) Reset

func (*RespondActivityTaskCanceledRequest) Size

func (*RespondActivityTaskCanceledRequest) String

func (*RespondActivityTaskCanceledRequest) Unmarshal

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

func (*RespondActivityTaskCanceledRequest) XXX_DiscardUnknown

func (m *RespondActivityTaskCanceledRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledRequest) XXX_Marshal

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

func (*RespondActivityTaskCanceledRequest) XXX_Merge

func (*RespondActivityTaskCanceledRequest) XXX_Size

func (*RespondActivityTaskCanceledRequest) XXX_Unmarshal

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

type RespondActivityTaskCanceledResponse

type RespondActivityTaskCanceledResponse struct {
}

func (*RespondActivityTaskCanceledResponse) Descriptor

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

func (*RespondActivityTaskCanceledResponse) Equal

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

func (*RespondActivityTaskCanceledResponse) GoString

func (*RespondActivityTaskCanceledResponse) Marshal

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

func (*RespondActivityTaskCanceledResponse) MarshalTo

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

func (*RespondActivityTaskCanceledResponse) MarshalToSizedBuffer

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

func (*RespondActivityTaskCanceledResponse) ProtoMessage

func (*RespondActivityTaskCanceledResponse) ProtoMessage()

func (*RespondActivityTaskCanceledResponse) Reset

func (*RespondActivityTaskCanceledResponse) Size

func (*RespondActivityTaskCanceledResponse) String

func (*RespondActivityTaskCanceledResponse) Unmarshal

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

func (*RespondActivityTaskCanceledResponse) XXX_DiscardUnknown

func (m *RespondActivityTaskCanceledResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledResponse) XXX_Marshal

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

func (*RespondActivityTaskCanceledResponse) XXX_Merge

func (*RespondActivityTaskCanceledResponse) XXX_Size

func (*RespondActivityTaskCanceledResponse) XXX_Unmarshal

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

type RespondActivityTaskCompletedRequest

type RespondActivityTaskCompletedRequest struct {
	NamespaceId     string                                  `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	CompleteRequest *v1.RespondActivityTaskCompletedRequest `protobuf:"bytes,2,opt,name=complete_request,json=completeRequest,proto3" json:"complete_request,omitempty"`
}

func (*RespondActivityTaskCompletedRequest) Descriptor

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

func (*RespondActivityTaskCompletedRequest) Equal

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

func (*RespondActivityTaskCompletedRequest) GetCompleteRequest

func (*RespondActivityTaskCompletedRequest) GetNamespaceId

func (m *RespondActivityTaskCompletedRequest) GetNamespaceId() string

func (*RespondActivityTaskCompletedRequest) GoString

func (*RespondActivityTaskCompletedRequest) Marshal

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

func (*RespondActivityTaskCompletedRequest) MarshalTo

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

func (*RespondActivityTaskCompletedRequest) MarshalToSizedBuffer

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

func (*RespondActivityTaskCompletedRequest) ProtoMessage

func (*RespondActivityTaskCompletedRequest) ProtoMessage()

func (*RespondActivityTaskCompletedRequest) Reset

func (*RespondActivityTaskCompletedRequest) Size

func (*RespondActivityTaskCompletedRequest) String

func (*RespondActivityTaskCompletedRequest) Unmarshal

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

func (*RespondActivityTaskCompletedRequest) XXX_DiscardUnknown

func (m *RespondActivityTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedRequest) XXX_Marshal

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

func (*RespondActivityTaskCompletedRequest) XXX_Merge

func (*RespondActivityTaskCompletedRequest) XXX_Size

func (*RespondActivityTaskCompletedRequest) XXX_Unmarshal

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

type RespondActivityTaskCompletedResponse

type RespondActivityTaskCompletedResponse struct {
}

func (*RespondActivityTaskCompletedResponse) Descriptor

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

func (*RespondActivityTaskCompletedResponse) Equal

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

func (*RespondActivityTaskCompletedResponse) GoString

func (*RespondActivityTaskCompletedResponse) Marshal

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

func (*RespondActivityTaskCompletedResponse) MarshalTo

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

func (*RespondActivityTaskCompletedResponse) MarshalToSizedBuffer

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

func (*RespondActivityTaskCompletedResponse) ProtoMessage

func (*RespondActivityTaskCompletedResponse) ProtoMessage()

func (*RespondActivityTaskCompletedResponse) Reset

func (*RespondActivityTaskCompletedResponse) Size

func (*RespondActivityTaskCompletedResponse) String

func (*RespondActivityTaskCompletedResponse) Unmarshal

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

func (*RespondActivityTaskCompletedResponse) XXX_DiscardUnknown

func (m *RespondActivityTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedResponse) XXX_Marshal

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

func (*RespondActivityTaskCompletedResponse) XXX_Merge

func (*RespondActivityTaskCompletedResponse) XXX_Size

func (*RespondActivityTaskCompletedResponse) XXX_Unmarshal

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

type RespondActivityTaskFailedRequest

type RespondActivityTaskFailedRequest struct {
	NamespaceId   string                               `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	FailedRequest *v1.RespondActivityTaskFailedRequest `protobuf:"bytes,2,opt,name=failed_request,json=failedRequest,proto3" json:"failed_request,omitempty"`
}

func (*RespondActivityTaskFailedRequest) Descriptor

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

func (*RespondActivityTaskFailedRequest) Equal

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

func (*RespondActivityTaskFailedRequest) GetFailedRequest

func (*RespondActivityTaskFailedRequest) GetNamespaceId

func (m *RespondActivityTaskFailedRequest) GetNamespaceId() string

func (*RespondActivityTaskFailedRequest) GoString

func (this *RespondActivityTaskFailedRequest) GoString() string

func (*RespondActivityTaskFailedRequest) Marshal

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

func (*RespondActivityTaskFailedRequest) MarshalTo

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

func (*RespondActivityTaskFailedRequest) MarshalToSizedBuffer

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

func (*RespondActivityTaskFailedRequest) ProtoMessage

func (*RespondActivityTaskFailedRequest) ProtoMessage()

func (*RespondActivityTaskFailedRequest) Reset

func (*RespondActivityTaskFailedRequest) Size

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

func (*RespondActivityTaskFailedRequest) String

func (*RespondActivityTaskFailedRequest) Unmarshal

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

func (*RespondActivityTaskFailedRequest) XXX_DiscardUnknown

func (m *RespondActivityTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedRequest) XXX_Marshal

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

func (*RespondActivityTaskFailedRequest) XXX_Merge

func (*RespondActivityTaskFailedRequest) XXX_Size

func (m *RespondActivityTaskFailedRequest) XXX_Size() int

func (*RespondActivityTaskFailedRequest) XXX_Unmarshal

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

type RespondActivityTaskFailedResponse

type RespondActivityTaskFailedResponse struct {
}

func (*RespondActivityTaskFailedResponse) Descriptor

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

func (*RespondActivityTaskFailedResponse) Equal

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

func (*RespondActivityTaskFailedResponse) GoString

func (this *RespondActivityTaskFailedResponse) GoString() string

func (*RespondActivityTaskFailedResponse) Marshal

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

func (*RespondActivityTaskFailedResponse) MarshalTo

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

func (*RespondActivityTaskFailedResponse) MarshalToSizedBuffer

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

func (*RespondActivityTaskFailedResponse) ProtoMessage

func (*RespondActivityTaskFailedResponse) ProtoMessage()

func (*RespondActivityTaskFailedResponse) Reset

func (*RespondActivityTaskFailedResponse) Size

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

func (*RespondActivityTaskFailedResponse) String

func (*RespondActivityTaskFailedResponse) Unmarshal

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

func (*RespondActivityTaskFailedResponse) XXX_DiscardUnknown

func (m *RespondActivityTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedResponse) XXX_Marshal

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

func (*RespondActivityTaskFailedResponse) XXX_Merge

func (*RespondActivityTaskFailedResponse) XXX_Size

func (m *RespondActivityTaskFailedResponse) XXX_Size() int

func (*RespondActivityTaskFailedResponse) XXX_Unmarshal

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

type RespondWorkflowTaskCompletedRequest

type RespondWorkflowTaskCompletedRequest struct {
	NamespaceId     string                                  `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	CompleteRequest *v1.RespondWorkflowTaskCompletedRequest `protobuf:"bytes,2,opt,name=complete_request,json=completeRequest,proto3" json:"complete_request,omitempty"`
}

func (*RespondWorkflowTaskCompletedRequest) Descriptor

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

func (*RespondWorkflowTaskCompletedRequest) Equal

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

func (*RespondWorkflowTaskCompletedRequest) GetCompleteRequest

func (*RespondWorkflowTaskCompletedRequest) GetNamespaceId

func (m *RespondWorkflowTaskCompletedRequest) GetNamespaceId() string

func (*RespondWorkflowTaskCompletedRequest) GoString

func (*RespondWorkflowTaskCompletedRequest) Marshal

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

func (*RespondWorkflowTaskCompletedRequest) MarshalTo

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

func (*RespondWorkflowTaskCompletedRequest) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage()

func (*RespondWorkflowTaskCompletedRequest) Reset

func (*RespondWorkflowTaskCompletedRequest) Size

func (*RespondWorkflowTaskCompletedRequest) String

func (*RespondWorkflowTaskCompletedRequest) Unmarshal

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

func (*RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown

func (m *RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondWorkflowTaskCompletedRequest) XXX_Marshal

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

func (*RespondWorkflowTaskCompletedRequest) XXX_Merge

func (*RespondWorkflowTaskCompletedRequest) XXX_Size

func (*RespondWorkflowTaskCompletedRequest) XXX_Unmarshal

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

type RespondWorkflowTaskCompletedResponse

type RespondWorkflowTaskCompletedResponse struct {
	StartedResponse     *RecordWorkflowTaskStartedResponse  `protobuf:"bytes,1,opt,name=started_response,json=startedResponse,proto3" json:"started_response,omitempty"`
	ActivityTasks       []*v1.PollActivityTaskQueueResponse `protobuf:"bytes,2,rep,name=activity_tasks,json=activityTasks,proto3" json:"activity_tasks,omitempty"`
	ResetHistoryEventId int64                               `protobuf:"varint,3,opt,name=reset_history_event_id,json=resetHistoryEventId,proto3" json:"reset_history_event_id,omitempty"`
}

func (*RespondWorkflowTaskCompletedResponse) Descriptor

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

func (*RespondWorkflowTaskCompletedResponse) Equal

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

func (*RespondWorkflowTaskCompletedResponse) GetActivityTasks added in v1.16.0

func (*RespondWorkflowTaskCompletedResponse) GetResetHistoryEventId added in v1.20.0

func (m *RespondWorkflowTaskCompletedResponse) GetResetHistoryEventId() int64

func (*RespondWorkflowTaskCompletedResponse) GetStartedResponse

func (*RespondWorkflowTaskCompletedResponse) GoString

func (*RespondWorkflowTaskCompletedResponse) Marshal

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

func (*RespondWorkflowTaskCompletedResponse) MarshalTo

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

func (*RespondWorkflowTaskCompletedResponse) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

func (*RespondWorkflowTaskCompletedResponse) Reset

func (*RespondWorkflowTaskCompletedResponse) Size

func (*RespondWorkflowTaskCompletedResponse) String

func (*RespondWorkflowTaskCompletedResponse) Unmarshal

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

func (*RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown

func (m *RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondWorkflowTaskCompletedResponse) XXX_Marshal

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

func (*RespondWorkflowTaskCompletedResponse) XXX_Merge

func (*RespondWorkflowTaskCompletedResponse) XXX_Size

func (*RespondWorkflowTaskCompletedResponse) XXX_Unmarshal

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

type RespondWorkflowTaskFailedRequest

type RespondWorkflowTaskFailedRequest struct {
	NamespaceId   string                               `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	FailedRequest *v1.RespondWorkflowTaskFailedRequest `protobuf:"bytes,2,opt,name=failed_request,json=failedRequest,proto3" json:"failed_request,omitempty"`
}

func (*RespondWorkflowTaskFailedRequest) Descriptor

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

func (*RespondWorkflowTaskFailedRequest) Equal

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

func (*RespondWorkflowTaskFailedRequest) GetFailedRequest

func (*RespondWorkflowTaskFailedRequest) GetNamespaceId

func (m *RespondWorkflowTaskFailedRequest) GetNamespaceId() string

func (*RespondWorkflowTaskFailedRequest) GoString

func (this *RespondWorkflowTaskFailedRequest) GoString() string

func (*RespondWorkflowTaskFailedRequest) Marshal

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

func (*RespondWorkflowTaskFailedRequest) MarshalTo

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

func (*RespondWorkflowTaskFailedRequest) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskFailedRequest) ProtoMessage

func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

func (*RespondWorkflowTaskFailedRequest) Reset

func (*RespondWorkflowTaskFailedRequest) Size

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

func (*RespondWorkflowTaskFailedRequest) String

func (*RespondWorkflowTaskFailedRequest) Unmarshal

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

func (*RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown

func (m *RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondWorkflowTaskFailedRequest) XXX_Marshal

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

func (*RespondWorkflowTaskFailedRequest) XXX_Merge

func (*RespondWorkflowTaskFailedRequest) XXX_Size

func (m *RespondWorkflowTaskFailedRequest) XXX_Size() int

func (*RespondWorkflowTaskFailedRequest) XXX_Unmarshal

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

type RespondWorkflowTaskFailedResponse

type RespondWorkflowTaskFailedResponse struct {
}

func (*RespondWorkflowTaskFailedResponse) Descriptor

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

func (*RespondWorkflowTaskFailedResponse) Equal

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

func (*RespondWorkflowTaskFailedResponse) GoString

func (this *RespondWorkflowTaskFailedResponse) GoString() string

func (*RespondWorkflowTaskFailedResponse) Marshal

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

func (*RespondWorkflowTaskFailedResponse) MarshalTo

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

func (*RespondWorkflowTaskFailedResponse) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskFailedResponse) ProtoMessage

func (*RespondWorkflowTaskFailedResponse) ProtoMessage()

func (*RespondWorkflowTaskFailedResponse) Reset

func (*RespondWorkflowTaskFailedResponse) Size

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

func (*RespondWorkflowTaskFailedResponse) String

func (*RespondWorkflowTaskFailedResponse) Unmarshal

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

func (*RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown

func (m *RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondWorkflowTaskFailedResponse) XXX_Marshal

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

func (*RespondWorkflowTaskFailedResponse) XXX_Merge

func (*RespondWorkflowTaskFailedResponse) XXX_Size

func (m *RespondWorkflowTaskFailedResponse) XXX_Size() int

func (*RespondWorkflowTaskFailedResponse) XXX_Unmarshal

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

type ScheduleWorkflowTaskRequest

type ScheduleWorkflowTaskRequest struct {
	NamespaceId         string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution   *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	IsFirstWorkflowTask bool                   `protobuf:"varint,3,opt,name=is_first_workflow_task,json=isFirstWorkflowTask,proto3" json:"is_first_workflow_task,omitempty"`
	ChildClock          *v15.VectorClock       `protobuf:"bytes,4,opt,name=child_clock,json=childClock,proto3" json:"child_clock,omitempty"`
	ParentClock         *v15.VectorClock       `protobuf:"bytes,5,opt,name=parent_clock,json=parentClock,proto3" json:"parent_clock,omitempty"`
}

func (*ScheduleWorkflowTaskRequest) Descriptor

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

func (*ScheduleWorkflowTaskRequest) Equal

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

func (*ScheduleWorkflowTaskRequest) GetChildClock added in v1.20.1

func (m *ScheduleWorkflowTaskRequest) GetChildClock() *v15.VectorClock

func (*ScheduleWorkflowTaskRequest) GetIsFirstWorkflowTask

func (m *ScheduleWorkflowTaskRequest) GetIsFirstWorkflowTask() bool

func (*ScheduleWorkflowTaskRequest) GetNamespaceId

func (m *ScheduleWorkflowTaskRequest) GetNamespaceId() string

func (*ScheduleWorkflowTaskRequest) GetParentClock added in v1.20.1

func (m *ScheduleWorkflowTaskRequest) GetParentClock() *v15.VectorClock

func (*ScheduleWorkflowTaskRequest) GetWorkflowExecution

func (m *ScheduleWorkflowTaskRequest) GetWorkflowExecution() *v14.WorkflowExecution

func (*ScheduleWorkflowTaskRequest) GoString

func (this *ScheduleWorkflowTaskRequest) GoString() string

func (*ScheduleWorkflowTaskRequest) Marshal

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

func (*ScheduleWorkflowTaskRequest) MarshalTo

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

func (*ScheduleWorkflowTaskRequest) MarshalToSizedBuffer

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

func (*ScheduleWorkflowTaskRequest) ProtoMessage

func (*ScheduleWorkflowTaskRequest) ProtoMessage()

func (*ScheduleWorkflowTaskRequest) Reset

func (m *ScheduleWorkflowTaskRequest) Reset()

func (*ScheduleWorkflowTaskRequest) Size

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

func (*ScheduleWorkflowTaskRequest) String

func (this *ScheduleWorkflowTaskRequest) String() string

func (*ScheduleWorkflowTaskRequest) Unmarshal

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

func (*ScheduleWorkflowTaskRequest) XXX_DiscardUnknown

func (m *ScheduleWorkflowTaskRequest) XXX_DiscardUnknown()

func (*ScheduleWorkflowTaskRequest) XXX_Marshal

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

func (*ScheduleWorkflowTaskRequest) XXX_Merge

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

func (*ScheduleWorkflowTaskRequest) XXX_Size

func (m *ScheduleWorkflowTaskRequest) XXX_Size() int

func (*ScheduleWorkflowTaskRequest) XXX_Unmarshal

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

type ScheduleWorkflowTaskResponse

type ScheduleWorkflowTaskResponse struct {
}

func (*ScheduleWorkflowTaskResponse) Descriptor

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

func (*ScheduleWorkflowTaskResponse) Equal

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

func (*ScheduleWorkflowTaskResponse) GoString

func (this *ScheduleWorkflowTaskResponse) GoString() string

func (*ScheduleWorkflowTaskResponse) Marshal

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

func (*ScheduleWorkflowTaskResponse) MarshalTo

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

func (*ScheduleWorkflowTaskResponse) MarshalToSizedBuffer

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

func (*ScheduleWorkflowTaskResponse) ProtoMessage

func (*ScheduleWorkflowTaskResponse) ProtoMessage()

func (*ScheduleWorkflowTaskResponse) Reset

func (m *ScheduleWorkflowTaskResponse) Reset()

func (*ScheduleWorkflowTaskResponse) Size

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

func (*ScheduleWorkflowTaskResponse) String

func (this *ScheduleWorkflowTaskResponse) String() string

func (*ScheduleWorkflowTaskResponse) Unmarshal

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

func (*ScheduleWorkflowTaskResponse) XXX_DiscardUnknown

func (m *ScheduleWorkflowTaskResponse) XXX_DiscardUnknown()

func (*ScheduleWorkflowTaskResponse) XXX_Marshal

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

func (*ScheduleWorkflowTaskResponse) XXX_Merge

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

func (*ScheduleWorkflowTaskResponse) XXX_Size

func (m *ScheduleWorkflowTaskResponse) XXX_Size() int

func (*ScheduleWorkflowTaskResponse) XXX_Unmarshal

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

type ShardReplicationStatus added in v1.14.0

type ShardReplicationStatus struct {
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// Max replication task id of current cluster
	MaxReplicationTaskId int64 `` /* 126-byte string literal not displayed */
	// Local time on this shard
	ShardLocalTime                   *time.Time                                   `protobuf:"bytes,3,opt,name=shard_local_time,json=shardLocalTime,proto3,stdtime" json:"shard_local_time,omitempty"` // Deprecated: Do not use.
	RemoteClusters                   map[string]*ShardReplicationStatusPerCluster ``                                                                                                                  /* 191-byte string literal not displayed */
	HandoverNamespaces               map[string]*HandoverNamespaceInfo            ``                                                                                                                  /* 203-byte string literal not displayed */
	MaxReplicationTaskVisibilityTime *time.Time                                   ``                                                                                                                  /* 171-byte string literal not displayed */
}

func (*ShardReplicationStatus) Descriptor added in v1.14.0

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

func (*ShardReplicationStatus) Equal added in v1.14.0

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

func (*ShardReplicationStatus) GetHandoverNamespaces added in v1.14.0

func (m *ShardReplicationStatus) GetHandoverNamespaces() map[string]*HandoverNamespaceInfo

func (*ShardReplicationStatus) GetMaxReplicationTaskId added in v1.14.0

func (m *ShardReplicationStatus) GetMaxReplicationTaskId() int64

func (*ShardReplicationStatus) GetMaxReplicationTaskVisibilityTime added in v1.17.2

func (m *ShardReplicationStatus) GetMaxReplicationTaskVisibilityTime() *time.Time

func (*ShardReplicationStatus) GetRemoteClusters added in v1.14.0

func (*ShardReplicationStatus) GetShardId added in v1.14.0

func (m *ShardReplicationStatus) GetShardId() int32

func (*ShardReplicationStatus) GetShardLocalTime deprecated added in v1.14.0

func (m *ShardReplicationStatus) GetShardLocalTime() *time.Time

Deprecated: Do not use.

func (*ShardReplicationStatus) GoString added in v1.14.0

func (this *ShardReplicationStatus) GoString() string

func (*ShardReplicationStatus) Marshal added in v1.14.0

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

func (*ShardReplicationStatus) MarshalTo added in v1.14.0

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

func (*ShardReplicationStatus) MarshalToSizedBuffer added in v1.14.0

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

func (*ShardReplicationStatus) ProtoMessage added in v1.14.0

func (*ShardReplicationStatus) ProtoMessage()

func (*ShardReplicationStatus) Reset added in v1.14.0

func (m *ShardReplicationStatus) Reset()

func (*ShardReplicationStatus) Size added in v1.14.0

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

func (*ShardReplicationStatus) String added in v1.14.0

func (this *ShardReplicationStatus) String() string

func (*ShardReplicationStatus) Unmarshal added in v1.14.0

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

func (*ShardReplicationStatus) XXX_DiscardUnknown added in v1.14.0

func (m *ShardReplicationStatus) XXX_DiscardUnknown()

func (*ShardReplicationStatus) XXX_Marshal added in v1.14.0

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

func (*ShardReplicationStatus) XXX_Merge added in v1.14.0

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

func (*ShardReplicationStatus) XXX_Size added in v1.14.0

func (m *ShardReplicationStatus) XXX_Size() int

func (*ShardReplicationStatus) XXX_Unmarshal added in v1.14.0

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

type ShardReplicationStatusPerCluster added in v1.14.0

type ShardReplicationStatusPerCluster struct {
	// Acked replication task id
	AckedTaskId int64 `protobuf:"varint,1,opt,name=acked_task_id,json=ackedTaskId,proto3" json:"acked_task_id,omitempty"`
	// Acked replication task creation time
	AckedTaskVisibilityTime *time.Time `` /* 142-byte string literal not displayed */
}

func (*ShardReplicationStatusPerCluster) Descriptor added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) Equal added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) GetAckedTaskId added in v1.14.0

func (m *ShardReplicationStatusPerCluster) GetAckedTaskId() int64

func (*ShardReplicationStatusPerCluster) GetAckedTaskVisibilityTime added in v1.14.0

func (m *ShardReplicationStatusPerCluster) GetAckedTaskVisibilityTime() *time.Time

func (*ShardReplicationStatusPerCluster) GoString added in v1.14.0

func (this *ShardReplicationStatusPerCluster) GoString() string

func (*ShardReplicationStatusPerCluster) Marshal added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) MarshalTo added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) MarshalToSizedBuffer added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) ProtoMessage added in v1.14.0

func (*ShardReplicationStatusPerCluster) ProtoMessage()

func (*ShardReplicationStatusPerCluster) Reset added in v1.14.0

func (*ShardReplicationStatusPerCluster) Size added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) String added in v1.14.0

func (*ShardReplicationStatusPerCluster) Unmarshal added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) XXX_DiscardUnknown added in v1.14.0

func (m *ShardReplicationStatusPerCluster) XXX_DiscardUnknown()

func (*ShardReplicationStatusPerCluster) XXX_Marshal added in v1.14.0

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

func (*ShardReplicationStatusPerCluster) XXX_Merge added in v1.14.0

func (*ShardReplicationStatusPerCluster) XXX_Size added in v1.14.0

func (m *ShardReplicationStatusPerCluster) XXX_Size() int

func (*ShardReplicationStatusPerCluster) XXX_Unmarshal added in v1.14.0

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

type SignalWithStartWorkflowExecutionRequest

type SignalWithStartWorkflowExecutionRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "with" is needed here. --)
	SignalWithStartRequest *v1.SignalWithStartWorkflowExecutionRequest `` /* 131-byte string literal not displayed */
}

func (*SignalWithStartWorkflowExecutionRequest) Descriptor

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

func (*SignalWithStartWorkflowExecutionRequest) Equal

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

func (*SignalWithStartWorkflowExecutionRequest) GetNamespaceId

func (m *SignalWithStartWorkflowExecutionRequest) GetNamespaceId() string

func (*SignalWithStartWorkflowExecutionRequest) GetSignalWithStartRequest

func (*SignalWithStartWorkflowExecutionRequest) GoString

func (*SignalWithStartWorkflowExecutionRequest) Marshal

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

func (*SignalWithStartWorkflowExecutionRequest) MarshalTo

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

func (*SignalWithStartWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage

func (*SignalWithStartWorkflowExecutionRequest) Reset

func (*SignalWithStartWorkflowExecutionRequest) Size

func (*SignalWithStartWorkflowExecutionRequest) String

func (*SignalWithStartWorkflowExecutionRequest) Unmarshal

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

func (*SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*SignalWithStartWorkflowExecutionRequest) XXX_Marshal

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

func (*SignalWithStartWorkflowExecutionRequest) XXX_Merge

func (*SignalWithStartWorkflowExecutionRequest) XXX_Size

func (*SignalWithStartWorkflowExecutionRequest) XXX_Unmarshal

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

type SignalWithStartWorkflowExecutionResponse

type SignalWithStartWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
}

func (*SignalWithStartWorkflowExecutionResponse) Descriptor

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

func (*SignalWithStartWorkflowExecutionResponse) Equal

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

func (*SignalWithStartWorkflowExecutionResponse) GetRunId

func (*SignalWithStartWorkflowExecutionResponse) GoString

func (*SignalWithStartWorkflowExecutionResponse) Marshal

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

func (*SignalWithStartWorkflowExecutionResponse) MarshalTo

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

func (*SignalWithStartWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage

func (*SignalWithStartWorkflowExecutionResponse) Reset

func (*SignalWithStartWorkflowExecutionResponse) Size

func (*SignalWithStartWorkflowExecutionResponse) String

func (*SignalWithStartWorkflowExecutionResponse) Unmarshal

func (*SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*SignalWithStartWorkflowExecutionResponse) XXX_Marshal

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

func (*SignalWithStartWorkflowExecutionResponse) XXX_Merge

func (*SignalWithStartWorkflowExecutionResponse) XXX_Size

func (*SignalWithStartWorkflowExecutionResponse) XXX_Unmarshal

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

type SignalWorkflowExecutionRequest

type SignalWorkflowExecutionRequest struct {
	NamespaceId               string                             `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	SignalRequest             *v1.SignalWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=signal_request,json=signalRequest,proto3" json:"signal_request,omitempty"`
	ExternalWorkflowExecution *v14.WorkflowExecution             `` /* 138-byte string literal not displayed */
	ChildWorkflowOnly         bool                               `protobuf:"varint,4,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"`
}

func (*SignalWorkflowExecutionRequest) Descriptor

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

func (*SignalWorkflowExecutionRequest) Equal

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

func (*SignalWorkflowExecutionRequest) GetChildWorkflowOnly

func (m *SignalWorkflowExecutionRequest) GetChildWorkflowOnly() bool

func (*SignalWorkflowExecutionRequest) GetExternalWorkflowExecution

func (m *SignalWorkflowExecutionRequest) GetExternalWorkflowExecution() *v14.WorkflowExecution

func (*SignalWorkflowExecutionRequest) GetNamespaceId

func (m *SignalWorkflowExecutionRequest) GetNamespaceId() string

func (*SignalWorkflowExecutionRequest) GetSignalRequest

func (*SignalWorkflowExecutionRequest) GoString

func (this *SignalWorkflowExecutionRequest) GoString() string

func (*SignalWorkflowExecutionRequest) Marshal

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

func (*SignalWorkflowExecutionRequest) MarshalTo

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

func (*SignalWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*SignalWorkflowExecutionRequest) ProtoMessage

func (*SignalWorkflowExecutionRequest) ProtoMessage()

func (*SignalWorkflowExecutionRequest) Reset

func (m *SignalWorkflowExecutionRequest) Reset()

func (*SignalWorkflowExecutionRequest) Size

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

func (*SignalWorkflowExecutionRequest) String

func (this *SignalWorkflowExecutionRequest) String() string

func (*SignalWorkflowExecutionRequest) Unmarshal

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

func (*SignalWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *SignalWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*SignalWorkflowExecutionRequest) XXX_Marshal

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

func (*SignalWorkflowExecutionRequest) XXX_Merge

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

func (*SignalWorkflowExecutionRequest) XXX_Size

func (m *SignalWorkflowExecutionRequest) XXX_Size() int

func (*SignalWorkflowExecutionRequest) XXX_Unmarshal

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

type SignalWorkflowExecutionResponse

type SignalWorkflowExecutionResponse struct {
}

func (*SignalWorkflowExecutionResponse) Descriptor

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

func (*SignalWorkflowExecutionResponse) Equal

func (this *SignalWorkflowExecutionResponse) Equal(that interface{}) bool

func (*SignalWorkflowExecutionResponse) GoString

func (this *SignalWorkflowExecutionResponse) GoString() string

func (*SignalWorkflowExecutionResponse) Marshal

func (m *SignalWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*SignalWorkflowExecutionResponse) MarshalTo

func (m *SignalWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*SignalWorkflowExecutionResponse) MarshalToSizedBuffer

func (m *SignalWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignalWorkflowExecutionResponse) ProtoMessage

func (*SignalWorkflowExecutionResponse) ProtoMessage()

func (*SignalWorkflowExecutionResponse) Reset

func (*SignalWorkflowExecutionResponse) Size

func (m *SignalWorkflowExecutionResponse) Size() (n int)

func (*SignalWorkflowExecutionResponse) String

func (this *SignalWorkflowExecutionResponse) String() string

func (*SignalWorkflowExecutionResponse) Unmarshal

func (m *SignalWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*SignalWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *SignalWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*SignalWorkflowExecutionResponse) XXX_Marshal

func (m *SignalWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignalWorkflowExecutionResponse) XXX_Merge

func (m *SignalWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*SignalWorkflowExecutionResponse) XXX_Size

func (m *SignalWorkflowExecutionResponse) XXX_Size() int

func (*SignalWorkflowExecutionResponse) XXX_Unmarshal

func (m *SignalWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type StartWorkflowExecutionRequest

type StartWorkflowExecutionRequest struct {
	NamespaceId                     string                            `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	StartRequest                    *v1.StartWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=start_request,json=startRequest,proto3" json:"start_request,omitempty"`
	ParentExecutionInfo             *v11.ParentExecutionInfo          `protobuf:"bytes,3,opt,name=parent_execution_info,json=parentExecutionInfo,proto3" json:"parent_execution_info,omitempty"`
	Attempt                         int32                             `protobuf:"varint,4,opt,name=attempt,proto3" json:"attempt,omitempty"`
	WorkflowExecutionExpirationTime *time.Time                        `` /* 166-byte string literal not displayed */
	ContinueAsNewInitiator          v12.ContinueAsNewInitiator        `` /* 182-byte string literal not displayed */
	// History service should use the values of continued_failure and last_completion_result
	// here, not the ones in start_request (those are moved into here in the frontend).
	ContinuedFailure         *v13.Failure   `protobuf:"bytes,7,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"`
	LastCompletionResult     *v14.Payloads  `protobuf:"bytes,8,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"`
	FirstWorkflowTaskBackoff *time.Duration `` /* 149-byte string literal not displayed */
	// For child or continued-as-new workflows, including a version here from the source
	// (parent/previous) will set the initial version stamp of this workflow.
	SourceVersionStamp *v14.WorkerVersionStamp `protobuf:"bytes,10,opt,name=source_version_stamp,json=sourceVersionStamp,proto3" json:"source_version_stamp,omitempty"`
}

func (*StartWorkflowExecutionRequest) Descriptor

func (*StartWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*StartWorkflowExecutionRequest) Equal

func (this *StartWorkflowExecutionRequest) Equal(that interface{}) bool

func (*StartWorkflowExecutionRequest) GetAttempt

func (m *StartWorkflowExecutionRequest) GetAttempt() int32

func (*StartWorkflowExecutionRequest) GetContinueAsNewInitiator

func (m *StartWorkflowExecutionRequest) GetContinueAsNewInitiator() v12.ContinueAsNewInitiator

func (*StartWorkflowExecutionRequest) GetContinuedFailure

func (m *StartWorkflowExecutionRequest) GetContinuedFailure() *v13.Failure

func (*StartWorkflowExecutionRequest) GetFirstWorkflowTaskBackoff added in v0.28.0

func (m *StartWorkflowExecutionRequest) GetFirstWorkflowTaskBackoff() *time.Duration

func (*StartWorkflowExecutionRequest) GetLastCompletionResult

func (m *StartWorkflowExecutionRequest) GetLastCompletionResult() *v14.Payloads

func (*StartWorkflowExecutionRequest) GetNamespaceId

func (m *StartWorkflowExecutionRequest) GetNamespaceId() string

func (*StartWorkflowExecutionRequest) GetParentExecutionInfo

func (m *StartWorkflowExecutionRequest) GetParentExecutionInfo() *v11.ParentExecutionInfo

func (*StartWorkflowExecutionRequest) GetSourceVersionStamp added in v1.21.0

func (m *StartWorkflowExecutionRequest) GetSourceVersionStamp() *v14.WorkerVersionStamp

func (*StartWorkflowExecutionRequest) GetStartRequest

func (*StartWorkflowExecutionRequest) GetWorkflowExecutionExpirationTime added in v0.28.0

func (m *StartWorkflowExecutionRequest) GetWorkflowExecutionExpirationTime() *time.Time

func (*StartWorkflowExecutionRequest) GoString

func (this *StartWorkflowExecutionRequest) GoString() string

func (*StartWorkflowExecutionRequest) Marshal

func (m *StartWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*StartWorkflowExecutionRequest) MarshalTo

func (m *StartWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartWorkflowExecutionRequest) MarshalToSizedBuffer

func (m *StartWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartWorkflowExecutionRequest) ProtoMessage

func (*StartWorkflowExecutionRequest) ProtoMessage()

func (*StartWorkflowExecutionRequest) Reset

func (m *StartWorkflowExecutionRequest) Reset()

func (*StartWorkflowExecutionRequest) Size

func (m *StartWorkflowExecutionRequest) Size() (n int)

func (*StartWorkflowExecutionRequest) String

func (this *StartWorkflowExecutionRequest) String() string

func (*StartWorkflowExecutionRequest) Unmarshal

func (m *StartWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*StartWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *StartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*StartWorkflowExecutionRequest) XXX_Marshal

func (m *StartWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartWorkflowExecutionRequest) XXX_Merge

func (m *StartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*StartWorkflowExecutionRequest) XXX_Size

func (m *StartWorkflowExecutionRequest) XXX_Size() int

func (*StartWorkflowExecutionRequest) XXX_Unmarshal

func (m *StartWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type StartWorkflowExecutionResponse

type StartWorkflowExecutionResponse struct {
	RunId string           `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Clock *v15.VectorClock `protobuf:"bytes,2,opt,name=clock,proto3" json:"clock,omitempty"`
	// Set if request_eager_execution is set on the start request
	EagerWorkflowTask *v1.PollWorkflowTaskQueueResponse `protobuf:"bytes,3,opt,name=eager_workflow_task,json=eagerWorkflowTask,proto3" json:"eager_workflow_task,omitempty"`
}

func (*StartWorkflowExecutionResponse) Descriptor

func (*StartWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*StartWorkflowExecutionResponse) Equal

func (this *StartWorkflowExecutionResponse) Equal(that interface{}) bool

func (*StartWorkflowExecutionResponse) GetClock added in v1.17.0

func (*StartWorkflowExecutionResponse) GetEagerWorkflowTask added in v1.20.0

func (*StartWorkflowExecutionResponse) GetRunId

func (m *StartWorkflowExecutionResponse) GetRunId() string

func (*StartWorkflowExecutionResponse) GoString

func (this *StartWorkflowExecutionResponse) GoString() string

func (*StartWorkflowExecutionResponse) Marshal

func (m *StartWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*StartWorkflowExecutionResponse) MarshalTo

func (m *StartWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*StartWorkflowExecutionResponse) MarshalToSizedBuffer

func (m *StartWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartWorkflowExecutionResponse) ProtoMessage

func (*StartWorkflowExecutionResponse) ProtoMessage()

func (*StartWorkflowExecutionResponse) Reset

func (m *StartWorkflowExecutionResponse) Reset()

func (*StartWorkflowExecutionResponse) Size

func (m *StartWorkflowExecutionResponse) Size() (n int)

func (*StartWorkflowExecutionResponse) String

func (this *StartWorkflowExecutionResponse) String() string

func (*StartWorkflowExecutionResponse) Unmarshal

func (m *StartWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*StartWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *StartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*StartWorkflowExecutionResponse) XXX_Marshal

func (m *StartWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartWorkflowExecutionResponse) XXX_Merge

func (m *StartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*StartWorkflowExecutionResponse) XXX_Size

func (m *StartWorkflowExecutionResponse) XXX_Size() int

func (*StartWorkflowExecutionResponse) XXX_Unmarshal

func (m *StartWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type StreamWorkflowReplicationMessagesRequest added in v1.21.0

type StreamWorkflowReplicationMessagesRequest struct {
	// Types that are valid to be assigned to Attributes:
	//
	//	*StreamWorkflowReplicationMessagesRequest_SyncReplicationState
	Attributes isStreamWorkflowReplicationMessagesRequest_Attributes `protobuf_oneof:"attributes"`
}

func (*StreamWorkflowReplicationMessagesRequest) Descriptor added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) Descriptor() ([]byte, []int)

func (*StreamWorkflowReplicationMessagesRequest) Equal added in v1.21.0

func (this *StreamWorkflowReplicationMessagesRequest) Equal(that interface{}) bool

func (*StreamWorkflowReplicationMessagesRequest) GetAttributes added in v1.21.0

func (m *StreamWorkflowReplicationMessagesRequest) GetAttributes() isStreamWorkflowReplicationMessagesRequest_Attributes

func (*StreamWorkflowReplicationMessagesRequest) GetSyncReplicationState added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) GoString added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) Marshal added in v1.21.0

func (m *StreamWorkflowReplicationMessagesRequest) Marshal() (dAtA []byte, err error)

func (*StreamWorkflowReplicationMessagesRequest) MarshalTo added in v1.21.0

func (m *StreamWorkflowReplicationMessagesRequest) MarshalTo(dAtA []byte) (int, error)

func (*StreamWorkflowReplicationMessagesRequest) MarshalToSizedBuffer added in v1.21.0

func (m *StreamWorkflowReplicationMessagesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamWorkflowReplicationMessagesRequest) ProtoMessage added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) Reset added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) Size added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) String added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) Unmarshal added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) XXX_DiscardUnknown added in v1.21.0

func (m *StreamWorkflowReplicationMessagesRequest) XXX_DiscardUnknown()

func (*StreamWorkflowReplicationMessagesRequest) XXX_Marshal added in v1.21.0

func (m *StreamWorkflowReplicationMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamWorkflowReplicationMessagesRequest) XXX_Merge added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) XXX_OneofWrappers added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamWorkflowReplicationMessagesRequest) XXX_Size added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest) XXX_Unmarshal added in v1.21.0

func (m *StreamWorkflowReplicationMessagesRequest) XXX_Unmarshal(b []byte) error

type StreamWorkflowReplicationMessagesRequest_SyncReplicationState added in v1.21.0

type StreamWorkflowReplicationMessagesRequest_SyncReplicationState struct {
	SyncReplicationState *v115.SyncReplicationState `` /* 129-byte string literal not displayed */
}

func (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState) Equal added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState) GoString added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState) MarshalTo added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState) MarshalToSizedBuffer added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState) Size added in v1.21.0

func (*StreamWorkflowReplicationMessagesRequest_SyncReplicationState) String added in v1.21.0

type StreamWorkflowReplicationMessagesResponse added in v1.21.0

type StreamWorkflowReplicationMessagesResponse struct {
	// Types that are valid to be assigned to Attributes:
	//
	//	*StreamWorkflowReplicationMessagesResponse_Messages
	Attributes isStreamWorkflowReplicationMessagesResponse_Attributes `protobuf_oneof:"attributes"`
}

func (*StreamWorkflowReplicationMessagesResponse) Descriptor added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) Descriptor() ([]byte, []int)

func (*StreamWorkflowReplicationMessagesResponse) Equal added in v1.21.0

func (this *StreamWorkflowReplicationMessagesResponse) Equal(that interface{}) bool

func (*StreamWorkflowReplicationMessagesResponse) GetAttributes added in v1.21.0

func (m *StreamWorkflowReplicationMessagesResponse) GetAttributes() isStreamWorkflowReplicationMessagesResponse_Attributes

func (*StreamWorkflowReplicationMessagesResponse) GetMessages added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) GoString added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) Marshal added in v1.21.0

func (m *StreamWorkflowReplicationMessagesResponse) Marshal() (dAtA []byte, err error)

func (*StreamWorkflowReplicationMessagesResponse) MarshalTo added in v1.21.0

func (m *StreamWorkflowReplicationMessagesResponse) MarshalTo(dAtA []byte) (int, error)

func (*StreamWorkflowReplicationMessagesResponse) MarshalToSizedBuffer added in v1.21.0

func (m *StreamWorkflowReplicationMessagesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamWorkflowReplicationMessagesResponse) ProtoMessage added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) Reset added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) Size added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) String added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) Unmarshal added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) XXX_DiscardUnknown added in v1.21.0

func (m *StreamWorkflowReplicationMessagesResponse) XXX_DiscardUnknown()

func (*StreamWorkflowReplicationMessagesResponse) XXX_Marshal added in v1.21.0

func (m *StreamWorkflowReplicationMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamWorkflowReplicationMessagesResponse) XXX_Merge added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) XXX_OneofWrappers added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamWorkflowReplicationMessagesResponse) XXX_Size added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse) XXX_Unmarshal added in v1.21.0

type StreamWorkflowReplicationMessagesResponse_Messages added in v1.21.0

type StreamWorkflowReplicationMessagesResponse_Messages struct {
	Messages *v115.WorkflowReplicationMessages `protobuf:"bytes,1,opt,name=messages,proto3,oneof" json:"messages,omitempty"`
}

func (*StreamWorkflowReplicationMessagesResponse_Messages) Equal added in v1.21.0

func (this *StreamWorkflowReplicationMessagesResponse_Messages) Equal(that interface{}) bool

func (*StreamWorkflowReplicationMessagesResponse_Messages) GoString added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse_Messages) MarshalTo added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse_Messages) MarshalToSizedBuffer added in v1.21.0

func (m *StreamWorkflowReplicationMessagesResponse_Messages) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamWorkflowReplicationMessagesResponse_Messages) Size added in v1.21.0

func (*StreamWorkflowReplicationMessagesResponse_Messages) String added in v1.21.0

type SyncActivityRequest

type SyncActivityRequest struct {
	NamespaceId        string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,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"`
	Version            int64                  `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	ScheduledEventId   int64                  `protobuf:"varint,5,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	ScheduledTime      *time.Time             `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedEventId     int64                  `protobuf:"varint,7,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	StartedTime        *time.Time             `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	LastHeartbeatTime  *time.Time             `protobuf:"bytes,9,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3,stdtime" json:"last_heartbeat_time,omitempty"`
	Details            *v14.Payloads          `protobuf:"bytes,10,opt,name=details,proto3" json:"details,omitempty"`
	Attempt            int32                  `protobuf:"varint,11,opt,name=attempt,proto3" json:"attempt,omitempty"`
	LastFailure        *v13.Failure           `protobuf:"bytes,12,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity string                 `protobuf:"bytes,13,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
	VersionHistory     *v18.VersionHistory    `protobuf:"bytes,14,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
	BaseExecutionInfo  *v11.BaseExecutionInfo `protobuf:"bytes,15,opt,name=base_execution_info,json=baseExecutionInfo,proto3" json:"base_execution_info,omitempty"`
}

func (*SyncActivityRequest) Descriptor

func (*SyncActivityRequest) Descriptor() ([]byte, []int)

func (*SyncActivityRequest) Equal

func (this *SyncActivityRequest) Equal(that interface{}) bool

func (*SyncActivityRequest) GetAttempt

func (m *SyncActivityRequest) GetAttempt() int32

func (*SyncActivityRequest) GetBaseExecutionInfo added in v1.21.0

func (m *SyncActivityRequest) GetBaseExecutionInfo() *v11.BaseExecutionInfo

func (*SyncActivityRequest) GetDetails

func (m *SyncActivityRequest) GetDetails() *v14.Payloads

func (*SyncActivityRequest) GetLastFailure

func (m *SyncActivityRequest) GetLastFailure() *v13.Failure

func (*SyncActivityRequest) GetLastHeartbeatTime

func (m *SyncActivityRequest) GetLastHeartbeatTime() *time.Time

func (*SyncActivityRequest) GetLastWorkerIdentity

func (m *SyncActivityRequest) GetLastWorkerIdentity() string

func (*SyncActivityRequest) GetNamespaceId

func (m *SyncActivityRequest) GetNamespaceId() string

func (*SyncActivityRequest) GetRunId

func (m *SyncActivityRequest) GetRunId() string

func (*SyncActivityRequest) GetScheduledEventId added in v1.17.0

func (m *SyncActivityRequest) GetScheduledEventId() int64

func (*SyncActivityRequest) GetScheduledTime

func (m *SyncActivityRequest) GetScheduledTime() *time.Time

func (*SyncActivityRequest) GetStartedEventId added in v1.17.0

func (m *SyncActivityRequest) GetStartedEventId() int64

func (*SyncActivityRequest) GetStartedTime

func (m *SyncActivityRequest) GetStartedTime() *time.Time

func (*SyncActivityRequest) GetVersion

func (m *SyncActivityRequest) GetVersion() int64

func (*SyncActivityRequest) GetVersionHistory

func (m *SyncActivityRequest) GetVersionHistory() *v18.VersionHistory

func (*SyncActivityRequest) GetWorkflowId

func (m *SyncActivityRequest) GetWorkflowId() string

func (*SyncActivityRequest) GoString

func (this *SyncActivityRequest) GoString() string

func (*SyncActivityRequest) Marshal

func (m *SyncActivityRequest) Marshal() (dAtA []byte, err error)

func (*SyncActivityRequest) MarshalTo

func (m *SyncActivityRequest) MarshalTo(dAtA []byte) (int, error)

func (*SyncActivityRequest) MarshalToSizedBuffer

func (m *SyncActivityRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncActivityRequest) ProtoMessage

func (*SyncActivityRequest) ProtoMessage()

func (*SyncActivityRequest) Reset

func (m *SyncActivityRequest) Reset()

func (*SyncActivityRequest) Size

func (m *SyncActivityRequest) Size() (n int)

func (*SyncActivityRequest) String

func (this *SyncActivityRequest) String() string

func (*SyncActivityRequest) Unmarshal

func (m *SyncActivityRequest) Unmarshal(dAtA []byte) error

func (*SyncActivityRequest) XXX_DiscardUnknown

func (m *SyncActivityRequest) XXX_DiscardUnknown()

func (*SyncActivityRequest) XXX_Marshal

func (m *SyncActivityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncActivityRequest) XXX_Merge

func (m *SyncActivityRequest) XXX_Merge(src proto.Message)

func (*SyncActivityRequest) XXX_Size

func (m *SyncActivityRequest) XXX_Size() int

func (*SyncActivityRequest) XXX_Unmarshal

func (m *SyncActivityRequest) XXX_Unmarshal(b []byte) error

type SyncActivityResponse

type SyncActivityResponse struct {
}

func (*SyncActivityResponse) Descriptor

func (*SyncActivityResponse) Descriptor() ([]byte, []int)

func (*SyncActivityResponse) Equal

func (this *SyncActivityResponse) Equal(that interface{}) bool

func (*SyncActivityResponse) GoString

func (this *SyncActivityResponse) GoString() string

func (*SyncActivityResponse) Marshal

func (m *SyncActivityResponse) Marshal() (dAtA []byte, err error)

func (*SyncActivityResponse) MarshalTo

func (m *SyncActivityResponse) MarshalTo(dAtA []byte) (int, error)

func (*SyncActivityResponse) MarshalToSizedBuffer

func (m *SyncActivityResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncActivityResponse) ProtoMessage

func (*SyncActivityResponse) ProtoMessage()

func (*SyncActivityResponse) Reset

func (m *SyncActivityResponse) Reset()

func (*SyncActivityResponse) Size

func (m *SyncActivityResponse) Size() (n int)

func (*SyncActivityResponse) String

func (this *SyncActivityResponse) String() string

func (*SyncActivityResponse) Unmarshal

func (m *SyncActivityResponse) Unmarshal(dAtA []byte) error

func (*SyncActivityResponse) XXX_DiscardUnknown

func (m *SyncActivityResponse) XXX_DiscardUnknown()

func (*SyncActivityResponse) XXX_Marshal

func (m *SyncActivityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncActivityResponse) XXX_Merge

func (m *SyncActivityResponse) XXX_Merge(src proto.Message)

func (*SyncActivityResponse) XXX_Size

func (m *SyncActivityResponse) XXX_Size() int

func (*SyncActivityResponse) XXX_Unmarshal

func (m *SyncActivityResponse) XXX_Unmarshal(b []byte) error

type SyncShardStatusRequest

type SyncShardStatusRequest struct {
	SourceCluster string     `protobuf:"bytes,1,opt,name=source_cluster,json=sourceCluster,proto3" json:"source_cluster,omitempty"`
	ShardId       int32      `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	StatusTime    *time.Time `protobuf:"bytes,3,opt,name=status_time,json=statusTime,proto3,stdtime" json:"status_time,omitempty"`
}

func (*SyncShardStatusRequest) Descriptor

func (*SyncShardStatusRequest) Descriptor() ([]byte, []int)

func (*SyncShardStatusRequest) Equal

func (this *SyncShardStatusRequest) Equal(that interface{}) bool

func (*SyncShardStatusRequest) GetShardId

func (m *SyncShardStatusRequest) GetShardId() int32

func (*SyncShardStatusRequest) GetSourceCluster

func (m *SyncShardStatusRequest) GetSourceCluster() string

func (*SyncShardStatusRequest) GetStatusTime added in v0.28.0

func (m *SyncShardStatusRequest) GetStatusTime() *time.Time

func (*SyncShardStatusRequest) GoString

func (this *SyncShardStatusRequest) GoString() string

func (*SyncShardStatusRequest) Marshal

func (m *SyncShardStatusRequest) Marshal() (dAtA []byte, err error)

func (*SyncShardStatusRequest) MarshalTo

func (m *SyncShardStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*SyncShardStatusRequest) MarshalToSizedBuffer

func (m *SyncShardStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncShardStatusRequest) ProtoMessage

func (*SyncShardStatusRequest) ProtoMessage()

func (*SyncShardStatusRequest) Reset

func (m *SyncShardStatusRequest) Reset()

func (*SyncShardStatusRequest) Size

func (m *SyncShardStatusRequest) Size() (n int)

func (*SyncShardStatusRequest) String

func (this *SyncShardStatusRequest) String() string

func (*SyncShardStatusRequest) Unmarshal

func (m *SyncShardStatusRequest) Unmarshal(dAtA []byte) error

func (*SyncShardStatusRequest) XXX_DiscardUnknown

func (m *SyncShardStatusRequest) XXX_DiscardUnknown()

func (*SyncShardStatusRequest) XXX_Marshal

func (m *SyncShardStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncShardStatusRequest) XXX_Merge

func (m *SyncShardStatusRequest) XXX_Merge(src proto.Message)

func (*SyncShardStatusRequest) XXX_Size

func (m *SyncShardStatusRequest) XXX_Size() int

func (*SyncShardStatusRequest) XXX_Unmarshal

func (m *SyncShardStatusRequest) XXX_Unmarshal(b []byte) error

type SyncShardStatusResponse

type SyncShardStatusResponse struct {
}

func (*SyncShardStatusResponse) Descriptor

func (*SyncShardStatusResponse) Descriptor() ([]byte, []int)

func (*SyncShardStatusResponse) Equal

func (this *SyncShardStatusResponse) Equal(that interface{}) bool

func (*SyncShardStatusResponse) GoString

func (this *SyncShardStatusResponse) GoString() string

func (*SyncShardStatusResponse) Marshal

func (m *SyncShardStatusResponse) Marshal() (dAtA []byte, err error)

func (*SyncShardStatusResponse) MarshalTo

func (m *SyncShardStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*SyncShardStatusResponse) MarshalToSizedBuffer

func (m *SyncShardStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SyncShardStatusResponse) ProtoMessage

func (*SyncShardStatusResponse) ProtoMessage()

func (*SyncShardStatusResponse) Reset

func (m *SyncShardStatusResponse) Reset()

func (*SyncShardStatusResponse) Size

func (m *SyncShardStatusResponse) Size() (n int)

func (*SyncShardStatusResponse) String

func (this *SyncShardStatusResponse) String() string

func (*SyncShardStatusResponse) Unmarshal

func (m *SyncShardStatusResponse) Unmarshal(dAtA []byte) error

func (*SyncShardStatusResponse) XXX_DiscardUnknown

func (m *SyncShardStatusResponse) XXX_DiscardUnknown()

func (*SyncShardStatusResponse) XXX_Marshal

func (m *SyncShardStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SyncShardStatusResponse) XXX_Merge

func (m *SyncShardStatusResponse) XXX_Merge(src proto.Message)

func (*SyncShardStatusResponse) XXX_Size

func (m *SyncShardStatusResponse) XXX_Size() int

func (*SyncShardStatusResponse) XXX_Unmarshal

func (m *SyncShardStatusResponse) XXX_Unmarshal(b []byte) error

type TerminateWorkflowExecutionRequest

type TerminateWorkflowExecutionRequest struct {
	NamespaceId               string                                `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TerminateRequest          *v1.TerminateWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=terminate_request,json=terminateRequest,proto3" json:"terminate_request,omitempty"`
	ExternalWorkflowExecution *v14.WorkflowExecution                `` /* 138-byte string literal not displayed */
	ChildWorkflowOnly         bool                                  `protobuf:"varint,4,opt,name=child_workflow_only,json=childWorkflowOnly,proto3" json:"child_workflow_only,omitempty"`
}

func (*TerminateWorkflowExecutionRequest) Descriptor

func (*TerminateWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*TerminateWorkflowExecutionRequest) Equal

func (this *TerminateWorkflowExecutionRequest) Equal(that interface{}) bool

func (*TerminateWorkflowExecutionRequest) GetChildWorkflowOnly added in v1.15.0

func (m *TerminateWorkflowExecutionRequest) GetChildWorkflowOnly() bool

func (*TerminateWorkflowExecutionRequest) GetExternalWorkflowExecution added in v1.15.0

func (m *TerminateWorkflowExecutionRequest) GetExternalWorkflowExecution() *v14.WorkflowExecution

func (*TerminateWorkflowExecutionRequest) GetNamespaceId

func (m *TerminateWorkflowExecutionRequest) GetNamespaceId() string

func (*TerminateWorkflowExecutionRequest) GetTerminateRequest

func (*TerminateWorkflowExecutionRequest) GoString

func (this *TerminateWorkflowExecutionRequest) GoString() string

func (*TerminateWorkflowExecutionRequest) Marshal

func (m *TerminateWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*TerminateWorkflowExecutionRequest) MarshalTo

func (m *TerminateWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionRequest) MarshalToSizedBuffer

func (m *TerminateWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionRequest) ProtoMessage

func (*TerminateWorkflowExecutionRequest) ProtoMessage()

func (*TerminateWorkflowExecutionRequest) Reset

func (*TerminateWorkflowExecutionRequest) Size

func (m *TerminateWorkflowExecutionRequest) Size() (n int)

func (*TerminateWorkflowExecutionRequest) String

func (*TerminateWorkflowExecutionRequest) Unmarshal

func (m *TerminateWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*TerminateWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *TerminateWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*TerminateWorkflowExecutionRequest) XXX_Marshal

func (m *TerminateWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateWorkflowExecutionRequest) XXX_Merge

func (*TerminateWorkflowExecutionRequest) XXX_Size

func (m *TerminateWorkflowExecutionRequest) XXX_Size() int

func (*TerminateWorkflowExecutionRequest) XXX_Unmarshal

func (m *TerminateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type TerminateWorkflowExecutionResponse

type TerminateWorkflowExecutionResponse struct {
}

func (*TerminateWorkflowExecutionResponse) Descriptor

func (*TerminateWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*TerminateWorkflowExecutionResponse) Equal

func (this *TerminateWorkflowExecutionResponse) Equal(that interface{}) bool

func (*TerminateWorkflowExecutionResponse) GoString

func (this *TerminateWorkflowExecutionResponse) GoString() string

func (*TerminateWorkflowExecutionResponse) Marshal

func (m *TerminateWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*TerminateWorkflowExecutionResponse) MarshalTo

func (m *TerminateWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionResponse) MarshalToSizedBuffer

func (m *TerminateWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TerminateWorkflowExecutionResponse) ProtoMessage

func (*TerminateWorkflowExecutionResponse) ProtoMessage()

func (*TerminateWorkflowExecutionResponse) Reset

func (*TerminateWorkflowExecutionResponse) Size

func (*TerminateWorkflowExecutionResponse) String

func (*TerminateWorkflowExecutionResponse) Unmarshal

func (m *TerminateWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*TerminateWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *TerminateWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*TerminateWorkflowExecutionResponse) XXX_Marshal

func (m *TerminateWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateWorkflowExecutionResponse) XXX_Merge

func (*TerminateWorkflowExecutionResponse) XXX_Size

func (*TerminateWorkflowExecutionResponse) XXX_Unmarshal

func (m *TerminateWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type UnimplementedHistoryServiceServer

type UnimplementedHistoryServiceServer struct {
}

UnimplementedHistoryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHistoryServiceServer) CloseShard

func (*UnimplementedHistoryServiceServer) DeleteWorkflowExecution added in v1.15.0

func (*UnimplementedHistoryServiceServer) DeleteWorkflowVisibilityRecord added in v1.17.0

func (*UnimplementedHistoryServiceServer) DescribeHistoryHost

func (*UnimplementedHistoryServiceServer) DescribeMutableState

func (*UnimplementedHistoryServiceServer) DescribeWorkflowExecution

func (*UnimplementedHistoryServiceServer) GenerateLastHistoryReplicationTasks added in v1.14.0

func (*UnimplementedHistoryServiceServer) GetDLQMessages

func (*UnimplementedHistoryServiceServer) GetDLQReplicationMessages

func (*UnimplementedHistoryServiceServer) GetMutableState

func (*UnimplementedHistoryServiceServer) GetReplicationMessages

func (*UnimplementedHistoryServiceServer) GetReplicationStatus added in v1.14.0

func (*UnimplementedHistoryServiceServer) GetShard added in v1.14.0

func (*UnimplementedHistoryServiceServer) IsActivityTaskValid added in v1.22.0

func (*UnimplementedHistoryServiceServer) IsWorkflowTaskValid added in v1.22.0

func (*UnimplementedHistoryServiceServer) MergeDLQMessages

func (*UnimplementedHistoryServiceServer) PollMutableState

func (*UnimplementedHistoryServiceServer) PollWorkflowExecutionUpdate added in v1.21.0

func (*UnimplementedHistoryServiceServer) PurgeDLQMessages

func (*UnimplementedHistoryServiceServer) QueryWorkflow

func (*UnimplementedHistoryServiceServer) ReapplyEvents

func (*UnimplementedHistoryServiceServer) RebuildMutableState added in v1.16.0

func (*UnimplementedHistoryServiceServer) RecordActivityTaskHeartbeat

func (*UnimplementedHistoryServiceServer) RecordActivityTaskStarted

func (*UnimplementedHistoryServiceServer) RecordChildExecutionCompleted

func (*UnimplementedHistoryServiceServer) RecordWorkflowTaskStarted

func (*UnimplementedHistoryServiceServer) RefreshWorkflowTasks

func (*UnimplementedHistoryServiceServer) RemoveSignalMutableState

func (*UnimplementedHistoryServiceServer) RemoveTask

func (*UnimplementedHistoryServiceServer) ReplicateEventsV2

func (*UnimplementedHistoryServiceServer) ReplicateWorkflowState added in v1.20.0

func (*UnimplementedHistoryServiceServer) ResetStickyTaskQueue

func (*UnimplementedHistoryServiceServer) ResetWorkflowExecution

func (*UnimplementedHistoryServiceServer) RespondActivityTaskCanceled

func (*UnimplementedHistoryServiceServer) RespondActivityTaskCompleted

func (*UnimplementedHistoryServiceServer) RespondActivityTaskFailed

func (*UnimplementedHistoryServiceServer) RespondWorkflowTaskCompleted

func (*UnimplementedHistoryServiceServer) RespondWorkflowTaskFailed

func (*UnimplementedHistoryServiceServer) ScheduleWorkflowTask

func (*UnimplementedHistoryServiceServer) SignalWorkflowExecution

func (*UnimplementedHistoryServiceServer) StartWorkflowExecution

func (*UnimplementedHistoryServiceServer) StreamWorkflowReplicationMessages added in v1.21.0

func (*UnimplementedHistoryServiceServer) SyncActivity

func (*UnimplementedHistoryServiceServer) SyncShardStatus

func (*UnimplementedHistoryServiceServer) TerminateWorkflowExecution

func (*UnimplementedHistoryServiceServer) UpdateWorkflowExecution added in v1.20.0

func (*UnimplementedHistoryServiceServer) VerifyChildExecutionCompletionRecorded added in v1.17.0

func (*UnimplementedHistoryServiceServer) VerifyFirstWorkflowTaskScheduled added in v1.17.0

type UpdateWorkflowExecutionRequest added in v1.20.0

type UpdateWorkflowExecutionRequest struct {
	NamespaceId string                             `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Request     *v1.UpdateWorkflowExecutionRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
}

(-- api-linter: core::0134=disabled

aip.dev/not-precedent: This service does not follow the update method AIP --)

func (*UpdateWorkflowExecutionRequest) Descriptor added in v1.20.0

func (*UpdateWorkflowExecutionRequest) Descriptor() ([]byte, []int)

func (*UpdateWorkflowExecutionRequest) Equal added in v1.20.0

func (this *UpdateWorkflowExecutionRequest) Equal(that interface{}) bool

func (*UpdateWorkflowExecutionRequest) GetNamespaceId added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) GetNamespaceId() string

func (*UpdateWorkflowExecutionRequest) GetRequest added in v1.20.0

func (*UpdateWorkflowExecutionRequest) GoString added in v1.20.0

func (this *UpdateWorkflowExecutionRequest) GoString() string

func (*UpdateWorkflowExecutionRequest) Marshal added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) Marshal() (dAtA []byte, err error)

func (*UpdateWorkflowExecutionRequest) MarshalTo added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateWorkflowExecutionRequest) MarshalToSizedBuffer added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateWorkflowExecutionRequest) ProtoMessage added in v1.20.0

func (*UpdateWorkflowExecutionRequest) ProtoMessage()

func (*UpdateWorkflowExecutionRequest) Reset added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) Reset()

func (*UpdateWorkflowExecutionRequest) Size added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) Size() (n int)

func (*UpdateWorkflowExecutionRequest) String added in v1.20.0

func (this *UpdateWorkflowExecutionRequest) String() string

func (*UpdateWorkflowExecutionRequest) Unmarshal added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) Unmarshal(dAtA []byte) error

func (*UpdateWorkflowExecutionRequest) XXX_DiscardUnknown added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*UpdateWorkflowExecutionRequest) XXX_Marshal added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateWorkflowExecutionRequest) XXX_Merge added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*UpdateWorkflowExecutionRequest) XXX_Size added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) XXX_Size() int

func (*UpdateWorkflowExecutionRequest) XXX_Unmarshal added in v1.20.0

func (m *UpdateWorkflowExecutionRequest) XXX_Unmarshal(b []byte) error

type UpdateWorkflowExecutionResponse added in v1.20.0

type UpdateWorkflowExecutionResponse struct {
	Response *v1.UpdateWorkflowExecutionResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
}

func (*UpdateWorkflowExecutionResponse) Descriptor added in v1.20.0

func (*UpdateWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*UpdateWorkflowExecutionResponse) Equal added in v1.20.0

func (this *UpdateWorkflowExecutionResponse) Equal(that interface{}) bool

func (*UpdateWorkflowExecutionResponse) GetResponse added in v1.20.0

func (*UpdateWorkflowExecutionResponse) GoString added in v1.20.0

func (this *UpdateWorkflowExecutionResponse) GoString() string

func (*UpdateWorkflowExecutionResponse) Marshal added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*UpdateWorkflowExecutionResponse) MarshalTo added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateWorkflowExecutionResponse) MarshalToSizedBuffer added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateWorkflowExecutionResponse) ProtoMessage added in v1.20.0

func (*UpdateWorkflowExecutionResponse) ProtoMessage()

func (*UpdateWorkflowExecutionResponse) Reset added in v1.20.0

func (*UpdateWorkflowExecutionResponse) Size added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) Size() (n int)

func (*UpdateWorkflowExecutionResponse) String added in v1.20.0

func (this *UpdateWorkflowExecutionResponse) String() string

func (*UpdateWorkflowExecutionResponse) Unmarshal added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*UpdateWorkflowExecutionResponse) XXX_DiscardUnknown added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*UpdateWorkflowExecutionResponse) XXX_Marshal added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateWorkflowExecutionResponse) XXX_Merge added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*UpdateWorkflowExecutionResponse) XXX_Size added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) XXX_Size() int

func (*UpdateWorkflowExecutionResponse) XXX_Unmarshal added in v1.20.0

func (m *UpdateWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type VerifyChildExecutionCompletionRecordedRequest added in v1.17.0

type VerifyChildExecutionCompletionRecordedRequest struct {
	NamespaceId            string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	ParentExecution        *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
	ChildExecution         *v14.WorkflowExecution `protobuf:"bytes,3,opt,name=child_execution,json=childExecution,proto3" json:"child_execution,omitempty"`
	ParentInitiatedId      int64                  `protobuf:"varint,4,opt,name=parent_initiated_id,json=parentInitiatedId,proto3" json:"parent_initiated_id,omitempty"`
	ParentInitiatedVersion int64                  `` /* 130-byte string literal not displayed */
	Clock                  *v15.VectorClock       `protobuf:"bytes,6,opt,name=clock,proto3" json:"clock,omitempty"`
}

func (*VerifyChildExecutionCompletionRecordedRequest) Descriptor added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) Equal added in v1.17.0

func (this *VerifyChildExecutionCompletionRecordedRequest) Equal(that interface{}) bool

func (*VerifyChildExecutionCompletionRecordedRequest) GetChildExecution added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) GetClock added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) GetNamespaceId added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) GetParentExecution added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) GetParentInitiatedId added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedRequest) GetParentInitiatedId() int64

func (*VerifyChildExecutionCompletionRecordedRequest) GetParentInitiatedVersion added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedRequest) GetParentInitiatedVersion() int64

func (*VerifyChildExecutionCompletionRecordedRequest) GoString added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) Marshal added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedRequest) Marshal() (dAtA []byte, err error)

func (*VerifyChildExecutionCompletionRecordedRequest) MarshalTo added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) MarshalToSizedBuffer added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VerifyChildExecutionCompletionRecordedRequest) ProtoMessage added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) Reset added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) Size added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) String added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) Unmarshal added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) XXX_DiscardUnknown added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedRequest) XXX_DiscardUnknown()

func (*VerifyChildExecutionCompletionRecordedRequest) XXX_Marshal added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyChildExecutionCompletionRecordedRequest) XXX_Merge added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) XXX_Size added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedRequest) XXX_Unmarshal added in v1.17.0

type VerifyChildExecutionCompletionRecordedResponse added in v1.17.0

type VerifyChildExecutionCompletionRecordedResponse struct {
}

func (*VerifyChildExecutionCompletionRecordedResponse) Descriptor added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) Equal added in v1.17.0

func (this *VerifyChildExecutionCompletionRecordedResponse) Equal(that interface{}) bool

func (*VerifyChildExecutionCompletionRecordedResponse) GoString added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) Marshal added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedResponse) Marshal() (dAtA []byte, err error)

func (*VerifyChildExecutionCompletionRecordedResponse) MarshalTo added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) MarshalToSizedBuffer added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VerifyChildExecutionCompletionRecordedResponse) ProtoMessage added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) Reset added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) Size added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) String added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) Unmarshal added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) XXX_DiscardUnknown added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedResponse) XXX_DiscardUnknown()

func (*VerifyChildExecutionCompletionRecordedResponse) XXX_Marshal added in v1.17.0

func (m *VerifyChildExecutionCompletionRecordedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyChildExecutionCompletionRecordedResponse) XXX_Merge added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) XXX_Size added in v1.17.0

func (*VerifyChildExecutionCompletionRecordedResponse) XXX_Unmarshal added in v1.17.0

type VerifyFirstWorkflowTaskScheduledRequest added in v1.17.0

type VerifyFirstWorkflowTaskScheduledRequest struct {
	NamespaceId       string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	WorkflowExecution *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Clock             *v15.VectorClock       `protobuf:"bytes,3,opt,name=clock,proto3" json:"clock,omitempty"`
}

func (*VerifyFirstWorkflowTaskScheduledRequest) Descriptor added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) Descriptor() ([]byte, []int)

func (*VerifyFirstWorkflowTaskScheduledRequest) Equal added in v1.17.0

func (this *VerifyFirstWorkflowTaskScheduledRequest) Equal(that interface{}) bool

func (*VerifyFirstWorkflowTaskScheduledRequest) GetClock added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) GetNamespaceId added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) GetNamespaceId() string

func (*VerifyFirstWorkflowTaskScheduledRequest) GetWorkflowExecution added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) GoString added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) Marshal added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) Marshal() (dAtA []byte, err error)

func (*VerifyFirstWorkflowTaskScheduledRequest) MarshalTo added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) MarshalTo(dAtA []byte) (int, error)

func (*VerifyFirstWorkflowTaskScheduledRequest) MarshalToSizedBuffer added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VerifyFirstWorkflowTaskScheduledRequest) ProtoMessage added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) Reset added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) Size added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) String added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) Unmarshal added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) Unmarshal(dAtA []byte) error

func (*VerifyFirstWorkflowTaskScheduledRequest) XXX_DiscardUnknown added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_DiscardUnknown()

func (*VerifyFirstWorkflowTaskScheduledRequest) XXX_Marshal added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyFirstWorkflowTaskScheduledRequest) XXX_Merge added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) XXX_Size added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledRequest) XXX_Unmarshal added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledRequest) XXX_Unmarshal(b []byte) error

type VerifyFirstWorkflowTaskScheduledResponse added in v1.17.0

type VerifyFirstWorkflowTaskScheduledResponse struct {
}

func (*VerifyFirstWorkflowTaskScheduledResponse) Descriptor added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) Descriptor() ([]byte, []int)

func (*VerifyFirstWorkflowTaskScheduledResponse) Equal added in v1.17.0

func (this *VerifyFirstWorkflowTaskScheduledResponse) Equal(that interface{}) bool

func (*VerifyFirstWorkflowTaskScheduledResponse) GoString added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) Marshal added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledResponse) Marshal() (dAtA []byte, err error)

func (*VerifyFirstWorkflowTaskScheduledResponse) MarshalTo added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledResponse) MarshalTo(dAtA []byte) (int, error)

func (*VerifyFirstWorkflowTaskScheduledResponse) MarshalToSizedBuffer added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VerifyFirstWorkflowTaskScheduledResponse) ProtoMessage added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) Reset added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) Size added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) String added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) Unmarshal added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) XXX_DiscardUnknown added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_DiscardUnknown()

func (*VerifyFirstWorkflowTaskScheduledResponse) XXX_Marshal added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyFirstWorkflowTaskScheduledResponse) XXX_Merge added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) XXX_Size added in v1.17.0

func (*VerifyFirstWorkflowTaskScheduledResponse) XXX_Unmarshal added in v1.17.0

func (m *VerifyFirstWorkflowTaskScheduledResponse) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL