Add timeout to error send

open-telemetry · Feb 29, 2024 · 7848e80 · 7848e80
1 parent d5d960d
commit 7848e80
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/service/internal/proctelemetry/config.go b/service/internal/proctelemetry/config.go
@@ -152,7 +152,10 @@ func InitPrometheusServer(registry *prometheus.Registry, address string, asyncEr
 	go func() {
 		defer serverWG.Done()
 		if serveErr := server.ListenAndServe(); serveErr != nil && !errors.Is(serveErr, http.ErrServerClosed) {
-			asyncErrorChannel <- serveErr
+			select {
+			case asyncErrorChannel <- serveErr:
+			case <-time.After(1 * time.Second):
+			}
 		}
 	}()
 	return server