database

Documentation

Index

• type DbFactory
  • func NewDBFactory(cfg config.CfgManager) (DbFactory, error)
• type PgDB
  • func NewPostgresConnection(cfg config.CfgManager) (*PgDB, error)
  • func (db PgDB) WithConnection(ctx context.Context, fn func(*pgxpool.Conn) error) error
  • func (db PgDB) WithTransaction(ctx context.Context, fn func(pgx.Tx) error) error

Types

type DbFactory

type DbFactory interface {
	Register(newDb func(DbFactory) any) DbFactory
	PgDb() *PgDB
	Get(name reflect.Type) any
}

func NewDBFactory

func NewDBFactory(cfg config.CfgManager) (DbFactory, error)

type PgDB

type PgDB struct {
	Pool *pgxpool.Pool
}

func NewPostgresConnection

func NewPostgresConnection(cfg config.CfgManager) (*PgDB, error)

func (PgDB) WithConnection

func (db PgDB) WithConnection(ctx context.Context, fn func(*pgxpool.Conn) error) error

func (PgDB) WithTransaction

func (db PgDB) WithTransaction(ctx context.Context, fn func(pgx.Tx) error) error