76
getWritePartitions dynamicconfig.IntPropertyFn,
77
emitGaugeMetrics dynamicconfig.BoolPropertyFn,
79
>
return &scaleManager{
80
>
partition: partition,
81
>
logger: log.With(logger, tag.ComponentPartitionScaler),
82
>
metricsHandler: metricsHandler,
83
>
userDataManager: userDataManager,
84
>
matchingClient: matchingClient,
85
>
partitionScaler: partitionScaler,
86
>
batchSize: int64(settings().BatchSize),
87
>
settings: settings,
88
>
getWritePartitions: getWritePartitions,
89
>
emitGaugeMetrics: emitGaugeMetrics,
90
>
timeSource: timeSource,
91
>
background: goro.NewHandle(baseCtx),
92
>
wakeup: make(chan struct{}, 1),
93
>
}
94
>
}
95
96
func (sm *scaleManager) Stop() {