db

Documentation

Index

• Variables
• func StoreTx(ctx context.Context, tx pgx.Tx) context.Context
• type App
  • func New(ctx context.Context, config Config, tracer trace.Tracer) (App, error)
  • func (a App) Bulk(ctx context.Context, fetcher func() ([]any, error), schema, table string, ...) (err error)
  • func (a App) Close()
  • func (a App) Create(ctx context.Context, query string, args ...any) (id uint64, err error)
  • func (a App) DoAtomic(ctx context.Context, action func(context.Context) error) (err error)
  • func (a App) Enabled() bool
  • func (a App) Exec(ctx context.Context, query string, args ...any) error
  • func (a App) Get(ctx context.Context, scanner func(pgx.Row) error, query string, args ...any) error
  • func (a App) List(ctx context.Context, scanner func(pgx.Rows) error, query string, args ...any) error
  • func (a App) One(ctx context.Context, query string, args ...any) error
  • func (a App) Ping(ctx context.Context) error
  • func (a App) Query(ctx context.Context, query string, args ...any) (rows pgx.Rows, err error)
  • func (a App) QueryRow(ctx context.Context, query string, args ...any) pgx.Row
• type Config
  • func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config
• type Database

Variables

var (
	ErrNoHost        = errors.New("no host for database connection")
	ErrNoTransaction = errors.New("no transaction in context, please wrap with DoAtomic()")
	SQLTimeout       = time.Second * 5
)

Functions

func StoreTx

func StoreTx(ctx context.Context, tx pgx.Tx) context.Context

Types

type App

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

func New

func New(ctx context.Context, config Config, tracer trace.Tracer) (App, error)

func (App) Bulk

func (a App) Bulk(ctx context.Context, fetcher func() ([]any, error), schema, table string, columns ...string) (err error)

func (App) Close

func (a App) Close()

func (App) Create

func (a App) Create(ctx context.Context, query string, args ...any) (id uint64, err error)

func (App) DoAtomic

func (a App) DoAtomic(ctx context.Context, action func(context.Context) error) (err error)

func (App) Enabled

func (a App) Enabled() bool

func (App) Exec

func (a App) Exec(ctx context.Context, query string, args ...any) error

func (App) Get

func (a App) Get(ctx context.Context, scanner func(pgx.Row) error, query string, args ...any) error

func (App) List

func (a App) List(ctx context.Context, scanner func(pgx.Rows) error, query string, args ...any) error

func (App) One

func (a App) One(ctx context.Context, query string, args ...any) error

func (App) Ping

func (a App) Ping(ctx context.Context) error

func (App) Query

func (a App) Query(ctx context.Context, query string, args ...any) (rows pgx.Rows, err error)

func (App) QueryRow

func (a App) QueryRow(ctx context.Context, query string, args ...any) pgx.Row

type Config

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

func Flags

func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config

type Database

type Database interface {
	Ping(context.Context) error
	Close()
	Begin(context.Context) (pgx.Tx, error)
	Query(context.Context, string, ...any) (pgx.Rows, error)
	QueryRow(context.Context, string, ...any) pgx.Row
	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
}