Vihren Atlas

request_response.pb.go ×4

Joint frontier

unlabeled · c_4e8958eb6e68

7 tests · 2150 LOC · 80 files · introduces 1 test · 40 LOC · 3 files

Introduces — evidence that enters the hierarchy at this concept

Code
10 ranges40 lines · 3 files
Tests
1 test

Contains — complete concept membership

All code (extent)
373 ranges2150 lines · 80 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.

1 test introduced at this concept.

Introduced code

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

3 files ranked by introduced lines: 40 introduced LOC across 10 ranges. Expand a file to inspect source; the > gutter marks introduced lines.

go.temporal.io/server/api/historyservice/v1/request_response.pb.go 22 introduced LOC · 4 ranges

Open complete file

8361 }
8362
8363 > func (x *DeleteDLQTasksRequest) Reset() { request_response.pb.go
8364 > *x = DeleteDLQTasksRequest{}
8365 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[126]
8366 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8367 > ms.StoreMessageInfo(mi)
8368 > }
8369
8370 func (x *DeleteDLQTasksRequest) String() string {
8377 mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[126]
8378 if x != nil {
8379 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) request_response.pb.go
8380 > if ms.LoadMessageInfo() == nil {
8381 > ms.StoreMessageInfo(mi)
8382 > }
8383 > return ms
8384 }
8385 return mi.MessageOf(x)
8413 }
8414
8415 > func (x *DeleteDLQTasksResponse) Reset() { request_response.pb.go
8416 > *x = DeleteDLQTasksResponse{}
8417 > mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[127]
8418 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
8419 > ms.StoreMessageInfo(mi)
8420 > }
8421
8422 func (x *DeleteDLQTasksResponse) String() string {
8429 mi := &file_temporal_server_api_historyservice_v1_request_response_proto_msgTypes[127]
8430 if x != nil {
8431 > ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) request_response.pb.go
8432 > if ms.LoadMessageInfo() == nil {
8433 > ms.StoreMessageInfo(mi)
8434 > }
8435 > return ms
8436 }
8437 return mi.MessageOf(x)
go.temporal.io/server/api/historyservice/v1/service_grpc.pb.go 11 introduced LOC · 4 ranges

Open complete file

962 }
963
964 > func (c *historyServiceClient) DeleteDLQTasks(ctx context.Context, in *DeleteDLQTasksRequest, opts ...grpc.CallOption) (*DeleteDLQTasksResponse, error) { service_grpc.pb.go
965 > out := new(DeleteDLQTasksResponse)
966 > err := c.cc.Invoke(ctx, HistoryService_DeleteDLQTasks_FullMethodName, in, out, opts...)
967 > if err != nil {
968 return nil, err
969 }
970 > return out, nil service_grpc.pb.go
971 }
972
2744 }
2745
2746 > func _HistoryService_DeleteDLQTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { service_grpc.pb.go
2747 > in := new(DeleteDLQTasksRequest)
2748 > if err := dec(in); err != nil {
2749 return nil, err
2750 }
2751 > if interceptor == nil { service_grpc.pb.go
2752 > return srv.(HistoryServiceServer).DeleteDLQTasks(ctx, in)
2753 > }
2754 info := &grpc.UnaryServerInfo{
2755 Server: srv,
go.temporal.io/server/client/history/client_gen.go 7 introduced LOC · 2 ranges

Open complete file

124 var response *historyservice.DeleteDLQTasksResponse
125 op := func(ctx context.Context, client historyservice.HistoryServiceClient) error {
126 > var err error client_gen.go
127 > ctx, cancel := c.createContext(ctx)
128 > defer cancel()
129 > response, err = client.DeleteDLQTasks(ctx, request, opts...)
130 > return err
131 > }
132 if err := c.executeWithRedirect(ctx, shardID, op); err != nil {
133 return nil, err
134 }
135 > return response, nil client_gen.go
136 }
137

Direct hierarchy

Parents

Children