(maxLagMillisecondsThrottleThreshold int64)
| 677 | } |
| 678 | |
| 679 | func (mctx *MigrationContext) SetMaxLagMillisecondsThrottleThreshold(maxLagMillisecondsThrottleThreshold int64) { |
| 680 | if maxLagMillisecondsThrottleThreshold < 100 { |
| 681 | maxLagMillisecondsThrottleThreshold = 100 |
| 682 | } |
| 683 | atomic.StoreInt64(&mctx.MaxLagMillisecondsThrottleThreshold, maxLagMillisecondsThrottleThreshold) |
| 684 | } |
| 685 | |
| 686 | func (mctx *MigrationContext) SetChunkSize(chunkSize int64) { |
| 687 | if chunkSize < 10 { |
no outgoing calls
no test coverage detected