Skip to content

Commit

Permalink
Add initial check for burstObserver
Browse files Browse the repository at this point in the history
  • Loading branch information
yuhan6665 committed Mar 6, 2024
1 parent 6991c11 commit fc7061b
Showing 1 changed file with 9 additions and 0 deletions.
9 changes: 9 additions & 0 deletions app/observatory/burst/healthping.go
Original file line number Diff line number Diff line change
Expand Up @@ -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() {
Expand Down

0 comments on commit fc7061b

Please sign in to comment.