db_utils

Documentation

Index

• Constants
• func LogMigrationErr(mErr MigrationErr, logger *slog.Logger)
• func NewMigrateInstance(db *sql.DB, sourceURL string, cfg *pgx_driver.Config) (*migrate.Migrate, error)
• type MigrationConfig
• type MigrationErr
  • func DoMigrate(ctx context.Context, cfg MigrationConfig) (uint, bool, MigrationErr)
  • func NewMigrationErr(err string, vars map[string]any) MigrationErr

Constants

const (
	OnDbConn       = "Establishing database connection"
	OnNewInstance  = "Creating new migrate instance"
	OnVersionCheck = "Checking database version"
	OnDrop         = "Dropping database"
	OnUpgrade      = "Upgrading database"
)

Those are actually not only errors, also used for logging

Functions

func LogMigrationErr

func LogMigrationErr(mErr MigrationErr, logger *slog.Logger)

func NewMigrateInstance

func NewMigrateInstance(db *sql.DB, sourceURL string, cfg *pgx_driver.Config) (*migrate.Migrate, error)

Types

type MigrationConfig

type MigrationConfig struct {
	MigrationsPath string
	DBurl          string
	VersionLimit   int
	Drop           bool
	Logger         *slog.Logger
}

type MigrationErr

type MigrationErr = errorsx.CustomErr[map[string]any]

func DoMigrate

func DoMigrate(ctx context.Context, cfg MigrationConfig) (uint, bool, MigrationErr)

func NewMigrationErr

func NewMigrationErr(err string, vars map[string]any) MigrationErr