adminservice

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2020 License: MIT Imports: 24 Imported by: 2

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 RegisterAdminServiceServer 

func RegisterAdminServiceServer(s *grpc.Server, srv AdminServiceServer)

Types

type AddSearchAttributeRequest 

type AddSearchAttributeRequest struct {
	SearchAttribute map[string]v16.IndexedValueType `` /* 239-byte string literal not displayed */
	SecurityToken   string                          `protobuf:"bytes,2,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
}

func (*AddSearchAttributeRequest) Descriptor 

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

func (*AddSearchAttributeRequest) Equal 

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

func (*AddSearchAttributeRequest) GetSearchAttribute 

func (m *AddSearchAttributeRequest) GetSearchAttribute() map[string]v16.IndexedValueType

func (*AddSearchAttributeRequest) GetSecurityToken 

func (m *AddSearchAttributeRequest) GetSecurityToken() string

func (*AddSearchAttributeRequest) GoString 

func (this *AddSearchAttributeRequest) GoString() string

func (*AddSearchAttributeRequest) Marshal 

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

func (*AddSearchAttributeRequest) MarshalTo 

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

func (*AddSearchAttributeRequest) MarshalToSizedBuffer 

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

func (*AddSearchAttributeRequest) ProtoMessage 

func (*AddSearchAttributeRequest) ProtoMessage()

func (*AddSearchAttributeRequest) Reset 

func (m *AddSearchAttributeRequest) Reset()

func (*AddSearchAttributeRequest) Size 

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

func (*AddSearchAttributeRequest) String 

func (this *AddSearchAttributeRequest) String() string

func (*AddSearchAttributeRequest) Unmarshal 

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

func (*AddSearchAttributeRequest) XXX_DiscardUnknown 

func (m *AddSearchAttributeRequest) XXX_DiscardUnknown()

func (*AddSearchAttributeRequest) XXX_Marshal 

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

func (*AddSearchAttributeRequest) XXX_Merge 

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

func (*AddSearchAttributeRequest) XXX_Size 

func (m *AddSearchAttributeRequest) XXX_Size() int

func (*AddSearchAttributeRequest) XXX_Unmarshal 

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

type AddSearchAttributeResponse 

type AddSearchAttributeResponse struct {
}

func (*AddSearchAttributeResponse) Descriptor 

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

func (*AddSearchAttributeResponse) Equal 

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

func (*AddSearchAttributeResponse) GoString 

func (this *AddSearchAttributeResponse) GoString() string

func (*AddSearchAttributeResponse) Marshal 

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

func (*AddSearchAttributeResponse) MarshalTo 

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

func (*AddSearchAttributeResponse) MarshalToSizedBuffer 

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

func (*AddSearchAttributeResponse) ProtoMessage 

func (*AddSearchAttributeResponse) ProtoMessage()

func (*AddSearchAttributeResponse) Reset 

func (m *AddSearchAttributeResponse) Reset()

func (*AddSearchAttributeResponse) Size 

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

func (*AddSearchAttributeResponse) String 

func (this *AddSearchAttributeResponse) String() string

func (*AddSearchAttributeResponse) Unmarshal 

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

func (*AddSearchAttributeResponse) XXX_DiscardUnknown 

func (m *AddSearchAttributeResponse) XXX_DiscardUnknown()

func (*AddSearchAttributeResponse) XXX_Marshal 

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

func (*AddSearchAttributeResponse) XXX_Merge 

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

func (*AddSearchAttributeResponse) XXX_Size 

func (m *AddSearchAttributeResponse) XXX_Size() int

func (*AddSearchAttributeResponse) XXX_Unmarshal 

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

type AdminServiceClient 

type AdminServiceClient interface {
	// DescribeWorkflowExecution returns information about the internal states of workflow execution.
	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(ctx context.Context, in *CloseShardRequest, opts ...grpc.CallOption) (*CloseShardResponse, error)
	RemoveTask(ctx context.Context, in *RemoveTaskRequest, opts ...grpc.CallOption) (*RemoveTaskResponse, error)
	// Returns the raw history of specified workflow execution.  It fails with 'NotFound' if specified workflow
	// execution in unknown to the service.
	// StartEventId defines the beginning of the event to fetch. The first event is inclusive.
	// EndEventId and EndEventVersion defines the end of the event to fetch. The end event is exclusive.
	GetWorkflowExecutionRawHistoryV2(ctx context.Context, in *GetWorkflowExecutionRawHistoryV2Request, opts ...grpc.CallOption) (*GetWorkflowExecutionRawHistoryV2Response, error)
	// GetReplicationMessages returns new replication tasks since the read level provided in the token.
	GetReplicationMessages(ctx context.Context, in *GetReplicationMessagesRequest, opts ...grpc.CallOption) (*GetReplicationMessagesResponse, error)
	// GetNamespaceReplicationMessages returns new namespace replication tasks since last retrieved task Id.
	GetNamespaceReplicationMessages(ctx context.Context, in *GetNamespaceReplicationMessagesRequest, opts ...grpc.CallOption) (*GetNamespaceReplicationMessagesResponse, error)
	// GetDLQReplicationMessages return replication messages based on DLQ info.
	GetDLQReplicationMessages(ctx context.Context, in *GetDLQReplicationMessagesRequest, opts ...grpc.CallOption) (*GetDLQReplicationMessagesResponse, error)
	// ReapplyEvents applies stale events to the current workflow and current run.
	ReapplyEvents(ctx context.Context, in *ReapplyEventsRequest, opts ...grpc.CallOption) (*ReapplyEventsResponse, error)
	// AddSearchAttribute whitelist search attribute in request.
	AddSearchAttribute(ctx context.Context, in *AddSearchAttributeRequest, opts ...grpc.CallOption) (*AddSearchAttributeResponse, error)
	// DescribeCluster returns information about Temporal cluster.
	DescribeCluster(ctx context.Context, in *DescribeClusterRequest, opts ...grpc.CallOption) (*DescribeClusterResponse, error)
	// GetDLQMessages returns messages from DLQ.
	GetDLQMessages(ctx context.Context, in *GetDLQMessagesRequest, opts ...grpc.CallOption) (*GetDLQMessagesResponse, error)
	// 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)
	// ResendReplicationTasks requests replication tasks from remote cluster and apply tasks to current cluster.
	ResendReplicationTasks(ctx context.Context, in *ResendReplicationTasksRequest, opts ...grpc.CallOption) (*ResendReplicationTasksResponse, error)
}

AdminServiceClient is the client API for AdminService service.

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

func NewAdminServiceClient 

func NewAdminServiceClient(cc *grpc.ClientConn) AdminServiceClient

type AdminServiceServer 

type AdminServiceServer interface {
	// DescribeWorkflowExecution returns information about the internal states of workflow execution.
	DescribeMutableState(context.Context, *DescribeMutableStateRequest) (*DescribeMutableStateResponse, error)
	// DescribeHistoryHost returns information about the internal states of a history host
	DescribeHistoryHost(context.Context, *DescribeHistoryHostRequest) (*DescribeHistoryHostResponse, error)
	CloseShard(context.Context, *CloseShardRequest) (*CloseShardResponse, error)
	RemoveTask(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)
	// Returns the raw history of specified workflow execution.  It fails with 'NotFound' if specified workflow
	// execution in unknown to the service.
	// StartEventId defines the beginning of the event to fetch. The first event is inclusive.
	// EndEventId and EndEventVersion defines the end of the event to fetch. The end event is exclusive.
	GetWorkflowExecutionRawHistoryV2(context.Context, *GetWorkflowExecutionRawHistoryV2Request) (*GetWorkflowExecutionRawHistoryV2Response, error)
	// GetReplicationMessages returns new replication tasks since the read level provided in the token.
	GetReplicationMessages(context.Context, *GetReplicationMessagesRequest) (*GetReplicationMessagesResponse, error)
	// GetNamespaceReplicationMessages returns new namespace replication tasks since last retrieved task Id.
	GetNamespaceReplicationMessages(context.Context, *GetNamespaceReplicationMessagesRequest) (*GetNamespaceReplicationMessagesResponse, error)
	// GetDLQReplicationMessages return replication messages based on DLQ info.
	GetDLQReplicationMessages(context.Context, *GetDLQReplicationMessagesRequest) (*GetDLQReplicationMessagesResponse, error)
	// ReapplyEvents applies stale events to the current workflow and current run.
	ReapplyEvents(context.Context, *ReapplyEventsRequest) (*ReapplyEventsResponse, error)
	// AddSearchAttribute whitelist search attribute in request.
	AddSearchAttribute(context.Context, *AddSearchAttributeRequest) (*AddSearchAttributeResponse, error)
	// DescribeCluster returns information about Temporal cluster.
	DescribeCluster(context.Context, *DescribeClusterRequest) (*DescribeClusterResponse, error)
	// GetDLQMessages returns messages from DLQ.
	GetDLQMessages(context.Context, *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)
	// 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)
	// ResendReplicationTasks requests replication tasks from remote cluster and apply tasks to current cluster.
	ResendReplicationTasks(context.Context, *ResendReplicationTasksRequest) (*ResendReplicationTasksResponse, error)
}

AdminServiceServer is the server API for AdminService service.

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 DescribeClusterRequest 

type DescribeClusterRequest struct {
}

func (*DescribeClusterRequest) Descriptor 

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

func (*DescribeClusterRequest) Equal 

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

func (*DescribeClusterRequest) GoString 

func (this *DescribeClusterRequest) GoString() string

func (*DescribeClusterRequest) Marshal 

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

func (*DescribeClusterRequest) MarshalTo 

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

func (*DescribeClusterRequest) MarshalToSizedBuffer 

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

func (*DescribeClusterRequest) ProtoMessage 

func (*DescribeClusterRequest) ProtoMessage()

func (*DescribeClusterRequest) Reset 

func (m *DescribeClusterRequest) Reset()

func (*DescribeClusterRequest) Size 

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

func (*DescribeClusterRequest) String 

func (this *DescribeClusterRequest) String() string

func (*DescribeClusterRequest) Unmarshal 

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

func (*DescribeClusterRequest) XXX_DiscardUnknown 

func (m *DescribeClusterRequest) XXX_DiscardUnknown()

func (*DescribeClusterRequest) XXX_Marshal 

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

func (*DescribeClusterRequest) XXX_Merge 

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

func (*DescribeClusterRequest) XXX_Size 

func (m *DescribeClusterRequest) XXX_Size() int

func (*DescribeClusterRequest) XXX_Unmarshal 

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

type DescribeClusterResponse 

type DescribeClusterResponse struct {
	SupportedClients map[string]string   `` /* 197-byte string literal not displayed */
	ServerVersion    string              `protobuf:"bytes,2,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	MembershipInfo   *v17.MembershipInfo `protobuf:"bytes,3,opt,name=membership_info,json=membershipInfo,proto3" json:"membership_info,omitempty"`
}

