historyservice

package
v1.14.1 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2021 License: MIT Imports: 31 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 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        *v112.NamespaceCacheInfo `protobuf:"bytes,3,opt,name=namespace_cache,json=namespaceCache,proto3" json:"namespace_cache,omitempty"`
	ShardControllerStatus string                   `` /* 126-byte string literal not displayed */
	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() *v112.NamespaceCacheInfo

func (*DescribeHistoryHostResponse) GetShardControllerStatus 

func (m *DescribeHistoryHostResponse) GetShardControllerStatus() string

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 (m *DescribeMutableStateRequest) GetExecution() *v14.WorkflowExecution

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    *v111.WorkflowMutableState `protobuf:"bytes,1,opt,name=cache_mutable_state,json=cacheMutableState,proto3" json:"cache_mutable_state,omitempty"`
	DatabaseMutableState *v111.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() *v111.WorkflowMutableState

func (*DescribeMutableStateResponse) GetDatabaseMutableState added in v0.28.0 

func (m *DescribeMutableStateResponse) GetDatabaseMutableState() *v111.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 (m *DescribeWorkflowExecutionRequest) GetRequest() *v1.DescribeWorkflowExecutionRequest

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 (m *DescribeWorkflowExecutionRequest) Reset()

func (*DescribeWorkflowExecutionRequest) Size 

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

func (*DescribeWorkflowExecutionRequest) String 

func (this *DescribeWorkflowExecutionRequest) String() 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 (m *DescribeWorkflowExecutionRequest) XXX_Merge(src proto.Message)

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       *v110.WorkflowExecutionConfig     `protobuf:"bytes,1,opt,name=execution_config,json=executionConfig,proto3" json:"execution_config,omitempty"`
	WorkflowExecutionInfo *v110.WorkflowExecutionInfo       `` /* 126-byte string literal not displayed */
	PendingActivities     []*v110.PendingActivityInfo       `protobuf:"bytes,3,rep,name=pending_activities,json=pendingActivities,proto3" json:"pending_activities,omitempty"`
	PendingChildren       []*v110.PendingChildExecutionInfo `protobuf:"bytes,4,rep,name=pending_children,json=pendingChildren,proto3" json:"pending_children,omitempty"`
}

func (*DescribeWorkflowExecutionResponse) Descriptor 

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

func (*DescribeWorkflowExecutionResponse) Equal 

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

func (*DescribeWorkflowExecutionResponse) GetExecutionConfig 

func (m *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v110.WorkflowExecutionConfig

func (*DescribeWorkflowExecutionResponse) GetPendingActivities 

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

func (*DescribeWorkflowExecutionResponse) GetPendingChildren 

func (m *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v110.PendingChildExecutionInfo

func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo 

func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *v110.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 (m *DescribeWorkflowExecutionResponse) Reset()

func (*DescribeWorkflowExecutionResponse) Size 

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

func (*DescribeWorkflowExecutionResponse) String 

func (this *DescribeWorkflowExecutionResponse) String() 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 (m *DescribeWorkflowExecutionResponse) XXX_Merge(src proto.Message)

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) Descriptor() ([]byte, []int)

func (*GenerateLastHistoryReplicationTasksRequest) Equal added in v1.14.0 

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

func (*GenerateLastHistoryReplicationTasksRequest) GetExecution added in v1.14.0 

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

func (*GenerateLastHistoryReplicationTasksRequest) GetNamespaceId added in v1.14.0 

func (m *GenerateLastHistoryReplicationTasksRequest) GetNamespaceId() string

func (*GenerateLastHistoryReplicationTasksRequest) GoString added in v1.14.0 

func (this *GenerateLastHistoryReplicationTasksRequest) GoString() string

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) ProtoMessage()

func (*GenerateLastHistoryReplicationTasksRequest) Reset added in v1.14.0 

func (m *GenerateLastHistoryReplicationTasksRequest) Reset()

func (*GenerateLastHistoryReplicationTasksRequest) Size added in v1.14.0 

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

func (*GenerateLastHistoryReplicationTasksRequest) String added in v1.14.0 

func (this *GenerateLastHistoryReplicationTasksRequest) String() string

func (*GenerateLastHistoryReplicationTasksRequest) Unmarshal added in v1.14.0 

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

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 (m *GenerateLastHistoryReplicationTasksRequest) XXX_Merge(src proto.Message)

func (*GenerateLastHistoryReplicationTasksRequest) XXX_Size added in v1.14.0 

func (m *GenerateLastHistoryReplicationTasksRequest) XXX_Size() int

func (*GenerateLastHistoryReplicationTasksRequest) XXX_Unmarshal added in v1.14.0 

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

type GenerateLastHistoryReplicationTasksResponse added in v1.14.0 

type GenerateLastHistoryReplicationTasksResponse struct {
}

func (*GenerateLastHistoryReplicationTasksResponse) Descriptor added in v1.14.0 

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

func (*GenerateLastHistoryReplicationTasksResponse) Equal added in v1.14.0 

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

func (*GenerateLastHistoryReplicationTasksResponse) GoString added in v1.14.0 

