pg

Documentation

Index

• Constants
• func New(epa types.EndPointAttr, dsn string) (types.EndPoint, error)
• func NewConnected(epa types.EndPointAttr, db *engine.DB) (types.EndPoint, error)
• type EndPoint
  • func (ep EndPoint) Listen(id int, channel string, pipe chan string) error
  • func (ep EndPoint) Notify(id int, channel string, pipe chan string) error

Constants

const (
	// PgMaxRetries holds Pg connect retry count
	PgMaxRetries = 5

	// SQLPubFmt holds notification query format string
	SQLPubFmt = "SELECT %s(?)"
)

Functions

func New

func New(epa types.EndPointAttr, dsn string) (types.EndPoint, error)

New create endpoint

func NewConnected

func NewConnected(epa types.EndPointAttr, db *engine.DB) (types.EndPoint, error)

NewConnected creates endpoint for connected service

Types

type EndPoint

type EndPoint struct {
	types.EndPointAttr
	// contains filtered or unexported fields
}

EndPoint holds database linked endpoint

func (EndPoint) Listen

func (ep EndPoint) Listen(id int, channel string, pipe chan string) error

Listen starts listening goroutine

func (EndPoint) Notify

func (ep EndPoint) Notify(id int, channel string, pipe chan string) error

Notify starts all notify goroutines