From 41381336b1b6fbb55ba81902737ee5e3d2ffcaeb Mon Sep 17 00:00:00 2001 From: Vincent Bernat Date: Thu, 6 Nov 2025 08:10:50 +0100 Subject: [PATCH] outlet/kafka: rename startScaler to runScaler There is not stopScaler and it's not like we can start several of them. --- outlet/kafka/root.go | 2 +- outlet/kafka/scaler.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/outlet/kafka/root.go b/outlet/kafka/root.go index 2bfbf94f..b968023c 100644 --- a/outlet/kafka/root.go +++ b/outlet/kafka/root.go @@ -135,7 +135,7 @@ func (c *realComponent) Start() error { // StartWorkers will start the initial workers. This should only be called once. func (c *realComponent) StartWorkers(workerBuilder WorkerBuilderFunc) error { - c.workerRequestChan = c.startScaler() + c.workerRequestChan = c.runScaler() c.workerBuilder = workerBuilder for range c.config.MinWorkers { if err := c.startOneWorker(); err != nil { diff --git a/outlet/kafka/scaler.go b/outlet/kafka/scaler.go index 7c531031..f96175ec 100644 --- a/outlet/kafka/scaler.go +++ b/outlet/kafka/scaler.go @@ -76,8 +76,8 @@ func (s *scalerState) nextWorkerCount(request ScaleRequest, minWorkers, maxWorke return next } -// startScaler starts the automatic scaling loop -func (c *realComponent) startScaler() chan<- ScaleRequest { +// runScaler starts the automatic scaling loop +func (c *realComponent) runScaler() chan<- ScaleRequest { ch := make(chan ScaleRequest, c.config.MaxWorkers) down := rate.Sometimes{Interval: c.config.WorkerDecreaseRateLimit} up := rate.Sometimes{Interval: c.config.WorkerIncreaseRateLimit}