func (this *GenerateLastHistoryReplicationTasksResponse) GoString() string

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 (m *GenerateLastHistoryReplicationTasksResponse) MarshalTo(dAtA []byte) (int, error)

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) ProtoMessage()

func (*GenerateLastHistoryReplicationTasksResponse) Reset added in v1.14.0 

func (m *GenerateLastHistoryReplicationTasksResponse) Reset()

func (*GenerateLastHistoryReplicationTasksResponse) Size added in v1.14.0 

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

func (*GenerateLastHistoryReplicationTasksResponse) String added in v1.14.0 

func (this *GenerateLastHistoryReplicationTasksResponse) String() string

func (*GenerateLastHistoryReplicationTasksResponse) Unmarshal added in v1.14.0 

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

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 (m *GenerateLastHistoryReplicationTasksResponse) XXX_Merge(src proto.Message)

func (*GenerateLastHistoryReplicationTasksResponse) XXX_Size added in v1.14.0 

func (m *GenerateLastHistoryReplicationTasksResponse) XXX_Size() int

func (*GenerateLastHistoryReplicationTasksResponse) XXX_Unmarshal added in v1.14.0 

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

type GetDLQMessagesRequest 

type GetDLQMessagesRequest struct {
	Type                  v16.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 (m *GetDLQMessagesRequest) GetType() v16.DeadLetterQueueType

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             v16.DeadLetterQueueType `protobuf:"varint,1,opt,name=type,proto3,enum=temporal.server.api.enums.v1.DeadLetterQueueType" json:"type,omitempty"`
	ReplicationTasks []*v113.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"`
}

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() []*v113.ReplicationTask

func (*GetDLQMessagesResponse) GetType 

func (m *GetDLQMessagesResponse) GetType() v16.DeadLetterQueueType

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 []*v113.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 (m *GetDLQReplicationMessagesRequest) GetTaskInfos() []*v113.ReplicationTaskInfo

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 (m *GetDLQReplicationMessagesRequest) Reset()

func (*GetDLQReplicationMessagesRequest) Size 

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

func (*GetDLQReplicationMessagesRequest) String 

func (this *GetDLQReplicationMessagesRequest) String() 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 (m *GetDLQReplicationMessagesRequest) XXX_Merge(src proto.Message)

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 []*v113.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() []*v113.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 (m *GetDLQReplicationMessagesResponse) Reset()

func (*GetDLQReplicationMessagesResponse) Size 

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

func (*GetDLQReplicationMessagesResponse) String 

func (this *GetDLQReplicationMessagesResponse) String() 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 (m *GetDLQReplicationMessagesResponse) XXX_Merge(src proto.Message)

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              *v15.TaskQueue         `protobuf:"bytes,6,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StickyTaskQueue        *v15.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                         v16.WorkflowExecutionState  `` /* 159-byte string literal not displayed */
	WorkflowStatus                        v12.WorkflowExecutionStatus `` /* 156-byte string literal not displayed */
	VersionHistories                      *v17.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 */
}

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) 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() *v15.TaskQueue

func (*GetMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout 

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

func (*GetMutableStateResponse) GetTaskQueue 

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

func (*GetMutableStateResponse) GetVersionHistories 

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

func (*GetMutableStateResponse) GetWorkflowState 

func (m *GetMutableStateResponse) GetWorkflowState() v16.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      []*v113.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 (m *GetReplicationMessagesRequest) GetTokens() []*v113.ReplicationToken

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]*v113.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]*v113.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 (m *GetReplicationStatusResponse) GetShards() []*ShardReplicationStatus

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 *v111.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() *v111.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)
	// 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)
	// 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)
	// 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)
	// 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)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(ctx context.Context, in *DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	ReplicateEventsV2(ctx context.Context, in *ReplicateEventsV2Request, opts ...grpc.CallOption) (*ReplicateEventsV2Response, 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)
}

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.

func NewHistoryServiceClient 

func NewHistoryServiceClient(cc *grpc.ClientConn) HistoryServiceClient

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)
	// 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)
	// 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)
	// 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)
	// 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)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	ReplicateEventsV2(context.Context, *ReplicateEventsV2Request) (*ReplicateEventsV2Response, 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)
}

HistoryServiceServer is the server API for HistoryService service.

type MergeDLQMessagesRequest 

type MergeDLQMessagesRequest struct {
	Type                  v16.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 (m *MergeDLQMessagesRequest) GetType() v16.DeadLetterQueueType

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              *v15.TaskQueue         `protobuf:"bytes,6,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	StickyTaskQueue        *v15.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                      *v17.VersionHistories       `protobuf:"bytes,14,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	WorkflowState                         v16.WorkflowExecutionState  `` /* 159-byte string literal not displayed */
	WorkflowStatus                        v12.WorkflowExecutionStatus `` /* 156-byte string literal not displayed */
	LastFirstEventTxnId                   int64                       `` /* 126-byte string literal not displayed */
}

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) 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() *v15.TaskQueue

func (*PollMutableStateResponse) GetStickyTaskQueueScheduleToStartTimeout 

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

func (*PollMutableStateResponse) GetTaskQueue 

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

func (*PollMutableStateResponse) GetVersionHistories 

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

func (*PollMutableStateResponse) GetWorkflowState 

