Vihren Atlas

Atlas › Test

TestDedupPollers_NoDuplicates

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

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

Co-introduced tests

1 other test enter at the same concept.

Covered source

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

go.temporal.io/server/common/taskqueue/stats.go 9 covered LOC · 3 ranges

Open complete file

19
20 // DedupPollers removes duplicate pollers by identity.
21 > func DedupPollers(pollerInfos []*taskqueuepb.PollerInfo) []*taskqueuepb.PollerInfo { stats.go
22 > allKeys := make(map[string]bool)
23 > var list []*taskqueuepb.PollerInfo
24 > for _, item := range pollerInfos {
25 > if _, value := allKeys[item.GetIdentity()]; !value { stats.go
26 > allKeys[item.GetIdentity()] = true
27 > list = append(list, item)
28 > }
29 }
30 > return list stats.go
31 }
32