[MANOPD-75552] Add port replacement for registry (#150)

* add port replacement * add port replacement
Netcracker · Apr 27, 2022 · ad99c81 · ad99c81
1 parent 5fcc379
commit ad99c81
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/kubemarine/kubernetes/__init__.py b/kubemarine/kubernetes/__init__.py
@@ -755,6 +755,13 @@ def patch_kubeadm_configmap(first_master, cluster):
     if cluster.context.get('patch_image_repo', False):
         cluster_config["imageRepository"] = cluster_config["imageRepository"].replace('/k8s.gcr.io', '')
 
+    new_image_repo_port = cluster.context.get('patch_image_repo_port', '')
+    old_image_repo_port = cluster.context.get('old_image_repo_port', '')
+    if new_image_repo_port and old_image_repo_port:
+        cluster_config["imageRepository"] = cluster_config["imageRepository"].replace('/k8s.gcr.io', '')
+        cluster_config["imageRepository"] = cluster_config["imageRepository"].replace(old_image_repo_port,
+                                                                                      new_image_repo_port)
+
     if version_higher_or_equal(current_kubernetes_version, version_coredns_path_breakage):
         cluster_config['dns']['imageRepository'] = "%s/coredns" % cluster_config["imageRepository"]