X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/8db3a110976bbb9288214eeb3064d31cb12c1c82..64e387b2f4f0fe6c4c7bf16232706c7cf194caf0:/services/keep-balance/server.go diff --git a/services/keep-balance/server.go b/services/keep-balance/server.go index 9f192d6355..05658b5e5d 100644 --- a/services/keep-balance/server.go +++ b/services/keep-balance/server.go @@ -11,10 +11,7 @@ import ( "syscall" "time" - "git.curoverse.com/arvados.git/sdk/go/arvados" - "git.curoverse.com/arvados.git/sdk/go/auth" - "github.com/julienschmidt/httprouter" - "github.com/prometheus/client_golang/prometheus/promhttp" + "git.arvados.org/arvados.git/sdk/go/arvados" "github.com/sirupsen/logrus" ) @@ -40,43 +37,22 @@ type RunOptions struct { } type Server struct { + http.Handler + Cluster *arvados.Cluster ArvClient *arvados.Client RunOptions RunOptions Metrics *metrics - httpHandler http.Handler - Logger logrus.FieldLogger Dumper logrus.FieldLogger } -// ServeHTTP implements service.Handler. -func (srv *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) { - srv.httpHandler.ServeHTTP(w, r) -} - // CheckHealth implements service.Handler. func (srv *Server) CheckHealth() error { return nil } -func (srv *Server) setup() { - if srv.Cluster.ManagementToken == "" { - srv.httpHandler = http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { - http.Error(w, "Management API authentication is not configured", http.StatusForbidden) - }) - } else { - mux := httprouter.New() - metricsH := promhttp.HandlerFor(srv.Metrics.reg, promhttp.HandlerOpts{ - ErrorLog: srv.Logger, - }) - mux.Handler("GET", "/metrics", metricsH) - mux.Handler("GET", "/metrics.json", metricsH) - srv.httpHandler = auth.RequireLiteralToken(srv.Cluster.ManagementToken, mux) - } -} - func (srv *Server) run() { var err error if srv.RunOptions.Once { @@ -86,6 +62,9 @@ func (srv *Server) run() { } if err != nil { srv.Logger.Error(err) + os.Exit(1) + } else { + os.Exit(0) } }