Remove rate limit divisor

Author: davidkyle

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/RequestExecutor.java

@@ -21,8 +21,6 @@ public interface RequestExecutor {
 
     void shutdown();
 
-    void updateRateLimitDivisor(int newDivisor);
-
     boolean isShutdown();
 
     boolean isTerminated();

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/sender/HttpRequestSender.java

@@ -113,10 +113,6 @@ public void start() {
         }
     }
 
-    public void updateRateLimitDivisor(int rateLimitDivisor) {
-        service.updateRateLimitDivisor(rateLimitDivisor);
-    }
-
     private void waitForStartToComplete() {
         try {
             if (startCompleted.await(START_COMPLETED_WAIT_TIME.getSeconds(), TimeUnit.SECONDS) == false) {

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/sender/RequestExecutorService.java

@@ -162,19 +162,6 @@ public int queueSize() {
         return rateLimitGroupings.values().stream().mapToInt(RateLimitingEndpointHandler::queueSize).sum();
     }
 
-    @Override
-    public void updateRateLimitDivisor(int numResponsibleNodes) {
-        // in the unlikely case where we get an invalid value, we'll just ignore it
-        if (numResponsibleNodes <= 0) {
-            return;
-        }
-
-        rateLimitDivisor.set(numResponsibleNodes);
-        for (var rateLimitingEndpointHandler : rateLimitGroupings.values()) {
-            rateLimitingEndpointHandler.updateTokensPerTimeUnit(rateLimitDivisor.get());
-        }
-    }
-
     /**
      * Begin servicing tasks.
      * <p>
@@ -393,22 +380,12 @@ static class RateLimitingEndpointHandler {
                 rateLimitSettings.requestsPerTimeUnit(),
                 rateLimitSettings.timeUnit()
             );
-
-            this.updateTokensPerTimeUnit(rateLimitDivisor);
         }
 
         public void init() {
             requestExecutorServiceSettings.registerQueueCapacityCallback(id, this::onCapacityChange);
         }
 
-        /**
-         * @param divisor - divisor to divide the initial requests per time unit by
-         */
-        private synchronized void updateTokensPerTimeUnit(Integer divisor) {
-            double updatedTokensPerTimeUnit = (double) originalRequestsPerTimeUnit / divisor;
-            rateLimiter.setRate(ACCUMULATED_TOKENS_LIMIT, updatedTokensPerTimeUnit, rateLimitSettings.timeUnit());
-        }
-
         public String id() {
             return id;
         }

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/external/http/sender/Sender.java

@@ -27,8 +27,6 @@ void send(
         ActionListener<InferenceServiceResults> listener
     );
 
-    void updateRateLimitDivisor(int rateLimitDivisor);
-
     void sendWithoutQueuing(
         Logger logger,
         Request request,

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/amazonbedrock/client/AmazonBedrockRequestSender.java

@@ -97,11 +97,6 @@ protected AmazonBedrockRequestSender(
         this.startCompleted = Objects.requireNonNull(startCompleted);
     }
 
-    @Override
-    public void updateRateLimitDivisor(int rateLimitDivisor) {
-        executorService.updateRateLimitDivisor(rateLimitDivisor);
-    }
-
     @Override
     public void start() {
         if (started.compareAndSet(false, true)) {

x-pack/plugin/inference/src/test/java/org/elasticsearch/xpack/inference/services/amazonbedrock/client/AmazonBedrockMockRequestSender.java

@@ -70,11 +70,6 @@ public void start() {
         // do nothing
     }
 
-    @Override
-    public void updateRateLimitDivisor(int rateLimitDivisor) {
-        // do nothing
-    }
-
     @Override
     public void send(
         RequestManager requestCreator,