|
9 | 9 | import org.slf4j.LoggerFactory;
|
10 | 10 |
|
11 | 11 | import io.fabric8.kubernetes.api.model.HasMetadata;
|
| 12 | +import io.fabric8.kubernetes.client.ConfigBuilder; |
12 | 13 | import io.fabric8.kubernetes.client.KubernetesClient;
|
13 | 14 | import io.fabric8.kubernetes.client.KubernetesClientBuilder;
|
14 | 15 | import io.fabric8.kubernetes.client.Version;
|
|
20 | 21 | @SuppressWarnings("rawtypes")
|
21 | 22 | public class Operator implements LifecycleAware {
|
22 | 23 | private static final Logger log = LoggerFactory.getLogger(Operator.class);
|
| 24 | + private static final int DEFAULT_MAX_CONCURRENT_REQUEST = 512; |
23 | 25 | private final KubernetesClient kubernetesClient;
|
24 | 26 | private final ControllerManager controllerManager = new ControllerManager();
|
25 | 27 | private final LeaderElectionManager leaderElectionManager =
|
@@ -59,7 +61,11 @@ public Operator(KubernetesClient client, Consumer<ConfigurationServiceOverrider>
|
59 | 61 | */
|
60 | 62 | public Operator(KubernetesClient kubernetesClient, ConfigurationService configurationService) {
|
61 | 63 | this.kubernetesClient =
|
62 |
| - kubernetesClient != null ? kubernetesClient : new KubernetesClientBuilder().build(); |
| 64 | + kubernetesClient != null ? kubernetesClient |
| 65 | + : new KubernetesClientBuilder() |
| 66 | + .withConfig(new ConfigBuilder() |
| 67 | + .withMaxConcurrentRequests(DEFAULT_MAX_CONCURRENT_REQUEST).build()) |
| 68 | + .build(); |
63 | 69 | ConfigurationServiceProvider.set(configurationService);
|
64 | 70 | configurationService.getLeaderElectionConfiguration()
|
65 | 71 | .ifPresent(c -> leaderElectionManager.init(c, this.kubernetesClient));
|
|
0 commit comments