adminservice

package
v1.24.0-m112.0 Latest Latest
Warning

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

 Go to latest Published: May 6, 2024 License: MIT Imports: 24 Imported by: 2

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

View Source 
const (
	AdminService_RebuildMutableState_FullMethodName               = "/temporal.server.api.adminservice.v1.AdminService/RebuildMutableState"
	AdminService_ImportWorkflowExecution_FullMethodName           = "/temporal.server.api.adminservice.v1.AdminService/ImportWorkflowExecution"
	AdminService_DescribeMutableState_FullMethodName              = "/temporal.server.api.adminservice.v1.AdminService/DescribeMutableState"
	AdminService_DescribeHistoryHost_FullMethodName               = "/temporal.server.api.adminservice.v1.AdminService/DescribeHistoryHost"
	AdminService_GetShard_FullMethodName                          = "/temporal.server.api.adminservice.v1.AdminService/GetShard"
	AdminService_CloseShard_FullMethodName                        = "/temporal.server.api.adminservice.v1.AdminService/CloseShard"
	AdminService_ListHistoryTasks_FullMethodName                  = "/temporal.server.api.adminservice.v1.AdminService/ListHistoryTasks"
	AdminService_RemoveTask_FullMethodName                        = "/temporal.server.api.adminservice.v1.AdminService/RemoveTask"
	AdminService_GetWorkflowExecutionRawHistoryV2_FullMethodName  = "/temporal.server.api.adminservice.v1.AdminService/GetWorkflowExecutionRawHistoryV2"
	AdminService_GetWorkflowExecutionRawHistory_FullMethodName    = "/temporal.server.api.adminservice.v1.AdminService/GetWorkflowExecutionRawHistory"
	AdminService_GetReplicationMessages_FullMethodName            = "/temporal.server.api.adminservice.v1.AdminService/GetReplicationMessages"
	AdminService_GetNamespaceReplicationMessages_FullMethodName   = "/temporal.server.api.adminservice.v1.AdminService/GetNamespaceReplicationMessages"
	AdminService_GetDLQReplicationMessages_FullMethodName         = "/temporal.server.api.adminservice.v1.AdminService/GetDLQReplicationMessages"
	AdminService_ReapplyEvents_FullMethodName                     = "/temporal.server.api.adminservice.v1.AdminService/ReapplyEvents"
	AdminService_AddSearchAttributes_FullMethodName               = "/temporal.server.api.adminservice.v1.AdminService/AddSearchAttributes"
	AdminService_RemoveSearchAttributes_FullMethodName            = "/temporal.server.api.adminservice.v1.AdminService/RemoveSearchAttributes"
	AdminService_GetSearchAttributes_FullMethodName               = "/temporal.server.api.adminservice.v1.AdminService/GetSearchAttributes"
	AdminService_DescribeCluster_FullMethodName                   = "/temporal.server.api.adminservice.v1.AdminService/DescribeCluster"
	AdminService_ListClusters_FullMethodName                      = "/temporal.server.api.adminservice.v1.AdminService/ListClusters"
	AdminService_ListClusterMembers_FullMethodName                = "/temporal.server.api.adminservice.v1.AdminService/ListClusterMembers"
	AdminService_AddOrUpdateRemoteCluster_FullMethodName          = "/temporal.server.api.adminservice.v1.AdminService/AddOrUpdateRemoteCluster"
	AdminService_RemoveRemoteCluster_FullMethodName               = "/temporal.server.api.adminservice.v1.AdminService/RemoveRemoteCluster"
	AdminService_GetDLQMessages_FullMethodName                    = "/temporal.server.api.adminservice.v1.AdminService/GetDLQMessages"
	AdminService_PurgeDLQMessages_FullMethodName                  = "/temporal.server.api.adminservice.v1.AdminService/PurgeDLQMessages"
	AdminService_MergeDLQMessages_FullMethodName                  = "/temporal.server.api.adminservice.v1.AdminService/MergeDLQMessages"
	AdminService_RefreshWorkflowTasks_FullMethodName              = "/temporal.server.api.adminservice.v1.AdminService/RefreshWorkflowTasks"
	AdminService_ResendReplicationTasks_FullMethodName            = "/temporal.server.api.adminservice.v1.AdminService/ResendReplicationTasks"
	AdminService_GetTaskQueueTasks_FullMethodName                 = "/temporal.server.api.adminservice.v1.AdminService/GetTaskQueueTasks"
	AdminService_DeleteWorkflowExecution_FullMethodName           = "/temporal.server.api.adminservice.v1.AdminService/DeleteWorkflowExecution"
	AdminService_StreamWorkflowReplicationMessages_FullMethodName = "/temporal.server.api.adminservice.v1.AdminService/StreamWorkflowReplicationMessages"
	AdminService_GetNamespace_FullMethodName                      = "/temporal.server.api.adminservice.v1.AdminService/GetNamespace"
	AdminService_GetDLQTasks_FullMethodName                       = "/temporal.server.api.adminservice.v1.AdminService/GetDLQTasks"
	AdminService_PurgeDLQTasks_FullMethodName                     = "/temporal.server.api.adminservice.v1.AdminService/PurgeDLQTasks"
	AdminService_MergeDLQTasks_FullMethodName                     = "/temporal.server.api.adminservice.v1.AdminService/MergeDLQTasks"
	AdminService_DescribeDLQJob_FullMethodName                    = "/temporal.server.api.adminservice.v1.AdminService/DescribeDLQJob"
	AdminService_CancelDLQJob_FullMethodName                      = "/temporal.server.api.adminservice.v1.AdminService/CancelDLQJob"
	AdminService_AddTasks_FullMethodName                          = "/temporal.server.api.adminservice.v1.AdminService/AddTasks"
	AdminService_ListQueues_FullMethodName                        = "/temporal.server.api.adminservice.v1.AdminService/ListQueues"
)

Variables

View Source 
var AdminService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "temporal.server.api.adminservice.v1.AdminService",
	HandlerType: (*AdminServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RebuildMutableState",
			Handler:    _AdminService_RebuildMutableState_Handler,
		},
		{
			MethodName: "ImportWorkflowExecution",
			Handler:    _AdminService_ImportWorkflowExecution_Handler,
		},
		{
			MethodName: "DescribeMutableState",
			Handler:    _AdminService_DescribeMutableState_Handler,
		},
		{
			MethodName: "DescribeHistoryHost",
			Handler:    _AdminService_DescribeHistoryHost_Handler,
		},
		{
			MethodName: "GetShard",
			Handler:    _AdminService_GetShard_Handler,
		},
		{
			MethodName: "CloseShard",
			Handler:    _AdminService_CloseShard_Handler,
		},
		{
			MethodName: "ListHistoryTasks",
			Handler:    _AdminService_ListHistoryTasks_Handler,
		},
		{
			MethodName: "RemoveTask",
			Handler:    _AdminService_RemoveTask_Handler,
		},
		{
			MethodName: "GetWorkflowExecutionRawHistoryV2",
			Handler:    _AdminService_GetWorkflowExecutionRawHistoryV2_Handler,
		},
		{
			MethodName: "GetWorkflowExecutionRawHistory",
			Handler:    _AdminService_GetWorkflowExecutionRawHistory_Handler,
		},
		{
			MethodName: "GetReplicationMessages",
			Handler:    _AdminService_GetReplicationMessages_Handler,
		},
		{
			MethodName: "GetNamespaceReplicationMessages",
			Handler:    _AdminService_GetNamespaceReplicationMessages_Handler,
		},
		{
			MethodName: "GetDLQReplicationMessages",
			Handler:    _AdminService_GetDLQReplicationMessages_Handler,
		},
		{
			MethodName: "ReapplyEvents",
			Handler:    _AdminService_ReapplyEvents_Handler,
		},
		{
			MethodName: "AddSearchAttributes",
			Handler:    _AdminService_AddSearchAttributes_Handler,
		},
		{
			MethodName: "RemoveSearchAttributes",
			Handler:    _AdminService_RemoveSearchAttributes_Handler,
		},
		{
			MethodName: "GetSearchAttributes",
			Handler:    _AdminService_GetSearchAttributes_Handler,
		},
		{
			MethodName: "DescribeCluster",
			Handler:    _AdminService_DescribeCluster_Handler,
		},
		{
			MethodName: "ListClusters",
			Handler:    _AdminService_ListClusters_Handler,
		},
		{
			MethodName: "ListClusterMembers",
			Handler:    _AdminService_ListClusterMembers_Handler,
		},
		{
			MethodName: "AddOrUpdateRemoteCluster",
			Handler:    _AdminService_AddOrUpdateRemoteCluster_Handler,
		},
		{
			MethodName: "RemoveRemoteCluster",
			Handler:    _AdminService_RemoveRemoteCluster_Handler,
		},
		{
			MethodName: "GetDLQMessages",
			Handler:    _AdminService_GetDLQMessages_Handler,
		},
		{
			MethodName: "PurgeDLQMessages",
			Handler:    _AdminService_PurgeDLQMessages_Handler,
		},
		{
			MethodName: "MergeDLQMessages",
			Handler:    _AdminService_MergeDLQMessages_Handler,
		},
		{
			MethodName: "RefreshWorkflowTasks",
			Handler:    _AdminService_RefreshWorkflowTasks_Handler,
		},
		{
			MethodName: "ResendReplicationTasks",
			Handler:    _AdminService_ResendReplicationTasks_Handler,
		},
		{
			MethodName: "GetTaskQueueTasks",
			Handler:    _AdminService_GetTaskQueueTasks_Handler,
		},
		{
			MethodName: "DeleteWorkflowExecution",
			Handler:    _AdminService_DeleteWorkflowExecution_Handler,
		},
		{
			MethodName: "GetNamespace",
			Handler:    _AdminService_GetNamespace_Handler,
		},
		{
			MethodName: "GetDLQTasks",
			Handler:    _AdminService_GetDLQTasks_Handler,
		},
		{
			MethodName: "PurgeDLQTasks",
			Handler:    _AdminService_PurgeDLQTasks_Handler,
		},
		{
			MethodName: "MergeDLQTasks",
			Handler:    _AdminService_MergeDLQTasks_Handler,
		},
		{
			MethodName: "DescribeDLQJob",
			Handler:    _AdminService_DescribeDLQJob_Handler,
		},
		{
			MethodName: "CancelDLQJob",
			Handler:    _AdminService_CancelDLQJob_Handler,
		},
		{
			MethodName: "AddTasks",
			Handler:    _AdminService_AddTasks_Handler,
		},
		{
			MethodName: "ListQueues",
			Handler:    _AdminService_ListQueues_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamWorkflowReplicationMessages",
			Handler:       _AdminService_StreamWorkflowReplicationMessages_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "temporal/server/api/adminservice/v1/service.proto",
}

AdminService_ServiceDesc is the grpc.ServiceDesc for AdminService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_temporal_server_api_adminservice_v1_request_response_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_adminservice_v1_service_proto protoreflect.FileDescriptor

Functions

func RegisterAdminServiceServer 

func RegisterAdminServiceServer(s grpc.ServiceRegistrar, 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 */
	FrontendHttpAddress           string `protobuf:"bytes,3,opt,name=frontend_http_address,json=frontendHttpAddress,proto3" json:"frontend_http_address,omitempty"`
	// contains filtered or unexported fields
}

func (*AddOrUpdateRemoteClusterRequest) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use AddOrUpdateRemoteClusterRequest.ProtoReflect.Descriptor instead.

func (*AddOrUpdateRemoteClusterRequest) Equal added in v1.14.0 

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

Equal returns whether two AddOrUpdateRemoteClusterRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection added in v1.14.0 

func (x *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

func (*AddOrUpdateRemoteClusterRequest) GetFrontendAddress added in v1.14.0 

func (x *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

func (*AddOrUpdateRemoteClusterRequest) GetFrontendHttpAddress added in v1.24.0 

func (x *AddOrUpdateRemoteClusterRequest) GetFrontendHttpAddress() string

func (*AddOrUpdateRemoteClusterRequest) Marshal added in v1.14.0 

func (val *AddOrUpdateRemoteClusterRequest) Marshal() ([]byte, error)

Marshal an object of type AddOrUpdateRemoteClusterRequest to the protobuf v3 wire format

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage added in v1.14.0 

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

func (*AddOrUpdateRemoteClusterRequest) ProtoReflect added in v1.23.0 

func (x *AddOrUpdateRemoteClusterRequest) ProtoReflect() protoreflect.Message

func (*AddOrUpdateRemoteClusterRequest) Reset added in v1.14.0 

func (x *AddOrUpdateRemoteClusterRequest) Reset()

func (*AddOrUpdateRemoteClusterRequest) Size added in v1.14.0 

func (val *AddOrUpdateRemoteClusterRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddOrUpdateRemoteClusterRequest) String added in v1.14.0 

func (x *AddOrUpdateRemoteClusterRequest) String() string

func (*AddOrUpdateRemoteClusterRequest) Unmarshal added in v1.14.0 

func (val *AddOrUpdateRemoteClusterRequest) Unmarshal(buf []byte) error

Unmarshal an object of type AddOrUpdateRemoteClusterRequest from the protobuf v3 wire format

type AddOrUpdateRemoteClusterResponse added in v1.14.0 

type AddOrUpdateRemoteClusterResponse struct {
	// contains filtered or unexported fields
}

func (*AddOrUpdateRemoteClusterResponse) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use AddOrUpdateRemoteClusterResponse.ProtoReflect.Descriptor instead.

func (*AddOrUpdateRemoteClusterResponse) Equal added in v1.14.0 

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

Equal returns whether two AddOrUpdateRemoteClusterResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddOrUpdateRemoteClusterResponse) Marshal added in v1.14.0 

func (val *AddOrUpdateRemoteClusterResponse) Marshal() ([]byte, error)

Marshal an object of type AddOrUpdateRemoteClusterResponse to the protobuf v3 wire format

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage added in v1.14.0 

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

func (*AddOrUpdateRemoteClusterResponse) ProtoReflect added in v1.23.0 

func (x *AddOrUpdateRemoteClusterResponse) ProtoReflect() protoreflect.Message

func (*AddOrUpdateRemoteClusterResponse) Reset added in v1.14.0 

func (x *AddOrUpdateRemoteClusterResponse) Reset()

func (*AddOrUpdateRemoteClusterResponse) Size added in v1.14.0 

func (val *AddOrUpdateRemoteClusterResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddOrUpdateRemoteClusterResponse) String added in v1.14.0 

func (x *AddOrUpdateRemoteClusterResponse) String() string

func (*AddOrUpdateRemoteClusterResponse) Unmarshal added in v1.14.0 

func (val *AddOrUpdateRemoteClusterResponse) Unmarshal(buf []byte) error

Unmarshal an object of type AddOrUpdateRemoteClusterResponse from the protobuf v3 wire format

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"`
	Namespace        string                          `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*AddSearchAttributesRequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use AddSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*AddSearchAttributesRequest) Equal added in v1.10.0 

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

Equal returns whether two AddSearchAttributesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddSearchAttributesRequest) GetIndexName added in v1.10.0 

func (x *AddSearchAttributesRequest) GetIndexName() string

func (*AddSearchAttributesRequest) GetNamespace added in v1.20.0 

func (x *AddSearchAttributesRequest) GetNamespace() string

func (*AddSearchAttributesRequest) GetSearchAttributes added in v1.10.0 

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

func (*AddSearchAttributesRequest) GetSkipSchemaUpdate added in v1.12.0 

func (x *AddSearchAttributesRequest) GetSkipSchemaUpdate() bool

func (*AddSearchAttributesRequest) Marshal added in v1.10.0 

func (val *AddSearchAttributesRequest) Marshal() ([]byte, error)

Marshal an object of type AddSearchAttributesRequest to the protobuf v3 wire format

func (*AddSearchAttributesRequest) ProtoMessage added in v1.10.0 

func (*AddSearchAttributesRequest) ProtoMessage()

func (*AddSearchAttributesRequest) ProtoReflect added in v1.23.0 

func (x *AddSearchAttributesRequest) ProtoReflect() protoreflect.Message

func (*AddSearchAttributesRequest) Reset added in v1.10.0 

func (x *AddSearchAttributesRequest) Reset()

func (*AddSearchAttributesRequest) Size added in v1.10.0 

func (val *AddSearchAttributesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddSearchAttributesRequest) String added in v1.10.0 

func (x *AddSearchAttributesRequest) String() string

func (*AddSearchAttributesRequest) Unmarshal added in v1.10.0 

func (val *AddSearchAttributesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type AddSearchAttributesRequest from the protobuf v3 wire format

type AddSearchAttributesResponse added in v1.10.0 

type AddSearchAttributesResponse struct {
	// contains filtered or unexported fields
}

func (*AddSearchAttributesResponse) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use AddSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*AddSearchAttributesResponse) Equal added in v1.10.0 

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

Equal returns whether two AddSearchAttributesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddSearchAttributesResponse) Marshal added in v1.10.0 

func (val *AddSearchAttributesResponse) Marshal() ([]byte, error)

Marshal an object of type AddSearchAttributesResponse to the protobuf v3 wire format

func (*AddSearchAttributesResponse) ProtoMessage added in v1.10.0 

func (*AddSearchAttributesResponse) ProtoMessage()

func (*AddSearchAttributesResponse) ProtoReflect added in v1.23.0 

func (x *AddSearchAttributesResponse) ProtoReflect() protoreflect.Message

func (*AddSearchAttributesResponse) Reset added in v1.10.0 

func (x *AddSearchAttributesResponse) Reset()

func (*AddSearchAttributesResponse) Size added in v1.10.0 

func (val *AddSearchAttributesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddSearchAttributesResponse) String added in v1.10.0 

func (x *AddSearchAttributesResponse) String() string

func (*AddSearchAttributesResponse) Unmarshal added in v1.10.0 

func (val *AddSearchAttributesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type AddSearchAttributesResponse from the protobuf v3 wire format

type AddTasksRequest added in v1.23.0 

type AddTasksRequest struct {
	ShardId int32                   `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Tasks   []*AddTasksRequest_Task `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

This is a direct copy of the same proto in the history service. We can't import it, though because of a circular dependency. In addition, we can't extract a common request proto because the shard_id needs to be present in the top proto layer, so we duplicate it. It shouldn't be a big deal because this proto is not very big.

func (*AddTasksRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use AddTasksRequest.ProtoReflect.Descriptor instead.

func (*AddTasksRequest) Equal added in v1.23.0 

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

Equal returns whether two AddTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddTasksRequest) GetShardId added in v1.23.0 

func (x *AddTasksRequest) GetShardId() int32

func (*AddTasksRequest) GetTasks added in v1.23.0 

func (x *AddTasksRequest) GetTasks() []*AddTasksRequest_Task

func (*AddTasksRequest) Marshal added in v1.23.0 

func (val *AddTasksRequest) Marshal() ([]byte, error)

Marshal an object of type AddTasksRequest to the protobuf v3 wire format

func (*AddTasksRequest) ProtoMessage added in v1.23.0 

func (*AddTasksRequest) ProtoMessage()

func (*AddTasksRequest) ProtoReflect added in v1.23.0 

func (x *AddTasksRequest) ProtoReflect() protoreflect.Message

func (*AddTasksRequest) Reset added in v1.23.0 

func (x *AddTasksRequest) Reset()

func (*AddTasksRequest) Size added in v1.23.0 

func (val *AddTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddTasksRequest) String added in v1.23.0 

func (x *AddTasksRequest) String() string

func (*AddTasksRequest) Unmarshal added in v1.23.0 

func (val *AddTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type AddTasksRequest from the protobuf v3 wire format

type AddTasksRequest_Task added in v1.23.0 

type AddTasksRequest_Task struct {
	CategoryId int32        `protobuf:"varint,1,opt,name=category_id,json=categoryId,proto3" json:"category_id,omitempty"`
	Blob       *v1.DataBlob `protobuf:"bytes,2,opt,name=blob,proto3" json:"blob,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTasksRequest_Task) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use AddTasksRequest_Task.ProtoReflect.Descriptor instead.

func (*AddTasksRequest_Task) GetBlob added in v1.23.0 

func (x *AddTasksRequest_Task) GetBlob() *v1.DataBlob

func (*AddTasksRequest_Task) GetCategoryId added in v1.23.0 

func (x *AddTasksRequest_Task) GetCategoryId() int32

func (*AddTasksRequest_Task) ProtoMessage added in v1.23.0 

func (*AddTasksRequest_Task) ProtoMessage()

func (*AddTasksRequest_Task) ProtoReflect added in v1.23.0 

func (x *AddTasksRequest_Task) ProtoReflect() protoreflect.Message

func (*AddTasksRequest_Task) Reset added in v1.23.0 

func (x *AddTasksRequest_Task) Reset()

func (*AddTasksRequest_Task) String added in v1.23.0 

func (x *AddTasksRequest_Task) String() string

type AddTasksResponse added in v1.23.0 

type AddTasksResponse struct {
	// contains filtered or unexported fields
}

func (*AddTasksResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use AddTasksResponse.ProtoReflect.Descriptor instead.

func (*AddTasksResponse) Equal added in v1.23.0 

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

Equal returns whether two AddTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddTasksResponse) Marshal added in v1.23.0 

func (val *AddTasksResponse) Marshal() ([]byte, error)

Marshal an object of type AddTasksResponse to the protobuf v3 wire format

func (*AddTasksResponse) ProtoMessage added in v1.23.0 

func (*AddTasksResponse) ProtoMessage()

func (*AddTasksResponse) ProtoReflect added in v1.23.0 

func (x *AddTasksResponse) ProtoReflect() protoreflect.Message

func (*AddTasksResponse) Reset added in v1.23.0 

func (x *AddTasksResponse) Reset()

func (*AddTasksResponse) Size added in v1.23.0 

func (val *AddTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddTasksResponse) String added in v1.23.0 

func (x *AddTasksResponse) String() string

func (*AddTasksResponse) Unmarshal added in v1.23.0 

func (val *AddTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type AddTasksResponse from the protobuf v3 wire format

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)
	// ImportWorkflowExecution attempts to import workflow according to persisted history events.
	// NOTE: this is experimental API
	ImportWorkflowExecution(ctx context.Context, in *ImportWorkflowExecutionRequest, opts ...grpc.CallOption) (*ImportWorkflowExecutionResponse, 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)
	// 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 inclusive.
	GetWorkflowExecutionRawHistory(ctx context.Context, in *GetWorkflowExecutionRawHistoryRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionRawHistoryResponse, 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)
	StreamWorkflowReplicationMessages(ctx context.Context, opts ...grpc.CallOption) (AdminService_StreamWorkflowReplicationMessagesClient, error)
	GetNamespace(ctx context.Context, in *GetNamespaceRequest, opts ...grpc.CallOption) (*GetNamespaceResponse, error)
	GetDLQTasks(ctx context.Context, in *GetDLQTasksRequest, opts ...grpc.CallOption) (*GetDLQTasksResponse, error)
	// (-- api-linter: core::0165::response-message-name=disabled
	//
	//	aip.dev/not-precedent:  --)
	PurgeDLQTasks(ctx context.Context, in *PurgeDLQTasksRequest, opts ...grpc.CallOption) (*PurgeDLQTasksResponse, error)
	MergeDLQTasks(ctx context.Context, in *MergeDLQTasksRequest, opts ...grpc.CallOption) (*MergeDLQTasksResponse, error)
	DescribeDLQJob(ctx context.Context, in *DescribeDLQJobRequest, opts ...grpc.CallOption) (*DescribeDLQJobResponse, error)
	CancelDLQJob(ctx context.Context, in *CancelDLQJobRequest, opts ...grpc.CallOption) (*CancelDLQJobResponse, error)
	AddTasks(ctx context.Context, in *AddTasksRequest, opts ...grpc.CallOption) (*AddTasksResponse, error)
	ListQueues(ctx context.Context, in *ListQueuesRequest, opts ...grpc.CallOption) (*ListQueuesResponse, error)
}

