Method runInBackground

modules/livestore/live_store_background.go:67–80

(fn func())

}

func (s *LiveStore) runInBackground(fn func()) {
	s.wg.Add(1)
	go func() {
		defer s.wg.Done()

		select {
		case <-s.startupComplete:
		case <-s.ctx.Done():
			return
		}

		fn()
	}()
}

func (s *LiveStore) globalCompleteLoop(idx int) {
	level.Info(s.logger).Log("msg", "starting completing loop", "index", idx)