Vihren Atlas

request_response.pb.go ×6

Code frontier

unlabeled · c_45d9c71a0a62

7 tests · 24136 LOC · 620 files · introduces 0 tests · 114 LOC · 8 files

Introduces — evidence that enters the hierarchy at this concept

Code
23 ranges114 lines · 8 files
Tests
0 tests

Contains — complete concept membership

All code (extent)
4877 ranges24136 lines · 620 files · Browse complete extent
All tests (intent)
7 testsBrowse complete intent

Neighbourhood graph

The orange circle is the focus. Violet and green circles are every ancestor and descendant, broader and narrower, at any distance; blue squares and pink diamonds are the introduced files and exact introduced tests of every visible concept, not only the focus's. Arrows point from broader to narrower concepts and bridge only concepts omitted from this view. Undirected links show source or test introduction. Concept and file size follows LOC; exact test nodes use test-count units.

Introduced files, introduced tests, and structurally relevant concept specialization

In the embedded map, ordinary wheel input scrolls the page; use the visible controls to zoom and drag to pan. Open the full-screen map for canvas navigation: wheel pans, Ctrl/Command plus wheel zooms, and arrow keys pan when this region is focused. On touch screens, open the full-screen map to pan or pinch. If JavaScript or WebGL is unavailable, use the native relationship evidence on this page.

Graph controls are ready.

Interactive rendering requires JavaScript and WebGL. Use the native relationship evidence on this page while the interactive map is unavailable.

Native relationship evidence

Every exact file and test below is linked only from the concept that introduces it.

Introduced tests

Every collected test enters the hierarchy at exactly one concept.

No tests are introduced at this concept. Its intent tests are introduced by other concepts.

Introduced code

Every collected source range enters the hierarchy at exactly one concept.

8 files ranked by introduced lines: 114 introduced LOC across 23 ranges. Expand a file to inspect source; the > gutter marks introduced lines.

go.temporal.io/server/api/matchingservice/v1/request_response.pb.go 36 introduced LOC · 6 ranges

Open complete file