AdminServiceClient is the client API for AdminService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAdminServiceClient 

func NewAdminServiceClient(cc grpc.ClientConnInterface) 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)
	// ImportWorkflowExecution attempts to import workflow according to persisted history events.
	// NOTE: this is experimental API
	ImportWorkflowExecution(context.Context, *ImportWorkflowExecutionRequest) (*ImportWorkflowExecutionResponse, 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)
	// 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 inclusive.
	GetWorkflowExecutionRawHistory(context.Context, *GetWorkflowExecutionRawHistoryRequest) (*GetWorkflowExecutionRawHistoryResponse, 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)
	StreamWorkflowReplicationMessages(AdminService_StreamWorkflowReplicationMessagesServer) error
	GetNamespace(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)
	GetDLQTasks(context.Context, *GetDLQTasksRequest) (*GetDLQTasksResponse, error)
	// (-- api-linter: core::0165::response-message-name=disabled
	//
	//	aip.dev/not-precedent:  --)
	PurgeDLQTasks(context.Context, *PurgeDLQTasksRequest) (*PurgeDLQTasksResponse, error)
	MergeDLQTasks(context.Context, *MergeDLQTasksRequest) (*MergeDLQTasksResponse, error)
	DescribeDLQJob(context.Context, *DescribeDLQJobRequest) (*DescribeDLQJobResponse, error)
	CancelDLQJob(context.Context, *CancelDLQJobRequest) (*CancelDLQJobResponse, error)
	AddTasks(context.Context, *AddTasksRequest) (*AddTasksResponse, error)
	ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)
	// contains filtered or unexported methods
}

AdminServiceServer is the server API for AdminService service. All implementations must embed UnimplementedAdminServiceServer for forward compatibility

type AdminService_StreamWorkflowReplicationMessagesClient added in v1.21.0 

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

type AdminService_StreamWorkflowReplicationMessagesServer added in v1.21.0 

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

type CancelDLQJobRequest added in v1.23.0 

type CancelDLQJobRequest struct {

	// Job token of MergeDLQTasks or PurgeDLQTasks job to cancel.
	JobToken []byte `protobuf:"bytes,1,opt,name=job_token,json=jobToken,proto3" json:"job_token,omitempty"`
	// The reason for cancellation.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelDLQJobRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use CancelDLQJobRequest.ProtoReflect.Descriptor instead.

func (*CancelDLQJobRequest) Equal added in v1.23.0 

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

Equal returns whether two CancelDLQJobRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelDLQJobRequest) GetJobToken added in v1.23.0 

func (x *CancelDLQJobRequest) GetJobToken() []byte

func (*CancelDLQJobRequest) GetReason added in v1.23.0 

func (x *CancelDLQJobRequest) GetReason() string

func (*CancelDLQJobRequest) Marshal added in v1.23.0 

func (val *CancelDLQJobRequest) Marshal() ([]byte, error)

Marshal an object of type CancelDLQJobRequest to the protobuf v3 wire format

func (*CancelDLQJobRequest) ProtoMessage added in v1.23.0 

func (*CancelDLQJobRequest) ProtoMessage()

func (*CancelDLQJobRequest) ProtoReflect added in v1.23.0 

func (x *CancelDLQJobRequest) ProtoReflect() protoreflect.Message

func (*CancelDLQJobRequest) Reset added in v1.23.0 

func (x *CancelDLQJobRequest) Reset()

func (*CancelDLQJobRequest) Size added in v1.23.0 

func (val *CancelDLQJobRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelDLQJobRequest) String added in v1.23.0 

func (x *CancelDLQJobRequest) String() string

func (*CancelDLQJobRequest) Unmarshal added in v1.23.0 

func (val *CancelDLQJobRequest) Unmarshal(buf []byte) error

Unmarshal an object of type CancelDLQJobRequest from the protobuf v3 wire format

type CancelDLQJobResponse added in v1.23.0 

type CancelDLQJobResponse struct {

	// This is true if the workflow was successfully terminated by this request and false if
	// the workflow was already completed or terminated.
	Canceled bool `protobuf:"varint,1,opt,name=canceled,proto3" json:"canceled,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelDLQJobResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use CancelDLQJobResponse.ProtoReflect.Descriptor instead.

func (*CancelDLQJobResponse) Equal added in v1.23.0 

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

Equal returns whether two CancelDLQJobResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelDLQJobResponse) GetCanceled added in v1.23.0 

func (x *CancelDLQJobResponse) GetCanceled() bool

func (*CancelDLQJobResponse) Marshal added in v1.23.0 

func (val *CancelDLQJobResponse) Marshal() ([]byte, error)

Marshal an object of type CancelDLQJobResponse to the protobuf v3 wire format

func (*CancelDLQJobResponse) ProtoMessage added in v1.23.0 

func (*CancelDLQJobResponse) ProtoMessage()

func (*CancelDLQJobResponse) ProtoReflect added in v1.23.0 

func (x *CancelDLQJobResponse) ProtoReflect() protoreflect.Message

func (*CancelDLQJobResponse) Reset added in v1.23.0 

func (x *CancelDLQJobResponse) Reset()

func (*CancelDLQJobResponse) Size added in v1.23.0 

func (val *CancelDLQJobResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelDLQJobResponse) String added in v1.23.0 

func (x *CancelDLQJobResponse) String() string

func (*CancelDLQJobResponse) Unmarshal added in v1.23.0 

func (val *CancelDLQJobResponse) Unmarshal(buf []byte) error

Unmarshal an object of type CancelDLQJobResponse from the protobuf v3 wire format

type CloseShardRequest 

type CloseShardRequest struct {
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseShardRequest) Descriptor deprecated 

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

Deprecated: Use CloseShardRequest.ProtoReflect.Descriptor instead.

func (*CloseShardRequest) Equal 

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

Equal returns whether two CloseShardRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CloseShardRequest) GetShardId 

func (x *CloseShardRequest) GetShardId() int32

func (*CloseShardRequest) Marshal 

func (val *CloseShardRequest) Marshal() ([]byte, error)

Marshal an object of type CloseShardRequest to the protobuf v3 wire format

func (*CloseShardRequest) ProtoMessage 

func (*CloseShardRequest) ProtoMessage()

func (*CloseShardRequest) ProtoReflect added in v1.23.0 

func (x *CloseShardRequest) ProtoReflect() protoreflect.Message

func (*CloseShardRequest) Reset 

func (x *CloseShardRequest) Reset()

func (*CloseShardRequest) Size 

func (val *CloseShardRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CloseShardRequest) String 

func (x *CloseShardRequest) String() string

func (*CloseShardRequest) Unmarshal 

func (val *CloseShardRequest) Unmarshal(buf []byte) error

Unmarshal an object of type CloseShardRequest from the protobuf v3 wire format

type CloseShardResponse 

type CloseShardResponse struct {
	// contains filtered or unexported fields
}

func (*CloseShardResponse) Descriptor deprecated 

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

Deprecated: Use CloseShardResponse.ProtoReflect.Descriptor instead.

func (*CloseShardResponse) Equal 

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

Equal returns whether two CloseShardResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CloseShardResponse) Marshal 

func (val *CloseShardResponse) Marshal() ([]byte, error)

Marshal an object of type CloseShardResponse to the protobuf v3 wire format

func (*CloseShardResponse) ProtoMessage 

func (*CloseShardResponse) ProtoMessage()

func (*CloseShardResponse) ProtoReflect added in v1.23.0 

func (x *CloseShardResponse) ProtoReflect() protoreflect.Message

func (*CloseShardResponse) Reset 

func (x *CloseShardResponse) Reset()

func (*CloseShardResponse) Size 

func (val *CloseShardResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CloseShardResponse) String 

func (x *CloseShardResponse) String() string

func (*CloseShardResponse) Unmarshal 

func (val *CloseShardResponse) Unmarshal(buf []byte) error

Unmarshal an object of type CloseShardResponse from the protobuf v3 wire format

type DLQJobToken added in v1.23.0 

type DLQJobToken struct {
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId      string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

DLQJobToken identifies a DLQ job. This proto is for internal use only and clients should not use it.

func (*DLQJobToken) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use DLQJobToken.ProtoReflect.Descriptor instead.

func (*DLQJobToken) Equal added in v1.23.0 

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

Equal returns whether two DLQJobToken values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DLQJobToken) GetRunId added in v1.23.0 

func (x *DLQJobToken) GetRunId() string

func (*DLQJobToken) GetWorkflowId added in v1.23.0 

func (x *DLQJobToken) GetWorkflowId() string

func (*DLQJobToken) Marshal added in v1.23.0 

func (val *DLQJobToken) Marshal() ([]byte, error)

Marshal an object of type DLQJobToken to the protobuf v3 wire format

func (*DLQJobToken) ProtoMessage added in v1.23.0 

func (*DLQJobToken) ProtoMessage()

func (*DLQJobToken) ProtoReflect added in v1.23.0 

func (x *DLQJobToken) ProtoReflect() protoreflect.Message

func (*DLQJobToken) Reset added in v1.23.0 

func (x *DLQJobToken) Reset()

func (*DLQJobToken) Size added in v1.23.0 

func (val *DLQJobToken) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DLQJobToken) String added in v1.23.0 

func (x *DLQJobToken) String() string

func (*DLQJobToken) Unmarshal added in v1.23.0 

func (val *DLQJobToken) Unmarshal(buf []byte) error

Unmarshal an object of type DLQJobToken from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*DeleteWorkflowExecutionRequest) Descriptor deprecated added in v1.17.0 

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

Deprecated: Use DeleteWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowExecutionRequest) Equal added in v1.17.0 

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

Equal returns whether two DeleteWorkflowExecutionRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeleteWorkflowExecutionRequest) GetExecution added in v1.17.0 

func (x *DeleteWorkflowExecutionRequest) GetExecution() *v1.WorkflowExecution

func (*DeleteWorkflowExecutionRequest) GetNamespace added in v1.17.0 

func (x *DeleteWorkflowExecutionRequest) GetNamespace() string

func (*DeleteWorkflowExecutionRequest) Marshal added in v1.17.0 

func (val *DeleteWorkflowExecutionRequest) Marshal() ([]byte, error)

Marshal an object of type DeleteWorkflowExecutionRequest to the protobuf v3 wire format

func (*DeleteWorkflowExecutionRequest) ProtoMessage added in v1.17.0 

func (*DeleteWorkflowExecutionRequest) ProtoMessage()

func (*DeleteWorkflowExecutionRequest) ProtoReflect added in v1.23.0 

func (x *DeleteWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*DeleteWorkflowExecutionRequest) Reset added in v1.17.0 

func (x *DeleteWorkflowExecutionRequest) Reset()

func (*DeleteWorkflowExecutionRequest) Size added in v1.17.0 

func (val *DeleteWorkflowExecutionRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeleteWorkflowExecutionRequest) String added in v1.17.0 

func (x *DeleteWorkflowExecutionRequest) String() string

func (*DeleteWorkflowExecutionRequest) Unmarshal added in v1.17.0 

func (val *DeleteWorkflowExecutionRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DeleteWorkflowExecutionRequest from the protobuf v3 wire format

type DeleteWorkflowExecutionResponse added in v1.17.0 

type DeleteWorkflowExecutionResponse struct {
	Warnings []string `protobuf:"bytes,1,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkflowExecutionResponse) Descriptor deprecated added in v1.17.0 

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

Deprecated: Use DeleteWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowExecutionResponse) Equal added in v1.17.0 

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

Equal returns whether two DeleteWorkflowExecutionResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeleteWorkflowExecutionResponse) GetWarnings added in v1.17.0 

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

func (*DeleteWorkflowExecutionResponse) Marshal added in v1.17.0 

func (val *DeleteWorkflowExecutionResponse) Marshal() ([]byte, error)

Marshal an object of type DeleteWorkflowExecutionResponse to the protobuf v3 wire format

func (*DeleteWorkflowExecutionResponse) ProtoMessage added in v1.17.0 

func (*DeleteWorkflowExecutionResponse) ProtoMessage()

func (*DeleteWorkflowExecutionResponse) ProtoReflect added in v1.23.0 

func (x *DeleteWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*DeleteWorkflowExecutionResponse) Reset added in v1.17.0 

func (x *DeleteWorkflowExecutionResponse) Reset()

func (*DeleteWorkflowExecutionResponse) Size added in v1.17.0 

func (val *DeleteWorkflowExecutionResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeleteWorkflowExecutionResponse) String added in v1.17.0 

func (x *DeleteWorkflowExecutionResponse) String() string

func (*DeleteWorkflowExecutionResponse) Unmarshal added in v1.17.0 

func (val *DeleteWorkflowExecutionResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DeleteWorkflowExecutionResponse from the protobuf v3 wire format

type DescribeClusterRequest 

type DescribeClusterRequest struct {
	ClusterName string `protobuf:"bytes,1,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeClusterRequest) Descriptor deprecated 

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

Deprecated: Use DescribeClusterRequest.ProtoReflect.Descriptor instead.

func (*DescribeClusterRequest) Equal 

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

Equal returns whether two DescribeClusterRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeClusterRequest) GetClusterName added in v1.14.0 

func (x *DescribeClusterRequest) GetClusterName() string

func (*DescribeClusterRequest) Marshal 

func (val *DescribeClusterRequest) Marshal() ([]byte, error)

Marshal an object of type DescribeClusterRequest to the protobuf v3 wire format

func (*DescribeClusterRequest) ProtoMessage 

func (*DescribeClusterRequest) ProtoMessage()

func (*DescribeClusterRequest) ProtoReflect added in v1.23.0 

func (x *DescribeClusterRequest) ProtoReflect() protoreflect.Message

func (*DescribeClusterRequest) Reset 

func (x *DescribeClusterRequest) Reset()

func (*DescribeClusterRequest) Size 

func (val *DescribeClusterRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeClusterRequest) String 

func (x *DescribeClusterRequest) String() string

func (*DescribeClusterRequest) Unmarshal 

func (val *DescribeClusterRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeClusterRequest from the protobuf v3 wire format

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 */
	Tags                     map[string]string   `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DescribeClusterResponse) Descriptor deprecated 

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

Deprecated: Use DescribeClusterResponse.ProtoReflect.Descriptor instead.

func (*DescribeClusterResponse) Equal 

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

Equal returns whether two DescribeClusterResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeClusterResponse) GetClusterId added in v1.14.0 

func (x *DescribeClusterResponse) GetClusterId() string

func (*DescribeClusterResponse) GetClusterName added in v1.14.0 

func (x *DescribeClusterResponse) GetClusterName() string

func (*DescribeClusterResponse) GetFailoverVersionIncrement added in v1.14.0 

func (x *DescribeClusterResponse) GetFailoverVersionIncrement() int64

func (*DescribeClusterResponse) GetHistoryShardCount added in v1.14.0 

func (x *DescribeClusterResponse) GetHistoryShardCount() int32

func (*DescribeClusterResponse) GetInitialFailoverVersion added in v1.14.0 

func (x *DescribeClusterResponse) GetInitialFailoverVersion() int64

func (*DescribeClusterResponse) GetIsGlobalNamespaceEnabled added in v1.14.0 

func (x *DescribeClusterResponse) GetIsGlobalNamespaceEnabled() bool

func (*DescribeClusterResponse) GetMembershipInfo 

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

func (*DescribeClusterResponse) GetPersistenceStore added in v1.14.0 

func (x *DescribeClusterResponse) GetPersistenceStore() string

func (*DescribeClusterResponse) GetServerVersion added in v1.0.0 

func (x *DescribeClusterResponse) GetServerVersion() string

func (*DescribeClusterResponse) GetSupportedClients added in v1.0.0 

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

func (*DescribeClusterResponse) GetTags added in v1.22.0 

func (x *DescribeClusterResponse) GetTags() map[string]string

func (*DescribeClusterResponse) GetVersionInfo added in v1.14.0 

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

func (*DescribeClusterResponse) GetVisibilityStore added in v1.14.0 

func (x *DescribeClusterResponse) GetVisibilityStore() string

func (*DescribeClusterResponse) Marshal 

func (val *DescribeClusterResponse) Marshal() ([]byte, error)

Marshal an object of type DescribeClusterResponse to the protobuf v3 wire format

func (*DescribeClusterResponse) ProtoMessage 

func (*DescribeClusterResponse) ProtoMessage()

func (*DescribeClusterResponse) ProtoReflect added in v1.23.0 

func (x *DescribeClusterResponse) ProtoReflect() protoreflect.Message

func (*DescribeClusterResponse) Reset 

func (x *DescribeClusterResponse) Reset()

func (*DescribeClusterResponse) Size 

func (val *DescribeClusterResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeClusterResponse) String 

func (x *DescribeClusterResponse) String() string

func (*DescribeClusterResponse) Unmarshal 

