Function startMonitoringServer

cmd/workers.go:538–578

(conf *config.Configuration)

}

func startMonitoringServer(conf *config.Configuration) *http.Server {
	redisOption, _ := redis_db.ParseRedisURL(conf.Redis.Dns, conf.Redis.SkipTLSVerify)
	asynqmonHandler := asynqmon.New(asynqmon.Options{
		RootPath: "/monitoring",
		RedisConnOpt: asynq.RedisClientOpt{
			Addr:      redisOption.Addr,
			Password:  redisOption.Password,
			DB:        redisOption.DB,
			TLSConfig: redisOption.TLSConfig,
			PoolSize:  conf.Redis.PoolSize,
		},
	})

	monitoringMux := http.NewServeMux()

	monitoringMux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Content-Type", "application/json")
		w.WriteHeader(http.StatusOK)
		_, _ = fmt.Fprintf(w, `{"status": "UP", "service": "worker"}`)
	})

	monitoringMux.Handle("/monitoring/", asynqmonHandler)
	if h := trace.MetricsHandler(); h != nil {
		monitoringMux.Handle("/metrics", middleware.MetricsAuthHandler(conf.Server.Secure, conf.Server.MetricsBearerToken, h))
	}

	monitoringAddr := fmt.Sprintf(":%s", conf.Queue.MonitoringPort)
	srv := &http.Server{
		Addr:    monitoringAddr,
		Handler: monitoringMux,
	}

	go func() {
		logrus.Errorf("Worker monitoring server listening on %s (health: /health, dashboard: /monitoring)", monitoringAddr)
		if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
			logrus.Fatalf("could not start monitoring server: %v", err)
		}
	}()

	return srv
}