Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Clean some TLS sidecar leftovers from the Entity Operator clases #10085

Merged
merged 1 commit into from
May 9, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -62,13 +62,6 @@ public class EntityOperator extends AbstractModel {
protected static final String TLS_SIDECAR_CA_CERTS_VOLUME_NAME = "cluster-ca-certs";
protected static final String TLS_SIDECAR_CA_CERTS_VOLUME_MOUNT = "/etc/tls-sidecar/cluster-ca-certs/";

// Volume name of the temporary volume used by the TLS sidecar container
// Because the container shares the pod with other containers, it needs to have unique name
/* test */ static final String TLS_SIDECAR_TMP_DIRECTORY_DEFAULT_VOLUME_NAME = "strimzi-tls-sidecar-tmp";

// Entity Operator configuration keys
/* test */ static final String ENV_VAR_ZOOKEEPER_CONNECT = "STRIMZI_ZOOKEEPER_CONNECT";

protected static final String CO_ENV_VAR_CUSTOM_ENTITY_OPERATOR_POD_LABELS = "STRIMZI_CUSTOM_ENTITY_OPERATOR_LABELS";

/**
Expand Down Expand Up @@ -105,20 +98,18 @@ protected EntityOperator(Reconciliation reconciliation, HasMetadata resource, Sh

this.zookeeperConnect = KafkaResources.zookeeperServiceName(cluster) + ":" + ZookeeperCluster.CLIENT_TLS_PORT;
}

/**
* Create an Entity Operator from given desired resource
*
* @param reconciliation The reconciliation
* @param kafkaAssembly desired resource with cluster configuration containing the Entity Operator one
* @param versions The versions.
* @param sharedEnvironmentProvider Shared environment provider.
* @param reconciliation The reconciliation marker
* @param kafkaAssembly Desired resource with cluster configuration containing the Entity Operator one
* @param sharedEnvironmentProvider Shared environment provider
*
* @return Entity Operator instance, null if not configured in the ConfigMap
*/
public static EntityOperator fromCrd(Reconciliation reconciliation,
Kafka kafkaAssembly,
KafkaVersion.Lookup versions,
SharedEnvironmentProvider sharedEnvironmentProvider) {
EntityOperatorSpec entityOperatorSpec = kafkaAssembly.getSpec().getEntityOperator();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
import io.strimzi.operator.cluster.model.ClusterCa;
import io.strimzi.operator.cluster.model.EntityOperator;
import io.strimzi.operator.cluster.model.ImagePullPolicy;
import io.strimzi.operator.cluster.model.KafkaVersion;
import io.strimzi.operator.cluster.operator.resource.ResourceOperatorSupplier;
import io.strimzi.operator.cluster.operator.resource.kubernetes.ConfigMapOperator;
import io.strimzi.operator.cluster.operator.resource.kubernetes.DeploymentOperator;
Expand Down Expand Up @@ -69,20 +68,18 @@ public class EntityOperatorReconciler {
* @param config Cluster Operator Configuration
* @param supplier Supplier with Kubernetes Resource Operators
* @param kafkaAssembly The Kafka custom resource
* @param versions The supported Kafka versions
* @param clusterCa The Cluster CA instance
*/
public EntityOperatorReconciler(
Reconciliation reconciliation,
ClusterOperatorConfig config,
ResourceOperatorSupplier supplier,
Kafka kafkaAssembly,
KafkaVersion.Lookup versions,
ClusterCa clusterCa
) {
this.reconciliation = reconciliation;
this.operationTimeoutMs = config.getOperationTimeoutMs();
this.entityOperator = EntityOperator.fromCrd(reconciliation, kafkaAssembly, versions, supplier.sharedEnvironmentProvider);
this.entityOperator = EntityOperator.fromCrd(reconciliation, kafkaAssembly, supplier.sharedEnvironmentProvider);
this.clusterCa = clusterCa;
this.maintenanceWindows = kafkaAssembly.getSpec().getMaintenanceTimeWindows();
this.isNetworkPolicyGeneration = config.isNetworkPolicyGeneration();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -799,7 +799,6 @@ EntityOperatorReconciler entityOperatorReconciler() {
config,
supplier,
kafkaAssembly,
versions,
clusterCa
);
}
Expand Down
Loading
Loading