diff --git a/main.go b/main.go index e6cfc9f..cbcdbe8 100644 --- a/main.go +++ b/main.go @@ -286,6 +286,9 @@ func raceUpstreams(pool []string) (string, error) { } // watchdog monitors message activity and triggers reconnection if stalled +// this is useful if bsky relay is down, which means all the jetstreams will be +// reachable but not send any messages. we should swap to alternate relay infrastructure +// in this case (via raceUpstreams) func watchdog(broadcaster *Broadcaster, trigger chan struct{}) { ticker := time.NewTicker(5 * time.Second) defer ticker.Stop()