database

Documentation

Index

• Constants
• Variables
• type Database
  • func New(ctx context.Context, retries int, configuration internal.Configuration, ...) (*Database, error)
  • func (self *Database) Close(ctx context.Context) error
  • func (self *Database) Exec(ctx context.Context, sql string, args ...interface{}) (int, error)
  • func (self *Database) Health(ctx context.Context) error
  • func (self *Database) Query(ctx context.Context, sql string, args ...interface{}) Scan
  • func (self *Database) Transaction(ctx context.Context, fn func(ctx context.Context) error) error
• type PgxLogger
  • func NewPgxLogger(logger core.Logger) *PgxLogger
  • func (self PgxLogger) Log(ctx context.Context, level pgx.LogLevel, msg string, ...)
• type Scan

Constants

const (
	POSTGRES_DSN                                = "postgresql://%s:%s@%s:%d/%s?sslmode=%s"
	CONTEXT_TRANSACTION_KEY internal.ContextKey = "database:tx"
)

const PGERRCODE_PATTERN = `\(SQLSTATE (.*)\)`

Variables

var (
	ErrGeneric     = internal.NewError("Database failed")
	ErrBelowMin    = internal.NewError("Database pool size below minimum")
	ErrTransaction = internal.NewError("Database transaction failed")
)

var (
	ErrNoRows             = internal.NewError("No rows in result set")
	ErrIntegrityViolation = internal.NewError("Integrity constraint violation")
)

Types

type Database

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

func New

func New(ctx context.Context, retries int, configuration internal.Configuration, logger core.Logger) (*Database, error)

func (*Database) Close

func (self *Database) Close(ctx context.Context) error

func (*Database) Exec

func (self *Database) Exec(ctx context.Context, sql string, args ...interface{}) (int, error)

func (*Database) Health

func (self *Database) Health(ctx context.Context) error

func (*Database) Query

func (self *Database) Query(ctx context.Context, sql string, args ...interface{}) Scan

func (*Database) Transaction

func (self *Database) Transaction(ctx context.Context, fn func(ctx context.Context) error) error

type PgxLogger

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

func NewPgxLogger

func NewPgxLogger(logger core.Logger) *PgxLogger

func (PgxLogger) Log

func (self PgxLogger) Log(ctx context.Context, level pgx.LogLevel, msg string, data map[string]interface{})

type Scan

type Scan struct {
	Scan func(dest ...interface{}) error
}