migrator

Documentation

Index

• Variables
• type FSUtils
• type Service
  • func New(logger *zap.Logger, store Store, migrationPath string, skipDownFiles bool) *Service
  • func (s *Service) Close() (error, error)
  • func (s *Service) Up() error
• type Store

Variables

var ErrDirtyMigrationExists = fmt.Errorf("dirty migration")

Types

type FSUtils

type FSUtils interface {
	GetMigrationFileList(migrationsDir string) (fsutils.DirElements, error)
	ReadFileContent(pathToFile string) (string, error)
}

type Service

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

func New

func New(logger *zap.Logger, store Store, migrationPath string, skipDownFiles bool) *Service

New returns a new migrator service

func (*Service) Close

func (s *Service) Close() (error, error)

func (*Service) Up

func (s *Service) Up() error

type Store

type Store interface {
	HasMigrationRun(filename string) (bool, error)
	InsertMigration(filename string) (model.Migration, error)
	RawExec(s string) error
	MarkMigrationCompleted(id uint) (model.Migration, error)
	EnsureMigrationTableExists() error
	GetLatestFailedMigration() (*model.Migration, error)
	Close() error
}