adminservice

package
v1.9.4 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2026 License: MIT Imports: 29 Imported by: 0

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_StartAdminBatchOperation_FullMethodName            = "/temporal.server.api.adminservice.v1.AdminService/StartAdminBatchOperation"
	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"
	AdminService_DeepHealthCheck_FullMethodName                     = "/temporal.server.api.adminservice.v1.AdminService/DeepHealthCheck"
	AdminService_SyncWorkflowState_FullMethodName                   = "/temporal.server.api.adminservice.v1.AdminService/SyncWorkflowState"
	AdminService_GenerateLastHistoryReplicationTasks_FullMethodName = "/temporal.server.api.adminservice.v1.AdminService/GenerateLastHistoryReplicationTasks"
	AdminService_DescribeTaskQueuePartition_FullMethodName          = "/temporal.server.api.adminservice.v1.AdminService/DescribeTaskQueuePartition"
	AdminService_ForceUnloadTaskQueuePartition_FullMethodName       = "/temporal.server.api.adminservice.v1.AdminService/ForceUnloadTaskQueuePartition"
	AdminService_MigrateSchedule_FullMethodName                     = "/temporal.server.api.adminservice.v1.AdminService/MigrateSchedule"
)

Variables

View Source 
var (
	MigrateScheduleRequest_SchedulerTarget_name = map[int32]string{
		0: "SCHEDULER_TARGET_UNSPECIFIED",
		1: "SCHEDULER_TARGET_CHASM",
		2: "SCHEDULER_TARGET_WORKFLOW",
	}
	MigrateScheduleRequest_SchedulerTarget_value = map[string]int32{
		"SCHEDULER_TARGET_UNSPECIFIED": 0,
		"SCHEDULER_TARGET_CHASM":       1,
		"SCHEDULER_TARGET_WORKFLOW":    2,
	}
)

Enum value maps for MigrateScheduleRequest_SchedulerTarget.

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: "StartAdminBatchOperation",
			Handler:    _AdminService_StartAdminBatchOperation_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,
		},
		{
			MethodName: "DeepHealthCheck",
			Handler:    _AdminService_DeepHealthCheck_Handler,
		},
		{
			MethodName: "SyncWorkflowState",
			Handler:    _AdminService_SyncWorkflowState_Handler,
		},
		{
			MethodName: "GenerateLastHistoryReplicationTasks",
			Handler:    _AdminService_GenerateLastHistoryReplicationTasks_Handler,
		},
		{
			MethodName: "DescribeTaskQueuePartition",
			Handler:    _AdminService_DescribeTaskQueuePartition_Handler,
		},
		{
			MethodName: "ForceUnloadTaskQueuePartition",
			Handler:    _AdminService_ForceUnloadTaskQueuePartition_Handler,
		},
		{
			MethodName: "MigrateSchedule",
			Handler:    _AdminService_MigrateSchedule_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 

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 */
	// Deprecated: Marked as deprecated in temporal/server/api/adminservice/v1/request_response.proto.
	FrontendHttpAddress string `protobuf:"bytes,3,opt,name=frontend_http_address,json=frontendHttpAddress,proto3" json:"frontend_http_address,omitempty"`
	// enable_replication controls whether replication streams are active.
	EnableReplication bool `protobuf:"varint,4,opt,name=enable_replication,json=enableReplication,proto3" json:"enable_replication,omitempty"`
	// contains filtered or unexported fields
}

func (*AddOrUpdateRemoteClusterRequest) Descriptor deprecated 

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

Deprecated: Use AddOrUpdateRemoteClusterRequest.ProtoReflect.Descriptor instead.

func (*AddOrUpdateRemoteClusterRequest) Equal 

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 

func (x *AddOrUpdateRemoteClusterRequest) GetEnableRemoteClusterConnection() bool

func (*AddOrUpdateRemoteClusterRequest) GetEnableReplication 

func (x *AddOrUpdateRemoteClusterRequest) GetEnableReplication() bool

func (*AddOrUpdateRemoteClusterRequest) GetFrontendAddress 

func (x *AddOrUpdateRemoteClusterRequest) GetFrontendAddress() string

func (*AddOrUpdateRemoteClusterRequest) GetFrontendHttpAddress deprecated 

func (x *AddOrUpdateRemoteClusterRequest) GetFrontendHttpAddress() string

Deprecated: Marked as deprecated in temporal/server/api/adminservice/v1/request_response.proto.

func (*AddOrUpdateRemoteClusterRequest) Marshal 

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

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

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage 

func (*AddOrUpdateRemoteClusterRequest) ProtoMessage()

func (*AddOrUpdateRemoteClusterRequest) ProtoReflect 

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

func (*AddOrUpdateRemoteClusterRequest) Reset 

func (x *AddOrUpdateRemoteClusterRequest) Reset()

func (*AddOrUpdateRemoteClusterRequest) Size 

func (val *AddOrUpdateRemoteClusterRequest) Size() int

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

func (*AddOrUpdateRemoteClusterRequest) String 

func (x *AddOrUpdateRemoteClusterRequest) String() string

func (*AddOrUpdateRemoteClusterRequest) Unmarshal 

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

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

type AddOrUpdateRemoteClusterResponse 

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

func (*AddOrUpdateRemoteClusterResponse) Descriptor deprecated 

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

Deprecated: Use AddOrUpdateRemoteClusterResponse.ProtoReflect.Descriptor instead.

func (*AddOrUpdateRemoteClusterResponse) Equal 

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 

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

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

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage 

func (*AddOrUpdateRemoteClusterResponse) ProtoMessage()

func (*AddOrUpdateRemoteClusterResponse) ProtoReflect 

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

func (*AddOrUpdateRemoteClusterResponse) Reset 

func (x *AddOrUpdateRemoteClusterResponse) Reset()

func (*AddOrUpdateRemoteClusterResponse) Size 

func (val *AddOrUpdateRemoteClusterResponse) Size() int

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

func (*AddOrUpdateRemoteClusterResponse) String 

func (x *AddOrUpdateRemoteClusterResponse) String() string

func (*AddOrUpdateRemoteClusterResponse) Unmarshal 

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

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

type AddSearchAttributesRequest 