func (val *DescribeClusterResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeClusterResponse from the protobuf v3 wire format

type DescribeDLQJobRequest added in v1.23.0 

type DescribeDLQJobRequest struct {

	// Job token of MergeDLQTasks or PurgeDLQTasks job.
	JobToken []byte `protobuf:"bytes,1,opt,name=job_token,json=jobToken,proto3" json:"job_token,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeDLQJobRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use DescribeDLQJobRequest.ProtoReflect.Descriptor instead.

func (*DescribeDLQJobRequest) Equal added in v1.23.0 

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

Equal returns whether two DescribeDLQJobRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeDLQJobRequest) GetJobToken added in v1.23.0 

func (x *DescribeDLQJobRequest) GetJobToken() []byte

func (*DescribeDLQJobRequest) Marshal added in v1.23.0 

func (val *DescribeDLQJobRequest) Marshal() ([]byte, error)

Marshal an object of type DescribeDLQJobRequest to the protobuf v3 wire format

func (*DescribeDLQJobRequest) ProtoMessage added in v1.23.0 

func (*DescribeDLQJobRequest) ProtoMessage()

func (*DescribeDLQJobRequest) ProtoReflect added in v1.23.0 

func (x *DescribeDLQJobRequest) ProtoReflect() protoreflect.Message

func (*DescribeDLQJobRequest) Reset added in v1.23.0 

func (x *DescribeDLQJobRequest) Reset()

func (*DescribeDLQJobRequest) Size added in v1.23.0 

func (val *DescribeDLQJobRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeDLQJobRequest) String added in v1.23.0 

func (x *DescribeDLQJobRequest) String() string

func (*DescribeDLQJobRequest) Unmarshal added in v1.23.0 

func (val *DescribeDLQJobRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeDLQJobRequest from the protobuf v3 wire format

type DescribeDLQJobResponse added in v1.23.0 

type DescribeDLQJobResponse struct {
	DlqKey         *v112.HistoryDLQKey    `protobuf:"bytes,1,opt,name=dlq_key,json=dlqKey,proto3" json:"dlq_key,omitempty"`
	OperationType  v14.DLQOperationType   `` /* 152-byte string literal not displayed */
	OperationState v14.DLQOperationState  `` /* 156-byte string literal not displayed */
	StartTime      *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime        *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// max_message_id is the ID of the last message(inclusive) to be processed as part of this job.
	MaxMessageId int64 `protobuf:"varint,6,opt,name=max_message_id,json=maxMessageId,proto3" json:"max_message_id,omitempty"`
	// last_processed_message_id is the ID of the last message that has been processed.
	// For PurgeDLQTasks job, it the ID of the last message that was purged.
	// For MergeDLQTasks job, it is the ID of the last message that was re-enqueued and removed from the DLQ.
	LastProcessedMessageId int64 `` /* 132-byte string literal not displayed */
	// messages_processed is the total number of messages that are re-enqueued and deleted from the DLQ so far by the DLQ job.
	MessagesProcessed int64 `protobuf:"varint,8,opt,name=messages_processed,json=messagesProcessed,proto3" json:"messages_processed,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeDLQJobResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use DescribeDLQJobResponse.ProtoReflect.Descriptor instead.

func (*DescribeDLQJobResponse) Equal added in v1.23.0 

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

Equal returns whether two DescribeDLQJobResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeDLQJobResponse) GetDlqKey added in v1.23.0 

func (x *DescribeDLQJobResponse) GetDlqKey() *v112.HistoryDLQKey

func (*DescribeDLQJobResponse) GetEndTime added in v1.23.0 

func (x *DescribeDLQJobResponse) GetEndTime() *timestamppb.Timestamp

func (*DescribeDLQJobResponse) GetLastProcessedMessageId added in v1.23.0 

func (x *DescribeDLQJobResponse) GetLastProcessedMessageId() int64

func (*DescribeDLQJobResponse) GetMaxMessageId added in v1.23.0 

func (x *DescribeDLQJobResponse) GetMaxMessageId() int64

func (*DescribeDLQJobResponse) GetMessagesProcessed added in v1.23.0 

func (x *DescribeDLQJobResponse) GetMessagesProcessed() int64

func (*DescribeDLQJobResponse) GetOperationState added in v1.23.0 

func (x *DescribeDLQJobResponse) GetOperationState() v14.DLQOperationState

func (*DescribeDLQJobResponse) GetOperationType added in v1.23.0 

func (x *DescribeDLQJobResponse) GetOperationType() v14.DLQOperationType

func (*DescribeDLQJobResponse) GetStartTime added in v1.23.0 

func (x *DescribeDLQJobResponse) GetStartTime() *timestamppb.Timestamp

func (*DescribeDLQJobResponse) Marshal added in v1.23.0 

func (val *DescribeDLQJobResponse) Marshal() ([]byte, error)

Marshal an object of type DescribeDLQJobResponse to the protobuf v3 wire format

func (*DescribeDLQJobResponse) ProtoMessage added in v1.23.0 

func (*DescribeDLQJobResponse) ProtoMessage()

func (*DescribeDLQJobResponse) ProtoReflect added in v1.23.0 

func (x *DescribeDLQJobResponse) ProtoReflect() protoreflect.Message

func (*DescribeDLQJobResponse) Reset added in v1.23.0 

func (x *DescribeDLQJobResponse) Reset()

func (*DescribeDLQJobResponse) Size added in v1.23.0 

func (val *DescribeDLQJobResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeDLQJobResponse) String added in v1.23.0 

func (x *DescribeDLQJobResponse) String() string

func (*DescribeDLQJobResponse) Unmarshal added in v1.23.0 

func (val *DescribeDLQJobResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeDLQJobResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

At least one of the parameters needs to be provided.

func (*DescribeHistoryHostRequest) Descriptor deprecated 

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

Deprecated: Use DescribeHistoryHostRequest.ProtoReflect.Descriptor instead.

func (*DescribeHistoryHostRequest) Equal 

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

Equal returns whether two DescribeHistoryHostRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeHistoryHostRequest) GetHostAddress 

func (x *DescribeHistoryHostRequest) GetHostAddress() string

func (*DescribeHistoryHostRequest) GetNamespace added in v0.28.0 

func (x *DescribeHistoryHostRequest) GetNamespace() string

func (*DescribeHistoryHostRequest) GetShardId added in v0.28.0 

func (x *DescribeHistoryHostRequest) GetShardId() int32

func (*DescribeHistoryHostRequest) GetWorkflowExecution added in v0.28.0 

func (x *DescribeHistoryHostRequest) GetWorkflowExecution() *v1.WorkflowExecution

func (*DescribeHistoryHostRequest) Marshal 

func (val *DescribeHistoryHostRequest) Marshal() ([]byte, error)

Marshal an object of type DescribeHistoryHostRequest to the protobuf v3 wire format

func (*DescribeHistoryHostRequest) ProtoMessage 

func (*DescribeHistoryHostRequest) ProtoMessage()

func (*DescribeHistoryHostRequest) ProtoReflect added in v1.23.0 

func (x *DescribeHistoryHostRequest) ProtoReflect() protoreflect.Message

func (*DescribeHistoryHostRequest) Reset 

func (x *DescribeHistoryHostRequest) Reset()

func (*DescribeHistoryHostRequest) Size 

func (val *DescribeHistoryHostRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeHistoryHostRequest) String 

func (x *DescribeHistoryHostRequest) String() string

func (*DescribeHistoryHostRequest) Unmarshal 

func (val *DescribeHistoryHostRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeHistoryHostRequest from the protobuf v3 wire format

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 *v13.NamespaceCacheInfo `protobuf:"bytes,3,opt,name=namespace_cache,json=namespaceCache,proto3" json:"namespace_cache,omitempty"`
	Address        string                  `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeHistoryHostResponse) Descriptor deprecated 

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

Deprecated: Use DescribeHistoryHostResponse.ProtoReflect.Descriptor instead.

func (*DescribeHistoryHostResponse) Equal 

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

Equal returns whether two DescribeHistoryHostResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeHistoryHostResponse) GetAddress 

func (x *DescribeHistoryHostResponse) GetAddress() string

func (*DescribeHistoryHostResponse) GetNamespaceCache 

func (x *DescribeHistoryHostResponse) GetNamespaceCache() *v13.NamespaceCacheInfo

func (*DescribeHistoryHostResponse) GetShardIds 

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

func (*DescribeHistoryHostResponse) GetShardsNumber added in v0.28.0 

func (x *DescribeHistoryHostResponse) GetShardsNumber() int32

func (*DescribeHistoryHostResponse) Marshal 

func (val *DescribeHistoryHostResponse) Marshal() ([]byte, error)

Marshal an object of type DescribeHistoryHostResponse to the protobuf v3 wire format

func (*DescribeHistoryHostResponse) ProtoMessage 

func (*DescribeHistoryHostResponse) ProtoMessage()

func (*DescribeHistoryHostResponse) ProtoReflect added in v1.23.0 

func (x *DescribeHistoryHostResponse) ProtoReflect() protoreflect.Message

func (*DescribeHistoryHostResponse) Reset 

func (x *DescribeHistoryHostResponse) Reset()

func (*DescribeHistoryHostResponse) Size 

func (val *DescribeHistoryHostResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeHistoryHostResponse) String 

func (x *DescribeHistoryHostResponse) String() string

func (*DescribeHistoryHostResponse) Unmarshal 

func (val *DescribeHistoryHostResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeHistoryHostResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*DescribeMutableStateRequest) Descriptor deprecated added in v1.3.0 

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

Deprecated: Use DescribeMutableStateRequest.ProtoReflect.Descriptor instead.

func (*DescribeMutableStateRequest) Equal added in v1.3.0 

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

Equal returns whether two DescribeMutableStateRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeMutableStateRequest) GetExecution added in v1.3.0 

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

func (*DescribeMutableStateRequest) GetNamespace added in v1.3.0 

func (x *DescribeMutableStateRequest) GetNamespace() string

func (*DescribeMutableStateRequest) Marshal added in v1.3.0 

func (val *DescribeMutableStateRequest) Marshal() ([]byte, error)

Marshal an object of type DescribeMutableStateRequest to the protobuf v3 wire format

func (*DescribeMutableStateRequest) ProtoMessage added in v1.3.0 

func (*DescribeMutableStateRequest) ProtoMessage()

func (*DescribeMutableStateRequest) ProtoReflect added in v1.23.0 

func (x *DescribeMutableStateRequest) ProtoReflect() protoreflect.Message

func (*DescribeMutableStateRequest) Reset added in v1.3.0 

func (x *DescribeMutableStateRequest) Reset()

func (*DescribeMutableStateRequest) Size added in v1.3.0 

func (val *DescribeMutableStateRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeMutableStateRequest) String added in v1.3.0 

func (x *DescribeMutableStateRequest) String() string

func (*DescribeMutableStateRequest) Unmarshal added in v1.3.0 

func (val *DescribeMutableStateRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeMutableStateRequest from the protobuf v3 wire format

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    *v12.WorkflowMutableState `protobuf:"bytes,3,opt,name=cache_mutable_state,json=cacheMutableState,proto3" json:"cache_mutable_state,omitempty"`
	DatabaseMutableState *v12.WorkflowMutableState `protobuf:"bytes,4,opt,name=database_mutable_state,json=databaseMutableState,proto3" json:"database_mutable_state,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeMutableStateResponse) Descriptor deprecated added in v1.3.0 

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

Deprecated: Use DescribeMutableStateResponse.ProtoReflect.Descriptor instead.

func (*DescribeMutableStateResponse) Equal added in v1.3.0 

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

Equal returns whether two DescribeMutableStateResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeMutableStateResponse) GetCacheMutableState added in v1.3.0 

func (x *DescribeMutableStateResponse) GetCacheMutableState() *v12.WorkflowMutableState

func (*DescribeMutableStateResponse) GetDatabaseMutableState added in v1.3.0 

func (x *DescribeMutableStateResponse) GetDatabaseMutableState() *v12.WorkflowMutableState

func (*DescribeMutableStateResponse) GetHistoryAddr added in v1.3.0 

func (x *DescribeMutableStateResponse) GetHistoryAddr() string

func (*DescribeMutableStateResponse) GetShardId added in v1.3.0 

func (x *DescribeMutableStateResponse) GetShardId() string

func (*DescribeMutableStateResponse) Marshal added in v1.3.0 

func (val *DescribeMutableStateResponse) Marshal() ([]byte, error)

Marshal an object of type DescribeMutableStateResponse to the protobuf v3 wire format

func (*DescribeMutableStateResponse) ProtoMessage added in v1.3.0 

func (*DescribeMutableStateResponse) ProtoMessage()

func (*DescribeMutableStateResponse) ProtoReflect added in v1.23.0 

func (x *DescribeMutableStateResponse) ProtoReflect() protoreflect.Message

func (*DescribeMutableStateResponse) Reset added in v1.3.0 

func (x *DescribeMutableStateResponse) Reset()

func (*DescribeMutableStateResponse) Size added in v1.3.0 

func (val *DescribeMutableStateResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeMutableStateResponse) String added in v1.3.0 

func (x *DescribeMutableStateResponse) String() string

func (*DescribeMutableStateResponse) Unmarshal added in v1.3.0 

func (val *DescribeMutableStateResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeMutableStateResponse from the protobuf v3 wire format

type GetDLQMessagesRequest 

type GetDLQMessagesRequest struct {
	Type                  v14.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"`
	// contains filtered or unexported fields
}

func (*GetDLQMessagesRequest) Descriptor deprecated 

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

Deprecated: Use GetDLQMessagesRequest.ProtoReflect.Descriptor instead.

func (*GetDLQMessagesRequest) Equal 

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

Equal returns whether two GetDLQMessagesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetDLQMessagesRequest) GetInclusiveEndMessageId 

func (x *GetDLQMessagesRequest) GetInclusiveEndMessageId() int64

func (*GetDLQMessagesRequest) GetMaximumPageSize 

func (x *GetDLQMessagesRequest) GetMaximumPageSize() int32

func (*GetDLQMessagesRequest) GetNextPageToken 

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

func (*GetDLQMessagesRequest) GetShardId 

func (x *GetDLQMessagesRequest) GetShardId() int32

func (*GetDLQMessagesRequest) GetSourceCluster 

func (x *GetDLQMessagesRequest) GetSourceCluster() string

func (*GetDLQMessagesRequest) GetType 

func (x *GetDLQMessagesRequest) GetType() v14.DeadLetterQueueType

func (*GetDLQMessagesRequest) Marshal 

func (val *GetDLQMessagesRequest) Marshal() ([]byte, error)

Marshal an object of type GetDLQMessagesRequest to the protobuf v3 wire format

func (*GetDLQMessagesRequest) ProtoMessage 

func (*GetDLQMessagesRequest) ProtoMessage()

func (*GetDLQMessagesRequest) ProtoReflect added in v1.23.0 

func (x *GetDLQMessagesRequest) ProtoReflect() protoreflect.Message

func (*GetDLQMessagesRequest) Reset 

func (x *GetDLQMessagesRequest) Reset()

func (*GetDLQMessagesRequest) Size 

func (val *GetDLQMessagesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetDLQMessagesRequest) String 

func (x *GetDLQMessagesRequest) String() string

func (*GetDLQMessagesRequest) Unmarshal 

func (val *GetDLQMessagesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetDLQMessagesRequest from the protobuf v3 wire format

type GetDLQMessagesResponse 

type GetDLQMessagesResponse struct {
	Type                 v14.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"`
	ReplicationTasksInfo []*v15.ReplicationTaskInfo `protobuf:"bytes,4,rep,name=replication_tasks_info,json=replicationTasksInfo,proto3" json:"replication_tasks_info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDLQMessagesResponse) Descriptor deprecated 

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

Deprecated: Use GetDLQMessagesResponse.ProtoReflect.Descriptor instead.

func (*GetDLQMessagesResponse) Equal 

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

Equal returns whether two GetDLQMessagesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetDLQMessagesResponse) GetNextPageToken 

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

func (*GetDLQMessagesResponse) GetReplicationTasks 

func (x *GetDLQMessagesResponse) GetReplicationTasks() []*v15.ReplicationTask

func (*GetDLQMessagesResponse) GetReplicationTasksInfo added in v1.21.0 

func (x *GetDLQMessagesResponse) GetReplicationTasksInfo() []*v15.ReplicationTaskInfo

func (*GetDLQMessagesResponse) GetType 

func (x *GetDLQMessagesResponse) GetType() v14.DeadLetterQueueType

func (*GetDLQMessagesResponse) Marshal 

func (val *GetDLQMessagesResponse) Marshal() ([]byte, error)

Marshal an object of type GetDLQMessagesResponse to the protobuf v3 wire format

func (*GetDLQMessagesResponse) ProtoMessage 

func (*GetDLQMessagesResponse) ProtoMessage()

func (*GetDLQMessagesResponse) ProtoReflect added in v1.23.0 

func (x *GetDLQMessagesResponse) ProtoReflect() protoreflect.Message

func (*GetDLQMessagesResponse) Reset 

func (x *GetDLQMessagesResponse) Reset()

func (*GetDLQMessagesResponse) Size 

func (val *GetDLQMessagesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetDLQMessagesResponse) String 

func (x *GetDLQMessagesResponse) String() string

func (*GetDLQMessagesResponse) Unmarshal 

func (val *GetDLQMessagesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetDLQMessagesResponse from the protobuf v3 wire format

type GetDLQReplicationMessagesRequest 

type GetDLQReplicationMessagesRequest struct {
	TaskInfos []*v15.ReplicationTaskInfo `protobuf:"bytes,1,rep,name=task_infos,json=taskInfos,proto3" json:"task_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDLQReplicationMessagesRequest) Descriptor deprecated 

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

Deprecated: Use GetDLQReplicationMessagesRequest.ProtoReflect.Descriptor instead.

func (*GetDLQReplicationMessagesRequest) Equal 

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

Equal returns whether two GetDLQReplicationMessagesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetDLQReplicationMessagesRequest) GetTaskInfos 

func (x *GetDLQReplicationMessagesRequest) GetTaskInfos() []*v15.ReplicationTaskInfo

func (*GetDLQReplicationMessagesRequest) Marshal 

func (val *GetDLQReplicationMessagesRequest) Marshal() ([]byte, error)

Marshal an object of type GetDLQReplicationMessagesRequest to the protobuf v3 wire format

func (*GetDLQReplicationMessagesRequest) ProtoMessage 

func (*GetDLQReplicationMessagesRequest) ProtoMessage()

func (*GetDLQReplicationMessagesRequest) ProtoReflect added in v1.23.0 

func (x *GetDLQReplicationMessagesRequest) ProtoReflect() protoreflect.Message

func (*GetDLQReplicationMessagesRequest) Reset 

func (x *GetDLQReplicationMessagesRequest) Reset()

func (*GetDLQReplicationMessagesRequest) Size 

func (val *GetDLQReplicationMessagesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetDLQReplicationMessagesRequest) String 

func (x *GetDLQReplicationMessagesRequest) String() string

func (*GetDLQReplicationMessagesRequest) Unmarshal 

func (val *GetDLQReplicationMessagesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetDLQReplicationMessagesRequest from the protobuf v3 wire format

type GetDLQReplicationMessagesResponse 

type GetDLQReplicationMessagesResponse struct {
	ReplicationTasks []*v15.ReplicationTask `protobuf:"bytes,1,rep,name=replication_tasks,json=replicationTasks,proto3" json:"replication_tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDLQReplicationMessagesResponse) Descriptor deprecated 

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

Deprecated: Use GetDLQReplicationMessagesResponse.ProtoReflect.Descriptor instead.

func (*GetDLQReplicationMessagesResponse) Equal 

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

Equal returns whether two GetDLQReplicationMessagesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetDLQReplicationMessagesResponse) GetReplicationTasks 

func (x *GetDLQReplicationMessagesResponse) GetReplicationTasks() []*v15.ReplicationTask

func (*GetDLQReplicationMessagesResponse) Marshal 

func (val *GetDLQReplicationMessagesResponse) Marshal() ([]byte, error)

Marshal an object of type GetDLQReplicationMessagesResponse to the protobuf v3 wire format

func (*GetDLQReplicationMessagesResponse) ProtoMessage 

func (*GetDLQReplicationMessagesResponse) ProtoMessage()

func (*GetDLQReplicationMessagesResponse) ProtoReflect added in v1.23.0 

func (x *GetDLQReplicationMessagesResponse) ProtoReflect() protoreflect.Message

func (*GetDLQReplicationMessagesResponse) Reset 

func (x *GetDLQReplicationMessagesResponse) Reset()

func (*GetDLQReplicationMessagesResponse) Size 

func (val *GetDLQReplicationMessagesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetDLQReplicationMessagesResponse) String 

func (x *GetDLQReplicationMessagesResponse) String() string

func (*GetDLQReplicationMessagesResponse) Unmarshal 

func (val *GetDLQReplicationMessagesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetDLQReplicationMessagesResponse from the protobuf v3 wire format

type GetDLQTasksRequest added in v1.23.0 

type GetDLQTasksRequest struct {
	DlqKey *v112.HistoryDLQKey `protobuf:"bytes,1,opt,name=dlq_key,json=dlqKey,proto3" json:"dlq_key,omitempty"`
	// page_size must be positive. Up to this many tasks will be returned.
	PageSize      int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDLQTasksRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use GetDLQTasksRequest.ProtoReflect.Descriptor instead.

func (*GetDLQTasksRequest) Equal added in v1.23.0 

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

Equal returns whether two GetDLQTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetDLQTasksRequest) GetDlqKey added in v1.23.0 

func (x *GetDLQTasksRequest) GetDlqKey() *v112.HistoryDLQKey

func (*GetDLQTasksRequest) GetNextPageToken added in v1.23.0 

func (x *GetDLQTasksRequest) GetNextPageToken() []byte

func (*GetDLQTasksRequest) GetPageSize added in v1.23.0 

func (x *GetDLQTasksRequest) GetPageSize() int32

func (*GetDLQTasksRequest) Marshal added in v1.23.0 

func (val *GetDLQTasksRequest) Marshal() ([]byte, error)

Marshal an object of type GetDLQTasksRequest to the protobuf v3 wire format

func (*GetDLQTasksRequest) ProtoMessage added in v1.23.0 

func (*GetDLQTasksRequest) ProtoMessage()

func (*GetDLQTasksRequest) ProtoReflect added in v1.23.0 

func (x *GetDLQTasksRequest) ProtoReflect() protoreflect.Message

func (*GetDLQTasksRequest) Reset added in v1.23.0 

func (x *GetDLQTasksRequest) Reset()

func (*GetDLQTasksRequest) Size added in v1.23.0 

func (val *GetDLQTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetDLQTasksRequest) String added in v1.23.0 

func (x *GetDLQTasksRequest) String() string

func (*GetDLQTasksRequest) Unmarshal added in v1.23.0 

func (val *GetDLQTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetDLQTasksRequest from the protobuf v3 wire format

type GetDLQTasksResponse added in v1.23.0 

type GetDLQTasksResponse struct {
	DlqTasks []*v112.HistoryDLQTask `protobuf:"bytes,1,rep,name=dlq_tasks,json=dlqTasks,proto3" json:"dlq_tasks,omitempty"`
	// next_page_token is empty if there are no more results. However, the converse is not true. If there are no more
	// results, this field may still be non-empty. This is to avoid having to do a count query to determine whether
	// there are more results.
	NextPageToken []byte `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDLQTasksResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use GetDLQTasksResponse.ProtoReflect.Descriptor instead.

func (*GetDLQTasksResponse) Equal added in v1.23.0 

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

Equal returns whether two GetDLQTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetDLQTasksResponse) GetDlqTasks added in v1.23.0 

func (x *GetDLQTasksResponse) GetDlqTasks() []*v112.HistoryDLQTask

func (*GetDLQTasksResponse) GetNextPageToken added in v1.23.0 

func (x *GetDLQTasksResponse) GetNextPageToken() []byte

func (*GetDLQTasksResponse) Marshal added in v1.23.0 

func (val *GetDLQTasksResponse) Marshal() ([]byte, error)

Marshal an object of type GetDLQTasksResponse to the protobuf v3 wire format

func (*GetDLQTasksResponse) ProtoMessage added in v1.23.0 

func (*GetDLQTasksResponse) ProtoMessage()

func (*GetDLQTasksResponse) ProtoReflect added in v1.23.0 

func (x *GetDLQTasksResponse) ProtoReflect() protoreflect.Message

func (*GetDLQTasksResponse) Reset added in v1.23.0 

func (x *GetDLQTasksResponse) Reset()

func (*GetDLQTasksResponse) Size added in v1.23.0 

func (val *GetDLQTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetDLQTasksResponse) String added in v1.23.0 

func (x *GetDLQTasksResponse) String() string

func (*GetDLQTasksResponse) Unmarshal added in v1.23.0 

func (val *GetDLQTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetDLQTasksResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*GetNamespaceReplicationMessagesRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespaceReplicationMessagesRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceReplicationMessagesRequest) Equal 

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

Equal returns whether two GetNamespaceReplicationMessagesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetNamespaceReplicationMessagesRequest) GetClusterName 

func (x *GetNamespaceReplicationMessagesRequest) GetClusterName() string

func (*GetNamespaceReplicationMessagesRequest) GetLastProcessedMessageId 

func (x *GetNamespaceReplicationMessagesRequest) GetLastProcessedMessageId() int64

func (*GetNamespaceReplicationMessagesRequest) GetLastRetrievedMessageId 

func (x *GetNamespaceReplicationMessagesRequest) GetLastRetrievedMessageId() int64

func (*GetNamespaceReplicationMessagesRequest) Marshal 

func (val *GetNamespaceReplicationMessagesRequest) Marshal() ([]byte, error)

Marshal an object of type GetNamespaceReplicationMessagesRequest to the protobuf v3 wire format

func (*GetNamespaceReplicationMessagesRequest) ProtoMessage 

func (*GetNamespaceReplicationMessagesRequest) ProtoMessage()

func (*GetNamespaceReplicationMessagesRequest) ProtoReflect added in v1.23.0 

func (x *GetNamespaceReplicationMessagesRequest) ProtoReflect() protoreflect.Message

func (*GetNamespaceReplicationMessagesRequest) Reset 

func (x *GetNamespaceReplicationMessagesRequest) Reset()

func (*GetNamespaceReplicationMessagesRequest) Size 

func (val *GetNamespaceReplicationMessagesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetNamespaceReplicationMessagesRequest) String 

func (x *GetNamespaceReplicationMessagesRequest) String() string

func (*GetNamespaceReplicationMessagesRequest) Unmarshal 

func (val *GetNamespaceReplicationMessagesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetNamespaceReplicationMessagesRequest from the protobuf v3 wire format

type GetNamespaceReplicationMessagesResponse 

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

func (*GetNamespaceReplicationMessagesResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespaceReplicationMessagesResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceReplicationMessagesResponse) Equal 

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

Equal returns whether two GetNamespaceReplicationMessagesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetNamespaceReplicationMessagesResponse) GetMessages 

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

func (*GetNamespaceReplicationMessagesResponse) Marshal 

func (val *GetNamespaceReplicationMessagesResponse) Marshal() ([]byte, error)

Marshal an object of type GetNamespaceReplicationMessagesResponse to the protobuf v3 wire format

func (*GetNamespaceReplicationMessagesResponse) ProtoMessage 

func (*GetNamespaceReplicationMessagesResponse) ProtoMessage()

func (*GetNamespaceReplicationMessagesResponse) ProtoReflect added in v1.23.0 

func (x *GetNamespaceReplicationMessagesResponse) ProtoReflect() protoreflect.Message

func (*GetNamespaceReplicationMessagesResponse) Reset 

func (x *GetNamespaceReplicationMessagesResponse) Reset()

func (*GetNamespaceReplicationMessagesResponse) Size 

func (val *GetNamespaceReplicationMessagesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetNamespaceReplicationMessagesResponse) String 

func (x *GetNamespaceReplicationMessagesResponse) String() string

func (*GetNamespaceReplicationMessagesResponse) Unmarshal 

func (val *GetNamespaceReplicationMessagesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetNamespaceReplicationMessagesResponse from the protobuf v3 wire format

type GetNamespaceRequest added in v1.22.0 

type GetNamespaceRequest struct {

	// Types that are assignable to Attributes:
	//
	//	*GetNamespaceRequest_Namespace
	//	*GetNamespaceRequest_Id
	Attributes isGetNamespaceRequest_Attributes `protobuf_oneof:"attributes"`
	// contains filtered or unexported fields
}

func (*GetNamespaceRequest) Descriptor deprecated added in v1.22.0 

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

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) Equal added in v1.22.0 

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

Equal returns whether two GetNamespaceRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetNamespaceRequest) GetAttributes added in v1.22.0 

func (m *GetNamespaceRequest) GetAttributes() isGetNamespaceRequest_Attributes

func (*GetNamespaceRequest) GetId added in v1.22.0 

func (x *GetNamespaceRequest) GetId() string

func (*GetNamespaceRequest) GetNamespace added in v1.22.0 

func (x *GetNamespaceRequest) GetNamespace() string

func (*GetNamespaceRequest) Marshal added in v1.22.0 

func (val *GetNamespaceRequest) Marshal() ([]byte, error)

Marshal an object of type GetNamespaceRequest to the protobuf v3 wire format

func (*GetNamespaceRequest) ProtoMessage added in v1.22.0 

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect added in v1.23.0 

func (x *GetNamespaceRequest) ProtoReflect() protoreflect.Message

func (*GetNamespaceRequest) Reset added in v1.22.0 

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) Size added in v1.22.0 

