adminservice

package
Version: v1.17.0 Latest Latest
Warning

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

Go to latest
Published: Jun 17, 2022 License: MIT Imports: 26 Imported by: 1

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 (*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 (*AddOrUpdateRemoteClusterResponse) Size added in v1.14.0

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

func (*AddOrUpdateRemoteClusterResponse) String added in v1.14.0

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 (*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.
	// Deprecated. Use operatorservice instead.
	AddSearchAttributes(ctx context.Context, in *AddSearchAttributesRequest, opts ...grpc.CallOption) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes and returns comprehensive information about them.
	// Deprecated. Use operatorservice instead.
	RemoveSearchAttributes(ctx context.Context, in *RemoveSearchAttributesRequest, opts ...grpc.CallOption) (*RemoveSearchAttributesResponse, error)
	// GetSearchAttributes returns comprehensive information about search attributes.
	// Deprecated. Use operatorservice instead.
	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)
	// DeleteWorkflowExecution force deletes a workflow's visibility record, current & concrete execution record and history if possible
	DeleteWorkflowExecution(ctx context.Context, in *DeleteWorkflowExecutionRequest, opts ...grpc.CallOption) (*DeleteWorkflowExecutionResponse, 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.
	// Deprecated. Use operatorservice instead.
	AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes and returns comprehensive information about them.
	// Deprecated. Use operatorservice instead.
	RemoveSearchAttributes(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)
	// GetSearchAttributes returns comprehensive information about search attributes.
	// Deprecated. Use operatorservice instead.
	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)
	// DeleteWorkflowExecution force deletes a workflow's visibility record, current & concrete execution record and history if possible
	DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, 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 DeleteWorkflowExecutionRequest added in v1.17.0

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

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

func (*DeleteWorkflowExecutionRequest) Equal added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) GetExecution added in v1.17.0

func (*DeleteWorkflowExecutionRequest) GetNamespace added in v1.17.0

func (m *DeleteWorkflowExecutionRequest) GetNamespace() string

func (*DeleteWorkflowExecutionRequest) GoString added in v1.17.0

func (this *DeleteWorkflowExecutionRequest) GoString() string

func (*DeleteWorkflowExecutionRequest) Marshal added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) MarshalTo added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) MarshalToSizedBuffer added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) ProtoMessage added in v1.17.0

func (*DeleteWorkflowExecutionRequest) ProtoMessage()

func (*DeleteWorkflowExecutionRequest) Reset added in v1.17.0

func (m *DeleteWorkflowExecutionRequest) Reset()

func (*DeleteWorkflowExecutionRequest) Size added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) String added in v1.17.0

func (this *DeleteWorkflowExecutionRequest) String() string

func (*DeleteWorkflowExecutionRequest) Unmarshal added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) XXX_DiscardUnknown added in v1.17.0

func (m *DeleteWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*DeleteWorkflowExecutionRequest) XXX_Marshal added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) XXX_Merge added in v1.17.0

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

func (*DeleteWorkflowExecutionRequest) XXX_Size added in v1.17.0

func (m *DeleteWorkflowExecutionRequest) XXX_Size() int

func (*DeleteWorkflowExecutionRequest) XXX_Unmarshal added in v1.17.0

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

type DeleteWorkflowExecutionResponse added in v1.17.0

type DeleteWorkflowExecutionResponse struct {
	Warnings []string `protobuf:"bytes,1,rep,name=warnings,proto3" json:"warnings,omitempty"`
}

func (*DeleteWorkflowExecutionResponse) Descriptor added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) Equal added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) GetWarnings added in v1.17.0

func (m *DeleteWorkflowExecutionResponse) GetWarnings() []string

func (*DeleteWorkflowExecutionResponse) GoString added in v1.17.0

func (this *DeleteWorkflowExecutionResponse) GoString() string

func (*DeleteWorkflowExecutionResponse) Marshal added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) MarshalTo added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) MarshalToSizedBuffer added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) ProtoMessage added in v1.17.0

func (*DeleteWorkflowExecutionResponse) ProtoMessage()

func (*DeleteWorkflowExecutionResponse) Reset added in v1.17.0

func (*DeleteWorkflowExecutionResponse) Size added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) String added in v1.17.0

func (this *DeleteWorkflowExecutionResponse) String() string

func (*DeleteWorkflowExecutionResponse) Unmarshal added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) XXX_DiscardUnknown added in v1.17.0

func (m *DeleteWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*DeleteWorkflowExecutionResponse) XXX_Marshal added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) XXX_Merge added in v1.17.0

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

