pg

Documentation

Index

• Variables
• func Listen(ctx context.Context, channel string, pgNotify chan<- string)
• func NewNotifyRouter() *notifyRouter

Variables

var (
	DBReconnectMaxDuration         = time.Minute * 5
	DBReconnectBackoffBaseDuration = time.Second
)

Defaults ...

Functions

func Listen

func Listen(ctx context.Context, channel string, pgNotify chan<- string)

Listen listens to postgres notifications. On failure, it'll keep retrying with backoff

func NewNotifyRouter

func NewNotifyRouter() *notifyRouter