database

Documentation

Index

• func New(ctx context.Context, dsn string, log logrus.FieldLogger, opts ...OptFunc) (*pgxpool.Pool, error)
• func NewLoaderContext(ctx context.Context, dbConn *pgxpool.Pool) context.Context
• func NewPool(ctx context.Context, dsn string, log logrus.FieldLogger, migrate bool, ...) (*pgxpool.Pool, error)
• func Transaction(ctx context.Context, callback func(ctx context.Context) error) error
• func TransactionFromContext(ctx context.Context) pgx.Tx
• type OptFunc
  • func WithSlowQueryLogger(d time.Duration) OptFunc

Functions

func New

func New(ctx context.Context, dsn string, log logrus.FieldLogger, opts ...OptFunc) (*pgxpool.Pool, error)

func NewLoaderContext

func NewLoaderContext(ctx context.Context, dbConn *pgxpool.Pool) context.Context

func NewPool

func NewPool(ctx context.Context, dsn string, log logrus.FieldLogger, migrate bool, opts ...OptFunc) (*pgxpool.Pool, error)

func Transaction

func Transaction(ctx context.Context, callback func(ctx context.Context) error) error

Transaction executes a callback function within a transaction. Multiple calls to Transaction will start "nested" transactions (https://www.postgresql.org/docs/current/sql-savepoint.html).

func TransactionFromContext

func TransactionFromContext(ctx context.Context) pgx.Tx

TransactionFromContext will return a potentially open transaction from the context, nil if none exists.

Types

type OptFunc

type OptFunc func(*settings)

func WithSlowQueryLogger

func WithSlowQueryLogger(d time.Duration) OptFunc

WithSlowQueryLogger enables slow query logging This exposes attributes of the slow query to the logger, so it should not be used in production