database

Documentation

Index

• type Database
  • func New(ctx context.Context, dsn string) Database
  • func (db Database) InTx(ctx context.Context, fn ...func(tx pgx.Tx) error) error
  • func (db Database) IsSchemaUpToDate(ctx context.Context) error
  • func (db Database) Migrate(ctx context.Context) error

Types

type Database

type Database struct {
	Pool *pgxpool.Pool
	// contains filtered or unexported fields
}

Database represents a new database.

func New

func New(ctx context.Context, dsn string) Database

New returns a new database.

func (Database) InTx

func (db Database) InTx(ctx context.Context, fn ...func(tx pgx.Tx) error) error

InTx runs the given function f within a transaction with isolation level serialization by default.

func (Database) IsSchemaUpToDate

func (db Database) IsSchemaUpToDate(ctx context.Context) error

IsSchemaUpToDate checks if the database schema is up to date.

func (Database) Migrate

func (db Database) Migrate(ctx context.Context) error

Migrate executes database migrations.