db

Documentation

Index

• func RunMigrationsDown(db *sql.DB) error
• func RunMigrationsUp(db *sql.DB) error
• type DB
  • func New(pg *pgxpool.Pool) *DB
  • func (db *DB) BeginStateTransaction(ctx context.Context) (pgx.Tx, error)

Functions

func RunMigrationsDown

func RunMigrationsDown(db *sql.DB) error

RunMigrationsDown runs migrate-down for the given config.

func RunMigrationsUp

func RunMigrationsUp(db *sql.DB) error

RunMigrationsUp runs migrate-up for the given config.

Types

type DB

type DB struct {
	// contains filtered or unexported fields
}

DB is the database layer of the data node

func New

func New(pg *pgxpool.Pool) *DB

New instantiates a DB

func (*DB) BeginStateTransaction

func (db *DB) BeginStateTransaction(ctx context.Context) (pgx.Tx, error)

BeginStateTransaction begins a DB transaction. The caller is responsible for committing or rolling back the transaction