pglistener

Documentation

Index

• Constants
• func Listen(ctx context.Context, pgUrl string, channel string, ...) (notifications chan *pq.Notification, err error)
• func RegisterNotifier(pgUrl string, setChannel string, deleteChannel string, table string) (err error)

Constants

const MAX_RECONN = time.Minute

const MIN_RECONN = 10 * time.Second

Functions

func Listen

func Listen(ctx context.Context, pgUrl string, channel string, reportErr pq.EventCallbackType) (notifications chan *pq.Notification, err error)

func RegisterNotifier

func RegisterNotifier(pgUrl string, setChannel string, deleteChannel string, table string) (err error)