repositories

Documentation

Index

• Variables
• type ErrIsNotDir
  • func (e *ErrIsNotDir) Error() string
• type MigrationDBRepo
  • func NewMigrationDBRepo(db storage.DB) (MigrationDBRepo, error)
• type MigrationFsRepo
  • func NewMigrationFsRepo(migrationsConfig *configloader.MigrationsConfig) (MigrationFsRepo, error)

Variables

var ErrMigrationVersionConflict = errors.New("migration version conflict")

Types

type ErrIsNotDir

type ErrIsNotDir struct {
	// contains filtered or unexported fields
}

func (*ErrIsNotDir) Error

func (e *ErrIsNotDir) Error() string

type MigrationDBRepo

type MigrationDBRepo interface {
	List() (map[string]*models.Migration, error)
	IsApplied(version string) (bool, error)
	Apply(upgradeScript string, migration *models.Migration) error
	ApplyWithTx(upgradeScript string, migration *models.Migration) error
	Revert(downgradeScript string, migration *models.Migration) error
	RevertWithTx(downgradeScript string, migration *models.Migration) error
}

func NewMigrationDBRepo

func NewMigrationDBRepo(db storage.DB) (MigrationDBRepo, error)

NewMigrationDBRepo initializes the MigrationDBRepo with a database. Furthermore, it ensures the migration table it operates on exists. If it is unable to create or confirm the table exists, an error is returned.

type MigrationFsRepo

type MigrationFsRepo interface {
	Create(migration *models.Migration) error
	List() (map[string]*models.Migration, error)
	ReadUpgradeScript(migration *models.Migration) (sqlparse.MigrationScript, error)
	ReadDowngradeScript(migration *models.Migration) (sqlparse.MigrationScript, error)
}

func NewMigrationFsRepo

func NewMigrationFsRepo(
	migrationsConfig *configloader.MigrationsConfig,
) (MigrationFsRepo, error)