From 6d61987ff64b2caf9f6075a2c6dd44878d7543b8 Mon Sep 17 00:00:00 2001 From: Fusl Date: Mon, 2 May 2022 10:00:44 +0000 Subject: [PATCH] lets increase the redis pool size --- main.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/main.go b/main.go index 49c51ad..f97b00c 100644 --- a/main.go +++ b/main.go @@ -86,15 +86,15 @@ func (that *ProjectBackfeedManager) PopItem(blocking bool) (*BackfeedItem, bool) select { case <-that.Context.Done(): return nil, false - case item := <-that.C: - return item, true + case item, ok := <-that.C: + return item, ok } } else { select { case <-that.Context.Done(): return nil, false - case item := <-that.C: - return item, true + case item, ok := <-that.C: + return item, ok default: return nil, false } @@ -511,6 +511,7 @@ func main() { log.Panicf("invalid REDIS_LEGACY url: %s", err) } legacyRedisOptions.ReadTimeout = 15 * time.Minute + legacyRedisOptions.PoolSize = 128 legacyRedisClient := redis.NewClient(legacyRedisOptions) backfeedRedisClient := redis.NewClusterClient(&redis.ClusterOptions{ @@ -518,6 +519,7 @@ func main() { Username: os.Getenv("REDIS_BACKFEED_USERNAME"), Password: os.Getenv("REDIS_BACKFEED_PASSWORD"), ReadTimeout: 15 * time.Minute, + PoolSize: 256, }) legacyRedisMetricsHook := redisprom.NewHook(