From fc7061bd02072f8cbd4bb75ff7993a1fa5bb8559 Mon Sep 17 00:00:00 2001 From: yuhan6665 <1588741+yuhan6665@users.noreply.github.com> Date: Tue, 5 Mar 2024 23:10:33 -0500 Subject: [PATCH] Add initial check for burstObserver --- app/observatory/burst/healthping.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/app/observatory/burst/healthping.go b/app/observatory/burst/healthping.go index cde9fbc1a97a..2f0bbcc6676d 100644 --- a/app/observatory/burst/healthping.go +++ b/app/observatory/burst/healthping.go @@ -79,6 +79,15 @@ func (h *HealthPing) StartScheduler(selector func() ([]string, error)) { tickerClose := make(chan struct{}) h.ticker = ticker h.tickerClose = tickerClose + go func() { + tags, err := selector() + if err != nil { + newError("error select outbounds for initial health check: ", err).AtWarning().WriteToLog() + return + } + h.Check(tags) + }() + go func() { for { go func() {