Skip to content

Commit b7c275e

Browse files
committed
Suppress redisClient.Close errors in latency tests
1 parent 37f1da2 commit b7c275e

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

e2e/distributed_latency_test.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ func TestDistributedLatencyTracking(t *testing.T) {
2929
redisClient := goredis.NewClient(&goredis.Options{
3030
Addr: mr.Addr(),
3131
})
32-
defer redisClient.Close()
32+
defer func() { _ = redisClient.Close() }()
3333

3434
logger, _ := zap.NewDevelopment()
3535

@@ -129,7 +129,7 @@ func TestMultiPodFailover(t *testing.T) {
129129
redisClient := goredis.NewClient(&goredis.Options{
130130
Addr: mr.Addr(),
131131
})
132-
defer redisClient.Close()
132+
defer func() { _ = redisClient.Close() }()
133133

134134
logger, _ := zap.NewDevelopment()
135135
tracker := redis.NewLatencyTracker(redisClient, logger)
@@ -159,7 +159,7 @@ func TestMultiPodFailover(t *testing.T) {
159159

160160
// Verify we can identify the fastest model
161161
var fastestModel string
162-
var fastestLatency time.Duration = 1 * time.Hour
162+
fastestLatency := 1 * time.Hour
163163

164164
for model, stats := range allStats {
165165
t.Logf("Model: %s, Avg: %v, P95: %v", model, stats.Average, stats.P95)
@@ -184,7 +184,7 @@ func TestConcurrentLatencyUpdates(t *testing.T) {
184184
redisClient := goredis.NewClient(&goredis.Options{
185185
Addr: mr.Addr(),
186186
})
187-
defer redisClient.Close()
187+
defer func() { _ = redisClient.Close() }()
188188

189189
logger := zap.NewNop() // Silence logs for concurrency test
190190
tracker := redis.NewLatencyTracker(redisClient, logger)
@@ -248,7 +248,7 @@ func TestLatencyBasedRouting(t *testing.T) {
248248
redisClient := goredis.NewClient(&goredis.Options{
249249
Addr: mr.Addr(),
250250
})
251-
defer redisClient.Close()
251+
defer func() { _ = redisClient.Close() }()
252252

253253
logger, _ := zap.NewDevelopment()
254254

@@ -313,7 +313,7 @@ func TestHealthScoreCalculation(t *testing.T) {
313313
redisClient := goredis.NewClient(&goredis.Options{
314314
Addr: mr.Addr(),
315315
})
316-
defer redisClient.Close()
316+
defer func() { _ = redisClient.Close() }()
317317

318318
logger, _ := zap.NewDevelopment()
319319
tracker := redis.NewLatencyTracker(redisClient, logger)

0 commit comments

Comments
 (0)