orm

Documentation

Index

• Variables
• func NewConnection(opts *Config, l *zap.Logger) (db *pg.DB, err error)
• type Config
  • func NewDefaultConfig(v *viper.Viper) (*Config, error)
• type Hook
  • func (h Hook) AfterQuery(e *pg.QueryEvent)
  • func (h *Hook) BeforeQuery(e *pg.QueryEvent)

Variables

var (
	// Module is default connection to PostgreSQL
	Module = module.Module{
		{Constructor: NewDefaultConfig},
		{Constructor: NewConnection},
	}

	// ErrEmptyConfig when given empty options
	ErrEmptyConfig = errors.New("database empty config")
	// ErrEmptyLogger when logger not initialized
	ErrEmptyLogger = errors.New("database empty logger")
)

Functions

func NewConnection

func NewConnection(opts *Config, l *zap.Logger) (db *pg.DB, err error)

NewConnection returns database connection

Types

type Config

type Config = struct {
	Addr     string
	User     string
	Password string
	Database string
	Debug    bool
	PoolSize int
	Logger   *zap.SugaredLogger
}

Config alias

func NewDefaultConfig

func NewDefaultConfig(v *viper.Viper) (*Config, error)

NewDefaultConfig returns connection config

type Hook

type Hook struct {
	StartAt time.Time
	Before  func(*pg.QueryEvent)
	After   func(*pg.QueryEvent)
}

Hook is a simple implementation of pg.QueryHook

func (Hook) AfterQuery

func (h Hook) AfterQuery(e *pg.QueryEvent)

AfterQuery callback

func (*Hook) BeforeQuery

func (h *Hook) BeforeQuery(e *pg.QueryEvent)

BeforeQuery callback