adminservice

package
v1.16.3 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2022 License: MIT Imports: 28 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 AddOrUpdateRemoteClusterRequest added in v1.14.0 

type AddOrUpdateRemoteClusterRequest struct {
	FrontendAddress               string `protobuf:"bytes,1,opt,name=frontend_address,json=frontendAddress,proto3" json:"frontend_address,omitempty"`
	EnableRemoteClusterConnection bool   `` /* 153-byte string literal not displayed */
}

func (*AddOrUpdateRemoteClusterRequest) Descriptor added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) Equal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection added in v1.14.0 

func (m *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

func (*AddOrUpdateRemoteClusterRequest) GetFrontendAddress added in v1.14.0 

func (m *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

func (*AddOrUpdateRemoteClusterRequest) GoString added in v1.14.0 

func (this *AddOrUpdateRemoteClusterRequest) GoString() string

func (*AddOrUpdateRemoteClusterRequest) Marshal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) MarshalTo added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) MarshalToSizedBuffer added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage added in v1.14.0 

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

func (*AddOrUpdateRemoteClusterRequest) Reset added in v1.14.0 

func (m *AddOrUpdateRemoteClusterRequest) Reset()

func (*AddOrUpdateRemoteClusterRequest) Size added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) String added in v1.14.0 

func (this *AddOrUpdateRemoteClusterRequest) String() string

func (*AddOrUpdateRemoteClusterRequest) Unmarshal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown added in v1.14.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_DiscardUnknown()

func (*AddOrUpdateRemoteClusterRequest) XXX_Marshal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) XXX_Merge added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterRequest) XXX_Size added in v1.14.0 

func (m *AddOrUpdateRemoteClusterRequest) XXX_Size() int

func (*AddOrUpdateRemoteClusterRequest) XXX_Unmarshal added in v1.14.0 

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

type AddOrUpdateRemoteClusterResponse added in v1.14.0 

type AddOrUpdateRemoteClusterResponse struct {
}

func (*AddOrUpdateRemoteClusterResponse) Descriptor added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) Equal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) GoString added in v1.14.0 

func (this *AddOrUpdateRemoteClusterResponse) GoString() string

func (*AddOrUpdateRemoteClusterResponse) Marshal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) MarshalTo added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) MarshalToSizedBuffer added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage added in v1.14.0 

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

func (*AddOrUpdateRemoteClusterResponse) Reset added in v1.14.0 

func (m *AddOrUpdateRemoteClusterResponse) Reset()

func (*AddOrUpdateRemoteClusterResponse) Size added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) String added in v1.14.0 

func (this *AddOrUpdateRemoteClusterResponse) String() string

func (*AddOrUpdateRemoteClusterResponse) Unmarshal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown added in v1.14.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_DiscardUnknown()

func (*AddOrUpdateRemoteClusterResponse) XXX_Marshal added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) XXX_Merge added in v1.14.0 

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

func (*AddOrUpdateRemoteClusterResponse) XXX_Size added in v1.14.0 

func (m *AddOrUpdateRemoteClusterResponse) XXX_Size() int

func (*AddOrUpdateRemoteClusterResponse) XXX_Unmarshal added in v1.14.0 

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

type AddSearchAttributesRequest added in v1.10.0 

