ElapsedRowCopyTime returns time since starting to copy chunks of rows
()
| 581 | |
| 582 | // ElapsedRowCopyTime returns time since starting to copy chunks of rows |
| 583 | func (mctx *MigrationContext) MarkRowCopyEndTime() { |
| 584 | mctx.throttleMutex.Lock() |
| 585 | defer mctx.throttleMutex.Unlock() |
| 586 | mctx.RowCopyEndTime = time.Now() |
| 587 | } |
| 588 | |
| 589 | func (mctx *MigrationContext) TimeSinceLastHeartbeatOnChangelog() time.Duration { |
| 590 | return time.Since(mctx.GetLastHeartbeatOnChangelogTime()) |
no outgoing calls
no test coverage detected