From 06d641f3b286e55d319aee20f5da69de16be6c1e Mon Sep 17 00:00:00 2001 From: Alex Shtin Date: Tue, 16 Aug 2022 14:08:36 -0700 Subject: [PATCH] Fix formating --- service/history/queueProcessorBase.go | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/service/history/queueProcessorBase.go b/service/history/queueProcessorBase.go index 3de81d506f3..05562af2423 100644 --- a/service/history/queueProcessorBase.go +++ b/service/history/queueProcessorBase.go @@ -57,17 +57,17 @@ type ( } queueProcessorBase struct { - clusterName string - shard shard.Context - timeSource clock.TimeSource - options *QueueProcessorOptions + clusterName string + shard shard.Context + timeSource clock.TimeSource + options *QueueProcessorOptions queueProcessor common.Daemon - logger log.Logger - metricsScope metrics.Scope - rateLimiter quotas.RateLimiter // Read rate limiter - ackMgr queueAckMgr - scheduler queues.Scheduler - rescheduler queues.Rescheduler + logger log.Logger + metricsScope metrics.Scope + rateLimiter quotas.RateLimiter // Read rate limiter + ackMgr queueAckMgr + scheduler queues.Scheduler + rescheduler queues.Rescheduler lastPollTime time.Time backoffTimerLock sync.Mutex @@ -110,7 +110,7 @@ func newQueueProcessorBase( notifyCh: make(chan struct{}, 1), shutdownCh: make(chan struct{}), logger: logger, - metricsScope: metricsScope, + metricsScope: metricsScope, ackMgr: queueAckMgr, lastPollTime: time.Time{}, readTaskRetrier: backoff.NewRetrier(