Vihren Atlas

request_response.pb.go ×12

Code frontier

unlabeled · c_442b8ef776af

4 tests · 43955 LOC · 757 files · introduces 0 tests · 137 LOC · 12 files

Introduces — evidence that enters the hierarchy at this concept

Code
38 ranges137 lines · 12 files
Tests
0 tests

Contains — complete concept membership

All code (extent)
10368 ranges43955 lines · 757 files · Browse complete extent
All tests (intent)
4 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.

12 files ranked by introduced lines: 137 introduced LOC across 38 ranges. Expand a file to inspect source; the > gutter marks introduced lines.

go.temporal.io/server/api/adminservice/v1/request_response.pb.go 60 introduced LOC · 12 ranges

Open complete file

3414 }
3415
3416 > func (x *GetTaskQueueTasksRequest) Reset() { request_response.pb.go
3417 > *x = GetTaskQueueTasksRequest{}
3418 > mi := &file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[55]
3419 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3420 > ms.StoreMessageInfo(mi)
3421 > }
3422
3423 func (x *GetTaskQueueTasksRequest) String() string {
3427 func (*GetTaskQueueTasksRequest) ProtoMessage() {}
3428
3429 > func (x *GetTaskQueueTasksRequest) ProtoReflect() protoreflect.Message { request_response.pb.go
3430 > mi := &file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[55]
3431 > if x != nil {
3432 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3433 > if ms.LoadMessageInfo() == nil {
3434 > ms.StoreMessageInfo(mi)
3435 > }
3436 > return ms
3437 }
3438 return mi.MessageOf(x)
3444 }
3445
3446 > func (x *GetTaskQueueTasksRequest) GetNamespace() string { request_response.pb.go
3447 > if x != nil {
3448 > return x.Namespace
3449 > }
3450 return ""
3451 }
3452
3453 > func (x *GetTaskQueueTasksRequest) GetTaskQueue() string { request_response.pb.go
3454 > if x != nil {
3455 > return x.TaskQueue
3456 > }
3457 return ""
3458 }
3459
3460 > func (x *GetTaskQueueTasksRequest) GetTaskQueueType() v16.TaskQueueType { request_response.pb.go
3461 > if x != nil {
3462 > return x.TaskQueueType
3463 > }
3464 return v16.TaskQueueType(0)
3465 }
3466
3467 > func (x *GetTaskQueueTasksRequest) GetMinPass() int64 { request_response.pb.go
3468 > if x != nil {
3469 > return x.MinPass
3470 > }
3471 return 0
3472 }
3473
3474 > func (x *GetTaskQueueTasksRequest) GetMinTaskId() int64 { request_response.pb.go
3475 > if x != nil {
3476 > return x.MinTaskId
3477 > }
3478 return 0
3479 }
3480
3481 > func (x *GetTaskQueueTasksRequest) GetMaxTaskId() int64 { request_response.pb.go
3482 > if x != nil {
3483 > return x.MaxTaskId
3484 > }
3485 return 0
3486 }
3487
3488 > func (x *GetTaskQueueTasksRequest) GetBatchSize() int32 { request_response.pb.go
3489 > if x != nil {
3490 > return x.BatchSize
3491 > }
3492 return 0
3493 }
3500 }
3501
3502 > func (x *GetTaskQueueTasksRequest) GetSubqueue() int32 { request_response.pb.go
3503 > if x != nil {
3504 > return x.Subqueue
3505 > }
3506 return 0
3507 }
3515 }
3516
3517 > func (x *GetTaskQueueTasksResponse) Reset() { request_response.pb.go
3518 > *x = GetTaskQueueTasksResponse{}
3519 > mi := &file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[56]
3520 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3521 > ms.StoreMessageInfo(mi)
3522 > }
3523
3524 func (x *GetTaskQueueTasksResponse) String() string {
3528 func (*GetTaskQueueTasksResponse) ProtoMessage() {}
3529
3530 > func (x *GetTaskQueueTasksResponse) ProtoReflect() protoreflect.Message { request_response.pb.go
3531 > mi := &file_temporal_server_api_adminservice_v1_request_response_proto_msgTypes[56]
3532 > if x != nil {
3533 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
3534 > if ms.LoadMessageInfo() == nil {
3535 > ms.StoreMessageInfo(mi)
3536 > }
3537 > return ms
3538 }
3539 return mi.MessageOf(x)
go.temporal.io/server/service/frontend/admin_handler.go 27 introduced LOC · 6 ranges

Open complete file

1743 ctx context.Context,
1744 request *adminservice.GetTaskQueueTasksRequest,
1745 > ) (_ *adminservice.GetTaskQueueTasksResponse, err error) { admin_handler.go
1746 > defer log.CapturePanic(adh.logger, &err)
1747 >
1748 > if request == nil {
1749 return nil, errRequestNotSet
1750 }
1751
1752 > namespaceID, err := adh.namespaceRegistry.GetNamespaceID(namespace.Name(request.GetNamespace())) admin_handler.go
1753 > if err != nil {
1754 return nil, err
1755 }
1756
1757 > var taskManager persistence.TaskManager admin_handler.go
1758 > if request.GetMinPass() != 0 {
1759 if adh.fairTaskManager == nil {
1760 return nil, serviceerror.NewInvalidArgument("Fairness table is not available on this cluster")
1762 taskManager = adh.fairTaskManager
1763 request.MaxTaskId = math.MaxInt64 // required for fairness GetTasks call
1764 > } else { admin_handler.go
1765 > taskManager = adh.taskManager
1766 > }
1767
1768 > resp, err := taskManager.GetTasks(ctx, &persistence.GetTasksRequest{ admin_handler.go
1769 > NamespaceID: namespaceID.String(),
1770 > TaskQueue: request.GetTaskQueue(),
1771 > TaskType: request.GetTaskQueueType(),
1772 > InclusiveMinTaskID: request.GetMinTaskId(),
1773 > ExclusiveMaxTaskID: request.GetMaxTaskId(),
1774 > InclusiveMinPass: request.GetMinPass(),
1775 > Subqueue: int(request.GetSubqueue()),
1776 > PageSize: int(request.GetBatchSize()),
1777 > NextPageToken: request.NextPageToken,
1778 > })
1779 > if err != nil {
1780 return nil, err
1781 }
1782
1783 > return &adminservice.GetTaskQueueTasksResponse{ admin_handler.go
1784 > Tasks: resp.Tasks,
1785 > NextPageToken: resp.NextPageToken,
1786 > }, nil
1787 }
1788
go.temporal.io/server/api/adminservice/v1/service_grpc.pb.go 17 introduced LOC · 5 ranges

Open complete file

424 }
425
426 > func (c *adminServiceClient) GetTaskQueueTasks(ctx context.Context, in *GetTaskQueueTasksRequest, opts ...grpc.CallOption) (*GetTaskQueueTasksResponse, error) { service_grpc.pb.go
427 > out := new(GetTaskQueueTasksResponse)
428 > err := c.cc.Invoke(ctx, AdminService_GetTaskQueueTasks_FullMethodName, in, out, opts...)
429 > if err != nil {
430 return nil, err
431 }
432 > return out, nil service_grpc.pb.go
433 }
434
1363 }
1364
1365 > func _AdminService_GetTaskQueueTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { service_grpc.pb.go
1366 > in := new(GetTaskQueueTasksRequest)
1367 > if err := dec(in); err != nil {
1368 return nil, err
1369 }
1370 > if interceptor == nil { service_grpc.pb.go
1371 return srv.(AdminServiceServer).GetTaskQueueTasks(ctx, in)
1372 }
1373 > info := &grpc.UnaryServerInfo{ service_grpc.pb.go
1374 > Server: srv,
1375 > FullMethod: AdminService_GetTaskQueueTasks_FullMethodName,
1376 > }
1377 > handler := func(ctx context.Context, req interface{}) (interface{}, error) {
1378 > return srv.(AdminServiceServer).GetTaskQueueTasks(ctx, req.(*GetTaskQueueTasksRequest))
1379 > }
1380 > return interceptor(ctx, in, info, handler)
1381 }
1382
go.temporal.io/server/common/util.go 7 introduced LOC · 1 range

