Atlas › Test
priority.fairnessKey
Exact test identity: go.temporal.io/server/common/activityoptions/TestMergeActivityOptionsCoversAllFields/updates/priority.fairnessKey
- Package
go.temporal.io/server/common/activityoptions- Suite / test hierarchy
TestMergeActivityOptionsCoversAllFields/updates/priority.fairnessKey- Test
priority.fairnessKey- Introduced at
- merge.go ×1 Frontier kind: Joint frontier
- Covered ranges
- 20
- Covered lines
- 22
- Covered files
- 1
Covered source
Expand a file to inspect source; the > gutter marks covered lines.
go.temporal.io/server/common/activityoptions/merge.go 22 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 {
18
return serviceerror.NewInvalidArgument("TaskQueue is not provided")
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 {
merge.go
59
return serviceerror.NewInvalidArgument("Priority is not provided")
60
}
61
>
if mergeInto.Priority == nil {
merge.go
62
>
mergeInto.Priority = &commonpb.Priority{}
merge.go
63
>
}
64
>
mergeInto.Priority.FairnessKey = mergeFrom.GetPriority().GetFairnessKey()
merge.go
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
129
}