X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/97e8290d683afff06fe2e9a4cec522a871a96df3..8e75f57bd693d0ceb1aab86ba0e84cb19b4d155a:/services/keep-balance/server.go diff --git a/services/keep-balance/server.go b/services/keep-balance/server.go index 9801a3fd45..5299b96c1c 100644 --- a/services/keep-balance/server.go +++ b/services/keep-balance/server.go @@ -12,6 +12,7 @@ import ( "time" "git.arvados.org/arvados.git/sdk/go/arvados" + "github.com/jmoiron/sqlx" "github.com/sirupsen/logrus" ) @@ -23,11 +24,12 @@ import ( // // RunOptions fields are controlled by command line flags. type RunOptions struct { - Once bool - CommitPulls bool - CommitTrash bool - Logger logrus.FieldLogger - Dumper logrus.FieldLogger + Once bool + CommitPulls bool + CommitTrash bool + CommitConfirmedFields bool + Logger logrus.FieldLogger + Dumper logrus.FieldLogger // SafeRendezvousState from the most recent balance operation, // or "" if unknown. If this changes from one run to the next, @@ -46,11 +48,13 @@ type Server struct { Logger logrus.FieldLogger Dumper logrus.FieldLogger + + DB *sqlx.DB } // CheckHealth implements service.Handler. func (srv *Server) CheckHealth() error { - return nil + return srv.DB.Ping() } // Done implements service.Handler. @@ -75,6 +79,7 @@ func (srv *Server) run() { func (srv *Server) runOnce() (*Balancer, error) { bal := &Balancer{ + DB: srv.DB, Logger: srv.Logger, Dumper: srv.Dumper, Metrics: srv.Metrics,