type AddSearchAttributesRequest struct {
	SearchAttributes map[string]v16.IndexedValueType `` /* 228-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 

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

Deprecated: Use AddSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*AddSearchAttributesRequest) Equal 

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 

func (x *AddSearchAttributesRequest) GetIndexName() string

func (*AddSearchAttributesRequest) GetNamespace 

func (x *AddSearchAttributesRequest) GetNamespace() string

func (*AddSearchAttributesRequest) GetSearchAttributes 

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

func (*AddSearchAttributesRequest) GetSkipSchemaUpdate 

func (x *AddSearchAttributesRequest) GetSkipSchemaUpdate() bool

func (*AddSearchAttributesRequest) Marshal 

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

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

func (*AddSearchAttributesRequest) ProtoMessage 

func (*AddSearchAttributesRequest) ProtoMessage()

func (*AddSearchAttributesRequest) ProtoReflect 

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

func (*AddSearchAttributesRequest) Reset 

func (x *AddSearchAttributesRequest) Reset()

func (*AddSearchAttributesRequest) Size 

func (val *AddSearchAttributesRequest) Size() int

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

func (*AddSearchAttributesRequest) String 

func (x *AddSearchAttributesRequest) String() string

func (*AddSearchAttributesRequest) Unmarshal 

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

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

type AddSearchAttributesResponse 

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

func (*AddSearchAttributesResponse) Descriptor deprecated 

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

Deprecated: Use AddSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*AddSearchAttributesResponse) Equal 

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 

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

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

func (*AddSearchAttributesResponse) ProtoMessage 

func (*AddSearchAttributesResponse) ProtoMessage()

func (*AddSearchAttributesResponse) ProtoReflect 

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

func (*AddSearchAttributesResponse) Reset 

func (x *AddSearchAttributesResponse) Reset()

func (*AddSearchAttributesResponse) Size 

func (val *AddSearchAttributesResponse) Size() int

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

func (*AddSearchAttributesResponse) String 

func (x *AddSearchAttributesResponse) String() string

func (*AddSearchAttributesResponse) Unmarshal 

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

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

type AddTasksRequest 

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 

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

Deprecated: Use AddTasksRequest.ProtoReflect.Descriptor instead.

func (*AddTasksRequest) Equal 

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 

func (x *AddTasksRequest) GetShardId() int32

func (*AddTasksRequest) GetTasks 

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

func (*AddTasksRequest) Marshal 

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

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

func (*AddTasksRequest) ProtoMessage 

func (*AddTasksRequest) ProtoMessage()

func (*AddTasksRequest) ProtoReflect 

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

func (*AddTasksRequest) Reset 

func (x *AddTasksRequest) Reset()

func (*AddTasksRequest) Size 

func (val *AddTasksRequest) Size() int

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

func (*AddTasksRequest) String 

func (x *AddTasksRequest) String() string

func (*AddTasksRequest) Unmarshal 

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

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

type AddTasksRequest_Task 

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 

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

Deprecated: Use AddTasksRequest_Task.ProtoReflect.Descriptor instead.

func (*AddTasksRequest_Task) GetBlob 

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

func (*AddTasksRequest_Task) GetCategoryId 

func (x *AddTasksRequest_Task) GetCategoryId() int32

func (*AddTasksRequest_Task) ProtoMessage 

func (*AddTasksRequest_Task) ProtoMessage()

func (*AddTasksRequest_Task) ProtoReflect 

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

func (*AddTasksRequest_Task) Reset 

func (x *AddTasksRequest_Task) Reset()

func (*AddTasksRequest_Task) String 

func (x *AddTasksRequest_Task) String() string

type AddTasksResponse 

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

func (*AddTasksResponse) Descriptor deprecated 

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

Deprecated: Use AddTasksResponse.ProtoReflect.Descriptor instead.

func (*AddTasksResponse) Equal 

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 

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

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

func (*AddTasksResponse) ProtoMessage 

func (*AddTasksResponse) ProtoMessage()

func (*AddTasksResponse) ProtoReflect 

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

func (*AddTasksResponse) Reset 

func (x *AddTasksResponse) Reset()

func (*AddTasksResponse) Size 

func (val *AddTasksResponse) Size() int

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

func (*AddTasksResponse) String 

func (x *AddTasksResponse) String() string

func (*AddTasksResponse) Unmarshal 

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)
	// StartAdminBatchOperation starts an admin batch operation. Supports internal operations like RefreshWorkflowTasks.
	StartAdminBatchOperation(ctx context.Context, in *StartAdminBatchOperationRequest, opts ...grpc.CallOption) (*StartAdminBatchOperationResponse, 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)
	DeepHealthCheck(ctx context.Context, in *DeepHealthCheckRequest, opts ...grpc.CallOption) (*DeepHealthCheckResponse, error)
	SyncWorkflowState(ctx context.Context, in *SyncWorkflowStateRequest, opts ...grpc.CallOption) (*SyncWorkflowStateResponse, error)
	GenerateLastHistoryReplicationTasks(ctx context.Context, in *GenerateLastHistoryReplicationTasksRequest, opts ...grpc.CallOption) (*GenerateLastHistoryReplicationTasksResponse, error)
	DescribeTaskQueuePartition(ctx context.Context, in *DescribeTaskQueuePartitionRequest, opts ...grpc.CallOption) (*DescribeTaskQueuePartitionResponse, error)
	ForceUnloadTaskQueuePartition(ctx context.Context, in *ForceUnloadTaskQueuePartitionRequest, opts ...grpc.CallOption) (*ForceUnloadTaskQueuePartitionResponse, error)
	// MigrateSchedule migrates a schedule between V1 (workflow-backed) and V2 (CHASM-backed) implementations.
	MigrateSchedule(ctx context.Context, in *MigrateScheduleRequest, opts ...grpc.CallOption) (*MigrateScheduleResponse, 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)
	// StartAdminBatchOperation starts an admin batch operation. Supports internal operations like RefreshWorkflowTasks.
	StartAdminBatchOperation(context.Context, *StartAdminBatchOperationRequest) (*StartAdminBatchOperationResponse, 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)
	DeepHealthCheck(context.Context, *DeepHealthCheckRequest) (*DeepHealthCheckResponse, error)
	SyncWorkflowState(context.Context, *SyncWorkflowStateRequest) (*SyncWorkflowStateResponse, error)
	GenerateLastHistoryReplicationTasks(context.Context, *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, error)
	DescribeTaskQueuePartition(context.Context, *DescribeTaskQueuePartitionRequest) (*DescribeTaskQueuePartitionResponse, error)
	ForceUnloadTaskQueuePartition(context.Context, *ForceUnloadTaskQueuePartitionRequest) (*ForceUnloadTaskQueuePartitionResponse, error)
	// MigrateSchedule migrates a schedule between V1 (workflow-backed) and V2 (CHASM-backed) implementations.
	MigrateSchedule(context.Context, *MigrateScheduleRequest) (*MigrateScheduleResponse, 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 

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

type AdminService_StreamWorkflowReplicationMessagesServer 

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

type BatchOperationRefreshTasks 

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

BatchOperationRefreshTasks refreshes tasks for batch executions. This regenerates all pending tasks for each execution.

func (*BatchOperationRefreshTasks) Descriptor deprecated 

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

Deprecated: Use BatchOperationRefreshTasks.ProtoReflect.Descriptor instead.

func (*BatchOperationRefreshTasks) Equal 

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

Equal returns whether two BatchOperationRefreshTasks 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 (*BatchOperationRefreshTasks) Marshal 

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

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

func (*BatchOperationRefreshTasks) ProtoMessage 

func (*BatchOperationRefreshTasks) ProtoMessage()

func (*BatchOperationRefreshTasks) ProtoReflect 

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

func (*BatchOperationRefreshTasks) Reset 

func (x *BatchOperationRefreshTasks) Reset()

func (*BatchOperationRefreshTasks) Size 

func (val *BatchOperationRefreshTasks) Size() int

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

func (*BatchOperationRefreshTasks) String 

func (x *BatchOperationRefreshTasks) String() string

func (*BatchOperationRefreshTasks) Unmarshal 

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

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

type CancelDLQJobRequest 

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 

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

Deprecated: Use CancelDLQJobRequest.ProtoReflect.Descriptor instead.

func (*CancelDLQJobRequest) Equal 

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 

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

func (*CancelDLQJobRequest) GetReason 

func (x *CancelDLQJobRequest) GetReason() string

func (*CancelDLQJobRequest) Marshal 

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

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

func (*CancelDLQJobRequest) ProtoMessage 

func (*CancelDLQJobRequest) ProtoMessage()

func (*CancelDLQJobRequest) ProtoReflect 

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

func (*CancelDLQJobRequest) Reset 

func (x *CancelDLQJobRequest) Reset()

func (*CancelDLQJobRequest) Size 

func (val *CancelDLQJobRequest) Size() int

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

func (*CancelDLQJobRequest) String 

func (x *CancelDLQJobRequest) String() string

func (*CancelDLQJobRequest) Unmarshal 

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

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

type CancelDLQJobResponse 

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 

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

Deprecated: Use CancelDLQJobResponse.ProtoReflect.Descriptor instead.

func (*CancelDLQJobResponse) Equal 

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 

func (x *CancelDLQJobResponse) GetCanceled() bool

func (*CancelDLQJobResponse) Marshal 

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

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

func (*CancelDLQJobResponse) ProtoMessage 

func (*CancelDLQJobResponse) ProtoMessage()

func (*CancelDLQJobResponse) ProtoReflect 

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

func (*CancelDLQJobResponse) Reset 

func (x *CancelDLQJobResponse) Reset()

func (*CancelDLQJobResponse) Size 

func (val *CancelDLQJobResponse) Size() int

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

func (*CancelDLQJobResponse) String 

func (x *CancelDLQJobResponse) String() string

func (*CancelDLQJobResponse) Unmarshal 

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 

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 

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 

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 

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

Deprecated: Use DLQJobToken.ProtoReflect.Descriptor instead.

func (*DLQJobToken) Equal 

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 

func (x *DLQJobToken) GetRunId() string

func (*DLQJobToken) GetWorkflowId 

func (x *DLQJobToken) GetWorkflowId() string

func (*DLQJobToken) Marshal 

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

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

func (*DLQJobToken) ProtoMessage 

func (*DLQJobToken) ProtoMessage()

func (*DLQJobToken) ProtoReflect 

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

func (*DLQJobToken) Reset 

func (x *DLQJobToken) Reset()

func (*DLQJobToken) Size 

func (val *DLQJobToken) Size() int

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

func (*DLQJobToken) String 

func (x *DLQJobToken) String() string

func (*DLQJobToken) Unmarshal 

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

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

type DeepHealthCheckRequest 

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

func (*DeepHealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use DeepHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*DeepHealthCheckRequest) Equal 

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

Equal returns whether two DeepHealthCheckRequest 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 (*DeepHealthCheckRequest) Marshal 

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

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

func (*DeepHealthCheckRequest) ProtoMessage 

func (*DeepHealthCheckRequest) ProtoMessage()

func (*DeepHealthCheckRequest) ProtoReflect 

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

func (*DeepHealthCheckRequest) Reset 

func (x *DeepHealthCheckRequest) Reset()

func (*DeepHealthCheckRequest) Size 

func (val *DeepHealthCheckRequest) Size() int

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

func (*DeepHealthCheckRequest) String 

func (x *DeepHealthCheckRequest) String() string

func (*DeepHealthCheckRequest) Unmarshal 

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

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

type DeepHealthCheckResponse 

type DeepHealthCheckResponse struct {
	State v14.HealthState `protobuf:"varint,1,opt,name=state,proto3,enum=temporal.server.api.enums.v1.HealthState" json:"state,omitempty"`
	// Per-service diagnostic details including per-host breakdown.
	Services []*v113.ServiceHealthDetail `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*DeepHealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use DeepHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*DeepHealthCheckResponse) Equal 

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

Equal returns whether two DeepHealthCheckResponse 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 (*DeepHealthCheckResponse) GetServices 

func (x *DeepHealthCheckResponse) GetServices() []*v113.ServiceHealthDetail

func (*DeepHealthCheckResponse) GetState 

func (x *DeepHealthCheckResponse) GetState() v14.HealthState

func (*DeepHealthCheckResponse) Marshal 

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

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

func (*DeepHealthCheckResponse) ProtoMessage 

func (*DeepHealthCheckResponse) ProtoMessage()

func (*DeepHealthCheckResponse) ProtoReflect 

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

func (*DeepHealthCheckResponse) Reset 

func (x *DeepHealthCheckResponse) Reset()

func (*DeepHealthCheckResponse) Size 

func (val *DeepHealthCheckResponse) Size() int

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

func (*DeepHealthCheckResponse) String 

func (x *DeepHealthCheckResponse) String() string

func (*DeepHealthCheckResponse) Unmarshal 

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

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

type DeleteWorkflowExecutionRequest 

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

func (*DeleteWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowExecutionRequest) Equal 

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

func (x *DeleteWorkflowExecutionRequest) GetArchetype() string

func (*DeleteWorkflowExecutionRequest) GetExecution 

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

func (*DeleteWorkflowExecutionRequest) GetNamespace 

func (x *DeleteWorkflowExecutionRequest) GetNamespace() string

func (*DeleteWorkflowExecutionRequest) Marshal 

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

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

func (*DeleteWorkflowExecutionRequest) ProtoMessage 

func (*DeleteWorkflowExecutionRequest) ProtoMessage()

func (*DeleteWorkflowExecutionRequest) ProtoReflect 

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

func (*DeleteWorkflowExecutionRequest) Reset 

func (x *DeleteWorkflowExecutionRequest) Reset()

func (*DeleteWorkflowExecutionRequest) Size 

func (val *DeleteWorkflowExecutionRequest) Size() int

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

func (*DeleteWorkflowExecutionRequest) String 

func (x *DeleteWorkflowExecutionRequest) String() string

func (*DeleteWorkflowExecutionRequest) Unmarshal 

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

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

type DeleteWorkflowExecutionResponse 

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

func (*DeleteWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowExecutionResponse) Equal 

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 

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

func (*DeleteWorkflowExecutionResponse) Marshal 

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

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

func (*DeleteWorkflowExecutionResponse) ProtoMessage 

func (*DeleteWorkflowExecutionResponse) ProtoMessage()

func (*DeleteWorkflowExecutionResponse) ProtoReflect 

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

func (*DeleteWorkflowExecutionResponse) Reset 

func (x *DeleteWorkflowExecutionResponse) Reset()

func (*DeleteWorkflowExecutionResponse) Size 

func (val *DeleteWorkflowExecutionResponse) Size() int

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

func (*DeleteWorkflowExecutionResponse) String 

func (x *DeleteWorkflowExecutionResponse) String() string

func (*DeleteWorkflowExecutionResponse) Unmarshal 

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 

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 

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   `` /* 183-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   `` /* 136-byte string literal not displayed */
	HttpAddress              string              `protobuf:"bytes,14,opt,name=http_address,json=httpAddress,proto3" json:"http_address,omitempty"`
	// 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 

func (x *DescribeClusterResponse) GetClusterId() string

func (*DescribeClusterResponse) GetClusterName 

func (x *DescribeClusterResponse) GetClusterName() string

func (*DescribeClusterResponse) GetFailoverVersionIncrement 

func (x *DescribeClusterResponse) GetFailoverVersionIncrement() int64

func (*DescribeClusterResponse) GetHistoryShardCount 

func (x *DescribeClusterResponse) GetHistoryShardCount() int32

func (*DescribeClusterResponse) GetHttpAddress 

func (x *DescribeClusterResponse) GetHttpAddress() string

func (*DescribeClusterResponse) GetInitialFailoverVersion 

func (x *DescribeClusterResponse) GetInitialFailoverVersion() int64

func (*DescribeClusterResponse) GetIsGlobalNamespaceEnabled 

func (x *DescribeClusterResponse) GetIsGlobalNamespaceEnabled() bool

func (*DescribeClusterResponse) GetMembershipInfo 

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

func (*DescribeClusterResponse) GetPersistenceStore 

func (x *DescribeClusterResponse) GetPersistenceStore() string

func (*DescribeClusterResponse) GetServerVersion 

func (x *DescribeClusterResponse) GetServerVersion() string

func (*DescribeClusterResponse) GetSupportedClients 

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

func (*DescribeClusterResponse) GetTags 

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

func (*DescribeClusterResponse) GetVersionInfo 

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

func (*DescribeClusterResponse) GetVisibilityStore 

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 

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 

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 

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

Deprecated: Use DescribeDLQJobRequest.ProtoReflect.Descriptor instead.

func (*DescribeDLQJobRequest) Equal 

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 

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

func (*DescribeDLQJobRequest) Marshal 

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

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

func (*DescribeDLQJobRequest) ProtoMessage 

func (*DescribeDLQJobRequest) ProtoMessage()

func (*DescribeDLQJobRequest) ProtoReflect 

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

func (*DescribeDLQJobRequest) Reset 

func (x *DescribeDLQJobRequest) Reset()

func (*DescribeDLQJobRequest) Size 

func (val *DescribeDLQJobRequest) Size() int

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

func (*DescribeDLQJobRequest) String 

func (x *DescribeDLQJobRequest) String() string

func (*DescribeDLQJobRequest) Unmarshal 

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

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

type DescribeDLQJobResponse 

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 

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

Deprecated: Use DescribeDLQJobResponse.ProtoReflect.Descriptor instead.

func (*DescribeDLQJobResponse) Equal 

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 

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

func (*DescribeDLQJobResponse) GetEndTime 

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

func (*DescribeDLQJobResponse) GetLastProcessedMessageId 

func (x *DescribeDLQJobResponse) GetLastProcessedMessageId() int64

func (*DescribeDLQJobResponse) GetMaxMessageId 

func (x *DescribeDLQJobResponse) GetMaxMessageId() int64

func (*DescribeDLQJobResponse) GetMessagesProcessed 

func (x *DescribeDLQJobResponse) GetMessagesProcessed() int64

func (*DescribeDLQJobResponse) GetOperationState 

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

func (*DescribeDLQJobResponse) GetOperationType 

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

func (*DescribeDLQJobResponse) GetStartTime 

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

func (*DescribeDLQJobResponse) Marshal 

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

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

func (*DescribeDLQJobResponse) ProtoMessage 

func (*DescribeDLQJobResponse) ProtoMessage()

func (*DescribeDLQJobResponse) ProtoReflect 

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

func (*DescribeDLQJobResponse) Reset 

func (x *DescribeDLQJobResponse) Reset()

func (*DescribeDLQJobResponse) Size 

func (val *DescribeDLQJobResponse) Size() int

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

func (*DescribeDLQJobResponse) String 

func (x *DescribeDLQJobResponse) String() string

func (*DescribeDLQJobResponse) Unmarshal 

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 

func (x *DescribeHistoryHostRequest) GetNamespace() string

func (*DescribeHistoryHostRequest) GetShardId 

func (x *DescribeHistoryHostRequest) GetShardId() int32

func (*DescribeHistoryHostRequest) GetWorkflowExecution 

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 

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 

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 

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 

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"`
	SkipForceReload bool                  `protobuf:"varint,3,opt,name=skip_force_reload,json=skipForceReload,proto3" json:"skip_force_reload,omitempty"`
	Archetype       string                `protobuf:"bytes,4,opt,name=archetype,proto3" json:"archetype,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeMutableStateRequest) Descriptor deprecated 

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

Deprecated: Use DescribeMutableStateRequest.ProtoReflect.Descriptor instead.

func (*DescribeMutableStateRequest) Equal 

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

func (x *DescribeMutableStateRequest) GetArchetype() string

func (*DescribeMutableStateRequest) GetExecution 

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

func (*DescribeMutableStateRequest) GetNamespace 

func (x *DescribeMutableStateRequest) GetNamespace() string

func (*DescribeMutableStateRequest) GetSkipForceReload 

func (x *DescribeMutableStateRequest) GetSkipForceReload() bool

func (*DescribeMutableStateRequest) Marshal 

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

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

func (*DescribeMutableStateRequest) ProtoMessage 

func (*DescribeMutableStateRequest) ProtoMessage()

func (*DescribeMutableStateRequest) ProtoReflect 

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

func (*DescribeMutableStateRequest) Reset 

func (x *DescribeMutableStateRequest) Reset()

func (*DescribeMutableStateRequest) Size 

func (val *DescribeMutableStateRequest) Size() int

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

func (*DescribeMutableStateRequest) String 

func (x *DescribeMutableStateRequest) String() string

func (*DescribeMutableStateRequest) Unmarshal 

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

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

type DescribeMutableStateResponse 

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 is only available when mutable state is in cache.
	CacheMutableState *v12.WorkflowMutableState `protobuf:"bytes,3,opt,name=cache_mutable_state,json=cacheMutableState,proto3" json:"cache_mutable_state,omitempty"`
	// DatabaseMutableState is always available,
	// but only loaded from database when mutable state is NOT in cache or skip_force_reload is false.
	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 

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

Deprecated: Use DescribeMutableStateResponse.ProtoReflect.Descriptor instead.

func (*DescribeMutableStateResponse) Equal 

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 

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

func (*DescribeMutableStateResponse) GetDatabaseMutableState 

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

func (*DescribeMutableStateResponse) GetHistoryAddr 

func (x *DescribeMutableStateResponse) GetHistoryAddr() string

func (*DescribeMutableStateResponse) GetShardId 

func (x *DescribeMutableStateResponse) GetShardId() string

func (*DescribeMutableStateResponse) Marshal 

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

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

func (*DescribeMutableStateResponse) ProtoMessage 

func (*DescribeMutableStateResponse) ProtoMessage()

func (*DescribeMutableStateResponse) ProtoReflect 

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

func (*DescribeMutableStateResponse) Reset 

func (x *DescribeMutableStateResponse) Reset()

func (*DescribeMutableStateResponse) Size 

func (val *DescribeMutableStateResponse) Size() int

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

func (*DescribeMutableStateResponse) String 

func (x *DescribeMutableStateResponse) String() string

func (*DescribeMutableStateResponse) Unmarshal 

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

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

type DescribeTaskQueuePartitionRequest 

type DescribeTaskQueuePartitionRequest struct {
	Namespace          string                   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueuePartition *v114.TaskQueuePartition `protobuf:"bytes,2,opt,name=task_queue_partition,json=taskQueuePartition,proto3" json:"task_queue_partition,omitempty"`
	// Absent means unversioned queue. Ignored for sticky partitions.
	BuildIds *v115.TaskQueueVersionSelection `protobuf:"bytes,3,opt,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskQueuePartitionRequest) Descriptor deprecated 

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

Deprecated: Use DescribeTaskQueuePartitionRequest.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueuePartitionRequest) Equal 

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