func (*DescribeClusterResponse) Descriptor 

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

func (*DescribeClusterResponse) Equal 

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

func (*DescribeClusterResponse) GetMembershipInfo 

func (m *DescribeClusterResponse) GetMembershipInfo() *v17.MembershipInfo

func (*DescribeClusterResponse) GetServerVersion added in v1.0.0 

func (m *DescribeClusterResponse) GetServerVersion() string

func (*DescribeClusterResponse) GetSupportedClients added in v1.0.0 

func (m *DescribeClusterResponse) GetSupportedClients() map[string]string

func (*DescribeClusterResponse) GoString 

func (this *DescribeClusterResponse) GoString() string

func (*DescribeClusterResponse) Marshal 

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

func (*DescribeClusterResponse) MarshalTo 

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

func (*DescribeClusterResponse) MarshalToSizedBuffer 

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

func (*DescribeClusterResponse) ProtoMessage 

func (*DescribeClusterResponse) ProtoMessage()

func (*DescribeClusterResponse) Reset 

func (m *DescribeClusterResponse) Reset()

func (*DescribeClusterResponse) Size 

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

func (*DescribeClusterResponse) String 

func (this *DescribeClusterResponse) String() string

func (*DescribeClusterResponse) Unmarshal 

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

func (*DescribeClusterResponse) XXX_DiscardUnknown 

