0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

wip

Browse source
This commit is contained in:
iliax 2023-07-11 14:54:52 +04:00
parent 7c3fb18b79
commit 12c6552433
2 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
kafka-ui-api/src/test/java/com/provectus/kafka/ui/service/metrics/scrape/inferred/InferredMetricsScraperTest.java
View file

@ -1,5 +1,7 @@
package com.provectus.kafka.ui.service.metrics.scrape.inferred; package com.provectus.kafka.ui.service.metrics.scrape.inferred;
import static com.provectus.kafka.ui.model.InternalLogDirStats.LogDirSpaceStats;
import static com.provectus.kafka.ui.model.InternalLogDirStats.SegmentStats;
import static com.provectus.kafka.ui.service.metrics.scrape.ScrapedClusterState.ConsumerGroupState; import static com.provectus.kafka.ui.service.metrics.scrape.ScrapedClusterState.ConsumerGroupState;
import static com.provectus.kafka.ui.service.metrics.scrape.ScrapedClusterState.NodeState; import static com.provectus.kafka.ui.service.metrics.scrape.ScrapedClusterState.NodeState;
import static com.provectus.kafka.ui.service.metrics.scrape.ScrapedClusterState.TopicState; import static com.provectus.kafka.ui.service.metrics.scrape.ScrapedClusterState.TopicState;
@ -29,8 +31,8 @@ class InferredMetricsScraperTest {
@Test @Test
void allExpectedMetricsScraped() { void allExpectedMetricsScraped() {
var segmentStats = new InternalLogDirStats.SegmentStats(1234L, 3); var segmentStats = new SegmentStats(1234L, 3);
var logDirStats = new InternalLogDirStats.LogDirSpaceStats(234L, 345L, Map.of(), Map.of()); var logDirStats = new LogDirSpaceStats(234L, 345L, Map.of(), Map.of());
Node node1 = new Node(1, "node1", 9092); Node node1 = new Node(1, "node1", 9092);
Node node2 = new Node(2, "node2", 9092); Node node2 = new Node(2, "node2", 9092);

1
kafka-ui-api/src/test/java/com/provectus/kafka/ui/service/metrics/scrape/prometheus/PrometheusMetricsRetrieverTest.java
View file

@ -13,7 +13,6 @@ import okhttp3.mockwebserver.MockWebServer;
import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.test.StepVerifier; import reactor.test.StepVerifier;
class PrometheusMetricsRetrieverTest { class PrometheusMetricsRetrieverTest {