Equal returns whether two DescribeTaskQueuePartitionRequest 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 (*DescribeTaskQueuePartitionRequest) GetBuildIds 

func (x *DescribeTaskQueuePartitionRequest) GetBuildIds() *v115.TaskQueueVersionSelection

func (*DescribeTaskQueuePartitionRequest) GetNamespace 

func (x *DescribeTaskQueuePartitionRequest) GetNamespace() string

func (*DescribeTaskQueuePartitionRequest) GetTaskQueuePartition 

func (x *DescribeTaskQueuePartitionRequest) GetTaskQueuePartition() *v114.TaskQueuePartition

func (*DescribeTaskQueuePartitionRequest) Marshal 

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

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

func (*DescribeTaskQueuePartitionRequest) ProtoMessage 

func (*DescribeTaskQueuePartitionRequest) ProtoMessage()

func (*DescribeTaskQueuePartitionRequest) ProtoReflect 

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

func (*DescribeTaskQueuePartitionRequest) Reset 

func (x *DescribeTaskQueuePartitionRequest) Reset()

func (*DescribeTaskQueuePartitionRequest) Size 

func (val *DescribeTaskQueuePartitionRequest) Size() int

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

func (*DescribeTaskQueuePartitionRequest) String 

func (x *DescribeTaskQueuePartitionRequest) String() string

func (*DescribeTaskQueuePartitionRequest) Unmarshal 

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

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

type DescribeTaskQueuePartitionResponse 

