db, err := sql.Open("postgres", ps.DataSource)
if err != nil {
log.Fatalf("sql.Open: %s", err)
db, err := sql.Open("postgres", ps.DataSource)
if err != nil {
log.Fatalf("sql.Open: %s", err)
if err = db.Ping(); err != nil {
log.Fatalf("db.Ping: %s", err)
}
if err = db.Ping(); err != nil {
log.Fatalf("db.Ping: %s", err)
}
- listener := pq.NewListener(ps.DataSource, time.Second, time.Minute, func(ev pq.ListenerEventType, err error) {
+ ps.pqListener = pq.NewListener(ps.DataSource, time.Second, time.Minute, func(ev pq.ListenerEventType, err error) {
if err != nil {
// Until we have a mechanism for catching up
// on missed events, we cannot recover from a
// dropped connection without breaking our
// promises to clients.
if err != nil {
// Until we have a mechanism for catching up
// on missed events, we cannot recover from a
// dropped connection without breaking our
// promises to clients.