Copied from go-kit/log These tests are designed to be run with the race detector.
(t *testing.T, logger log.Logger, total int)
| 143 | // These tests are designed to be run with the race detector. |
| 144 | |
| 145 | func testConcurrency(t *testing.T, logger log.Logger, total int) { |
| 146 | n := int(math.Sqrt(float64(total))) |
| 147 | share := total / n |
| 148 | |
| 149 | var g errgroup.Group |
| 150 | for i := 0; i < n; i++ { |
| 151 | g.Go(func() error { |
| 152 | for i := 0; i < share; i++ { |
| 153 | if err := logger.Log("key", i); err != nil { |
| 154 | return err |
| 155 | } |
| 156 | } |
| 157 | return nil |
| 158 | }) |
| 159 | } |
| 160 | |
| 161 | require.NoError(t, g.Wait(), "concurrent logging error") |
| 162 | } |
| 163 | |
| 164 | func benchmarkRunner(b *testing.B, logger log.Logger, f func(log.Logger)) { |
| 165 | lc := log.With(logger, "common_key", "common_value") |
no test coverage detected