|
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