Add initial check for burstObserver

XTLS · Mar 6, 2024 · 6012464 · 6012464
1 parent 6991c11
commit 6012464
Showing 1 changed file with 9 additions and 0 deletions.
diff --git 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() {