Skip to content

Commit

Permalink
Fix formating
Browse files Browse the repository at this point in the history
  • Loading branch information
alexshtin committed Aug 16, 2022
1 parent 4426702 commit 06d641f
Showing 1 changed file with 11 additions and 11 deletions.
22 changes: 11 additions & 11 deletions service/history/queueProcessorBase.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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(
Expand Down

0 comments on commit 06d641f

Please # to comment.