Skip to content

Commit

Permalink
BE: Chore: Cleanup model package
Browse files Browse the repository at this point in the history
  • Loading branch information
wernerdv committed Jan 11, 2025
1 parent 8ddda3d commit 9931200
Show file tree
Hide file tree
Showing 17 changed files with 5 additions and 99 deletions.
1 change: 0 additions & 1 deletion api/src/main/java/io/kafbat/ui/model/BrokerMetrics.java
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package io.kafbat.ui.model;

import io.kafbat.ui.model.MetricDTO;
import java.util.List;
import lombok.Builder;
import lombok.Data;
Expand Down
12 changes: 2 additions & 10 deletions api/src/main/java/io/kafbat/ui/model/CleanupPolicy.java
Original file line number Diff line number Diff line change
Expand Up @@ -20,18 +20,10 @@ public enum CleanupPolicy {
this.policies = policies;
}

public String getPolicy() {
return policies.get(0);
}

public static CleanupPolicy fromString(String string) {
return Arrays.stream(CleanupPolicy.values())
.filter(v ->
v.policies.stream().anyMatch(
s -> s.equals(string.replace(" ", "")
)
)
).findFirst()
.filter(v -> v.policies.stream().anyMatch(s -> s.equals(string.replace(" ", ""))))
.findFirst()
.orElse(UNKNOWN);
}
}
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package io.kafbat.ui.model;


import java.util.List;
import lombok.Builder;
import lombok.Data;
Expand All @@ -17,13 +16,13 @@ public class InternalBrokerConfig {
private final List<ConfigEntry.ConfigSynonym> synonyms;

public static InternalBrokerConfig from(ConfigEntry configEntry, boolean readOnlyCluster) {
InternalBrokerConfig.InternalBrokerConfigBuilder builder = InternalBrokerConfig.builder()
return InternalBrokerConfig.builder()
.name(configEntry.name())
.value(configEntry.value())
.source(configEntry.source())
.isReadOnly(readOnlyCluster || configEntry.isReadOnly())
.isSensitive(configEntry.isSensitive())
.synonyms(configEntry.synonyms());
return builder.build();
.synonyms(configEntry.synonyms())
.build();
}
}
Original file line number Diff line number Diff line change
@@ -1,15 +1,12 @@
package io.kafbat.ui.model;

import io.kafbat.ui.model.MetricDTO;
import io.kafbat.ui.model.ServerStatusDTO;
import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
import javax.annotation.Nullable;
import lombok.Builder;
import lombok.Data;


@Data
@Builder(toBuilder = true)
public class InternalClusterMetrics {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,9 +1,6 @@
package io.kafbat.ui.model;

import com.google.common.base.Throwables;
import io.kafbat.ui.model.BrokerDiskUsageDTO;
import io.kafbat.ui.model.MetricsCollectionErrorDTO;
import io.kafbat.ui.model.ServerStatusDTO;
import java.math.BigDecimal;
import java.util.List;
import java.util.Optional;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,5 +20,4 @@ public class InternalPartition {
private final Long segmentSize;
private final Integer segmentCount;


}
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@
import lombok.Value;
import org.apache.kafka.common.TopicPartition;


public class InternalPartitionsOffsets {

@Value
Expand Down
13 changes: 0 additions & 13 deletions api/src/main/java/io/kafbat/ui/model/InternalSegmentSizeDto.java

This file was deleted.

3 changes: 0 additions & 3 deletions api/src/main/java/io/kafbat/ui/model/InternalTopic.java
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package io.kafbat.ui.model;

import io.kafbat.ui.config.ClustersProperties;
import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
Expand All @@ -16,8 +15,6 @@
@Builder(toBuilder = true)
public class InternalTopic {

ClustersProperties clustersProperties;

// from TopicDescription
private final String name;
private final boolean internal;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@
import lombok.Data;
import org.apache.kafka.clients.admin.ConfigEntry;


@Data
@Builder
public class InternalTopicConfig {
Expand Down
1 change: 0 additions & 1 deletion api/src/main/java/io/kafbat/ui/model/Metrics.java
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@
import lombok.Builder;
import lombok.Value;


@Builder
@Value
public class Metrics {
Expand Down
1 change: 0 additions & 1 deletion api/src/main/java/io/kafbat/ui/model/Statistics.java
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package io.kafbat.ui.model;

import io.kafbat.ui.model.ServerStatusDTO;
import io.kafbat.ui.service.ReactiveAdminClient;
import java.util.List;
import java.util.Map;
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

0 comments on commit 9931200

Please sign in to comment.