func (val *GetNamespaceRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetNamespaceRequest) String added in v1.22.0 

func (x *GetNamespaceRequest) String() string

func (*GetNamespaceRequest) Unmarshal added in v1.22.0 

func (val *GetNamespaceRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetNamespaceRequest from the protobuf v3 wire format

type GetNamespaceRequest_Id added in v1.22.0 

type GetNamespaceRequest_Id struct {
	Id string `protobuf:"bytes,2,opt,name=id,proto3,oneof"`
}

type GetNamespaceRequest_Namespace added in v1.22.0 

type GetNamespaceRequest_Namespace struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof"`
}

type GetNamespaceResponse added in v1.22.0 

type GetNamespaceResponse struct {
	Info              *v110.NamespaceInfo              `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Config            *v110.NamespaceConfig            `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig *v111.NamespaceReplicationConfig `protobuf:"bytes,5,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
	ConfigVersion     int64                            `protobuf:"varint,6,opt,name=config_version,json=configVersion,proto3" json:"config_version,omitempty"`
	FailoverVersion   int64                            `protobuf:"varint,7,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	FailoverHistory   []*v111.FailoverStatus           `protobuf:"bytes,8,rep,name=failover_history,json=failoverHistory,proto3" json:"failover_history,omitempty"`
	IsGlobalNamespace bool                             `protobuf:"varint,9,opt,name=is_global_namespace,json=isGlobalNamespace,proto3" json:"is_global_namespace,omitempty"`
	// The list of registered Nexus outgoing services that are used by this namespace sorted in ascending order by service
	// name.
	OutgoingServices []*v12.NexusOutgoingService `protobuf:"bytes,10,rep,name=outgoing_services,json=outgoingServices,proto3" json:"outgoing_services,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNamespaceResponse) Descriptor deprecated added in v1.22.0 

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

Deprecated: Use GetNamespaceResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceResponse) Equal added in v1.22.0 

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

Equal returns whether two GetNamespaceResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetNamespaceResponse) GetConfig added in v1.22.0 

func (x *GetNamespaceResponse) GetConfig() *v110.NamespaceConfig

func (*GetNamespaceResponse) GetConfigVersion added in v1.22.0 

func (x *GetNamespaceResponse) GetConfigVersion() int64

func (*GetNamespaceResponse) GetFailoverHistory added in v1.22.0 

func (x *GetNamespaceResponse) GetFailoverHistory() []*v111.FailoverStatus

func (*GetNamespaceResponse) GetFailoverVersion added in v1.22.0 

func (x *GetNamespaceResponse) GetFailoverVersion() int64

func (*GetNamespaceResponse) GetInfo added in v1.22.0 

func (x *GetNamespaceResponse) GetInfo() *v110.NamespaceInfo

func (*GetNamespaceResponse) GetIsGlobalNamespace added in v1.23.0 

func (x *GetNamespaceResponse) GetIsGlobalNamespace() bool

func (*GetNamespaceResponse) GetOutgoingServices added in v1.24.0 

func (x *GetNamespaceResponse) GetOutgoingServices() []*v12.NexusOutgoingService

func (*GetNamespaceResponse) GetReplicationConfig added in v1.22.0 

func (x *GetNamespaceResponse) GetReplicationConfig() *v111.NamespaceReplicationConfig

func (*GetNamespaceResponse) Marshal added in v1.22.0 

func (val *GetNamespaceResponse) Marshal() ([]byte, error)

Marshal an object of type GetNamespaceResponse to the protobuf v3 wire format

func (*GetNamespaceResponse) ProtoMessage added in v1.22.0 

func (*GetNamespaceResponse) ProtoMessage()

func (*GetNamespaceResponse) ProtoReflect added in v1.23.0 

func (x *GetNamespaceResponse) ProtoReflect() protoreflect.Message

func (*GetNamespaceResponse) Reset added in v1.22.0 

func (x *GetNamespaceResponse) Reset()

func (*GetNamespaceResponse) Size added in v1.22.0 

func (val *GetNamespaceResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetNamespaceResponse) String added in v1.22.0 

func (x *GetNamespaceResponse) String() string

func (*GetNamespaceResponse) Unmarshal added in v1.22.0 

func (val *GetNamespaceResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetNamespaceResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*GetReplicationMessagesRequest) Descriptor deprecated 

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

Deprecated: Use GetReplicationMessagesRequest.ProtoReflect.Descriptor instead.

func (*GetReplicationMessagesRequest) Equal 

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

Equal returns whether two GetReplicationMessagesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetReplicationMessagesRequest) GetClusterName 

func (x *GetReplicationMessagesRequest) GetClusterName() string

func (*GetReplicationMessagesRequest) GetTokens 

func (x *GetReplicationMessagesRequest) GetTokens() []*v15.ReplicationToken

func (*GetReplicationMessagesRequest) Marshal 

func (val *GetReplicationMessagesRequest) Marshal() ([]byte, error)

Marshal an object of type GetReplicationMessagesRequest to the protobuf v3 wire format

func (*GetReplicationMessagesRequest) ProtoMessage 

func (*GetReplicationMessagesRequest) ProtoMessage()

func (*GetReplicationMessagesRequest) ProtoReflect added in v1.23.0 

func (x *GetReplicationMessagesRequest) ProtoReflect() protoreflect.Message

func (*GetReplicationMessagesRequest) Reset 

func (x *GetReplicationMessagesRequest) Reset()

func (*GetReplicationMessagesRequest) Size 

func (val *GetReplicationMessagesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetReplicationMessagesRequest) String 

func (x *GetReplicationMessagesRequest) String() string

func (*GetReplicationMessagesRequest) Unmarshal 

func (val *GetReplicationMessagesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetReplicationMessagesRequest from the protobuf v3 wire format

type GetReplicationMessagesResponse 

type GetReplicationMessagesResponse struct {
	ShardMessages map[int32]*v15.ReplicationMessages `` /* 189-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetReplicationMessagesResponse) Descriptor deprecated 

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

Deprecated: Use GetReplicationMessagesResponse.ProtoReflect.Descriptor instead.

func (*GetReplicationMessagesResponse) Equal 

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

Equal returns whether two GetReplicationMessagesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetReplicationMessagesResponse) GetShardMessages added in v0.28.0 

func (x *GetReplicationMessagesResponse) GetShardMessages() map[int32]*v15.ReplicationMessages

func (*GetReplicationMessagesResponse) Marshal 

func (val *GetReplicationMessagesResponse) Marshal() ([]byte, error)

Marshal an object of type GetReplicationMessagesResponse to the protobuf v3 wire format

func (*GetReplicationMessagesResponse) ProtoMessage 

func (*GetReplicationMessagesResponse) ProtoMessage()

func (*GetReplicationMessagesResponse) ProtoReflect added in v1.23.0 

func (x *GetReplicationMessagesResponse) ProtoReflect() protoreflect.Message

func (*GetReplicationMessagesResponse) Reset 

func (x *GetReplicationMessagesResponse) Reset()

func (*GetReplicationMessagesResponse) Size 

func (val *GetReplicationMessagesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetReplicationMessagesResponse) String 

func (x *GetReplicationMessagesResponse) String() string

func (*GetReplicationMessagesResponse) Unmarshal 

func (val *GetReplicationMessagesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetReplicationMessagesResponse from the protobuf v3 wire format

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"`
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSearchAttributesRequest) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use GetSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*GetSearchAttributesRequest) Equal added in v1.10.0 

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

Equal returns whether two GetSearchAttributesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetSearchAttributesRequest) GetIndexName added in v1.10.0 

func (x *GetSearchAttributesRequest) GetIndexName() string

func (*GetSearchAttributesRequest) GetNamespace added in v1.20.0 

func (x *GetSearchAttributesRequest) GetNamespace() string

func (*GetSearchAttributesRequest) Marshal added in v1.10.0 

func (val *GetSearchAttributesRequest) Marshal() ([]byte, error)

Marshal an object of type GetSearchAttributesRequest to the protobuf v3 wire format

func (*GetSearchAttributesRequest) ProtoMessage added in v1.10.0 

func (*GetSearchAttributesRequest) ProtoMessage()

func (*GetSearchAttributesRequest) ProtoReflect added in v1.23.0 

func (x *GetSearchAttributesRequest) ProtoReflect() protoreflect.Message

func (*GetSearchAttributesRequest) Reset added in v1.10.0 

func (x *GetSearchAttributesRequest) Reset()

func (*GetSearchAttributesRequest) Size added in v1.10.0 

func (val *GetSearchAttributesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetSearchAttributesRequest) String added in v1.10.0 

func (x *GetSearchAttributesRequest) String() string

func (*GetSearchAttributesRequest) Unmarshal added in v1.10.0 

func (val *GetSearchAttributesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetSearchAttributesRequest from the protobuf v3 wire format

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 */
	// contains filtered or unexported fields
}

func (*GetSearchAttributesResponse) Descriptor deprecated added in v1.10.0 

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

Deprecated: Use GetSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*GetSearchAttributesResponse) Equal added in v1.10.0 

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

Equal returns whether two GetSearchAttributesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetSearchAttributesResponse) GetAddWorkflowExecutionInfo added in v1.10.0 

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

func (*GetSearchAttributesResponse) GetCustomAttributes added in v1.10.0 

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

func (*GetSearchAttributesResponse) GetMapping added in v1.10.0 

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

func (*GetSearchAttributesResponse) GetSystemAttributes added in v1.10.0 

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

func (*GetSearchAttributesResponse) Marshal added in v1.10.0 

func (val *GetSearchAttributesResponse) Marshal() ([]byte, error)

Marshal an object of type GetSearchAttributesResponse to the protobuf v3 wire format

func (*GetSearchAttributesResponse) ProtoMessage added in v1.10.0 

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) ProtoReflect added in v1.23.0 

func (x *GetSearchAttributesResponse) ProtoReflect() protoreflect.Message

func (*GetSearchAttributesResponse) Reset added in v1.10.0 

func (x *GetSearchAttributesResponse) Reset()

func (*GetSearchAttributesResponse) Size added in v1.10.0 

func (val *GetSearchAttributesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetSearchAttributesResponse) String added in v1.10.0 

func (x *GetSearchAttributesResponse) String() string

func (*GetSearchAttributesResponse) Unmarshal added in v1.10.0 

func (val *GetSearchAttributesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetSearchAttributesResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*GetShardRequest) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use GetShardRequest.ProtoReflect.Descriptor instead.

func (*GetShardRequest) Equal added in v1.14.0 

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

Equal returns whether two GetShardRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetShardRequest) GetShardId added in v1.14.0 

func (x *GetShardRequest) GetShardId() int32

func (*GetShardRequest) Marshal added in v1.14.0 

func (val *GetShardRequest) Marshal() ([]byte, error)

Marshal an object of type GetShardRequest to the protobuf v3 wire format

func (*GetShardRequest) ProtoMessage added in v1.14.0 

func (*GetShardRequest) ProtoMessage()

func (*GetShardRequest) ProtoReflect added in v1.23.0 

func (x *GetShardRequest) ProtoReflect() protoreflect.Message

func (*GetShardRequest) Reset added in v1.14.0 

func (x *GetShardRequest) Reset()

func (*GetShardRequest) Size added in v1.14.0 

func (val *GetShardRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetShardRequest) String added in v1.14.0 

func (x *GetShardRequest) String() string

func (*GetShardRequest) Unmarshal added in v1.14.0 

