Method GetCurrentLagDuration

go/base/context.go:593–595

()

}

func (mctx *MigrationContext) GetCurrentLagDuration() time.Duration {
	return time.Duration(atomic.LoadInt64(&mctx.CurrentLag))
}

func (mctx *MigrationContext) GetProgressPct() float64 {
	return math.Float64frombits(atomic.LoadUint64(&mctx.currentProgress))