✨ add new config params

Transfa · Jul 6, 2024 · ae03698 · ae03698
1 parent 87698c1
commit ae03698
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/sendhooks/adapter/adapter.go b/sendhooks/adapter/adapter.go
@@ -41,6 +41,8 @@ type Configuration struct {
 	Redis                RedisConfig `json:"redis"`
 	SecretHashHeaderName string      `json:"secretHashHeaderName"`
 	Broker               string      `json:"broker"`
+	NumWorkers           int         `json:"numWorkers"`
+	ChannelSize          int         `json:"channelSize"`
 }
 
 // Adapter defines methods for interacting with different queue systems.

diff --git a/sendhooks/adapter/redis_adapter/redis_adapter.go b/sendhooks/adapter/redis_adapter/redis_adapter.go
@@ -71,7 +71,7 @@ func (r *RedisAdapter) Connect() error {
 		Password:  redisPassword,
 		DB:        redisDBInt,
 		TLSConfig: tlsConfig,
-		PoolSize:  50,
+		PoolSize:  r.config.NumWorkers,
 	})
 
 	return nil

diff --git a/sendhooks/main.go b/sendhooks/main.go
@@ -39,8 +39,8 @@ func main() {
 	}
 
 	// Define the size of the channel and the number of workers
-	webhookQueue := make(chan adapter.WebhookPayload, 1000)
-	numWorkers := 50
+	webhookQueue := make(chan adapter.WebhookPayload, conf.ChannelSize)
+	numWorkers := conf.NumWorkers
 
 	// Start the worker pool
 	var wg sync.WaitGroup