in migration.go [53:74]
func (m *Migrator) RunMigrations(manager *Manager) (ApplyResults, error) {
currentVersion := m.version.Current()
var results ApplyResults
for _, entry := range m.migrations {
if entry.version <= currentVersion {
continue
}
r, err := entry.migration(manager)
results = append(results, r...)
if err != nil {
return results, err
}
err = m.version.Set(entry.version)
if err != nil {
return results, fmt.Errorf("failed to save migration version: %w", err)
}
}
return results, nil
}