pkg/ratelimit: add SetConfig; pkg/settings/cresettings: remove WorkflowRegistrationQueueLimit

Author: jmank88

pkg/ratelimit/ratelimiter.go

@@ -67,3 +67,16 @@ func (rl *RateLimiter) AllowVerbose(sender string) (senderAllow bool, globalAllo
 
 	return senderLimiter.Allow(), rl.global.Allow()
 }
+
+func (rl *RateLimiter) SetConfig(config RateLimiterConfig) {
+	rl.mu.Lock()
+	defer rl.mu.Unlock()
+	rl.config = config
+	rl.global.SetLimit(rate.Limit(config.GlobalRPS))
+	rl.global.SetBurst(config.GlobalBurst)
+
+	for _, limiter := range rl.perSender {
+		limiter.SetLimit(rate.Limit(config.PerSenderRPS))
+		limiter.SetBurst(config.PerSenderBurst)
+	}
+}

pkg/settings/cresettings/defaults.json

@@ -1,6 +1,5 @@
 {
 	"WorkflowLimit": "200",
-	"WorkflowRegistrationQueueLimit": "20",
 	"WorkflowExecutionConcurrencyLimit": "50",
 	"WorkflowTriggerRateLimit": "200rps:200",
 	"GatewayUnauthenticatedRequestRateLimit": "100rps:-1",

pkg/settings/cresettings/defaults.toml

@@ -1,5 +1,4 @@
 WorkflowLimit = '200'
-WorkflowRegistrationQueueLimit = '20'
 WorkflowExecutionConcurrencyLimit = '50'
 WorkflowTriggerRateLimit = '200rps:200'
 GatewayUnauthenticatedRequestRateLimit = '100rps:-1'

pkg/settings/cresettings/settings.go

@@ -45,7 +45,6 @@ var Config Schema
 
 var Default = Schema{
 	WorkflowLimit:                               Int(200),
-	WorkflowRegistrationQueueLimit:              Int(20),
 	WorkflowExecutionConcurrencyLimit:           Int(50),
 	WorkflowTriggerRateLimit:                    Rate(200, 200),
 	GatewayUnauthenticatedRequestRateLimit:      Rate(rate.Every(time.Second/100), -1),
@@ -128,7 +127,6 @@ var Default = Schema{
 
 type Schema struct {
 	WorkflowLimit                               Setting[int] `unit:"{workflow}"`
-	WorkflowRegistrationQueueLimit              Setting[int] `unit:"{workflow}"`
 	WorkflowExecutionConcurrencyLimit           Setting[int] `unit:"{workflow}"`
 	WorkflowTriggerRateLimit                    Setting[config.Rate]
 	GatewayUnauthenticatedRequestRateLimit      Setting[config.Rate]