Vihren Atlas

Atlas › Test

taskQueue.name

go.temporal.io/server/common/activityoptions/TestMergeActivityOptionsCoversAllFields/updates/taskQueue.name

Package
go.temporal.io/server/common/activityoptions
Suite / test hierarchy
TestMergeActivityOptionsCoversAllFields/updates/taskQueue.name
Test
taskQueue.name
Introduced at
merge.go ×1 Joint frontier
Covered ranges
20
Covered lines
21
Covered files
1

Covered source

Expand a file to inspect source; the > gutter marks covered lines.

go.temporal.io/server/common/activityoptions/merge.go 21 covered LOC · 20 ranges

Open complete file

13 //
14 //nolint:revive // cyclomatic: field-mask application requires explicit handling of each supported field
15 > func MergeActivityOptions(mergeInto, mergeFrom *activitypb.ActivityOptions, updateFields map[string]struct{}) error { merge.go
16 > if _, ok := updateFields["taskQueue.name"]; ok {
17 > if mergeFrom.GetTaskQueue() == nil { merge.go
18 return serviceerror.NewInvalidArgument("TaskQueue is not provided")
19 }
20 > if mergeInto.TaskQueue == nil { merge.go
21 > mergeInto.TaskQueue = mergeFrom.GetTaskQueue() merge.go
22 > } else { merge.go
23 mergeInto.TaskQueue.Name = mergeFrom.GetTaskQueue().GetName()
24 }
25 }
26
27 > if _, ok := updateFields["scheduleToCloseTimeout"]; ok { merge.go
28 mergeInto.ScheduleToCloseTimeout = mergeFrom.GetScheduleToCloseTimeout()
29 }
30
31 > if _, ok := updateFields["scheduleToStartTimeout"]; ok { merge.go
32 mergeInto.ScheduleToStartTimeout = mergeFrom.GetScheduleToStartTimeout()
33 }
34
35 > if _, ok := updateFields["startToCloseTimeout"]; ok { merge.go
36 mergeInto.StartToCloseTimeout = mergeFrom.GetStartToCloseTimeout()
37 }
38
39 > if _, ok := updateFields["heartbeatTimeout"]; ok { merge.go
40 mergeInto.HeartbeatTimeout = mergeFrom.GetHeartbeatTimeout()
41 }
42
43 > if _, ok := updateFields["priority"]; ok { merge.go
44 mergeInto.Priority = mergeFrom.GetPriority()
45 }
46
47 > if _, ok := updateFields["priority.priorityKey"]; ok { merge.go
48 if mergeFrom.GetPriority() == nil {
49 return serviceerror.NewInvalidArgument("Priority is not provided")
55 }
56
57 > if _, ok := updateFields["priority.fairnessKey"]; ok { merge.go
58 if mergeFrom.GetPriority() == nil {
59 return serviceerror.NewInvalidArgument("Priority is not provided")
65 }
66
67 > if _, ok := updateFields["priority.fairnessWeight"]; ok { merge.go
68 if mergeFrom.GetPriority() == nil {
69 return serviceerror.NewInvalidArgument("Priority is not provided")
75 }
76
77 > if _, ok := updateFields["retryPolicy"]; ok { merge.go
78 if mergeFrom.GetRetryPolicy() == nil {
79 return serviceerror.NewInvalidArgument("RetryPolicy is not provided")
82 }
83
84 > if _, ok := updateFields["retryPolicy.initialInterval"]; ok { merge.go
85 if mergeFrom.GetRetryPolicy() == nil {
86 return serviceerror.NewInvalidArgument("RetryPolicy is not provided")
92 }
93
94 > if _, ok := updateFields["retryPolicy.backoffCoefficient"]; ok { merge.go
95 if mergeFrom.GetRetryPolicy() == nil {
96 return serviceerror.NewInvalidArgument("RetryPolicy is not provided")
102 }
103
104 > if _, ok := updateFields["retryPolicy.maximumInterval"]; ok { merge.go
105 if mergeFrom.GetRetryPolicy() == nil {
106 return serviceerror.NewInvalidArgument("RetryPolicy is not provided")
112 }
113
114 > if _, ok := updateFields["retryPolicy.maximumAttempts"]; ok { merge.go
115 if mergeFrom.GetRetryPolicy() == nil {
116 return serviceerror.NewInvalidArgument("RetryPolicy is not provided")
122 }
123
124 > if _, ok := updateFields["startDelay"]; ok { merge.go
125 mergeInto.StartDelay = mergeFrom.GetStartDelay()
126 }
127
128 > return nil merge.go
129 }