Function BenchmarkPubSubCreation

pool_pubsub_bench_test.go:196–215

BenchmarkPubSubCreation benchmarks PubSub creation and subscription

(b *testing.B)

// BenchmarkPubSubCreation benchmarks PubSub creation and subscription
func BenchmarkPubSubCreation(b *testing.B) {
	ctx := context.Background()

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

	for _, poolSize := range poolSizes {
		b.Run(fmt.Sprintf("PoolSize_%d", poolSize), func(b *testing.B) {
			client := benchmarkClient(poolSize)
			defer client.Close()

			b.ResetTimer()
			b.ReportAllocs()

			for i := 0; i < b.N; i++ {
				pubsub := client.Subscribe(ctx, "test-channel")
				pubsub.Close()
			}
		})
	}
}

// BenchmarkPubSubPatternCreation benchmarks PubSub pattern subscription
func BenchmarkPubSubPatternCreation(b *testing.B) {