(retries int64)
| 489 | } |
| 490 | |
| 491 | func (mctx *MigrationContext) SetDefaultNumRetries(retries int64) { |
| 492 | mctx.throttleMutex.Lock() |
| 493 | defer mctx.throttleMutex.Unlock() |
| 494 | if retries > 0 { |
| 495 | mctx.defaultNumRetries = retries |
| 496 | } |
| 497 | } |
| 498 | |
| 499 | func (mctx *MigrationContext) MaxRetries() int64 { |
| 500 | mctx.throttleMutex.Lock() |
no outgoing calls