(b *testing.B)
| 106 | } |
| 107 | |
| 108 | func BenchmarkUpdateRingState(b *testing.B) { |
| 109 | for _, numInstances := range []int{50, 100, 500} { |
| 110 | for _, numZones := range []int{1, 3} { |
| 111 | for _, numTokens := range []int{128, 256, 512} { |
| 112 | for _, updateTokens := range []bool{false, true} { |
| 113 | b.Run(fmt.Sprintf("num instances = %d, num zones = %d, num tokens = %d, update tokens = %t", numInstances, numZones, numTokens, updateTokens), func(b *testing.B) { |
| 114 | benchmarkUpdateRingState(b, NewRandomTokenGenerator(), numInstances, numZones, numTokens, updateTokens) |
| 115 | }) |
| 116 | } |
| 117 | } |
| 118 | } |
| 119 | } |
| 120 | } |
| 121 | |
| 122 | func benchmarkUpdateRingState(b *testing.B, g TokenGenerator, numInstances, numZones, numTokens int, updateTokens bool) { |
| 123 | cfg := Config{ |
nothing calls this directly
no test coverage detected