db

Documentation

Index

• Variables
• func StoreTx(ctx context.Context, tx pgx.Tx) context.Context
• type App
  • func New(config Config, tracer trace.Tracer) (App, error)
  • func (a App) Bulk(ctx context.Context, fetcher func() ([]any, error), schema, table string, ...) error
  • func (a App) Close()
  • func (a App) Create(ctx context.Context, query string, args ...any) (uint64, error)
  • func (a App) DoAtomic(ctx context.Context, action func(context.Context) error) 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) (err error)
  • func (a App) One(ctx context.Context, query string, args ...any) error
  • func (a App) Ping() error
• 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(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) error

func (App) Close

func (a App) Close()

func (App) Create

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

func (App) DoAtomic

func (a App) DoAtomic(ctx context.Context, action func(context.Context) error) 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) (err error)

func (App) One

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

func (App) Ping

func (a App) Ping() error

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
}