Vihren Atlas

request_response.pb.go ×7

Joint frontier

unlabeled · c_fe901394d94e

8 tests · 3877 LOC · 200 files · introduces 2 tests · 58 LOC · 3 files

Introduces — evidence that enters the hierarchy at this concept

Code
14 ranges58 lines · 3 files
Tests
2 tests

Contains — complete concept membership

All code (extent)
572 ranges3877 lines · 200 files · Browse complete extent
All tests (intent)
8 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.

2 tests introduced at this concept.

Introduced code

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

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

go.temporal.io/server/api/historyservice/v1/request_response.pb.go 28 introduced LOC · 7 ranges

Open complete file

4176 }
4177
4178 > func (x *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v15.WorkflowExecutionConfig { request_response.pb.go
4179 > if x != nil {
4180 > return x.ExecutionConfig
4181 > }
4182 return nil
4183 }
4190 }
4191
4192 > func (x *DescribeWorkflowExecutionResponse) GetPendingActivities() []*v15.PendingActivityInfo { request_response.pb.go
4193 > if x != nil {
4194 > return x.PendingActivities
4195 > }
4196 return nil
4197 }
4198
4199 > func (x *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v15.PendingChildExecutionInfo { request_response.pb.go
4200 > if x != nil {
4201 > return x.PendingChildren
4202 > }
4203 return nil
4204 }
4205
4206 > func (x *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v15.PendingWorkflowTaskInfo { request_response.pb.go
4207 > if x != nil {
4208 > return x.PendingWorkflowTask
4209 > }
4210 return nil
4211 }
4212
4213 > func (x *DescribeWorkflowExecutionResponse) GetCallbacks() []*v15.CallbackInfo { request_response.pb.go
4214 > if x != nil {
4215 > return x.Callbacks
4216 > }
4217 return nil
4218 }
4219
4220 > func (x *DescribeWorkflowExecutionResponse) GetPendingNexusOperations() []*v15.PendingNexusOperationInfo { request_response.pb.go
4221 > if x != nil {
4222 > return x.PendingNexusOperations
4223 > }
4224 return nil
4225 }
4226
4227 > func (x *DescribeWorkflowExecutionResponse) GetWorkflowExtendedInfo() *v15.WorkflowExecutionExtendedInfo { request_response.pb.go
4228 > if x != nil {
4229 > return x.WorkflowExtendedInfo
4230 > }
4231 return nil
4232 }
go.temporal.io/server/service/frontend/workflow_handler.go 26 introduced LOC · 6 ranges

Open complete file

3284
3285 // DescribeWorkflowExecution returns information about the specified workflow execution.
3286 > func (wh *WorkflowHandler) DescribeWorkflowExecution(ctx context.Context, request *workflowservice.DescribeWorkflowExecutionRequest) (_ *workflowservice.DescribeWorkflowExecutionResponse, retError error) { workflow_handler.go
3287 > defer log.CapturePanic(wh.logger, &retError)
3288 >
3289 > if request == nil {
3290 return nil, errRequestNotSet
3291 }
3292
3293 > namespaceID, err := wh.namespaceRegistry.GetNamespaceID(namespace.Name(request.GetNamespace())) workflow_handler.go
3294 > if err != nil {
3295 return nil, err
3296 }
3297
3298 > if err := validateExecution(request.Execution); err != nil { workflow_handler.go
3299 return nil, err
3300 }
3301
3302 > response, err := wh.historyClient.DescribeWorkflowExecution(ctx, &historyservice.DescribeWorkflowExecutionRequest{ workflow_handler.go
3303 > NamespaceId: namespaceID.String(),
3304 > Request: request,
3305 > })
3306 >
3307 > if err != nil {
3308 return nil, err
3309 }
3310
3311 > if response.GetWorkflowExecutionInfo().GetSearchAttributes() != nil { workflow_handler.go
3312 saTypeMap, err := wh.saProvider.GetSearchAttributes(wh.visibilityMgr.GetIndexName(), false)
3313 if err != nil {
3324 }
3325
3326 > response.GetWorkflowExecutionInfo().VersioningInfo = worker_versioning.AddV31VersioningInfoToV32(response.GetWorkflowExecutionInfo().GetVersioningInfo()) workflow_handler.go
3327 >
3328 > return &workflowservice.DescribeWorkflowExecutionResponse{
3329 > ExecutionConfig: response.GetExecutionConfig(),
3330 > WorkflowExecutionInfo: response.GetWorkflowExecutionInfo(),
3331 > PendingActivities: response.GetPendingActivities(),
3332 > PendingChildren: response.GetPendingChildren(),
3333 > PendingWorkflowTask: response.GetPendingWorkflowTask(),
3334 > Callbacks: response.GetCallbacks(),
3335 > PendingNexusOperations: response.GetPendingNexusOperations(),
3336 > WorkflowExtendedInfo: response.GetWorkflowExtendedInfo(),
3337 > }, nil
3338 }
3339
go.temporal.io/server/common/worker_versioning/worker_versioning.go 4 introduced LOC · 1 range

Open complete file

1113 // We store versioning info in the modern v0.32 format, so call this before returning the object to readers
1114 // to mutatively populate the missing fields.
1115 > func AddV31VersioningInfoToV32(info *workflowpb.WorkflowExecutionVersioningInfo) *workflowpb.WorkflowExecutionVersioningInfo { worker_versioning.go
1116 > if info == nil {
1117 > return nil
1118 > }
1119 //nolint:staticcheck // SA1019: worker versioning v0.31
1120 if info.Version == "" && info.DeploymentVersion != nil {

Direct hierarchy

Parents

Children