type AddSearchAttributesRequest struct {
	SearchAttributes map[string]v16.IndexedValueType `` /* 242-byte string literal not displayed */
	IndexName        string                          `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	SkipSchemaUpdate bool                            `protobuf:"varint,3,opt,name=skip_schema_update,json=skipSchemaUpdate,proto3" json:"skip_schema_update,omitempty"`
}

func (*AddSearchAttributesRequest) Descriptor added in v1.10.0 

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

func (*AddSearchAttributesRequest) Equal added in v1.10.0 

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

func (*AddSearchAttributesRequest) GetIndexName added in v1.10.0 

func (m *AddSearchAttributesRequest) GetIndexName() string

func (*AddSearchAttributesRequest) GetSearchAttributes added in v1.10.0 

func (m *AddSearchAttributesRequest) GetSearchAttributes() map[string]v16.IndexedValueType

func (*AddSearchAttributesRequest) GetSkipSchemaUpdate added in v1.12.0 

func (m *AddSearchAttributesRequest) GetSkipSchemaUpdate() bool

func (*AddSearchAttributesRequest) GoString added in v1.10.0 

func (this *AddSearchAttributesRequest) GoString() string

func (*AddSearchAttributesRequest) Marshal added in v1.10.0 

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

func (*AddSearchAttributesRequest) MarshalTo added in v1.10.0 

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

func (*AddSearchAttributesRequest) MarshalToSizedBuffer added in v1.10.0 

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

func (*AddSearchAttributesRequest) ProtoMessage added in v1.10.0 

func (*AddSearchAttributesRequest) ProtoMessage()

func (*AddSearchAttributesRequest) Reset added in v1.10.0 

func (m *AddSearchAttributesRequest) Reset()

func (*AddSearchAttributesRequest) Size added in v1.10.0 

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

func (*AddSearchAttributesRequest) String added in v1.10.0 

func (this *AddSearchAttributesRequest) String() string

func (*AddSearchAttributesRequest) Unmarshal added in v1.10.0 

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

func (*AddSearchAttributesRequest) XXX_DiscardUnknown added in v1.10.0 

func (m *AddSearchAttributesRequest) XXX_DiscardUnknown()

func (*AddSearchAttributesRequest) XXX_Marshal added in v1.10.0 

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

func (*AddSearchAttributesRequest) XXX_Merge added in v1.10.0 

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

func (*AddSearchAttributesRequest) XXX_Size added in v1.10.0 

func (m *AddSearchAttributesRequest) XXX_Size() int

func (*AddSearchAttributesRequest) XXX_Unmarshal added in v1.10.0 

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

type AddSearchAttributesResponse added in v1.10.0 

type AddSearchAttributesResponse struct {
}

func (*AddSearchAttributesResponse) Descriptor added in v1.10.0 

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

func (*AddSearchAttributesResponse) Equal added in v1.10.0 

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

func (*AddSearchAttributesResponse) GoString added in v1.10.0 

func (this *AddSearchAttributesResponse) GoString() string

func (*AddSearchAttributesResponse) Marshal added in v1.10.0 

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

func (*AddSearchAttributesResponse) MarshalTo added in v1.10.0 

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

func (*AddSearchAttributesResponse) MarshalToSizedBuffer added in v1.10.0 

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

func (*AddSearchAttributesResponse) ProtoMessage added in v1.10.0 

func (*AddSearchAttributesResponse) ProtoMessage()

func (*AddSearchAttributesResponse) Reset added in v1.10.0 

func (m *AddSearchAttributesResponse) Reset()

func (*AddSearchAttributesResponse) Size added in v1.10.0 

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

func (*AddSearchAttributesResponse) String added in v1.10.0 

func (this *AddSearchAttributesResponse) String() string

func (*AddSearchAttributesResponse) Unmarshal added in v1.10.0 

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

func (*AddSearchAttributesResponse) XXX_DiscardUnknown added in v1.10.0 

func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()

func (*AddSearchAttributesResponse) XXX_Marshal added in v1.10.0 

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

func (*AddSearchAttributesResponse) XXX_Merge added in v1.10.0 

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

func (*AddSearchAttributesResponse) XXX_Size added in v1.10.0 

func (m *AddSearchAttributesResponse) XXX_Size() int

func (*AddSearchAttributesResponse) XXX_Unmarshal added in v1.10.0 

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

type AdminServiceClient 

type AdminServiceClient interface {
	// RebuildMutableState attempts to rebuild mutable state according to persisted history events.
	// NOTE: this is experimental API
	RebuildMutableState(ctx context.Context, in *RebuildMutableStateRequest, opts ...grpc.CallOption) (*RebuildMutableStateResponse, error)
	// 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)
	GetShard(ctx context.Context, in *GetShardRequest, opts ...grpc.CallOption) (*GetShardResponse, error)
	CloseShard(ctx context.Context, in *CloseShardRequest, opts ...grpc.CallOption) (*CloseShardResponse, error)
	ListHistoryTasks(ctx context.Context, in *ListHistoryTasksRequest, opts ...grpc.CallOption) (*ListHistoryTasksResponse, 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)
	// AddSearchAttributes add custom search attributes and returns comprehensive information about them.
	AddSearchAttributes(ctx context.Context, in *AddSearchAttributesRequest, opts ...grpc.CallOption) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes and returns comprehensive information about them.
	RemoveSearchAttributes(ctx context.Context, in *RemoveSearchAttributesRequest, opts ...grpc.CallOption) (*RemoveSearchAttributesResponse, error)
	// GetSearchAttributes returns comprehensive information about search attributes.
	GetSearchAttributes(ctx context.Context, in *GetSearchAttributesRequest, opts ...grpc.CallOption) (*GetSearchAttributesResponse, error)
	// DescribeCluster returns information about Temporal cluster.
	DescribeCluster(ctx context.Context, in *DescribeClusterRequest, opts ...grpc.CallOption) (*DescribeClusterResponse, error)
	// ListClusters returns information about Temporal clusters.
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	// ListClusterMembers returns information about Temporal cluster members.
	ListClusterMembers(ctx context.Context, in *ListClusterMembersRequest, opts ...grpc.CallOption) (*ListClusterMembersResponse, error)
	// AddOrUpdateRemoteCluster adds or updates remote cluster.
	AddOrUpdateRemoteCluster(ctx context.Context, in *AddOrUpdateRemoteClusterRequest, opts ...grpc.CallOption) (*AddOrUpdateRemoteClusterResponse, error)
	// RemoveRemoteCluster removes remote cluster.
	RemoveRemoteCluster(ctx context.Context, in *RemoveRemoteClusterRequest, opts ...grpc.CallOption) (*RemoveRemoteClusterResponse, error)
	// GetDLQMessages returns messages from DLQ.
	GetDLQMessages(ctx context.Context, in *GetDLQMessagesRequest, opts ...grpc.CallOption) (*GetDLQMessagesResponse, error)
	// (-- api-linter: core::0165::response-message-name=disabled
	//     aip.dev/not-precedent:  --)
	// PurgeDLQMessages purges messages from DLQ.
	PurgeDLQMessages(ctx context.Context, in *PurgeDLQMessagesRequest, opts ...grpc.CallOption) (*PurgeDLQMessagesResponse, error)
	// MergeDLQMessages merges messages from DLQ.
	MergeDLQMessages(ctx context.Context, in *MergeDLQMessagesRequest, opts ...grpc.CallOption) (*MergeDLQMessagesResponse, error)
	// RefreshWorkflowTasks refreshes all tasks of a workflow.
	RefreshWorkflowTasks(ctx context.Context, in *RefreshWorkflowTasksRequest, opts ...grpc.CallOption) (*RefreshWorkflowTasksResponse, error)
	// ResendReplicationTasks requests replication tasks from remote cluster and apply tasks to current cluster.
	ResendReplicationTasks(ctx context.Context, in *ResendReplicationTasksRequest, opts ...grpc.CallOption) (*ResendReplicationTasksResponse, error)
	// GetTaskQueueTasks returns tasks from task queue.
	GetTaskQueueTasks(ctx context.Context, in *GetTaskQueueTasksRequest, opts ...grpc.CallOption) (*GetTaskQueueTasksResponse, 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 {
	// RebuildMutableState attempts to rebuild mutable state according to persisted history events.
	// NOTE: this is experimental API
	RebuildMutableState(context.Context, *RebuildMutableStateRequest) (*RebuildMutableStateResponse, error)
	// 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)
	GetShard(context.Context, *GetShardRequest) (*GetShardResponse, error)
	CloseShard(context.Context, *CloseShardRequest) (*CloseShardResponse, error)
	ListHistoryTasks(context.Context, *ListHistoryTasksRequest) (*ListHistoryTasksResponse, 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)
	// AddSearchAttributes add custom search attributes and returns comprehensive information about them.
	AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes and returns comprehensive information about them.
	RemoveSearchAttributes(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)
	// GetSearchAttributes returns comprehensive information about search attributes.
	GetSearchAttributes(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)
	// DescribeCluster returns information about Temporal cluster.
	DescribeCluster(context.Context, *DescribeClusterRequest) (*DescribeClusterResponse, error)
	// ListClusters returns information about Temporal clusters.
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	// ListClusterMembers returns information about Temporal cluster members.
	ListClusterMembers(context.Context, *ListClusterMembersRequest) (*ListClusterMembersResponse, error)
	// AddOrUpdateRemoteCluster adds or updates remote cluster.
	AddOrUpdateRemoteCluster(context.Context, *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)
	// RemoveRemoteCluster removes remote cluster.
	RemoveRemoteCluster(context.Context, *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)
	// GetDLQMessages returns messages from DLQ.
	GetDLQMessages(context.Context, *GetDLQMessagesRequest) (*GetDLQMessagesResponse, error)
	// (-- api-linter: core::0165::response-message-name=disabled
	//     aip.dev/not-precedent:  --)
	// PurgeDLQMessages purges messages from DLQ.
	PurgeDLQMessages(context.Context, *PurgeDLQMessagesRequest) (*PurgeDLQMessagesResponse, error)
	// MergeDLQMessages merges messages from DLQ.
	MergeDLQMessages(context.Context, *MergeDLQMessagesRequest) (*MergeDLQMessagesResponse, error)
	// RefreshWorkflowTasks refreshes all tasks of a workflow.
	RefreshWorkflowTasks(context.Context, *RefreshWorkflowTasksRequest) (*RefreshWorkflowTasksResponse, error)
	// ResendReplicationTasks requests replication tasks from remote cluster and apply tasks to current cluster.
	ResendReplicationTasks(context.Context, *ResendReplicationTasksRequest) (*ResendReplicationTasksResponse, error)
	// GetTaskQueueTasks returns tasks from task queue.
	GetTaskQueueTasks(context.Context, *GetTaskQueueTasksRequest) (*GetTaskQueueTasksResponse, 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 {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
}

func (*DescribeClusterRequest) Descriptor 

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

func (*DescribeClusterRequest) Equal 

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

func (*DescribeClusterRequest) GetClusterName added in v1.14.0 

func (m *DescribeClusterRequest) GetClusterName() string

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           *v18.MembershipInfo `protobuf:"bytes,3,opt,name=membership_info,json=membershipInfo,proto3" json:"membership_info,omitempty"`
	ClusterId                string              `protobuf:"bytes,4,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ClusterName              string              `protobuf:"bytes,5,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HistoryShardCount        int32               `protobuf:"varint,6,opt,name=history_shard_count,json=historyShardCount,proto3" json:"history_shard_count,omitempty"`
	PersistenceStore         string              `protobuf:"bytes,7,opt,name=persistence_store,json=persistenceStore,proto3" json:"persistence_store,omitempty"`
	VisibilityStore          string              `protobuf:"bytes,8,opt,name=visibility_store,json=visibilityStore,proto3" json:"visibility_store,omitempty"`
	VersionInfo              *v19.VersionInfo    `protobuf:"bytes,9,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	FailoverVersionIncrement int64               `` /* 137-byte string literal not displayed */
	InitialFailoverVersion   int64               `` /* 131-byte string literal not displayed */
	IsGlobalNamespaceEnabled bool                `` /* 139-byte string literal not displayed */
}

func (*DescribeClusterResponse) Descriptor 

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

func (*DescribeClusterResponse) Equal 

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

func (*DescribeClusterResponse) GetClusterId added in v1.14.0 

func (m *DescribeClusterResponse) GetClusterId() string

func (*DescribeClusterResponse) GetClusterName added in v1.14.0 

func (m *DescribeClusterResponse) GetClusterName() string

func (*DescribeClusterResponse) GetFailoverVersionIncrement added in v1.14.0 

func (m *DescribeClusterResponse) GetFailoverVersionIncrement() int64

func (*DescribeClusterResponse) GetHistoryShardCount added in v1.14.0 

func (m *DescribeClusterResponse) GetHistoryShardCount() int32

func (*DescribeClusterResponse) GetInitialFailoverVersion added in v1.14.0 

func (m *DescribeClusterResponse) GetInitialFailoverVersion() int64

func (*DescribeClusterResponse) GetIsGlobalNamespaceEnabled added in v1.14.0 

func (m *DescribeClusterResponse) GetIsGlobalNamespaceEnabled() bool

func (*DescribeClusterResponse) GetMembershipInfo 

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

func (*DescribeClusterResponse) GetPersistenceStore added in v1.14.0 

func (m *DescribeClusterResponse) GetPersistenceStore() string

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) GetVersionInfo added in v1.14.0 

func (m *DescribeClusterResponse) GetVersionInfo() *v19.VersionInfo

func (*DescribeClusterResponse) GetVisibilityStore added in v1.14.0 

func (m *DescribeClusterResponse) GetVisibilityStore() 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 GetSearchAttributesRequest added in v1.10.0 

type GetSearchAttributesRequest struct {
	IndexName string `protobuf:"bytes,1,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
}