type DescribeTaskQueuePartitionResponse struct {

	// contains k-v pairs of the type: buildID -> TaskQueueVersionInfoInternal
	VersionsInfoInternal map[string]*v114.TaskQueueVersionInfoInternal `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DescribeTaskQueuePartitionResponse) Descriptor deprecated 

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

Deprecated: Use DescribeTaskQueuePartitionResponse.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueuePartitionResponse) Equal 

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

Equal returns whether two DescribeTaskQueuePartitionResponse 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 (*DescribeTaskQueuePartitionResponse) GetVersionsInfoInternal 

func (x *DescribeTaskQueuePartitionResponse) GetVersionsInfoInternal() map[string]*v114.TaskQueueVersionInfoInternal

func (*DescribeTaskQueuePartitionResponse) Marshal 

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

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

func (*DescribeTaskQueuePartitionResponse) ProtoMessage 

func (*DescribeTaskQueuePartitionResponse) ProtoMessage()

func (*DescribeTaskQueuePartitionResponse) ProtoReflect 

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

func (*DescribeTaskQueuePartitionResponse) Reset 

func (x *DescribeTaskQueuePartitionResponse) Reset()

func (*DescribeTaskQueuePartitionResponse) Size 

func (val *DescribeTaskQueuePartitionResponse) Size() int

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

func (*DescribeTaskQueuePartitionResponse) String 

func (x *DescribeTaskQueuePartitionResponse) String() string

func (*DescribeTaskQueuePartitionResponse) Unmarshal 

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

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

type ForceUnloadTaskQueuePartitionRequest 

type ForceUnloadTaskQueuePartitionRequest struct {
	Namespace          string                   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueuePartition *v114.TaskQueuePartition `protobuf:"bytes,2,opt,name=task_queue_partition,json=taskQueuePartition,proto3" json:"task_queue_partition,omitempty"`
	// contains filtered or unexported fields
}

func (*ForceUnloadTaskQueuePartitionRequest) Descriptor deprecated 

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

Deprecated: Use ForceUnloadTaskQueuePartitionRequest.ProtoReflect.Descriptor instead.

func (*ForceUnloadTaskQueuePartitionRequest) Equal 

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

Equal returns whether two ForceUnloadTaskQueuePartitionRequest 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 (*ForceUnloadTaskQueuePartitionRequest) GetNamespace 

func (x *ForceUnloadTaskQueuePartitionRequest) GetNamespace() string

func (*ForceUnloadTaskQueuePartitionRequest) GetTaskQueuePartition 

func (x *ForceUnloadTaskQueuePartitionRequest) GetTaskQueuePartition() *v114.TaskQueuePartition

func (*ForceUnloadTaskQueuePartitionRequest) Marshal 

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

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

func (*ForceUnloadTaskQueuePartitionRequest) ProtoMessage 

func (*ForceUnloadTaskQueuePartitionRequest) ProtoMessage()

func (*ForceUnloadTaskQueuePartitionRequest) ProtoReflect 

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

func (*ForceUnloadTaskQueuePartitionRequest) Reset 

func (x *ForceUnloadTaskQueuePartitionRequest) Reset()

func (*ForceUnloadTaskQueuePartitionRequest) Size 

func (val *ForceUnloadTaskQueuePartitionRequest) Size() int

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

func (*ForceUnloadTaskQueuePartitionRequest) String 

func (x *ForceUnloadTaskQueuePartitionRequest) String() string

func (*ForceUnloadTaskQueuePartitionRequest) Unmarshal 

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

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

type ForceUnloadTaskQueuePartitionResponse 

type ForceUnloadTaskQueuePartitionResponse struct {
	WasLoaded bool `protobuf:"varint,1,opt,name=was_loaded,json=wasLoaded,proto3" json:"was_loaded,omitempty"`
	// contains filtered or unexported fields
}

func (*ForceUnloadTaskQueuePartitionResponse) Descriptor deprecated 

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

Deprecated: Use ForceUnloadTaskQueuePartitionResponse.ProtoReflect.Descriptor instead.

func (*ForceUnloadTaskQueuePartitionResponse) Equal 

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

Equal returns whether two ForceUnloadTaskQueuePartitionResponse 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 (*ForceUnloadTaskQueuePartitionResponse) GetWasLoaded 

func (x *ForceUnloadTaskQueuePartitionResponse) GetWasLoaded() bool

func (*ForceUnloadTaskQueuePartitionResponse) Marshal 

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

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

func (*ForceUnloadTaskQueuePartitionResponse) ProtoMessage 

func (*ForceUnloadTaskQueuePartitionResponse) ProtoMessage()

func (*ForceUnloadTaskQueuePartitionResponse) ProtoReflect 

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

func (*ForceUnloadTaskQueuePartitionResponse) Reset 

func (x *ForceUnloadTaskQueuePartitionResponse) Reset()

func (*ForceUnloadTaskQueuePartitionResponse) Size 

func (val *ForceUnloadTaskQueuePartitionResponse) Size() int

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

func (*ForceUnloadTaskQueuePartitionResponse) String 

func (x *ForceUnloadTaskQueuePartitionResponse) String() string

func (*ForceUnloadTaskQueuePartitionResponse) Unmarshal 

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

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

type GenerateLastHistoryReplicationTasksRequest 

type GenerateLastHistoryReplicationTasksRequest 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"`
	TargetClusters []string              `protobuf:"bytes,3,rep,name=target_clusters,json=targetClusters,proto3" json:"target_clusters,omitempty"`
	Archetype      string                `protobuf:"bytes,4,opt,name=archetype,proto3" json:"archetype,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateLastHistoryReplicationTasksRequest) Descriptor deprecated 

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

Deprecated: Use GenerateLastHistoryReplicationTasksRequest.ProtoReflect.Descriptor instead.

func (*GenerateLastHistoryReplicationTasksRequest) Equal 

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

Equal returns whether two GenerateLastHistoryReplicationTasksRequest 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 (*GenerateLastHistoryReplicationTasksRequest) GetArchetype 

func (x *GenerateLastHistoryReplicationTasksRequest) GetArchetype() string

func (*GenerateLastHistoryReplicationTasksRequest) GetExecution 

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

func (*GenerateLastHistoryReplicationTasksRequest) GetNamespace 

func (x *GenerateLastHistoryReplicationTasksRequest) GetNamespace() string

func (*GenerateLastHistoryReplicationTasksRequest) GetTargetClusters 

func (x *GenerateLastHistoryReplicationTasksRequest) GetTargetClusters() []string

func (*GenerateLastHistoryReplicationTasksRequest) Marshal 

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

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

func (*GenerateLastHistoryReplicationTasksRequest) ProtoMessage 

func (*GenerateLastHistoryReplicationTasksRequest) ProtoMessage()

func (*GenerateLastHistoryReplicationTasksRequest) ProtoReflect 

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

func (*GenerateLastHistoryReplicationTasksRequest) Reset 

func (x *GenerateLastHistoryReplicationTasksRequest) Reset()

func (*GenerateLastHistoryReplicationTasksRequest) Size 

func (val *GenerateLastHistoryReplicationTasksRequest) Size() int

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

func (*GenerateLastHistoryReplicationTasksRequest) String 

func (x *GenerateLastHistoryReplicationTasksRequest) String() string

func (*GenerateLastHistoryReplicationTasksRequest) Unmarshal 

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

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

type GenerateLastHistoryReplicationTasksResponse 

type GenerateLastHistoryReplicationTasksResponse struct {
	StateTransitionCount int64 `protobuf:"varint,1,opt,name=state_transition_count,json=stateTransitionCount,proto3" json:"state_transition_count,omitempty"`
	HistoryLength        int64 `protobuf:"varint,2,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateLastHistoryReplicationTasksResponse) Descriptor deprecated 

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

Deprecated: Use GenerateLastHistoryReplicationTasksResponse.ProtoReflect.Descriptor instead.

func (*GenerateLastHistoryReplicationTasksResponse) Equal 

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

Equal returns whether two GenerateLastHistoryReplicationTasksResponse 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 (*GenerateLastHistoryReplicationTasksResponse) GetHistoryLength 

func (x *GenerateLastHistoryReplicationTasksResponse) GetHistoryLength() int64

func (*GenerateLastHistoryReplicationTasksResponse) GetStateTransitionCount 

func (x *GenerateLastHistoryReplicationTasksResponse) GetStateTransitionCount() int64

func (*GenerateLastHistoryReplicationTasksResponse) Marshal 

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

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

func (*GenerateLastHistoryReplicationTasksResponse) ProtoMessage 

func (*GenerateLastHistoryReplicationTasksResponse) ProtoMessage()

func (*GenerateLastHistoryReplicationTasksResponse) ProtoReflect 

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

func (*GenerateLastHistoryReplicationTasksResponse) Reset 

func (x *GenerateLastHistoryReplicationTasksResponse) Reset()

func (*GenerateLastHistoryReplicationTasksResponse) Size 

func (val *GenerateLastHistoryReplicationTasksResponse) Size() int

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

func (*GenerateLastHistoryReplicationTasksResponse) String 

func (x *GenerateLastHistoryReplicationTasksResponse) String() string

func (*GenerateLastHistoryReplicationTasksResponse) Unmarshal 

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

Unmarshal an object of type GenerateLastHistoryReplicationTasksResponse 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 

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 

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 

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 

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 

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 

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 

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

Deprecated: Use GetDLQTasksRequest.ProtoReflect.Descriptor instead.

func (*GetDLQTasksRequest) Equal 

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 

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

func (*GetDLQTasksRequest) GetNextPageToken 

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

func (*GetDLQTasksRequest) GetPageSize 

func (x *GetDLQTasksRequest) GetPageSize() int32

func (*GetDLQTasksRequest) Marshal 

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

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

func (*GetDLQTasksRequest) ProtoMessage 

func (*GetDLQTasksRequest) ProtoMessage()

func (*GetDLQTasksRequest) ProtoReflect 

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

func (*GetDLQTasksRequest) Reset 

func (x *GetDLQTasksRequest) Reset()

func (*GetDLQTasksRequest) Size 

func (val *GetDLQTasksRequest) Size() int

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

func (*GetDLQTasksRequest) String 

func (x *GetDLQTasksRequest) String() string

func (*GetDLQTasksRequest) Unmarshal 

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

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

type GetDLQTasksResponse 

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 

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

Deprecated: Use GetDLQTasksResponse.ProtoReflect.Descriptor instead.

func (*GetDLQTasksResponse) Equal 

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 

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

func (*GetDLQTasksResponse) GetNextPageToken 

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

func (*GetDLQTasksResponse) Marshal 

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

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

func (*GetDLQTasksResponse) ProtoMessage 

func (*GetDLQTasksResponse) ProtoMessage()

func (*GetDLQTasksResponse) ProtoReflect 

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

func (*GetDLQTasksResponse) Reset 

func (x *GetDLQTasksResponse) Reset()

func (*GetDLQTasksResponse) Size 

func (val *GetDLQTasksResponse) Size() int

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

func (*GetDLQTasksResponse) String 

func (x *GetDLQTasksResponse) String() string

func (*GetDLQTasksResponse) Unmarshal 

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 

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 

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 

type GetNamespaceRequest struct {

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

func (*GetNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use GetNamespaceRequest.ProtoReflect.Descriptor instead.

func (*GetNamespaceRequest) Equal 

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 

func (x *GetNamespaceRequest) GetAttributes() isGetNamespaceRequest_Attributes

func (*GetNamespaceRequest) GetId 

func (x *GetNamespaceRequest) GetId() string

func (*GetNamespaceRequest) GetNamespace 

func (x *GetNamespaceRequest) GetNamespace() string

func (*GetNamespaceRequest) Marshal 

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

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

func (*GetNamespaceRequest) ProtoMessage 

func (*GetNamespaceRequest) ProtoMessage()

func (*GetNamespaceRequest) ProtoReflect 

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

func (*GetNamespaceRequest) Reset 

func (x *GetNamespaceRequest) Reset()

func (*GetNamespaceRequest) Size 

func (val *GetNamespaceRequest) Size() int

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

func (*GetNamespaceRequest) String 

func (x *GetNamespaceRequest) String() string

func (*GetNamespaceRequest) Unmarshal 

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

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

type GetNamespaceRequest_Id 

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

type GetNamespaceRequest_Namespace 

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

type GetNamespaceResponse 

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

func (*GetNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use GetNamespaceResponse.ProtoReflect.Descriptor instead.

func (*GetNamespaceResponse) Equal 

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 

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

func (*GetNamespaceResponse) GetConfigVersion 

func (x *GetNamespaceResponse) GetConfigVersion() int64

func (*GetNamespaceResponse) GetFailoverHistory 

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

func (*GetNamespaceResponse) GetFailoverVersion 

func (x *GetNamespaceResponse) GetFailoverVersion() int64

func (*GetNamespaceResponse) GetInfo 

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

func (*GetNamespaceResponse) GetIsGlobalNamespace 

func (x *GetNamespaceResponse) GetIsGlobalNamespace() bool

func (*GetNamespaceResponse) GetReplicationConfig 

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

func (*GetNamespaceResponse) Marshal 

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

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

func (*GetNamespaceResponse) ProtoMessage 

func (*GetNamespaceResponse) ProtoMessage()

func (*GetNamespaceResponse) ProtoReflect 

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

func (*GetNamespaceResponse) Reset 

func (x *GetNamespaceResponse) Reset()

func (*GetNamespaceResponse) Size 

func (val *GetNamespaceResponse) Size() int

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

func (*GetNamespaceResponse) String 

func (x *GetNamespaceResponse) String() string

func (*GetNamespaceResponse) Unmarshal 

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 

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 `` /* 175-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 

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 

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 

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 

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

Deprecated: Use GetSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*GetSearchAttributesRequest) Equal 

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 

func (x *GetSearchAttributesRequest) GetIndexName() string

func (*GetSearchAttributesRequest) GetNamespace 

func (x *GetSearchAttributesRequest) GetNamespace() string

func (*GetSearchAttributesRequest) Marshal 

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

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

func (*GetSearchAttributesRequest) ProtoMessage 

func (*GetSearchAttributesRequest) ProtoMessage()

func (*GetSearchAttributesRequest) ProtoReflect 

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

func (*GetSearchAttributesRequest) Reset 

func (x *GetSearchAttributesRequest) Reset()

func (*GetSearchAttributesRequest) Size 

func (val *GetSearchAttributesRequest) Size() int

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

func (*GetSearchAttributesRequest) String 

func (x *GetSearchAttributesRequest) String() string

func (*GetSearchAttributesRequest) Unmarshal 

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

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

type GetSearchAttributesResponse 

type GetSearchAttributesResponse struct {
	CustomAttributes map[string]v16.IndexedValueType `` /* 228-byte string literal not displayed */
	SystemAttributes map[string]v16.IndexedValueType `` /* 228-byte string literal not displayed */
	Mapping          map[string]string               `` /* 141-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 

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

Deprecated: Use GetSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*GetSearchAttributesResponse) Equal 

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 

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

func (*GetSearchAttributesResponse) GetCustomAttributes 

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

func (*GetSearchAttributesResponse) GetMapping 

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

func (*GetSearchAttributesResponse) GetSystemAttributes 

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

func (*GetSearchAttributesResponse) Marshal 

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

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

func (*GetSearchAttributesResponse) ProtoMessage 

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) ProtoReflect 

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

func (*GetSearchAttributesResponse) Reset 

func (x *GetSearchAttributesResponse) Reset()

func (*GetSearchAttributesResponse) Size 

func (val *GetSearchAttributesResponse) Size() int

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

func (*GetSearchAttributesResponse) String 

func (x *GetSearchAttributesResponse) String() string

func (*GetSearchAttributesResponse) Unmarshal 

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

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

type GetShardRequest 

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 

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

Deprecated: Use GetShardRequest.ProtoReflect.Descriptor instead.

func (*GetShardRequest) Equal 

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 

func (x *GetShardRequest) GetShardId() int32

func (*GetShardRequest) Marshal 

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

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

func (*GetShardRequest) ProtoMessage 

func (*GetShardRequest) ProtoMessage()

func (*GetShardRequest) ProtoReflect 

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

func (*GetShardRequest) Reset 

func (x *GetShardRequest) Reset()

func (*GetShardRequest) Size 

func (val *GetShardRequest) Size() int

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

func (*GetShardRequest) String 

func (x *GetShardRequest) String() string

func (*GetShardRequest) Unmarshal 

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

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

type GetShardResponse 

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 

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

Deprecated: Use GetShardResponse.ProtoReflect.Descriptor instead.

func (*GetShardResponse) Equal 

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 

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

func (*GetShardResponse) Marshal 

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

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

func (*GetShardResponse) ProtoMessage 

func (*GetShardResponse) ProtoMessage()

func (*GetShardResponse) ProtoReflect 

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

func (*GetShardResponse) Reset 

func (x *GetShardResponse) Reset()

func (*GetShardResponse) Size 

func (val *GetShardResponse) Size() int

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

func (*GetShardResponse) String 

func (x *GetShardResponse) String() string

func (*GetShardResponse) Unmarshal 

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

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

type GetTaskQueueTasksRequest 

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 */
	MinPass       int64             `protobuf:"varint,9,opt,name=min_pass,json=minPass,proto3" json:"min_pass,omitempty"`
	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"`
	Subqueue      int32             `protobuf:"varint,8,opt,name=subqueue,proto3" json:"subqueue,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskQueueTasksRequest) Descriptor deprecated 

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

Deprecated: Use GetTaskQueueTasksRequest.ProtoReflect.Descriptor instead.

func (*GetTaskQueueTasksRequest) Equal 

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 

func (x *GetTaskQueueTasksRequest) GetBatchSize() int32

func (*GetTaskQueueTasksRequest) GetMaxTaskId 

func (x *GetTaskQueueTasksRequest) GetMaxTaskId() int64

func (*GetTaskQueueTasksRequest) GetMinPass 

func (x *GetTaskQueueTasksRequest) GetMinPass() int64

func (*GetTaskQueueTasksRequest) GetMinTaskId 

func (x *GetTaskQueueTasksRequest) GetMinTaskId() int64

func (*GetTaskQueueTasksRequest) GetNamespace 

func (x *GetTaskQueueTasksRequest) GetNamespace() string

func (*GetTaskQueueTasksRequest) GetNextPageToken 

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

func (*GetTaskQueueTasksRequest) GetSubqueue 

func (x *GetTaskQueueTasksRequest) GetSubqueue() int32

func (*GetTaskQueueTasksRequest) GetTaskQueue 

func (x *GetTaskQueueTasksRequest) GetTaskQueue() string

func (*GetTaskQueueTasksRequest) GetTaskQueueType 

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

func (*GetTaskQueueTasksRequest) Marshal 

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

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

func (*GetTaskQueueTasksRequest) ProtoMessage 

func (*GetTaskQueueTasksRequest) ProtoMessage()

func (*GetTaskQueueTasksRequest) ProtoReflect 

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

func (*GetTaskQueueTasksRequest) Reset 

func (x *GetTaskQueueTasksRequest) Reset()

func (*GetTaskQueueTasksRequest) Size 

func (val *GetTaskQueueTasksRequest) Size() int

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

func (*GetTaskQueueTasksRequest) String 

func (x *GetTaskQueueTasksRequest) String() string

func (*GetTaskQueueTasksRequest) Unmarshal 

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

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

type GetTaskQueueTasksResponse 

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 

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

Deprecated: Use GetTaskQueueTasksResponse.ProtoReflect.Descriptor instead.

func (*GetTaskQueueTasksResponse) Equal 

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 

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

func (*GetTaskQueueTasksResponse) GetTasks 

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

func (*GetTaskQueueTasksResponse) Marshal 

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

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

func (*GetTaskQueueTasksResponse) ProtoMessage 

func (*GetTaskQueueTasksResponse) ProtoMessage()

func (*GetTaskQueueTasksResponse) ProtoReflect 

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

func (*GetTaskQueueTasksResponse) Reset 

func (x *GetTaskQueueTasksResponse) Reset()

func (*GetTaskQueueTasksResponse) Size 

func (val *GetTaskQueueTasksResponse) Size() int

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

func (*GetTaskQueueTasksResponse) String 

func (x *GetTaskQueueTasksResponse) String() string

func (*GetTaskQueueTasksResponse) Unmarshal 

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 

func (x *GetWorkflowExecutionRawHistoryRequest) GetEndEventId() int64

func (*GetWorkflowExecutionRawHistoryRequest) GetEndEventVersion 

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 

func (x *GetWorkflowExecutionRawHistoryRequest) GetNamespaceId() string

func (*GetWorkflowExecutionRawHistoryRequest) GetNextPageToken 

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

func (*GetWorkflowExecutionRawHistoryRequest) GetStartEventId 

func (x *GetWorkflowExecutionRawHistoryRequest) GetStartEventId() int64

func (*GetWorkflowExecutionRawHistoryRequest) GetStartEventVersion 

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 

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 

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

func (*GetWorkflowExecutionRawHistoryResponse) GetNextPageToken 

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

func (*GetWorkflowExecutionRawHistoryResponse) GetVersionHistory 

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 

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 

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 

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 

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 

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 

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 

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

Deprecated: Use ImportWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*ImportWorkflowExecutionRequest) Equal 

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 

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

func (*ImportWorkflowExecutionRequest) GetHistoryBatches 

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

func (*ImportWorkflowExecutionRequest) GetNamespace 

func (x *ImportWorkflowExecutionRequest) GetNamespace() string

func (*ImportWorkflowExecutionRequest) GetToken 

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

func (*ImportWorkflowExecutionRequest) GetVersionHistory 

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

func (*ImportWorkflowExecutionRequest) Marshal 

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

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

func (*ImportWorkflowExecutionRequest) ProtoMessage 

func (*ImportWorkflowExecutionRequest) ProtoMessage()

func (*ImportWorkflowExecutionRequest) ProtoReflect 

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

func (*ImportWorkflowExecutionRequest) Reset 

func (x *ImportWorkflowExecutionRequest) Reset()

func (*ImportWorkflowExecutionRequest) Size 

func (val *ImportWorkflowExecutionRequest) Size() int

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

func (*ImportWorkflowExecutionRequest) String 

func (x *ImportWorkflowExecutionRequest) String() string

func (*ImportWorkflowExecutionRequest) Unmarshal 

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

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

type ImportWorkflowExecutionResponse 

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

func (*ImportWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use ImportWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*ImportWorkflowExecutionResponse) Equal 

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 

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

func (*ImportWorkflowExecutionResponse) Marshal 

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

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

func (*ImportWorkflowExecutionResponse) ProtoMessage 

func (*ImportWorkflowExecutionResponse) ProtoMessage()

func (*ImportWorkflowExecutionResponse) ProtoReflect 

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

func (*ImportWorkflowExecutionResponse) Reset 

func (x *ImportWorkflowExecutionResponse) Reset()

func (*ImportWorkflowExecutionResponse) Size 

func (val *ImportWorkflowExecutionResponse) Size() int

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

func (*ImportWorkflowExecutionResponse) String 

func (x *ImportWorkflowExecutionResponse) String() string

func (*ImportWorkflowExecutionResponse) Unmarshal 

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

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

type ListClusterMembersRequest 

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 

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

Deprecated: Use ListClusterMembersRequest.ProtoReflect.Descriptor instead.

func (*ListClusterMembersRequest) Equal 

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 

func (x *ListClusterMembersRequest) GetHostId() string

func (*ListClusterMembersRequest) GetLastHeartbeatWithin 

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

func (*ListClusterMembersRequest) GetNextPageToken 

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

func (*ListClusterMembersRequest) GetPageSize 

func (x *ListClusterMembersRequest) GetPageSize() int32

func (*ListClusterMembersRequest) GetRole 

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

func (*ListClusterMembersRequest) GetRpcAddress 

func (x *ListClusterMembersRequest) GetRpcAddress() string

func (*ListClusterMembersRequest) GetSessionStartedAfterTime 

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

func (*ListClusterMembersRequest) Marshal 

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

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

func (*ListClusterMembersRequest) ProtoMessage 

func (*ListClusterMembersRequest) ProtoMessage()

func (*ListClusterMembersRequest) ProtoReflect 

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

func (*ListClusterMembersRequest) Reset 

func (x *ListClusterMembersRequest) Reset()

func (*ListClusterMembersRequest) Size 

func (val *ListClusterMembersRequest) Size() int

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

func (*ListClusterMembersRequest) String 

func (x *ListClusterMembersRequest) String() string

func (*ListClusterMembersRequest) Unmarshal 

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

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

type ListClusterMembersResponse 

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 

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

Deprecated: Use ListClusterMembersResponse.ProtoReflect.Descriptor instead.

func (*ListClusterMembersResponse) Equal 

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 

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

func (*ListClusterMembersResponse) GetNextPageToken 

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

func (*ListClusterMembersResponse) Marshal 

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

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

func (*ListClusterMembersResponse) ProtoMessage 

func (*ListClusterMembersResponse) ProtoMessage()

func (*ListClusterMembersResponse) ProtoReflect 

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

func (*ListClusterMembersResponse) Reset 

func (x *ListClusterMembersResponse) Reset()

func (*ListClusterMembersResponse) Size 

func (val *ListClusterMembersResponse) Size() int

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

func (*ListClusterMembersResponse) String 

func (x *ListClusterMembersResponse) String() string

func (*ListClusterMembersResponse) Unmarshal 

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

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

type ListClustersRequest 

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 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) Equal 

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 

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

func (*ListClustersRequest) GetPageSize 

func (x *ListClustersRequest) GetPageSize() int32

func (*ListClustersRequest) Marshal 

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

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

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect 

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

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) Size 

func (val *ListClustersRequest) Size() int

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

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

func (*ListClustersRequest) Unmarshal 

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

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

type ListClustersResponse 

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 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) Equal 

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 

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

func (*ListClustersResponse) GetNextPageToken 

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

func (*ListClustersResponse) Marshal 

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

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

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect 

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

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) Size 

func (val *ListClustersResponse) Size() int

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

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

func (*ListClustersResponse) Unmarshal 

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

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

type ListHistoryTasksRequest 

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 

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

Deprecated: Use ListHistoryTasksRequest.ProtoReflect.Descriptor instead.

func (*ListHistoryTasksRequest) Equal 

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 

func (x *ListHistoryTasksRequest) GetBatchSize() int32

func (*ListHistoryTasksRequest) GetCategory 

func (x *ListHistoryTasksRequest) GetCategory() int32

func (*ListHistoryTasksRequest) GetNextPageToken 

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

func (*ListHistoryTasksRequest) GetShardId 

func (x *ListHistoryTasksRequest) GetShardId() int32

func (*ListHistoryTasksRequest) GetTaskRange 

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

func (*ListHistoryTasksRequest) Marshal 

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

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

func (*ListHistoryTasksRequest) ProtoMessage 

func (*ListHistoryTasksRequest) ProtoMessage()

func (*ListHistoryTasksRequest) ProtoReflect 

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

func (*ListHistoryTasksRequest) Reset 

func (x *ListHistoryTasksRequest) Reset()

func (*ListHistoryTasksRequest) Size 

func (val *ListHistoryTasksRequest) Size() int

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

func (*ListHistoryTasksRequest) String 

func (x *ListHistoryTasksRequest) String() string

func (*ListHistoryTasksRequest) Unmarshal 

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

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

type ListHistoryTasksResponse 

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 

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

Deprecated: Use ListHistoryTasksResponse.ProtoReflect.Descriptor instead.

func (*ListHistoryTasksResponse) Equal 

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 

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

func (*ListHistoryTasksResponse) GetTasks 

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

func (*ListHistoryTasksResponse) Marshal 

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

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

func (*ListHistoryTasksResponse) ProtoMessage 

func (*ListHistoryTasksResponse) ProtoMessage()

func (*ListHistoryTasksResponse) ProtoReflect 

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

func (*ListHistoryTasksResponse) Reset 

func (x *ListHistoryTasksResponse) Reset()

func (*ListHistoryTasksResponse) Size 

func (val *ListHistoryTasksResponse) Size() int

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

func (*ListHistoryTasksResponse) String 

func (x *ListHistoryTasksResponse) String() string

func (*ListHistoryTasksResponse) Unmarshal 

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

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

type ListQueuesRequest 

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 

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

Deprecated: Use ListQueuesRequest.ProtoReflect.Descriptor instead.

func (*ListQueuesRequest) Equal 

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 

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

func (*ListQueuesRequest) GetPageSize 

func (x *ListQueuesRequest) GetPageSize() int32

func (*ListQueuesRequest) GetQueueType 

func (x *ListQueuesRequest) GetQueueType() int32

func (*ListQueuesRequest) Marshal 

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

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

func (*ListQueuesRequest) ProtoMessage 

func (*ListQueuesRequest) ProtoMessage()

func (*ListQueuesRequest) ProtoReflect 

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

func (*ListQueuesRequest) Reset 

func (x *ListQueuesRequest) Reset()

func (*ListQueuesRequest) Size 

func (val *ListQueuesRequest) Size() int

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

func (*ListQueuesRequest) String 

func (x *ListQueuesRequest) String() string

func (*ListQueuesRequest) Unmarshal 

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

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

type ListQueuesResponse 

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 

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

Deprecated: Use ListQueuesResponse.ProtoReflect.Descriptor instead.

func (*ListQueuesResponse) Equal 

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 

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

func (*ListQueuesResponse) GetQueues 

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

func (*ListQueuesResponse) Marshal 

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

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

func (*ListQueuesResponse) ProtoMessage 

func (*ListQueuesResponse) ProtoMessage()

func (*ListQueuesResponse) ProtoReflect 

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

func (*ListQueuesResponse) Reset 

func (x *ListQueuesResponse) Reset()

func (*ListQueuesResponse) Size 

func (val *ListQueuesResponse) Size() int

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

func (*ListQueuesResponse) String 

func (x *ListQueuesResponse) String() string

func (*ListQueuesResponse) Unmarshal 

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

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

type ListQueuesResponse_QueueInfo 

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"`
	LastMessageId int64  `protobuf:"varint,3,opt,name=last_message_id,json=lastMessageId,proto3" json:"last_message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuesResponse_QueueInfo) Descriptor deprecated 

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

Deprecated: Use ListQueuesResponse_QueueInfo.ProtoReflect.Descriptor instead.

func (*ListQueuesResponse_QueueInfo) GetLastMessageId 

func (x *ListQueuesResponse_QueueInfo) GetLastMessageId() int64

func (*ListQueuesResponse_QueueInfo) GetMessageCount 

func (x *ListQueuesResponse_QueueInfo) GetMessageCount() int64

func (*ListQueuesResponse_QueueInfo) GetQueueName 

func (x *ListQueuesResponse_QueueInfo) GetQueueName() string

func (*ListQueuesResponse_QueueInfo) ProtoMessage 

func (*ListQueuesResponse_QueueInfo) ProtoMessage()

func (*ListQueuesResponse_QueueInfo) ProtoReflect 

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

func (*ListQueuesResponse_QueueInfo) Reset 

func (x *ListQueuesResponse_QueueInfo) Reset()

func (*ListQueuesResponse_QueueInfo) String 

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 

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 

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 

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 

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

Deprecated: Use MergeDLQTasksRequest.ProtoReflect.Descriptor instead.

func (*MergeDLQTasksRequest) Equal 

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 

func (x *MergeDLQTasksRequest) GetBatchSize() int32

func (*MergeDLQTasksRequest) GetDlqKey 

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

func (*MergeDLQTasksRequest) GetInclusiveMaxTaskMetadata 

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

func (*MergeDLQTasksRequest) Marshal 

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

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

func (*MergeDLQTasksRequest) ProtoMessage 

func (*MergeDLQTasksRequest) ProtoMessage()

func (*MergeDLQTasksRequest) ProtoReflect 

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

func (*MergeDLQTasksRequest) Reset 

func (x *MergeDLQTasksRequest) Reset()

func (*MergeDLQTasksRequest) Size 

func (val *MergeDLQTasksRequest) Size() int

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

func (*MergeDLQTasksRequest) String 

func (x *MergeDLQTasksRequest) String() string

func (*MergeDLQTasksRequest) Unmarshal 

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

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

type MergeDLQTasksResponse 

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 

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

Deprecated: Use MergeDLQTasksResponse.ProtoReflect.Descriptor instead.

func (*MergeDLQTasksResponse) Equal 

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 

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

func (*MergeDLQTasksResponse) Marshal 

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

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

func (*MergeDLQTasksResponse) ProtoMessage 

func (*MergeDLQTasksResponse) ProtoMessage()

func (*MergeDLQTasksResponse) ProtoReflect 

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

func (*MergeDLQTasksResponse) Reset 

func (x *MergeDLQTasksResponse) Reset()

func (*MergeDLQTasksResponse) Size 

func (val *MergeDLQTasksResponse) Size() int

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

func (*MergeDLQTasksResponse) String 

func (x *MergeDLQTasksResponse) String() string

func (*MergeDLQTasksResponse) Unmarshal 

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

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

type MigrateScheduleRequest 

type MigrateScheduleRequest struct {

	// Namespace name.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Schedule ID.
	ScheduleId string `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// Target scheduler implementation.
	Target MigrateScheduleRequest_SchedulerTarget `` /* 146-byte string literal not displayed */
	// Identity of the caller.
	Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// Used for request deduplication.
	RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrateScheduleRequest) Descriptor deprecated 

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

Deprecated: Use MigrateScheduleRequest.ProtoReflect.Descriptor instead.

func (*MigrateScheduleRequest) Equal 

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

Equal returns whether two MigrateScheduleRequest 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 (*MigrateScheduleRequest) GetIdentity 

func (x *MigrateScheduleRequest) GetIdentity() string

func (*MigrateScheduleRequest) GetNamespace 

func (x *MigrateScheduleRequest) GetNamespace() string

func (*MigrateScheduleRequest) GetRequestId 

func (x *MigrateScheduleRequest) GetRequestId() string

func (*MigrateScheduleRequest) GetScheduleId 

func (x *MigrateScheduleRequest) GetScheduleId() string

func (*MigrateScheduleRequest) GetTarget 

func (x *MigrateScheduleRequest) GetTarget() MigrateScheduleRequest_SchedulerTarget

func (*MigrateScheduleRequest) Marshal 

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

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

func (*MigrateScheduleRequest) ProtoMessage 

func (*MigrateScheduleRequest) ProtoMessage()

func (*MigrateScheduleRequest) ProtoReflect 

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

func (*MigrateScheduleRequest) Reset 

func (x *MigrateScheduleRequest) Reset()

func (*MigrateScheduleRequest) Size 

func (val *MigrateScheduleRequest) Size() int

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

func (*MigrateScheduleRequest) String 

func (x *MigrateScheduleRequest) String() string

func (*MigrateScheduleRequest) Unmarshal 

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

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

type MigrateScheduleRequest_SchedulerTarget 

type MigrateScheduleRequest_SchedulerTarget int32

Target scheduler implementation for migration. 

const (
	MigrateScheduleRequest_SCHEDULER_TARGET_UNSPECIFIED MigrateScheduleRequest_SchedulerTarget = 0
	MigrateScheduleRequest_SCHEDULER_TARGET_CHASM       MigrateScheduleRequest_SchedulerTarget = 1
	MigrateScheduleRequest_SCHEDULER_TARGET_WORKFLOW    MigrateScheduleRequest_SchedulerTarget = 2
)

func (MigrateScheduleRequest_SchedulerTarget) Descriptor 

func (MigrateScheduleRequest_SchedulerTarget) Descriptor() protoreflect.EnumDescriptor

func (MigrateScheduleRequest_SchedulerTarget) Enum 

func (x MigrateScheduleRequest_SchedulerTarget) Enum() *MigrateScheduleRequest_SchedulerTarget

func (MigrateScheduleRequest_SchedulerTarget) EnumDescriptor deprecated 

func (MigrateScheduleRequest_SchedulerTarget) EnumDescriptor() ([]byte, []int)

Deprecated: Use MigrateScheduleRequest_SchedulerTarget.Descriptor instead.

func (MigrateScheduleRequest_SchedulerTarget) Number 

func (x MigrateScheduleRequest_SchedulerTarget) Number() protoreflect.EnumNumber

func (MigrateScheduleRequest_SchedulerTarget) String 

func (x MigrateScheduleRequest_SchedulerTarget) String() string

func (MigrateScheduleRequest_SchedulerTarget) Type 

func (MigrateScheduleRequest_SchedulerTarget) Type() protoreflect.EnumType

type MigrateScheduleResponse 

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

func (*MigrateScheduleResponse) Descriptor deprecated 

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

Deprecated: Use MigrateScheduleResponse.ProtoReflect.Descriptor instead.

func (*MigrateScheduleResponse) Equal 

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

Equal returns whether two MigrateScheduleResponse 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 (*MigrateScheduleResponse) Marshal 

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

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

func (*MigrateScheduleResponse) ProtoMessage 

func (*MigrateScheduleResponse) ProtoMessage()

func (*MigrateScheduleResponse) ProtoReflect 

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

func (*MigrateScheduleResponse) Reset 

func (x *MigrateScheduleResponse) Reset()

func (*MigrateScheduleResponse) Size 

func (val *MigrateScheduleResponse) Size() int

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

func (*MigrateScheduleResponse) String 

func (x *MigrateScheduleResponse) String() string

func (*MigrateScheduleResponse) Unmarshal 

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

Unmarshal an object of type MigrateScheduleResponse 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 

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 

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 

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 

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

Deprecated: Use PurgeDLQTasksRequest.ProtoReflect.Descriptor instead.

func (*PurgeDLQTasksRequest) Equal 

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 

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

func (*PurgeDLQTasksRequest) GetInclusiveMaxTaskMetadata 

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

func (*PurgeDLQTasksRequest) Marshal 

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

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

func (*PurgeDLQTasksRequest) ProtoMessage 

func (*PurgeDLQTasksRequest) ProtoMessage()

func (*PurgeDLQTasksRequest) ProtoReflect 

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

func (*PurgeDLQTasksRequest) Reset 

func (x *PurgeDLQTasksRequest) Reset()

func (*PurgeDLQTasksRequest) Size 

func (val *PurgeDLQTasksRequest) Size() int

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

func (*PurgeDLQTasksRequest) String 

func (x *PurgeDLQTasksRequest) String() string

func (*PurgeDLQTasksRequest) Unmarshal 

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

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

type PurgeDLQTasksResponse 

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 

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

Deprecated: Use PurgeDLQTasksResponse.ProtoReflect.Descriptor instead.

func (*PurgeDLQTasksResponse) Equal 

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 

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

func (*PurgeDLQTasksResponse) Marshal 

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

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

func (*PurgeDLQTasksResponse) ProtoMessage 

func (*PurgeDLQTasksResponse) ProtoMessage()

func (*PurgeDLQTasksResponse) ProtoReflect 

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

func (*PurgeDLQTasksResponse) Reset 

func (x *PurgeDLQTasksResponse) Reset()

func (*PurgeDLQTasksResponse) Size 

func (val *PurgeDLQTasksResponse) Size() int

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

func (*PurgeDLQTasksResponse) String 

func (x *PurgeDLQTasksResponse) String() string

func (*PurgeDLQTasksResponse) Unmarshal 

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 

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 

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 

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 

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 

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

Deprecated: Use RebuildMutableStateRequest.ProtoReflect.Descriptor instead.

func (*RebuildMutableStateRequest) Equal 

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 

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

func (*RebuildMutableStateRequest) GetNamespace 

func (x *RebuildMutableStateRequest) GetNamespace() string

func (*RebuildMutableStateRequest) Marshal 

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

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

func (*RebuildMutableStateRequest) ProtoMessage 

func (*RebuildMutableStateRequest) ProtoMessage()

func (*RebuildMutableStateRequest) ProtoReflect 

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

func (*RebuildMutableStateRequest) Reset 

func (x *RebuildMutableStateRequest) Reset()

func (*RebuildMutableStateRequest) Size 

func (val *RebuildMutableStateRequest) Size() int

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

func (*RebuildMutableStateRequest) String 

func (x *RebuildMutableStateRequest) String() string

func (*RebuildMutableStateRequest) Unmarshal 

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

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

type RebuildMutableStateResponse 

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

func (*RebuildMutableStateResponse) Descriptor deprecated 

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

Deprecated: Use RebuildMutableStateResponse.ProtoReflect.Descriptor instead.

func (*RebuildMutableStateResponse) Equal 

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 

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

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

func (*RebuildMutableStateResponse) ProtoMessage 

func (*RebuildMutableStateResponse) ProtoMessage()

func (*RebuildMutableStateResponse) ProtoReflect 

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

func (*RebuildMutableStateResponse) Reset 

func (x *RebuildMutableStateResponse) Reset()

func (*RebuildMutableStateResponse) Size 

func (val *RebuildMutableStateResponse) Size() int

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

func (*RebuildMutableStateResponse) String 

func (x *RebuildMutableStateResponse) String() string

func (*RebuildMutableStateResponse) Unmarshal 

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"`
	Archetype   string                `protobuf:"bytes,4,opt,name=archetype,proto3" json:"archetype,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) GetArchetype 

func (x *RefreshWorkflowTasksRequest) GetArchetype() string

func (*RefreshWorkflowTasksRequest) GetExecution 

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

func (*RefreshWorkflowTasksRequest) GetNamespaceId 

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 

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 

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 

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 

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

Deprecated: Use RemoveRemoteClusterRequest.ProtoReflect.Descriptor instead.

func (*RemoveRemoteClusterRequest) Equal 

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 

func (x *RemoveRemoteClusterRequest) GetClusterName() string

func (*RemoveRemoteClusterRequest) Marshal 

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

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

func (*RemoveRemoteClusterRequest) ProtoMessage 

func (*RemoveRemoteClusterRequest) ProtoMessage()

func (*RemoveRemoteClusterRequest) ProtoReflect 

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

func (*RemoveRemoteClusterRequest) Reset 

func (x *RemoveRemoteClusterRequest) Reset()

func (*RemoveRemoteClusterRequest) Size 

func (val *RemoveRemoteClusterRequest) Size() int

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

func (*RemoveRemoteClusterRequest) String 

func (x *RemoveRemoteClusterRequest) String() string

func (*RemoveRemoteClusterRequest) Unmarshal 

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

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

type RemoveRemoteClusterResponse 

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

func (*RemoveRemoteClusterResponse) Descriptor deprecated 

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

Deprecated: Use RemoveRemoteClusterResponse.ProtoReflect.Descriptor instead.

func (*RemoveRemoteClusterResponse) Equal 

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 

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

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

func (*RemoveRemoteClusterResponse) ProtoMessage 

func (*RemoveRemoteClusterResponse) ProtoMessage()

func (*RemoveRemoteClusterResponse) ProtoReflect 

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

func (*RemoveRemoteClusterResponse) Reset 

func (x *RemoveRemoteClusterResponse) Reset()

func (*RemoveRemoteClusterResponse) Size 

func (val *RemoveRemoteClusterResponse) Size() int

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

func (*RemoveRemoteClusterResponse) String 

func (x *RemoveRemoteClusterResponse) String() string

func (*RemoveRemoteClusterResponse) Unmarshal 

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

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

type RemoveSearchAttributesRequest 

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 

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

Deprecated: Use RemoveSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*RemoveSearchAttributesRequest) Equal 

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 

func (x *RemoveSearchAttributesRequest) GetIndexName() string

func (*RemoveSearchAttributesRequest) GetNamespace 

func (x *RemoveSearchAttributesRequest) GetNamespace() string

func (*RemoveSearchAttributesRequest) GetSearchAttributes 

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

func (*RemoveSearchAttributesRequest) Marshal 

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

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

func (*RemoveSearchAttributesRequest) ProtoMessage 

func (*RemoveSearchAttributesRequest) ProtoMessage()

func (*RemoveSearchAttributesRequest) ProtoReflect 

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

func (*RemoveSearchAttributesRequest) Reset 

func (x *RemoveSearchAttributesRequest) Reset()

func (*RemoveSearchAttributesRequest) Size 

func (val *RemoveSearchAttributesRequest) Size() int

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

func (*RemoveSearchAttributesRequest) String 

func (x *RemoveSearchAttributesRequest) String() string

func (*RemoveSearchAttributesRequest) Unmarshal 

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

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

type RemoveSearchAttributesResponse 

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

func (*RemoveSearchAttributesResponse) Descriptor deprecated 

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

Deprecated: Use RemoveSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*RemoveSearchAttributesResponse) Equal 

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 

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

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

func (*RemoveSearchAttributesResponse) ProtoMessage 

func (*RemoveSearchAttributesResponse) ProtoMessage()

func (*RemoveSearchAttributesResponse) ProtoReflect 

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

func (*RemoveSearchAttributesResponse) Reset 

func (x *RemoveSearchAttributesResponse) Reset()

func (*RemoveSearchAttributesResponse) Size 

func (val *RemoveSearchAttributesResponse) Size() int

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

func (*RemoveSearchAttributesResponse) String 

func (x *RemoveSearchAttributesResponse) String() string

func (*RemoveSearchAttributesResponse) Unmarshal 

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 

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 

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 

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 

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 

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 StartAdminBatchOperationRequest 

type StartAdminBatchOperationRequest struct {

	// Namespace that contains the batch operation.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Visibility query defines the group of workflows to apply the batch operation.
	// This field and `executions` are mutually exclusive.
	VisibilityQuery string `protobuf:"bytes,2,opt,name=visibility_query,json=visibilityQuery,proto3" json:"visibility_query,omitempty"`
	// A unique job identifier for this batch operation.
	JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Reason for the operation.
	Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// List of workflow executions to apply the batch operation to.
	// This field and `visibility_query` are mutually exclusive.
	Executions []*v1.WorkflowExecution `protobuf:"bytes,5,rep,name=executions,proto3" json:"executions,omitempty"`
	// The identity of the worker/client.
	Identity string `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
	// The admin batch operation to perform.
	//
	// Types that are valid to be assigned to Operation:
	//
	//	*StartAdminBatchOperationRequest_RefreshTasksOperation
	Operation isStartAdminBatchOperationRequest_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

StartAdminBatchOperationRequest starts an admin batch operation. WARNING: Batch Operations are exposed to all users of the namespace. Admin Batch Operations should be exercised with caution.

func (*StartAdminBatchOperationRequest) Descriptor deprecated 

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

Deprecated: Use StartAdminBatchOperationRequest.ProtoReflect.Descriptor instead.

func (*StartAdminBatchOperationRequest) Equal 

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

Equal returns whether two StartAdminBatchOperationRequest 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 (*StartAdminBatchOperationRequest) GetExecutions 

func (x *StartAdminBatchOperationRequest) GetExecutions() []*v1.WorkflowExecution

func (*StartAdminBatchOperationRequest) GetIdentity 

func (x *StartAdminBatchOperationRequest) GetIdentity() string

func (*StartAdminBatchOperationRequest) GetJobId 

func (x *StartAdminBatchOperationRequest) GetJobId() string

func (*StartAdminBatchOperationRequest) GetNamespace 

func (x *StartAdminBatchOperationRequest) GetNamespace() string

func (*StartAdminBatchOperationRequest) GetOperation 

func (x *StartAdminBatchOperationRequest) GetOperation() isStartAdminBatchOperationRequest_Operation

func (*StartAdminBatchOperationRequest) GetReason 

func (x *StartAdminBatchOperationRequest) GetReason() string

func (*StartAdminBatchOperationRequest) GetRefreshTasksOperation 

func (x *StartAdminBatchOperationRequest) GetRefreshTasksOperation() *BatchOperationRefreshTasks

func (*StartAdminBatchOperationRequest) GetVisibilityQuery 

func (x *StartAdminBatchOperationRequest) GetVisibilityQuery() string

func (*StartAdminBatchOperationRequest) Marshal 

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

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

func (*StartAdminBatchOperationRequest) ProtoMessage 

func (*StartAdminBatchOperationRequest) ProtoMessage()

func (*StartAdminBatchOperationRequest) ProtoReflect 

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

func (*StartAdminBatchOperationRequest) Reset 

func (x *StartAdminBatchOperationRequest) Reset()

func (*StartAdminBatchOperationRequest) Size 

func (val *StartAdminBatchOperationRequest) Size() int

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

func (*StartAdminBatchOperationRequest) String 

func (x *StartAdminBatchOperationRequest) String() string

func (*StartAdminBatchOperationRequest) Unmarshal 

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

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

type StartAdminBatchOperationRequest_RefreshTasksOperation 

type StartAdminBatchOperationRequest_RefreshTasksOperation struct {
	RefreshTasksOperation *BatchOperationRefreshTasks `protobuf:"bytes,10,opt,name=refresh_tasks_operation,json=refreshTasksOperation,proto3,oneof"`
}

type StartAdminBatchOperationResponse 

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

func (*StartAdminBatchOperationResponse) Descriptor deprecated 

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

Deprecated: Use StartAdminBatchOperationResponse.ProtoReflect.Descriptor instead.

func (*StartAdminBatchOperationResponse) Equal 

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

Equal returns whether two StartAdminBatchOperationResponse 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 (*StartAdminBatchOperationResponse) Marshal 

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

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

func (*StartAdminBatchOperationResponse) ProtoMessage 

func (*StartAdminBatchOperationResponse) ProtoMessage()

func (*StartAdminBatchOperationResponse) ProtoReflect 

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

func (*StartAdminBatchOperationResponse) Reset 

func (x *StartAdminBatchOperationResponse) Reset()

func (*StartAdminBatchOperationResponse) Size 

func (val *StartAdminBatchOperationResponse) Size() int

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

func (*StartAdminBatchOperationResponse) String 

func (x *StartAdminBatchOperationResponse) String() string

func (*StartAdminBatchOperationResponse) Unmarshal 

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

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

type StreamWorkflowReplicationMessagesRequest 

type StreamWorkflowReplicationMessagesRequest struct {

	// Types that are valid to be assigned to Attributes:
	//
	//	*StreamWorkflowReplicationMessagesRequest_SyncReplicationState
	Attributes isStreamWorkflowReplicationMessagesRequest_Attributes `protobuf_oneof:"attributes"`
	// contains filtered or unexported fields
}

func (*StreamWorkflowReplicationMessagesRequest) Descriptor deprecated 

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

Deprecated: Use StreamWorkflowReplicationMessagesRequest.ProtoReflect.Descriptor instead.

func (*StreamWorkflowReplicationMessagesRequest) Equal 

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 

func (x *StreamWorkflowReplicationMessagesRequest) GetAttributes() isStreamWorkflowReplicationMessagesRequest_Attributes

func (*StreamWorkflowReplicationMessagesRequest) GetSyncReplicationState 

func (x *StreamWorkflowReplicationMessagesRequest) GetSyncReplicationState() *v15.SyncReplicationState

func (*StreamWorkflowReplicationMessagesRequest) Marshal 

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

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

func (*StreamWorkflowReplicationMessagesRequest) ProtoMessage 

func (*StreamWorkflowReplicationMessagesRequest) ProtoMessage()

func (*StreamWorkflowReplicationMessagesRequest) ProtoReflect 

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

func (*StreamWorkflowReplicationMessagesRequest) Reset 

func (x *StreamWorkflowReplicationMessagesRequest) Reset()

func (*StreamWorkflowReplicationMessagesRequest) Size 

func (val *StreamWorkflowReplicationMessagesRequest) Size() int

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

func (*StreamWorkflowReplicationMessagesRequest) String 

func (x *StreamWorkflowReplicationMessagesRequest) String() string

func (*StreamWorkflowReplicationMessagesRequest) Unmarshal 

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

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

type StreamWorkflowReplicationMessagesRequest_SyncReplicationState 

type StreamWorkflowReplicationMessagesRequest_SyncReplicationState struct {
	SyncReplicationState *v15.SyncReplicationState `protobuf:"bytes,1,opt,name=sync_replication_state,json=syncReplicationState,proto3,oneof"`
}

type StreamWorkflowReplicationMessagesResponse 

type StreamWorkflowReplicationMessagesResponse struct {

	// Types that are valid to be assigned to Attributes:
	//
	//	*StreamWorkflowReplicationMessagesResponse_Messages
	Attributes isStreamWorkflowReplicationMessagesResponse_Attributes `protobuf_oneof:"attributes"`
	// contains filtered or unexported fields
}

func (*StreamWorkflowReplicationMessagesResponse) Descriptor deprecated 

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

Deprecated: Use StreamWorkflowReplicationMessagesResponse.ProtoReflect.Descriptor instead.

func (*StreamWorkflowReplicationMessagesResponse) Equal 

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 

func (x *StreamWorkflowReplicationMessagesResponse) GetAttributes() isStreamWorkflowReplicationMessagesResponse_Attributes

func (*StreamWorkflowReplicationMessagesResponse) GetMessages 

func (x *StreamWorkflowReplicationMessagesResponse) GetMessages() *v15.WorkflowReplicationMessages

func (*StreamWorkflowReplicationMessagesResponse) Marshal 

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

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

func (*StreamWorkflowReplicationMessagesResponse) ProtoMessage 

func (*StreamWorkflowReplicationMessagesResponse) ProtoMessage()

func (*StreamWorkflowReplicationMessagesResponse) ProtoReflect 

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

func (*StreamWorkflowReplicationMessagesResponse) Reset 

func (x *StreamWorkflowReplicationMessagesResponse) Reset()

func (*StreamWorkflowReplicationMessagesResponse) Size 

func (val *StreamWorkflowReplicationMessagesResponse) Size() int

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

func (*StreamWorkflowReplicationMessagesResponse) String 

func (x *StreamWorkflowReplicationMessagesResponse) String() string

func (*StreamWorkflowReplicationMessagesResponse) Unmarshal 

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

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

type StreamWorkflowReplicationMessagesResponse_Messages 

type StreamWorkflowReplicationMessagesResponse_Messages struct {
	Messages *v15.WorkflowReplicationMessages `protobuf:"bytes,1,opt,name=messages,proto3,oneof"`
}

type SyncWorkflowStateRequest 

type SyncWorkflowStateRequest 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"`
	VersionedTransition *v12.VersionedTransition `protobuf:"bytes,3,opt,name=versioned_transition,json=versionedTransition,proto3" json:"versioned_transition,omitempty"`
	VersionHistories    *v11.VersionHistories    `protobuf:"bytes,4,opt,name=version_histories,json=versionHistories,proto3" json:"version_histories,omitempty"`
	TargetClusterId     int32                    `protobuf:"varint,5,opt,name=target_cluster_id,json=targetClusterId,proto3" json:"target_cluster_id,omitempty"`
	// (-- api-linter: core::0141::forbidden-types=disabled --)
	ArchetypeId uint32 `protobuf:"varint,6,opt,name=archetype_id,json=archetypeId,proto3" json:"archetype_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncWorkflowStateRequest) Descriptor deprecated 

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

Deprecated: Use SyncWorkflowStateRequest.ProtoReflect.Descriptor instead.

func (*SyncWorkflowStateRequest) Equal 

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

Equal returns whether two SyncWorkflowStateRequest 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 (*SyncWorkflowStateRequest) GetArchetypeId 

func (x *SyncWorkflowStateRequest) GetArchetypeId() uint32

func (*SyncWorkflowStateRequest) GetExecution 

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

func (*SyncWorkflowStateRequest) GetNamespaceId 

func (x *SyncWorkflowStateRequest) GetNamespaceId() string

func (*SyncWorkflowStateRequest) GetTargetClusterId 

func (x *SyncWorkflowStateRequest) GetTargetClusterId() int32

func (*SyncWorkflowStateRequest) GetVersionHistories 

func (x *SyncWorkflowStateRequest) GetVersionHistories() *v11.VersionHistories

func (*SyncWorkflowStateRequest) GetVersionedTransition 

func (x *SyncWorkflowStateRequest) GetVersionedTransition() *v12.VersionedTransition

func (*SyncWorkflowStateRequest) Marshal 

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

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

func (*SyncWorkflowStateRequest) ProtoMessage 

func (*SyncWorkflowStateRequest) ProtoMessage()

func (*SyncWorkflowStateRequest) ProtoReflect 

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

func (*SyncWorkflowStateRequest) Reset 

func (x *SyncWorkflowStateRequest) Reset()

func (*SyncWorkflowStateRequest) Size 

func (val *SyncWorkflowStateRequest) Size() int

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

func (*SyncWorkflowStateRequest) String 

func (x *SyncWorkflowStateRequest) String() string

func (*SyncWorkflowStateRequest) Unmarshal 

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

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

type SyncWorkflowStateResponse 

type SyncWorkflowStateResponse struct {
	VersionedTransitionArtifact *v15.VersionedTransitionArtifact `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SyncWorkflowStateResponse) Descriptor deprecated 

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

Deprecated: Use SyncWorkflowStateResponse.ProtoReflect.Descriptor instead.

func (*SyncWorkflowStateResponse) Equal 

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

Equal returns whether two SyncWorkflowStateResponse 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 (*SyncWorkflowStateResponse) GetVersionedTransitionArtifact 

func (x *SyncWorkflowStateResponse) GetVersionedTransitionArtifact() *v15.VersionedTransitionArtifact

func (*SyncWorkflowStateResponse) Marshal 

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

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

func (*SyncWorkflowStateResponse) ProtoMessage 

func (*SyncWorkflowStateResponse) ProtoMessage()

func (*SyncWorkflowStateResponse) ProtoReflect 

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

func (*SyncWorkflowStateResponse) Reset 

func (x *SyncWorkflowStateResponse) Reset()

func (*SyncWorkflowStateResponse) Size 

func (val *SyncWorkflowStateResponse) Size() int

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

func (*SyncWorkflowStateResponse) String 

func (x *SyncWorkflowStateResponse) String() string

func (*SyncWorkflowStateResponse) Unmarshal 

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

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

type Task 

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 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) Equal 

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 

func (x *Task) GetFireTime() *timestamppb.Timestamp

func (*Task) GetNamespaceId 

func (x *Task) GetNamespaceId() string

func (*Task) GetRunId 

func (x *Task) GetRunId() string

func (*Task) GetTaskId 

func (x *Task) GetTaskId() int64

func (*Task) GetTaskType 

func (x *Task) GetTaskType() v14.TaskType

func (*Task) GetVersion 

func (x *Task) GetVersion() int64

func (*Task) GetWorkflowId 

func (x *Task) GetWorkflowId() string

func (*Task) Marshal 

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

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) Size 

