dbump

Sep 25, 2022

Changes in this version

type Config

+ NoDatabaseLock bool

Jul 1, 2022

Changes in this version

type Config

+ Num int

+ Timeout time.Duration

type MigratorMode

+ const ModeApplyAll

+ const ModeApplyN

+ const ModeRevertAll

+ const ModeRevertN

Jun 30, 2022

Changes in this version

type Config

+ AfterStep func(ctx context.Context, step Step)

+ BeforeStep func(ctx context.Context, step Step)

type Migrator

+ Drop func(ctx context.Context) error

type MigratorMode

+ const ModeDrop

+ const ModeRedo

Jun 30, 2022

Changes in this version

+ var ErrMigrationAlreadyLocked = errors.New("migration is locked already")

type Migrator

+ DoStep func(ctx context.Context, step Step) error

+ type Step struct

+ DisableTx bool

+ Query string

+ Version int

Jun 25, 2022

Changes in this version

type Config

+ DisableTx bool

type Migrator

+ Begin func(ctx context.Context) error

+ Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

Jun 25, 2022

Changes in this version

+ type Conn interface

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

type Migration

+ Revert string

type Migrator

+ func AsLocklessMigrator(m Migrator) Migrator

Jun 23, 2022

Changes in this version

+ type Config struct

+ Loader Loader

+ Migrator Migrator

+ Mode MigratorMode

+ UseForce bool

+ ZigZag bool

+ type MigratorMode int

+ const ModeDown

+ const ModeDownOne

+ const ModeNotSet

+ const ModeUp

+ const ModeUpOne

Jun 15, 2022

Changes in this version

+ type FS interface

+ type FileSysLoader struct

+ func NewFileSysLoader(fs FS, path string) *FileSysLoader

+ func (el *FileSysLoader) Load() ([]*Migration, error)

Jun 4, 2022

Changes in this version

+ type DB interface

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

type Migration

+ ApplyFn MigrationFn

+ RollbackFn MigrationFn

+ type MigrationFn func(db DB) error

type Migrator

+ Init func(ctx context.Context) error

+ LockDB func(ctx context.Context) error

+ UnlockDB func(ctx context.Context) error

Oct 18, 2021

Changes in this version

+ const MigrationDelimiter

+ func Run(ctx context.Context, m Migrator, l Loader) error

+ type DiskLoader struct

+ func NewDiskLoader(path string) *DiskLoader

+ func (dl *DiskLoader) Load() ([]*Migration, error)

+ type EmbedLoader struct

+ func NewEmbedLoader(fs embed.FS, path string) *EmbedLoader

+ func (el *EmbedLoader) Load() ([]*Migration, error)

+ type Loader interface

+ Load func() ([]*Migration, error)

+ type Migration struct

+ Apply string

+ ID int

+ Name string

+ Rollback string

+ type Migrator interface

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

+ Lock func(ctx context.Context) error

+ SetVersion func(ctx context.Context, version int) error

+ Unlock func(ctx context.Context) error

+ Version func(ctx context.Context) (version int, err error)

+ type MigratorClickHouse struct

+ func NewMigratorClickHouse(db *sql.DB) *MigratorClickHouse

+ func (ch *MigratorClickHouse) Exec(ctx context.Context, query string, args ...interface{}) error

+ func (ch *MigratorClickHouse) Lock(ctx context.Context) error

+ func (ch *MigratorClickHouse) SetVersion(ctx context.Context, version int) error

+ func (ch *MigratorClickHouse) Unlock(ctx context.Context) error

+ func (ch *MigratorClickHouse) Version(ctx context.Context) (version int, err error)

+ type MigratorMySQL struct

+ func NewMigratorMySQL(db *sql.DB) *MigratorMySQL

+ func (my *MigratorMySQL) Exec(ctx context.Context, query string, args ...interface{}) error

+ func (my *MigratorMySQL) Lock(ctx context.Context) error

+ func (my *MigratorMySQL) SetVersion(ctx context.Context, version int) error

+ func (my *MigratorMySQL) Unlock(ctx context.Context) error

+ func (my *MigratorMySQL) Version(ctx context.Context) (version int, err error)

+ type MigratorPostgres struct

+ func NewMigratorPostgres(db *sql.DB) *MigratorPostgres

+ func (pg *MigratorPostgres) Exec(ctx context.Context, query string, args ...interface{}) error

+ func (pg *MigratorPostgres) Lock(ctx context.Context) error

+ func (pg *MigratorPostgres) SetVersion(ctx context.Context, version int) error

+ func (pg *MigratorPostgres) Unlock(ctx context.Context) error

+ func (pg *MigratorPostgres) Version(ctx context.Context) (version int, err error)

+ type SliceLoader struct

+ func NewSliceLoader(migrations []*Migration) *SliceLoader

+ func (sl *SliceLoader) AddMigration(m *Migration)

+ func (sl *SliceLoader) Load() ([]*Migration, error)