func (*GetSearchAttributesRequest) Descriptor added in v1.10.0 

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

func (*GetSearchAttributesRequest) Equal added in v1.10.0 

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

func (*GetSearchAttributesRequest) GetIndexName added in v1.10.0 

func (m *GetSearchAttributesRequest) GetIndexName() string

func (*GetSearchAttributesRequest) GoString added in v1.10.0 

func (this *GetSearchAttributesRequest) GoString() string

func (*GetSearchAttributesRequest) Marshal added in v1.10.0 

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

func (*GetSearchAttributesRequest) MarshalTo added in v1.10.0 

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

func (*GetSearchAttributesRequest) MarshalToSizedBuffer added in v1.10.0 

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

func (*GetSearchAttributesRequest) ProtoMessage added in v1.10.0 

func (*GetSearchAttributesRequest) ProtoMessage()

func (*GetSearchAttributesRequest) Reset added in v1.10.0 

func (m *GetSearchAttributesRequest) Reset()

func (*GetSearchAttributesRequest) Size added in v1.10.0 

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

func (*GetSearchAttributesRequest) String added in v1.10.0 

func (this *GetSearchAttributesRequest) String() string

func (*GetSearchAttributesRequest) Unmarshal added in v1.10.0 

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

func (*GetSearchAttributesRequest) XXX_DiscardUnknown added in v1.10.0 

func (m *GetSearchAttributesRequest) XXX_DiscardUnknown()

func (*GetSearchAttributesRequest) XXX_Marshal added in v1.10.0 

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

func (*GetSearchAttributesRequest) XXX_Merge added in v1.10.0 

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

func (*GetSearchAttributesRequest) XXX_Size added in v1.10.0 

func (m *GetSearchAttributesRequest) XXX_Size() int

func (*GetSearchAttributesRequest) XXX_Unmarshal added in v1.10.0 

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

type GetSearchAttributesResponse added in v1.10.0 

type GetSearchAttributesResponse struct {
	CustomAttributes map[string]v16.IndexedValueType `` /* 242-byte string literal not displayed */
	SystemAttributes map[string]v16.IndexedValueType `` /* 242-byte string literal not displayed */
	Mapping          map[string]string               `` /* 155-byte string literal not displayed */
	// State of the workflow that adds search attributes to the system.
	AddWorkflowExecutionInfo *v17.WorkflowExecutionInfo `` /* 137-byte string literal not displayed */
}

func (*GetSearchAttributesResponse) Descriptor added in v1.10.0 

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

func (*GetSearchAttributesResponse) Equal added in v1.10.0 

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

func (*GetSearchAttributesResponse) GetAddWorkflowExecutionInfo added in v1.10.0 

func (m *GetSearchAttributesResponse) GetAddWorkflowExecutionInfo() *v17.WorkflowExecutionInfo

func (*GetSearchAttributesResponse) GetCustomAttributes added in v1.10.0 

func (m *GetSearchAttributesResponse) GetCustomAttributes() map[string]v16.IndexedValueType

func (*GetSearchAttributesResponse) GetMapping added in v1.10.0 

func (m *GetSearchAttributesResponse) GetMapping() map[string]string

func (*GetSearchAttributesResponse) GetSystemAttributes added in v1.10.0 

func (m *GetSearchAttributesResponse) GetSystemAttributes() map[string]v16.IndexedValueType

func (*GetSearchAttributesResponse) GoString added in v1.10.0 

func (this *GetSearchAttributesResponse) GoString() string

func (*GetSearchAttributesResponse) Marshal added in v1.10.0 

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

func (*GetSearchAttributesResponse) MarshalTo added in v1.10.0 

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

func (*GetSearchAttributesResponse) MarshalToSizedBuffer added in v1.10.0 

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

func (*GetSearchAttributesResponse) ProtoMessage added in v1.10.0 

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) Reset added in v1.10.0 

func (m *GetSearchAttributesResponse) Reset()

func (*GetSearchAttributesResponse) Size added in v1.10.0 

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

func (*GetSearchAttributesResponse) String added in v1.10.0 

func (this *GetSearchAttributesResponse) String() string

func (*GetSearchAttributesResponse) Unmarshal added in v1.10.0 

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

func (*GetSearchAttributesResponse) XXX_DiscardUnknown added in v1.10.0 

func (m *GetSearchAttributesResponse) XXX_DiscardUnknown()

func (*GetSearchAttributesResponse) XXX_Marshal added in v1.10.0 

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

func (*GetSearchAttributesResponse) XXX_Merge added in v1.10.0 

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

func (*GetSearchAttributesResponse) XXX_Size added in v1.10.0 

func (m *GetSearchAttributesResponse) XXX_Size() int