func (m *DescribeClusterResponse) XXX_DiscardUnknown()

func (*DescribeClusterResponse) XXX_Marshal 

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

func (*DescribeClusterResponse) XXX_Merge 

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

func (*DescribeClusterResponse) XXX_Size 

func (m *DescribeClusterResponse) XXX_Size() int

func (*DescribeClusterResponse) XXX_Unmarshal 

func (m *DescribeClusterResponse) 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"`
	Namespace         string                `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution *v1.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) GetNamespace added in v0.28.0 

func (m *DescribeHistoryHostRequest) GetNamespace() 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() *v1.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        *v12.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() *v12.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 added in v1.3.0 

type DescribeMutableStateRequest struct {
	Namespace string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*DescribeMutableStateRequest) Descriptor added in v1.3.0 

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

func (*DescribeMutableStateRequest) Equal added in v1.3.0 

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

func (*DescribeMutableStateRequest) GetExecution added in v1.3.0 

func (m *DescribeMutableStateRequest) GetExecution() *v1.WorkflowExecution

func (*DescribeMutableStateRequest) GetNamespace added in v1.3.0 

func (m *DescribeMutableStateRequest) GetNamespace() string

func (*DescribeMutableStateRequest) GoString added in v1.3.0 

func (this *DescribeMutableStateRequest) GoString() string

func (*DescribeMutableStateRequest) Marshal added in v1.3.0 

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

func (*DescribeMutableStateRequest) MarshalTo added in v1.3.0 

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

func (*DescribeMutableStateRequest) MarshalToSizedBuffer added in v1.3.0 

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

func (*DescribeMutableStateRequest) ProtoMessage added in v1.3.0 

func (*DescribeMutableStateRequest) ProtoMessage()

func (*DescribeMutableStateRequest) Reset added in v1.3.0 

func (m *DescribeMutableStateRequest) Reset()

func (*DescribeMutableStateRequest) Size added in v1.3.0 

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

func (*DescribeMutableStateRequest) String added in v1.3.0 

func (this *DescribeMutableStateRequest) String() string

func (*DescribeMutableStateRequest) Unmarshal added in v1.3.0 

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

func (*DescribeMutableStateRequest) XXX_DiscardUnknown added in v1.3.0 

func (m *DescribeMutableStateRequest) XXX_DiscardUnknown()

func (*DescribeMutableStateRequest) XXX_Marshal added in v1.3.0 

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

func (*DescribeMutableStateRequest) XXX_Merge added in v1.3.0 

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

func (*DescribeMutableStateRequest) XXX_Size added in v1.3.0 

func (m *DescribeMutableStateRequest) XXX_Size() int

func (*DescribeMutableStateRequest) XXX_Unmarshal added in v1.3.0 

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

type DescribeMutableStateResponse added in v1.3.0 

type DescribeMutableStateResponse struct {
	ShardId              string                    `protobuf:"bytes,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	HistoryAddr          string                    `protobuf:"bytes,2,opt,name=history_addr,json=historyAddr,proto3" json:"history_addr,omitempty"`
	CacheMutableState    *v11.WorkflowMutableState `protobuf:"bytes,3,opt,name=cache_mutable_state,json=cacheMutableState,proto3" json:"cache_mutable_state,omitempty"`
	DatabaseMutableState *v11.WorkflowMutableState `protobuf:"bytes,4,opt,name=database_mutable_state,json=databaseMutableState,proto3" json:"database_mutable_state,omitempty"`
}

