ETAUnknown constant

Signed-off-by: Shlomi Noach <2607934+shlomi-noach@users.noreply.github.com>

go/base/context.go

@@ -52,6 +52,7 @@ const (
 const (
 	HTTPStatusOK       = 200
 	MaxEventsBatchSize = 1000
+	ETAUnknown         = math.MinInt64
 )
 
 var (
@@ -268,6 +269,7 @@ func NewMigrationContext() *MigrationContext {
 		MaxLagMillisecondsThrottleThreshold: 1500,
 		CutOverLockTimeoutSeconds:           3,
 		DMLBatchSize:                        10,
+		etaNanoseonds:                       ETAUnknown,
 		maxLoad:                             NewLoadMap(),
 		criticalLoad:                        NewLoadMap(),
 		throttleMutex:                       &sync.Mutex{},
@@ -485,6 +487,9 @@ func (this *MigrationContext) SetETADuration(etaDuration time.Duration) {
 
 func (this *MigrationContext) GetETASeconds() int64 {
 	nano := atomic.LoadInt64(&this.etaNanoseonds)
+	if nano < 0 {
+		return ETAUnknown
+	}
 	return nano / int64(time.Second)
 }
 

go/logic/migrator.go

@@ -939,7 +939,7 @@ func (this *Migrator) printStatus(rule PrintStatusRule, writers ...io.Writer) {
 	}
 
 	var etaSeconds float64 = math.MaxFloat64
-	var etaDuration = time.Duration(math.MinInt64)
+	var etaDuration = time.Duration(base.ETAUnknown)
 	if progressPct >= 100.0 {
 		etaDuration = 0
 	} else if progressPct >= 0.1 {
@@ -957,7 +957,7 @@ func (this *Migrator) printStatus(rule PrintStatusRule, writers ...io.Writer) {
 	switch etaDuration {
 	case 0:
 		eta = "due"
-	case time.Duration(math.MinInt64):
+	case time.Duration(base.ETAUnknown):
 		eta = "N/A"
 	default:
 		eta = base.PrettifyDurationOutput(etaDuration)