67
}
68
70
>
shardCounter: shardCounter,
71
>
totalNumShards: totalNumShards,
72
>
updateAppliedCallback: updateAppliedCallback,
73
>
subscription: shardCounter.SubscribeShardCount(),
74
>
}
75
>
76
>
scaler.shardCount.Store(shardCountNotSet)
77
>
scaler.shutdownWG.Go(func() {
78
>
79
>
for count := range scaler.subscription.ShardCount() {
80
>
scaler.shardCount.Store(int64(count))
81
>
if scaler.updateAppliedCallback != nil {
82
scaler.updateAppliedCallback <- struct{}{}
83
}