()
| 497 | } |
| 498 | |
| 499 | func (mctx *MigrationContext) MaxRetries() int64 { |
| 500 | mctx.throttleMutex.Lock() |
| 501 | defer mctx.throttleMutex.Unlock() |
| 502 | retries := mctx.defaultNumRetries |
| 503 | return retries |
| 504 | } |
| 505 | |
| 506 | func (mctx *MigrationContext) IsTransactionalTable() bool { |
| 507 | switch strings.ToLower(mctx.TableEngine) { |
no outgoing calls