func (m *PollMutableStateResponse) GetWorkflowState() v16.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 PurgeDLQMessagesRequest 

type PurgeDLQMessagesRequest struct {
	Type                  v16.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 (m *PurgeDLQMessagesRequest) GetType() v16.DeadLetterQueueType

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 (m *QueryWorkflowResponse) GetResponse() *v1.QueryWorkflowResponse

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     *v114.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 (m *ReapplyEventsRequest) GetRequest() *v114.ReapplyEventsRequest

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 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 (m *RecordActivityTaskHeartbeatRequest) GetHeartbeatRequest() *v1.RecordActivityTaskHeartbeatRequest

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 (m *RecordActivityTaskHeartbeatRequest) Reset()

func (*RecordActivityTaskHeartbeatRequest) Size 

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

func (*RecordActivityTaskHeartbeatRequest) String 

func (this *RecordActivityTaskHeartbeatRequest) String() 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 (m *RecordActivityTaskHeartbeatRequest) XXX_Merge(src proto.Message)

func (*RecordActivityTaskHeartbeatRequest) XXX_Size 

func (m *RecordActivityTaskHeartbeatRequest) XXX_Size() int

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 (this *RecordActivityTaskHeartbeatResponse) GoString() string

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 (m *RecordActivityTaskHeartbeatResponse) Reset()

func (*RecordActivityTaskHeartbeatResponse) Size 

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

func (*RecordActivityTaskHeartbeatResponse) String 

func (this *RecordActivityTaskHeartbeatResponse) String() 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 (m *RecordActivityTaskHeartbeatResponse) XXX_Merge(src proto.Message)

func (*RecordActivityTaskHeartbeatResponse) XXX_Size 

func (m *RecordActivityTaskHeartbeatResponse) XXX_Size() int

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"`
	ScheduleId        int64                  `protobuf:"varint,3,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_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"`
}

func (*RecordActivityTaskStartedRequest) Descriptor 

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

func (*RecordActivityTaskStartedRequest) Equal 

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

func (*RecordActivityTaskStartedRequest) GetNamespaceId 

func (m *RecordActivityTaskStartedRequest) GetNamespaceId() string

func (*RecordActivityTaskStartedRequest) GetPollRequest 

func (m *RecordActivityTaskStartedRequest) GetPollRequest() *v1.PollActivityTaskQueueRequest

func (*RecordActivityTaskStartedRequest) GetRequestId 

func (m *RecordActivityTaskStartedRequest) GetRequestId() string

func (*RecordActivityTaskStartedRequest) GetScheduleId 

func (m *RecordActivityTaskStartedRequest) GetScheduleId() 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 (m *RecordActivityTaskStartedRequest) Reset()

func (*RecordActivityTaskStartedRequest) Size 

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

func (*RecordActivityTaskStartedRequest) String 

func (this *RecordActivityTaskStartedRequest) String() 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 (m *RecordActivityTaskStartedRequest) XXX_Merge(src proto.Message)

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              *v19.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"`
}

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) 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() *v19.HistoryEvent

func (*RecordActivityTaskStartedResponse) GetStartedTime added in v0.28.0 

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

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 (m *RecordActivityTaskStartedResponse) Reset()

func (*RecordActivityTaskStartedResponse) Size 

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

func (*RecordActivityTaskStartedResponse) String 

func (this *RecordActivityTaskStartedResponse) String() 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 (m *RecordActivityTaskStartedResponse) XXX_Merge(src proto.Message)

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"`
	WorkflowExecution  *v14.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	InitiatedId        int64                  `protobuf:"varint,3,opt,name=initiated_id,json=initiatedId,proto3" json:"initiated_id,omitempty"`
	CompletedExecution *v14.WorkflowExecution `protobuf:"bytes,4,opt,name=completed_execution,json=completedExecution,proto3" json:"completed_execution,omitempty"`
	CompletionEvent    *v19.HistoryEvent      `protobuf:"bytes,5,opt,name=completion_event,json=completionEvent,proto3" json:"completion_event,omitempty"`
}

* 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) GetCompletedExecution 

func (m *RecordChildExecutionCompletedRequest) GetCompletedExecution() *v14.WorkflowExecution

func (*RecordChildExecutionCompletedRequest) GetCompletionEvent 

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

func (*RecordChildExecutionCompletedRequest) GetInitiatedId 

func (m *RecordChildExecutionCompletedRequest) GetInitiatedId() int64

func (*RecordChildExecutionCompletedRequest) GetNamespaceId 

func (m *RecordChildExecutionCompletedRequest) GetNamespaceId() string

func (*RecordChildExecutionCompletedRequest) GetWorkflowExecution 

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

func (*RecordChildExecutionCompletedRequest) GoString 

func (this *RecordChildExecutionCompletedRequest) GoString() string

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 (m *RecordChildExecutionCompletedRequest) Reset()

func (*RecordChildExecutionCompletedRequest) Size 

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

func (*RecordChildExecutionCompletedRequest) String 

func (this *RecordChildExecutionCompletedRequest) String() 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 (m *RecordChildExecutionCompletedRequest) XXX_Merge(src proto.Message)

