dbmigrate

Jul 12, 2026

Changes in this version

type Option

+ func WithSession(cfg SessionConfig) Option

+ type SessionConfig struct

+ LockTimeout time.Duration

+ StatementTimeout time.Duration

+ func (c SessionConfig) Configure(ctx context.Context, exec Execer) error

+ type UnlockFailureEvicter interface

+ EvictAfterUnlockFailure func() error

Jul 4, 2026

Changes in this version

+ func Baseline(ctx context.Context, fsys fs.FS, exec Execer, through string, l Ledger) error

+ func WithAdvisoryLock(ctx context.Context, s LockSession, cfg LockConfig, ...) (err error)

+ type Ledger struct

+ Table string

+ func (l Ledger) Applied(ctx context.Context, q RowQuerier, name string) (bool, error)

+ func (l Ledger) Ensure(ctx context.Context, exec Execer) error

+ func (l Ledger) Record(ctx context.Context, exec Execer, name string) error

+ type LockConfig struct

+ Acquire time.Duration

+ Key int64

+ OnUnlockError func(error)

+ Poll time.Duration

+ Release time.Duration

+ type LockSession interface

+ AdvisoryUnlock func(ctx context.Context, key int64) (bool, error)

+ TryAdvisoryLock func(ctx context.Context, key int64) (bool, error)

+ func SQLLockSession(c *sql.Conn) LockSession

type Option

+ func WithLedger(l Ledger, q RowQuerier) Option

+ type Row interface

+ Scan func(dest ...any) error

+ type RowQuerier interface

+ QueryRow func(ctx context.Context, query string, args ...any) Row

+ func SQLQueryRow(db SQLQueryRowContext) RowQuerier

+ type SQLQueryRowContext interface

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

Jul 3, 2026

Changes in this version

+ const ManifestName

+ func Apply(ctx context.Context, fsys fs.FS, exec Execer, opts ...Option) error

+ func Manifest(fsys fs.FS) (names []string, err error)

+ type Execer func(context.Context, string) error

+ func SQLExec(db SQLExecer) Execer

+ type Option func(*options)

+ func WithOnly(names ...string) Option

+ type SQLExecer interface

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)