type github.com/go-pg/pg/v10.Listener
22 uses
github.com/go-pg/pg/v10 (current package)
db.go#L78: func (db *DB) Listen(ctx context.Context, channels ...string) *Listener {
db.go#L79: ln := &Listener{
listener.go#L32: type Listener struct {
listener.go#L47: func (ln *Listener) String() string {
listener.go#L54: func (ln *Listener) init() {
listener.go#L58: func (ln *Listener) connWithLock(ctx context.Context) (*pool.Conn, error) {
listener.go#L77: func (ln *Listener) conn(ctx context.Context) (*pool.Conn, error) {
listener.go#L110: func (ln *Listener) releaseConn(ctx context.Context, cn *pool.Conn, err error, allowTimeout bool) {
listener.go#L120: func (ln *Listener) reconnect(ctx context.Context, reason error) {
listener.go#L125: func (ln *Listener) closeTheCn(reason error) error {
listener.go#L139: func (ln *Listener) Close() error {
listener.go#L153: func (ln *Listener) Listen(ctx context.Context, channels ...string) error {
listener.go#L172: func (ln *Listener) listen(ctx context.Context, cn *pool.Conn, channels ...string) error {
listener.go#L185: func (ln *Listener) Unlisten(ctx context.Context, channels ...string) error {
listener.go#L205: func (ln *Listener) unlisten(ctx context.Context, cn *pool.Conn, channels ...string) error {
listener.go#L219: func (ln *Listener) Receive(ctx context.Context) (channel string, payload string, err error) {
listener.go#L225: func (ln *Listener) ReceiveTimeout(
listener.go#L250: func (ln *Listener) Channel() <-chan Notification {
listener.go#L256: func (ln *Listener) ChannelSize(size int) <-chan Notification {
listener.go#L260: func (ln *Listener) channel(size int) <-chan Notification {
listener.go#L271: func (ln *Listener) initChannel(size int) {
listener.go#L364: func (ln *Listener) ping() error {