db

Documentation

Index

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

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 Config

type Config struct {
	Host    string
	User    string
	Pass    string
	Name    string
	SSLMode string
	Port    uint
	MinConn uint
	MaxConn uint
}

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)
}

type Service

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

func New

func New(ctx context.Context, config *Config, tracerProvider trace.TracerProvider) (Service, error)

func (Service) Bulk

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

func (Service) Close

func (s Service) Close()

func (Service) Create

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

func (Service) DoAtomic

func (s Service) DoAtomic(ctx context.Context, action func(context.Context) error) (err error)

func (Service) Enabled

func (s Service) Enabled() bool

func (Service) Exec

func (s Service) Exec(ctx context.Context, query string, args ...any) error

func (Service) Get

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

func (Service) List

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

func (Service) One

func (s Service) One(ctx context.Context, query string, args ...any) error

func (Service) Ping

func (s Service) Ping(ctx context.Context) error

func (Service) Query

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

func (Service) QueryRow

func (s Service) QueryRow(ctx context.Context, query string, args ...any) pgx.Row