eventsOut uint64
}
+var _ debugStatuser = (*pgEventSource)(nil)
+
func (ps *pgEventSource) setup() {
ps.shutdown = make(chan error, 1)
ps.sinks = make(map[*pgEventSink]bool)
return ps.db
}
-func (ps *pgEventSource) Status() interface{} {
+func (ps *pgEventSource) DebugStatus() interface{} {
ps.mtx.Lock()
defer ps.mtx.Unlock()
blocked := 0