func (*RecordChildExecutionCompletedRequest) XXX_Size 

func (m *RecordChildExecutionCompletedRequest) XXX_Size() int

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 (this *RecordChildExecutionCompletedResponse) GoString() string

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 (m *RecordChildExecutionCompletedResponse) Reset()

func (*RecordChildExecutionCompletedResponse) Size 

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

func (*RecordChildExecutionCompletedResponse) String 

func (this *RecordChildExecutionCompletedResponse) String() 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 (m *RecordChildExecutionCompletedResponse) XXX_Merge(src proto.Message)

func (*RecordChildExecutionCompletedResponse) XXX_Size 

func (m *RecordChildExecutionCompletedResponse) XXX_Size() int

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"`
	ScheduleId        int64                  `protobuf:"varint,3,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_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"`
}

func (*RecordWorkflowTaskStartedRequest) Descriptor 

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

func (*RecordWorkflowTaskStartedRequest) Equal 

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

func (*RecordWorkflowTaskStartedRequest) GetNamespaceId 

func (m *RecordWorkflowTaskStartedRequest) GetNamespaceId() string

func (*RecordWorkflowTaskStartedRequest) GetPollRequest 

func (m *RecordWorkflowTaskStartedRequest) GetPollRequest() *v1.PollWorkflowTaskQueueRequest

func (*RecordWorkflowTaskStartedRequest) GetRequestId 

func (m *RecordWorkflowTaskStartedRequest) GetRequestId() string

func (*RecordWorkflowTaskStartedRequest) GetScheduleId 

func (m *RecordWorkflowTaskStartedRequest) GetScheduleId() 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 (m *RecordWorkflowTaskStartedRequest) Reset()

func (*RecordWorkflowTaskStartedRequest) Size 

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

func (*RecordWorkflowTaskStartedRequest) String 

func (this *RecordWorkflowTaskStartedRequest) String() 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 (m *RecordWorkflowTaskStartedRequest) XXX_Merge(src proto.Message)

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 */
	WorkflowTaskInfo           *v17.TransientWorkflowTaskInfo `protobuf:"bytes,8,opt,name=workflow_task_info,json=workflowTaskInfo,proto3" json:"workflow_task_info,omitempty"`
	WorkflowExecutionTaskQueue *v15.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]*v18.WorkflowQuery  `` /* 156-byte string literal not displayed */
}

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

func (m *RecordWorkflowTaskStartedResponse) GetNextEventId() int64

func (*RecordWorkflowTaskStartedResponse) GetPreviousStartedEventId 

func (m *RecordWorkflowTaskStartedResponse) GetPreviousStartedEventId() int64

func (*RecordWorkflowTaskStartedResponse) GetQueries 

func (m *RecordWorkflowTaskStartedResponse) GetQueries() map[string]*v18.WorkflowQuery

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

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

func (*RecordWorkflowTaskStartedResponse) GetWorkflowTaskInfo 

func (m *RecordWorkflowTaskStartedResponse) GetWorkflowTaskInfo() *v17.TransientWorkflowTaskInfo

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 (m *RecordWorkflowTaskStartedResponse) Reset()

func (*RecordWorkflowTaskStartedResponse) Size 

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

func (*RecordWorkflowTaskStartedResponse) String 

func (this *RecordWorkflowTaskStartedResponse) String() 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 (m *RecordWorkflowTaskStartedResponse) XXX_Merge(src proto.Message)

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     *v114.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 (m *RefreshWorkflowTasksRequest) GetRequest() *v114.RefreshWorkflowTasksRequest

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 (m *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 (m *RemoveSignalMutableStateResponse) Reset()

func (*RemoveSignalMutableStateResponse) Size 

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

func (*RemoveSignalMutableStateResponse) String 

func (this *RemoveSignalMutableStateResponse) String() 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 (m *RemoveSignalMutableStateResponse) XXX_Merge(src proto.Message)

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       v16.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() v16.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 []*v17.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"`
}

func (*ReplicateEventsV2Request) Descriptor 

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

func (*ReplicateEventsV2Request) Equal 

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

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() []*v17.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 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 (m *RequestCancelWorkflowExecutionRequest) GetCancelRequest() *v1.RequestCancelWorkflowExecutionRequest

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 (this *RequestCancelWorkflowExecutionRequest) GoString() string

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 (m *RequestCancelWorkflowExecutionRequest) Reset()

func (*RequestCancelWorkflowExecutionRequest) Size 

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

func (*RequestCancelWorkflowExecutionRequest) String 

func (this *RequestCancelWorkflowExecutionRequest) String() 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 (m *RequestCancelWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*RequestCancelWorkflowExecutionRequest) XXX_Size 

func (m *RequestCancelWorkflowExecutionRequest) XXX_Size() int

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 (this *RequestCancelWorkflowExecutionResponse) GoString() string

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) ProtoMessage()

func (*RequestCancelWorkflowExecutionResponse) Reset 

func (m *RequestCancelWorkflowExecutionResponse) Reset()

func (*RequestCancelWorkflowExecutionResponse) Size 

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

func (*RequestCancelWorkflowExecutionResponse) String 

