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))