func (val *GetShardRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetShardRequest from the protobuf v3 wire format

type GetShardResponse added in v1.14.0 

type GetShardResponse struct {
	ShardInfo *v12.ShardInfo `protobuf:"bytes,1,opt,name=shard_info,json=shardInfo,proto3" json:"shard_info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardResponse) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use GetShardResponse.ProtoReflect.Descriptor instead.

func (*GetShardResponse) Equal added in v1.14.0 

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

Equal returns whether two GetShardResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetShardResponse) GetShardInfo added in v1.14.0 

func (x *GetShardResponse) GetShardInfo() *v12.ShardInfo

func (*GetShardResponse) Marshal added in v1.14.0 

func (val *GetShardResponse) Marshal() ([]byte, error)

Marshal an object of type GetShardResponse to the protobuf v3 wire format

func (*GetShardResponse) ProtoMessage added in v1.14.0 

func (*GetShardResponse) ProtoMessage()

func (*GetShardResponse) ProtoReflect added in v1.23.0 

func (x *GetShardResponse) ProtoReflect() protoreflect.Message

func (*GetShardResponse) Reset added in v1.14.0 

func (x *GetShardResponse) Reset()

func (*GetShardResponse) Size added in v1.14.0 

func (val *GetShardResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetShardResponse) String added in v1.14.0 

func (x *GetShardResponse) String() string

func (*GetShardResponse) Unmarshal added in v1.14.0 

func (val *GetShardResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetShardResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*GetTaskQueueTasksRequest) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use GetTaskQueueTasksRequest.ProtoReflect.Descriptor instead.

func (*GetTaskQueueTasksRequest) Equal added in v1.14.0 

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

Equal returns whether two GetTaskQueueTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetTaskQueueTasksRequest) GetBatchSize added in v1.14.0 

func (x *GetTaskQueueTasksRequest) GetBatchSize() int32

func (*GetTaskQueueTasksRequest) GetMaxTaskId added in v1.14.0 

func (x *GetTaskQueueTasksRequest) GetMaxTaskId() int64

func (*GetTaskQueueTasksRequest) GetMinTaskId added in v1.14.0 

func (x *GetTaskQueueTasksRequest) GetMinTaskId() int64

func (*GetTaskQueueTasksRequest) GetNamespace added in v1.14.0 

func (x *GetTaskQueueTasksRequest) GetNamespace() string

func (*GetTaskQueueTasksRequest) GetNextPageToken added in v1.16.0 

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

func (*GetTaskQueueTasksRequest) GetTaskQueue added in v1.14.0 

func (x *GetTaskQueueTasksRequest) GetTaskQueue() string

func (*GetTaskQueueTasksRequest) GetTaskQueueType added in v1.14.0 

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

func (*GetTaskQueueTasksRequest) Marshal added in v1.14.0 

func (val *GetTaskQueueTasksRequest) Marshal() ([]byte, error)

Marshal an object of type GetTaskQueueTasksRequest to the protobuf v3 wire format

func (*GetTaskQueueTasksRequest) ProtoMessage added in v1.14.0 

func (*GetTaskQueueTasksRequest) ProtoMessage()

func (*GetTaskQueueTasksRequest) ProtoReflect added in v1.23.0 

func (x *GetTaskQueueTasksRequest) ProtoReflect() protoreflect.Message

func (*GetTaskQueueTasksRequest) Reset added in v1.14.0 

func (x *GetTaskQueueTasksRequest) Reset()

func (*GetTaskQueueTasksRequest) Size added in v1.14.0 

func (val *GetTaskQueueTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetTaskQueueTasksRequest) String added in v1.14.0 

func (x *GetTaskQueueTasksRequest) String() string

func (*GetTaskQueueTasksRequest) Unmarshal added in v1.14.0 

func (val *GetTaskQueueTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetTaskQueueTasksRequest from the protobuf v3 wire format

type GetTaskQueueTasksResponse added in v1.14.0 

type GetTaskQueueTasksResponse struct {
	Tasks         []*v12.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"`
	// contains filtered or unexported fields
}

func (*GetTaskQueueTasksResponse) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use GetTaskQueueTasksResponse.ProtoReflect.Descriptor instead.

func (*GetTaskQueueTasksResponse) Equal added in v1.14.0 

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

Equal returns whether two GetTaskQueueTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetTaskQueueTasksResponse) GetNextPageToken added in v1.16.0 

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

func (*GetTaskQueueTasksResponse) GetTasks added in v1.14.0 

func (x *GetTaskQueueTasksResponse) GetTasks() []*v12.AllocatedTaskInfo

func (*GetTaskQueueTasksResponse) Marshal added in v1.14.0 

func (val *GetTaskQueueTasksResponse) Marshal() ([]byte, error)

Marshal an object of type GetTaskQueueTasksResponse to the protobuf v3 wire format

func (*GetTaskQueueTasksResponse) ProtoMessage added in v1.14.0 

func (*GetTaskQueueTasksResponse) ProtoMessage()

func (*GetTaskQueueTasksResponse) ProtoReflect added in v1.23.0 

func (x *GetTaskQueueTasksResponse) ProtoReflect() protoreflect.Message

func (*GetTaskQueueTasksResponse) Reset added in v1.14.0 

func (x *GetTaskQueueTasksResponse) Reset()

func (*GetTaskQueueTasksResponse) Size added in v1.14.0 

func (val *GetTaskQueueTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetTaskQueueTasksResponse) String added in v1.14.0 

func (x *GetTaskQueueTasksResponse) String() string

func (*GetTaskQueueTasksResponse) Unmarshal added in v1.14.0 

func (val *GetTaskQueueTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetTaskQueueTasksResponse from the protobuf v3 wire format

type GetWorkflowExecutionRawHistoryRequest 

type GetWorkflowExecutionRawHistoryRequest struct {
	NamespaceId       string                `protobuf:"bytes,1,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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowExecutionRawHistoryRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowExecutionRawHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionRawHistoryRequest) Equal 

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

Equal returns whether two GetWorkflowExecutionRawHistoryRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkflowExecutionRawHistoryRequest) GetEndEventId added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryRequest) GetEndEventId() int64

func (*GetWorkflowExecutionRawHistoryRequest) GetEndEventVersion added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryRequest) GetEndEventVersion() int64

func (*GetWorkflowExecutionRawHistoryRequest) GetExecution 

func (x *GetWorkflowExecutionRawHistoryRequest) GetExecution() *v1.WorkflowExecution

func (*GetWorkflowExecutionRawHistoryRequest) GetMaximumPageSize 

func (x *GetWorkflowExecutionRawHistoryRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionRawHistoryRequest) GetNamespaceId added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryRequest) GetNamespaceId() string

func (*GetWorkflowExecutionRawHistoryRequest) GetNextPageToken 

func (x *GetWorkflowExecutionRawHistoryRequest) GetNextPageToken() []byte

func (*GetWorkflowExecutionRawHistoryRequest) GetStartEventId added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryRequest) GetStartEventId() int64

func (*GetWorkflowExecutionRawHistoryRequest) GetStartEventVersion added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryRequest) GetStartEventVersion() int64

func (*GetWorkflowExecutionRawHistoryRequest) Marshal 

func (val *GetWorkflowExecutionRawHistoryRequest) Marshal() ([]byte, error)

Marshal an object of type GetWorkflowExecutionRawHistoryRequest to the protobuf v3 wire format

func (*GetWorkflowExecutionRawHistoryRequest) ProtoMessage 

func (*GetWorkflowExecutionRawHistoryRequest) ProtoMessage()

func (*GetWorkflowExecutionRawHistoryRequest) ProtoReflect added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionRawHistoryRequest) Reset 

func (x *GetWorkflowExecutionRawHistoryRequest) Reset()

func (*GetWorkflowExecutionRawHistoryRequest) Size 

func (val *GetWorkflowExecutionRawHistoryRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkflowExecutionRawHistoryRequest) String 

func (x *GetWorkflowExecutionRawHistoryRequest) String() string

func (*GetWorkflowExecutionRawHistoryRequest) Unmarshal 

func (val *GetWorkflowExecutionRawHistoryRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkflowExecutionRawHistoryRequest from the protobuf v3 wire format

type GetWorkflowExecutionRawHistoryResponse 

type GetWorkflowExecutionRawHistoryResponse 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 *v11.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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowExecutionRawHistoryResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowExecutionRawHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionRawHistoryResponse) Equal 

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

Equal returns whether two GetWorkflowExecutionRawHistoryResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkflowExecutionRawHistoryResponse) GetHistoryBatches 

func (x *GetWorkflowExecutionRawHistoryResponse) GetHistoryBatches() []*v1.DataBlob

func (*GetWorkflowExecutionRawHistoryResponse) GetHistoryNodeIds added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryResponse) GetHistoryNodeIds() []int64

func (*GetWorkflowExecutionRawHistoryResponse) GetNextPageToken 

func (x *GetWorkflowExecutionRawHistoryResponse) GetNextPageToken() []byte

func (*GetWorkflowExecutionRawHistoryResponse) GetVersionHistory added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryResponse) GetVersionHistory() *v11.VersionHistory

func (*GetWorkflowExecutionRawHistoryResponse) Marshal 

func (val *GetWorkflowExecutionRawHistoryResponse) Marshal() ([]byte, error)

Marshal an object of type GetWorkflowExecutionRawHistoryResponse to the protobuf v3 wire format

func (*GetWorkflowExecutionRawHistoryResponse) ProtoMessage 

func (*GetWorkflowExecutionRawHistoryResponse) ProtoMessage()

func (*GetWorkflowExecutionRawHistoryResponse) ProtoReflect added in v1.24.0 

func (x *GetWorkflowExecutionRawHistoryResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionRawHistoryResponse) Reset 

func (x *GetWorkflowExecutionRawHistoryResponse) Reset()

func (*GetWorkflowExecutionRawHistoryResponse) Size 

func (val *GetWorkflowExecutionRawHistoryResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkflowExecutionRawHistoryResponse) String 

func (x *GetWorkflowExecutionRawHistoryResponse) String() string

func (*GetWorkflowExecutionRawHistoryResponse) Unmarshal 

func (val *GetWorkflowExecutionRawHistoryResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkflowExecutionRawHistoryResponse from the protobuf v3 wire format

type GetWorkflowExecutionRawHistoryV2Request 

type GetWorkflowExecutionRawHistoryV2Request struct {
	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"`
	// contains filtered or unexported fields
}

* 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 deprecated 

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

Deprecated: Use GetWorkflowExecutionRawHistoryV2Request.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionRawHistoryV2Request) Equal 

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

Equal returns whether two GetWorkflowExecutionRawHistoryV2Request values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkflowExecutionRawHistoryV2Request) GetEndEventId 

func (x *GetWorkflowExecutionRawHistoryV2Request) GetEndEventId() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion 

func (x *GetWorkflowExecutionRawHistoryV2Request) GetEndEventVersion() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GetExecution 

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

func (*GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize 

func (x *GetWorkflowExecutionRawHistoryV2Request) GetMaximumPageSize() int32

func (*GetWorkflowExecutionRawHistoryV2Request) GetNamespaceId added in v1.17.0 

func (x *GetWorkflowExecutionRawHistoryV2Request) GetNamespaceId() string

func (*GetWorkflowExecutionRawHistoryV2Request) GetNextPageToken 

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

func (*GetWorkflowExecutionRawHistoryV2Request) GetStartEventId 

func (x *GetWorkflowExecutionRawHistoryV2Request) GetStartEventId() int64

func (*GetWorkflowExecutionRawHistoryV2Request) GetStartEventVersion 

func (x *GetWorkflowExecutionRawHistoryV2Request) GetStartEventVersion() int64

func (*GetWorkflowExecutionRawHistoryV2Request) Marshal 

func (val *GetWorkflowExecutionRawHistoryV2Request) Marshal() ([]byte, error)

Marshal an object of type GetWorkflowExecutionRawHistoryV2Request to the protobuf v3 wire format

func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage 

func (*GetWorkflowExecutionRawHistoryV2Request) ProtoMessage()

func (*GetWorkflowExecutionRawHistoryV2Request) ProtoReflect added in v1.23.0 

func (x *GetWorkflowExecutionRawHistoryV2Request) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionRawHistoryV2Request) Reset 

func (x *GetWorkflowExecutionRawHistoryV2Request) Reset()

func (*GetWorkflowExecutionRawHistoryV2Request) Size 

func (val *GetWorkflowExecutionRawHistoryV2Request) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkflowExecutionRawHistoryV2Request) String 

func (x *GetWorkflowExecutionRawHistoryV2Request) String() string

func (*GetWorkflowExecutionRawHistoryV2Request) Unmarshal 

func (val *GetWorkflowExecutionRawHistoryV2Request) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkflowExecutionRawHistoryV2Request from the protobuf v3 wire format

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 *v11.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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowExecutionRawHistoryV2Response) Descriptor deprecated 

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

Deprecated: Use GetWorkflowExecutionRawHistoryV2Response.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionRawHistoryV2Response) Equal 

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

Equal returns whether two GetWorkflowExecutionRawHistoryV2Response values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkflowExecutionRawHistoryV2Response) GetHistoryBatches 

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetHistoryNodeIds added in v1.17.0 

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetNextPageToken 

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

func (*GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory 

func (x *GetWorkflowExecutionRawHistoryV2Response) GetVersionHistory() *v11.VersionHistory

func (*GetWorkflowExecutionRawHistoryV2Response) Marshal 

func (val *GetWorkflowExecutionRawHistoryV2Response) Marshal() ([]byte, error)

Marshal an object of type GetWorkflowExecutionRawHistoryV2Response to the protobuf v3 wire format

func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage 

func (*GetWorkflowExecutionRawHistoryV2Response) ProtoMessage()

func (*GetWorkflowExecutionRawHistoryV2Response) ProtoReflect added in v1.23.0 

func (x *GetWorkflowExecutionRawHistoryV2Response) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionRawHistoryV2Response) Reset 

func (x *GetWorkflowExecutionRawHistoryV2Response) Reset()

func (*GetWorkflowExecutionRawHistoryV2Response) Size 

func (val *GetWorkflowExecutionRawHistoryV2Response) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkflowExecutionRawHistoryV2Response) String 

func (x *GetWorkflowExecutionRawHistoryV2Response) String() string

func (*GetWorkflowExecutionRawHistoryV2Response) Unmarshal 

func (val *GetWorkflowExecutionRawHistoryV2Response) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkflowExecutionRawHistoryV2Response from the protobuf v3 wire format

type ImportWorkflowExecutionRequest added in v1.23.0 

type ImportWorkflowExecutionRequest 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"`
	HistoryBatches []*v1.DataBlob        `protobuf:"bytes,3,rep,name=history_batches,json=historyBatches,proto3" json:"history_batches,omitempty"`
	VersionHistory *v11.VersionHistory   `protobuf:"bytes,4,opt,name=version_history,json=versionHistory,proto3" json:"version_history,omitempty"`
	Token          []byte                `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportWorkflowExecutionRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use ImportWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*ImportWorkflowExecutionRequest) Equal added in v1.23.0 

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

Equal returns whether two ImportWorkflowExecutionRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ImportWorkflowExecutionRequest) GetExecution added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) GetExecution() *v1.WorkflowExecution

func (*ImportWorkflowExecutionRequest) GetHistoryBatches added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) GetHistoryBatches() []*v1.DataBlob

func (*ImportWorkflowExecutionRequest) GetNamespace added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) GetNamespace() string

func (*ImportWorkflowExecutionRequest) GetToken added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) GetToken() []byte

func (*ImportWorkflowExecutionRequest) GetVersionHistory added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) GetVersionHistory() *v11.VersionHistory

func (*ImportWorkflowExecutionRequest) Marshal added in v1.23.0 

func (val *ImportWorkflowExecutionRequest) Marshal() ([]byte, error)

Marshal an object of type ImportWorkflowExecutionRequest to the protobuf v3 wire format

func (*ImportWorkflowExecutionRequest) ProtoMessage added in v1.23.0 

func (*ImportWorkflowExecutionRequest) ProtoMessage()

func (*ImportWorkflowExecutionRequest) ProtoReflect added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*ImportWorkflowExecutionRequest) Reset added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) Reset()

func (*ImportWorkflowExecutionRequest) Size added in v1.23.0 

func (val *ImportWorkflowExecutionRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ImportWorkflowExecutionRequest) String added in v1.23.0 

func (x *ImportWorkflowExecutionRequest) String() string

func (*ImportWorkflowExecutionRequest) Unmarshal added in v1.23.0 

func (val *ImportWorkflowExecutionRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ImportWorkflowExecutionRequest from the protobuf v3 wire format

type ImportWorkflowExecutionResponse added in v1.23.0 

type ImportWorkflowExecutionResponse struct {
	Token []byte `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*ImportWorkflowExecutionResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use ImportWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*ImportWorkflowExecutionResponse) Equal added in v1.23.0 

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

Equal returns whether two ImportWorkflowExecutionResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ImportWorkflowExecutionResponse) GetToken added in v1.23.0 

func (x *ImportWorkflowExecutionResponse) GetToken() []byte

func (*ImportWorkflowExecutionResponse) Marshal added in v1.23.0 

func (val *ImportWorkflowExecutionResponse) Marshal() ([]byte, error)

Marshal an object of type ImportWorkflowExecutionResponse to the protobuf v3 wire format

func (*ImportWorkflowExecutionResponse) ProtoMessage added in v1.23.0 

func (*ImportWorkflowExecutionResponse) ProtoMessage()

func (*ImportWorkflowExecutionResponse) ProtoReflect added in v1.23.0 

func (x *ImportWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*ImportWorkflowExecutionResponse) Reset added in v1.23.0 

func (x *ImportWorkflowExecutionResponse) Reset()

func (*ImportWorkflowExecutionResponse) Size added in v1.23.0 

func (val *ImportWorkflowExecutionResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ImportWorkflowExecutionResponse) String added in v1.23.0 

func (x *ImportWorkflowExecutionResponse) String() string

func (*ImportWorkflowExecutionResponse) Unmarshal added in v1.23.0 

func (val *ImportWorkflowExecutionResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ImportWorkflowExecutionResponse from the protobuf v3 wire format

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 *durationpb.Duration  `protobuf:"bytes,1,opt,name=last_heartbeat_within,json=lastHeartbeatWithin,proto3" json:"last_heartbeat_within,omitempty"`
	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                v14.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 *timestamppb.Timestamp `` /* 134-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"`
	// contains filtered or unexported fields
}

func (*ListClusterMembersRequest) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use ListClusterMembersRequest.ProtoReflect.Descriptor instead.

func (*ListClusterMembersRequest) Equal added in v1.14.0 

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

Equal returns whether two ListClusterMembersRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListClusterMembersRequest) GetHostId added in v1.14.0 

func (x *ListClusterMembersRequest) GetHostId() string

func (*ListClusterMembersRequest) GetLastHeartbeatWithin added in v1.14.0 

func (x *ListClusterMembersRequest) GetLastHeartbeatWithin() *durationpb.Duration

func (*ListClusterMembersRequest) GetNextPageToken added in v1.14.0 

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

func (*ListClusterMembersRequest) GetPageSize added in v1.14.0 

func (x *ListClusterMembersRequest) GetPageSize() int32

func (*ListClusterMembersRequest) GetRole added in v1.14.0 

func (x *ListClusterMembersRequest) GetRole() v14.ClusterMemberRole

func (*ListClusterMembersRequest) GetRpcAddress added in v1.14.0 

func (x *ListClusterMembersRequest) GetRpcAddress() string

func (*ListClusterMembersRequest) GetSessionStartedAfterTime added in v1.14.0 

func (x *ListClusterMembersRequest) GetSessionStartedAfterTime() *timestamppb.Timestamp

func (*ListClusterMembersRequest) Marshal added in v1.14.0 

func (val *ListClusterMembersRequest) Marshal() ([]byte, error)

Marshal an object of type ListClusterMembersRequest to the protobuf v3 wire format

func (*ListClusterMembersRequest) ProtoMessage added in v1.14.0 

func (*ListClusterMembersRequest) ProtoMessage()

func (*ListClusterMembersRequest) ProtoReflect added in v1.23.0 

func (x *ListClusterMembersRequest) ProtoReflect() protoreflect.Message

func (*ListClusterMembersRequest) Reset added in v1.14.0 

func (x *ListClusterMembersRequest) Reset()

func (*ListClusterMembersRequest) Size added in v1.14.0 

func (val *ListClusterMembersRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListClusterMembersRequest) String added in v1.14.0 

func (x *ListClusterMembersRequest) String() string

func (*ListClusterMembersRequest) Unmarshal added in v1.14.0 

func (val *ListClusterMembersRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListClusterMembersRequest from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*ListClusterMembersResponse) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use ListClusterMembersResponse.ProtoReflect.Descriptor instead.

func (*ListClusterMembersResponse) Equal added in v1.14.0 

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

Equal returns whether two ListClusterMembersResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListClusterMembersResponse) GetActiveMembers added in v1.14.0 

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

func (*ListClusterMembersResponse) GetNextPageToken added in v1.14.0 

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

func (*ListClusterMembersResponse) Marshal added in v1.14.0 

func (val *ListClusterMembersResponse) Marshal() ([]byte, error)

Marshal an object of type ListClusterMembersResponse to the protobuf v3 wire format

func (*ListClusterMembersResponse) ProtoMessage added in v1.14.0 

func (*ListClusterMembersResponse) ProtoMessage()

func (*ListClusterMembersResponse) ProtoReflect added in v1.23.0 

func (x *ListClusterMembersResponse) ProtoReflect() protoreflect.Message

func (*ListClusterMembersResponse) Reset added in v1.14.0 

func (x *ListClusterMembersResponse) Reset()

func (*ListClusterMembersResponse) Size added in v1.14.0 

func (val *ListClusterMembersResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListClusterMembersResponse) String added in v1.14.0 

func (x *ListClusterMembersResponse) String() string

func (*ListClusterMembersResponse) Unmarshal added in v1.14.0 

func (val *ListClusterMembersResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListClusterMembersResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*ListClustersRequest) Descriptor deprecated added in v1.15.0 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) Equal added in v1.15.0 

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

Equal returns whether two ListClustersRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListClustersRequest) GetNextPageToken added in v1.15.0 

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

func (*ListClustersRequest) GetPageSize added in v1.15.0 

func (x *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) Marshal added in v1.15.0 

func (val *ListClustersRequest) Marshal() ([]byte, error)

Marshal an object of type ListClustersRequest to the protobuf v3 wire format

func (*ListClustersRequest) ProtoMessage added in v1.15.0 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect added in v1.23.0 

func (x *ListClustersRequest) ProtoReflect() protoreflect.Message

func (*ListClustersRequest) Reset added in v1.15.0 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) Size added in v1.15.0 

func (val *ListClustersRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListClustersRequest) String added in v1.15.0 

func (x *ListClustersRequest) String() string

func (*ListClustersRequest) Unmarshal added in v1.15.0 

func (val *ListClustersRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListClustersRequest from the protobuf v3 wire format

type ListClustersResponse added in v1.15.0 

type ListClustersResponse struct {
	Clusters      []*v12.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"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated added in v1.15.0 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) Equal added in v1.15.0 

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

Equal returns whether two ListClustersResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListClustersResponse) GetClusters added in v1.15.0 

func (x *ListClustersResponse) GetClusters() []*v12.ClusterMetadata

func (*ListClustersResponse) GetNextPageToken added in v1.15.0 

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

func (*ListClustersResponse) Marshal added in v1.15.0 

func (val *ListClustersResponse) Marshal() ([]byte, error)

Marshal an object of type ListClustersResponse to the protobuf v3 wire format

func (*ListClustersResponse) ProtoMessage added in v1.15.0 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect added in v1.23.0 

func (x *ListClustersResponse) ProtoReflect() protoreflect.Message

func (*ListClustersResponse) Reset added in v1.15.0 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) Size added in v1.15.0 

func (val *ListClustersResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListClustersResponse) String added in v1.15.0 

func (x *ListClustersResponse) String() string

func (*ListClustersResponse) Unmarshal added in v1.15.0 

func (val *ListClustersResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListClustersResponse from the protobuf v3 wire format

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"`
	// The task category. See tasks.TaskCategoryRegistry for more.
	Category      int32          `protobuf:"varint,2,opt,name=category,proto3" json:"category,omitempty"`
	TaskRange     *v11.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"`
	// contains filtered or unexported fields
}

func (*ListHistoryTasksRequest) Descriptor deprecated added in v1.16.0 

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

Deprecated: Use ListHistoryTasksRequest.ProtoReflect.Descriptor instead.

func (*ListHistoryTasksRequest) Equal added in v1.16.0 

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

Equal returns whether two ListHistoryTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListHistoryTasksRequest) GetBatchSize added in v1.16.0 

func (x *ListHistoryTasksRequest) GetBatchSize() int32

func (*ListHistoryTasksRequest) GetCategory added in v1.16.0 

func (x *ListHistoryTasksRequest) GetCategory() int32

func (*ListHistoryTasksRequest) GetNextPageToken added in v1.16.0 

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

func (*ListHistoryTasksRequest) GetShardId added in v1.16.0 

func (x *ListHistoryTasksRequest) GetShardId() int32

func (*ListHistoryTasksRequest) GetTaskRange added in v1.16.0 

func (x *ListHistoryTasksRequest) GetTaskRange() *v11.TaskRange

func (*ListHistoryTasksRequest) Marshal added in v1.16.0 

func (val *ListHistoryTasksRequest) Marshal() ([]byte, error)

Marshal an object of type ListHistoryTasksRequest to the protobuf v3 wire format

func (*ListHistoryTasksRequest) ProtoMessage added in v1.16.0 

func (*ListHistoryTasksRequest) ProtoMessage()

func (*ListHistoryTasksRequest) ProtoReflect added in v1.23.0 

func (x *ListHistoryTasksRequest) ProtoReflect() protoreflect.Message

func (*ListHistoryTasksRequest) Reset added in v1.16.0 

func (x *ListHistoryTasksRequest) Reset()

func (*ListHistoryTasksRequest) Size added in v1.16.0 

func (val *ListHistoryTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListHistoryTasksRequest) String added in v1.16.0 

func (x *ListHistoryTasksRequest) String() string

func (*ListHistoryTasksRequest) Unmarshal added in v1.16.0 

func (val *ListHistoryTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListHistoryTasksRequest from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*ListHistoryTasksResponse) Descriptor deprecated added in v1.16.0 

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

Deprecated: Use ListHistoryTasksResponse.ProtoReflect.Descriptor instead.

func (*ListHistoryTasksResponse) Equal added in v1.16.0 

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

Equal returns whether two ListHistoryTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListHistoryTasksResponse) GetNextPageToken added in v1.16.0 

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

func (*ListHistoryTasksResponse) GetTasks added in v1.16.0 

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

func (*ListHistoryTasksResponse) Marshal added in v1.16.0 

func (val *ListHistoryTasksResponse) Marshal() ([]byte, error)

Marshal an object of type ListHistoryTasksResponse to the protobuf v3 wire format

func (*ListHistoryTasksResponse) ProtoMessage added in v1.16.0 

func (*ListHistoryTasksResponse) ProtoMessage()

func (*ListHistoryTasksResponse) ProtoReflect added in v1.23.0 

func (x *ListHistoryTasksResponse) ProtoReflect() protoreflect.Message

func (*ListHistoryTasksResponse) Reset added in v1.16.0 

func (x *ListHistoryTasksResponse) Reset()

func (*ListHistoryTasksResponse) Size added in v1.16.0 

func (val *ListHistoryTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListHistoryTasksResponse) String added in v1.16.0 

func (x *ListHistoryTasksResponse) String() string

func (*ListHistoryTasksResponse) Unmarshal added in v1.16.0 

func (val *ListHistoryTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListHistoryTasksResponse from the protobuf v3 wire format

type ListQueuesRequest added in v1.23.0 

type ListQueuesRequest struct {
	QueueType     int32  `protobuf:"varint,1,opt,name=queue_type,json=queueType,proto3" json:"queue_type,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuesRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use ListQueuesRequest.ProtoReflect.Descriptor instead.

func (*ListQueuesRequest) Equal added in v1.23.0 

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

Equal returns whether two ListQueuesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListQueuesRequest) GetNextPageToken added in v1.23.0 

func (x *ListQueuesRequest) GetNextPageToken() []byte

func (*ListQueuesRequest) GetPageSize added in v1.23.0 

func (x *ListQueuesRequest) GetPageSize() int32

func (*ListQueuesRequest) GetQueueType added in v1.23.0 

func (x *ListQueuesRequest) GetQueueType() int32

func (*ListQueuesRequest) Marshal added in v1.23.0 

func (val *ListQueuesRequest) Marshal() ([]byte, error)

Marshal an object of type ListQueuesRequest to the protobuf v3 wire format

func (*ListQueuesRequest) ProtoMessage added in v1.23.0 

func (*ListQueuesRequest) ProtoMessage()

func (*ListQueuesRequest) ProtoReflect added in v1.23.0 

func (x *ListQueuesRequest) ProtoReflect() protoreflect.Message

func (*ListQueuesRequest) Reset added in v1.23.0 

func (x *ListQueuesRequest) Reset()

func (*ListQueuesRequest) Size added in v1.23.0 

func (val *ListQueuesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListQueuesRequest) String added in v1.23.0 

func (x *ListQueuesRequest) String() string

func (*ListQueuesRequest) Unmarshal added in v1.23.0 

func (val *ListQueuesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListQueuesRequest from the protobuf v3 wire format

type ListQueuesResponse added in v1.23.0 

type ListQueuesResponse struct {
	Queues        []*ListQueuesResponse_QueueInfo `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
	NextPageToken []byte                          `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuesResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use ListQueuesResponse.ProtoReflect.Descriptor instead.

func (*ListQueuesResponse) Equal added in v1.23.0 

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

Equal returns whether two ListQueuesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListQueuesResponse) GetNextPageToken added in v1.23.0 

func (x *ListQueuesResponse) GetNextPageToken() []byte

func (*ListQueuesResponse) GetQueues added in v1.23.0 

func (x *ListQueuesResponse) GetQueues() []*ListQueuesResponse_QueueInfo

func (*ListQueuesResponse) Marshal added in v1.23.0 

func (val *ListQueuesResponse) Marshal() ([]byte, error)

Marshal an object of type ListQueuesResponse to the protobuf v3 wire format

func (*ListQueuesResponse) ProtoMessage added in v1.23.0 

func (*ListQueuesResponse) ProtoMessage()

func (*ListQueuesResponse) ProtoReflect added in v1.23.0 

func (x *ListQueuesResponse) ProtoReflect() protoreflect.Message

func (*ListQueuesResponse) Reset added in v1.23.0 

func (x *ListQueuesResponse) Reset()

func (*ListQueuesResponse) Size added in v1.23.0 

func (val *ListQueuesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListQueuesResponse) String added in v1.23.0 

func (x *ListQueuesResponse) String() string

func (*ListQueuesResponse) Unmarshal added in v1.23.0 

func (val *ListQueuesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListQueuesResponse from the protobuf v3 wire format

type ListQueuesResponse_QueueInfo added in v1.23.0 

type ListQueuesResponse_QueueInfo struct {
	QueueName    string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	MessageCount int64  `protobuf:"varint,2,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuesResponse_QueueInfo) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use ListQueuesResponse_QueueInfo.ProtoReflect.Descriptor instead.

func (*ListQueuesResponse_QueueInfo) GetMessageCount added in v1.23.0 

func (x *ListQueuesResponse_QueueInfo) GetMessageCount() int64

func (*ListQueuesResponse_QueueInfo) GetQueueName added in v1.23.0 

func (x *ListQueuesResponse_QueueInfo) GetQueueName() string

func (*ListQueuesResponse_QueueInfo) ProtoMessage added in v1.23.0 

func (*ListQueuesResponse_QueueInfo) ProtoMessage()

func (*ListQueuesResponse_QueueInfo) ProtoReflect added in v1.23.0 

func (x *ListQueuesResponse_QueueInfo) ProtoReflect() protoreflect.Message

func (*ListQueuesResponse_QueueInfo) Reset added in v1.23.0 

func (x *ListQueuesResponse_QueueInfo) Reset()

func (*ListQueuesResponse_QueueInfo) String added in v1.23.0 

func (x *ListQueuesResponse_QueueInfo) String() string

type MergeDLQMessagesRequest 

type MergeDLQMessagesRequest struct {
	Type                  v14.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"`
	// contains filtered or unexported fields
}

func (*MergeDLQMessagesRequest) Descriptor deprecated 

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

Deprecated: Use MergeDLQMessagesRequest.ProtoReflect.Descriptor instead.

func (*MergeDLQMessagesRequest) Equal 

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

Equal returns whether two MergeDLQMessagesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*MergeDLQMessagesRequest) GetInclusiveEndMessageId 

func (x *MergeDLQMessagesRequest) GetInclusiveEndMessageId() int64

func (*MergeDLQMessagesRequest) GetMaximumPageSize 

func (x *MergeDLQMessagesRequest) GetMaximumPageSize() int32

func (*MergeDLQMessagesRequest) GetNextPageToken 

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

func (*MergeDLQMessagesRequest) GetShardId 

func (x *MergeDLQMessagesRequest) GetShardId() int32

func (*MergeDLQMessagesRequest) GetSourceCluster 

func (x *MergeDLQMessagesRequest) GetSourceCluster() string

func (*MergeDLQMessagesRequest) GetType 

func (x *MergeDLQMessagesRequest) GetType() v14.DeadLetterQueueType

func (*MergeDLQMessagesRequest) Marshal 

func (val *MergeDLQMessagesRequest) Marshal() ([]byte, error)

Marshal an object of type MergeDLQMessagesRequest to the protobuf v3 wire format

func (*MergeDLQMessagesRequest) ProtoMessage 

func (*MergeDLQMessagesRequest) ProtoMessage()

func (*MergeDLQMessagesRequest) ProtoReflect added in v1.23.0 

func (x *MergeDLQMessagesRequest) ProtoReflect() protoreflect.Message

func (*MergeDLQMessagesRequest) Reset 

func (x *MergeDLQMessagesRequest) Reset()

func (*MergeDLQMessagesRequest) Size 

func (val *MergeDLQMessagesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*MergeDLQMessagesRequest) String 

func (x *MergeDLQMessagesRequest) String() string

func (*MergeDLQMessagesRequest) Unmarshal 

func (val *MergeDLQMessagesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type MergeDLQMessagesRequest from the protobuf v3 wire format

type MergeDLQMessagesResponse 

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

func (*MergeDLQMessagesResponse) Descriptor deprecated 

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

Deprecated: Use MergeDLQMessagesResponse.ProtoReflect.Descriptor instead.

func (*MergeDLQMessagesResponse) Equal 

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

Equal returns whether two MergeDLQMessagesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*MergeDLQMessagesResponse) GetNextPageToken 

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

func (*MergeDLQMessagesResponse) Marshal 

func (val *MergeDLQMessagesResponse) Marshal() ([]byte, error)

Marshal an object of type MergeDLQMessagesResponse to the protobuf v3 wire format

func (*MergeDLQMessagesResponse) ProtoMessage 

func (*MergeDLQMessagesResponse) ProtoMessage()

func (*MergeDLQMessagesResponse) ProtoReflect added in v1.23.0 

func (x *MergeDLQMessagesResponse) ProtoReflect() protoreflect.Message

func (*MergeDLQMessagesResponse) Reset 

func (x *MergeDLQMessagesResponse) Reset()

func (*MergeDLQMessagesResponse) Size 

func (val *MergeDLQMessagesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*MergeDLQMessagesResponse) String 

func (x *MergeDLQMessagesResponse) String() string

func (*MergeDLQMessagesResponse) Unmarshal 

func (val *MergeDLQMessagesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type MergeDLQMessagesResponse from the protobuf v3 wire format

type MergeDLQTasksRequest added in v1.23.0 

type MergeDLQTasksRequest struct {
	DlqKey                   *v112.HistoryDLQKey          `protobuf:"bytes,1,opt,name=dlq_key,json=dlqKey,proto3" json:"dlq_key,omitempty"`
	InclusiveMaxTaskMetadata *v112.HistoryDLQTaskMetadata `` /* 137-byte string literal not displayed */
	// batch_size controls how many tasks to merge at a time. The default can be found in the dlq package of the server.
	// - If this is negative, an error will be returned.
	// - If this is 0, the default will be used.
	// - If this is greater than the maximum allowed batch size, an error will be returned.
	// - Otherwise, the specified batch size will be used.
	BatchSize int32 `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

func (*MergeDLQTasksRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use MergeDLQTasksRequest.ProtoReflect.Descriptor instead.

func (*MergeDLQTasksRequest) Equal added in v1.23.0 

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

Equal returns whether two MergeDLQTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*MergeDLQTasksRequest) GetBatchSize added in v1.23.0 

func (x *MergeDLQTasksRequest) GetBatchSize() int32

func (*MergeDLQTasksRequest) GetDlqKey added in v1.23.0 

func (x *MergeDLQTasksRequest) GetDlqKey() *v112.HistoryDLQKey

func (*MergeDLQTasksRequest) GetInclusiveMaxTaskMetadata added in v1.23.0 

func (x *MergeDLQTasksRequest) GetInclusiveMaxTaskMetadata() *v112.HistoryDLQTaskMetadata

func (*MergeDLQTasksRequest) Marshal added in v1.23.0 

func (val *MergeDLQTasksRequest) Marshal() ([]byte, error)

Marshal an object of type MergeDLQTasksRequest to the protobuf v3 wire format

func (*MergeDLQTasksRequest) ProtoMessage added in v1.23.0 

func (*MergeDLQTasksRequest) ProtoMessage()

func (*MergeDLQTasksRequest) ProtoReflect added in v1.23.0 

func (x *MergeDLQTasksRequest) ProtoReflect() protoreflect.Message

func (*MergeDLQTasksRequest) Reset added in v1.23.0 

func (x *MergeDLQTasksRequest) Reset()

func (*MergeDLQTasksRequest) Size added in v1.23.0 

func (val *MergeDLQTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*MergeDLQTasksRequest) String added in v1.23.0 

func (x *MergeDLQTasksRequest) String() string

func (*MergeDLQTasksRequest) Unmarshal added in v1.23.0 

func (val *MergeDLQTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type MergeDLQTasksRequest from the protobuf v3 wire format

type MergeDLQTasksResponse added in v1.23.0 

type MergeDLQTasksResponse struct {
	JobToken []byte `protobuf:"bytes,1,opt,name=job_token,json=jobToken,proto3" json:"job_token,omitempty"`
	// contains filtered or unexported fields
}

func (*MergeDLQTasksResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use MergeDLQTasksResponse.ProtoReflect.Descriptor instead.

func (*MergeDLQTasksResponse) Equal added in v1.23.0 

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

Equal returns whether two MergeDLQTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*MergeDLQTasksResponse) GetJobToken added in v1.23.0 

func (x *MergeDLQTasksResponse) GetJobToken() []byte

func (*MergeDLQTasksResponse) Marshal added in v1.23.0 

func (val *MergeDLQTasksResponse) Marshal() ([]byte, error)

Marshal an object of type MergeDLQTasksResponse to the protobuf v3 wire format

func (*MergeDLQTasksResponse) ProtoMessage added in v1.23.0 

func (*MergeDLQTasksResponse) ProtoMessage()

func (*MergeDLQTasksResponse) ProtoReflect added in v1.23.0 

func (x *MergeDLQTasksResponse) ProtoReflect() protoreflect.Message

func (*MergeDLQTasksResponse) Reset added in v1.23.0 

func (x *MergeDLQTasksResponse) Reset()

func (*MergeDLQTasksResponse) Size added in v1.23.0 

func (val *MergeDLQTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*MergeDLQTasksResponse) String added in v1.23.0 

func (x *MergeDLQTasksResponse) String() string

func (*MergeDLQTasksResponse) Unmarshal added in v1.23.0 

func (val *MergeDLQTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type MergeDLQTasksResponse from the protobuf v3 wire format

type PurgeDLQMessagesRequest 

type PurgeDLQMessagesRequest struct {
	Type                  v14.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 */
	// contains filtered or unexported fields
}

func (*PurgeDLQMessagesRequest) Descriptor deprecated 

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

Deprecated: Use PurgeDLQMessagesRequest.ProtoReflect.Descriptor instead.

func (*PurgeDLQMessagesRequest) Equal 

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

Equal returns whether two PurgeDLQMessagesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PurgeDLQMessagesRequest) GetInclusiveEndMessageId 

func (x *PurgeDLQMessagesRequest) GetInclusiveEndMessageId() int64

func (*PurgeDLQMessagesRequest) GetShardId 

func (x *PurgeDLQMessagesRequest) GetShardId() int32

func (*PurgeDLQMessagesRequest) GetSourceCluster 

func (x *PurgeDLQMessagesRequest) GetSourceCluster() string

func (*PurgeDLQMessagesRequest) GetType 

func (x *PurgeDLQMessagesRequest) GetType() v14.DeadLetterQueueType

func (*PurgeDLQMessagesRequest) Marshal 

func (val *PurgeDLQMessagesRequest) Marshal() ([]byte, error)

Marshal an object of type PurgeDLQMessagesRequest to the protobuf v3 wire format

func (*PurgeDLQMessagesRequest) ProtoMessage 

func (*PurgeDLQMessagesRequest) ProtoMessage()

func (*PurgeDLQMessagesRequest) ProtoReflect added in v1.23.0 

func (x *PurgeDLQMessagesRequest) ProtoReflect() protoreflect.Message

func (*PurgeDLQMessagesRequest) Reset 

func (x *PurgeDLQMessagesRequest) Reset()

func (*PurgeDLQMessagesRequest) Size 

func (val *PurgeDLQMessagesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PurgeDLQMessagesRequest) String 

func (x *PurgeDLQMessagesRequest) String() string

func (*PurgeDLQMessagesRequest) Unmarshal 

func (val *PurgeDLQMessagesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type PurgeDLQMessagesRequest from the protobuf v3 wire format

type PurgeDLQMessagesResponse 

type PurgeDLQMessagesResponse struct {
	// contains filtered or unexported fields
}

func (*PurgeDLQMessagesResponse) Descriptor deprecated 

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

Deprecated: Use PurgeDLQMessagesResponse.ProtoReflect.Descriptor instead.

func (*PurgeDLQMessagesResponse) Equal 

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

Equal returns whether two PurgeDLQMessagesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PurgeDLQMessagesResponse) Marshal 

func (val *PurgeDLQMessagesResponse) Marshal() ([]byte, error)

Marshal an object of type PurgeDLQMessagesResponse to the protobuf v3 wire format

func (*PurgeDLQMessagesResponse) ProtoMessage 

func (*PurgeDLQMessagesResponse) ProtoMessage()

func (*PurgeDLQMessagesResponse) ProtoReflect added in v1.23.0 

func (x *PurgeDLQMessagesResponse) ProtoReflect() protoreflect.Message

func (*PurgeDLQMessagesResponse) Reset 

func (x *PurgeDLQMessagesResponse) Reset()

func (*PurgeDLQMessagesResponse) Size 

func (val *PurgeDLQMessagesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PurgeDLQMessagesResponse) String 

func (x *PurgeDLQMessagesResponse) String() string

func (*PurgeDLQMessagesResponse) Unmarshal 

func (val *PurgeDLQMessagesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type PurgeDLQMessagesResponse from the protobuf v3 wire format

type PurgeDLQTasksRequest added in v1.23.0 

type PurgeDLQTasksRequest struct {
	DlqKey                   *v112.HistoryDLQKey          `protobuf:"bytes,1,opt,name=dlq_key,json=dlqKey,proto3" json:"dlq_key,omitempty"`
	InclusiveMaxTaskMetadata *v112.HistoryDLQTaskMetadata `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PurgeDLQTasksRequest) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use PurgeDLQTasksRequest.ProtoReflect.Descriptor instead.