func (this *RequestCancelWorkflowExecutionResponse) String() 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 (m *RequestCancelWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*RequestCancelWorkflowExecutionResponse) XXX_Size 

func (m *RequestCancelWorkflowExecutionResponse) XXX_Size() int

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 (m *ResetStickyTaskQueueRequest) GetExecution() *v14.WorkflowExecution

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 (m *ResetWorkflowExecutionRequest) GetResetRequest() *v1.ResetWorkflowExecutionRequest

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 (m *RespondActivityTaskCanceledRequest) GetCancelRequest() *v1.RespondActivityTaskCanceledRequest

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 (m *RespondActivityTaskCanceledRequest) Reset()

func (*RespondActivityTaskCanceledRequest) Size 

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

func (*RespondActivityTaskCanceledRequest) String 

func (this *RespondActivityTaskCanceledRequest) String() 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 (m *RespondActivityTaskCanceledRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCanceledRequest) XXX_Size 

func (m *RespondActivityTaskCanceledRequest) XXX_Size() int

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 (this *RespondActivityTaskCanceledResponse) GoString() string

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 (m *RespondActivityTaskCanceledResponse) Reset()

func (*RespondActivityTaskCanceledResponse) Size 

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

func (*RespondActivityTaskCanceledResponse) String 

func (this *RespondActivityTaskCanceledResponse) String() 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 (m *RespondActivityTaskCanceledResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCanceledResponse) XXX_Size 

func (m *RespondActivityTaskCanceledResponse) XXX_Size() int

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 (m *RespondActivityTaskCompletedRequest) GetCompleteRequest() *v1.RespondActivityTaskCompletedRequest

func (*RespondActivityTaskCompletedRequest) GetNamespaceId 

func (m *RespondActivityTaskCompletedRequest) GetNamespaceId() string

func (*RespondActivityTaskCompletedRequest) GoString 

func (this *RespondActivityTaskCompletedRequest) GoString() string

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 (m *RespondActivityTaskCompletedRequest) Reset()

func (*RespondActivityTaskCompletedRequest) Size 

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

func (*RespondActivityTaskCompletedRequest) String 

func (this *RespondActivityTaskCompletedRequest) String() 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 (m *RespondActivityTaskCompletedRequest) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCompletedRequest) XXX_Size 

func (m *RespondActivityTaskCompletedRequest) XXX_Size() int

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 (this *RespondActivityTaskCompletedResponse) GoString() string

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 (m *RespondActivityTaskCompletedResponse) Reset()

func (*RespondActivityTaskCompletedResponse) Size 

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

func (*RespondActivityTaskCompletedResponse) String 

func (this *RespondActivityTaskCompletedResponse) String() 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 (m *RespondActivityTaskCompletedResponse) XXX_Merge(src proto.Message)

func (*RespondActivityTaskCompletedResponse) XXX_Size 

func (m *RespondActivityTaskCompletedResponse) XXX_Size() int

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 (m *RespondActivityTaskFailedRequest) GetFailedRequest() *v1.RespondActivityTaskFailedRequest

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 (m *RespondActivityTaskFailedRequest) Reset()

func (*RespondActivityTaskFailedRequest) Size 

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

func (*RespondActivityTaskFailedRequest) String 

func (this *RespondActivityTaskFailedRequest) String() 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 (m *RespondActivityTaskFailedRequest) XXX_Merge(src proto.Message)

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 (m *RespondActivityTaskFailedResponse) Reset()

func (*RespondActivityTaskFailedResponse) Size 

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

func (*RespondActivityTaskFailedResponse) String 

func (this *RespondActivityTaskFailedResponse) String() 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 (m *RespondActivityTaskFailedResponse) XXX_Merge(src proto.Message)

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 (m *RespondWorkflowTaskCompletedRequest) GetCompleteRequest() *v1.RespondWorkflowTaskCompletedRequest

func (*RespondWorkflowTaskCompletedRequest) GetNamespaceId 

func (m *RespondWorkflowTaskCompletedRequest) GetNamespaceId() string

func (*RespondWorkflowTaskCompletedRequest) GoString 

func (this *RespondWorkflowTaskCompletedRequest) GoString() string

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 (m *RespondWorkflowTaskCompletedRequest) Reset()

func (*RespondWorkflowTaskCompletedRequest) Size 

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

func (*RespondWorkflowTaskCompletedRequest) String 

func (this *RespondWorkflowTaskCompletedRequest) String() 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 (m *RespondWorkflowTaskCompletedRequest) XXX_Merge(src proto.Message)

func (*RespondWorkflowTaskCompletedRequest) XXX_Size 

func (m *RespondWorkflowTaskCompletedRequest) XXX_Size() int

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"`
}

func (*RespondWorkflowTaskCompletedResponse) Descriptor 

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

func (*RespondWorkflowTaskCompletedResponse) Equal 

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

func (*RespondWorkflowTaskCompletedResponse) GetStartedResponse 

func (m *RespondWorkflowTaskCompletedResponse) GetStartedResponse() *RecordWorkflowTaskStartedResponse

func (*RespondWorkflowTaskCompletedResponse) GoString 

func (this *RespondWorkflowTaskCompletedResponse) GoString() string

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 (m *RespondWorkflowTaskCompletedResponse) Reset()

