Method runDryRun

cli/migrate/migrate.go:1328–1352

(ret <-chan interface{})

}

func (m *Migrate) runDryRun(ret <-chan interface{}) error {
	var op herrors.Op = "migrate.Migrate.runDryRun"
	migrations := make([]*Migration, 0)
	var lastInsertVersion int64
	for r := range ret {
		if m.stop() {
			return nil
		}

		switch r := r.(type) {
		case error:
			return herrors.E(op, r)
		case *Migration:
			if r.Body != nil {
				version := int64(r.Version)
				if version != lastInsertVersion {
					migrations = append(migrations, r)
					lastInsertVersion = version
				}
			}
		}
	}
	fmt.Fprintf(os.Stdout, "%s", printDryRunStatus(migrations))
	return nil
}

func (m *Migrate) squashMigrations(retUp <-chan interface{}, retDown <-chan interface{}, dataUp chan<- interface{}, dataDown chan<- interface{}, versions chan<- int64) error {
	var latestVersion int64