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
release/v1.30.x
tasks/api/matchingservice/v1/service.pb.go
T
Jacob MoodyandGitHub 7d1a144404 auto enabling priority and fairness (#8650) 
## What changed?
Add a new dynamic config for Auto Enabling fairness and priority if we
see the relevant tasks coming in.

## Why?
Seamlessly start to transition users who start using the fields over to
the new code path.

## How did you test it?
- [X] built
- [x] run locally and tested manually 
- [x] covered by existing tests
- [x] added new unit test(s)
- [x] added new functional test(s)

## Potential risks
Due to storing this in the userdata we are using that interface a bit
more, we also need to change the initialization such that we start it
before being able to substantiate the defaultQ, this change in
initialization might have unintended side effects that I'm not currently
seeing.
2026-01-06 14:40:23 -06:00

259 lines
34 KiB
Go
Raw Permalink Blame History

// Code generated by protoc-gen-go. DO NOT EDIT.
// plugins:
// protoc-gen-go
// protoc
// source: temporal/server/api/matchingservice/v1/service.proto
package matchingservice
import (
reflect "reflect"
unsafe "unsafe"
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_matchingservice_v1_service_proto protoreflect.FileDescriptor
const file_temporal_server_api_matchingservice_v1_service_proto_rawDesc = "" +
"\n" +
"4temporal/server/api/matchingservice/v1/service.proto\x12&temporal.server.api.matchingservice.v1\x1a=temporal/server/api/matchingservice/v1/request_response.proto2\xf54\n" +
"\x0fMatchingService\x12\xa6\x01\n" +
"\x15PollWorkflowTaskQueue\x12D.temporal.server.api.matchingservice.v1.PollWorkflowTaskQueueRequest\x1aE.temporal.server.api.matchingservice.v1.PollWorkflowTaskQueueResponse\"\x00\x12\xa6\x01\n" +
"\x15PollActivityTaskQueue\x12D.temporal.server.api.matchingservice.v1.PollActivityTaskQueueRequest\x1aE.temporal.server.api.matchingservice.v1.PollActivityTaskQueueResponse\"\x00\x12\x94\x01\n" +
"\x0fAddWorkflowTask\x12>.temporal.server.api.matchingservice.v1.AddWorkflowTaskRequest\x1a?.temporal.server.api.matchingservice.v1.AddWorkflowTaskResponse\"\x00\x12\x94\x01\n" +
"\x0fAddActivityTask\x12>.temporal.server.api.matchingservice.v1.AddActivityTaskRequest\x1a?.temporal.server.api.matchingservice.v1.AddActivityTaskResponse\"\x00\x12\x8e\x01\n" +
"\rQueryWorkflow\x12<.temporal.server.api.matchingservice.v1.QueryWorkflowRequest\x1a=.temporal.server.api.matchingservice.v1.QueryWorkflowResponse\"\x00\x12\xb2\x01\n" +
"\x19RespondQueryTaskCompleted\x12H.temporal.server.api.matchingservice.v1.RespondQueryTaskCompletedRequest\x1aI.temporal.server.api.matchingservice.v1.RespondQueryTaskCompletedResponse\"\x00\x12\x9a\x01\n" +
"\x11DispatchNexusTask\x12@.temporal.server.api.matchingservice.v1.DispatchNexusTaskRequest\x1aA.temporal.server.api.matchingservice.v1.DispatchNexusTaskResponse\"\x00\x12\x9d\x01\n" +
"\x12PollNexusTaskQueue\x12A.temporal.server.api.matchingservice.v1.PollNexusTaskQueueRequest\x1aB.temporal.server.api.matchingservice.v1.PollNexusTaskQueueResponse\"\x00\x12\xb2\x01\n" +
"\x19RespondNexusTaskCompleted\x12H.temporal.server.api.matchingservice.v1.RespondNexusTaskCompletedRequest\x1aI.temporal.server.api.matchingservice.v1.RespondNexusTaskCompletedResponse\"\x00\x12\xa9\x01\n" +
"\x16RespondNexusTaskFailed\x12E.temporal.server.api.matchingservice.v1.RespondNexusTaskFailedRequest\x1aF.temporal.server.api.matchingservice.v1.RespondNexusTaskFailedResponse\"\x00\x12\xa6\x01\n" +
"\x15CancelOutstandingPoll\x12D.temporal.server.api.matchingservice.v1.CancelOutstandingPollRequest\x1aE.temporal.server.api.matchingservice.v1.CancelOutstandingPollResponse\"\x00\x12\x9a\x01\n" +
"\x11DescribeTaskQueue\x12@.temporal.server.api.matchingservice.v1.DescribeTaskQueueRequest\x1aA.temporal.server.api.matchingservice.v1.DescribeTaskQueueResponse\"\x00\x12\xb5\x01\n" +
"\x1aDescribeTaskQueuePartition\x12I.temporal.server.api.matchingservice.v1.DescribeTaskQueuePartitionRequest\x1aJ.temporal.server.api.matchingservice.v1.DescribeTaskQueuePartitionResponse\"\x00\x12\xb8\x01\n" +
"\x1bDescribeVersionedTaskQueues\x12J.temporal.server.api.matchingservice.v1.DescribeVersionedTaskQueuesRequest\x1aK.temporal.server.api.matchingservice.v1.DescribeVersionedTaskQueuesResponse\"\x00\x12\xac\x01\n" +
"\x17ListTaskQueuePartitions\x12F.temporal.server.api.matchingservice.v1.ListTaskQueuePartitionsRequest\x1aG.temporal.server.api.matchingservice.v1.ListTaskQueuePartitionsResponse\"\x00\x12\xc7\x01\n" +
" UpdateWorkerBuildIdCompatibility\x12O.temporal.server.api.matchingservice.v1.UpdateWorkerBuildIdCompatibilityRequest\x1aP.temporal.server.api.matchingservice.v1.UpdateWorkerBuildIdCompatibilityResponse\"\x00\x12\xbe\x01\n" +
"\x1dGetWorkerBuildIdCompatibility\x12L.temporal.server.api.matchingservice.v1.GetWorkerBuildIdCompatibilityRequest\x1aM.temporal.server.api.matchingservice.v1.GetWorkerBuildIdCompatibilityResponse\"\x00\x12\xa3\x01\n" +
"\x14GetTaskQueueUserData\x12C.temporal.server.api.matchingservice.v1.GetTaskQueueUserDataRequest\x1aD.temporal.server.api.matchingservice.v1.GetTaskQueueUserDataResponse\"\x00\x12\xb8\x01\n" +
"\x1bUpdateWorkerVersioningRules\x12J.temporal.server.api.matchingservice.v1.UpdateWorkerVersioningRulesRequest\x1aK.temporal.server.api.matchingservice.v1.UpdateWorkerVersioningRulesResponse\"\x00\x12\xaf\x01\n" +
"\x18GetWorkerVersioningRules\x12G.temporal.server.api.matchingservice.v1.GetWorkerVersioningRulesRequest\x1aH.temporal.server.api.matchingservice.v1.GetWorkerVersioningRulesResponse\"\x00\x12\xa9\x01\n" +
"\x16SyncDeploymentUserData\x12E.temporal.server.api.matchingservice.v1.SyncDeploymentUserDataRequest\x1aF.temporal.server.api.matchingservice.v1.SyncDeploymentUserDataResponse\"\x00\x12\xd9\x01\n" +
"&ApplyTaskQueueUserDataReplicationEvent\x12U.temporal.server.api.matchingservice.v1.ApplyTaskQueueUserDataReplicationEventRequest\x1aV.temporal.server.api.matchingservice.v1.ApplyTaskQueueUserDataReplicationEventResponse\"\x00\x12\xb5\x01\n" +
"\x1aGetBuildIdTaskQueueMapping\x12I.temporal.server.api.matchingservice.v1.GetBuildIdTaskQueueMappingRequest\x1aJ.temporal.server.api.matchingservice.v1.GetBuildIdTaskQueueMappingResponse\"\x00\x12\xb8\x01\n" +
"\x1bForceLoadTaskQueuePartition\x12J.temporal.server.api.matchingservice.v1.ForceLoadTaskQueuePartitionRequest\x1aK.temporal.server.api.matchingservice.v1.ForceLoadTaskQueuePartitionResponse\"\x00\x12\xa3\x01\n" +
"\x14ForceUnloadTaskQueue\x12C.temporal.server.api.matchingservice.v1.ForceUnloadTaskQueueRequest\x1aD.temporal.server.api.matchingservice.v1.ForceUnloadTaskQueueResponse\"\x00\x12\xbe\x01\n" +
"\x1dForceUnloadTaskQueuePartition\x12L.temporal.server.api.matchingservice.v1.ForceUnloadTaskQueuePartitionRequest\x1aM.temporal.server.api.matchingservice.v1.ForceUnloadTaskQueuePartitionResponse\"\x00\x12\xac\x01\n" +
"\x17UpdateTaskQueueUserData\x12F.temporal.server.api.matchingservice.v1.UpdateTaskQueueUserDataRequest\x1aG.temporal.server.api.matchingservice.v1.UpdateTaskQueueUserDataResponse\"\x00\x12\xb5\x01\n" +
"\x1aReplicateTaskQueueUserData\x12I.temporal.server.api.matchingservice.v1.ReplicateTaskQueueUserDataRequest\x1aJ.temporal.server.api.matchingservice.v1.ReplicateTaskQueueUserDataResponse\"\x00\x12\xca\x01\n" +
"!CheckTaskQueueUserDataPropagation\x12P.temporal.server.api.matchingservice.v1.CheckTaskQueueUserDataPropagationRequest\x1aQ.temporal.server.api.matchingservice.v1.CheckTaskQueueUserDataPropagationResponse\"\x00\x12\xa0\x01\n" +
"\x13CreateNexusEndpoint\x12B.temporal.server.api.matchingservice.v1.CreateNexusEndpointRequest\x1aC.temporal.server.api.matchingservice.v1.CreateNexusEndpointResponse\"\x00\x12\xa0\x01\n" +
"\x13UpdateNexusEndpoint\x12B.temporal.server.api.matchingservice.v1.UpdateNexusEndpointRequest\x1aC.temporal.server.api.matchingservice.v1.UpdateNexusEndpointResponse\"\x00\x12\xa0\x01\n" +
"\x13DeleteNexusEndpoint\x12B.temporal.server.api.matchingservice.v1.DeleteNexusEndpointRequest\x1aC.temporal.server.api.matchingservice.v1.DeleteNexusEndpointResponse\"\x00\x12\x9d\x01\n" +
"\x12ListNexusEndpoints\x12A.temporal.server.api.matchingservice.v1.ListNexusEndpointsRequest\x1aB.temporal.server.api.matchingservice.v1.ListNexusEndpointsResponse\"\x00\x12\xa6\x01\n" +
"\x15RecordWorkerHeartbeat\x12D.temporal.server.api.matchingservice.v1.RecordWorkerHeartbeatRequest\x1aE.temporal.server.api.matchingservice.v1.RecordWorkerHeartbeatResponse\"\x00\x12\x88\x01\n" +
"\vListWorkers\x12:.temporal.server.api.matchingservice.v1.ListWorkersRequest\x1a;.temporal.server.api.matchingservice.v1.ListWorkersResponse\"\x00\x12\xa6\x01\n" +
"\x15UpdateTaskQueueConfig\x12D.temporal.server.api.matchingservice.v1.UpdateTaskQueueConfigRequest\x1aE.temporal.server.api.matchingservice.v1.UpdateTaskQueueConfigResponse\"\x00\x12\x91\x01\n" +
"\x0eDescribeWorker\x12=.temporal.server.api.matchingservice.v1.DescribeWorkerRequest\x1a>.temporal.server.api.matchingservice.v1.DescribeWorkerResponse\"\x00\x12\xa0\x01\n" +
"\x13UpdateFairnessState\x12B.temporal.server.api.matchingservice.v1.UpdateFairnessStateRequest\x1aC.temporal.server.api.matchingservice.v1.UpdateFairnessStateResponse\"\x00\x12\xc4\x01\n" +
"\x1fCheckTaskQueueVersionMembership\x12N.temporal.server.api.matchingservice.v1.CheckTaskQueueVersionMembershipRequest\x1aO.temporal.server.api.matchingservice.v1.CheckTaskQueueVersionMembershipResponse\"\x00B>Z<go.temporal.io/server/api/matchingservice/v1;matchingserviceb\x06proto3"
var file_temporal_server_api_matchingservice_v1_service_proto_goTypes = []any{
(*PollWorkflowTaskQueueRequest)(nil), // 0: temporal.server.api.matchingservice.v1.PollWorkflowTaskQueueRequest
(*PollActivityTaskQueueRequest)(nil), // 1: temporal.server.api.matchingservice.v1.PollActivityTaskQueueRequest
(*AddWorkflowTaskRequest)(nil), // 2: temporal.server.api.matchingservice.v1.AddWorkflowTaskRequest
(*AddActivityTaskRequest)(nil), // 3: temporal.server.api.matchingservice.v1.AddActivityTaskRequest
(*QueryWorkflowRequest)(nil), // 4: temporal.server.api.matchingservice.v1.QueryWorkflowRequest
(*RespondQueryTaskCompletedRequest)(nil), // 5: temporal.server.api.matchingservice.v1.RespondQueryTaskCompletedRequest
(*DispatchNexusTaskRequest)(nil), // 6: temporal.server.api.matchingservice.v1.DispatchNexusTaskRequest
(*PollNexusTaskQueueRequest)(nil), // 7: temporal.server.api.matchingservice.v1.PollNexusTaskQueueRequest
(*RespondNexusTaskCompletedRequest)(nil), // 8: temporal.server.api.matchingservice.v1.RespondNexusTaskCompletedRequest
(*RespondNexusTaskFailedRequest)(nil), // 9: temporal.server.api.matchingservice.v1.RespondNexusTaskFailedRequest
(*CancelOutstandingPollRequest)(nil), // 10: temporal.server.api.matchingservice.v1.CancelOutstandingPollRequest
(*DescribeTaskQueueRequest)(nil), // 11: temporal.server.api.matchingservice.v1.DescribeTaskQueueRequest
(*DescribeTaskQueuePartitionRequest)(nil), // 12: temporal.server.api.matchingservice.v1.DescribeTaskQueuePartitionRequest
(*DescribeVersionedTaskQueuesRequest)(nil), // 13: temporal.server.api.matchingservice.v1.DescribeVersionedTaskQueuesRequest
(*ListTaskQueuePartitionsRequest)(nil), // 14: temporal.server.api.matchingservice.v1.ListTaskQueuePartitionsRequest
(*UpdateWorkerBuildIdCompatibilityRequest)(nil), // 15: temporal.server.api.matchingservice.v1.UpdateWorkerBuildIdCompatibilityRequest
(*GetWorkerBuildIdCompatibilityRequest)(nil), // 16: temporal.server.api.matchingservice.v1.GetWorkerBuildIdCompatibilityRequest
(*GetTaskQueueUserDataRequest)(nil), // 17: temporal.server.api.matchingservice.v1.GetTaskQueueUserDataRequest
(*UpdateWorkerVersioningRulesRequest)(nil), // 18: temporal.server.api.matchingservice.v1.UpdateWorkerVersioningRulesRequest
(*GetWorkerVersioningRulesRequest)(nil), // 19: temporal.server.api.matchingservice.v1.GetWorkerVersioningRulesRequest
(*SyncDeploymentUserDataRequest)(nil), // 20: temporal.server.api.matchingservice.v1.SyncDeploymentUserDataRequest
(*ApplyTaskQueueUserDataReplicationEventRequest)(nil), // 21: temporal.server.api.matchingservice.v1.ApplyTaskQueueUserDataReplicationEventRequest
(*GetBuildIdTaskQueueMappingRequest)(nil), // 22: temporal.server.api.matchingservice.v1.GetBuildIdTaskQueueMappingRequest
(*ForceLoadTaskQueuePartitionRequest)(nil), // 23: temporal.server.api.matchingservice.v1.ForceLoadTaskQueuePartitionRequest
(*ForceUnloadTaskQueueRequest)(nil), // 24: temporal.server.api.matchingservice.v1.ForceUnloadTaskQueueRequest
(*ForceUnloadTaskQueuePartitionRequest)(nil), // 25: temporal.server.api.matchingservice.v1.ForceUnloadTaskQueuePartitionRequest
(*UpdateTaskQueueUserDataRequest)(nil), // 26: temporal.server.api.matchingservice.v1.UpdateTaskQueueUserDataRequest
(*ReplicateTaskQueueUserDataRequest)(nil), // 27: temporal.server.api.matchingservice.v1.ReplicateTaskQueueUserDataRequest
(*CheckTaskQueueUserDataPropagationRequest)(nil), // 28: temporal.server.api.matchingservice.v1.CheckTaskQueueUserDataPropagationRequest
(*CreateNexusEndpointRequest)(nil), // 29: temporal.server.api.matchingservice.v1.CreateNexusEndpointRequest
(*UpdateNexusEndpointRequest)(nil), // 30: temporal.server.api.matchingservice.v1.UpdateNexusEndpointRequest
(*DeleteNexusEndpointRequest)(nil), // 31: temporal.server.api.matchingservice.v1.DeleteNexusEndpointRequest
(*ListNexusEndpointsRequest)(nil), // 32: temporal.server.api.matchingservice.v1.ListNexusEndpointsRequest
(*RecordWorkerHeartbeatRequest)(nil), // 33: temporal.server.api.matchingservice.v1.RecordWorkerHeartbeatRequest
(*ListWorkersRequest)(nil), // 34: temporal.server.api.matchingservice.v1.ListWorkersRequest
(*UpdateTaskQueueConfigRequest)(nil), // 35: temporal.server.api.matchingservice.v1.UpdateTaskQueueConfigRequest
(*DescribeWorkerRequest)(nil), // 36: temporal.server.api.matchingservice.v1.DescribeWorkerRequest
(*UpdateFairnessStateRequest)(nil), // 37: temporal.server.api.matchingservice.v1.UpdateFairnessStateRequest
(*CheckTaskQueueVersionMembershipRequest)(nil), // 38: temporal.server.api.matchingservice.v1.CheckTaskQueueVersionMembershipRequest
(*PollWorkflowTaskQueueResponse)(nil), // 39: temporal.server.api.matchingservice.v1.PollWorkflowTaskQueueResponse
(*PollActivityTaskQueueResponse)(nil), // 40: temporal.server.api.matchingservice.v1.PollActivityTaskQueueResponse
(*AddWorkflowTaskResponse)(nil), // 41: temporal.server.api.matchingservice.v1.AddWorkflowTaskResponse
(*AddActivityTaskResponse)(nil), // 42: temporal.server.api.matchingservice.v1.AddActivityTaskResponse
(*QueryWorkflowResponse)(nil), // 43: temporal.server.api.matchingservice.v1.QueryWorkflowResponse
(*RespondQueryTaskCompletedResponse)(nil), // 44: temporal.server.api.matchingservice.v1.RespondQueryTaskCompletedResponse
(*DispatchNexusTaskResponse)(nil), // 45: temporal.server.api.matchingservice.v1.DispatchNexusTaskResponse
(*PollNexusTaskQueueResponse)(nil), // 46: temporal.server.api.matchingservice.v1.PollNexusTaskQueueResponse
(*RespondNexusTaskCompletedResponse)(nil), // 47: temporal.server.api.matchingservice.v1.RespondNexusTaskCompletedResponse
(*RespondNexusTaskFailedResponse)(nil), // 48: temporal.server.api.matchingservice.v1.RespondNexusTaskFailedResponse
(*CancelOutstandingPollResponse)(nil), // 49: temporal.server.api.matchingservice.v1.CancelOutstandingPollResponse
(*DescribeTaskQueueResponse)(nil), // 50: temporal.server.api.matchingservice.v1.DescribeTaskQueueResponse
(*DescribeTaskQueuePartitionResponse)(nil), // 51: temporal.server.api.matchingservice.v1.DescribeTaskQueuePartitionResponse
(*DescribeVersionedTaskQueuesResponse)(nil), // 52: temporal.server.api.matchingservice.v1.DescribeVersionedTaskQueuesResponse
(*ListTaskQueuePartitionsResponse)(nil), // 53: temporal.server.api.matchingservice.v1.ListTaskQueuePartitionsResponse
(*UpdateWorkerBuildIdCompatibilityResponse)(nil), // 54: temporal.server.api.matchingservice.v1.UpdateWorkerBuildIdCompatibilityResponse
(*GetWorkerBuildIdCompatibilityResponse)(nil), // 55: temporal.server.api.matchingservice.v1.GetWorkerBuildIdCompatibilityResponse
(*GetTaskQueueUserDataResponse)(nil), // 56: temporal.server.api.matchingservice.v1.GetTaskQueueUserDataResponse
(*UpdateWorkerVersioningRulesResponse)(nil), // 57: temporal.server.api.matchingservice.v1.UpdateWorkerVersioningRulesResponse
(*GetWorkerVersioningRulesResponse)(nil), // 58: temporal.server.api.matchingservice.v1.GetWorkerVersioningRulesResponse
(*SyncDeploymentUserDataResponse)(nil), // 59: temporal.server.api.matchingservice.v1.SyncDeploymentUserDataResponse
(*ApplyTaskQueueUserDataReplicationEventResponse)(nil), // 60: temporal.server.api.matchingservice.v1.ApplyTaskQueueUserDataReplicationEventResponse
(*GetBuildIdTaskQueueMappingResponse)(nil), // 61: temporal.server.api.matchingservice.v1.GetBuildIdTaskQueueMappingResponse
(*ForceLoadTaskQueuePartitionResponse)(nil), // 62: temporal.server.api.matchingservice.v1.ForceLoadTaskQueuePartitionResponse
(*ForceUnloadTaskQueueResponse)(nil), // 63: temporal.server.api.matchingservice.v1.ForceUnloadTaskQueueResponse
(*ForceUnloadTaskQueuePartitionResponse)(nil), // 64: temporal.server.api.matchingservice.v1.ForceUnloadTaskQueuePartitionResponse
(*UpdateTaskQueueUserDataResponse)(nil), // 65: temporal.server.api.matchingservice.v1.UpdateTaskQueueUserDataResponse
(*ReplicateTaskQueueUserDataResponse)(nil), // 66: temporal.server.api.matchingservice.v1.ReplicateTaskQueueUserDataResponse
(*CheckTaskQueueUserDataPropagationResponse)(nil), // 67: temporal.server.api.matchingservice.v1.CheckTaskQueueUserDataPropagationResponse
(*CreateNexusEndpointResponse)(nil), // 68: temporal.server.api.matchingservice.v1.CreateNexusEndpointResponse
(*UpdateNexusEndpointResponse)(nil), // 69: temporal.server.api.matchingservice.v1.UpdateNexusEndpointResponse
(*DeleteNexusEndpointResponse)(nil), // 70: temporal.server.api.matchingservice.v1.DeleteNexusEndpointResponse
(*ListNexusEndpointsResponse)(nil), // 71: temporal.server.api.matchingservice.v1.ListNexusEndpointsResponse
(*RecordWorkerHeartbeatResponse)(nil), // 72: temporal.server.api.matchingservice.v1.RecordWorkerHeartbeatResponse
(*ListWorkersResponse)(nil), // 73: temporal.server.api.matchingservice.v1.ListWorkersResponse
(*UpdateTaskQueueConfigResponse)(nil), // 74: temporal.server.api.matchingservice.v1.UpdateTaskQueueConfigResponse
(*DescribeWorkerResponse)(nil), // 75: temporal.server.api.matchingservice.v1.DescribeWorkerResponse
(*UpdateFairnessStateResponse)(nil), // 76: temporal.server.api.matchingservice.v1.UpdateFairnessStateResponse
(*CheckTaskQueueVersionMembershipResponse)(nil), // 77: temporal.server.api.matchingservice.v1.CheckTaskQueueVersionMembershipResponse
}
var file_temporal_server_api_matchingservice_v1_service_proto_depIdxs = []int32{
0, // 0: temporal.server.api.matchingservice.v1.MatchingService.PollWorkflowTaskQueue:input_type -> temporal.server.api.matchingservice.v1.PollWorkflowTaskQueueRequest
1, // 1: temporal.server.api.matchingservice.v1.MatchingService.PollActivityTaskQueue:input_type -> temporal.server.api.matchingservice.v1.PollActivityTaskQueueRequest
2, // 2: temporal.server.api.matchingservice.v1.MatchingService.AddWorkflowTask:input_type -> temporal.server.api.matchingservice.v1.AddWorkflowTaskRequest
3, // 3: temporal.server.api.matchingservice.v1.MatchingService.AddActivityTask:input_type -> temporal.server.api.matchingservice.v1.AddActivityTaskRequest
4, // 4: temporal.server.api.matchingservice.v1.MatchingService.QueryWorkflow:input_type -> temporal.server.api.matchingservice.v1.QueryWorkflowRequest
5, // 5: temporal.server.api.matchingservice.v1.MatchingService.RespondQueryTaskCompleted:input_type -> temporal.server.api.matchingservice.v1.RespondQueryTaskCompletedRequest
6, // 6: temporal.server.api.matchingservice.v1.MatchingService.DispatchNexusTask:input_type -> temporal.server.api.matchingservice.v1.DispatchNexusTaskRequest
7, // 7: temporal.server.api.matchingservice.v1.MatchingService.PollNexusTaskQueue:input_type -> temporal.server.api.matchingservice.v1.PollNexusTaskQueueRequest
8, // 8: temporal.server.api.matchingservice.v1.MatchingService.RespondNexusTaskCompleted:input_type -> temporal.server.api.matchingservice.v1.RespondNexusTaskCompletedRequest
9, // 9: temporal.server.api.matchingservice.v1.MatchingService.RespondNexusTaskFailed:input_type -> temporal.server.api.matchingservice.v1.RespondNexusTaskFailedRequest
10, // 10: temporal.server.api.matchingservice.v1.MatchingService.CancelOutstandingPoll:input_type -> temporal.server.api.matchingservice.v1.CancelOutstandingPollRequest
11, // 11: temporal.server.api.matchingservice.v1.MatchingService.DescribeTaskQueue:input_type -> temporal.server.api.matchingservice.v1.DescribeTaskQueueRequest
12, // 12: temporal.server.api.matchingservice.v1.MatchingService.DescribeTaskQueuePartition:input_type -> temporal.server.api.matchingservice.v1.DescribeTaskQueuePartitionRequest
13, // 13: temporal.server.api.matchingservice.v1.MatchingService.DescribeVersionedTaskQueues:input_type -> temporal.server.api.matchingservice.v1.DescribeVersionedTaskQueuesRequest
14, // 14: temporal.server.api.matchingservice.v1.MatchingService.ListTaskQueuePartitions:input_type -> temporal.server.api.matchingservice.v1.ListTaskQueuePartitionsRequest
15, // 15: temporal.server.api.matchingservice.v1.MatchingService.UpdateWorkerBuildIdCompatibility:input_type -> temporal.server.api.matchingservice.v1.UpdateWorkerBuildIdCompatibilityRequest
16, // 16: temporal.server.api.matchingservice.v1.MatchingService.GetWorkerBuildIdCompatibility:input_type -> temporal.server.api.matchingservice.v1.GetWorkerBuildIdCompatibilityRequest
17, // 17: temporal.server.api.matchingservice.v1.MatchingService.GetTaskQueueUserData:input_type -> temporal.server.api.matchingservice.v1.GetTaskQueueUserDataRequest
18, // 18: temporal.server.api.matchingservice.v1.MatchingService.UpdateWorkerVersioningRules:input_type -> temporal.server.api.matchingservice.v1.UpdateWorkerVersioningRulesRequest
19, // 19: temporal.server.api.matchingservice.v1.MatchingService.GetWorkerVersioningRules:input_type -> temporal.server.api.matchingservice.v1.GetWorkerVersioningRulesRequest
20, // 20: temporal.server.api.matchingservice.v1.MatchingService.SyncDeploymentUserData:input_type -> temporal.server.api.matchingservice.v1.SyncDeploymentUserDataRequest
21, // 21: temporal.server.api.matchingservice.v1.MatchingService.ApplyTaskQueueUserDataReplicationEvent:input_type -> temporal.server.api.matchingservice.v1.ApplyTaskQueueUserDataReplicationEventRequest
22, // 22: temporal.server.api.matchingservice.v1.MatchingService.GetBuildIdTaskQueueMapping:input_type -> temporal.server.api.matchingservice.v1.GetBuildIdTaskQueueMappingRequest
23, // 23: temporal.server.api.matchingservice.v1.MatchingService.ForceLoadTaskQueuePartition:input_type -> temporal.server.api.matchingservice.v1.ForceLoadTaskQueuePartitionRequest
24, // 24: temporal.server.api.matchingservice.v1.MatchingService.ForceUnloadTaskQueue:input_type -> temporal.server.api.matchingservice.v1.ForceUnloadTaskQueueRequest
25, // 25: temporal.server.api.matchingservice.v1.MatchingService.ForceUnloadTaskQueuePartition:input_type -> temporal.server.api.matchingservice.v1.ForceUnloadTaskQueuePartitionRequest
26, // 26: temporal.server.api.matchingservice.v1.MatchingService.UpdateTaskQueueUserData:input_type -> temporal.server.api.matchingservice.v1.UpdateTaskQueueUserDataRequest
27, // 27: temporal.server.api.matchingservice.v1.MatchingService.ReplicateTaskQueueUserData:input_type -> temporal.server.api.matchingservice.v1.ReplicateTaskQueueUserDataRequest
28, // 28: temporal.server.api.matchingservice.v1.MatchingService.CheckTaskQueueUserDataPropagation:input_type -> temporal.server.api.matchingservice.v1.CheckTaskQueueUserDataPropagationRequest
29, // 29: temporal.server.api.matchingservice.v1.MatchingService.CreateNexusEndpoint:input_type -> temporal.server.api.matchingservice.v1.CreateNexusEndpointRequest
30, // 30: temporal.server.api.matchingservice.v1.MatchingService.UpdateNexusEndpoint:input_type -> temporal.server.api.matchingservice.v1.UpdateNexusEndpointRequest
31, // 31: temporal.server.api.matchingservice.v1.MatchingService.DeleteNexusEndpoint:input_type -> temporal.server.api.matchingservice.v1.DeleteNexusEndpointRequest
32, // 32: temporal.server.api.matchingservice.v1.MatchingService.ListNexusEndpoints:input_type -> temporal.server.api.matchingservice.v1.ListNexusEndpointsRequest
33, // 33: temporal.server.api.matchingservice.v1.MatchingService.RecordWorkerHeartbeat:input_type -> temporal.server.api.matchingservice.v1.RecordWorkerHeartbeatRequest
34, // 34: temporal.server.api.matchingservice.v1.MatchingService.ListWorkers:input_type -> temporal.server.api.matchingservice.v1.ListWorkersRequest
35, // 35: temporal.server.api.matchingservice.v1.MatchingService.UpdateTaskQueueConfig:input_type -> temporal.server.api.matchingservice.v1.UpdateTaskQueueConfigRequest
36, // 36: temporal.server.api.matchingservice.v1.MatchingService.DescribeWorker:input_type -> temporal.server.api.matchingservice.v1.DescribeWorkerRequest
37, // 37: temporal.server.api.matchingservice.v1.MatchingService.UpdateFairnessState:input_type -> temporal.server.api.matchingservice.v1.UpdateFairnessStateRequest
38, // 38: temporal.server.api.matchingservice.v1.MatchingService.CheckTaskQueueVersionMembership:input_type -> temporal.server.api.matchingservice.v1.CheckTaskQueueVersionMembershipRequest
39, // 39: temporal.server.api.matchingservice.v1.MatchingService.PollWorkflowTaskQueue:output_type -> temporal.server.api.matchingservice.v1.PollWorkflowTaskQueueResponse
40, // 40: temporal.server.api.matchingservice.v1.MatchingService.PollActivityTaskQueue:output_type -> temporal.server.api.matchingservice.v1.PollActivityTaskQueueResponse
41, // 41: temporal.server.api.matchingservice.v1.MatchingService.AddWorkflowTask:output_type -> temporal.server.api.matchingservice.v1.AddWorkflowTaskResponse
42, // 42: temporal.server.api.matchingservice.v1.MatchingService.AddActivityTask:output_type -> temporal.server.api.matchingservice.v1.AddActivityTaskResponse
43, // 43: temporal.server.api.matchingservice.v1.MatchingService.QueryWorkflow:output_type -> temporal.server.api.matchingservice.v1.QueryWorkflowResponse
44, // 44: temporal.server.api.matchingservice.v1.MatchingService.RespondQueryTaskCompleted:output_type -> temporal.server.api.matchingservice.v1.RespondQueryTaskCompletedResponse
45, // 45: temporal.server.api.matchingservice.v1.MatchingService.DispatchNexusTask:output_type -> temporal.server.api.matchingservice.v1.DispatchNexusTaskResponse
46, // 46: temporal.server.api.matchingservice.v1.MatchingService.PollNexusTaskQueue:output_type -> temporal.server.api.matchingservice.v1.PollNexusTaskQueueResponse
47, // 47: temporal.server.api.matchingservice.v1.MatchingService.RespondNexusTaskCompleted:output_type -> temporal.server.api.matchingservice.v1.RespondNexusTaskCompletedResponse
48, // 48: temporal.server.api.matchingservice.v1.MatchingService.RespondNexusTaskFailed:output_type -> temporal.server.api.matchingservice.v1.RespondNexusTaskFailedResponse
49, // 49: temporal.server.api.matchingservice.v1.MatchingService.CancelOutstandingPoll:output_type -> temporal.server.api.matchingservice.v1.CancelOutstandingPollResponse
50, // 50: temporal.server.api.matchingservice.v1.MatchingService.DescribeTaskQueue:output_type -> temporal.server.api.matchingservice.v1.DescribeTaskQueueResponse
51, // 51: temporal.server.api.matchingservice.v1.MatchingService.DescribeTaskQueuePartition:output_type -> temporal.server.api.matchingservice.v1.DescribeTaskQueuePartitionResponse
52, // 52: temporal.server.api.matchingservice.v1.MatchingService.DescribeVersionedTaskQueues:output_type -> temporal.server.api.matchingservice.v1.DescribeVersionedTaskQueuesResponse
53, // 53: temporal.server.api.matchingservice.v1.MatchingService.ListTaskQueuePartitions:output_type -> temporal.server.api.matchingservice.v1.ListTaskQueuePartitionsResponse
54, // 54: temporal.server.api.matchingservice.v1.MatchingService.UpdateWorkerBuildIdCompatibility:output_type -> temporal.server.api.matchingservice.v1.UpdateWorkerBuildIdCompatibilityResponse
55, // 55: temporal.server.api.matchingservice.v1.MatchingService.GetWorkerBuildIdCompatibility:output_type -> temporal.server.api.matchingservice.v1.GetWorkerBuildIdCompatibilityResponse
56, // 56: temporal.server.api.matchingservice.v1.MatchingService.GetTaskQueueUserData:output_type -> temporal.server.api.matchingservice.v1.GetTaskQueueUserDataResponse
57, // 57: temporal.server.api.matchingservice.v1.MatchingService.UpdateWorkerVersioningRules:output_type -> temporal.server.api.matchingservice.v1.UpdateWorkerVersioningRulesResponse
58, // 58: temporal.server.api.matchingservice.v1.MatchingService.GetWorkerVersioningRules:output_type -> temporal.server.api.matchingservice.v1.GetWorkerVersioningRulesResponse
59, // 59: temporal.server.api.matchingservice.v1.MatchingService.SyncDeploymentUserData:output_type -> temporal.server.api.matchingservice.v1.SyncDeploymentUserDataResponse
60, // 60: temporal.server.api.matchingservice.v1.MatchingService.ApplyTaskQueueUserDataReplicationEvent:output_type -> temporal.server.api.matchingservice.v1.ApplyTaskQueueUserDataReplicationEventResponse
61, // 61: temporal.server.api.matchingservice.v1.MatchingService.GetBuildIdTaskQueueMapping:output_type -> temporal.server.api.matchingservice.v1.GetBuildIdTaskQueueMappingResponse
62, // 62: temporal.server.api.matchingservice.v1.MatchingService.ForceLoadTaskQueuePartition:output_type -> temporal.server.api.matchingservice.v1.ForceLoadTaskQueuePartitionResponse
63, // 63: temporal.server.api.matchingservice.v1.MatchingService.ForceUnloadTaskQueue:output_type -> temporal.server.api.matchingservice.v1.ForceUnloadTaskQueueResponse
64, // 64: temporal.server.api.matchingservice.v1.MatchingService.ForceUnloadTaskQueuePartition:output_type -> temporal.server.api.matchingservice.v1.ForceUnloadTaskQueuePartitionResponse
65, // 65: temporal.server.api.matchingservice.v1.MatchingService.UpdateTaskQueueUserData:output_type -> temporal.server.api.matchingservice.v1.UpdateTaskQueueUserDataResponse
66, // 66: temporal.server.api.matchingservice.v1.MatchingService.ReplicateTaskQueueUserData:output_type -> temporal.server.api.matchingservice.v1.ReplicateTaskQueueUserDataResponse
67, // 67: temporal.server.api.matchingservice.v1.MatchingService.CheckTaskQueueUserDataPropagation:output_type -> temporal.server.api.matchingservice.v1.CheckTaskQueueUserDataPropagationResponse
68, // 68: temporal.server.api.matchingservice.v1.MatchingService.CreateNexusEndpoint:output_type -> temporal.server.api.matchingservice.v1.CreateNexusEndpointResponse
69, // 69: temporal.server.api.matchingservice.v1.MatchingService.UpdateNexusEndpoint:output_type -> temporal.server.api.matchingservice.v1.UpdateNexusEndpointResponse
70, // 70: temporal.server.api.matchingservice.v1.MatchingService.DeleteNexusEndpoint:output_type -> temporal.server.api.matchingservice.v1.DeleteNexusEndpointResponse
71, // 71: temporal.server.api.matchingservice.v1.MatchingService.ListNexusEndpoints:output_type -> temporal.server.api.matchingservice.v1.ListNexusEndpointsResponse
72, // 72: temporal.server.api.matchingservice.v1.MatchingService.RecordWorkerHeartbeat:output_type -> temporal.server.api.matchingservice.v1.RecordWorkerHeartbeatResponse
73, // 73: temporal.server.api.matchingservice.v1.MatchingService.ListWorkers:output_type -> temporal.server.api.matchingservice.v1.ListWorkersResponse
74, // 74: temporal.server.api.matchingservice.v1.MatchingService.UpdateTaskQueueConfig:output_type -> temporal.server.api.matchingservice.v1.UpdateTaskQueueConfigResponse
75, // 75: temporal.server.api.matchingservice.v1.MatchingService.DescribeWorker:output_type -> temporal.server.api.matchingservice.v1.DescribeWorkerResponse
76, // 76: temporal.server.api.matchingservice.v1.MatchingService.UpdateFairnessState:output_type -> temporal.server.api.matchingservice.v1.UpdateFairnessStateResponse
77, // 77: temporal.server.api.matchingservice.v1.MatchingService.CheckTaskQueueVersionMembership:output_type -> temporal.server.api.matchingservice.v1.CheckTaskQueueVersionMembershipResponse
39, // [39:78] is the sub-list for method output_type
0, // [0:39] 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_matchingservice_v1_service_proto_init() }
func file_temporal_server_api_matchingservice_v1_service_proto_init() {
if File_temporal_server_api_matchingservice_v1_service_proto != nil {
return
}
file_temporal_server_api_matchingservice_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_matchingservice_v1_service_proto_rawDesc), len(file_temporal_server_api_matchingservice_v1_service_proto_rawDesc)),
NumEnums: 0,
NumMessages: 0,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_temporal_server_api_matchingservice_v1_service_proto_goTypes,
DependencyIndexes: file_temporal_server_api_matchingservice_v1_service_proto_depIdxs,
}.Build()
File_temporal_server_api_matchingservice_v1_service_proto = out.File
file_temporal_server_api_matchingservice_v1_service_proto_goTypes = nil
file_temporal_server_api_matchingservice_v1_service_proto_depIdxs = nil
}
Reference in New Issue View Git Blame Copy Permalink