func (*PurgeDLQTasksRequest) Equal added in v1.23.0 

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

Equal returns whether two PurgeDLQTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PurgeDLQTasksRequest) GetDlqKey added in v1.23.0 

func (x *PurgeDLQTasksRequest) GetDlqKey() *v112.HistoryDLQKey

func (*PurgeDLQTasksRequest) GetInclusiveMaxTaskMetadata added in v1.23.0 

func (x *PurgeDLQTasksRequest) GetInclusiveMaxTaskMetadata() *v112.HistoryDLQTaskMetadata

func (*PurgeDLQTasksRequest) Marshal added in v1.23.0 

func (val *PurgeDLQTasksRequest) Marshal() ([]byte, error)

Marshal an object of type PurgeDLQTasksRequest to the protobuf v3 wire format

func (*PurgeDLQTasksRequest) ProtoMessage added in v1.23.0 

func (*PurgeDLQTasksRequest) ProtoMessage()

func (*PurgeDLQTasksRequest) ProtoReflect added in v1.23.0 

func (x *PurgeDLQTasksRequest) ProtoReflect() protoreflect.Message

func (*PurgeDLQTasksRequest) Reset added in v1.23.0 

func (x *PurgeDLQTasksRequest) Reset()

func (*PurgeDLQTasksRequest) Size added in v1.23.0 

func (val *PurgeDLQTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PurgeDLQTasksRequest) String added in v1.23.0 

func (x *PurgeDLQTasksRequest) String() string

func (*PurgeDLQTasksRequest) Unmarshal added in v1.23.0 

func (val *PurgeDLQTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type PurgeDLQTasksRequest from the protobuf v3 wire format

type PurgeDLQTasksResponse added in v1.23.0 

type PurgeDLQTasksResponse struct {

	// job_token is a token that can be used to query the status of the purge operation.
	JobToken []byte `protobuf:"bytes,1,opt,name=job_token,json=jobToken,proto3" json:"job_token,omitempty"`
	// contains filtered or unexported fields
}

func (*PurgeDLQTasksResponse) Descriptor deprecated added in v1.23.0 

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

Deprecated: Use PurgeDLQTasksResponse.ProtoReflect.Descriptor instead.

func (*PurgeDLQTasksResponse) Equal added in v1.23.0 

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

Equal returns whether two PurgeDLQTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PurgeDLQTasksResponse) GetJobToken added in v1.23.0 

func (x *PurgeDLQTasksResponse) GetJobToken() []byte

func (*PurgeDLQTasksResponse) Marshal added in v1.23.0 

func (val *PurgeDLQTasksResponse) Marshal() ([]byte, error)

Marshal an object of type PurgeDLQTasksResponse to the protobuf v3 wire format

func (*PurgeDLQTasksResponse) ProtoMessage added in v1.23.0 

func (*PurgeDLQTasksResponse) ProtoMessage()

func (*PurgeDLQTasksResponse) ProtoReflect added in v1.23.0 

func (x *PurgeDLQTasksResponse) ProtoReflect() protoreflect.Message

func (*PurgeDLQTasksResponse) Reset added in v1.23.0 

func (x *PurgeDLQTasksResponse) Reset()

func (*PurgeDLQTasksResponse) Size added in v1.23.0 

func (val *PurgeDLQTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PurgeDLQTasksResponse) String added in v1.23.0 

func (x *PurgeDLQTasksResponse) String() string

func (*PurgeDLQTasksResponse) Unmarshal added in v1.23.0 

func (val *PurgeDLQTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type PurgeDLQTasksResponse from the protobuf v3 wire format

type ReapplyEventsRequest 

type ReapplyEventsRequest struct {
	NamespaceId       string                `protobuf:"bytes,4,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,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"`
	// contains filtered or unexported fields
}

ReapplyEventsRequest is the request for reapply events API.

func (*ReapplyEventsRequest) Descriptor deprecated 

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

Deprecated: Use ReapplyEventsRequest.ProtoReflect.Descriptor instead.

func (*ReapplyEventsRequest) Equal 

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

Equal returns whether two ReapplyEventsRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ReapplyEventsRequest) GetEvents 

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

func (*ReapplyEventsRequest) GetNamespaceId added in v1.17.0 

func (x *ReapplyEventsRequest) GetNamespaceId() string

func (*ReapplyEventsRequest) GetWorkflowExecution 

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

func (*ReapplyEventsRequest) Marshal 

func (val *ReapplyEventsRequest) Marshal() ([]byte, error)

Marshal an object of type ReapplyEventsRequest to the protobuf v3 wire format

func (*ReapplyEventsRequest) ProtoMessage 

func (*ReapplyEventsRequest) ProtoMessage()

func (*ReapplyEventsRequest) ProtoReflect added in v1.23.0 

func (x *ReapplyEventsRequest) ProtoReflect() protoreflect.Message

func (*ReapplyEventsRequest) Reset 

func (x *ReapplyEventsRequest) Reset()

func (*ReapplyEventsRequest) Size 

func (val *ReapplyEventsRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ReapplyEventsRequest) String 

func (x *ReapplyEventsRequest) String() string

func (*ReapplyEventsRequest) Unmarshal 

func (val *ReapplyEventsRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ReapplyEventsRequest from the protobuf v3 wire format

type ReapplyEventsResponse 

type ReapplyEventsResponse struct {
	// contains filtered or unexported fields
}

func (*ReapplyEventsResponse) Descriptor deprecated 

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

Deprecated: Use ReapplyEventsResponse.ProtoReflect.Descriptor instead.

func (*ReapplyEventsResponse) Equal 

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

Equal returns whether two ReapplyEventsResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ReapplyEventsResponse) Marshal 

func (val *ReapplyEventsResponse) Marshal() ([]byte, error)

Marshal an object of type ReapplyEventsResponse to the protobuf v3 wire format

func (*ReapplyEventsResponse) ProtoMessage 

func (*ReapplyEventsResponse) ProtoMessage()

func (*ReapplyEventsResponse) ProtoReflect added in v1.23.0 

func (x *ReapplyEventsResponse) ProtoReflect() protoreflect.Message

func (*ReapplyEventsResponse) Reset 

func (x *ReapplyEventsResponse) Reset()

func (*ReapplyEventsResponse) Size 

func (val *ReapplyEventsResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ReapplyEventsResponse) String 

func (x *ReapplyEventsResponse) String() string

func (*ReapplyEventsResponse) Unmarshal 

func (val *ReapplyEventsResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ReapplyEventsResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*RebuildMutableStateRequest) Descriptor deprecated added in v1.16.0 

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

Deprecated: Use RebuildMutableStateRequest.ProtoReflect.Descriptor instead.

func (*RebuildMutableStateRequest) Equal added in v1.16.0 

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

Equal returns whether two RebuildMutableStateRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RebuildMutableStateRequest) GetExecution added in v1.16.0 

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

func (*RebuildMutableStateRequest) GetNamespace added in v1.16.0 

func (x *RebuildMutableStateRequest) GetNamespace() string

func (*RebuildMutableStateRequest) Marshal added in v1.16.0 

func (val *RebuildMutableStateRequest) Marshal() ([]byte, error)

Marshal an object of type RebuildMutableStateRequest to the protobuf v3 wire format

func (*RebuildMutableStateRequest) ProtoMessage added in v1.16.0 

func (*RebuildMutableStateRequest) ProtoMessage()

func (*RebuildMutableStateRequest) ProtoReflect added in v1.23.0 

func (x *RebuildMutableStateRequest) ProtoReflect() protoreflect.Message

func (*RebuildMutableStateRequest) Reset added in v1.16.0 

func (x *RebuildMutableStateRequest) Reset()

func (*RebuildMutableStateRequest) Size added in v1.16.0 

func (val *RebuildMutableStateRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RebuildMutableStateRequest) String added in v1.16.0 

func (x *RebuildMutableStateRequest) String() string

func (*RebuildMutableStateRequest) Unmarshal added in v1.16.0 

func (val *RebuildMutableStateRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RebuildMutableStateRequest from the protobuf v3 wire format

type RebuildMutableStateResponse added in v1.16.0 

type RebuildMutableStateResponse struct {
	// contains filtered or unexported fields
}

func (*RebuildMutableStateResponse) Descriptor deprecated added in v1.16.0 

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

Deprecated: Use RebuildMutableStateResponse.ProtoReflect.Descriptor instead.

func (*RebuildMutableStateResponse) Equal added in v1.16.0 

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

Equal returns whether two RebuildMutableStateResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RebuildMutableStateResponse) Marshal added in v1.16.0 

func (val *RebuildMutableStateResponse) Marshal() ([]byte, error)

Marshal an object of type RebuildMutableStateResponse to the protobuf v3 wire format

func (*RebuildMutableStateResponse) ProtoMessage added in v1.16.0 

func (*RebuildMutableStateResponse) ProtoMessage()

func (*RebuildMutableStateResponse) ProtoReflect added in v1.23.0 

func (x *RebuildMutableStateResponse) ProtoReflect() protoreflect.Message

func (*RebuildMutableStateResponse) Reset added in v1.16.0 

func (x *RebuildMutableStateResponse) Reset()

func (*RebuildMutableStateResponse) Size added in v1.16.0 

func (val *RebuildMutableStateResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RebuildMutableStateResponse) String added in v1.16.0 

func (x *RebuildMutableStateResponse) String() string

func (*RebuildMutableStateResponse) Unmarshal added in v1.16.0 

func (val *RebuildMutableStateResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RebuildMutableStateResponse from the protobuf v3 wire format

type RefreshWorkflowTasksRequest 

type RefreshWorkflowTasksRequest struct {
	NamespaceId string                `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution   *v1.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshWorkflowTasksRequest) Descriptor deprecated 

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

Deprecated: Use RefreshWorkflowTasksRequest.ProtoReflect.Descriptor instead.

func (*RefreshWorkflowTasksRequest) Equal 

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

Equal returns whether two RefreshWorkflowTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RefreshWorkflowTasksRequest) GetExecution 

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

func (*RefreshWorkflowTasksRequest) GetNamespaceId added in v1.17.0 

func (x *RefreshWorkflowTasksRequest) GetNamespaceId() string

func (*RefreshWorkflowTasksRequest) Marshal 

func (val *RefreshWorkflowTasksRequest) Marshal() ([]byte, error)

Marshal an object of type RefreshWorkflowTasksRequest to the protobuf v3 wire format

func (*RefreshWorkflowTasksRequest) ProtoMessage 

func (*RefreshWorkflowTasksRequest) ProtoMessage()

func (*RefreshWorkflowTasksRequest) ProtoReflect added in v1.23.0 

func (x *RefreshWorkflowTasksRequest) ProtoReflect() protoreflect.Message

func (*RefreshWorkflowTasksRequest) Reset 

func (x *RefreshWorkflowTasksRequest) Reset()

func (*RefreshWorkflowTasksRequest) Size 

func (val *RefreshWorkflowTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RefreshWorkflowTasksRequest) String 

func (x *RefreshWorkflowTasksRequest) String() string

func (*RefreshWorkflowTasksRequest) Unmarshal 

func (val *RefreshWorkflowTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RefreshWorkflowTasksRequest from the protobuf v3 wire format

type RefreshWorkflowTasksResponse 

type RefreshWorkflowTasksResponse struct {
	// contains filtered or unexported fields
}

func (*RefreshWorkflowTasksResponse) Descriptor deprecated 

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

Deprecated: Use RefreshWorkflowTasksResponse.ProtoReflect.Descriptor instead.

func (*RefreshWorkflowTasksResponse) Equal 

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

Equal returns whether two RefreshWorkflowTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RefreshWorkflowTasksResponse) Marshal 

func (val *RefreshWorkflowTasksResponse) Marshal() ([]byte, error)

Marshal an object of type RefreshWorkflowTasksResponse to the protobuf v3 wire format

func (*RefreshWorkflowTasksResponse) ProtoMessage 

func (*RefreshWorkflowTasksResponse) ProtoMessage()

func (*RefreshWorkflowTasksResponse) ProtoReflect added in v1.23.0 

func (x *RefreshWorkflowTasksResponse) ProtoReflect() protoreflect.Message

func (*RefreshWorkflowTasksResponse) Reset 

func (x *RefreshWorkflowTasksResponse) Reset()

func (*RefreshWorkflowTasksResponse) Size 

func (val *RefreshWorkflowTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RefreshWorkflowTasksResponse) String 

func (x *RefreshWorkflowTasksResponse) String() string

func (*RefreshWorkflowTasksResponse) Unmarshal 

func (val *RefreshWorkflowTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RefreshWorkflowTasksResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*RemoveRemoteClusterRequest) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use RemoveRemoteClusterRequest.ProtoReflect.Descriptor instead.

func (*RemoveRemoteClusterRequest) Equal added in v1.14.0 

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

Equal returns whether two RemoveRemoteClusterRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveRemoteClusterRequest) GetClusterName added in v1.14.0 

func (x *RemoveRemoteClusterRequest) GetClusterName() string

func (*RemoveRemoteClusterRequest) Marshal added in v1.14.0 

func (val *RemoveRemoteClusterRequest) Marshal() ([]byte, error)

Marshal an object of type RemoveRemoteClusterRequest to the protobuf v3 wire format

func (*RemoveRemoteClusterRequest) ProtoMessage added in v1.14.0 

func (*RemoveRemoteClusterRequest) ProtoMessage()

func (*RemoveRemoteClusterRequest) ProtoReflect added in v1.23.0 

func (x *RemoveRemoteClusterRequest) ProtoReflect() protoreflect.Message

func (*RemoveRemoteClusterRequest) Reset added in v1.14.0 

func (x *RemoveRemoteClusterRequest) Reset()

func (*RemoveRemoteClusterRequest) Size added in v1.14.0 

func (val *RemoveRemoteClusterRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveRemoteClusterRequest) String added in v1.14.0 

func (x *RemoveRemoteClusterRequest) String() string

func (*RemoveRemoteClusterRequest) Unmarshal added in v1.14.0 

func (val *RemoveRemoteClusterRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveRemoteClusterRequest from the protobuf v3 wire format

type RemoveRemoteClusterResponse added in v1.14.0 

type RemoveRemoteClusterResponse struct {
	// contains filtered or unexported fields
}

func (*RemoveRemoteClusterResponse) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use RemoveRemoteClusterResponse.ProtoReflect.Descriptor instead.

func (*RemoveRemoteClusterResponse) Equal added in v1.14.0 

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

Equal returns whether two RemoveRemoteClusterResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveRemoteClusterResponse) Marshal added in v1.14.0 

func (val *RemoveRemoteClusterResponse) Marshal() ([]byte, error)

Marshal an object of type RemoveRemoteClusterResponse to the protobuf v3 wire format

func (*RemoveRemoteClusterResponse) ProtoMessage added in v1.14.0 

func (*RemoveRemoteClusterResponse) ProtoMessage()

func (*RemoveRemoteClusterResponse) ProtoReflect added in v1.23.0 

func (x *RemoveRemoteClusterResponse) ProtoReflect() protoreflect.Message

func (*RemoveRemoteClusterResponse) Reset added in v1.14.0 

func (x *RemoveRemoteClusterResponse) Reset()

func (*RemoveRemoteClusterResponse) Size added in v1.14.0 

func (val *RemoveRemoteClusterResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveRemoteClusterResponse) String added in v1.14.0 

func (x *RemoveRemoteClusterResponse) String() string

func (*RemoveRemoteClusterResponse) Unmarshal added in v1.14.0 

func (val *RemoveRemoteClusterResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveRemoteClusterResponse from the protobuf v3 wire format

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"`
	Namespace        string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveSearchAttributesRequest) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use RemoveSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*RemoveSearchAttributesRequest) Equal added in v1.11.0 

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

Equal returns whether two RemoveSearchAttributesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveSearchAttributesRequest) GetIndexName added in v1.11.0 

func (x *RemoveSearchAttributesRequest) GetIndexName() string

func (*RemoveSearchAttributesRequest) GetNamespace added in v1.20.0 

func (x *RemoveSearchAttributesRequest) GetNamespace() string

func (*RemoveSearchAttributesRequest) GetSearchAttributes added in v1.11.0 

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

func (*RemoveSearchAttributesRequest) Marshal added in v1.11.0 

func (val *RemoveSearchAttributesRequest) Marshal() ([]byte, error)

Marshal an object of type RemoveSearchAttributesRequest to the protobuf v3 wire format

func (*RemoveSearchAttributesRequest) ProtoMessage added in v1.11.0 

func (*RemoveSearchAttributesRequest) ProtoMessage()

func (*RemoveSearchAttributesRequest) ProtoReflect added in v1.23.0 

func (x *RemoveSearchAttributesRequest) ProtoReflect() protoreflect.Message

func (*RemoveSearchAttributesRequest) Reset added in v1.11.0 

func (x *RemoveSearchAttributesRequest) Reset()

func (*RemoveSearchAttributesRequest) Size added in v1.11.0 

func (val *RemoveSearchAttributesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveSearchAttributesRequest) String added in v1.11.0 

func (x *RemoveSearchAttributesRequest) String() string

func (*RemoveSearchAttributesRequest) Unmarshal added in v1.11.0 

func (val *RemoveSearchAttributesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveSearchAttributesRequest from the protobuf v3 wire format

type RemoveSearchAttributesResponse added in v1.11.0 

type RemoveSearchAttributesResponse struct {
	// contains filtered or unexported fields
}

func (*RemoveSearchAttributesResponse) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use RemoveSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*RemoveSearchAttributesResponse) Equal added in v1.11.0 

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

Equal returns whether two RemoveSearchAttributesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveSearchAttributesResponse) Marshal added in v1.11.0 

func (val *RemoveSearchAttributesResponse) Marshal() ([]byte, error)

Marshal an object of type RemoveSearchAttributesResponse to the protobuf v3 wire format

