From 60291dba0c232abd834b8af407d0ed1972102d43 Mon Sep 17 00:00:00 2001 From: csviri Date: Wed, 30 Nov 2022 16:40:34 +0100 Subject: [PATCH 1/2] feat: setting a higher default max onccurent request for client --- .../src/main/java/io/javaoperatorsdk/operator/Operator.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java index 8d7199f727..8935cb977a 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java @@ -5,6 +5,7 @@ import java.util.Set; import java.util.function.Consumer; +import io.fabric8.kubernetes.client.ConfigBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -20,6 +21,7 @@ @SuppressWarnings("rawtypes") public class Operator implements LifecycleAware { private static final Logger log = LoggerFactory.getLogger(Operator.class); + private static final int DEFAULT_MAX_CONCURRENT_REQUEST = 512; private final KubernetesClient kubernetesClient; private final ControllerManager controllerManager = new ControllerManager(); private final LeaderElectionManager leaderElectionManager = @@ -59,7 +61,9 @@ public Operator(KubernetesClient client, Consumer */ public Operator(KubernetesClient kubernetesClient, ConfigurationService configurationService) { this.kubernetesClient = - kubernetesClient != null ? kubernetesClient : new KubernetesClientBuilder().build(); + kubernetesClient != null ? kubernetesClient : new KubernetesClientBuilder() + .withConfig(new ConfigBuilder().withMaxConcurrentRequests(DEFAULT_MAX_CONCURRENT_REQUEST).build()) + .build(); ConfigurationServiceProvider.set(configurationService); configurationService.getLeaderElectionConfiguration() .ifPresent(c -> leaderElectionManager.init(c, this.kubernetesClient)); From d72325e048bfe5c884cd2a33c974fd9fd2051d0d Mon Sep 17 00:00:00 2001 From: csviri Date: Wed, 30 Nov 2022 16:46:17 +0100 Subject: [PATCH 2/2] format --- .../main/java/io/javaoperatorsdk/operator/Operator.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java index 8935cb977a..37a1a501d0 100644 --- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java +++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Operator.java @@ -5,11 +5,11 @@ import java.util.Set; import java.util.function.Consumer; -import io.fabric8.kubernetes.client.ConfigBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import io.fabric8.kubernetes.api.model.HasMetadata; +import io.fabric8.kubernetes.client.ConfigBuilder; import io.fabric8.kubernetes.client.KubernetesClient; import io.fabric8.kubernetes.client.KubernetesClientBuilder; import io.fabric8.kubernetes.client.Version; @@ -61,8 +61,10 @@ public Operator(KubernetesClient client, Consumer */ public Operator(KubernetesClient kubernetesClient, ConfigurationService configurationService) { this.kubernetesClient = - kubernetesClient != null ? kubernetesClient : new KubernetesClientBuilder() - .withConfig(new ConfigBuilder().withMaxConcurrentRequests(DEFAULT_MAX_CONCURRENT_REQUEST).build()) + kubernetesClient != null ? kubernetesClient + : new KubernetesClientBuilder() + .withConfig(new ConfigBuilder() + .withMaxConcurrentRequests(DEFAULT_MAX_CONCURRENT_REQUEST).build()) .build(); ConfigurationServiceProvider.set(configurationService); configurationService.getLeaderElectionConfiguration()