Open complete file

518
519 // GenerateRandomString is used for generate test string
520 > func GenerateRandomString(n int) string { util.go
521 > letterRunes := []rune("random")
522 > b := make([]rune, n)
523 > for i := range b {
524 > b[i] = letterRunes[rand.Intn(len(letterRunes))]
525 > }
526 > return string(b)
527 }
528
go.temporal.io/server/common/persistence/sql/sqlplugin/sqlite/plugin.go 5 introduced LOC · 4 ranges

Open complete file

104 walEnabled := strings.EqualFold(cfg.ConnectAttributes["journal_mode"], "wal")
105 if cfg.MaxConns > 0 {
106 > if cfg.MaxConns > 1 && !walEnabled { plugin.go
107 logger.Warn(
108 "SQLite MaxConns > 1 without WAL mode (journal_mode=wal) may cause 'database is locked' errors. "+
111 )
112 }
113 > db.SetMaxOpenConns(cfg.MaxConns) plugin.go
114 } else {
115 db.SetMaxOpenConns(1)
116 }
117 if cfg.MaxIdleConns > 0 {
118 > db.SetMaxIdleConns(cfg.MaxIdleConns) plugin.go
119 } else {
120 db.SetMaxIdleConns(1)
121 }
122 if cfg.MaxConnLifetime > 0 {
123 > db.SetConnMaxLifetime(cfg.MaxConnLifetime) plugin.go
124 > }
125 // For in-memory databases, the database is deleted when the last connection
126 // closes. Set ConnMaxIdleTime to 0 (infinite) to prevent idle connections
go.temporal.io/server/common/persistence/persistence_rate_limited_clients.go 4 introduced LOC · 2 ranges

