notifier

type Listener ¶

type Listener interface {
	io.Closer
	Listen(ctx context.Context, topic string, callback func(n *Notification)) error
}

Listener connects to PostgreSQL and listens to a channel with LISTEN. Listen calls the callback for every notification, with its JSON payload parsed, until the context is done. The default implementation, from NewListener, uses lib/pq; callers may implement Listener for another backend.

func NewListener(p xdb.Provider, minReconnectInterval time.Duration, maxReconnectInterval time.Duration) Listener

type Notification ¶

type Notification struct {
	Channel string
	Payload values.MapAny
	// RawPayload, or the empty string if unspecified.
	RawPayload string
}