X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/c4a0f7a714586e61ad844de58837a20c76eda2a8..47b2e4988e9bfb69ef00de1c900a20f714af5f2f:/services/ws/event_source.go diff --git a/services/ws/event_source.go b/services/ws/event_source.go index 7c1b58492d..6a308b3a62 100644 --- a/services/ws/event_source.go +++ b/services/ws/event_source.go @@ -242,6 +242,12 @@ func (ps *pgEventSource) DB() *sql.DB { return ps.db } +func (ps *pgEventSource) DBHealth() error { + ctx, _ := context.WithDeadline(context.Background(), time.Now().Add(time.Second)) + var i int + return ps.db.QueryRowContext(ctx, "SELECT 1").Scan(&i) +} + func (ps *pgEventSource) DebugStatus() interface{} { ps.mtx.Lock() defer ps.mtx.Unlock()