|
32 | 32 | import io.kubernetes.client.openapi.models.V1Service; |
33 | 33 | import io.kubernetes.client.openapi.models.V1ServiceAccount; |
34 | 34 | import io.kubernetes.client.openapi.models.V1ServiceSpec; |
| 35 | +import io.kubernetes.client.openapi.models.V1Volume; |
| 36 | +import io.kubernetes.client.openapi.models.V1VolumeMount; |
35 | 37 | import oracle.kubernetes.operator.utils.GeneratedOperatorObjects; |
36 | 38 | import oracle.kubernetes.operator.utils.KubernetesArtifactUtils; |
37 | 39 | import oracle.kubernetes.operator.utils.OperatorValues; |
@@ -197,7 +199,7 @@ private V1Deployment getActualWeblogicOperatorDeployment() { |
197 | 199 | } |
198 | 200 |
|
199 | 201 | protected V1Deployment getExpectedWeblogicOperatorDeployment() { |
200 | | - return newDeployment() |
| 202 | + V1Deployment deployment = newDeployment() |
201 | 203 | .metadata( |
202 | 204 | newObjectMeta() |
203 | 205 | .name("weblogic-operator") |
@@ -315,10 +317,6 @@ protected V1Deployment getExpectedWeblogicOperatorDeployment() { |
315 | 317 | newVolumeMount() |
316 | 318 | .name("deployment-volume") |
317 | 319 | .mountPath("/deployment")) |
318 | | - .addVolumeMountsItem( |
319 | | - newVolumeMount() |
320 | | - .name("log-volume") |
321 | | - .mountPath("/logs")) |
322 | 320 | .addVolumeMountsItem( |
323 | 321 | newVolumeMount() |
324 | 322 | .name("probes-volume") |
@@ -346,15 +344,22 @@ protected V1Deployment getExpectedWeblogicOperatorDeployment() { |
346 | 344 | newVolume() |
347 | 345 | .name("deployment-volume") |
348 | 346 | .emptyDir(new V1EmptyDirVolumeSource())) |
349 | | - .addVolumesItem( |
350 | | - newVolume() |
351 | | - .name("log-volume") |
352 | | - .emptyDir(new V1EmptyDirVolumeSource())) |
353 | 347 | .addVolumesItem( |
354 | 348 | newVolume() |
355 | 349 | .name("probes-volume") |
356 | 350 | .emptyDir(new V1EmptyDirVolumeSource())) |
357 | 351 | ))); |
| 352 | + |
| 353 | + boolean isElkIntegrationEnabled = Boolean.parseBoolean(getInputs().getElkIntegrationEnabled()); |
| 354 | + if (!isElkIntegrationEnabled) { |
| 355 | + List<V1VolumeMount> mounts = deployment.getSpec().getTemplate().getSpec() |
| 356 | + .getContainers().get(0).getVolumeMounts(); |
| 357 | + mounts.add(mounts.size() - 1, newVolumeMount().name("log-volume").mountPath("/logs")); |
| 358 | + List<V1Volume> volumees = deployment.getSpec().getTemplate().getSpec().getVolumes(); |
| 359 | + volumees.add(volumees.size() - 1, newVolume().name("log-volume").emptyDir(new V1EmptyDirVolumeSource())); |
| 360 | + } |
| 361 | + |
| 362 | + return deployment; |
358 | 363 | } |
359 | 364 |
|
360 | 365 | void expectProbes(V1Container container) { |
|
0 commit comments