func (*RespondWorkflowTaskCompletedResponse) Size 

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

func (*RespondWorkflowTaskCompletedResponse) String 

func (this *RespondWorkflowTaskCompletedResponse) String() 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 (m *RespondWorkflowTaskCompletedResponse) XXX_Merge(src proto.Message)

func (*RespondWorkflowTaskCompletedResponse) XXX_Size 

func (m *RespondWorkflowTaskCompletedResponse) XXX_Size() int

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 (m *RespondWorkflowTaskFailedRequest) GetFailedRequest() *v1.RespondWorkflowTaskFailedRequest

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 (m *RespondWorkflowTaskFailedRequest) Reset()

func (*RespondWorkflowTaskFailedRequest) Size 

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

func (*RespondWorkflowTaskFailedRequest) String 

func (this *RespondWorkflowTaskFailedRequest) String() 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 (m *RespondWorkflowTaskFailedRequest) XXX_Merge(src proto.Message)

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 (m *RespondWorkflowTaskFailedResponse) Reset()

func (*RespondWorkflowTaskFailedResponse) Size 

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

func (*RespondWorkflowTaskFailedResponse) String 

func (this *RespondWorkflowTaskFailedResponse) String() 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 (m *RespondWorkflowTaskFailedResponse) XXX_Merge(src proto.Message)

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"`
}

func (*ScheduleWorkflowTaskRequest) Descriptor 

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

func (*ScheduleWorkflowTaskRequest) Equal 

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

func (*ScheduleWorkflowTaskRequest) GetIsFirstWorkflowTask 

func (m *ScheduleWorkflowTaskRequest) GetIsFirstWorkflowTask() bool

func (*ScheduleWorkflowTaskRequest) GetNamespaceId 

func (m *ScheduleWorkflowTaskRequest) GetNamespaceId() string

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"`
	RemoteClusters     map[string]*ShardReplicationStatusPerCluster `` /* 191-byte string literal not displayed */
	HandoverNamespaces map[string]*HandoverNamespaceInfo            `` /* 203-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) GetRemoteClusters added in v1.14.0 

func (m *ShardReplicationStatus) GetRemoteClusters() map[string]*ShardReplicationStatusPerCluster

func (*ShardReplicationStatus) GetShardId added in v1.14.0 

func (m *ShardReplicationStatus) GetShardId() int32

func (*ShardReplicationStatus) GetShardLocalTime added in v1.14.0 

func (m *ShardReplicationStatus) GetShardLocalTime() *time.Time

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 (m *ShardReplicationStatusPerCluster) Reset()

func (*ShardReplicationStatusPerCluster) Size added in v1.14.0 

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

func (*ShardReplicationStatusPerCluster) String added in v1.14.0 

func (this *ShardReplicationStatusPerCluster) String() string

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 (m *ShardReplicationStatusPerCluster) XXX_Merge(src proto.Message)

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 (m *SignalWithStartWorkflowExecutionRequest) GetSignalWithStartRequest() *v1.SignalWithStartWorkflowExecutionRequest

func (*SignalWithStartWorkflowExecutionRequest) GoString 

func (this *SignalWithStartWorkflowExecutionRequest) GoString() string

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) ProtoMessage()

func (*SignalWithStartWorkflowExecutionRequest) Reset 

func (m *SignalWithStartWorkflowExecutionRequest) Reset()

func (*SignalWithStartWorkflowExecutionRequest) Size 

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

func (*SignalWithStartWorkflowExecutionRequest) String 

func (this *SignalWithStartWorkflowExecutionRequest) String() 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 (m *SignalWithStartWorkflowExecutionRequest) XXX_Merge(src proto.Message)

func (*SignalWithStartWorkflowExecutionRequest) XXX_Size 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_Size() int

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 (m *SignalWithStartWorkflowExecutionResponse) GetRunId() string

func (*SignalWithStartWorkflowExecutionResponse) GoString 

func (this *SignalWithStartWorkflowExecutionResponse) GoString() string

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) ProtoMessage()

func (*SignalWithStartWorkflowExecutionResponse) Reset 

func (m *SignalWithStartWorkflowExecutionResponse) Reset()

func (*SignalWithStartWorkflowExecutionResponse) Size 

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

func (*SignalWithStartWorkflowExecutionResponse) String 

func (this *SignalWithStartWorkflowExecutionResponse) String() string

func (*SignalWithStartWorkflowExecutionResponse) Unmarshal 

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

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 (m *SignalWithStartWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*SignalWithStartWorkflowExecutionResponse) XXX_Size 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_Size() int

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 (m *SignalWorkflowExecutionRequest) GetSignalRequest() *v1.SignalWorkflowExecutionRequest

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 (m *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 */
	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 */
}

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

func (m *StartWorkflowExecutionRequest) GetStartRequest() *v1.StartWorkflowExecutionRequest

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"`
}

func (*StartWorkflowExecutionResponse) Descriptor 

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