3337 }
3338
3339 > func (x *ForceLoadTaskQueuePartitionRequest) Reset() { request_response.pb.go
3340 > *x = ForceLoadTaskQueuePartitionRequest{}
3341 > mi := &file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[43]
3342 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3343 > ms.StoreMessageInfo(mi)
3344 > }
3345
3346 func (x *ForceLoadTaskQueuePartitionRequest) String() string {
3350 func (*ForceLoadTaskQueuePartitionRequest) ProtoMessage() {}
3351
3352 > func (x *ForceLoadTaskQueuePartitionRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
3353 > mi := &file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[43]
3354 > if x != nil {
3355 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3356 > if ms.LoadMessageInfo() == nil {
3357 > ms.StoreMessageInfo(mi)
3358 > }
3359 > return ms
3360 }
3361 return mi.MessageOf(x)
3367 }
3368
3369 > func (x *ForceLoadTaskQueuePartitionRequest) GetNamespaceId() string { request_response.pb.go
3370 > if x != nil {
3371 > return x.NamespaceId
3372 > }
3373 return ""
3374 }
3375
3376 > func (x *ForceLoadTaskQueuePartitionRequest) GetTaskQueuePartition() *v18.TaskQueuePartition { request_response.pb.go
3377 > if x != nil {
3378 > return x.TaskQueuePartition
3379 > }
3380 return nil
3381 }
3388 }
3389
3390 > func (x *ForceLoadTaskQueuePartitionResponse) Reset() { request_response.pb.go
3391 > *x = ForceLoadTaskQueuePartitionResponse{}
3392 > mi := &file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[44]
3393 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3394 > ms.StoreMessageInfo(mi)
3395 > }
3396
3397 func (x *ForceLoadTaskQueuePartitionResponse) String() string {
3401 func (*ForceLoadTaskQueuePartitionResponse) ProtoMessage() {}
3402
3403 > func (x *ForceLoadTaskQueuePartitionResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
3404 > mi := &file_temporal_server_api_matchingservice_v1_request_response_proto_msgTypes[44]
3405 > if x != nil {
3406 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3407 > if ms.LoadMessageInfo() == nil {
3408 > ms.StoreMessageInfo(mi)
3409 > }
3410 > return ms
3411 }
3412 return mi.MessageOf(x)
go.temporal.io/server/service/matching/pri_forwarder.go 20 introduced LOC · 1 range

Open complete file

251 }
252 return newInternalStartedTask(&startedTaskInfo{workflowTaskInfo: resp}), nil
253 > case enumspb.TASK_QUEUE_TYPE_ACTIVITY: pri_forwarder.go
254 > resp, err := client.PollActivityTaskQueue(ctx, &matchingservice.PollActivityTaskQueueRequest{
255 > NamespaceId: target.TaskQueue().NamespaceId(),
256 > PollerId: pollerID,
257 > PollRequest: &workflowservice.PollActivityTaskQueueRequest{
258 > TaskQueue: &taskqueuepb.TaskQueue{
259 > Name: target.RpcName(),
260 > Kind: enumspb.TASK_QUEUE_KIND_NORMAL,
261 > },
262 > Identity: identity,
263 > TaskQueueMetadata: pollMetadata.taskQueueMetadata,
264 > WorkerVersionCapabilities: pollMetadata.workerVersionCapabilities,
265 > DeploymentOptions: pollMetadata.deploymentOptions,
266 > WorkerInstanceKey: pollMetadata.workerInstanceKey,
267 > WorkerControlTaskQueue: pollMetadata.workerControlTaskQueue,
268 > },
269 > ForwardedSource: source.RpcName(),
270 > Conditions: pollMetadata.conditions,
271 > })
272 > if err != nil {
273 return nil, err
274 } else if resp.TaskToken == nil {
go.temporal.io/server/api/matchingservice/v1/service_grpc.pb.go 17 introduced LOC · 5 ranges

Open complete file

488 }
489
490 > func (c *matchingServiceClient) ForceLoadTaskQueuePartition(ctx context.Context, in *ForceLoadTaskQueuePartitionRequest, opts ...grpc.CallOption) (*ForceLoadTaskQueuePartitionResponse, error) { service_grpc.pb.go
491 > out := new(ForceLoadTaskQueuePartitionResponse)
492 > err := c.cc.Invoke(ctx, MatchingService_ForceLoadTaskQueuePartition_FullMethodName, in, out, opts...)
493 > if err != nil {
494 return nil, err
495 }
496 > return out, nil service_grpc.pb.go
497 }
498
1425 }
1426
1427 > func _MatchingService_ForceLoadTaskQueuePartition_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { service_grpc.pb.go
1428 > in := new(ForceLoadTaskQueuePartitionRequest)
1429 > if err := dec(in); err != nil {
1430 return nil, err
1431 }
1432 > if interceptor == nil { service_grpc.pb.go
1433 return srv.(MatchingServiceServer).ForceLoadTaskQueuePartition(ctx, in)
1434 }
1435 > info := &grpc.UnaryServerInfo{ service_grpc.pb.go
1436 > Server: srv,
1437 > FullMethod: MatchingService_ForceLoadTaskQueuePartition_FullMethodName,
1438 > }
1439 > handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1440 > return srv.(MatchingServiceServer).ForceLoadTaskQueuePartition(ctx, req.(*ForceLoadTaskQueuePartitionRequest))
1441 > }
1442 > return interceptor(ctx, in, info, handler)
1443 }
1444
go.temporal.io/server/service/matching/handler.go 17 introduced LOC · 4 ranges

Open complete file

