Method OnReconnect

internal/storage/pgwatcher.go:50–52

(cb func())

}

func (w *PgWatcher) OnReconnect(cb func()) {
	w.Listener.OnReconnect(cb)
}

func (w *PgWatcher) emit(cb Callback, event *pgevents.TableEvent) {
	device := &Device{}