From e892e2d2be715badda2dd08e4c67600352c4696e Mon Sep 17 00:00:00 2001 From: Ulric Qin Date: Wed, 13 Apr 2022 20:16:11 +0800 Subject: [PATCH] code refactor --- inputs/redis/redis.go | 1 + 1 file changed, 1 insertion(+) diff --git a/inputs/redis/redis.go b/inputs/redis/redis.go index 8bb487e..664b1f8 100644 --- a/inputs/redis/redis.go +++ b/inputs/redis/redis.go @@ -81,6 +81,7 @@ func (t *Target) LoopGather(r *Redis, queue chan *types.Sample) { for { select { case <-t.quit: + close(t.quit) return default: time.Sleep(t.getInterval(r))