From e7b8088c41bd115bfcbec90c750bdd68a6e603da Mon Sep 17 00:00:00 2001 From: Holger Obermaier <40787752+ho-ob@users.noreply.github.com> Date: Tue, 19 Apr 2022 11:42:46 +0200 Subject: [PATCH] Extended go routine use case in sample receiver --- receivers/sampleReceiver.go | 26 ++++++++++++++++++-------- 1 file changed, 18 insertions(+), 8 deletions(-) diff --git a/receivers/sampleReceiver.go b/receivers/sampleReceiver.go index 2892d56..19d6f25 100644 --- a/receivers/sampleReceiver.go +++ b/receivers/sampleReceiver.go @@ -36,16 +36,26 @@ func (r *SampleReceiver) Start() { // or use own go routine but always make sure it exits // as soon as it gets the signal of the r.done channel + // + // r.done = make(chan bool) // r.wg.Add(1) // go func() { - // for { - // select { - // case <-r.done: - // r.wg.Done() - // return - // } - // } - // r.wg.Done() + // defer r.wg.Done() + // + // // Create ticker + // ticker := time.NewTicker(30 * time.Second) + // defer ticker.Stop() + // + // for { + // readMetric() + // select { + // case <-ticker.C: + // // process ticker event -> continue + // continue + // case <-r.done: + // return + // } + // } // }() }