database

Documentation

Index

• func WaitForDB(ctx context.Context, pgdsn string) error
• type Postgres
  • func NewPostgres(pgdsn string) (*Postgres, error)
  • func (p *Postgres) Close() error
  • func (p *Postgres) GetDB() *sql.DB
  • func (p *Postgres) InitDB() error

Functions

func WaitForDB

func WaitForDB(ctx context.Context, pgdsn string) error

WaitForDB waits for the database to be ready

Types

type Postgres

type Postgres struct {
	DB *sql.DB
	// contains filtered or unexported fields
}

Postgres is the database connection

func NewPostgres

func NewPostgres(pgdsn string) (*Postgres, error)

NewPostgres creates a new Postgres database connection

func (*Postgres) Close

func (p *Postgres) Close() error

Close closes the database connection

func (*Postgres) GetDB

func (p *Postgres) GetDB() *sql.DB

GetDB returns the database connection

func (*Postgres) InitDB

func (p *Postgres) InitDB() error

InitDB initializes the database