func (*DescribeMutableStateResponse) Descriptor added in v1.3.0 

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

func (*DescribeMutableStateResponse) Equal added in v1.3.0 

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

func (*DescribeMutableStateResponse) GetCacheMutableState added in v1.3.0 

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

func (*DescribeMutableStateResponse) GetDatabaseMutableState added in v1.3.0 

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

func (*DescribeMutableStateResponse) GetHistoryAddr added in v1.3.0 

func (m *DescribeMutableStateResponse) GetHistoryAddr() string

func (*DescribeMutableStateResponse) GetShardId added in v1.3.0 

func (m *DescribeMutableStateResponse) GetShardId() string

func (*DescribeMutableStateResponse) GoString added in v1.3.0 

func (this *DescribeMutableStateResponse) GoString() string

func (*DescribeMutableStateResponse) Marshal added in v1.3.0 

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

func (*DescribeMutableStateResponse) MarshalTo added in v1.3.0 

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

func (*DescribeMutableStateResponse) MarshalToSizedBuffer added in v1.3.0 

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

func (*DescribeMutableStateResponse) ProtoMessage added in v1.3.0 

func (*DescribeMutableStateResponse) ProtoMessage()

func (*DescribeMutableStateResponse) Reset added in v1.3.0 

func (m *DescribeMutableStateResponse) Reset()

func (*DescribeMutableStateResponse) Size added in v1.3.0 

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

func (*DescribeMutableStateResponse) String added in v1.3.0 

func (this *DescribeMutableStateResponse) String() string

func (*DescribeMutableStateResponse) Unmarshal added in v1.3.0 

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

func (*DescribeMutableStateResponse) XXX_DiscardUnknown added in v1.3.0 

func (m *DescribeMutableStateResponse) XXX_DiscardUnknown()

func (*DescribeMutableStateResponse) XXX_Marshal added in v1.3.0 

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

func (*DescribeMutableStateResponse) XXX_Merge added in v1.3.0 

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

func (*DescribeMutableStateResponse) XXX_Size added in v1.3.0 

func (m *DescribeMutableStateResponse) XXX_Size() int

func (*DescribeMutableStateResponse) XXX_Unmarshal added in v1.3.0 

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

type GetDLQMessagesRequest 

