pq

Documentation

Index

• type Listener
  • func NewListener(dbDSN string, dbChannel string, minReconnectInterval time.Duration, ...) (*Listener, error)
  • func (s *Listener) Listen(ctx context.Context, exec sql.ProjectionTrigger) error

Types

type Listener

type Listener struct {
	// contains filtered or unexported fields
}

Listener a Notification listener for pq

func NewListener

func NewListener(
	dbDSN string,
	dbChannel string,
	minReconnectInterval time.Duration,
	maxReconnectInterval time.Duration,
	logger goengine.Logger,
	metrics sql.Metrics,
) (*Listener, error)

NewListener returns a new notification listener

func (*Listener) Listen

func (s *Listener) Listen(ctx context.Context, exec sql.ProjectionTrigger) error

Listen start listening on the configures dbChannel and when a notification is received call the trigger