Method executeDMLWriteFuncs

go/logic/migrator.go:1878–1901

()

}

func (mgtr *Migrator) executeDMLWriteFuncs() error {
	if mgtr.migrationContext.Noop {
		mgtr.migrationContext.Log.Debugf("Noop operation; not really executing DML write funcs")
		return nil
	}
	for {
		if atomic.LoadInt64(&mgtr.finishedMigrating) > 0 {
			return nil
		}

		mgtr.throttler.throttle(nil)

		select {
		case eventStruct := <-mgtr.applyEventsQueue:
			{
				if err := mgtr.onApplyEventStruct(eventStruct); err != nil {
					return err
				}
			}
		case <-time.After(time.Second):
			continue
		}
	}
}

// finalCleanup takes actions at very end of migration, dropping tables etc.
func (mgtr *Migrator) finalCleanup() error {