Open complete file

648 ctx context.Context,
649 request *CreateNamespaceRequest,
650 > ) (*CreateNamespaceResponse, error) { persistence_rate_limited_clients.go
651 > if err := allow(ctx, "CreateNamespace", CallerSegmentMissing, p.systemRateLimiter, p.namespaceRateLimiter, p.shardRateLimiter); err != nil {
652 return nil, err
653 }
654
655 > response, err := p.persistence.CreateNamespace(ctx, request) persistence_rate_limited_clients.go
656 > return response, err
657 }
658
go.temporal.io/server/common/resource/fx.go 4 introduced LOC · 2 ranges

Open complete file

508 frontendURL := cfg.PublicClient.HostPort
509 if frontendURL == "" {
510 > if hasIFE { fx.go
511 frontendURL = resolver.MakeURL(primitives.InternalFrontendService)
512 > } else { fx.go
513 > frontendURL = resolver.MakeURL(primitives.FrontendService)
514 > }
515 }
516 frontendHTTPURL := cfg.PublicClient.HTTPHostPort
go.temporal.io/server/temporal/server_option.go 4 introduced LOC · 1 range

Open complete file

195 func WithChainedFrontendGrpcInterceptors(
196 interceptors ...grpc.UnaryServerInterceptor,
197 > ) ServerOption { server_option.go
198 > return applyFunc(func(s *serverOptions) {
199 > s.customFrontendInterceptors = interceptors
200 > })
201 }
202
go.temporal.io/server/common/log/with_logger.go 3 introduced LOC · 1 range

Open complete file

44
45 // Warn writes message to the log (if enabled).
46 > func (l *withLogger) Warn(msg string, tags ...tag.Tag) { with_logger.go
47 > l.logger.Warn(msg, l.prependTags(tags)...)
48 > }
49
50 // Error writes message to the log (if enabled).
go.temporal.io/server/common/namespace/nsregistry/registry.go 2 introduced LOC · 1 range

Open complete file

395 ns, err = r.getNamespaceByNamePersistence(name)
396 } else {
397 > ns, err = r.GetNamespace(name) registry.go
398 > }
399 if err != nil {
400 return namespace.CustomSearchAttributesMapper{}, err
go.temporal.io/server/common/persistence/persistence_metric_clients.go 2 introduced LOC · 1 range

Open complete file

430 case tasks.CategoryIDReplication:
431 operation = metrics.PersistenceGetReplicationTasksScope
432 > case tasks.CategoryIDArchival: persistence_metric_clients.go
433 > operation = metrics.PersistenceGetArchivalTasksScope
434 case tasks.CategoryIDOutbound:
435 operation = metrics.PersistenceGetOutboundTasksScope
go.temporal.io/server/service/frontend/http_api_server.go 2 introduced LOC · 2 ranges

Open complete file

102 // Wrap the listener in a TLS listener if there is any TLS config
103 if tlsConfigProvider != nil {
104 > if tlsConfig, err := tlsConfigProvider.GetFrontendServerConfig(); err != nil { http_api_server.go
105 return nil, fmt.Errorf("failed getting TLS config for HTTP API: %w", err)
106 > } else if tlsConfig != nil { http_api_server.go
107 listener = tls.NewListener(listener, tlsConfig)
108 }

Direct hierarchy

Parents

Children