pglistener

Documentation

Index

• type PgListener
  • func New(dsn string) (*PgListener, error)
  • func (pl *PgListener) Close() error
  • func (pl *PgListener) Listen(ctx context.Context) (<-chan models.Event, error)

Types

type PgListener

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

func New

func New(dsn string) (*PgListener, error)

func (*PgListener) Close

func (pl *PgListener) Close() error

func (*PgListener) Listen

func (pl *PgListener) Listen(ctx context.Context) (<-chan models.Event, error)