code refactor

2022-04-13 20:16:11 +08:00 · 2022-04-13 20:16:11 +08:00 · e892e2d2be
parent 8e14600321
commit e892e2d2be
1 changed files with 1 additions and 0 deletions
--- 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))