Method getMigrationStateAndETA

go/logic/migrator.go:1322–1334

getMigrationStateAndETA returns the state and eta of the migration.

(rowsEstimate int64)

// getMigrationStateAndETA returns the state and eta of the migration.
func (mgtr *Migrator) getMigrationStateAndETA(rowsEstimate int64) (state, eta string, etaDuration time.Duration) {
	eta, etaDuration = mgtr.getMigrationETA(rowsEstimate)
	state = "migrating"
	if atomic.LoadInt64(&mgtr.migrationContext.CountingRowsFlag) > 0 && !mgtr.migrationContext.ConcurrentCountTableRows {
		state = "counting rows"
	} else if atomic.LoadInt64(&mgtr.migrationContext.IsPostponingCutOver) > 0 {
		eta = "due"
		state = "postponing cut-over"
	} else if isThrottled, throttleReason, _ := mgtr.migrationContext.IsThrottled(); isThrottled {
		state = fmt.Sprintf("throttled, %s", throttleReason)
	}
	return state, eta, etaDuration
}

// shouldPrintStatus returns true when the migrator is due to print status info.
func (mgtr *Migrator) shouldPrintStatus(rule PrintStatusRule, elapsedSeconds int64, etaDuration time.Duration) (shouldPrint bool) {