237
238 if request.GetForwardedSource() != "" {
239 > h.reportForwardedPerTaskQueueCounter(opMetrics, namespace.ID(request.GetNamespaceId())) handler.go
240 > }
241
242 if _, err := common.ValidateLongPollContextTimeoutIsSet(
265
266 if request.GetForwardedSource() != "" {
267 > h.reportForwardedPerTaskQueueCounter(opMetrics, namespace.ID(request.GetNamespaceId())) handler.go
268 > }
269
270 if _, err := common.ValidateLongPollContextTimeoutIsSet(
482 ctx context.Context,
483 request *matchingservice.ForceLoadTaskQueuePartitionRequest,
484 > ) (_ *matchingservice.ForceLoadTaskQueuePartitionResponse, retError error) { handler.go
485 > defer log.CapturePanic(h.logger, &retError)
486 > return h.engine.ForceLoadTaskQueuePartition(ctx, request)
487 > }
488
489 func (h *Handler) UpdateTaskQueueUserData(
692 }
693
694 > func (h *Handler) reportForwardedPerTaskQueueCounter(opMetrics metrics.Handler, namespaceId namespace.ID) { handler.go
695 > metrics.ForwardedPerTaskQueueCounter.With(opMetrics).Record(1)
696 > metrics.MatchingClientForwardedCounter.With(h.metricsHandler).
697 > Record(
698 > 1,
699 > metrics.OperationTag(metrics.MatchingAddWorkflowTaskScope),
700 > metrics.NamespaceTag(h.namespaceName(namespaceId).String()),
701 > metrics.ServiceRoleTag(metrics.MatchingRoleTagValue))
702 > }
703
704 func (h *Handler) UpdateTaskQueueConfig(
go.temporal.io/server/client/matching/client_gen.go 9 introduced LOC · 2 ranges

Open complete file

272 request *matchingservice.ForceLoadTaskQueuePartitionRequest,
273 opts ...grpc.CallOption,
274 > ) (*matchingservice.ForceLoadTaskQueuePartitionResponse, error) { client_gen.go
275 >
276 > p := tqid.PartitionFromPartitionProto(request.GetTaskQueuePartition(), request.GetNamespaceId())
277 >
278 > client, err := c.getClientForTaskQueuePartition(p)
279 > if err != nil {
280 return nil, err
281 }
282 > ctx, cancel := c.createContext(ctx) client_gen.go
283 > defer cancel()
284 > return client.ForceLoadTaskQueuePartition(ctx, request, opts...)
285 }
286
go.temporal.io/server/client/matching/metric_client_gen.go 7 introduced LOC · 2 ranges

Open complete file

196 request *matchingservice.ForceLoadTaskQueuePartitionRequest,
197 opts ...grpc.CallOption,
198 > ) (_ *matchingservice.ForceLoadTaskQueuePartitionResponse, retError error) { metric_client_gen.go
199 >
200 > metricsHandler, startTime := c.startMetricsRecording(ctx, "MatchingClientForceLoadTaskQueuePartition")
201 > defer func() {
202 > c.finishMetricsRecording(metricsHandler, startTime, retError)
203 > }()
204
205 > return c.client.ForceLoadTaskQueuePartition(ctx, request, opts...) metric_client_gen.go
206 }
207
go.temporal.io/server/service/matching/matching_engine.go 6 introduced LOC · 2 ranges

Open complete file

2529 ctx context.Context,
2530 req *matchingservice.ForceLoadTaskQueuePartitionRequest,
2531 > ) (*matchingservice.ForceLoadTaskQueuePartitionResponse, error) { matching_engine.go
2532 > partition := tqid.PartitionFromPartitionProto(req.GetTaskQueuePartition(), req.GetNamespaceId())
2533 > // Leverage getTaskQueuePartitionManager to check and then create the partition
2534 > _, wasUnloaded, err := e.getTaskQueuePartitionManager(ctx, partition, true, loadCauseForce)
2535 > if err != nil {
2536 return nil, err
2537 }
2538 > return &matchingservice.ForceLoadTaskQueuePartitionResponse{WasUnloaded: wasUnloaded}, nil matching_engine.go
2539 }
2540
go.temporal.io/server/client/matching/metric_client.go 2 introduced LOC · 1 range

Open complete file

196
197 switch {
198 > case forwardedFrom != "": metric_client.go
199 > metrics.MatchingClientForwardedCounter.With(metricsHandler).Record(1)
200 default:
201 // TODO: confirmed from metrics, it seems this error does happen at the moment...

Direct hierarchy

Parents

Children