postgres

Documentation

Index

• type Config
• type DB
  • func New(ctx context.Context, cfg *Config) (DB, error)

Types

type Config

type Config struct {
	Name     string `yaml:"name" validate:"required"`
	Host     string `yaml:"host" validate:"required"`
	Port     int    `yaml:"port" validate:"required"`
	User     string `yaml:"user" validate:"required"`
	Password string `yaml:"password" env:"ROSTAM_POSTGRES_PASSWORD" validate:"required"`
}

type DB

type DB interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
	Close()
}

func New

func New(ctx context.Context, cfg *Config) (DB, error)