func (*GetSearchAttributesResponse) XXX_Unmarshal added in v1.10.0 

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

type GetShardRequest added in v1.14.0 

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

func (*GetShardRequest) Descriptor added in v1.14.0 

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

func (*GetShardRequest) Equal added in v1.14.0 

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

func (*GetShardRequest) GetShardId added in v1.14.0 

func (m *GetShardRequest) GetShardId() int32

func (*GetShardRequest) GoString added in v1.14.0 

func (this *GetShardRequest) GoString() string

func (*GetShardRequest) Marshal added in v1.14.0 

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

func (*GetShardRequest) MarshalTo added in v1.14.0 

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

func (*GetShardRequest) MarshalToSizedBuffer added in v1.14.0 

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

func (*GetShardRequest) ProtoMessage added in v1.14.0 

func (*GetShardRequest) ProtoMessage()

func (*GetShardRequest) Reset added in v1.14.0 

func (m *GetShardRequest) Reset()

func (*GetShardRequest) Size added in v1.14.0 

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

func (*GetShardRequest) String added in v1.14.0 

func (this *GetShardRequest) String() string

func (*GetShardRequest) Unmarshal added in v1.14.0 

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

func (*GetShardRequest) XXX_DiscardUnknown added in v1.14.0 

func (m *GetShardRequest) XXX_DiscardUnknown()

func (*GetShardRequest) XXX_Marshal added in v1.14.0 

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

func (*GetShardRequest) XXX_Merge added in v1.14.0 

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

func (*GetShardRequest) XXX_Size added in v1.14.0 

func (m *GetShardRequest) XXX_Size() int

func (*GetShardRequest) XXX_Unmarshal added in v1.14.0 

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

type GetShardResponse added in v1.14.0 

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

func (*GetShardResponse) Descriptor added in v1.14.0 

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

func (*GetShardResponse) Equal added in v1.14.0 

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

func (*GetShardResponse) GetShardInfo added in v1.14.0 

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

func (*GetShardResponse) GoString added in v1.14.0 

func (this *GetShardResponse) GoString() string

func (*GetShardResponse) Marshal added in v1.14.0 

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

func (*GetShardResponse) MarshalTo added in v1.14.0 

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

func (*GetShardResponse) MarshalToSizedBuffer added in v1.14.0 

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

func (*GetShardResponse) ProtoMessage added in v1.14.0 

func (*GetShardResponse) ProtoMessage()

func (*GetShardResponse) Reset added in v1.14.0 

func (m *GetShardResponse) Reset()

func (*GetShardResponse) Size added in v1.14.0 

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

func (*GetShardResponse) String added in v1.14.0 

func (this *GetShardResponse) String() string

func (*GetShardResponse) Unmarshal added in v1.14.0 

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

func (*GetShardResponse) XXX_DiscardUnknown added in v1.14.0 

func (m *GetShardResponse) XXX_DiscardUnknown()

func (*GetShardResponse) XXX_Marshal added in v1.14.0 

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

func (*GetShardResponse) XXX_Merge added in v1.14.0 

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

func (*GetShardResponse) XXX_Size added in v1.14.0 

func (m *GetShardResponse) XXX_Size() int

func (*GetShardResponse) XXX_Unmarshal added in v1.14.0 

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

type GetTaskQueueTasksRequest added in v1.14.0 

type GetTaskQueueTasksRequest struct {
	Namespace     string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueue     string            `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	TaskQueueType v16.TaskQueueType `` /* 144-byte string literal not displayed */
	MinTaskId     int64             `protobuf:"varint,4,opt,name=min_task_id,json=minTaskId,proto3" json:"min_task_id,omitempty"`
	MaxTaskId     int64             `protobuf:"varint,5,opt,name=max_task_id,json=maxTaskId,proto3" json:"max_task_id,omitempty"`
	BatchSize     int32             `protobuf:"varint,6,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	NextPageToken []byte            `protobuf:"bytes,7,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*GetTaskQueueTasksRequest) Descriptor added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) Equal added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) GetBatchSize added in v1.14.0 

func (m *GetTaskQueueTasksRequest) GetBatchSize() int32

func (*GetTaskQueueTasksRequest) GetMaxTaskId added in v1.14.0 

func (m *GetTaskQueueTasksRequest) GetMaxTaskId() int64

func (*GetTaskQueueTasksRequest) GetMinTaskId added in v1.14.0 

func (m *GetTaskQueueTasksRequest) GetMinTaskId() int64

func (*GetTaskQueueTasksRequest) GetNamespace added in v1.14.0 

func (m *GetTaskQueueTasksRequest) GetNamespace() string

func (*GetTaskQueueTasksRequest) GetNextPageToken added in v1.16.0 

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

func (*GetTaskQueueTasksRequest) GetTaskQueue added in v1.14.0 

func (m *GetTaskQueueTasksRequest) GetTaskQueue() string

func (*GetTaskQueueTasksRequest) GetTaskQueueType added in v1.14.0 

func (m *GetTaskQueueTasksRequest) GetTaskQueueType() v16.TaskQueueType

func (*GetTaskQueueTasksRequest) GoString added in v1.14.0 

func (this *GetTaskQueueTasksRequest) GoString() string

func (*GetTaskQueueTasksRequest) Marshal added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) MarshalTo added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) MarshalToSizedBuffer added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) ProtoMessage added in v1.14.0 

func (*GetTaskQueueTasksRequest) ProtoMessage()

func (*GetTaskQueueTasksRequest) Reset added in v1.14.0 

func (m *GetTaskQueueTasksRequest) Reset()

func (*GetTaskQueueTasksRequest) Size added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) String added in v1.14.0 

func (this *GetTaskQueueTasksRequest) String() string

func (*GetTaskQueueTasksRequest) Unmarshal added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) XXX_DiscardUnknown added in v1.14.0 

func (m *GetTaskQueueTasksRequest) XXX_DiscardUnknown()

func (*GetTaskQueueTasksRequest) XXX_Marshal added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) XXX_Merge added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) XXX_Size added in v1.14.0 

func (m *GetTaskQueueTasksRequest) XXX_Size() int

func (*GetTaskQueueTasksRequest) XXX_Unmarshal added in v1.14.0 

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

type GetTaskQueueTasksResponse added in v1.14.0 

type GetTaskQueueTasksResponse struct {
	Tasks         []*v11.AllocatedTaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	NextPageToken []byte                   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*GetTaskQueueTasksResponse) Descriptor added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) Equal added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) GetNextPageToken added in v1.16.0 

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

func (*GetTaskQueueTasksResponse) GetTasks added in v1.14.0 

func (m *GetTaskQueueTasksResponse) GetTasks() []*v11.AllocatedTaskInfo

func (*GetTaskQueueTasksResponse) GoString added in v1.14.0 

func (this *GetTaskQueueTasksResponse) GoString() string

func (*GetTaskQueueTasksResponse) Marshal added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) MarshalTo added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) MarshalToSizedBuffer added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) ProtoMessage added in v1.14.0 

func (*GetTaskQueueTasksResponse) ProtoMessage()

func (*GetTaskQueueTasksResponse) Reset added in v1.14.0 

func (m *GetTaskQueueTasksResponse) Reset()

func (*GetTaskQueueTasksResponse) Size added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) String added in v1.14.0 

func (this *GetTaskQueueTasksResponse) String() string

