|
123 | 123 | import com.cloud.utils.LogUtils; |
124 | 124 | import com.cloud.utils.Pair; |
125 | 125 | import com.cloud.utils.UuidUtils; |
126 | | -import com.cloud.utils.component.ComponentContext; |
127 | 126 | import com.cloud.utils.db.EntityManager; |
128 | 127 | import com.cloud.utils.exception.CloudRuntimeException; |
129 | 128 | import com.cloud.utils.net.NetUtils; |
@@ -316,10 +315,10 @@ public class UnmanagedVMsManagerImpl implements UnmanagedVMsManager { |
316 | 315 | @Inject |
317 | 316 | private ImportVmTasksManager importVmTasksManager; |
318 | 317 |
|
319 | | - private KubernetesServiceHelper kubernetesServiceHelper; |
| 318 | + private List<KubernetesServiceHelper> kubernetesServiceHelpers; |
320 | 319 |
|
321 | | - private void setKubernetesServiceHelper(KubernetesServiceHelper helper) { |
322 | | - this.kubernetesServiceHelper = helper; |
| 320 | + public void setKubernetesServiceHelpers(final List<KubernetesServiceHelper> kubernetesServiceHelpers) { |
| 321 | + this.kubernetesServiceHelpers = kubernetesServiceHelpers; |
323 | 322 | } |
324 | 323 |
|
325 | 324 | protected Gson gson; |
@@ -2394,10 +2393,7 @@ void performUnmanageVMInstancePrechecks(VMInstanceVO vmVO) { |
2394 | 2393 | } |
2395 | 2394 |
|
2396 | 2395 | private boolean isVmPartOfCKSCluster(VMInstanceVO vmVO) { |
2397 | | - if (kubernetesServiceHelper == null) { |
2398 | | - setKubernetesServiceHelper(ComponentContext.getComponent(KubernetesServiceHelper.class)); |
2399 | | - } |
2400 | | - return kubernetesServiceHelper.findByVmId(vmVO.getId()) != null; |
| 2396 | + return kubernetesServiceHelpers.get(0).findByVmId(vmVO.getId()) != null; |
2401 | 2397 | } |
2402 | 2398 |
|
2403 | 2399 | private boolean hasVolumeSnapshotsPriorToUnmanageVM(VMInstanceVO vmVO) { |
|
0 commit comments