Method ElapsedRowCopyTime

go/base/context.go:567–580

ElapsedRowCopyTime returns time since starting to copy chunks of rows

()

// ElapsedRowCopyTime returns time since starting to copy chunks of rows
func (mctx *MigrationContext) ElapsedRowCopyTime() time.Duration {
	mctx.throttleMutex.Lock()
	defer mctx.throttleMutex.Unlock()

	if mctx.RowCopyStartTime.IsZero() {
		// Row copy hasn't started yet
		return 0
	}

	if mctx.RowCopyEndTime.IsZero() {
		return time.Since(mctx.RowCopyStartTime)
	}
	return mctx.RowCopyEndTime.Sub(mctx.RowCopyStartTime)
}

// ElapsedRowCopyTime returns time since starting to copy chunks of rows
func (mctx *MigrationContext) MarkRowCopyEndTime() {