dbutil

Documentation

Index

• Constants
• type Configuration
  • func NewConfig(defaultConfig Configuration) Configuration
• type Connector
  • func NewConnector(config Configuration) *Connector
  • func (c *Connector) Close()
  • func (c *Connector) GetDb(ctx goContext.Context) orm.DB
  • func (c *Connector) RunInTransaction(ctx goContext.Context, fn func(goContext.Context) error) error
• type IntegrityViolationError
  • func (e IntegrityViolationError) Error() string
• type Logger
  • func (Logger) AfterQuery(ctx goContext.Context, q *pg.QueryEvent) error
  • func (Logger) BeforeQuery(ctx goContext.Context, q *pg.QueryEvent) (goContext.Context, error)
• type NotFoundError
  • func (e NotFoundError) Error() string

Constants

const (
	AscOrder  = "asc"
	DescOrder = "desc"
)

Types

type Configuration

type Configuration struct {
	Host       string
	Port       int
	Name       string
	User       string
	Password   string
	LogQueries bool
}

func NewConfig

func NewConfig(defaultConfig Configuration) Configuration

type Connector

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

func NewConnector

func NewConnector(config Configuration) *Connector

func (*Connector) Close

func (c *Connector) Close()

func (*Connector) GetDb

func (c *Connector) GetDb(ctx goContext.Context) orm.DB

func (*Connector) RunInTransaction

func (c *Connector) RunInTransaction(ctx goContext.Context, fn func(goContext.Context) error) error

type IntegrityViolationError

type IntegrityViolationError struct {
	Message string
}

func (IntegrityViolationError) Error

func (e IntegrityViolationError) Error() string

type Logger

type Logger struct{}

func (Logger) AfterQuery

func (Logger) AfterQuery(ctx goContext.Context, q *pg.QueryEvent) error

func (Logger) BeforeQuery

func (Logger) BeforeQuery(ctx goContext.Context, q *pg.QueryEvent) (goContext.Context, error)

type NotFoundError

type NotFoundError struct {
	Message string
}

func (NotFoundError) Error

func (e NotFoundError) Error() string