Vihren Atlas

Atlas › Test

TestMergeStats_RightOlderAge

go.temporal.io/server/common/taskqueue/TestMergeStats_RightOlderAge

Package
go.temporal.io/server/common/taskqueue
Suite / test hierarchy
TestMergeStats_RightOlderAge
Test
TestMergeStats_RightOlderAge
Introduced at
stats.go ×1 Joint frontier
Covered ranges
6
Covered lines
12
Covered files
1

Covered source

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

go.temporal.io/server/common/taskqueue/stats.go 12 covered LOC · 6 ranges

Open complete file

7
8 // MergeStats merges from into into. Mutates into.
9 > func MergeStats(into, from *taskqueuepb.TaskQueueStats) { stats.go
10 > if from == nil {
11 return
12 }
13 > into.ApproximateBacklogCount += from.ApproximateBacklogCount stats.go
14 > into.ApproximateBacklogAge = oldestBacklogAge(into.ApproximateBacklogAge, from.ApproximateBacklogAge)
15 > into.TasksAddRate += from.TasksAddRate
16 > into.TasksDispatchRate += from.TasksDispatchRate
17 > into.RateLimitingActive = into.RateLimitingActive || from.RateLimitingActive
18 }
19
31 }
32
33 > func oldestBacklogAge(left, right *durationpb.Duration) *durationpb.Duration { stats.go
34 > if left == nil {
35 left = durationpb.New(0)
36 }
37 > if right == nil { stats.go
38 right = durationpb.New(0)
39 }
40 > if left.AsDuration() > right.AsDuration() { stats.go
41 return left
42 }
43 > return right stats.go
44 }