db

Documentation

Index

• Variables
• func NewDb(pool *pgxpool.Pool) *sqlc.Queries
• func NewPgxPool(cfg *config.ServerConfig) (*pgxpool.Pool, error)
• func RegisterDBPoolHooks(lc fx.Lifecycle, pool *pgxpool.Pool)

Variables

var Module = fx.Module("db",
	fx.Provide(
		NewPgxPool,
		NewDb,
	),
	fx.Invoke(RegisterDBPoolHooks),
)

Module is the fx module for the database.

Functions

func NewDb

func NewDb(pool *pgxpool.Pool) *sqlc.Queries

NewDb creates a new db instance

func NewPgxPool

func NewPgxPool(cfg *config.ServerConfig) (*pgxpool.Pool, error)

NewPgxPool creates a new postgres pool.

func RegisterDBPoolHooks

func RegisterDBPoolHooks(lc fx.Lifecycle, pool *pgxpool.Pool)

RegisterDBPoolHooks starts and stops the DB pool.