func (*StartWorkflowExecutionResponse) Equal 

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

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 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"`
	ScheduledId        int64               `protobuf:"varint,5,opt,name=scheduled_id,json=scheduledId,proto3" json:"scheduled_id,omitempty"`
	ScheduledTime      *time.Time          `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedId          int64               `protobuf:"varint,7,opt,name=started_id,json=startedId,proto3" json:"started_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     *v17.VersionHistory `protobuf:"bytes,14,opt,name=version_history,json=versionHistory,proto3" json:"version_history,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) 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) GetScheduledId 

func (m *SyncActivityRequest) GetScheduledId() int64

func (*SyncActivityRequest) GetScheduledTime 

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

func (*SyncActivityRequest) GetStartedId 

func (m *SyncActivityRequest) GetStartedId() 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() *v17.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"`
}

func (*TerminateWorkflowExecutionRequest) Descriptor 

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

func (*TerminateWorkflowExecutionRequest) Equal 

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

func (*TerminateWorkflowExecutionRequest) GetNamespaceId 

func (m *TerminateWorkflowExecutionRequest) GetNamespaceId() string

func (*TerminateWorkflowExecutionRequest) GetTerminateRequest 

func (m *TerminateWorkflowExecutionRequest) GetTerminateRequest() *v1.TerminateWorkflowExecutionRequest

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 (m *TerminateWorkflowExecutionRequest) Reset()

func (*TerminateWorkflowExecutionRequest) Size 

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

func (*TerminateWorkflowExecutionRequest) String 

func (this *TerminateWorkflowExecutionRequest) String() 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 (m *TerminateWorkflowExecutionRequest) XXX_Merge(src proto.Message)

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 (m *TerminateWorkflowExecutionResponse) Reset()

func (*TerminateWorkflowExecutionResponse) Size 

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

func (*TerminateWorkflowExecutionResponse) String 

func (this *TerminateWorkflowExecutionResponse) String() 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 (m *TerminateWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*TerminateWorkflowExecutionResponse) XXX_Size 

func (m *TerminateWorkflowExecutionResponse) XXX_Size() int

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) CloseShard(ctx context.Context, req *CloseShardRequest) (*CloseShardResponse, error)

func (*UnimplementedHistoryServiceServer) DescribeHistoryHost 

func (*UnimplementedHistoryServiceServer) DescribeHistoryHost(ctx context.Context, req *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)

func (*UnimplementedHistoryServiceServer) DescribeMutableState 

func (*UnimplementedHistoryServiceServer) DescribeMutableState(ctx context.Context, req *DescribeMutableStateRequest) (*DescribeMutableStateResponse, error)

func (*UnimplementedHistoryServiceServer) DescribeWorkflowExecution 

func (*UnimplementedHistoryServiceServer) DescribeWorkflowExecution(ctx context.Context, req *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)

func (*UnimplementedHistoryServiceServer) GenerateLastHistoryReplicationTasks added in v1.14.0 

func (*UnimplementedHistoryServiceServer) GenerateLastHistoryReplicationTasks(ctx context.Context, req *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, error)

func (*UnimplementedHistoryServiceServer) GetDLQMessages 

func (*UnimplementedHistoryServiceServer) GetDLQMessages(ctx context.Context, req *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)

func (*UnimplementedHistoryServiceServer) GetDLQReplicationMessages 

func (*UnimplementedHistoryServiceServer) GetDLQReplicationMessages(ctx context.Context, req *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)

func (*UnimplementedHistoryServiceServer) GetMutableState 

func (*UnimplementedHistoryServiceServer) GetMutableState(ctx context.Context, req *GetMutableStateRequest) (*GetMutableStateResponse, error)

func (*UnimplementedHistoryServiceServer) GetReplicationMessages 

func (*UnimplementedHistoryServiceServer) GetReplicationMessages(ctx context.Context, req *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)

func (*UnimplementedHistoryServiceServer) GetReplicationStatus added in v1.14.0 

func (*UnimplementedHistoryServiceServer) GetReplicationStatus(ctx context.Context, req *GetReplicationStatusRequest) (*GetReplicationStatusResponse, error)

func (*UnimplementedHistoryServiceServer) GetShard added in v1.14.0 

func (*UnimplementedHistoryServiceServer) GetShard(ctx context.Context, req *GetShardRequest) (*GetShardResponse, error)

func (*UnimplementedHistoryServiceServer) MergeDLQMessages 

func (*UnimplementedHistoryServiceServer) MergeDLQMessages(ctx context.Context, req *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)

func (*UnimplementedHistoryServiceServer) PollMutableState 

func (*UnimplementedHistoryServiceServer) PollMutableState(ctx context.Context, req *PollMutableStateRequest) (*PollMutableStateResponse, error)

func (*UnimplementedHistoryServiceServer) PurgeDLQMessages 

func (*UnimplementedHistoryServiceServer) PurgeDLQMessages(ctx context.Context, req *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)

func (*UnimplementedHistoryServiceServer) QueryWorkflow 