func (*GetTaskQueueTasksResponse) Unmarshal added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) XXX_DiscardUnknown added in v1.14.0 

func (m *GetTaskQueueTasksResponse) XXX_DiscardUnknown()

func (*GetTaskQueueTasksResponse) XXX_Marshal added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) XXX_Merge added in v1.14.0 

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

func (*GetTaskQueueTasksResponse) XXX_Size added in v1.14.0 

func (m *GetTaskQueueTasksResponse) XXX_Size() int

func (*GetTaskQueueTasksResponse) XXX_Unmarshal added in v1.14.0 

func (m *GetTaskQueueTasksResponse) 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 ListClusterMembersRequest added in v1.14.0 

type ListClusterMembersRequest struct {
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "within" is used to indicate a time range. --)
	LastHeartbeatWithin *time.Duration        `` /* 132-byte string literal not displayed */
	RpcAddress          string                `protobuf:"bytes,2,opt,name=rpc_address,json=rpcAddress,proto3" json:"rpc_address,omitempty"`
	HostId              string                `protobuf:"bytes,3,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	Role                v13.ClusterMemberRole `protobuf:"varint,4,opt,name=role,proto3,enum=temporal.server.api.enums.v1.ClusterMemberRole" json:"role,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "after" is used to indicate a time range. --)
	SessionStartedAfterTime *time.Time `` /* 142-byte string literal not displayed */
	PageSize                int32      `protobuf:"varint,6,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken           []byte     `protobuf:"bytes,7,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClusterMembersRequest) Descriptor added in v1.14.0 

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

func (*ListClusterMembersRequest) Equal added in v1.14.0 

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

func (*ListClusterMembersRequest) GetHostId added in v1.14.0 

func (m *ListClusterMembersRequest) GetHostId() string

func (*ListClusterMembersRequest) GetLastHeartbeatWithin added in v1.14.0 

func (m *ListClusterMembersRequest) GetLastHeartbeatWithin() *time.Duration

func (*ListClusterMembersRequest) GetNextPageToken added in v1.14.0 

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

func (*ListClusterMembersRequest) GetPageSize added in v1.14.0 

func (m *ListClusterMembersRequest) GetPageSize() int32

func (*ListClusterMembersRequest) GetRole added in v1.14.0 

func (m *ListClusterMembersRequest) GetRole() v13.ClusterMemberRole

func (*ListClusterMembersRequest) GetRpcAddress added in v1.14.0 

func (m *ListClusterMembersRequest) GetRpcAddress() string

func (*ListClusterMembersRequest) GetSessionStartedAfterTime added in v1.14.0 

func (m *ListClusterMembersRequest) GetSessionStartedAfterTime() *time.Time

func (*ListClusterMembersRequest) GoString added in v1.14.0 

func (this *ListClusterMembersRequest) GoString() string

func (*ListClusterMembersRequest) Marshal added in v1.14.0 

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

func (*ListClusterMembersRequest) MarshalTo added in v1.14.0 

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

func (*ListClusterMembersRequest) MarshalToSizedBuffer added in v1.14.0 

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

func (*ListClusterMembersRequest) ProtoMessage added in v1.14.0 

func (*ListClusterMembersRequest) ProtoMessage()

func (*ListClusterMembersRequest) Reset added in v1.14.0 

func (m *ListClusterMembersRequest) Reset()

func (*ListClusterMembersRequest) Size added in v1.14.0 

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

func (*ListClusterMembersRequest) String added in v1.14.0 

func (this *ListClusterMembersRequest) String() string

func (*ListClusterMembersRequest) Unmarshal added in v1.14.0 

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

func (*ListClusterMembersRequest) XXX_DiscardUnknown added in v1.14.0 

func (m *ListClusterMembersRequest) XXX_DiscardUnknown()

func (*ListClusterMembersRequest) XXX_Marshal added in v1.14.0 

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

func (*ListClusterMembersRequest) XXX_Merge added in v1.14.0 

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

func (*ListClusterMembersRequest) XXX_Size added in v1.14.0 

func (m *ListClusterMembersRequest) XXX_Size() int

func (*ListClusterMembersRequest) XXX_Unmarshal added in v1.14.0 

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

type ListClusterMembersResponse added in v1.14.0 

type ListClusterMembersResponse struct {
	ActiveMembers []*v18.ClusterMember `protobuf:"bytes,1,rep,name=active_members,json=activeMembers,proto3" json:"active_members,omitempty"`
	NextPageToken []byte               `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClusterMembersResponse) Descriptor added in v1.14.0 

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

func (*ListClusterMembersResponse) Equal added in v1.14.0 

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

func (*ListClusterMembersResponse) GetActiveMembers added in v1.14.0 

func (m *ListClusterMembersResponse) GetActiveMembers() []*v18.ClusterMember

func (*ListClusterMembersResponse) GetNextPageToken added in v1.14.0 

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

func (*ListClusterMembersResponse) GoString added in v1.14.0 

func (this *ListClusterMembersResponse) GoString() string

func (*ListClusterMembersResponse) Marshal added in v1.14.0 

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

func (*ListClusterMembersResponse) MarshalTo added in v1.14.0 

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

func (*ListClusterMembersResponse) MarshalToSizedBuffer added in v1.14.0 

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

func (*ListClusterMembersResponse) ProtoMessage added in v1.14.0 

func (*ListClusterMembersResponse) ProtoMessage()

func (*ListClusterMembersResponse) Reset added in v1.14.0 

func (m *ListClusterMembersResponse) Reset()

func (*ListClusterMembersResponse) Size added in v1.14.0 

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

func (*ListClusterMembersResponse) String added in v1.14.0 

func (this *ListClusterMembersResponse) String() string

func (*ListClusterMembersResponse) Unmarshal added in v1.14.0 

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

func (*ListClusterMembersResponse) XXX_DiscardUnknown added in v1.14.0 

func (m *ListClusterMembersResponse) XXX_DiscardUnknown()

func (*ListClusterMembersResponse) XXX_Marshal added in v1.14.0 

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

func (*ListClusterMembersResponse) XXX_Merge added in v1.14.0 

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

func (*ListClusterMembersResponse) XXX_Size added in v1.14.0 

func (m *ListClusterMembersResponse) XXX_Size() int

func (*ListClusterMembersResponse) XXX_Unmarshal added in v1.14.0 

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

type ListClustersRequest added in v1.15.0 

type ListClustersRequest struct {
	PageSize      int32  `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClustersRequest) Descriptor added in v1.15.0 

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

func (*ListClustersRequest) Equal added in v1.15.0 

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

func (*ListClustersRequest) GetNextPageToken added in v1.15.0 

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

func (*ListClustersRequest) GetPageSize added in v1.15.0 

func (m *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) GoString added in v1.15.0 

func (this *ListClustersRequest) GoString() string

func (*ListClustersRequest) Marshal added in v1.15.0 

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

func (*ListClustersRequest) MarshalTo added in v1.15.0 

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

func (*ListClustersRequest) MarshalToSizedBuffer added in v1.15.0 

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

func (*ListClustersRequest) ProtoMessage added in v1.15.0 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) Reset added in v1.15.0 

func (m *ListClustersRequest) Reset()

func (*ListClustersRequest) Size added in v1.15.0 

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

