Commit fa35b50d authored by Labros Papadopoulos's avatar Labros Papadopoulos
Browse files

feat: refactor telemetry

parent 0dda682c
Loading
Loading
Loading
Loading
+2 −2
Original line number Diff line number Diff line
@@ -10,8 +10,6 @@ import static org.etsi.osl.hypo.core.common.constants.SonataKafkaTriggersConstan
import static org.junit.jupiter.api.Assertions.*;
import static org.mockito.ArgumentMatchers.any;

import org.etsi.osl.hypo.clients.telemetry.helpers.HasReceivedMessagesSupplier;
import org.etsi.osl.hypo.clients.telemetry.helpers.InMemoryKafkaTestLifecycleManager;
import io.quarkus.test.InjectMock;
import io.quarkus.test.common.QuarkusTestResource;
import io.quarkus.test.junit.QuarkusTest;
@@ -29,6 +27,8 @@ import java.time.Duration;
import java.util.UUID;
import org.eclipse.microprofile.reactive.messaging.Message;
import org.eclipse.microprofile.reactive.messaging.Metadata;
import org.etsi.osl.hypo.clients.telemetry.helpers.HasReceivedMessagesSupplier;
import org.etsi.osl.hypo.clients.telemetry.helpers.InMemoryKafkaTestLifecycleManager;
import org.etsi.osl.hypo.clients.telemetry.service.TelemetryService;
import org.etsi.osl.hypo.core.common.Status;
import org.etsi.osl.hypo.core.common.telemetry.CloudEventDashboardData;
+0 −1
Original line number Diff line number Diff line
@@ -11,7 +11,6 @@ import java.util.List;
import java.util.Map;
import java.util.UUID;
import org.etsi.osl.hypo.clients.telemetry.config.ApplicationProperties;
import org.etsi.osl.hypo.clients.telemetry.service.EditSecretService;
import org.etsi.osl.hypo.core.common.telemetry.CloudEventDeleteServiceTelemetry;
import org.etsi.osl.hypo.core.common.telemetry.CloudEventUpdateServiceTelemetry;
import org.etsi.osl.hypo.core.common.telemetry.DeleteTelemetryData;
+0 −1
Original line number Diff line number Diff line
@@ -15,7 +15,6 @@ import java.util.UUID;
import org.eclipse.microprofile.rest.client.inject.RestClient;
import org.etsi.osl.hypo.clients.telemetry.client.GrafanaClient;
import org.etsi.osl.hypo.clients.telemetry.model.grafana.GrafanaResponse;
import org.etsi.osl.hypo.clients.telemetry.service.GrafanaService;
import org.etsi.osl.hypo.core.common.telemetry.CloudEventUpdateServiceTelemetry;
import org.etsi.osl.hypo.core.common.telemetry.UpdateTelemetryData;
import org.junit.jupiter.api.Test;
+0 −1
Original line number Diff line number Diff line
@@ -15,7 +15,6 @@ import io.quarkus.test.kubernetes.client.WithKubernetesTestServer;
import jakarta.inject.Inject;
import java.util.HashMap;
import java.util.Map;
import org.etsi.osl.hypo.clients.telemetry.service.KubernetesService;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;

+0 −4
Original line number Diff line number Diff line
@@ -26,10 +26,6 @@ import org.eclipse.microprofile.reactive.messaging.Metadata;
import org.etsi.osl.hypo.clients.telemetry.exceptions.JobNotFoundException;
import org.etsi.osl.hypo.clients.telemetry.model.grafana.GrafanaResponse;
import org.etsi.osl.hypo.clients.telemetry.model.telemetry.DashboardServiceMap;
import org.etsi.osl.hypo.clients.telemetry.service.EditSecretService;
import org.etsi.osl.hypo.clients.telemetry.service.GrafanaService;
import org.etsi.osl.hypo.clients.telemetry.service.KubernetesService;
import org.etsi.osl.hypo.clients.telemetry.service.TelemetryService;
import org.etsi.osl.hypo.core.common.Status;
import org.etsi.osl.hypo.core.common.telemetry.CloudEventDashboardData;
import org.etsi.osl.hypo.core.common.telemetry.CloudEventDeleteServiceData;
Loading