Function TestMetricsUnderStress

extra/redisotel-native/metrics_stress_test.go:27–127

TestMetricsUnderStress validates metrics recording under concurrent load.

(t *testing.T)

// TestMetricsUnderStress validates metrics recording under concurrent load.
func TestMetricsUnderStress(t *testing.T) {
	ctx := context.Background()
	testClient := redis.NewClient(&redis.Options{Addr: "localhost:6379"})
	if err := testClient.Ping(ctx).Err(); err != nil {
		testClient.Close()
		t.Skip("Redis not available at localhost:6379")
	}
	testClient.Close()

	reader := metric.NewManualReader()
	meterProvider := metric.NewMeterProvider(metric.WithReader(reader))
	defer func() {
		_ = meterProvider.Shutdown(ctx)
	}()

	otel.SetMeterProvider(meterProvider)
	resetObservabilityForTest()

	otelInstance := GetObservabilityInstance()
	config := NewConfig().
		WithEnabled(true).
		WithMeterProvider(meterProvider).
		WithMetricGroups(MetricGroupAll)

	if err := otelInstance.Init(config); err != nil {
		t.Fatalf("Failed to initialize OTel: %v", err)
	}
	defer otelInstance.Shutdown()

	rdb := redis.NewClient(&redis.Options{
		Addr:         "localhost:6379",
		PoolSize:     stressTestConcurrency,
		MinIdleConns: 10,
	})
	defer rdb.Close()

	var opsCompleted atomic.Int64
	var opsErrors atomic.Int64
	startTime := time.Now()
	deadline := startTime.Add(stressTestDuration)

	statusTicker := time.NewTicker(stressTestStatusInterval)
	defer statusTicker.Stop()
	done := make(chan struct{})

	go func() {
		for {
			select {
			case <-statusTicker.C:
				elapsed := time.Since(startTime).Seconds()
				ops := opsCompleted.Load()
				t.Logf("[%.0fs] %d ops, %.1f ops/sec", elapsed, ops, float64(ops)/elapsed)
			case <-done:
				return
			}
		}
	}()