func (*ListClustersRequest) String added in v1.15.0 

func (this *ListClustersRequest) String() string

func (*ListClustersRequest) Unmarshal added in v1.15.0 

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

func (*ListClustersRequest) XXX_DiscardUnknown added in v1.15.0 

func (m *ListClustersRequest) XXX_DiscardUnknown()

func (*ListClustersRequest) XXX_Marshal added in v1.15.0 

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

func (*ListClustersRequest) XXX_Merge added in v1.15.0 

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

func (*ListClustersRequest) XXX_Size added in v1.15.0 

func (m *ListClustersRequest) XXX_Size() int

func (*ListClustersRequest) XXX_Unmarshal added in v1.15.0 

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

type ListClustersResponse added in v1.15.0 

type ListClustersResponse struct {
	Clusters      []*v11.ClusterMetadata `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	NextPageToken []byte                 `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClustersResponse) Descriptor added in v1.15.0 

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

func (*ListClustersResponse) Equal added in v1.15.0 

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

func (*ListClustersResponse) GetClusters added in v1.15.0 

func (m *ListClustersResponse) GetClusters() []*v11.ClusterMetadata

func (*ListClustersResponse) GetNextPageToken added in v1.15.0 

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

func (*ListClustersResponse) GoString added in v1.15.0 

func (this *ListClustersResponse) GoString() string

func (*ListClustersResponse) Marshal added in v1.15.0 

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

func (*ListClustersResponse) MarshalTo added in v1.15.0 

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

func (*ListClustersResponse) MarshalToSizedBuffer added in v1.15.0 

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

func (*ListClustersResponse) ProtoMessage added in v1.15.0 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) Reset added in v1.15.0 

func (m *ListClustersResponse) Reset()

func (*ListClustersResponse) Size added in v1.15.0 

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

func (*ListClustersResponse) String added in v1.15.0 

func (this *ListClustersResponse) String() string

func (*ListClustersResponse) Unmarshal added in v1.15.0 

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

func (*ListClustersResponse) XXX_DiscardUnknown added in v1.15.0 

func (m *ListClustersResponse) XXX_DiscardUnknown()

func (*ListClustersResponse) XXX_Marshal added in v1.15.0 

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

func (*ListClustersResponse) XXX_Merge added in v1.15.0 

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

func (*ListClustersResponse) XXX_Size added in v1.15.0 

func (m *ListClustersResponse) XXX_Size() int

func (*ListClustersResponse) XXX_Unmarshal added in v1.15.0 

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

type ListHistoryTasksRequest added in v1.16.0 

type ListHistoryTasksRequest 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"`
	TaskRange     *v14.TaskRange   `protobuf:"bytes,3,opt,name=task_range,json=taskRange,proto3" json:"task_range,omitempty"`
	BatchSize     int32            `protobuf:"varint,4,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	NextPageToken []byte           `protobuf:"bytes,5,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListHistoryTasksRequest) Descriptor added in v1.16.0 

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

func (*ListHistoryTasksRequest) Equal added in v1.16.0 

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

func (*ListHistoryTasksRequest) GetBatchSize added in v1.16.0 

func (m *ListHistoryTasksRequest) GetBatchSize() int32

func (*ListHistoryTasksRequest) GetCategory added in v1.16.0 

func (m *ListHistoryTasksRequest) GetCategory() v13.TaskCategory

func (*ListHistoryTasksRequest) GetNextPageToken added in v1.16.0 

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

func (*ListHistoryTasksRequest) GetShardId added in v1.16.0 

func (m *ListHistoryTasksRequest) GetShardId() int32

func (*ListHistoryTasksRequest) GetTaskRange added in v1.16.0 

func (m *ListHistoryTasksRequest) GetTaskRange() *v14.TaskRange

func (*ListHistoryTasksRequest) GoString added in v1.16.0 

func (this *ListHistoryTasksRequest) GoString() string

func (*ListHistoryTasksRequest) Marshal added in v1.16.0 

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

func (*ListHistoryTasksRequest) MarshalTo added in v1.16.0 

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

func (*ListHistoryTasksRequest) MarshalToSizedBuffer added in v1.16.0 

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

func (*ListHistoryTasksRequest) ProtoMessage added in v1.16.0 

func (*ListHistoryTasksRequest) ProtoMessage()

func (*ListHistoryTasksRequest) Reset added in v1.16.0 

func (m *ListHistoryTasksRequest) Reset()

func (*ListHistoryTasksRequest) Size added in v1.16.0 

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

func (*ListHistoryTasksRequest) String added in v1.16.0 

func (this *ListHistoryTasksRequest) String() string

func (*ListHistoryTasksRequest) Unmarshal added in v1.16.0 

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

func (*ListHistoryTasksRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *ListHistoryTasksRequest) XXX_DiscardUnknown()

func (*ListHistoryTasksRequest) XXX_Marshal added in v1.16.0 

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

func (*ListHistoryTasksRequest) XXX_Merge added in v1.16.0 

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

func (*ListHistoryTasksRequest) XXX_Size added in v1.16.0 

func (m *ListHistoryTasksRequest) XXX_Size() int

func (*ListHistoryTasksRequest) XXX_Unmarshal added in v1.16.0 

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

type ListHistoryTasksResponse added in v1.16.0 

