migrations

Documentation

Index

• Constants
• type Migration
• type MigrationEntity
• type MigrationsRepository
• type SqlMigrationService
  • func NewMigrationService(repo MigrationsRepository) *SqlMigrationService
  • func (m *SqlMigrationService) Register(migration Migration) error
  • func (m *SqlMigrationService) Run() error
  • func (m *SqlMigrationService) WasApplied(name string) bool

Constants

const (
	MIGRATION_TABLE_NAME = "_migrations"
)

Types

type Migration

type Migration interface {
	Name() string
	Order() int
	Up() bool
	Down() bool
}

type MigrationEntity

type MigrationEntity struct {
	ID         string    `json:"id"`
	ExecutedOn time.Time `json:"executed_on"`
	Name       string    `json:"name"`
	Status     bool      `json:"status"`
}

type MigrationsRepository

type MigrationsRepository interface {
	CreateTable() error
	GetAppliedMigrations() ([]MigrationEntity, error)
	SaveMigrationStatus(migration MigrationEntity) error
}

type SqlMigrationService

type SqlMigrationService struct {
	Context context.Context

	Migrations        *orderedmap.OrderedMap[int, Migration]
	AppliedMigrations []MigrationEntity
	Repository        MigrationsRepository
	// contains filtered or unexported fields
}

func NewMigrationService

func NewMigrationService(repo MigrationsRepository) *SqlMigrationService

func (*SqlMigrationService) Register

func (m *SqlMigrationService) Register(migration Migration) error

func (*SqlMigrationService) Run

func (m *SqlMigrationService) Run() error

func (*SqlMigrationService) WasApplied

func (m *SqlMigrationService) WasApplied(name string) bool