fxpostgres

Documentation

Index

• Variables
• type Config
• type Driver

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
	}),
)

Types

type Config

type Config struct {
	URL            string `json:"url"`
	MigrationsPath string `json:"migrationsPath"`
}

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)
}