notification_connection

type NotificationConnection interface {
	// Listen starts listening a channel
	Listen(channel string) error

	// Unlisten stops listening a channel
	Unlisten(channel string) error

	// Close closes the connection
	Close() error

	// NotificationChannel returns channel for receiving notifications
	NotificationChannel() <-chan *pq.Notification
}