func (*RemoveSearchAttributesResponse) ProtoMessage added in v1.11.0 

func (*RemoveSearchAttributesResponse) ProtoMessage()

func (*RemoveSearchAttributesResponse) ProtoReflect added in v1.23.0 

func (x *RemoveSearchAttributesResponse) ProtoReflect() protoreflect.Message

func (*RemoveSearchAttributesResponse) Reset added in v1.11.0 

func (x *RemoveSearchAttributesResponse) Reset()

func (*RemoveSearchAttributesResponse) Size added in v1.11.0 

func (val *RemoveSearchAttributesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveSearchAttributesResponse) String added in v1.11.0 

func (x *RemoveSearchAttributesResponse) String() string

func (*RemoveSearchAttributesResponse) Unmarshal added in v1.11.0 

func (val *RemoveSearchAttributesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveSearchAttributesResponse from the protobuf v3 wire format

type RemoveTaskRequest 

type RemoveTaskRequest struct {
	ShardId int32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// The task category. See tasks.TaskCategoryRegistry for more.
	Category       int32                  `protobuf:"varint,2,opt,name=category,proto3" json:"category,omitempty"`
	TaskId         int64                  `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	VisibilityTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=visibility_time,json=visibilityTime,proto3" json:"visibility_time,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveTaskRequest) Descriptor deprecated 

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

Deprecated: Use RemoveTaskRequest.ProtoReflect.Descriptor instead.

func (*RemoveTaskRequest) Equal 

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

Equal returns whether two RemoveTaskRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveTaskRequest) GetCategory 

func (x *RemoveTaskRequest) GetCategory() int32

func (*RemoveTaskRequest) GetShardId 

func (x *RemoveTaskRequest) GetShardId() int32

func (*RemoveTaskRequest) GetTaskId 

func (x *RemoveTaskRequest) GetTaskId() int64

func (*RemoveTaskRequest) GetVisibilityTime added in v0.28.0 

func (x *RemoveTaskRequest) GetVisibilityTime() *timestamppb.Timestamp

func (*RemoveTaskRequest) Marshal 

func (val *RemoveTaskRequest) Marshal() ([]byte, error)

Marshal an object of type RemoveTaskRequest to the protobuf v3 wire format

func (*RemoveTaskRequest) ProtoMessage 

func (*RemoveTaskRequest) ProtoMessage()

func (*RemoveTaskRequest) ProtoReflect added in v1.23.0 

func (x *RemoveTaskRequest) ProtoReflect() protoreflect.Message

func (*RemoveTaskRequest) Reset 

func (x *RemoveTaskRequest) Reset()

func (*RemoveTaskRequest) Size 

func (val *RemoveTaskRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveTaskRequest) String 

func (x *RemoveTaskRequest) String() string

func (*RemoveTaskRequest) Unmarshal 

func (val *RemoveTaskRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveTaskRequest from the protobuf v3 wire format

type RemoveTaskResponse 

type RemoveTaskResponse struct {
	// contains filtered or unexported fields
}

func (*RemoveTaskResponse) Descriptor deprecated 

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

Deprecated: Use RemoveTaskResponse.ProtoReflect.Descriptor instead.

func (*RemoveTaskResponse) Equal 

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

Equal returns whether two RemoveTaskResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RemoveTaskResponse) Marshal 

func (val *RemoveTaskResponse) Marshal() ([]byte, error)

Marshal an object of type RemoveTaskResponse to the protobuf v3 wire format

func (*RemoveTaskResponse) ProtoMessage 

func (*RemoveTaskResponse) ProtoMessage()

func (*RemoveTaskResponse) ProtoReflect added in v1.23.0 

func (x *RemoveTaskResponse) ProtoReflect() protoreflect.Message

func (*RemoveTaskResponse) Reset 

func (x *RemoveTaskResponse) Reset()

func (*RemoveTaskResponse) Size 

func (val *RemoveTaskResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RemoveTaskResponse) String 

func (x *RemoveTaskResponse) String() string

func (*RemoveTaskResponse) Unmarshal 

func (val *RemoveTaskResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RemoveTaskResponse from the protobuf v3 wire format

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"`
	// contains filtered or unexported fields
}

func (*ResendReplicationTasksRequest) Descriptor deprecated 

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

Deprecated: Use ResendReplicationTasksRequest.ProtoReflect.Descriptor instead.

func (*ResendReplicationTasksRequest) Equal 

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

Equal returns whether two ResendReplicationTasksRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ResendReplicationTasksRequest) GetEndEventId 

func (x *ResendReplicationTasksRequest) GetEndEventId() int64

func (*ResendReplicationTasksRequest) GetEndVersion 

func (x *ResendReplicationTasksRequest) GetEndVersion() int64

func (*ResendReplicationTasksRequest) GetNamespaceId 

func (x *ResendReplicationTasksRequest) GetNamespaceId() string

func (*ResendReplicationTasksRequest) GetRemoteCluster 

func (x *ResendReplicationTasksRequest) GetRemoteCluster() string

func (*ResendReplicationTasksRequest) GetRunId 

func (x *ResendReplicationTasksRequest) GetRunId() string

func (*ResendReplicationTasksRequest) GetStartEventId 

func (x *ResendReplicationTasksRequest) GetStartEventId() int64

func (*ResendReplicationTasksRequest) GetStartVersion 

func (x *ResendReplicationTasksRequest) GetStartVersion() int64

func (*ResendReplicationTasksRequest) GetWorkflowId 

func (x *ResendReplicationTasksRequest) GetWorkflowId() string

func (*ResendReplicationTasksRequest) Marshal 

func (val *ResendReplicationTasksRequest) Marshal() ([]byte, error)

Marshal an object of type ResendReplicationTasksRequest to the protobuf v3 wire format

func (*ResendReplicationTasksRequest) ProtoMessage 

func (*ResendReplicationTasksRequest) ProtoMessage()

func (*ResendReplicationTasksRequest) ProtoReflect added in v1.23.0 

func (x *ResendReplicationTasksRequest) ProtoReflect() protoreflect.Message

func (*ResendReplicationTasksRequest) Reset 

func (x *ResendReplicationTasksRequest) Reset()

func (*ResendReplicationTasksRequest) Size 

func (val *ResendReplicationTasksRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ResendReplicationTasksRequest) String 

func (x *ResendReplicationTasksRequest) String() string

func (*ResendReplicationTasksRequest) Unmarshal 

func (val *ResendReplicationTasksRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ResendReplicationTasksRequest from the protobuf v3 wire format

type ResendReplicationTasksResponse 

type ResendReplicationTasksResponse struct {
	// contains filtered or unexported fields
}

func (*ResendReplicationTasksResponse) Descriptor deprecated 

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

Deprecated: Use ResendReplicationTasksResponse.ProtoReflect.Descriptor instead.

func (*ResendReplicationTasksResponse) Equal 

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

Equal returns whether two ResendReplicationTasksResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ResendReplicationTasksResponse) Marshal 

func (val *ResendReplicationTasksResponse) Marshal() ([]byte, error)

Marshal an object of type ResendReplicationTasksResponse to the protobuf v3 wire format

func (*ResendReplicationTasksResponse) ProtoMessage 

func (*ResendReplicationTasksResponse) ProtoMessage()

func (*ResendReplicationTasksResponse) ProtoReflect added in v1.23.0 

func (x *ResendReplicationTasksResponse) ProtoReflect() protoreflect.Message

func (*ResendReplicationTasksResponse) Reset 

func (x *ResendReplicationTasksResponse) Reset()

func (*ResendReplicationTasksResponse) Size 

func (val *ResendReplicationTasksResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ResendReplicationTasksResponse) String 

func (x *ResendReplicationTasksResponse) String() string

func (*ResendReplicationTasksResponse) Unmarshal 

func (val *ResendReplicationTasksResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ResendReplicationTasksResponse from the protobuf v3 wire format

type StreamWorkflowReplicationMessagesRequest added in v1.21.0 

type StreamWorkflowReplicationMessagesRequest struct {

	// Types that are assignable to Attributes:
	//
	//	*StreamWorkflowReplicationMessagesRequest_SyncReplicationState
	Attributes isStreamWorkflowReplicationMessagesRequest_Attributes `protobuf_oneof:"attributes"`
	// contains filtered or unexported fields
}

func (*StreamWorkflowReplicationMessagesRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use StreamWorkflowReplicationMessagesRequest.ProtoReflect.Descriptor instead.

func (*StreamWorkflowReplicationMessagesRequest) Equal added in v1.21.0 

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

Equal returns whether two StreamWorkflowReplicationMessagesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StreamWorkflowReplicationMessagesRequest) GetAttributes added in v1.21.0 

func (m *StreamWorkflowReplicationMessagesRequest) GetAttributes() isStreamWorkflowReplicationMessagesRequest_Attributes

func (*StreamWorkflowReplicationMessagesRequest) GetSyncReplicationState added in v1.21.0 

func (x *StreamWorkflowReplicationMessagesRequest) GetSyncReplicationState() *v15.SyncReplicationState

func (*StreamWorkflowReplicationMessagesRequest) Marshal added in v1.21.0 

func (val *StreamWorkflowReplicationMessagesRequest) Marshal() ([]byte, error)

Marshal an object of type StreamWorkflowReplicationMessagesRequest to the protobuf v3 wire format

func (*StreamWorkflowReplicationMessagesRequest) ProtoMessage added in v1.21.0 

func (*StreamWorkflowReplicationMessagesRequest) ProtoMessage()

func (*StreamWorkflowReplicationMessagesRequest) ProtoReflect added in v1.23.0 

func (x *StreamWorkflowReplicationMessagesRequest) ProtoReflect() protoreflect.Message

func (*StreamWorkflowReplicationMessagesRequest) Reset added in v1.21.0 

func (x *StreamWorkflowReplicationMessagesRequest) Reset()

func (*StreamWorkflowReplicationMessagesRequest) Size added in v1.21.0 

func (val *StreamWorkflowReplicationMessagesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StreamWorkflowReplicationMessagesRequest) String added in v1.21.0 

func (x *StreamWorkflowReplicationMessagesRequest) String() string

func (*StreamWorkflowReplicationMessagesRequest) Unmarshal added in v1.21.0 

func (val *StreamWorkflowReplicationMessagesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type StreamWorkflowReplicationMessagesRequest from the protobuf v3 wire format

type StreamWorkflowReplicationMessagesRequest_SyncReplicationState added in v1.21.0 

type StreamWorkflowReplicationMessagesRequest_SyncReplicationState struct {
	SyncReplicationState *v15.SyncReplicationState `protobuf:"bytes,1,opt,name=sync_replication_state,json=syncReplicationState,proto3,oneof"`
}

type StreamWorkflowReplicationMessagesResponse added in v1.21.0 

type StreamWorkflowReplicationMessagesResponse struct {

	// Types that are assignable to Attributes:
	//
	//	*StreamWorkflowReplicationMessagesResponse_Messages
	Attributes isStreamWorkflowReplicationMessagesResponse_Attributes `protobuf_oneof:"attributes"`
	// contains filtered or unexported fields
}

func (*StreamWorkflowReplicationMessagesResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use StreamWorkflowReplicationMessagesResponse.ProtoReflect.Descriptor instead.

func (*StreamWorkflowReplicationMessagesResponse) Equal added in v1.21.0 

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

Equal returns whether two StreamWorkflowReplicationMessagesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*StreamWorkflowReplicationMessagesResponse) GetAttributes added in v1.21.0 

func (m *StreamWorkflowReplicationMessagesResponse) GetAttributes() isStreamWorkflowReplicationMessagesResponse_Attributes

func (*StreamWorkflowReplicationMessagesResponse) GetMessages added in v1.21.0 

func (x *StreamWorkflowReplicationMessagesResponse) GetMessages() *v15.WorkflowReplicationMessages

func (*StreamWorkflowReplicationMessagesResponse) Marshal added in v1.21.0 

func (val *StreamWorkflowReplicationMessagesResponse) Marshal() ([]byte, error)

Marshal an object of type StreamWorkflowReplicationMessagesResponse to the protobuf v3 wire format

func (*StreamWorkflowReplicationMessagesResponse) ProtoMessage added in v1.21.0 

func (*StreamWorkflowReplicationMessagesResponse) ProtoMessage()

func (*StreamWorkflowReplicationMessagesResponse) ProtoReflect added in v1.23.0 

func (x *StreamWorkflowReplicationMessagesResponse) ProtoReflect() protoreflect.Message

func (*StreamWorkflowReplicationMessagesResponse) Reset added in v1.21.0 

func (x *StreamWorkflowReplicationMessagesResponse) Reset()

func (*StreamWorkflowReplicationMessagesResponse) Size added in v1.21.0 

func (val *StreamWorkflowReplicationMessagesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*StreamWorkflowReplicationMessagesResponse) String added in v1.21.0 

func (x *StreamWorkflowReplicationMessagesResponse) String() string

func (*StreamWorkflowReplicationMessagesResponse) Unmarshal added in v1.21.0 

func (val *StreamWorkflowReplicationMessagesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type StreamWorkflowReplicationMessagesResponse from the protobuf v3 wire format

type StreamWorkflowReplicationMessagesResponse_Messages added in v1.21.0 

type StreamWorkflowReplicationMessagesResponse_Messages struct {
	Messages *v15.WorkflowReplicationMessages `protobuf:"bytes,1,opt,name=messages,proto3,oneof"`
}

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    v14.TaskType           `` /* 129-byte string literal not displayed */
	FireTime    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=fire_time,json=fireTime,proto3" json:"fire_time,omitempty"`
	Version     int64                  `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) Equal added in v1.14.0 

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

Equal returns whether two Task values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*Task) GetFireTime added in v1.14.0 

func (x *Task) GetFireTime() *timestamppb.Timestamp

func (*Task) GetNamespaceId added in v1.14.0 

func (x *Task) GetNamespaceId() string

func (*Task) GetRunId added in v1.14.0 

func (x *Task) GetRunId() string

func (*Task) GetTaskId added in v1.14.0 

func (x *Task) GetTaskId() int64

func (*Task) GetTaskType added in v1.14.0 

func (x *Task) GetTaskType() v14.TaskType

func (*Task) GetVersion added in v1.14.0 

func (x *Task) GetVersion() int64

func (*Task) GetWorkflowId added in v1.14.0 

func (x *Task) GetWorkflowId() string

func (*Task) Marshal added in v1.14.0 

func (val *Task) Marshal() ([]byte, error)

Marshal an object of type Task to the protobuf v3 wire format

func (*Task) ProtoMessage added in v1.14.0 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect added in v1.23.0 

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset added in v1.14.0 

func (x *Task) Reset()

func (*Task) Size added in v1.14.0 

func (val *Task) Size() int

Size returns the size of the object, in bytes, once serialized

func (*Task) String added in v1.14.0 

func (x *Task) String() string

func (*Task) Unmarshal added in v1.14.0 

func (val *Task) Unmarshal(buf []byte) error

Unmarshal an object of type Task from the protobuf v3 wire format

type UnimplementedAdminServiceServer 

type UnimplementedAdminServiceServer struct {
}

UnimplementedAdminServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAdminServiceServer) AddOrUpdateRemoteCluster added in v1.14.0 

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

func (UnimplementedAdminServiceServer) AddSearchAttributes added in v1.10.0 

func (UnimplementedAdminServiceServer) AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

func (UnimplementedAdminServiceServer) AddTasks added in v1.23.0 

func (UnimplementedAdminServiceServer) AddTasks(context.Context, *AddTasksRequest) (*AddTasksResponse, error)

func (UnimplementedAdminServiceServer) CancelDLQJob added in v1.23.0 

func (UnimplementedAdminServiceServer) CancelDLQJob(context.Context, *CancelDLQJobRequest) (*CancelDLQJobResponse, error)

func (UnimplementedAdminServiceServer) CloseShard 

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

func (UnimplementedAdminServiceServer) DeleteWorkflowExecution added in v1.17.0 

func (UnimplementedAdminServiceServer) DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)

func (UnimplementedAdminServiceServer) DescribeCluster 

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

func (UnimplementedAdminServiceServer) DescribeDLQJob added in v1.23.0 

func (UnimplementedAdminServiceServer) DescribeDLQJob(context.Context, *DescribeDLQJobRequest) (*DescribeDLQJobResponse, error)

func (UnimplementedAdminServiceServer) DescribeHistoryHost 

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

func (UnimplementedAdminServiceServer) DescribeMutableState added in v1.3.0 

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

func (UnimplementedAdminServiceServer) GetDLQMessages 

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

func (UnimplementedAdminServiceServer) GetDLQReplicationMessages 

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

func (UnimplementedAdminServiceServer) GetDLQTasks added in v1.23.0 

func (UnimplementedAdminServiceServer) GetDLQTasks(context.Context, *GetDLQTasksRequest) (*GetDLQTasksResponse, error)

func (UnimplementedAdminServiceServer) GetNamespace added in v1.22.0 

func (UnimplementedAdminServiceServer) GetNamespace(context.Context, *GetNamespaceRequest) (*GetNamespaceResponse, error)

func (UnimplementedAdminServiceServer) GetNamespaceReplicationMessages 

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

func (UnimplementedAdminServiceServer) GetReplicationMessages 

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

func (UnimplementedAdminServiceServer) GetSearchAttributes added in v1.10.0 

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

func (UnimplementedAdminServiceServer) GetShard added in v1.14.0 

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

func (UnimplementedAdminServiceServer) GetTaskQueueTasks added in v1.14.0 

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

func (UnimplementedAdminServiceServer) GetWorkflowExecutionRawHistory 

func (UnimplementedAdminServiceServer) GetWorkflowExecutionRawHistory(context.Context, *GetWorkflowExecutionRawHistoryRequest) (*GetWorkflowExecutionRawHistoryResponse, error)

func (UnimplementedAdminServiceServer) GetWorkflowExecutionRawHistoryV2 

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

func (UnimplementedAdminServiceServer) ImportWorkflowExecution added in v1.23.0 

func (UnimplementedAdminServiceServer) ImportWorkflowExecution(context.Context, *ImportWorkflowExecutionRequest) (*ImportWorkflowExecutionResponse, error)

func (UnimplementedAdminServiceServer) ListClusterMembers added in v1.14.0 

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

func (UnimplementedAdminServiceServer) ListClusters added in v1.15.0 

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

func (UnimplementedAdminServiceServer) ListHistoryTasks added in v1.16.0 

func (UnimplementedAdminServiceServer) ListHistoryTasks(context.Context, *ListHistoryTasksRequest) (*ListHistoryTasksResponse, error)

func (UnimplementedAdminServiceServer) ListQueues added in v1.23.0 

func (UnimplementedAdminServiceServer) ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)

func (UnimplementedAdminServiceServer) MergeDLQMessages 

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

func (UnimplementedAdminServiceServer) MergeDLQTasks added in v1.23.0 

func (UnimplementedAdminServiceServer) MergeDLQTasks(context.Context, *MergeDLQTasksRequest) (*MergeDLQTasksResponse, error)

func (UnimplementedAdminServiceServer) PurgeDLQMessages 

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

func (UnimplementedAdminServiceServer) PurgeDLQTasks added in v1.23.0 

func (UnimplementedAdminServiceServer) PurgeDLQTasks(context.Context, *PurgeDLQTasksRequest) (*PurgeDLQTasksResponse, error)

func (UnimplementedAdminServiceServer) ReapplyEvents 

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

func (UnimplementedAdminServiceServer) RebuildMutableState added in v1.16.0 

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

func (UnimplementedAdminServiceServer) RefreshWorkflowTasks 

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

func (UnimplementedAdminServiceServer) RemoveRemoteCluster added in v1.14.0 

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

func (UnimplementedAdminServiceServer) RemoveSearchAttributes added in v1.11.0 

func (UnimplementedAdminServiceServer) RemoveSearchAttributes(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)

func (UnimplementedAdminServiceServer) RemoveTask 

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

func (UnimplementedAdminServiceServer) ResendReplicationTasks 

func (UnimplementedAdminServiceServer) ResendReplicationTasks(context.Context, *ResendReplicationTasksRequest) (*ResendReplicationTasksResponse, error)

func (UnimplementedAdminServiceServer) StreamWorkflowReplicationMessages added in v1.21.0 

func (UnimplementedAdminServiceServer) StreamWorkflowReplicationMessages(AdminService_StreamWorkflowReplicationMessagesServer) error

type UnsafeAdminServiceServer added in v1.23.0 

type UnsafeAdminServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeAdminServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServiceServer will result in compilation errors.

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.