kafka-ui/kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/KafkaCluster.java

package com.provectus.kafka.ui.model;

import com.provectus.kafka.ui.config.ClustersProperties;
import com.provectus.kafka.ui.connect.api.KafkaConnectClientApi;
import com.provectus.kafka.ui.emitter.PollingSettings;
import com.provectus.kafka.ui.service.ksql.KsqlApiClient;
import com.provectus.kafka.ui.service.masking.DataMasking;
import com.provectus.kafka.ui.service.metrics.scrape.MetricsScrapping;
import com.provectus.kafka.ui.sr.api.KafkaSrClientApi;
import com.provectus.kafka.ui.util.ReactiveFailover;
import java.util.Map;
import java.util.Properties;
import lombok.AccessLevel;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import prometheus.query.api.PrometheusClientApi;

@Data
@Builder(toBuilder = true)
@AllArgsConstructor(access = AccessLevel.PRIVATE)
public class KafkaCluster {
  private final ClustersProperties.Cluster originalProperties;

  private final String name;
  private final String version;
  private final String bootstrapServers;
  private final Properties properties;
  private final boolean readOnly;
  private final boolean exposeMetricsViaPrometheusEndpoint;
  private final DataMasking masking;
  private final PollingSettings pollingSettings;
  private final ReactiveFailover<KafkaSrClientApi> schemaRegistryClient;
  private final Map<String, ReactiveFailover<KafkaConnectClientApi>> connectsClients;
  private final ReactiveFailover<KsqlApiClient> ksqlClient;
  private final MetricsScrapping metricsScrapping;
  private final ReactiveFailover<PrometheusClientApi> prometheusStorageClient;
}