repo

Documentation

Index

• type Config
  • func (c *Config) FormatDSN() string
• type Ctx
• type Repo
  • func New(cfg *Config, logger *structlog.Logger) (*Repo, error)
  • func (r *Repo) Close()
  • func (r *Repo) Tx(ctx Ctx, opts *sql.TxOptions, f func(*sqlx.Tx) error) (err error)

Types

type Config

type Config struct {
	Host          string
	Port          int
	Name          string
	User          string
	Pass          string
	MaxIdleConns  int
	MaxOpenConns  int
	MigrationPath string
}

func (*Config) FormatDSN

func (c *Config) FormatDSN() string

type Ctx

type Ctx = context.Context

type Repo

type Repo struct {
	DB       *sqlx.DB
	ReformDB *reform.DB
	// contains filtered or unexported fields
}

func New

func New(cfg *Config, logger *structlog.Logger) (*Repo, error)

func (*Repo) Close

func (r *Repo) Close()

Close closes connection to DB.

func (*Repo) Tx

func (r *Repo) Tx(ctx Ctx, opts *sql.TxOptions, f func(*sqlx.Tx) error) (err error)