| 9 | ) |
| 10 | |
| 11 | type PgWatcher struct { |
| 12 | *pgevents.Listener |
| 13 | } |
| 14 | |
| 15 | func NewPgWatcher(connectionString string, table string) (*PgWatcher, error) { |
| 16 | listener, err := pgevents.OpenListener(connectionString) |
nothing calls this directly
no outgoing calls
no test coverage detected