| 667 | } |
| 668 | |
| 669 | func (mctx *MigrationContext) SetHeartbeatIntervalMilliseconds(heartbeatIntervalMilliseconds int64) { |
| 670 | if heartbeatIntervalMilliseconds < 100 { |
| 671 | heartbeatIntervalMilliseconds = 100 |
| 672 | } |
| 673 | if heartbeatIntervalMilliseconds > 1000 { |
| 674 | heartbeatIntervalMilliseconds = 1000 |
| 675 | } |
| 676 | mctx.HeartbeatIntervalMilliseconds = heartbeatIntervalMilliseconds |
| 677 | } |
| 678 | |
| 679 | func (mctx *MigrationContext) SetMaxLagMillisecondsThrottleThreshold(maxLagMillisecondsThrottleThreshold int64) { |
| 680 | if maxLagMillisecondsThrottleThreshold < 100 { |