hanzoai/tasks
2
0
Fork 0
mirror of https://github.com/hanzoai/tasks.git synced 2026-10-04 02:04:03 +00:00
Code Issues Packages Projects Releases Wiki Activity
Files
rescue/uncommitted
tasks/api/adminservice/v1/service.pb.go
T
Veeral PatelGitHubHanzo Dev
 d8af9436cc feat: add GetTaskQueueUserData RPC to admin service (#9934) 
## What changed?

This PR adds a new `GetTaskQueueUserData` RPC to the admin service.

Given a namespace, task queue name, task queue type, and optional
partition ID (default is 0, which is `root`), it returns the user data
currently loaded by that partition.

This PR wraps the existing `GetTaskQueueUserData` RPC in Matching
Service. We will also create a `tdbg` command which calls this Admin
Service RPC, in a separate PR.

## Why?

Each task queue family has associated metadata, stored in
[TaskQueueUserData](https://github.com/temporalio/temporal/blob/main/proto/internal/temporal/server/api/persistence/v1/task_queues.proto).
Metadata related to worker versioning, queue rate limiting, fairness are
all stored in `TaskQueueUserData`.

TaskQueueUserData is replicated from the root partition to all other
partitions.

However, there is no admin-accessible way to read the user data loaded
by a specific partition or compare versions across partitions to
diagnose replication lag.

## Files changed

| File | Change |
|---|---|
| `proto/internal/.../adminservice/v1/request_response.proto` | Added
`GetTaskQueueUserDataRequest` and `GetTaskQueueUserDataResponse`
messages |
| `proto/internal/.../adminservice/v1/service.proto` | Added
`GetTaskQueueUserData` RPC to `AdminService` |
| `service/frontend/admin_handler.go` | Implemented
`AdminHandler.GetTaskQueueUserData`: validates request, resolves
namespace → ID, builds partition RPC name via `tqid`, calls matching
service, returns per-type entry + version |
| `service/frontend/admin_handler_test.go` | Added unit tests |

## How did you test it?

- [x] built
- [x] run locally and tested manually
- [x] added new unit test(s)
- [x] added new integration test(s) - not applicable, not touching
persistence layer
- [x] added new functional test(s)

### Unit tests

100% unit test coverage

  | Test case | Input | Expected |
  |---|---|---|
  | Nil request | `request == nil` | `errRequestNotSet` |
  | Empty namespace | `namespace == ""` | `errNamespaceNotSet` |
| Namespace not found | Namespace registry returns not-found | Error
propagated; matching never called |
| Invalid task queue name | `task_queue` starts with `/_sys/` |
`INVALID_ARGUMENT` from `tqid.NewTaskQueueFamily`; matching never called
|
| Root partition | `partition_id=0`, workflow type | Sends bare name
`my-queue` to matching; returns correct `user_data` and `version` |
| Non-root partition | `partition_id=1`, workflow type | Sends mangled
name `/_sys/my-queue/1` to matching |
| No per-type data | Matching returns response with empty `per_type` map
| `user_data` is nil; `version` still populated |
| Matching error | Matching client returns error | Error propagated to
caller |

### Functional tests

| Test | Setup | What it verifies |

|------------------------------------------------|--------------------------------|----------------------------------------------------------------------------------|
| TestAdminGetTaskQueueUserData_RootPartition | Write fairness weight
config to a workflow task queue | Admin RPC resolves namespace by name,
routes to root partition (partition_id=0), returns version > 0 and
non-nil per-type data |
| TestAdminGetTaskQueueUserData_NonRootPartition | Same write, then poll
until non-root partition replicates | Admin RPC routes to a non-root
partition (partition_id=1) via mangled name, returns the same version as
root after replication |

### Manual tests

<details>
<summary>Setup</summary>

1. Build and start the server: `make temporal-server && make
start-sqlite`
2. Create namespace: `temporal operator namespace create default`
3. Insert assignment rule: `temporal task-queue versioning
insert-assignment-rule`

</details>

<details>
<summary>Case 1 — Root partition, workflow type</summary>

```
grpcurl -plaintext \
  -d '{"namespace":"default","task_queue":"my-queue","task_queue_type":"TASK_QUEUE_TYPE_WORKFLOW"}' \
  localhost:7233 \
  temporal.server.api.adminservice.v1.AdminService/GetTaskQueueUserData
```

```json
{
  "version": "1"
}
```
</details>

<details>
<summary>Case 2 — Root partition, activity type</summary>

```
grpcurl -plaintext \
  -d '{"namespace":"default","task_queue":"my-queue","task_queue_type":"TASK_QUEUE_TYPE_ACTIVITY"}' \
  localhost:7233 \
  temporal.server.api.adminservice.v1.AdminService/GetTaskQueueUserData
```

```json
{
  "version": "1"
}
```
</details>

<details>
<summary>Case 3 — Non-root partition, workflow type</summary>

```
grpcurl -plaintext \
  -d '{"namespace":"default","task_queue":"my-queue","task_queue_type":"TASK_QUEUE_TYPE_WORKFLOW","partition_id":1}' \
  localhost:7233 \
  temporal.server.api.adminservice.v1.AdminService/GetTaskQueueUserData
```

```json
{
  "version": "1"
}
```
</details>

<details>
<summary>Case 4 — Non-root partition, activity type</summary>

```
grpcurl -plaintext \
  -d '{"namespace":"default","task_queue":"my-queue","task_queue_type":"TASK_QUEUE_TYPE_ACTIVITY","partition_id":1}' \
  localhost:7233 \
  temporal.server.api.adminservice.v1.AdminService/GetTaskQueueUserData
```

```json
{
  "version": "1"
}
```

</details>

<details>
<summary>Case 5 — Non-root partition, activity type, with user
data</summary>

Setup: Add rate limit config

```
grpcurl -plaintext \
  -d '{
    "namespace": "default",
    "task_queue": "my-queue",
    "task_queue_type": "TASK_QUEUE_TYPE_ACTIVITY",
    "update_queue_rate_limit": {
      "rate_limit": {
        "requests_per_second": 50.0
      },
      "reason": "manual test"
    }
  }' \
  localhost:7233 \
  temporal.api.workflowservice.v1.WorkflowService/UpdateTaskQueueConfig
```

```
grpcurl -plaintext \
  -d '{
    "namespace": "default",
    "task_queue": "my-queue",
    "task_queue_type": "TASK_QUEUE_TYPE_ACTIVITY"
  }' \
  localhost:7233 \
  temporal.server.api.adminservice.v1.AdminService/GetTaskQueueUserData
```

```json
{
  "userData": {
    "config": {
      "queueRateLimit": {
        "rateLimit": {
          "requestsPerSecond": 50
        },
        "metadata": {
          "reason": "manual test",
          "updateTime": "2026-04-13T21:40:39.888Z"
        }
      }
    }
  },
  "version": "2"
}
```

</details>

<details>
<summary>Case 6 — Namespace not found</summary>

```
grpcurl -plaintext \
  -d '{"namespace":"nonexistent","task_queue":"my-queue","task_queue_type":"TASK_QUEUE_TYPE_WORKFLOW"}' \
  localhost:7233 \
  temporal.server.api.adminservice.v1.AdminService/GetTaskQueueUserData
```

```
ERROR:
  Code: NotFound
  Message: Namespace nonexistent is not found.
```

`NOT_FOUND` from namespace registry; matching never called.

</details>

---------

Co-authored-by: Hanzo Dev <[email protected]>
2026-04-14 18:35:19 -07:00

298 lines
37 KiB
Go
Raw Permalink Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// plugins:
// protoc-gen-go
// protoc
// source: temporal/server/api/adminservice/v1/service.proto
package adminservice
import (
reflect "reflect"
unsafe "unsafe"
_ "go.temporal.io/server/api/common/v1"
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
var File_temporal_server_api_adminservice_v1_service_proto protoreflect.FileDescriptor
const file_temporal_server_api_adminservice_v1_service_proto_rawDesc = "" +
"\n" +
"1temporal/server/api/adminservice/v1/service.proto\x12#temporal.server.api.adminservice.v1\x1a:temporal/server/api/adminservice/v1/request_response.proto\x1a0temporal/server/api/common/v1/api_category.proto2\xb3:\n" +
"\fAdminService\x12\xa0\x01\n" +
"\x13RebuildMutableState\x12?.temporal.server.api.adminservice.v1.RebuildMutableStateRequest\x1a@.temporal.server.api.adminservice.v1.RebuildMutableStateResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xac\x01\n" +
"\x17ImportWorkflowExecution\x12C.temporal.server.api.adminservice.v1.ImportWorkflowExecutionRequest\x1aD.temporal.server.api.adminservice.v1.ImportWorkflowExecutionResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa3\x01\n" +
"\x14DescribeMutableState\x12@.temporal.server.api.adminservice.v1.DescribeMutableStateRequest\x1aA.temporal.server.api.adminservice.v1.DescribeMutableStateResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa0\x01\n" +
"\x13DescribeHistoryHost\x12?.temporal.server.api.adminservice.v1.DescribeHistoryHostRequest\x1a@.temporal.server.api.adminservice.v1.DescribeHistoryHostResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x7f\n" +
"\bGetShard\x124.temporal.server.api.adminservice.v1.GetShardRequest\x1a5.temporal.server.api.adminservice.v1.GetShardResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x85\x01\n" +
"\n" +
"CloseShard\x126.temporal.server.api.adminservice.v1.CloseShardRequest\x1a7.temporal.server.api.adminservice.v1.CloseShardResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x97\x01\n" +
"\x10ListHistoryTasks\x12<.temporal.server.api.adminservice.v1.ListHistoryTasksRequest\x1a=.temporal.server.api.adminservice.v1.ListHistoryTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x85\x01\n" +
"\n" +
"RemoveTask\x126.temporal.server.api.adminservice.v1.RemoveTaskRequest\x1a7.temporal.server.api.adminservice.v1.RemoveTaskResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xc7\x01\n" +
" GetWorkflowExecutionRawHistoryV2\x12L.temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryV2Request\x1aM.temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryV2Response\"\x06\x8a\xb5\x18\x02\b\x03\x12\xc1\x01\n" +
"\x1eGetWorkflowExecutionRawHistory\x12J.temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryRequest\x1aK.temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa9\x01\n" +
"\x16GetReplicationMessages\x12B.temporal.server.api.adminservice.v1.GetReplicationMessagesRequest\x1aC.temporal.server.api.adminservice.v1.GetReplicationMessagesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xc4\x01\n" +
"\x1fGetNamespaceReplicationMessages\x12K.temporal.server.api.adminservice.v1.GetNamespaceReplicationMessagesRequest\x1aL.temporal.server.api.adminservice.v1.GetNamespaceReplicationMessagesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xb2\x01\n" +
"\x19GetDLQReplicationMessages\x12E.temporal.server.api.adminservice.v1.GetDLQReplicationMessagesRequest\x1aF.temporal.server.api.adminservice.v1.GetDLQReplicationMessagesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x8e\x01\n" +
"\rReapplyEvents\x129.temporal.server.api.adminservice.v1.ReapplyEventsRequest\x1a:.temporal.server.api.adminservice.v1.ReapplyEventsResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa0\x01\n" +
"\x13AddSearchAttributes\x12?.temporal.server.api.adminservice.v1.AddSearchAttributesRequest\x1a@.temporal.server.api.adminservice.v1.AddSearchAttributesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa9\x01\n" +
"\x16RemoveSearchAttributes\x12B.temporal.server.api.adminservice.v1.RemoveSearchAttributesRequest\x1aC.temporal.server.api.adminservice.v1.RemoveSearchAttributesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa0\x01\n" +
"\x13GetSearchAttributes\x12?.temporal.server.api.adminservice.v1.GetSearchAttributesRequest\x1a@.temporal.server.api.adminservice.v1.GetSearchAttributesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x94\x01\n" +
"\x0fDescribeCluster\x12;.temporal.server.api.adminservice.v1.DescribeClusterRequest\x1a<.temporal.server.api.adminservice.v1.DescribeClusterResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x8b\x01\n" +
"\fListClusters\x128.temporal.server.api.adminservice.v1.ListClustersRequest\x1a9.temporal.server.api.adminservice.v1.ListClustersResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x9d\x01\n" +
"\x12ListClusterMembers\x12>.temporal.server.api.adminservice.v1.ListClusterMembersRequest\x1a?.temporal.server.api.adminservice.v1.ListClusterMembersResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xaf\x01\n" +
"\x18AddOrUpdateRemoteCluster\x12D.temporal.server.api.adminservice.v1.AddOrUpdateRemoteClusterRequest\x1aE.temporal.server.api.adminservice.v1.AddOrUpdateRemoteClusterResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa0\x01\n" +
"\x13RemoveRemoteCluster\x12?.temporal.server.api.adminservice.v1.RemoveRemoteClusterRequest\x1a@.temporal.server.api.adminservice.v1.RemoveRemoteClusterResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x91\x01\n" +
"\x0eGetDLQMessages\x12:.temporal.server.api.adminservice.v1.GetDLQMessagesRequest\x1a;.temporal.server.api.adminservice.v1.GetDLQMessagesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x97\x01\n" +
"\x10PurgeDLQMessages\x12<.temporal.server.api.adminservice.v1.PurgeDLQMessagesRequest\x1a=.temporal.server.api.adminservice.v1.PurgeDLQMessagesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x97\x01\n" +
"\x10MergeDLQMessages\x12<.temporal.server.api.adminservice.v1.MergeDLQMessagesRequest\x1a=.temporal.server.api.adminservice.v1.MergeDLQMessagesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa3\x01\n" +
"\x14RefreshWorkflowTasks\x12@.temporal.server.api.adminservice.v1.RefreshWorkflowTasksRequest\x1aA.temporal.server.api.adminservice.v1.RefreshWorkflowTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xaf\x01\n" +
"\x18StartAdminBatchOperation\x12D.temporal.server.api.adminservice.v1.StartAdminBatchOperationRequest\x1aE.temporal.server.api.adminservice.v1.StartAdminBatchOperationResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa9\x01\n" +
"\x16ResendReplicationTasks\x12B.temporal.server.api.adminservice.v1.ResendReplicationTasksRequest\x1aC.temporal.server.api.adminservice.v1.ResendReplicationTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x9a\x01\n" +
"\x11GetTaskQueueTasks\x12=.temporal.server.api.adminservice.v1.GetTaskQueueTasksRequest\x1a>.temporal.server.api.adminservice.v1.GetTaskQueueTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xac\x01\n" +
"\x17DeleteWorkflowExecution\x12C.temporal.server.api.adminservice.v1.DeleteWorkflowExecutionRequest\x1aD.temporal.server.api.adminservice.v1.DeleteWorkflowExecutionResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xce\x01\n" +
"!StreamWorkflowReplicationMessages\x12M.temporal.server.api.adminservice.v1.StreamWorkflowReplicationMessagesRequest\x1aN.temporal.server.api.adminservice.v1.StreamWorkflowReplicationMessagesResponse\"\x06\x8a\xb5\x18\x02\b\x03(\x010\x01\x12\x8b\x01\n" +
"\fGetNamespace\x128.temporal.server.api.adminservice.v1.GetNamespaceRequest\x1a9.temporal.server.api.adminservice.v1.GetNamespaceResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x88\x01\n" +
"\vGetDLQTasks\x127.temporal.server.api.adminservice.v1.GetDLQTasksRequest\x1a8.temporal.server.api.adminservice.v1.GetDLQTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x8e\x01\n" +
"\rPurgeDLQTasks\x129.temporal.server.api.adminservice.v1.PurgeDLQTasksRequest\x1a:.temporal.server.api.adminservice.v1.PurgeDLQTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x8e\x01\n" +
"\rMergeDLQTasks\x129.temporal.server.api.adminservice.v1.MergeDLQTasksRequest\x1a:.temporal.server.api.adminservice.v1.MergeDLQTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x91\x01\n" +
"\x0eDescribeDLQJob\x12:.temporal.server.api.adminservice.v1.DescribeDLQJobRequest\x1a;.temporal.server.api.adminservice.v1.DescribeDLQJobResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x8b\x01\n" +
"\fCancelDLQJob\x128.temporal.server.api.adminservice.v1.CancelDLQJobRequest\x1a9.temporal.server.api.adminservice.v1.CancelDLQJobResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x7f\n" +
"\bAddTasks\x124.temporal.server.api.adminservice.v1.AddTasksRequest\x1a5.temporal.server.api.adminservice.v1.AddTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x85\x01\n" +
"\n" +
"ListQueues\x126.temporal.server.api.adminservice.v1.ListQueuesRequest\x1a7.temporal.server.api.adminservice.v1.ListQueuesResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x94\x01\n" +
"\x0fDeepHealthCheck\x12;.temporal.server.api.adminservice.v1.DeepHealthCheckRequest\x1a<.temporal.server.api.adminservice.v1.DeepHealthCheckResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x9a\x01\n" +
"\x11SyncWorkflowState\x12=.temporal.server.api.adminservice.v1.SyncWorkflowStateRequest\x1a>.temporal.server.api.adminservice.v1.SyncWorkflowStateResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xd0\x01\n" +
"#GenerateLastHistoryReplicationTasks\x12O.temporal.server.api.adminservice.v1.GenerateLastHistoryReplicationTasksRequest\x1aP.temporal.server.api.adminservice.v1.GenerateLastHistoryReplicationTasksResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xb5\x01\n" +
"\x1aDescribeTaskQueuePartition\x12F.temporal.server.api.adminservice.v1.DescribeTaskQueuePartitionRequest\x1aG.temporal.server.api.adminservice.v1.DescribeTaskQueuePartitionResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xbe\x01\n" +
"\x1dForceUnloadTaskQueuePartition\x12I.temporal.server.api.adminservice.v1.ForceUnloadTaskQueuePartitionRequest\x1aJ.temporal.server.api.adminservice.v1.ForceUnloadTaskQueuePartitionResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\xa3\x01\n" +
"\x14GetTaskQueueUserData\x12@.temporal.server.api.adminservice.v1.GetTaskQueueUserDataRequest\x1aA.temporal.server.api.adminservice.v1.GetTaskQueueUserDataResponse\"\x06\x8a\xb5\x18\x02\b\x03\x12\x94\x01\n" +
"\x0fMigrateSchedule\x12;.temporal.server.api.adminservice.v1.MigrateScheduleRequest\x1a<.temporal.server.api.adminservice.v1.MigrateScheduleResponse\"\x06\x8a\xb5\x18\x02\b\x03B8Z6go.temporal.io/server/api/adminservice/v1;adminserviceb\x06proto3"
var file_temporal_server_api_adminservice_v1_service_proto_goTypes = []any{
(*RebuildMutableStateRequest)(nil), // 0: temporal.server.api.adminservice.v1.RebuildMutableStateRequest
(*ImportWorkflowExecutionRequest)(nil), // 1: temporal.server.api.adminservice.v1.ImportWorkflowExecutionRequest
(*DescribeMutableStateRequest)(nil), // 2: temporal.server.api.adminservice.v1.DescribeMutableStateRequest
(*DescribeHistoryHostRequest)(nil), // 3: temporal.server.api.adminservice.v1.DescribeHistoryHostRequest
(*GetShardRequest)(nil), // 4: temporal.server.api.adminservice.v1.GetShardRequest
(*CloseShardRequest)(nil), // 5: temporal.server.api.adminservice.v1.CloseShardRequest
(*ListHistoryTasksRequest)(nil), // 6: temporal.server.api.adminservice.v1.ListHistoryTasksRequest
(*RemoveTaskRequest)(nil), // 7: temporal.server.api.adminservice.v1.RemoveTaskRequest
(*GetWorkflowExecutionRawHistoryV2Request)(nil), // 8: temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryV2Request
(*GetWorkflowExecutionRawHistoryRequest)(nil), // 9: temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryRequest
(*GetReplicationMessagesRequest)(nil), // 10: temporal.server.api.adminservice.v1.GetReplicationMessagesRequest
(*GetNamespaceReplicationMessagesRequest)(nil), // 11: temporal.server.api.adminservice.v1.GetNamespaceReplicationMessagesRequest
(*GetDLQReplicationMessagesRequest)(nil), // 12: temporal.server.api.adminservice.v1.GetDLQReplicationMessagesRequest
(*ReapplyEventsRequest)(nil), // 13: temporal.server.api.adminservice.v1.ReapplyEventsRequest
(*AddSearchAttributesRequest)(nil), // 14: temporal.server.api.adminservice.v1.AddSearchAttributesRequest
(*RemoveSearchAttributesRequest)(nil), // 15: temporal.server.api.adminservice.v1.RemoveSearchAttributesRequest
(*GetSearchAttributesRequest)(nil), // 16: temporal.server.api.adminservice.v1.GetSearchAttributesRequest
(*DescribeClusterRequest)(nil), // 17: temporal.server.api.adminservice.v1.DescribeClusterRequest
(*ListClustersRequest)(nil), // 18: temporal.server.api.adminservice.v1.ListClustersRequest
(*ListClusterMembersRequest)(nil), // 19: temporal.server.api.adminservice.v1.ListClusterMembersRequest
(*AddOrUpdateRemoteClusterRequest)(nil), // 20: temporal.server.api.adminservice.v1.AddOrUpdateRemoteClusterRequest
(*RemoveRemoteClusterRequest)(nil), // 21: temporal.server.api.adminservice.v1.RemoveRemoteClusterRequest
(*GetDLQMessagesRequest)(nil), // 22: temporal.server.api.adminservice.v1.GetDLQMessagesRequest
(*PurgeDLQMessagesRequest)(nil), // 23: temporal.server.api.adminservice.v1.PurgeDLQMessagesRequest
(*MergeDLQMessagesRequest)(nil), // 24: temporal.server.api.adminservice.v1.MergeDLQMessagesRequest
(*RefreshWorkflowTasksRequest)(nil), // 25: temporal.server.api.adminservice.v1.RefreshWorkflowTasksRequest
(*StartAdminBatchOperationRequest)(nil), // 26: temporal.server.api.adminservice.v1.StartAdminBatchOperationRequest
(*ResendReplicationTasksRequest)(nil), // 27: temporal.server.api.adminservice.v1.ResendReplicationTasksRequest
(*GetTaskQueueTasksRequest)(nil), // 28: temporal.server.api.adminservice.v1.GetTaskQueueTasksRequest
(*DeleteWorkflowExecutionRequest)(nil), // 29: temporal.server.api.adminservice.v1.DeleteWorkflowExecutionRequest
(*StreamWorkflowReplicationMessagesRequest)(nil), // 30: temporal.server.api.adminservice.v1.StreamWorkflowReplicationMessagesRequest
(*GetNamespaceRequest)(nil), // 31: temporal.server.api.adminservice.v1.GetNamespaceRequest
(*GetDLQTasksRequest)(nil), // 32: temporal.server.api.adminservice.v1.GetDLQTasksRequest
(*PurgeDLQTasksRequest)(nil), // 33: temporal.server.api.adminservice.v1.PurgeDLQTasksRequest
(*MergeDLQTasksRequest)(nil), // 34: temporal.server.api.adminservice.v1.MergeDLQTasksRequest
(*DescribeDLQJobRequest)(nil), // 35: temporal.server.api.adminservice.v1.DescribeDLQJobRequest
(*CancelDLQJobRequest)(nil), // 36: temporal.server.api.adminservice.v1.CancelDLQJobRequest
(*AddTasksRequest)(nil), // 37: temporal.server.api.adminservice.v1.AddTasksRequest
(*ListQueuesRequest)(nil), // 38: temporal.server.api.adminservice.v1.ListQueuesRequest
(*DeepHealthCheckRequest)(nil), // 39: temporal.server.api.adminservice.v1.DeepHealthCheckRequest
(*SyncWorkflowStateRequest)(nil), // 40: temporal.server.api.adminservice.v1.SyncWorkflowStateRequest
(*GenerateLastHistoryReplicationTasksRequest)(nil), // 41: temporal.server.api.adminservice.v1.GenerateLastHistoryReplicationTasksRequest
(*DescribeTaskQueuePartitionRequest)(nil), // 42: temporal.server.api.adminservice.v1.DescribeTaskQueuePartitionRequest
(*ForceUnloadTaskQueuePartitionRequest)(nil), // 43: temporal.server.api.adminservice.v1.ForceUnloadTaskQueuePartitionRequest
(*GetTaskQueueUserDataRequest)(nil), // 44: temporal.server.api.adminservice.v1.GetTaskQueueUserDataRequest
(*MigrateScheduleRequest)(nil), // 45: temporal.server.api.adminservice.v1.MigrateScheduleRequest
(*RebuildMutableStateResponse)(nil), // 46: temporal.server.api.adminservice.v1.RebuildMutableStateResponse
(*ImportWorkflowExecutionResponse)(nil), // 47: temporal.server.api.adminservice.v1.ImportWorkflowExecutionResponse
(*DescribeMutableStateResponse)(nil), // 48: temporal.server.api.adminservice.v1.DescribeMutableStateResponse
(*DescribeHistoryHostResponse)(nil), // 49: temporal.server.api.adminservice.v1.DescribeHistoryHostResponse
(*GetShardResponse)(nil), // 50: temporal.server.api.adminservice.v1.GetShardResponse
(*CloseShardResponse)(nil), // 51: temporal.server.api.adminservice.v1.CloseShardResponse
(*ListHistoryTasksResponse)(nil), // 52: temporal.server.api.adminservice.v1.ListHistoryTasksResponse
(*RemoveTaskResponse)(nil), // 53: temporal.server.api.adminservice.v1.RemoveTaskResponse
(*GetWorkflowExecutionRawHistoryV2Response)(nil), // 54: temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryV2Response
(*GetWorkflowExecutionRawHistoryResponse)(nil), // 55: temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryResponse
(*GetReplicationMessagesResponse)(nil), // 56: temporal.server.api.adminservice.v1.GetReplicationMessagesResponse
(*GetNamespaceReplicationMessagesResponse)(nil), // 57: temporal.server.api.adminservice.v1.GetNamespaceReplicationMessagesResponse
(*GetDLQReplicationMessagesResponse)(nil), // 58: temporal.server.api.adminservice.v1.GetDLQReplicationMessagesResponse
(*ReapplyEventsResponse)(nil), // 59: temporal.server.api.adminservice.v1.ReapplyEventsResponse
(*AddSearchAttributesResponse)(nil), // 60: temporal.server.api.adminservice.v1.AddSearchAttributesResponse
(*RemoveSearchAttributesResponse)(nil), // 61: temporal.server.api.adminservice.v1.RemoveSearchAttributesResponse
(*GetSearchAttributesResponse)(nil), // 62: temporal.server.api.adminservice.v1.GetSearchAttributesResponse
(*DescribeClusterResponse)(nil), // 63: temporal.server.api.adminservice.v1.DescribeClusterResponse
(*ListClustersResponse)(nil), // 64: temporal.server.api.adminservice.v1.ListClustersResponse
(*ListClusterMembersResponse)(nil), // 65: temporal.server.api.adminservice.v1.ListClusterMembersResponse
(*AddOrUpdateRemoteClusterResponse)(nil), // 66: temporal.server.api.adminservice.v1.AddOrUpdateRemoteClusterResponse
(*RemoveRemoteClusterResponse)(nil), // 67: temporal.server.api.adminservice.v1.RemoveRemoteClusterResponse
(*GetDLQMessagesResponse)(nil), // 68: temporal.server.api.adminservice.v1.GetDLQMessagesResponse
(*PurgeDLQMessagesResponse)(nil), // 69: temporal.server.api.adminservice.v1.PurgeDLQMessagesResponse
(*MergeDLQMessagesResponse)(nil), // 70: temporal.server.api.adminservice.v1.MergeDLQMessagesResponse
(*RefreshWorkflowTasksResponse)(nil), // 71: temporal.server.api.adminservice.v1.RefreshWorkflowTasksResponse
(*StartAdminBatchOperationResponse)(nil), // 72: temporal.server.api.adminservice.v1.StartAdminBatchOperationResponse
(*ResendReplicationTasksResponse)(nil), // 73: temporal.server.api.adminservice.v1.ResendReplicationTasksResponse
(*GetTaskQueueTasksResponse)(nil), // 74: temporal.server.api.adminservice.v1.GetTaskQueueTasksResponse
(*DeleteWorkflowExecutionResponse)(nil), // 75: temporal.server.api.adminservice.v1.DeleteWorkflowExecutionResponse
(*StreamWorkflowReplicationMessagesResponse)(nil), // 76: temporal.server.api.adminservice.v1.StreamWorkflowReplicationMessagesResponse
(*GetNamespaceResponse)(nil), // 77: temporal.server.api.adminservice.v1.GetNamespaceResponse
(*GetDLQTasksResponse)(nil), // 78: temporal.server.api.adminservice.v1.GetDLQTasksResponse
(*PurgeDLQTasksResponse)(nil), // 79: temporal.server.api.adminservice.v1.PurgeDLQTasksResponse
(*MergeDLQTasksResponse)(nil), // 80: temporal.server.api.adminservice.v1.MergeDLQTasksResponse
(*DescribeDLQJobResponse)(nil), // 81: temporal.server.api.adminservice.v1.DescribeDLQJobResponse
(*CancelDLQJobResponse)(nil), // 82: temporal.server.api.adminservice.v1.CancelDLQJobResponse
(*AddTasksResponse)(nil), // 83: temporal.server.api.adminservice.v1.AddTasksResponse
(*ListQueuesResponse)(nil), // 84: temporal.server.api.adminservice.v1.ListQueuesResponse
(*DeepHealthCheckResponse)(nil), // 85: temporal.server.api.adminservice.v1.DeepHealthCheckResponse
(*SyncWorkflowStateResponse)(nil), // 86: temporal.server.api.adminservice.v1.SyncWorkflowStateResponse
(*GenerateLastHistoryReplicationTasksResponse)(nil), // 87: temporal.server.api.adminservice.v1.GenerateLastHistoryReplicationTasksResponse
(*DescribeTaskQueuePartitionResponse)(nil), // 88: temporal.server.api.adminservice.v1.DescribeTaskQueuePartitionResponse
(*ForceUnloadTaskQueuePartitionResponse)(nil), // 89: temporal.server.api.adminservice.v1.ForceUnloadTaskQueuePartitionResponse
(*GetTaskQueueUserDataResponse)(nil), // 90: temporal.server.api.adminservice.v1.GetTaskQueueUserDataResponse
(*MigrateScheduleResponse)(nil), // 91: temporal.server.api.adminservice.v1.MigrateScheduleResponse
}
var file_temporal_server_api_adminservice_v1_service_proto_depIdxs = []int32{
0, // 0: temporal.server.api.adminservice.v1.AdminService.RebuildMutableState:input_type -> temporal.server.api.adminservice.v1.RebuildMutableStateRequest
1, // 1: temporal.server.api.adminservice.v1.AdminService.ImportWorkflowExecution:input_type -> temporal.server.api.adminservice.v1.ImportWorkflowExecutionRequest
2, // 2: temporal.server.api.adminservice.v1.AdminService.DescribeMutableState:input_type -> temporal.server.api.adminservice.v1.DescribeMutableStateRequest
3, // 3: temporal.server.api.adminservice.v1.AdminService.DescribeHistoryHost:input_type -> temporal.server.api.adminservice.v1.DescribeHistoryHostRequest
4, // 4: temporal.server.api.adminservice.v1.AdminService.GetShard:input_type -> temporal.server.api.adminservice.v1.GetShardRequest
5, // 5: temporal.server.api.adminservice.v1.AdminService.CloseShard:input_type -> temporal.server.api.adminservice.v1.CloseShardRequest
6, // 6: temporal.server.api.adminservice.v1.AdminService.ListHistoryTasks:input_type -> temporal.server.api.adminservice.v1.ListHistoryTasksRequest
7, // 7: temporal.server.api.adminservice.v1.AdminService.RemoveTask:input_type -> temporal.server.api.adminservice.v1.RemoveTaskRequest
8, // 8: temporal.server.api.adminservice.v1.AdminService.GetWorkflowExecutionRawHistoryV2:input_type -> temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryV2Request
9, // 9: temporal.server.api.adminservice.v1.AdminService.GetWorkflowExecutionRawHistory:input_type -> temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryRequest
10, // 10: temporal.server.api.adminservice.v1.AdminService.GetReplicationMessages:input_type -> temporal.server.api.adminservice.v1.GetReplicationMessagesRequest
11, // 11: temporal.server.api.adminservice.v1.AdminService.GetNamespaceReplicationMessages:input_type -> temporal.server.api.adminservice.v1.GetNamespaceReplicationMessagesRequest
12, // 12: temporal.server.api.adminservice.v1.AdminService.GetDLQReplicationMessages:input_type -> temporal.server.api.adminservice.v1.GetDLQReplicationMessagesRequest
13, // 13: temporal.server.api.adminservice.v1.AdminService.ReapplyEvents:input_type -> temporal.server.api.adminservice.v1.ReapplyEventsRequest
14, // 14: temporal.server.api.adminservice.v1.AdminService.AddSearchAttributes:input_type -> temporal.server.api.adminservice.v1.AddSearchAttributesRequest
15, // 15: temporal.server.api.adminservice.v1.AdminService.RemoveSearchAttributes:input_type -> temporal.server.api.adminservice.v1.RemoveSearchAttributesRequest
16, // 16: temporal.server.api.adminservice.v1.AdminService.GetSearchAttributes:input_type -> temporal.server.api.adminservice.v1.GetSearchAttributesRequest
17, // 17: temporal.server.api.adminservice.v1.AdminService.DescribeCluster:input_type -> temporal.server.api.adminservice.v1.DescribeClusterRequest
18, // 18: temporal.server.api.adminservice.v1.AdminService.ListClusters:input_type -> temporal.server.api.adminservice.v1.ListClustersRequest
19, // 19: temporal.server.api.adminservice.v1.AdminService.ListClusterMembers:input_type -> temporal.server.api.adminservice.v1.ListClusterMembersRequest
20, // 20: temporal.server.api.adminservice.v1.AdminService.AddOrUpdateRemoteCluster:input_type -> temporal.server.api.adminservice.v1.AddOrUpdateRemoteClusterRequest
21, // 21: temporal.server.api.adminservice.v1.AdminService.RemoveRemoteCluster:input_type -> temporal.server.api.adminservice.v1.RemoveRemoteClusterRequest
22, // 22: temporal.server.api.adminservice.v1.AdminService.GetDLQMessages:input_type -> temporal.server.api.adminservice.v1.GetDLQMessagesRequest
23, // 23: temporal.server.api.adminservice.v1.AdminService.PurgeDLQMessages:input_type -> temporal.server.api.adminservice.v1.PurgeDLQMessagesRequest
24, // 24: temporal.server.api.adminservice.v1.AdminService.MergeDLQMessages:input_type -> temporal.server.api.adminservice.v1.MergeDLQMessagesRequest
25, // 25: temporal.server.api.adminservice.v1.AdminService.RefreshWorkflowTasks:input_type -> temporal.server.api.adminservice.v1.RefreshWorkflowTasksRequest
26, // 26: temporal.server.api.adminservice.v1.AdminService.StartAdminBatchOperation:input_type -> temporal.server.api.adminservice.v1.StartAdminBatchOperationRequest
27, // 27: temporal.server.api.adminservice.v1.AdminService.ResendReplicationTasks:input_type -> temporal.server.api.adminservice.v1.ResendReplicationTasksRequest
28, // 28: temporal.server.api.adminservice.v1.AdminService.GetTaskQueueTasks:input_type -> temporal.server.api.adminservice.v1.GetTaskQueueTasksRequest
29, // 29: temporal.server.api.adminservice.v1.AdminService.DeleteWorkflowExecution:input_type -> temporal.server.api.adminservice.v1.DeleteWorkflowExecutionRequest
30, // 30: temporal.server.api.adminservice.v1.AdminService.StreamWorkflowReplicationMessages:input_type -> temporal.server.api.adminservice.v1.StreamWorkflowReplicationMessagesRequest
31, // 31: temporal.server.api.adminservice.v1.AdminService.GetNamespace:input_type -> temporal.server.api.adminservice.v1.GetNamespaceRequest
32, // 32: temporal.server.api.adminservice.v1.AdminService.GetDLQTasks:input_type -> temporal.server.api.adminservice.v1.GetDLQTasksRequest
33, // 33: temporal.server.api.adminservice.v1.AdminService.PurgeDLQTasks:input_type -> temporal.server.api.adminservice.v1.PurgeDLQTasksRequest
34, // 34: temporal.server.api.adminservice.v1.AdminService.MergeDLQTasks:input_type -> temporal.server.api.adminservice.v1.MergeDLQTasksRequest
35, // 35: temporal.server.api.adminservice.v1.AdminService.DescribeDLQJob:input_type -> temporal.server.api.adminservice.v1.DescribeDLQJobRequest
36, // 36: temporal.server.api.adminservice.v1.AdminService.CancelDLQJob:input_type -> temporal.server.api.adminservice.v1.CancelDLQJobRequest
37, // 37: temporal.server.api.adminservice.v1.AdminService.AddTasks:input_type -> temporal.server.api.adminservice.v1.AddTasksRequest
38, // 38: temporal.server.api.adminservice.v1.AdminService.ListQueues:input_type -> temporal.server.api.adminservice.v1.ListQueuesRequest
39, // 39: temporal.server.api.adminservice.v1.AdminService.DeepHealthCheck:input_type -> temporal.server.api.adminservice.v1.DeepHealthCheckRequest
40, // 40: temporal.server.api.adminservice.v1.AdminService.SyncWorkflowState:input_type -> temporal.server.api.adminservice.v1.SyncWorkflowStateRequest
41, // 41: temporal.server.api.adminservice.v1.AdminService.GenerateLastHistoryReplicationTasks:input_type -> temporal.server.api.adminservice.v1.GenerateLastHistoryReplicationTasksRequest
42, // 42: temporal.server.api.adminservice.v1.AdminService.DescribeTaskQueuePartition:input_type -> temporal.server.api.adminservice.v1.DescribeTaskQueuePartitionRequest
43, // 43: temporal.server.api.adminservice.v1.AdminService.ForceUnloadTaskQueuePartition:input_type -> temporal.server.api.adminservice.v1.ForceUnloadTaskQueuePartitionRequest
44, // 44: temporal.server.api.adminservice.v1.AdminService.GetTaskQueueUserData:input_type -> temporal.server.api.adminservice.v1.GetTaskQueueUserDataRequest
45, // 45: temporal.server.api.adminservice.v1.AdminService.MigrateSchedule:input_type -> temporal.server.api.adminservice.v1.MigrateScheduleRequest
46, // 46: temporal.server.api.adminservice.v1.AdminService.RebuildMutableState:output_type -> temporal.server.api.adminservice.v1.RebuildMutableStateResponse
47, // 47: temporal.server.api.adminservice.v1.AdminService.ImportWorkflowExecution:output_type -> temporal.server.api.adminservice.v1.ImportWorkflowExecutionResponse
48, // 48: temporal.server.api.adminservice.v1.AdminService.DescribeMutableState:output_type -> temporal.server.api.adminservice.v1.DescribeMutableStateResponse
49, // 49: temporal.server.api.adminservice.v1.AdminService.DescribeHistoryHost:output_type -> temporal.server.api.adminservice.v1.DescribeHistoryHostResponse
50, // 50: temporal.server.api.adminservice.v1.AdminService.GetShard:output_type -> temporal.server.api.adminservice.v1.GetShardResponse
51, // 51: temporal.server.api.adminservice.v1.AdminService.CloseShard:output_type -> temporal.server.api.adminservice.v1.CloseShardResponse
52, // 52: temporal.server.api.adminservice.v1.AdminService.ListHistoryTasks:output_type -> temporal.server.api.adminservice.v1.ListHistoryTasksResponse
53, // 53: temporal.server.api.adminservice.v1.AdminService.RemoveTask:output_type -> temporal.server.api.adminservice.v1.RemoveTaskResponse
54, // 54: temporal.server.api.adminservice.v1.AdminService.GetWorkflowExecutionRawHistoryV2:output_type -> temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryV2Response
55, // 55: temporal.server.api.adminservice.v1.AdminService.GetWorkflowExecutionRawHistory:output_type -> temporal.server.api.adminservice.v1.GetWorkflowExecutionRawHistoryResponse
56, // 56: temporal.server.api.adminservice.v1.AdminService.GetReplicationMessages:output_type -> temporal.server.api.adminservice.v1.GetReplicationMessagesResponse
57, // 57: temporal.server.api.adminservice.v1.AdminService.GetNamespaceReplicationMessages:output_type -> temporal.server.api.adminservice.v1.GetNamespaceReplicationMessagesResponse
58, // 58: temporal.server.api.adminservice.v1.AdminService.GetDLQReplicationMessages:output_type -> temporal.server.api.adminservice.v1.GetDLQReplicationMessagesResponse
59, // 59: temporal.server.api.adminservice.v1.AdminService.ReapplyEvents:output_type -> temporal.server.api.adminservice.v1.ReapplyEventsResponse
60, // 60: temporal.server.api.adminservice.v1.AdminService.AddSearchAttributes:output_type -> temporal.server.api.adminservice.v1.AddSearchAttributesResponse
61, // 61: temporal.server.api.adminservice.v1.AdminService.RemoveSearchAttributes:output_type -> temporal.server.api.adminservice.v1.RemoveSearchAttributesResponse
62, // 62: temporal.server.api.adminservice.v1.AdminService.GetSearchAttributes:output_type -> temporal.server.api.adminservice.v1.GetSearchAttributesResponse
63, // 63: temporal.server.api.adminservice.v1.AdminService.DescribeCluster:output_type -> temporal.server.api.adminservice.v1.DescribeClusterResponse
64, // 64: temporal.server.api.adminservice.v1.AdminService.ListClusters:output_type -> temporal.server.api.adminservice.v1.ListClustersResponse
65, // 65: temporal.server.api.adminservice.v1.AdminService.ListClusterMembers:output_type -> temporal.server.api.adminservice.v1.ListClusterMembersResponse
66, // 66: temporal.server.api.adminservice.v1.AdminService.AddOrUpdateRemoteCluster:output_type -> temporal.server.api.adminservice.v1.AddOrUpdateRemoteClusterResponse
67, // 67: temporal.server.api.adminservice.v1.AdminService.RemoveRemoteCluster:output_type -> temporal.server.api.adminservice.v1.RemoveRemoteClusterResponse
68, // 68: temporal.server.api.adminservice.v1.AdminService.GetDLQMessages:output_type -> temporal.server.api.adminservice.v1.GetDLQMessagesResponse
69, // 69: temporal.server.api.adminservice.v1.AdminService.PurgeDLQMessages:output_type -> temporal.server.api.adminservice.v1.PurgeDLQMessagesResponse
70, // 70: temporal.server.api.adminservice.v1.AdminService.MergeDLQMessages:output_type -> temporal.server.api.adminservice.v1.MergeDLQMessagesResponse
71, // 71: temporal.server.api.adminservice.v1.AdminService.RefreshWorkflowTasks:output_type -> temporal.server.api.adminservice.v1.RefreshWorkflowTasksResponse
72, // 72: temporal.server.api.adminservice.v1.AdminService.StartAdminBatchOperation:output_type -> temporal.server.api.adminservice.v1.StartAdminBatchOperationResponse
73, // 73: temporal.server.api.adminservice.v1.AdminService.ResendReplicationTasks:output_type -> temporal.server.api.adminservice.v1.ResendReplicationTasksResponse
74, // 74: temporal.server.api.adminservice.v1.AdminService.GetTaskQueueTasks:output_type -> temporal.server.api.adminservice.v1.GetTaskQueueTasksResponse
75, // 75: temporal.server.api.adminservice.v1.AdminService.DeleteWorkflowExecution:output_type -> temporal.server.api.adminservice.v1.DeleteWorkflowExecutionResponse
76, // 76: temporal.server.api.adminservice.v1.AdminService.StreamWorkflowReplicationMessages:output_type -> temporal.server.api.adminservice.v1.StreamWorkflowReplicationMessagesResponse
77, // 77: temporal.server.api.adminservice.v1.AdminService.GetNamespace:output_type -> temporal.server.api.adminservice.v1.GetNamespaceResponse
78, // 78: temporal.server.api.adminservice.v1.AdminService.GetDLQTasks:output_type -> temporal.server.api.adminservice.v1.GetDLQTasksResponse
79, // 79: temporal.server.api.adminservice.v1.AdminService.PurgeDLQTasks:output_type -> temporal.server.api.adminservice.v1.PurgeDLQTasksResponse
80, // 80: temporal.server.api.adminservice.v1.AdminService.MergeDLQTasks:output_type -> temporal.server.api.adminservice.v1.MergeDLQTasksResponse
81, // 81: temporal.server.api.adminservice.v1.AdminService.DescribeDLQJob:output_type -> temporal.server.api.adminservice.v1.DescribeDLQJobResponse
82, // 82: temporal.server.api.adminservice.v1.AdminService.CancelDLQJob:output_type -> temporal.server.api.adminservice.v1.CancelDLQJobResponse
83, // 83: temporal.server.api.adminservice.v1.AdminService.AddTasks:output_type -> temporal.server.api.adminservice.v1.AddTasksResponse
84, // 84: temporal.server.api.adminservice.v1.AdminService.ListQueues:output_type -> temporal.server.api.adminservice.v1.ListQueuesResponse
85, // 85: temporal.server.api.adminservice.v1.AdminService.DeepHealthCheck:output_type -> temporal.server.api.adminservice.v1.DeepHealthCheckResponse
86, // 86: temporal.server.api.adminservice.v1.AdminService.SyncWorkflowState:output_type -> temporal.server.api.adminservice.v1.SyncWorkflowStateResponse
87, // 87: temporal.server.api.adminservice.v1.AdminService.GenerateLastHistoryReplicationTasks:output_type -> temporal.server.api.adminservice.v1.GenerateLastHistoryReplicationTasksResponse
88, // 88: temporal.server.api.adminservice.v1.AdminService.DescribeTaskQueuePartition:output_type -> temporal.server.api.adminservice.v1.DescribeTaskQueuePartitionResponse
89, // 89: temporal.server.api.adminservice.v1.AdminService.ForceUnloadTaskQueuePartition:output_type -> temporal.server.api.adminservice.v1.ForceUnloadTaskQueuePartitionResponse
90, // 90: temporal.server.api.adminservice.v1.AdminService.GetTaskQueueUserData:output_type -> temporal.server.api.adminservice.v1.GetTaskQueueUserDataResponse
91, // 91: temporal.server.api.adminservice.v1.AdminService.MigrateSchedule:output_type -> temporal.server.api.adminservice.v1.MigrateScheduleResponse
46, // [46:92] is the sub-list for method output_type
0, // [0:46] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name
}
func init() { file_temporal_server_api_adminservice_v1_service_proto_init() }
func file_temporal_server_api_adminservice_v1_service_proto_init() {
if File_temporal_server_api_adminservice_v1_service_proto != nil {
return
}
file_temporal_server_api_adminservice_v1_request_response_proto_init()
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_temporal_server_api_adminservice_v1_service_proto_rawDesc), len(file_temporal_server_api_adminservice_v1_service_proto_rawDesc)),
NumEnums: 0,
NumMessages: 0,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_temporal_server_api_adminservice_v1_service_proto_goTypes,
DependencyIndexes: file_temporal_server_api_adminservice_v1_service_proto_depIdxs,
}.Build()
File_temporal_server_api_adminservice_v1_service_proto = out.File
file_temporal_server_api_adminservice_v1_service_proto_goTypes = nil
file_temporal_server_api_adminservice_v1_service_proto_depIdxs = nil
}
Reference in New Issue View Git Blame Copy Permalink