migrator

Jan 5, 2026

Changes in this version

type Migrator

+ func (m *Migrator) Count() int

May 22, 2024

Changes in this version

+ type Migration struct

+ Func func(context.Context, pgx.Tx) error

+ Name string

+ func (m *Migration) String() string

+ type MigrationNoTx struct

+ Func func(context.Context, PgxIface) error

+ Name string

+ func (m *MigrationNoTx) String() string

+ type Migrator struct

+ TableName string

+ func New(opts ...Option) (*Migrator, error)

+ func (m *Migrator) Migrate(ctx context.Context, db PgxIface) error

+ func (m *Migrator) NeedUpgrade(ctx context.Context, db PgxIface) (bool, error)

+ func (m *Migrator) Pending(ctx context.Context, db PgxIface) ([]interface{}, int, error)

+ type Option func(*Migrator)

+ func Migrations(migrations ...interface{}) Option

+ func SetNotice(noticeFunc func(string)) Option

+ func TableName(tableName string) Option

+ type PgxIface interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Ping func(ctx context.Context) error

+ Query func(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row