Thread remote config for default rate limit (#311)

Author: kriskowal

clients/index.js

@@ -456,6 +456,7 @@ function onRemoteConfigUpdate(changedKeys, forceUpdate) {
     self.updateCircuitShorts(hasChanged, forceUpdate);
     self.updateCircuitCodeNames(hasChanged, forceUpdate);
     self.updateRateLimitingEnabled(hasChanged, forceUpdate);
+    self.updateDefaultServiceRpsLimit(hasChanged, forceUpdate);
     self.updateTotalRpsLimit(hasChanged, forceUpdate);
     self.updateExemptServices(hasChanged, forceUpdate);
     self.updateRpsLimitForServiceName(hasChanged, forceUpdate);
@@ -636,6 +637,14 @@ ApplicationClients.prototype.updatePartialAffinityEnabled = function updateParti
     }
 };
 
+ApplicationClients.prototype.updateDefaultServiceRpsLimit = function updateDefaultServiceRpsLimit(hasChanged, forceUpdate) {
+    var self = this;
+    if (forceUpdate || hasChanged['ratelimiting.defaultServiceRpsLimit']) {
+        var limit = self.remoteConfig.get('ratelimiting.defaultServiceRpsLimit', 0);
+        self.serviceProxy.rateLimiter.updateDefaultServiceRpsLimit(limit);
+    }
+};
+
 ApplicationClients.prototype.updateTotalRpsLimit = function updateTotalRpsLimit(hasChanged, forceUpdate) {
     var self = this;
     if (forceUpdate || hasChanged['rateLimiting.totalRpsLimit']) {

rate_limiter.js

@@ -310,6 +310,17 @@ function updateServiceLimit(serviceName, limit) {
     }
 };
 
+RateLimiter.prototype.updateDefaultServiceRpsLimit =
+function updateDefaultServiceRpsLimit(limit) {
+    var self = this;
+
+    if (limit === 0) {
+        self.defaultServiceRpsLimit = DEFAULT_SERVICE_RPS_LIMIT;
+    } else {
+        self.defaultServiceRpsLimit = limit;
+    }
+};
+
 RateLimiter.prototype.updateTotalLimit =
 function updateTotalLimit(limit) {
     var self = this;