(chunkSize int64)
| 684 | } |
| 685 | |
| 686 | func (mctx *MigrationContext) SetChunkSize(chunkSize int64) { |
| 687 | if chunkSize < 10 { |
| 688 | chunkSize = 10 |
| 689 | } |
| 690 | if chunkSize > 100000 { |
| 691 | chunkSize = 100000 |
| 692 | } |
| 693 | atomic.StoreInt64(&mctx.ChunkSize, chunkSize) |
| 694 | } |
| 695 | |
| 696 | func (mctx *MigrationContext) SetDMLBatchSize(batchSize int64) { |
| 697 | if batchSize < 1 { |
no outgoing calls
no test coverage detected