func (*DeleteWorkflowExecutionResponse) XXX_Size added in v1.17.0

func (m *DeleteWorkflowExecutionResponse) XXX_Size() int

func (*DeleteWorkflowExecutionResponse) XXX_Unmarshal added in v1.17.0

func (m *DeleteWorkflowExecutionResponse) 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 (*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 (*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 (*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 (*GetDLQReplicationMessagesRequest) GoString

func (this *GetDLQReplicationMessagesRequest) GoString() string

func (*GetDLQReplicationMessagesRequest) Marshal

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

func (*GetDLQReplicationMessagesRequest) MarshalTo

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

func (*GetDLQReplicationMessagesRequest) MarshalToSizedBuffer

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

func (*GetDLQReplicationMessagesRequest) ProtoMessage

func (*GetDLQReplicationMessagesRequest) ProtoMessage()

func (*GetDLQReplicationMessagesRequest) Reset

func (*GetDLQReplicationMessagesRequest) Size

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

func (*GetDLQReplicationMessagesRequest) String

func (*GetDLQReplicationMessagesRequest) Unmarshal

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

func (*GetDLQReplicationMessagesRequest) XXX_DiscardUnknown

func (m *GetDLQReplicationMessagesRequest) XXX_DiscardUnknown()

func (*GetDLQReplicationMessagesRequest) XXX_Marshal

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

func (*GetDLQReplicationMessagesRequest) XXX_Merge

func (*GetDLQReplicationMessagesRequest) XXX_Size

func (m *GetDLQReplicationMessagesRequest) XXX_Size() int

func (*GetDLQReplicationMessagesRequest) XXX_Unmarshal

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

type GetDLQReplicationMessagesResponse

type GetDLQReplicationMessagesResponse struct {
	ReplicationTasks []*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 (*GetDLQReplicationMessagesResponse) Size

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

func (*GetDLQReplicationMessagesResponse) String

func (*GetDLQReplicationMessagesResponse) Unmarshal

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

func (*GetDLQReplicationMessagesResponse) XXX_DiscardUnknown

func (m *GetDLQReplicationMessagesResponse) XXX_DiscardUnknown()

func (*GetDLQReplicationMessagesResponse) XXX_Marshal

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

func (*GetDLQReplicationMessagesResponse) XXX_Merge

func (*GetDLQReplicationMessagesResponse) XXX_Size

func (m *GetDLQReplicationMessagesResponse) XXX_Size() int

func (*GetDLQReplicationMessagesResponse) XXX_Unmarshal

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

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

func (*GetNamespaceReplicationMessagesRequest) Size

func (*GetNamespaceReplicationMessagesRequest) 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 (*GetNamespaceReplicationMessagesRequest) XXX_Size

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 (*GetNamespaceReplicationMessagesResponse) GoString

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

func (*GetNamespaceReplicationMessagesResponse) Size

func (*GetNamespaceReplicationMessagesResponse) 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 (*GetNamespaceReplicationMessagesResponse) XXX_Size

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 (*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 (*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 {
	// TODO (alex): remove in 1.18+ in flavor of namespace_id.
	Namespace         string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NamespaceId       string                `protobuf:"bytes,9,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,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 (*GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion

func (m *GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GetExecution

func (*GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize

func (m *GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize() int32

func (*GetWorkflowExecutionRawHistoryV2Request) GetNamespace

func (*GetWorkflowExecutionRawHistoryV2Request) GetNamespaceId added in v1.17.0

func (m *GetWorkflowExecutionRawHistoryV2Request) GetNamespaceId() 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 (*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) Reset

func (*GetWorkflowExecutionRawHistoryV2Request) Size

func (*GetWorkflowExecutionRawHistoryV2Request) 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 (*GetWorkflowExecutionRawHistoryV2Request) XXX_Size

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"`
	HistoryNodeIds []int64             `protobuf:"varint,4,rep,packed,name=history_node_ids,json=historyNodeIds,proto3" json:"history_node_ids,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) GetHistoryNodeIds added in v1.17.0

func (m *GetWorkflowExecutionRawHistoryV2Response) GetHistoryNodeIds() []int64

func (*GetWorkflowExecutionRawHistoryV2Response) GetNextPageToken

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory

func (*GetWorkflowExecutionRawHistoryV2Response) GoString

func (*GetWorkflowExecutionRawHistoryV2Response) Marshal

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

func (*GetWorkflowExecutionRawHistoryV2Response) MarshalTo