X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/fd717a88835be62ae1b5c4b1ecd74c21cab0e744..066f9bcf5a74c255cb64cf89e554cf64ec719f5a:/services/ws/event_source.go diff --git a/services/ws/event_source.go b/services/ws/event_source.go index 16538795f4..ea90ec7242 100644 --- a/services/ws/event_source.go +++ b/services/ws/event_source.go @@ -44,6 +44,8 @@ type pgEventSource struct { eventsOut uint64 } +var _ debugStatuser = (*pgEventSource)(nil) + func (ps *pgEventSource) setup() { ps.shutdown = make(chan error, 1) ps.sinks = make(map[*pgEventSink]bool) @@ -172,7 +174,7 @@ func (ps *pgEventSource) DB() *sql.DB { return ps.db } -func (ps *pgEventSource) Status() interface{} { +func (ps *pgEventSource) DebugStatus() interface{} { ps.mtx.Lock() defer ps.mtx.Unlock() blocked := 0