mig

Mar 9, 2023

Changes in this version

type Mig

+ func FromPgxV4(ms Migrations, conn *pgx4.Conn, opts ...Option) *Mig

+ func FromPgxV4Pool(ms Migrations, pool *pgxPoolV4.Pool, opts ...Option) (*Mig, func(), error)

+ func FromPgxV5(ms Migrations, conn *pgx5.Conn, opts ...Option) *Mig

+ func FromPgxV5Pool(ms Migrations, pool *pgxPoolV5.Pool, opts ...Option) (*Mig, func(), error)

+ func New(ms Migrations, db Database, opts ...Option) *Mig

type Migrations

+ func FromDir(path string) (Migrations, error)

+ type Option func(*Mig)

+ func WithAcquireConnectionTimeout(timeout time.Duration) Option

Feb 8, 2023

Changes in this version

+ var ErrDuplicateVersion = errors.New("duplicate version")

+ var ErrInvalidVersion = errors.New("invalid migration version prefix")

+ type Database interface

+ CreateSchemaMigrationsTable func(ctx context.Context) error

+ LastVersion func(ctx context.Context) (uint64, error)

+ Lock func(ctx context.Context) error

+ RunMigration func(ctx context.Context, query string) error

+ SetLastVersion func(ctx context.Context, lastVersion uint64) error

+ Unlock func(ctx context.Context) error

+ type Mig struct

+ func NewMig(ms Migrations, db Database) *Mig

+ func (d *Mig) Migrate(ctx context.Context) error

+ type Migration struct

+ Name string

+ Path string

+ SQL string

+ Version uint64

+ type Migrations []Migration

+ func FromEmbedFS(fs embed.FS, path string) (Migrations, error)

+ func (ms *Migrations) Len() int

+ func (ms *Migrations) Less(i, j int) bool

+ func (ms *Migrations) Swap(i, j int)

+ type Pgx4 struct

+ func NewPgx4(conn *pgxpool.Conn, opts ...Pgx4Option) *Pgx4

+ func (db *Pgx4) CreateSchemaMigrationsTable(ctx context.Context) error

+ func (db *Pgx4) LastVersion(ctx context.Context) (uint64, error)

+ func (db *Pgx4) Lock(ctx context.Context) error

+ func (db *Pgx4) RunMigration(ctx context.Context, query string) error

+ func (db *Pgx4) SetLastVersion(ctx context.Context, lastVersion uint64) error

+ func (db *Pgx4) Unlock(ctx context.Context) error

+ type Pgx4Option func(*Pgx4)

+ func WithCustomTable(name string) Pgx4Option