diff --git a/src/automation/src/main/java/eu/teraflow/automation/Serializer.java b/src/automation/src/main/java/eu/teraflow/automation/Serializer.java index ed64e53cf918916b456bd9e670397c1a4e2181d2..8462b195c2bb843d68ac4cf9f8951c9d6232ec70 100644 --- a/src/automation/src/main/java/eu/teraflow/automation/Serializer.java +++ b/src/automation/src/main/java/eu/teraflow/automation/Serializer.java @@ -1,5 +1,6 @@ package eu.teraflow.automation; +import automation.Automation; import context.ContextOuterClass; import context.ContextOuterClass.DeviceId; import context.ContextOuterClass.DeviceOperationalStatusEnum; @@ -12,6 +13,9 @@ import eu.teraflow.automation.device.model.Device; import eu.teraflow.automation.device.model.DeviceConfig; import eu.teraflow.automation.device.model.DeviceEvent; import eu.teraflow.automation.device.model.DeviceOperationalStatus; +import eu.teraflow.automation.model.DeviceRole; +import eu.teraflow.automation.model.DeviceRoleId; +import eu.teraflow.automation.model.DeviceRoleType; import java.util.stream.Collectors; import javax.inject.Singleton; @@ -22,10 +26,76 @@ public class Serializer { return deviceId.getDeviceUuid().getUuid(); } - public DeviceId serializeDeviceId(String expectedDeviceId) { - final var uuid = Uuid.newBuilder().setUuid(expectedDeviceId).build(); + public Automation.DeviceRoleId serialize(DeviceRoleId deviceRoleId) { + final var builder = Automation.DeviceRoleId.newBuilder(); - return ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(uuid).build(); + final var deviceRoleDevRoleId = deviceRoleId.getId(); + final var deviceRoleDeviceId = deviceRoleId.getDeviceId(); + + final var deviceRoleDevRoleIdUuid = serializeUuid(deviceRoleDevRoleId); + final var deviceRoleDeviceIdUuid = serializeUuid(deviceRoleDeviceId); + + final var deviceId = DeviceId.newBuilder().setDeviceUuid(deviceRoleDeviceIdUuid); + + builder.setDevRoleId(deviceRoleDevRoleIdUuid); + builder.setDevId(deviceId); + + return builder.build(); + } + + public DeviceRoleId deserialize(Automation.DeviceRoleId deviceRoleId) { + final var devRoleId = deserialize(deviceRoleId.getDevRoleId()); + final var devId = deserialize(deviceRoleId.getDevId()); + + return new DeviceRoleId(devRoleId, devId); + } + + public Automation.DeviceRoleType serialize(DeviceRoleType deviceRoleType) { + switch (deviceRoleType) { + case NONE: + return Automation.DeviceRoleType.NONE; + case DEV_OPS: + return Automation.DeviceRoleType.DEV_OPS; + case DEV_CONF: + return Automation.DeviceRoleType.DEV_CONF; + case PIPELINE_CONF: + return Automation.DeviceRoleType.PIPELINE_CONF; + default: + return Automation.DeviceRoleType.UNRECOGNIZED; + } + } + + public DeviceRoleType deserialize(Automation.DeviceRoleType serializedDeviceRoleType) { + switch (serializedDeviceRoleType) { + case DEV_OPS: + return DeviceRoleType.DEV_OPS; + case DEV_CONF: + return DeviceRoleType.DEV_CONF; + case PIPELINE_CONF: + return DeviceRoleType.PIPELINE_CONF; + case NONE: + case UNRECOGNIZED: + default: + return DeviceRoleType.NONE; + } + } + + public Automation.DeviceRole serialize(DeviceRole deviceRole) { + final var builder = Automation.DeviceRole.newBuilder(); + final var serializedDeviceRoleId = serialize(deviceRole.getDeviceRoleId()); + final var serializedDeviceRoleType = serialize(deviceRole.getType()); + + builder.setDevRoleId(serializedDeviceRoleId); + builder.setDevRoleType(serializedDeviceRoleType); + + return builder.build(); + } + + public DeviceRole deserialize(Automation.DeviceRole deviceRole) { + final var deviceRoleId = deserialize(deviceRole.getDevRoleId()); + final var deviceRoleType = deserialize(deviceRole.getDevRoleType()); + + return new DeviceRole(deviceRoleId, deviceRoleType); } public ContextOuterClass.EventTypeEnum serialize(EventTypeEnum eventTypeEnum) { @@ -77,8 +147,10 @@ public class Serializer { public ContextOuterClass.DeviceEvent serialize(DeviceEvent deviceEvent) { final var builder = ContextOuterClass.DeviceEvent.newBuilder(); + final var deviceIdUuid = serializeUuid(deviceEvent.getDeviceId()); + final var deviceId = DeviceId.newBuilder().setDeviceUuid(deviceIdUuid); - builder.setDeviceId(serializeDeviceId(deviceEvent.getDeviceId())); + builder.setDeviceId(deviceId); builder.setEvent(serialize(deviceEvent.getEvent())); return builder.build(); @@ -180,8 +252,10 @@ public class Serializer { public ContextOuterClass.Device serialize(Device device) { final var builder = ContextOuterClass.Device.newBuilder(); + final var deviceIdUuid = serializeUuid(device.getDeviceId()); + final var deviceId = DeviceId.newBuilder().setDeviceUuid(deviceIdUuid); - builder.setDeviceId(serializeDeviceId(device.getDeviceId())); + builder.setDeviceId(deviceId); builder.setDeviceType(device.getDeviceType()); builder.setDeviceConfig(serialize(device.getDeviceConfig())); builder.setDeviceOperationalStatus(serialize(device.getDeviceOperationalStatus())); diff --git a/src/automation/src/main/java/eu/teraflow/automation/context/ContextGatewayImpl.java b/src/automation/src/main/java/eu/teraflow/automation/context/ContextGatewayImpl.java index 30083a14406d745460aa3204f043dff78267ac61..4a6a09ec634adf9c765238ea16c89f4e2dbb737c 100644 --- a/src/automation/src/main/java/eu/teraflow/automation/context/ContextGatewayImpl.java +++ b/src/automation/src/main/java/eu/teraflow/automation/context/ContextGatewayImpl.java @@ -38,7 +38,8 @@ public class ContextGatewayImpl implements ContextGateway { @Override public Uni<Device> getDevice(String deviceId) { - final var serializedDeviceId = serializer.serializeDeviceId(deviceId); + final var serializedDeviceIdUuid = serializer.serializeUuid(deviceId); + final var serializedDeviceId = ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(serializedDeviceIdUuid).build(); return streamingDelegateContext .getDevice(serializedDeviceId) diff --git a/src/automation/src/main/java/eu/teraflow/automation/device/DeviceGatewayImpl.java b/src/automation/src/main/java/eu/teraflow/automation/device/DeviceGatewayImpl.java index d0983c12d01ec048416a4b5c0a597357d7ba4c59..bfe96e519f140b13e03a3cd74e01e702d2981321 100644 --- a/src/automation/src/main/java/eu/teraflow/automation/device/DeviceGatewayImpl.java +++ b/src/automation/src/main/java/eu/teraflow/automation/device/DeviceGatewayImpl.java @@ -1,5 +1,6 @@ package eu.teraflow.automation.device; +import context.ContextOuterClass; import device.DeviceService; import eu.teraflow.automation.Serializer; import eu.teraflow.automation.device.model.Device; @@ -26,7 +27,8 @@ public class DeviceGatewayImpl implements DeviceGateway { @Override public Uni<DeviceConfig> getInitialConfiguration(String deviceId) { - final var serializedDeviceId = serializer.serializeDeviceId(deviceId); + final var serializedDeviceIdUuid = serializer.serializeUuid(deviceId); + final var serializedDeviceId = ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(serializedDeviceIdUuid).build(); return deviceDelegate .getInitialConfig(serializedDeviceId) diff --git a/src/automation/src/test/java/eu/teraflow/automation/AutomationServiceTest.java b/src/automation/src/test/java/eu/teraflow/automation/AutomationServiceTest.java index fbceb55ec246438aaee522579be21790b363207a..7d8b642ae40ae358169018fb840bfd71c6aa259b 100644 --- a/src/automation/src/test/java/eu/teraflow/automation/AutomationServiceTest.java +++ b/src/automation/src/test/java/eu/teraflow/automation/AutomationServiceTest.java @@ -11,6 +11,7 @@ import eu.teraflow.automation.context.ContextGateway; import eu.teraflow.automation.device.DeviceGateway; import eu.teraflow.automation.device.model.*; import eu.teraflow.automation.device.model.Device; +import eu.teraflow.automation.model.DeviceRoleType; import io.quarkus.grpc.GrpcClient; import io.quarkus.test.junit.QuarkusTest; import io.quarkus.test.junit.mockito.InjectMock; @@ -61,15 +62,13 @@ class AutomationServiceTest { Mockito.when(deviceGateway.configureDevice(Mockito.any())) .thenReturn(Uni.createFrom().item(DEVICE_ID)); - // TODO 1. add (de)serialization for device role (and its components) in serializer module - // TODO 2. use it here - final var serializedDeviceRoleId = - DeviceRoleId.newBuilder() - .setDevRoleId(serializer.serializeUuid(DEVICE_ROLE_ID)) - .setDevId(serializer.serializeDeviceId(DEVICE_ID)) - .build(); - final var serializedDeviceRole = - DeviceRole.newBuilder().setDevRoleId(serializedDeviceRoleId).build(); + final var deviceRoleId = + new eu.teraflow.automation.model.DeviceRoleId(DEVICE_ROLE_ID, DEVICE_ID); + final var deviceRoleType = DeviceRoleType.DEV_OPS; + final var deviceRole = + new eu.teraflow.automation.model.DeviceRole(deviceRoleId, deviceRoleType); + final var serializedDeviceRole = serializer.serialize(deviceRole); + client .ztpAdd(serializedDeviceRole) .subscribe() @@ -78,6 +77,10 @@ class AutomationServiceTest { LOGGER.infof("Received %s", deviceRoleState); final var devRoleId = deviceRoleState.getDevRoleId(); + final var deviceRoleIdUuid = serializer.deserialize(devRoleId); + + assertThat(deviceRoleIdUuid.getId()).isEqualTo(DEVICE_ROLE_ID); + final var deviceId = serializer.deserialize(devRoleId.getDevId()); assertThat(deviceId).isEqualTo(DEVICE_ID); @@ -90,40 +93,47 @@ class AutomationServiceTest { @Test void shouldUpdateDeviceRole() throws ExecutionException, InterruptedException, TimeoutException { CompletableFuture<String> message = new CompletableFuture<>(); - final var UUID_VALUE = "0f14d0ab-9605-7862-a9e4-5ed26688389b"; + final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; + final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; - final var uuid = serializer.serializeUuid(UUID_VALUE); - final var deviceRoleId = DeviceRoleId.newBuilder().setDevRoleId(uuid).build(); - final var deviceRole = DeviceRole.newBuilder().setDevRoleId(deviceRoleId).build(); + final var deviceRoleId = + new eu.teraflow.automation.model.DeviceRoleId(DEVICE_ROLE_ID, DEVICE_ID); + final var deviceRoleType = DeviceRoleType.DEV_CONF; + final var deviceRole = + new eu.teraflow.automation.model.DeviceRole(deviceRoleId, deviceRoleType); + final var serializedDeviceRole = serializer.serialize(deviceRole); client - .ztpUpdate(deviceRole) + .ztpUpdate(serializedDeviceRole) .subscribe() .with( deviceRoleState -> { LOGGER.infof("Received response %s", deviceRoleState); message.complete(deviceRoleState.getDevRoleId().toString()); }); - assertThat(message.get(5, TimeUnit.SECONDS)).contains(UUID_VALUE); + assertThat(message.get(5, TimeUnit.SECONDS)).contains(DEVICE_ID); } @Test void shouldGetDeviceRole() throws ExecutionException, InterruptedException, TimeoutException { CompletableFuture<String> message = new CompletableFuture<>(); - final var UUID_VALUE = "0f14d0ab-9605-7862-a9e4-5ed26688389b"; + final var DEVICE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389b"; + final var DEVICE_ROLE_ID = "0f14d0ab-9608-7862-a9e4-5ed26688389a"; - final var uuid = serializer.serializeUuid(UUID_VALUE); - final var deviceRoleId = DeviceRoleId.newBuilder().setDevRoleId(uuid).build(); + final var deviceRoleId = new eu.teraflow.automation.model.DeviceRoleId(DEVICE_ROLE_ID, DEVICE_ID); + final var serializeDeviceRoleId = serializer.serialize(deviceRoleId); client - .ztpGetDeviceRole(deviceRoleId) + .ztpGetDeviceRole(serializeDeviceRoleId) .subscribe() .with( deviceRole -> { LOGGER.infof("Received response %s", deviceRole); + assertThat(deviceRole.getDevRoleId().getDevId().getDeviceUuid().getUuid()) + .isEqualTo(DEVICE_ID); message.complete(deviceRole.getDevRoleId().toString()); }); - assertThat(message.get(5, TimeUnit.SECONDS)).contains(UUID_VALUE); + assertThat(message.get(5, TimeUnit.SECONDS)).contains(DEVICE_ROLE_ID); } @Test diff --git a/src/automation/src/test/java/eu/teraflow/automation/SerializerTest.java b/src/automation/src/test/java/eu/teraflow/automation/SerializerTest.java index de4a7930da6f51686b8173054b705d229986f9ff..2e5e6ab75684a89c3edf3757f279b30225530e52 100644 --- a/src/automation/src/test/java/eu/teraflow/automation/SerializerTest.java +++ b/src/automation/src/test/java/eu/teraflow/automation/SerializerTest.java @@ -2,6 +2,7 @@ package eu.teraflow.automation; import static org.assertj.core.api.Assertions.assertThat; +import automation.Automation; import context.ContextOuterClass; import context.ContextOuterClass.DeviceId; import context.ContextOuterClass.DeviceOperationalStatusEnum; @@ -14,6 +15,9 @@ import eu.teraflow.automation.device.model.Device; import eu.teraflow.automation.device.model.DeviceConfig; import eu.teraflow.automation.device.model.DeviceEvent; import eu.teraflow.automation.device.model.DeviceOperationalStatus; +import eu.teraflow.automation.model.DeviceRole; +import eu.teraflow.automation.model.DeviceRoleId; +import eu.teraflow.automation.model.DeviceRoleType; import io.quarkus.test.junit.QuarkusTest; import java.util.List; import java.util.stream.Stream; @@ -29,24 +33,124 @@ class SerializerTest { @Inject Serializer serializer; @Test - void shouldSerializeDeviceId() { - final var expectedId = "expectedDeviceId"; - final var expectedUuid = Uuid.newBuilder().setUuid(expectedId).build(); - final var expectedDeviceId = DeviceId.newBuilder().setDeviceUuid(expectedUuid).build(); + void shouldDeserializeDeviceId() { + final var expectedDeviceId = "expectedDeviceId"; - final var serializedDeviceId = serializer.serializeDeviceId("expectedDeviceId"); + final var serializedDeviceIdUuid = serializer.serializeUuid("expectedDeviceId"); + final var serializedDeviceId = DeviceId.newBuilder().setDeviceUuid(serializedDeviceIdUuid).build(); - assertThat(serializedDeviceId).usingRecursiveComparison().isEqualTo(expectedDeviceId); + final var deviceId = serializer.deserialize(serializedDeviceId); + + assertThat(deviceId).isEqualTo(expectedDeviceId); } @Test - void shouldDeserializeDeviceId() { + void shouldSerializeDeviceRoleId() { + final var expectedDevRoleId = "expectedDevRoleId"; final var expectedDeviceId = "expectedDeviceId"; - final var serializedDeviceId = serializer.serializeDeviceId("expectedDeviceId"); - final var deviceId = serializer.deserialize(serializedDeviceId); + final var deviceRoleId = new DeviceRoleId(expectedDevRoleId, expectedDeviceId); + final var serializedDeviceRoleIdUuid = serializer.serializeUuid(expectedDevRoleId); + final var serializedDeviceRoleDeviceIdUuid = serializer.serializeUuid(expectedDeviceId); + final var serializedDeviceRoleDeviceId = ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(serializedDeviceRoleDeviceIdUuid).build(); - assertThat(deviceId).isEqualTo(expectedDeviceId); + final var expectedDeviceRoleId = + Automation.DeviceRoleId.newBuilder() + .setDevRoleId(serializedDeviceRoleIdUuid) + .setDevId(serializedDeviceRoleDeviceId) + .build(); + + final var serializedDevRoleId = + serializer.serialize(deviceRoleId); + + assertThat(serializedDevRoleId).usingRecursiveComparison().isEqualTo(expectedDeviceRoleId); + } + + @Test + void shouldDeserializeDeviceRoleId() { + final var expectedDevRoleId = "expectedDevRoleId"; + final var expectedDeviceId = "expectedDeviceId"; + + final var expectedDeviceRoleId = new DeviceRoleId(expectedDevRoleId, expectedDeviceId); + + final var serializedDeviceRoleId = serializer.serialize(expectedDeviceRoleId); + final var deviceRoleId = serializer.deserialize(serializedDeviceRoleId); + + assertThat(deviceRoleId).usingRecursiveComparison().isEqualTo(expectedDeviceRoleId); + } + + private static Stream<Arguments> provideDeviceRoleType() { + return Stream.of( + Arguments.of(DeviceRoleType.DEV_OPS, Automation.DeviceRoleType.DEV_OPS), + Arguments.of(DeviceRoleType.DEV_CONF, Automation.DeviceRoleType.DEV_CONF), + Arguments.of(DeviceRoleType.NONE, Automation.DeviceRoleType.NONE), + Arguments.of(DeviceRoleType.PIPELINE_CONF, Automation.DeviceRoleType.PIPELINE_CONF)); + } + + @ParameterizedTest + @MethodSource("provideDeviceRoleType") + void shouldSerializeDeviceRoleType( + DeviceRoleType deviceRoleType, Automation.DeviceRoleType expectedSerializedType) { + final var serializedType = serializer.serialize(deviceRoleType); + assertThat(serializedType.getNumber()).isEqualTo(expectedSerializedType.getNumber()); + } + + @ParameterizedTest + @MethodSource("provideDeviceRoleType") + void shouldDeserializeDeviceRoleType( + DeviceRoleType expectedDeviceRoleType, + Automation.DeviceRoleType serializedDeviceRoleTypeType) { + + final var deviceRoleType = serializer.deserialize(serializedDeviceRoleTypeType); + + assertThat(deviceRoleType).isEqualTo(expectedDeviceRoleType); + } + + @Test + void shouldSerializeDeviceRole() { + final var expectedDevRoleId = "expectedDevRoleId"; + final var expectedDeviceId = "expectedDeviceId"; + + final var deviceRoleId = new DeviceRoleId(expectedDevRoleId, expectedDeviceId); + final var deviceRoleType = DeviceRoleType.PIPELINE_CONF; + + final var deviceRole = new DeviceRole(deviceRoleId,deviceRoleType); + + final var serializedDeviceRoleId = serializer.serialize(deviceRoleId); + final var serializedDeviceRoleType = serializer.serialize(deviceRoleType); + final var expectedDeviceRole = + Automation.DeviceRole.newBuilder() + .setDevRoleId(serializedDeviceRoleId) + .setDevRoleType(serializedDeviceRoleType) + .build(); + + final var serializedDeviceRole = serializer.serialize(deviceRole); + + assertThat(serializedDeviceRole).usingRecursiveComparison().isEqualTo(expectedDeviceRole); + } + + @Test + void shouldDeserializeDeviceRole() { + final var expectedDevRoleId = "expectedDevRoleId"; + final var expectedDeviceId = "expectedDeviceId"; + + final var expectedDeviceRoleId = new DeviceRoleId(expectedDevRoleId, expectedDeviceId); + final var expectedDeviceRoleType = DeviceRoleType.NONE; + + final var expectedDeviceRole = new DeviceRole(expectedDeviceRoleId, expectedDeviceRoleType); + + final var serializedDeviceRoleId = serializer.serialize(expectedDeviceRoleId); + final var serializedDeviceRoleType = serializer.serialize(expectedDeviceRoleType); + + final var serializedDeviceRole = + Automation.DeviceRole.newBuilder() + .setDevRoleId(serializedDeviceRoleId) + .setDevRoleType(serializedDeviceRoleType) + .build(); + + final var deviceRole = serializer.deserialize(serializedDeviceRole); + + assertThat(deviceRole).usingRecursiveComparison().isEqualTo(expectedDeviceRole); } private static Stream<Arguments> provideEventTypeEnum() { @@ -302,7 +406,11 @@ class SerializerTest { final var expectedDeviceConfig = ContextOuterClass.DeviceConfig.newBuilder().addConfigRules(expectedConfigRule).build(); final var deviceBuilder = ContextOuterClass.Device.newBuilder(); - deviceBuilder.setDeviceId(serializer.serializeDeviceId("deviceId")); + + final var serializedDeviceIdUuid = serializer.serializeUuid("deviceId"); + final var serializedDeviceId = DeviceId.newBuilder().setDeviceUuid(serializedDeviceIdUuid).build(); + + deviceBuilder.setDeviceId(serializedDeviceId); deviceBuilder.setDeviceType("deviceType"); deviceBuilder.setDeviceConfig(expectedDeviceConfig); deviceBuilder.setDeviceOperationalStatus(serializer.serialize(DeviceOperationalStatus.ENABLED)); @@ -334,8 +442,12 @@ class SerializerTest { .build(); final var deviceConfig = ContextOuterClass.DeviceConfig.newBuilder().addConfigRules(configRule).build(); + + final var serializedDeviceIdUuid = serializer.serializeUuid("deviceId"); + final var serializedDeviceId = DeviceId.newBuilder().setDeviceUuid(serializedDeviceIdUuid).build(); + final var deviceBuilder = ContextOuterClass.Device.newBuilder(); - deviceBuilder.setDeviceId(serializer.serializeDeviceId("deviceId")); + deviceBuilder.setDeviceId(serializedDeviceId); deviceBuilder.setDeviceType("deviceType"); deviceBuilder.setDeviceConfig(deviceConfig); deviceBuilder.setDeviceOperationalStatus(serializer.serialize(DeviceOperationalStatus.ENABLED)); diff --git a/src/automation/target/kubernetes/kubernetes.yml b/src/automation/target/kubernetes/kubernetes.yml index dc1022a61eed345a9d0c7814de48a282e991e5b6..a290b69d11926eee164bd55a6cbc845c64b9cb99 100644 --- a/src/automation/target/kubernetes/kubernetes.yml +++ b/src/automation/target/kubernetes/kubernetes.yml @@ -3,8 +3,8 @@ apiVersion: v1 kind: Service metadata: annotations: - app.quarkus.io/commit-id: d58523db1ec1df9eb01b331f1a5c88dce7857811 - app.quarkus.io/build-timestamp: 2022-02-08 - 17:04:19 +0000 + app.quarkus.io/commit-id: 74c131c1ab16a4a8b243c27ae34b4d26487c9e05 + app.quarkus.io/build-timestamp: 2022-02-10 - 13:53:38 +0000 labels: app.kubernetes.io/name: automationservice app.kubernetes.io/version: 0.1.0 @@ -12,12 +12,12 @@ metadata: name: automationservice spec: ports: - - name: grpc-server - port: 9999 - targetPort: 9999 - name: http port: 8080 targetPort: 8080 + - name: grpc-server + port: 9999 + targetPort: 9999 selector: app.kubernetes.io/name: automationservice app.kubernetes.io/version: 0.1.0 @@ -27,28 +27,28 @@ apiVersion: apps/v1 kind: Deployment metadata: annotations: - app.quarkus.io/commit-id: d58523db1ec1df9eb01b331f1a5c88dce7857811 - app.quarkus.io/build-timestamp: 2022-02-08 - 17:04:19 +0000 + app.quarkus.io/commit-id: 74c131c1ab16a4a8b243c27ae34b4d26487c9e05 + app.quarkus.io/build-timestamp: 2022-02-10 - 13:53:38 +0000 labels: app: automationservice - app.kubernetes.io/name: automationservice app.kubernetes.io/version: 0.1.0 + app.kubernetes.io/name: automationservice name: automationservice spec: replicas: 1 selector: matchLabels: - app.kubernetes.io/name: automationservice app.kubernetes.io/version: 0.1.0 + app.kubernetes.io/name: automationservice template: metadata: annotations: - app.quarkus.io/commit-id: d58523db1ec1df9eb01b331f1a5c88dce7857811 - app.quarkus.io/build-timestamp: 2022-02-08 - 17:04:19 +0000 + app.quarkus.io/commit-id: 74c131c1ab16a4a8b243c27ae34b4d26487c9e05 + app.quarkus.io/build-timestamp: 2022-02-10 - 13:53:38 +0000 labels: app: automationservice - app.kubernetes.io/name: automationservice app.kubernetes.io/version: 0.1.0 + app.kubernetes.io/name: automationservice spec: containers: - env: @@ -74,12 +74,12 @@ spec: timeoutSeconds: 10 name: automationservice ports: - - containerPort: 9999 - name: grpc-server - protocol: TCP - containerPort: 8080 name: http protocol: TCP + - containerPort: 9999 + name: grpc-server + protocol: TCP readinessProbe: failureThreshold: 3 httpGet: