90
91
// Start registers dynamic config subscriptions and computes the initial rate limits.
93
>
r.mu.Lock()
94
>
defer r.mu.Unlock()
95
>
96
>
// Overall system rate limit will be the min of the two configs that are partition wise times the number of partitons.
97
>
var cancel func()
98
>
r.adminNsRate, cancel = r.config.AdminNamespaceToPartitionRateSub(r.setAdminNsRate)
99
>
r.cancels = append(r.cancels, cancel)
100
>
r.adminTqRate, cancel = r.config.AdminNamespaceTaskQueueToPartitionRateSub(r.setAdminTqRate)
101
>
r.cancels = append(r.cancels, cancel)
102
>
r.numReadPartitions, cancel = r.config.NumReadPartitionsSub(r.setNumReadPartitions)
103
>
r.cancels = append(r.cancels, cancel)
104
>
r.computeEffectiveRPSAndSourceLocked()
105
>
}
106
107
func (r *rateLimitManager) setAdminNsRate(rps float64) {