func (val *Task) Size() int

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

func (*Task) String 

func (x *Task) String() string

func (*Task) Unmarshal 

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 

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

func (UnimplementedAdminServiceServer) AddSearchAttributes 

func (UnimplementedAdminServiceServer) AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

func (UnimplementedAdminServiceServer) AddTasks 

func (UnimplementedAdminServiceServer) AddTasks(context.Context, *AddTasksRequest) (*AddTasksResponse, error)

func (UnimplementedAdminServiceServer) CancelDLQJob 

func (UnimplementedAdminServiceServer) CancelDLQJob(context.Context, *CancelDLQJobRequest) (*CancelDLQJobResponse, error)

func (UnimplementedAdminServiceServer) CloseShard 

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

func (UnimplementedAdminServiceServer) DeepHealthCheck 

func (UnimplementedAdminServiceServer) DeepHealthCheck(context.Context, *DeepHealthCheckRequest) (*DeepHealthCheckResponse, error)

func (UnimplementedAdminServiceServer) DeleteWorkflowExecution 

func (UnimplementedAdminServiceServer) DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)

func (UnimplementedAdminServiceServer) DescribeCluster 

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

func (UnimplementedAdminServiceServer) DescribeDLQJob 

func (UnimplementedAdminServiceServer) DescribeDLQJob(context.Context, *DescribeDLQJobRequest) (*DescribeDLQJobResponse, error)

