From 066d2a1dc50462c5ce3ec49410f2be277ba26549 Mon Sep 17 00:00:00 2001 From: Mathieu Lecarme Date: Fri, 17 Jun 2022 15:07:54 +0200 Subject: [PATCH] Forever loop over loki websocket can be stopped. --- pkg/acquisition/modules/loki/loki.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/acquisition/modules/loki/loki.go b/pkg/acquisition/modules/loki/loki.go index 8c3ac48c4..4c60c663b 100644 --- a/pkg/acquisition/modules/loki/loki.go +++ b/pkg/acquisition/modules/loki/loki.go @@ -351,6 +351,9 @@ func (l *LokiSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) er defer c.Close() var resp Tail for { // draining the websocket + if !t.Alive() { // someone want to close this loop + return nil + } t, msg, err := c.ReadMessage() if len(msg) == 0 { time.Sleep(100 * time.Millisecond)