func (*UnimplementedHistoryServiceServer) QueryWorkflow(ctx context.Context, req *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

func (*UnimplementedHistoryServiceServer) ReapplyEvents 

func (*UnimplementedHistoryServiceServer) ReapplyEvents(ctx context.Context, req *ReapplyEventsRequest) (*ReapplyEventsResponse, error)

func (*UnimplementedHistoryServiceServer) RecordActivityTaskHeartbeat 

func (*UnimplementedHistoryServiceServer) RecordActivityTaskHeartbeat(ctx context.Context, req *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)

func (*UnimplementedHistoryServiceServer) RecordActivityTaskStarted 

func (*UnimplementedHistoryServiceServer) RecordActivityTaskStarted(ctx context.Context, req *RecordActivityTaskStartedRequest) (*RecordActivityTaskStartedResponse, error)

func (*UnimplementedHistoryServiceServer) RecordChildExecutionCompleted 

func (*UnimplementedHistoryServiceServer) RecordChildExecutionCompleted(ctx context.Context, req *RecordChildExecutionCompletedRequest) (*RecordChildExecutionCompletedResponse, error)

func (*UnimplementedHistoryServiceServer) RecordWorkflowTaskStarted 

func (*UnimplementedHistoryServiceServer) RecordWorkflowTaskStarted(ctx context.Context, req *RecordWorkflowTaskStartedRequest) (*RecordWorkflowTaskStartedResponse, error)

func (*UnimplementedHistoryServiceServer) RefreshWorkflowTasks 

func (*UnimplementedHistoryServiceServer) RefreshWorkflowTasks(ctx context.Context, req *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)

func (*UnimplementedHistoryServiceServer) RemoveSignalMutableState 

func (*UnimplementedHistoryServiceServer) RemoveSignalMutableState(ctx context.Context, req *RemoveSignalMutableStateRequest) (*RemoveSignalMutableStateResponse, error)

func (*UnimplementedHistoryServiceServer) RemoveTask 

func (*UnimplementedHistoryServiceServer) RemoveTask(ctx context.Context, req *RemoveTaskRequest) (*RemoveTaskResponse, error)

func (*UnimplementedHistoryServiceServer) ReplicateEventsV2 

func (*UnimplementedHistoryServiceServer) ReplicateEventsV2(ctx context.Context, req *ReplicateEventsV2Request) (*ReplicateEventsV2Response, error)

func (*UnimplementedHistoryServiceServer) RequestCancelWorkflowExecution 

func (*UnimplementedHistoryServiceServer) RequestCancelWorkflowExecution(ctx context.Context, req *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)

func (*UnimplementedHistoryServiceServer) ResetStickyTaskQueue 

func (*UnimplementedHistoryServiceServer) ResetStickyTaskQueue(ctx context.Context, req *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)

func (*UnimplementedHistoryServiceServer) ResetWorkflowExecution 

func (*UnimplementedHistoryServiceServer) ResetWorkflowExecution(ctx context.Context, req *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)

func (*UnimplementedHistoryServiceServer) RespondActivityTaskCanceled 

func (*UnimplementedHistoryServiceServer) RespondActivityTaskCanceled(ctx context.Context, req *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)

func (*UnimplementedHistoryServiceServer) RespondActivityTaskCompleted 

func (*UnimplementedHistoryServiceServer) RespondActivityTaskCompleted(ctx context.Context, req *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)

func (*UnimplementedHistoryServiceServer) RespondActivityTaskFailed 

func (*UnimplementedHistoryServiceServer) RespondActivityTaskFailed(ctx context.Context, req *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)

func (*UnimplementedHistoryServiceServer) RespondWorkflowTaskCompleted 

func (*UnimplementedHistoryServiceServer) RespondWorkflowTaskCompleted(ctx context.Context, req *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)

func (*UnimplementedHistoryServiceServer) RespondWorkflowTaskFailed 

func (*UnimplementedHistoryServiceServer) RespondWorkflowTaskFailed(ctx context.Context, req *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)

func (*UnimplementedHistoryServiceServer) ScheduleWorkflowTask 

func (*UnimplementedHistoryServiceServer) ScheduleWorkflowTask(ctx context.Context, req *ScheduleWorkflowTaskRequest) (*ScheduleWorkflowTaskResponse, error)

func (*UnimplementedHistoryServiceServer) SignalWithStartWorkflowExecution 

func (*UnimplementedHistoryServiceServer) SignalWithStartWorkflowExecution(ctx context.Context, req *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)

func (*UnimplementedHistoryServiceServer) SignalWorkflowExecution 

func (*UnimplementedHistoryServiceServer) SignalWorkflowExecution(ctx context.Context, req *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)

func (*UnimplementedHistoryServiceServer) StartWorkflowExecution 

func (*UnimplementedHistoryServiceServer) StartWorkflowExecution(ctx context.Context, req *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)

func (*UnimplementedHistoryServiceServer) SyncActivity 

func (*UnimplementedHistoryServiceServer) SyncActivity(ctx context.Context, req *SyncActivityRequest) (*SyncActivityResponse, error)

func (*UnimplementedHistoryServiceServer) SyncShardStatus 

func (*UnimplementedHistoryServiceServer) SyncShardStatus(ctx context.Context, req *SyncShardStatusRequest) (*SyncShardStatusResponse, error)

func (*UnimplementedHistoryServiceServer) TerminateWorkflowExecution 

func (*UnimplementedHistoryServiceServer) TerminateWorkflowExecution(ctx context.Context, req *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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