fxpostgres

Documentation

Index

• Variables
• type Config
• type Driver
• type MigrationsRunner
  • func NewMigrationsRunner(config *Config, logger *zap.Logger, shutdowner fx.Shutdowner) *MigrationsRunner
  • func (r *MigrationsRunner) MigrateDown() error
  • func (r *MigrationsRunner) MigrateUp() error

Variables

var Module = fx.Options(
	fx.Provide(func(lc fx.Lifecycle, cfg *Config) (Driver, error) {
		driver, err := postgres.New(context.Background(), cfg.URL)
		if err != nil {
			return nil, err
		}
		lc.Append(fx.Hook{
			OnStart: func(ctx context.Context) error {
				return driver.Ping(ctx)
			},
			OnStop: func(context.Context) error {
				driver.Close()
				return nil
			},
		})

		return driver, nil
	}),
	fx.Provide(NewMigrationsRunner),
)

Types

type Config

type Config struct {
	URL            string `split_words:"true"`
	MigrationsPath string `split_words:"true"`
}

type Driver

type Driver interface {
	Ping(ctx context.Context) error
	Close()
	CountRows(ctx context.Context, query string, args ...interface{}) (int, error)
	ExecuteQuery(ctx context.Context, query string, args ...interface{}) error
	QueryRow(ctx context.Context, query string, args ...interface{}) (pgx.Row, error)
	QueryRows(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
}

type MigrationsRunner

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

func NewMigrationsRunner

func NewMigrationsRunner(config *Config, logger *zap.Logger, shutdowner fx.Shutdowner) *MigrationsRunner

func (*MigrationsRunner) MigrateDown

func (r *MigrationsRunner) MigrateDown() error

func (*MigrationsRunner) MigrateUp

func (r *MigrationsRunner) MigrateUp() error