type ListHistoryTasksResponse struct {
	Tasks         []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	NextPageToken []byte  `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListHistoryTasksResponse) Descriptor added in v1.16.0 

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

func (*ListHistoryTasksResponse) Equal added in v1.16.0 

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

func (*ListHistoryTasksResponse) GetNextPageToken added in v1.16.0 

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

func (*ListHistoryTasksResponse) GetTasks added in v1.16.0 

func (m *ListHistoryTasksResponse) GetTasks() []*Task

func (*ListHistoryTasksResponse) GoString added in v1.16.0 

func (this *ListHistoryTasksResponse) GoString() string

func (*ListHistoryTasksResponse) Marshal added in v1.16.0 

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

func (*ListHistoryTasksResponse) MarshalTo added in v1.16.0 

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

func (*ListHistoryTasksResponse) MarshalToSizedBuffer added in v1.16.0 

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

func (*ListHistoryTasksResponse) ProtoMessage added in v1.16.0 

func (*ListHistoryTasksResponse) ProtoMessage()

func (*ListHistoryTasksResponse) Reset added in v1.16.0 

func (m *ListHistoryTasksResponse) Reset()

func (*ListHistoryTasksResponse) Size added in v1.16.0 

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

func (*ListHistoryTasksResponse) String added in v1.16.0 

func (this *ListHistoryTasksResponse) String() string

func (*ListHistoryTasksResponse) Unmarshal added in v1.16.0 

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

func (*ListHistoryTasksResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *ListHistoryTasksResponse) XXX_DiscardUnknown()

func (*ListHistoryTasksResponse) XXX_Marshal added in v1.16.0 

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

func (*ListHistoryTasksResponse) XXX_Merge added in v1.16.0 

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

func (*ListHistoryTasksResponse) XXX_Size added in v1.16.0 

func (m *ListHistoryTasksResponse) XXX_Size() int

func (*ListHistoryTasksResponse) XXX_Unmarshal added in v1.16.0 

func (m *ListHistoryTasksResponse) 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 RebuildMutableStateRequest added in v1.16.0 

type RebuildMutableStateRequest 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 (*RebuildMutableStateRequest) Descriptor added in v1.16.0 

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

func (*RebuildMutableStateRequest) Equal added in v1.16.0 

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

func (*RebuildMutableStateRequest) GetExecution added in v1.16.0 

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

func (*RebuildMutableStateRequest) GetNamespace added in v1.16.0 

func (m *RebuildMutableStateRequest) GetNamespace() string

func (*RebuildMutableStateRequest) GoString added in v1.16.0 

func (this *RebuildMutableStateRequest) GoString() string

func (*RebuildMutableStateRequest) Marshal added in v1.16.0 

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

func (*RebuildMutableStateRequest) MarshalTo added in v1.16.0 

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

func (*RebuildMutableStateRequest) MarshalToSizedBuffer added in v1.16.0 

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

func (*RebuildMutableStateRequest) ProtoMessage added in v1.16.0 

func (*RebuildMutableStateRequest) ProtoMessage()

func (*RebuildMutableStateRequest) Reset added in v1.16.0 

func (m *RebuildMutableStateRequest) Reset()

func (*RebuildMutableStateRequest) Size added in v1.16.0 

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

func (*RebuildMutableStateRequest) String added in v1.16.0 

func (this *RebuildMutableStateRequest) String() string

func (*RebuildMutableStateRequest) Unmarshal added in v1.16.0 

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

func (*RebuildMutableStateRequest) XXX_DiscardUnknown added in v1.16.0 

func (m *RebuildMutableStateRequest) XXX_DiscardUnknown()

func (*RebuildMutableStateRequest) XXX_Marshal added in v1.16.0 

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

func (*RebuildMutableStateRequest) XXX_Merge added in v1.16.0 

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

func (*RebuildMutableStateRequest) XXX_Size added in v1.16.0 

func (m *RebuildMutableStateRequest) XXX_Size() int

func (*RebuildMutableStateRequest) XXX_Unmarshal added in v1.16.0 

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

type RebuildMutableStateResponse added in v1.16.0 

type RebuildMutableStateResponse struct {
}

func (*RebuildMutableStateResponse) Descriptor added in v1.16.0 

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

func (*RebuildMutableStateResponse) Equal added in v1.16.0 

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

func (*RebuildMutableStateResponse) GoString added in v1.16.0 

func (this *RebuildMutableStateResponse) GoString() string

func (*RebuildMutableStateResponse) Marshal added in v1.16.0 

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

func (*RebuildMutableStateResponse) MarshalTo added in v1.16.0 

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

func (*RebuildMutableStateResponse) MarshalToSizedBuffer added in v1.16.0 

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

func (*RebuildMutableStateResponse) ProtoMessage added in v1.16.0 

func (*RebuildMutableStateResponse) ProtoMessage()

func (*RebuildMutableStateResponse) Reset added in v1.16.0 

func (m *RebuildMutableStateResponse) Reset()

func (*RebuildMutableStateResponse) Size added in v1.16.0 

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

func (*RebuildMutableStateResponse) String added in v1.16.0 

func (this *RebuildMutableStateResponse) String() string

func (*RebuildMutableStateResponse) Unmarshal added in v1.16.0 

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

func (*RebuildMutableStateResponse) XXX_DiscardUnknown added in v1.16.0 

func (m *RebuildMutableStateResponse) XXX_DiscardUnknown()

func (*RebuildMutableStateResponse) XXX_Marshal added in v1.16.0 

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

func (*RebuildMutableStateResponse) XXX_Merge added in v1.16.0 

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

func (*RebuildMutableStateResponse) XXX_Size added in v1.16.0 

func (m *RebuildMutableStateResponse) XXX_Size() int

func (*RebuildMutableStateResponse) XXX_Unmarshal added in v1.16.0 

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

type 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 RemoveRemoteClusterRequest added in v1.14.0 

type RemoveRemoteClusterRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
}

func (*RemoveRemoteClusterRequest) Descriptor added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) Equal added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) GetClusterName added in v1.14.0 

func (m *RemoveRemoteClusterRequest) GetClusterName() string

func (*RemoveRemoteClusterRequest) GoString added in v1.14.0 

func (this *RemoveRemoteClusterRequest) GoString() string

func (*RemoveRemoteClusterRequest) Marshal added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) MarshalTo added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) MarshalToSizedBuffer added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) ProtoMessage added in v1.14.0 

func (*RemoveRemoteClusterRequest) ProtoMessage()

func (*RemoveRemoteClusterRequest) Reset added in v1.14.0 

func (m *RemoveRemoteClusterRequest) Reset()

func (*RemoveRemoteClusterRequest) Size added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) String added in v1.14.0 

func (this *RemoveRemoteClusterRequest) String() string

func (*RemoveRemoteClusterRequest) Unmarshal added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) XXX_DiscardUnknown added in v1.14.0 

func (m *RemoveRemoteClusterRequest) XXX_DiscardUnknown()

func (*RemoveRemoteClusterRequest) XXX_Marshal added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) XXX_Merge added in v1.14.0 

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

func (*RemoveRemoteClusterRequest) XXX_Size added in v1.14.0 

func (m *RemoveRemoteClusterRequest) XXX_Size() int

func (*RemoveRemoteClusterRequest) XXX_Unmarshal added in v1.14.0 

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

type RemoveRemoteClusterResponse added in v1.14.0 

type RemoveRemoteClusterResponse struct {
}

func (*RemoveRemoteClusterResponse) Descriptor added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) Equal added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) GoString added in v1.14.0 

func (this *RemoveRemoteClusterResponse) GoString() string

func (*RemoveRemoteClusterResponse) Marshal added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) MarshalTo added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) MarshalToSizedBuffer added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) ProtoMessage added in v1.14.0 

func (*RemoveRemoteClusterResponse) ProtoMessage()

func (*RemoveRemoteClusterResponse) Reset added in v1.14.0 

func (m *RemoveRemoteClusterResponse) Reset()

func (*RemoveRemoteClusterResponse) Size added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) String added in v1.14.0 

func (this *RemoveRemoteClusterResponse) String() string

func (*RemoveRemoteClusterResponse) Unmarshal added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) XXX_DiscardUnknown added in v1.14.0 

func (m *RemoveRemoteClusterResponse) XXX_DiscardUnknown()

func (*RemoveRemoteClusterResponse) XXX_Marshal added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) XXX_Merge added in v1.14.0 

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

func (*RemoveRemoteClusterResponse) XXX_Size added in v1.14.0 

func (m *RemoveRemoteClusterResponse) XXX_Size() int

func (*RemoveRemoteClusterResponse) XXX_Unmarshal added in v1.14.0 

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

type RemoveSearchAttributesRequest added in v1.11.0 

type RemoveSearchAttributesRequest struct {
	SearchAttributes []string `protobuf:"bytes,1,rep,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	IndexName        string   `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
}

func (*RemoveSearchAttributesRequest) Descriptor added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) Equal added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) GetIndexName added in v1.11.0 

func (m *RemoveSearchAttributesRequest) GetIndexName() string

func (*RemoveSearchAttributesRequest) GetSearchAttributes added in v1.11.0 

func (m *RemoveSearchAttributesRequest) GetSearchAttributes() []string

func (*RemoveSearchAttributesRequest) GoString added in v1.11.0 

