database

Documentation

Index

• Variables
• func Close()
• func Connect(host string, port uint, user, pass, dbname string)
• func ExecWithTimeout(ctx context.Context, t time.Duration, query string, args ...interface{}) error
• func Migrate()
• func QueryRowWithTimeout(ctx context.Context, t time.Duration, query string, args ...interface{}) (pgx.Row, error)
• func QueryWithTimeout(ctx context.Context, t time.Duration, query string, args ...interface{}) (pgx.Rows, error)

Variables

var DB *pgxpool.Pool

Functions

func Close

func Close()

func Connect

func Connect(host string, port uint, user, pass, dbname string)

func ExecWithTimeout

func ExecWithTimeout(ctx context.Context, t time.Duration, query string,
	args ...interface{}) error

func Migrate

func Migrate()

func QueryRowWithTimeout

func QueryRowWithTimeout(ctx context.Context, t time.Duration, query string,
	args ...interface{}) (pgx.Row, error)

func QueryWithTimeout

func QueryWithTimeout(ctx context.Context, t time.Duration, query string,
	args ...interface{}) (pgx.Rows, error)