func (UnimplementedAdminServiceServer) DescribeHistoryHost 

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

func (UnimplementedAdminServiceServer) DescribeMutableState 

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

func (UnimplementedAdminServiceServer) DescribeTaskQueuePartition 

func (UnimplementedAdminServiceServer) DescribeTaskQueuePartition(context.Context, *DescribeTaskQueuePartitionRequest) (*DescribeTaskQueuePartitionResponse, error)

func (UnimplementedAdminServiceServer) ForceUnloadTaskQueuePartition 

func (UnimplementedAdminServiceServer) ForceUnloadTaskQueuePartition(context.Context, *ForceUnloadTaskQueuePartitionRequest) (*ForceUnloadTaskQueuePartitionResponse, error)

func (UnimplementedAdminServiceServer) GenerateLastHistoryReplicationTasks 

func (UnimplementedAdminServiceServer) GenerateLastHistoryReplicationTasks(context.Context, *GenerateLastHistoryReplicationTasksRequest) (*GenerateLastHistoryReplicationTasksResponse, 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 

func (UnimplementedAdminServiceServer) GetDLQTasks(context.Context, *GetDLQTasksRequest) (*GetDLQTasksResponse, error)

func (UnimplementedAdminServiceServer) GetNamespace 

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 

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

func (UnimplementedAdminServiceServer) GetShard 

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

func (UnimplementedAdminServiceServer) GetTaskQueueTasks 

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 

func (UnimplementedAdminServiceServer) ImportWorkflowExecution(context.Context, *ImportWorkflowExecutionRequest) (*ImportWorkflowExecutionResponse, error)

func (UnimplementedAdminServiceServer) ListClusterMembers 

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

func (UnimplementedAdminServiceServer) ListClusters 

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

func (UnimplementedAdminServiceServer) ListHistoryTasks 

func (UnimplementedAdminServiceServer) ListHistoryTasks(context.Context, *ListHistoryTasksRequest) (*ListHistoryTasksResponse, error)

func (UnimplementedAdminServiceServer) ListQueues 

func (UnimplementedAdminServiceServer) ListQueues(context.Context, *ListQueuesRequest) (*ListQueuesResponse, error)

func (UnimplementedAdminServiceServer) MergeDLQMessages 

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

func (UnimplementedAdminServiceServer) MergeDLQTasks 

func (UnimplementedAdminServiceServer) MergeDLQTasks(context.Context, *MergeDLQTasksRequest) (*MergeDLQTasksResponse, error)

func (UnimplementedAdminServiceServer) MigrateSchedule 

func (UnimplementedAdminServiceServer) MigrateSchedule(context.Context, *MigrateScheduleRequest) (*MigrateScheduleResponse, error)

func (UnimplementedAdminServiceServer) PurgeDLQMessages 

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

func (UnimplementedAdminServiceServer) PurgeDLQTasks 

func (UnimplementedAdminServiceServer) PurgeDLQTasks(context.Context, *PurgeDLQTasksRequest) (*PurgeDLQTasksResponse, error)

func (UnimplementedAdminServiceServer) ReapplyEvents 

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

func (UnimplementedAdminServiceServer) RebuildMutableState 

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

func (UnimplementedAdminServiceServer) RefreshWorkflowTasks 

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

func (UnimplementedAdminServiceServer) RemoveRemoteCluster 

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

func (UnimplementedAdminServiceServer) RemoveSearchAttributes 

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

func (UnimplementedAdminServiceServer) StartAdminBatchOperation(context.Context, *StartAdminBatchOperationRequest) (*StartAdminBatchOperationResponse, error)

func (UnimplementedAdminServiceServer) StreamWorkflowReplicationMessages 

func (UnimplementedAdminServiceServer) StreamWorkflowReplicationMessages(AdminService_StreamWorkflowReplicationMessagesServer) error

func (UnimplementedAdminServiceServer) SyncWorkflowState 

func (UnimplementedAdminServiceServer) SyncWorkflowState(context.Context, *SyncWorkflowStateRequest) (*SyncWorkflowStateResponse, error)

type UnsafeAdminServiceServer 

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.