func (this *RemoveSearchAttributesRequest) GoString() string

func (*RemoveSearchAttributesRequest) Marshal added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) MarshalTo added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) MarshalToSizedBuffer added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) ProtoMessage added in v1.11.0 

func (*RemoveSearchAttributesRequest) ProtoMessage()

func (*RemoveSearchAttributesRequest) Reset added in v1.11.0 

func (m *RemoveSearchAttributesRequest) Reset()

func (*RemoveSearchAttributesRequest) Size added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) String added in v1.11.0 

func (this *RemoveSearchAttributesRequest) String() string

func (*RemoveSearchAttributesRequest) Unmarshal added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) XXX_DiscardUnknown added in v1.11.0 

func (m *RemoveSearchAttributesRequest) XXX_DiscardUnknown()

func (*RemoveSearchAttributesRequest) XXX_Marshal added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) XXX_Merge added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) XXX_Size added in v1.11.0 

func (m *RemoveSearchAttributesRequest) XXX_Size() int

func (*RemoveSearchAttributesRequest) XXX_Unmarshal added in v1.11.0 

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

type RemoveSearchAttributesResponse added in v1.11.0 

type RemoveSearchAttributesResponse struct {
}

func (*RemoveSearchAttributesResponse) Descriptor added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) Equal added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) GoString added in v1.11.0 

func (this *RemoveSearchAttributesResponse) GoString() string

func (*RemoveSearchAttributesResponse) Marshal added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) MarshalTo added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) MarshalToSizedBuffer added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) ProtoMessage added in v1.11.0 

func (*RemoveSearchAttributesResponse) ProtoMessage()

func (*RemoveSearchAttributesResponse) Reset added in v1.11.0 

func (m *RemoveSearchAttributesResponse) Reset()

func (*RemoveSearchAttributesResponse) Size added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) String added in v1.11.0 

func (this *RemoveSearchAttributesResponse) String() string

func (*RemoveSearchAttributesResponse) Unmarshal added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) XXX_DiscardUnknown added in v1.11.0 

func (m *RemoveSearchAttributesResponse) XXX_DiscardUnknown()

func (*RemoveSearchAttributesResponse) XXX_Marshal added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) XXX_Merge added in v1.11.0 

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

func (*RemoveSearchAttributesResponse) XXX_Size added in v1.11.0 

func (m *RemoveSearchAttributesResponse) XXX_Size() int

func (*RemoveSearchAttributesResponse) XXX_Unmarshal added in v1.11.0 

func (m *RemoveSearchAttributesResponse) 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 Task added in v1.14.0 

type Task 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"`
	TaskId      int64        `protobuf:"varint,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskType    v13.TaskType `` /* 129-byte string literal not displayed */
	FireTime    *time.Time   `protobuf:"bytes,6,opt,name=fire_time,json=fireTime,proto3,stdtime" json:"fire_time,omitempty"`
	Version     int64        `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
}

func (*Task) Descriptor added in v1.14.0 

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

func (*Task) Equal added in v1.14.0 

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

func (*Task) GetFireTime added in v1.14.0 

func (m *Task) GetFireTime() *time.Time

func (*Task) GetNamespaceId added in v1.14.0 

func (m *Task) GetNamespaceId() string

func (*Task) GetRunId added in v1.14.0 

func (m *Task) GetRunId() string

func (*Task) GetTaskId added in v1.14.0 

func (m *Task) GetTaskId() int64

func (*Task) GetTaskType added in v1.14.0 

func (m *Task) GetTaskType() v13.TaskType

func (*Task) GetVersion added in v1.14.0 

func (m *Task) GetVersion() int64

func (*Task) GetWorkflowId added in v1.14.0 

func (m *Task) GetWorkflowId() string

func (*Task) GoString added in v1.14.0 

func (this *Task) GoString() string

func (*Task) Marshal added in v1.14.0 

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

func (*Task) MarshalTo added in v1.14.0 

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

func (*Task) MarshalToSizedBuffer added in v1.14.0 

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

func (*Task) ProtoMessage added in v1.14.0 

func (*Task) ProtoMessage()

func (*Task) Reset added in v1.14.0 

func (m *Task) Reset()

func (*Task) Size added in v1.14.0 

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

func (*Task) String added in v1.14.0 

func (this *Task) String() string

func (*Task) Unmarshal added in v1.14.0 

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

func (*Task) XXX_DiscardUnknown added in v1.14.0 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal added in v1.14.0 

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

func (*Task) XXX_Merge added in v1.14.0 

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

func (*Task) XXX_Size added in v1.14.0 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal added in v1.14.0 

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

type UnimplementedAdminServiceServer 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedAdminServiceServer) AddOrUpdateRemoteCluster added in v1.14.0 

func (*UnimplementedAdminServiceServer) AddOrUpdateRemoteCluster(ctx context.Context, req *AddOrUpdateRemoteClusterRequest) (*AddOrUpdateRemoteClusterResponse, error)

func (*UnimplementedAdminServiceServer) AddSearchAttributes added in v1.10.0 

func (*UnimplementedAdminServiceServer) AddSearchAttributes(ctx context.Context, req *AddSearchAttributesRequest) (*AddSearchAttributesResponse, 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) GetSearchAttributes added in v1.10.0 

func (*UnimplementedAdminServiceServer) GetSearchAttributes(ctx context.Context, req *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)

func (*UnimplementedAdminServiceServer) GetShard added in v1.14.0 

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

func (*UnimplementedAdminServiceServer) GetTaskQueueTasks added in v1.14.0 

func (*UnimplementedAdminServiceServer) GetTaskQueueTasks(ctx context.Context, req *GetTaskQueueTasksRequest) (*GetTaskQueueTasksResponse, error)

func (*UnimplementedAdminServiceServer) GetWorkflowExecutionRawHistoryV2 

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

func (*UnimplementedAdminServiceServer) ListClusterMembers added in v1.14.0 

func (*UnimplementedAdminServiceServer) ListClusterMembers(ctx context.Context, req *ListClusterMembersRequest) (*ListClusterMembersResponse, error)

func (*UnimplementedAdminServiceServer) ListClusters added in v1.15.0 

func (*UnimplementedAdminServiceServer) ListClusters(ctx context.Context, req *ListClustersRequest) (*ListClustersResponse, error)

func (*UnimplementedAdminServiceServer) ListHistoryTasks added in v1.16.0 

func (*UnimplementedAdminServiceServer) ListHistoryTasks(ctx context.Context, req *ListHistoryTasksRequest) (*ListHistoryTasksResponse, 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) RebuildMutableState added in v1.16.0 

func (*UnimplementedAdminServiceServer) RebuildMutableState(ctx context.Context, req *RebuildMutableStateRequest) (*RebuildMutableStateResponse, error)

func (*UnimplementedAdminServiceServer) RefreshWorkflowTasks 

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

func (*UnimplementedAdminServiceServer) RemoveRemoteCluster added in v1.14.0 

func (*UnimplementedAdminServiceServer) RemoveRemoteCluster(ctx context.Context, req *RemoveRemoteClusterRequest) (*RemoveRemoteClusterResponse, error)

func (*UnimplementedAdminServiceServer) RemoveSearchAttributes added in v1.11.0 

func (*UnimplementedAdminServiceServer) RemoveSearchAttributes(ctx context.Context, req *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, 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.