db

Documentation

Index

• func Down(ctx context.Context, cfg *Config, logger *zap.Logger) error
• func Setup(cfg *Config, logger *zap.Logger) error
• type Config
• type DB
  • func GetConnection(ctx context.Context, cfg *Config, logger *zap.Logger) (*DB, error)
  • func NewConnection(ctx context.Context, cfg *Config, logger *zap.Logger) (*DB, error)

Functions

func Down

func Down(ctx context.Context, cfg *Config, logger *zap.Logger) error

Down to run the down migrations

func Setup

func Setup(cfg *Config, logger *zap.Logger) error

Setup runs the database migrations upto the current version

Types

type Config

type Config struct {
	Host     string
	Port     int
	User     string
	Password string
	Name     string
	ForceTLS bool
}

type DB

type DB struct {
	*pgx.Conn
}

func GetConnection

func GetConnection(ctx context.Context, cfg *Config, logger *zap.Logger) (*DB, error)

GetConnection creates a new connection if not available or else returns the current connection

func NewConnection

func NewConnection(ctx context.Context, cfg *Config, logger *zap.Logger) (*DB, error)

NewConnection creates and returns a new DB connection