once

Author: musa-asad

plugins/inputs/prometheus/target_allocator.go

@@ -9,6 +9,7 @@ import (
 	"os"
 	"path/filepath"
 	"strings"
+	"sync"
 	"time"
 
 	"github.com/go-kit/log"
@@ -42,6 +43,7 @@ type TargetAllocatorManager struct {
 	enabled             bool
 	host                component.Host
 	shutdownCh          chan struct{}
+	shutdownOnce        sync.Once
 	taReadyCh           chan struct{}
 	reloadConfigHandler func(config *promconfig.Config)
 	manager             *tamanager.Manager
@@ -177,7 +179,9 @@ func (tam *TargetAllocatorManager) Run() error {
 }
 func (tam *TargetAllocatorManager) Shutdown() {
 	tam.manager.Shutdown()
-	close(tam.shutdownCh)
+	tam.shutdownOnce.Do(func() {
+		close(tam.shutdownCh)
+	})
 }
 func (tam *TargetAllocatorManager) AttachReloadConfigHandler(handler func(config *promconfig.Config)) {
 	tam.reloadConfigHandler = handler