Atlas › Test

TestDedupPollers_Empty

Exact test identity: go.temporal.io/server/common/taskqueue/TestDedupPollers_Empty

Package: go.temporal.io/server/common/taskqueue
Suite / test hierarchy: TestDedupPollers_Empty
Test: TestDedupPollers_Empty
Introduced at: stats.go ×2 Frontier kind: Joint frontier
Covered ranges: 2
Covered lines: 5
Covered files: 1

Covered source

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

go.temporal.io/server/common/taskqueue/stats.go 5 covered LOC · 2 ranges

  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 {
  
  26
  
  			allKeys[item.GetIdentity()] = true

  28
  
  		}
  
  29
  
  	}
  
  30
  >
  	return list
  
stats.go

  31
  
  }
  
  32