type GetDLQMessagesRequest struct {
	Type                  v13.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() v13.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             v13.DeadLetterQueueType `protobuf:"varint,1,opt,name=type,proto3,enum=temporal.server.api.enums.v1.DeadLetterQueueType" json:"type,omitempty"`
	ReplicationTasks []*v15.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() []*v15.ReplicationTask

func (*GetDLQMessagesResponse) GetType 

func (m *GetDLQMessagesResponse) GetType() v13.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 []*v15.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() []*v15.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 []*v15.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() []*v15.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 GetNamespaceReplicationMessagesRequest 

type GetNamespaceReplicationMessagesRequest struct {
	// lastRetrievedMessageId is where the next fetch should begin with.
	LastRetrievedMessageId int64 `` /* 132-byte string literal not displayed */
	// lastProcessedMessageId is the last messageId that is processed on the passive side.
	// This can be different than lastRetrievedMessageId if passive side supports prefetching messages.
	LastProcessedMessageId int64 `` /* 132-byte string literal not displayed */
	// clusterName is the name of the pulling cluster.
	ClusterName string `protobuf:"bytes,3,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
}

func (*GetNamespaceReplicationMessagesRequest) Descriptor 

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

func (*GetNamespaceReplicationMessagesRequest) Equal 

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

func (*GetNamespaceReplicationMessagesRequest) GetClusterName 

func (m *GetNamespaceReplicationMessagesRequest) GetClusterName() string

func (*GetNamespaceReplicationMessagesRequest) GetLastProcessedMessageId 

func (m *GetNamespaceReplicationMessagesRequest) GetLastProcessedMessageId() int64

func (*GetNamespaceReplicationMessagesRequest) GetLastRetrievedMessageId 

func (m *GetNamespaceReplicationMessagesRequest) GetLastRetrievedMessageId() int64

func (*GetNamespaceReplicationMessagesRequest) GoString 

func (this *GetNamespaceReplicationMessagesRequest) GoString() string

func (*GetNamespaceReplicationMessagesRequest) Marshal 

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

func (*GetNamespaceReplicationMessagesRequest) MarshalTo 

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

func (*GetNamespaceReplicationMessagesRequest) MarshalToSizedBuffer 

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

func (*GetNamespaceReplicationMessagesRequest) ProtoMessage 

func (*GetNamespaceReplicationMessagesRequest) ProtoMessage()

func (*GetNamespaceReplicationMessagesRequest) Reset 

func (m *GetNamespaceReplicationMessagesRequest) Reset()

func (*GetNamespaceReplicationMessagesRequest) Size 

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

func (*GetNamespaceReplicationMessagesRequest) String 

func (this *GetNamespaceReplicationMessagesRequest) String() string

func (*GetNamespaceReplicationMessagesRequest) Unmarshal 

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

func (*GetNamespaceReplicationMessagesRequest) XXX_DiscardUnknown 

func (m *GetNamespaceReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetNamespaceReplicationMessagesRequest) XXX_Marshal 

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

func (*GetNamespaceReplicationMessagesRequest) XXX_Merge 

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

func (*GetNamespaceReplicationMessagesRequest) XXX_Size 

func (m *GetNamespaceReplicationMessagesRequest) XXX_Size() int

func (*GetNamespaceReplicationMessagesRequest) XXX_Unmarshal 

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

type GetNamespaceReplicationMessagesResponse 

type GetNamespaceReplicationMessagesResponse struct {
	Messages *v15.ReplicationMessages `protobuf:"bytes,1,opt,name=messages,proto3" json:"messages,omitempty"`
}

func (*GetNamespaceReplicationMessagesResponse) Descriptor 

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

func (*GetNamespaceReplicationMessagesResponse) Equal 

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

func (*GetNamespaceReplicationMessagesResponse) GetMessages 

func (m *GetNamespaceReplicationMessagesResponse) GetMessages() *v15.ReplicationMessages

func (*GetNamespaceReplicationMessagesResponse) GoString 

func (this *GetNamespaceReplicationMessagesResponse) GoString() string

func (*GetNamespaceReplicationMessagesResponse) Marshal 

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

func (*GetNamespaceReplicationMessagesResponse) MarshalTo 

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

func (*GetNamespaceReplicationMessagesResponse) MarshalToSizedBuffer 

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

func (*GetNamespaceReplicationMessagesResponse) ProtoMessage 

func (*GetNamespaceReplicationMessagesResponse) ProtoMessage()

func (*GetNamespaceReplicationMessagesResponse) Reset 

func (m *GetNamespaceReplicationMessagesResponse) Reset()

func (*GetNamespaceReplicationMessagesResponse) Size 

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

func (*GetNamespaceReplicationMessagesResponse) String 

func (this *GetNamespaceReplicationMessagesResponse) String() string

func (*GetNamespaceReplicationMessagesResponse) Unmarshal 

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

func (*GetNamespaceReplicationMessagesResponse) XXX_DiscardUnknown 

func (m *GetNamespaceReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetNamespaceReplicationMessagesResponse) XXX_Marshal 

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

func (*GetNamespaceReplicationMessagesResponse) XXX_Merge 

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

func (*GetNamespaceReplicationMessagesResponse) XXX_Size 

func (m *GetNamespaceReplicationMessagesResponse) XXX_Size() int

func (*GetNamespaceReplicationMessagesResponse) XXX_Unmarshal 

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

type GetReplicationMessagesRequest 

type GetReplicationMessagesRequest struct {
	Tokens      []*v15.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() []*v15.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]*v15.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]*v15.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 GetWorkflowExecutionRawHistoryV2Request 

type GetWorkflowExecutionRawHistoryV2Request struct {
	Namespace         string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution         *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	StartEventId      int64                 `protobuf:"varint,3,opt,name=start_event_id,json=startEventId,proto3" json:"start_event_id,omitempty"`
	StartEventVersion int64                 `protobuf:"varint,4,opt,name=start_event_version,json=startEventVersion,proto3" json:"start_event_version,omitempty"`
	EndEventId        int64                 `protobuf:"varint,5,opt,name=end_event_id,json=endEventId,proto3" json:"end_event_id,omitempty"`
	EndEventVersion   int64                 `protobuf:"varint,6,opt,name=end_event_version,json=endEventVersion,proto3" json:"end_event_version,omitempty"`
	MaximumPageSize   int32                 `protobuf:"varint,7,opt,name=maximum_page_size,json=maximumPageSize,proto3" json:"maximum_page_size,omitempty"`
	NextPageToken     []byte                `protobuf:"bytes,8,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

* StartEventId defines the beginning of the event to fetch. The first event is exclusive. EndEventId and EndEventVersion defines the end of the event to fetch. The end event is exclusive.

func (*GetWorkflowExecutionRawHistoryV2Request) Descriptor 

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

func (*GetWorkflowExecutionRawHistoryV2Request) Equal 

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

func (*GetWorkflowExecutionRawHistoryV2Request) GetEndEventId 

func (m *GetWorkflowExecutionRawHistoryV2Request) GetEndEventId() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion 

func (m *GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GetExecution 

func (m *GetWorkflowExecutionRawHistoryV2Request) GetExecution() *v1.WorkflowExecution

func (*GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize 

func (m *GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize() int32

func (*GetWorkflowExecutionRawHistoryV2Request) GetNamespace 

func (m *GetWorkflowExecutionRawHistoryV2Request) GetNamespace() string

func (*GetWorkflowExecutionRawHistoryV2Request) GetNextPageToken 

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

func (*GetWorkflowExecutionRawHistoryV2Request) GetStartEventId 

func (m *GetWorkflowExecutionRawHistoryV2Request) GetStartEventId() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GetStartEventVersion 

func (m *GetWorkflowExecutionRawHistoryV2Request) GetStartEventVersion() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GoString 

func (this *GetWorkflowExecutionRawHistoryV2Request) GoString() string

func (*GetWorkflowExecutionRawHistoryV2Request) Marshal 

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

func (*GetWorkflowExecutionRawHistoryV2Request) MarshalTo 

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

func (*GetWorkflowExecutionRawHistoryV2Request) MarshalToSizedBuffer 

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

func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage 

func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage()

func (*GetWorkflowExecutionRawHistoryV2Request) Reset 

func (m *GetWorkflowExecutionRawHistoryV2Request) Reset()

func (*GetWorkflowExecutionRawHistoryV2Request) Size 

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

func (*GetWorkflowExecutionRawHistoryV2Request) String 

func (this *GetWorkflowExecutionRawHistoryV2Request) String() string

func (*GetWorkflowExecutionRawHistoryV2Request) Unmarshal 

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

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_DiscardUnknown 

func (m *GetWorkflowExecutionRawHistoryV2Request) XXX_DiscardUnknown()

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Marshal 

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

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Merge 

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

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Size 

func (m *GetWorkflowExecutionRawHistoryV2Request) XXX_Size() int

func (*GetWorkflowExecutionRawHistoryV2Request) XXX_Unmarshal 

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

type GetWorkflowExecutionRawHistoryV2Response 

type GetWorkflowExecutionRawHistoryV2Response struct {
	NextPageToken  []byte              `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	HistoryBatches []*v1.DataBlob      `protobuf:"bytes,2,rep,name=history_batches,json=historyBatches,proto3" json:"history_batches,omitempty"`
	VersionHistory *v14.VersionHistory `protobuf:"bytes,3,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
}

func (*GetWorkflowExecutionRawHistoryV2Response) Descriptor 

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

func (*GetWorkflowExecutionRawHistoryV2Response) Equal 

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetHistoryBatches 

func (m *GetWorkflowExecutionRawHistoryV2Response) GetHistoryBatches() []*v1.DataBlob

func (*GetWorkflowExecutionRawHistoryV2Response) GetNextPageToken 

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory 

func (m *GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory() *v14.VersionHistory

func (*GetWorkflowExecutionRawHistoryV2Response) GoString 

func (this *GetWorkflowExecutionRawHistoryV2Response) GoString() string

func (*GetWorkflowExecutionRawHistoryV2Response) Marshal 

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

func (*GetWorkflowExecutionRawHistoryV2Response) MarshalTo 

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

func (*GetWorkflowExecutionRawHistoryV2Response) MarshalToSizedBuffer 

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

func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage 

func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage()

func (*GetWorkflowExecutionRawHistoryV2Response) Reset 

func (m *GetWorkflowExecutionRawHistoryV2Response) Reset()

func (*GetWorkflowExecutionRawHistoryV2Response) Size 

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

func (*GetWorkflowExecutionRawHistoryV2Response) String 

func (this *GetWorkflowExecutionRawHistoryV2Response) String() string

func (*GetWorkflowExecutionRawHistoryV2Response) Unmarshal 

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

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_DiscardUnknown 

func (m *GetWorkflowExecutionRawHistoryV2Response) XXX_DiscardUnknown()

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Marshal 

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

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Merge 

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

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Size 

func (m *GetWorkflowExecutionRawHistoryV2Response) XXX_Size() int

func (*GetWorkflowExecutionRawHistoryV2Response) XXX_Unmarshal 

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

type MergeDLQMessagesRequest 

type MergeDLQMessagesRequest struct {
	Type                  v13.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() v13.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 PurgeDLQMessagesRequest 

type PurgeDLQMessagesRequest struct {
	Type                  v13.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() v13.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 ReapplyEventsRequest 

type ReapplyEventsRequest struct {
	Namespace         string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Events            *v1.DataBlob          `protobuf:"bytes,3,opt,name=events,proto3" json:"events,omitempty"`
}

ReapplyEventsRequest is the request for reapply events API.

func (*ReapplyEventsRequest) Descriptor 

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

func (*ReapplyEventsRequest) Equal 

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

func (*ReapplyEventsRequest) GetEvents 

func (m *ReapplyEventsRequest) GetEvents() *v1.DataBlob

func (*ReapplyEventsRequest) GetNamespace 

func (m *ReapplyEventsRequest) GetNamespace() string

func (*ReapplyEventsRequest) GetWorkflowExecution 

func (m *ReapplyEventsRequest) GetWorkflowExecution() *v1.WorkflowExecution

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 RefreshWorkflowTasksRequest 

type RefreshWorkflowTasksRequest struct {
	Namespace string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*RefreshWorkflowTasksRequest) Descriptor 

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

func (*RefreshWorkflowTasksRequest) Equal 

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

func (*RefreshWorkflowTasksRequest) GetExecution 

func (m *RefreshWorkflowTasksRequest) GetExecution() *v1.WorkflowExecution

func (*RefreshWorkflowTasksRequest) GetNamespace 

func (m *RefreshWorkflowTasksRequest) GetNamespace() string

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 RemoveTaskRequest 

type RemoveTaskRequest struct {
	ShardId        int32            `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Category       v13.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() v13.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 ResendReplicationTasksRequest 

type ResendReplicationTasksRequest 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"`
	RemoteCluster string `protobuf:"bytes,4,opt,name=remote_cluster,json=remoteCluster,proto3" json:"remote_cluster,omitempty"`
	StartEventId  int64  `protobuf:"varint,5,opt,name=start_event_id,json=startEventId,proto3" json:"start_event_id,omitempty"`
	StartVersion  int64  `protobuf:"varint,6,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndEventId    int64  `protobuf:"varint,7,opt,name=end_event_id,json=endEventId,proto3" json:"end_event_id,omitempty"`
	EndVersion    int64  `protobuf:"varint,8,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
}

func (*ResendReplicationTasksRequest) Descriptor 

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

func (*ResendReplicationTasksRequest) Equal 

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

func (*ResendReplicationTasksRequest) GetEndEventId 

func (m *ResendReplicationTasksRequest) GetEndEventId() int64

func (*ResendReplicationTasksRequest) GetEndVersion 

func (m *ResendReplicationTasksRequest) GetEndVersion() int64

func (*ResendReplicationTasksRequest) GetNamespaceId 

func (m *ResendReplicationTasksRequest) GetNamespaceId() string

func (*ResendReplicationTasksRequest) GetRemoteCluster 

func (m *ResendReplicationTasksRequest) GetRemoteCluster() string

func (*ResendReplicationTasksRequest) GetRunId 

func (m *ResendReplicationTasksRequest) GetRunId() string

func (*ResendReplicationTasksRequest) GetStartEventId 

func (m *ResendReplicationTasksRequest) GetStartEventId() int64

func (*ResendReplicationTasksRequest) GetStartVersion 

func (m *ResendReplicationTasksRequest) GetStartVersion() int64

func (*ResendReplicationTasksRequest) GetWorkflowId 

func (m *ResendReplicationTasksRequest) GetWorkflowId() string

func (*ResendReplicationTasksRequest) GoString 

func (this *ResendReplicationTasksRequest) GoString() string

func (*ResendReplicationTasksRequest) Marshal 

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

func (*ResendReplicationTasksRequest) MarshalTo 

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

func (*ResendReplicationTasksRequest) MarshalToSizedBuffer 

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

func (*ResendReplicationTasksRequest) ProtoMessage 

func (*ResendReplicationTasksRequest) ProtoMessage()

func (*ResendReplicationTasksRequest) Reset 

func (m *ResendReplicationTasksRequest) Reset()

func (*ResendReplicationTasksRequest) Size 

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

func (*ResendReplicationTasksRequest) String 

func (this *ResendReplicationTasksRequest) String() string

func (*ResendReplicationTasksRequest) Unmarshal 

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

func (*ResendReplicationTasksRequest) XXX_DiscardUnknown 

func (m *ResendReplicationTasksRequest) XXX_DiscardUnknown()

func (*ResendReplicationTasksRequest) XXX_Marshal 

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

func (*ResendReplicationTasksRequest) XXX_Merge 

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

func (*ResendReplicationTasksRequest) XXX_Size 

func (m *ResendReplicationTasksRequest) XXX_Size() int

func (*ResendReplicationTasksRequest) XXX_Unmarshal 

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

type ResendReplicationTasksResponse 

type ResendReplicationTasksResponse struct {
}

func (*ResendReplicationTasksResponse) Descriptor 

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

func (*ResendReplicationTasksResponse) Equal 

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

func (*ResendReplicationTasksResponse) GoString 

func (this *ResendReplicationTasksResponse) GoString() string

func (*ResendReplicationTasksResponse) Marshal 

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

func (*ResendReplicationTasksResponse) MarshalTo 

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

func (*ResendReplicationTasksResponse) MarshalToSizedBuffer 

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

func (*ResendReplicationTasksResponse) ProtoMessage 

func (*ResendReplicationTasksResponse) ProtoMessage()

func (*ResendReplicationTasksResponse) Reset 

func (m *ResendReplicationTasksResponse) Reset()

func (*ResendReplicationTasksResponse) Size 

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

func (*ResendReplicationTasksResponse) String 

func (this *ResendReplicationTasksResponse) String() string

func (*ResendReplicationTasksResponse) Unmarshal 

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

func (*ResendReplicationTasksResponse) XXX_DiscardUnknown 

func (m *ResendReplicationTasksResponse) XXX_DiscardUnknown()

func (*ResendReplicationTasksResponse) XXX_Marshal 

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

func (*ResendReplicationTasksResponse) XXX_Merge 

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

func (*ResendReplicationTasksResponse) XXX_Size 

func (m *ResendReplicationTasksResponse) XXX_Size() int

func (*ResendReplicationTasksResponse) XXX_Unmarshal 

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

type UnimplementedAdminServiceServer 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServiceServer) AddSearchAttribute 

func (*UnimplementedAdminServiceServer) AddSearchAttribute(ctx context.Context, req *AddSearchAttributeRequest) (*AddSearchAttributeResponse, error)

func (*UnimplementedAdminServiceServer) CloseShard 

func (*UnimplementedAdminServiceServer) CloseShard(ctx context.Context, req *CloseShardRequest) (*CloseShardResponse, error)

func (*UnimplementedAdminServiceServer) DescribeCluster 

func (*UnimplementedAdminServiceServer) DescribeCluster(ctx context.Context, req *DescribeClusterRequest) (*DescribeClusterResponse, error)

func (*UnimplementedAdminServiceServer) DescribeHistoryHost 

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

func (*UnimplementedAdminServiceServer) DescribeMutableState added in v1.3.0 

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

func (*UnimplementedAdminServiceServer) GetDLQMessages 

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

func (*UnimplementedAdminServiceServer) GetDLQReplicationMessages 

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

func (*UnimplementedAdminServiceServer) GetNamespaceReplicationMessages 

func (*UnimplementedAdminServiceServer) GetNamespaceReplicationMessages(ctx context.Context, req *GetNamespaceReplicationMessagesRequest) (*GetNamespaceReplicationMessagesResponse, error)

func (*UnimplementedAdminServiceServer) GetReplicationMessages 

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

func (*UnimplementedAdminServiceServer) GetWorkflowExecutionRawHistoryV2 

func (*UnimplementedAdminServiceServer) GetWorkflowExecutionRawHistoryV2(ctx context.Context, req *GetWorkflowExecutionRawHistoryV2Request) (*GetWorkflowExecutionRawHistoryV2Response, error)

func (*UnimplementedAdminServiceServer) MergeDLQMessages 

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

func (*UnimplementedAdminServiceServer) PurgeDLQMessages 

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

func (*UnimplementedAdminServiceServer) ReapplyEvents 

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

func (*UnimplementedAdminServiceServer) RefreshWorkflowTasks 

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

func (*UnimplementedAdminServiceServer) RemoveTask 

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

func (*UnimplementedAdminServiceServer) ResendReplicationTasks 

func (*UnimplementedAdminServiceServer) ResendReplicationTasks(ctx context.Context, req *ResendReplicationTasksRequest) (*ResendReplicationTasksResponse, 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.