stdpgxfx

Documentation

Overview

Package stdpgxfx provides sql.DB connection pools usng pgx/v5.

Index

• func Provide(mainPoolName string, derivedPoolNames ...string) fx.Option
• func ProvideDeriver(name string, deriver Deriver) fx.Option
• func TestProvide(tb testing.TB, mainPoolName string, derivedPoolNames ...string) fx.Option
• type AfterMigrateRole
• type Config
• type Deriver
• type Params
• type PgtestdbTestMigratorParams
• type Result
  • func New(p Params) (r Result, err error)
• type TestMigrator
  • func NewPgtestdbTestMigrator(params PgtestdbTestMigratorParams) TestMigrator
• type TestMigratorFunc
  • func (f TestMigratorFunc) Migrate(tb testing.TB, cfg Config, pcfg *pgxpool.Config) (*pgxpool.Config, error)

Functions

func Provide

func Provide(mainPoolName string, derivedPoolNames ...string) fx.Option

Provide components as fx dependencies.

func ProvideDeriver

func ProvideDeriver(name string, deriver Deriver) fx.Option

ProvideDeriver is a short-hande function for providing a named deriver function that.

func TestProvide

func TestProvide(tb testing.TB, mainPoolName string, derivedPoolNames ...string) fx.Option

TestProvide provides the package's components as an fx module with a setup more useful for testing.

Types

type AfterMigrateRole

type AfterMigrateRole struct {
	User     string
	Password string
}

AfterMigrateRole can be optionally provided to further customize the role used to connect to the database that was just migrated. This is useful if the eventual role being used from the application is different from the migration (superuser) role and the testrole.

type Config

type Config struct {
	// RWDatabaseURL configures the database connection string for the read-write connection.
	RWDatabaseURL string `env:"RW_DATABASE_URL"`
}

Config configures the module.

type Deriver

type Deriver func(base *pgxpool.Config) *pgxpool.Config

Deriver needs to be provided by the user of this module if derived pools are created.

type Params

type Params struct {
	fx.In
	Config Config
}

Params describe the main parameters for providing components.

type PgtestdbTestMigratorParams

type PgtestdbTestMigratorParams struct {
	fx.In
	Migrator  pgtestdb.Migrator
	Role      *pgtestdb.Role    `optional:"true"`
	AfterRole *AfterMigrateRole `optional:"true"`
}

type Result

type Result struct {
	fx.Out
	PoolConfig *pgxpool.Config
}

Result describe the main components provided for this module.

func New

func New(p Params) (r Result, err error)

New is the main constructor. In this package it only provides the pool configuration used through out the package.

type TestMigrator

type TestMigrator interface {
	Migrate(
		tb testing.TB,
		cfg Config,
		pcfg *pgxpool.Config,
	) (*pgxpool.Config, error)
}

TestMigrator can be implemented and provided to migrate the database for tests.

func NewPgtestdbTestMigrator

func NewPgtestdbTestMigrator(params PgtestdbTestMigratorParams) TestMigrator

NewPgtestdbTestMigrator implements the TestMigrator using the pgtestdb library.

type TestMigratorFunc

type TestMigratorFunc func(
	tb testing.TB,
	cfg Config,
	pcfg *pgxpool.Config,
) (*pgxpool.Config, error)

TestMigratorFunc makes it easy to implement the migrator.

func (TestMigratorFunc) Migrate

func (f TestMigratorFunc) Migrate(
	tb testing.TB, cfg Config, pcfg *pgxpool.Config,
) (*pgxpool.Config, error)