(batchSize int64)
| 694 | } |
| 695 | |
| 696 | func (mctx *MigrationContext) SetDMLBatchSize(batchSize int64) { |
| 697 | if batchSize < 1 { |
| 698 | batchSize = 1 |
| 699 | } |
| 700 | if batchSize > MaxEventsBatchSize { |
| 701 | batchSize = MaxEventsBatchSize |
| 702 | } |
| 703 | atomic.StoreInt64(&mctx.DMLBatchSize, batchSize) |
| 704 | } |
| 705 | |
| 706 | func (mctx *MigrationContext) SetThrottleGeneralCheckResult(checkResult *ThrottleCheckResult) *ThrottleCheckResult { |
| 707 | mctx.throttleMutex.Lock() |
no outgoing calls
no test coverage detected