Skip to content

Commit 79e3910

Browse files
authored
BE: Chore: Cleanup model package (#763)
1 parent c1f4424 commit 79e3910

17 files changed

+5
-99
lines changed

api/src/main/java/io/kafbat/ui/model/BrokerMetrics.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.kafbat.ui.model;
22

3-
import io.kafbat.ui.model.MetricDTO;
43
import java.util.List;
54
import lombok.Builder;
65
import lombok.Data;

api/src/main/java/io/kafbat/ui/model/CleanupPolicy.java

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -20,18 +20,10 @@ public enum CleanupPolicy {
2020
this.policies = policies;
2121
}
2222

23-
public String getPolicy() {
24-
return policies.get(0);
25-
}
26-
2723
public static CleanupPolicy fromString(String string) {
2824
return Arrays.stream(CleanupPolicy.values())
29-
.filter(v ->
30-
v.policies.stream().anyMatch(
31-
s -> s.equals(string.replace(" ", "")
32-
)
33-
)
34-
).findFirst()
25+
.filter(v -> v.policies.stream().anyMatch(s -> s.equals(string.replace(" ", ""))))
26+
.findFirst()
3527
.orElse(UNKNOWN);
3628
}
3729
}

api/src/main/java/io/kafbat/ui/model/InternalBrokerConfig.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.kafbat.ui.model;
22

3-
43
import java.util.List;
54
import lombok.Builder;
65
import lombok.Data;
@@ -17,13 +16,13 @@ public class InternalBrokerConfig {
1716
private final List<ConfigEntry.ConfigSynonym> synonyms;
1817

1918
public static InternalBrokerConfig from(ConfigEntry configEntry, boolean readOnlyCluster) {
20-
InternalBrokerConfig.InternalBrokerConfigBuilder builder = InternalBrokerConfig.builder()
19+
return InternalBrokerConfig.builder()
2120
.name(configEntry.name())
2221
.value(configEntry.value())
2322
.source(configEntry.source())
2423
.isReadOnly(readOnlyCluster || configEntry.isReadOnly())
2524
.isSensitive(configEntry.isSensitive())
26-
.synonyms(configEntry.synonyms());
27-
return builder.build();
25+
.synonyms(configEntry.synonyms())
26+
.build();
2827
}
2928
}

api/src/main/java/io/kafbat/ui/model/InternalClusterMetrics.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,12 @@
11
package io.kafbat.ui.model;
22

3-
import io.kafbat.ui.model.MetricDTO;
4-
import io.kafbat.ui.model.ServerStatusDTO;
53
import java.math.BigDecimal;
64
import java.util.List;
75
import java.util.Map;
86
import javax.annotation.Nullable;
97
import lombok.Builder;
108
import lombok.Data;
119

12-
1310
@Data
1411
@Builder(toBuilder = true)
1512
public class InternalClusterMetrics {

api/src/main/java/io/kafbat/ui/model/InternalClusterState.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,6 @@
11
package io.kafbat.ui.model;
22

33
import com.google.common.base.Throwables;
4-
import io.kafbat.ui.model.BrokerDiskUsageDTO;
5-
import io.kafbat.ui.model.MetricsCollectionErrorDTO;
6-
import io.kafbat.ui.model.ServerStatusDTO;
74
import java.math.BigDecimal;
85
import java.util.List;
96
import java.util.Optional;

api/src/main/java/io/kafbat/ui/model/InternalPartition.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,5 +20,4 @@ public class InternalPartition {
2020
private final Long segmentSize;
2121
private final Integer segmentCount;
2222

23-
2423
}

api/src/main/java/io/kafbat/ui/model/InternalPartitionsOffsets.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
import lombok.Value;
88
import org.apache.kafka.common.TopicPartition;
99

10-
1110
public class InternalPartitionsOffsets {
1211

1312
@Value

api/src/main/java/io/kafbat/ui/model/InternalSegmentSizeDto.java

Lines changed: 0 additions & 13 deletions
This file was deleted.

api/src/main/java/io/kafbat/ui/model/InternalTopic.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.kafbat.ui.model;
22

3-
import io.kafbat.ui.config.ClustersProperties;
43
import java.math.BigDecimal;
54
import java.util.List;
65
import java.util.Map;
@@ -16,8 +15,6 @@
1615
@Builder(toBuilder = true)
1716
public class InternalTopic {
1817

19-
ClustersProperties clustersProperties;
20-
2118
// from TopicDescription
2219
private final String name;
2320
private final boolean internal;

api/src/main/java/io/kafbat/ui/model/InternalTopicConfig.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
import lombok.Data;
66
import org.apache.kafka.clients.admin.ConfigEntry;
77

8-
98
@Data
109
@Builder
1110
public class InternalTopicConfig {

api/src/main/java/io/kafbat/ui/model/Metrics.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import lombok.Builder;
1212
import lombok.Value;
1313

14-
1514
@Builder
1615
@Value
1716
public class Metrics {

api/src/main/java/io/kafbat/ui/model/Statistics.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.kafbat.ui.model;
22

3-
import io.kafbat.ui.model.ServerStatusDTO;
43
import io.kafbat.ui.service.ReactiveAdminClient;
54
import java.util.List;
65
import java.util.Map;

api/src/main/java/io/kafbat/ui/model/schemaregistry/ErrorResponse.java

Lines changed: 0 additions & 14 deletions
This file was deleted.

api/src/main/java/io/kafbat/ui/model/schemaregistry/InternalCompatibilityCheck.java

Lines changed: 0 additions & 10 deletions
This file was deleted.

api/src/main/java/io/kafbat/ui/model/schemaregistry/InternalCompatibilityLevel.java

Lines changed: 0 additions & 8 deletions
This file was deleted.

api/src/main/java/io/kafbat/ui/model/schemaregistry/InternalNewSchema.java

Lines changed: 0 additions & 17 deletions
This file was deleted.

api/src/main/java/io/kafbat/ui/model/schemaregistry/SubjectIdResponse.java

Lines changed: 0 additions & 8 deletions
This file was deleted.

0 commit comments

Comments
 (0)