Function BenchmarkPoolGetPut

pool_pubsub_bench_test.go:65–97

============================================================================= POOL BENCHMARKS ============================================================================= BenchmarkPoolGetPut benchmarks the core pool Get/Put operations

(b *testing.B)

// BenchmarkPoolGetPut benchmarks the core pool Get/Put operations
func BenchmarkPoolGetPut(b *testing.B) {
	ctx := context.Background()

	poolSizes := []int{1, 2, 4, 8, 16, 32, 64, 128}

	for _, poolSize := range poolSizes {
		b.Run(fmt.Sprintf("PoolSize_%d", poolSize), func(b *testing.B) {
			connPool := pool.NewConnPool(&pool.Options{
				Dialer:             dummyDialer,
				PoolSize:           int32(poolSize),
				MaxConcurrentDials: poolSize,
				PoolTimeout:        time.Second,
				DialTimeout:        time.Second,
				ConnMaxIdleTime:    time.Hour,
				MinIdleConns:       int32(0), // Start with no idle connections
			})
			defer connPool.Close()

			b.ResetTimer()
			b.ReportAllocs()

			b.RunParallel(func(pb *testing.PB) {
				for pb.Next() {
					cn, err := connPool.Get(ctx)
					if err != nil {
						b.Fatal(err)
					}
					connPool.Put(ctx, cn)
				}
			})
		})
	}
}

// BenchmarkPoolGetPutWithMinIdle benchmarks pool operations with MinIdleConns
func BenchmarkPoolGetPutWithMinIdle(b *testing.B) {