database

Documentation

Index

• func Queries(ctx context.Context) (*db.Queries, error)
• func WithLazyTx(ctx context.Context, tx *LazyTx) context.Context
• func WithQueries(ctx context.Context, q *db.Queries) context.Context
• type LazyTx
  • func GetLazyTx(ctx context.Context) (*LazyTx, bool)
  • func NewLazyTx(ctx context.Context, pool *Pool, log *logger.Logger) *LazyTx
  • func (lt *LazyTx) Commit(ctx context.Context) error
  • func (lt *LazyTx) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)
  • func (lt *LazyTx) IsStarted() bool
  • func (lt *LazyTx) OnCommit(hook func())
  • func (lt *LazyTx) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
  • func (lt *LazyTx) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
  • func (lt *LazyTx) Rollback(ctx context.Context) error
• type Pool
  • func New(cfg config.DatabaseConfig, m *metrics.Metrics) (*Pool, error)
  • func (p *Pool) CheckHealth(ctx context.Context) error

Functions

func Queries

func Queries(ctx context.Context) (*db.Queries, error)

func WithLazyTx

func WithLazyTx(ctx context.Context, tx *LazyTx) context.Context

WithLazyTx stores the LazyTx in the context

func WithQueries

func WithQueries(ctx context.Context, q *db.Queries) context.Context

Types

type LazyTx

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

func GetLazyTx

func GetLazyTx(ctx context.Context) (*LazyTx, bool)

GetLazyTx retrieves the LazyTx from the context

func NewLazyTx

func NewLazyTx(ctx context.Context, pool *Pool, log *logger.Logger) *LazyTx

func (*LazyTx) Commit

func (lt *LazyTx) Commit(ctx context.Context) error

func (*LazyTx) Exec

func (lt *LazyTx) Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)

func (*LazyTx) IsStarted

func (lt *LazyTx) IsStarted() bool

func (*LazyTx) OnCommit

func (lt *LazyTx) OnCommit(hook func())

OnCommit registers a function to be called after the transaction successfully commits

func (*LazyTx) Query

func (lt *LazyTx) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

func (*LazyTx) QueryRow

func (lt *LazyTx) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row

func (*LazyTx) Rollback

func (lt *LazyTx) Rollback(ctx context.Context) error

type Pool

type Pool struct {
	*pgxpool.Pool
	// contains filtered or unexported fields
}

func New

func New(cfg config.DatabaseConfig, m *metrics.Metrics) (*Pool, error)

func (*Pool) CheckHealth

func (p *Pool) CheckHealth(ctx context.Context) error