database

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.