Function BenchmarkPoolGetRemove

internal/pool/bench_test.go:65–100

(b *testing.B)

}

func BenchmarkPoolGetRemove(b *testing.B) {
	ctx := context.Background()
	benchmarks := []poolGetRemoveBenchmark{
		{1},
		{2},
		{8},
		{32},
		{64},
		{128},
	}

	for _, bm := range benchmarks {
		b.Run(bm.String(), func(b *testing.B) {
			connPool := pool.NewConnPool(&pool.Options{
				Dialer:             dummyDialer,
				PoolSize:           int32(bm.poolSize),
				MaxConcurrentDials: bm.poolSize,
				PoolTimeout:        time.Second,
				DialTimeout:        1 * time.Second,
				ConnMaxIdleTime:    time.Hour,
			})

			b.ResetTimer()
			rmvErr := errors.New("Bench test remove")
			b.RunParallel(func(pb *testing.PB) {
				for pb.Next() {
					cn, err := connPool.Get(ctx)
					if err != nil {
						b.Fatal(err)
					}
					connPool.Remove(ctx, cn, rmvErr)
				}
			})
		})
	}
}