28
requestPriorityFn RequestPriorityFn,
29
prioritiesOrdered []int,
31
>
rateLimiters := make(map[int]RequestRateLimiter)
32
>
for _, priority := range prioritiesOrdered {
33
>
if priority == OperatorPriority {
34
>
rateLimiters[priority] = NewRequestRateLimiterAdapter(
35
>
NewDynamicRateLimiter(
36
>
NewOperatorRateBurst(rateBurstFn, operatorRPSRatio),
37
>
defaultRefreshInterval,
38
>
),
39
>
)
40
>
} else {
41
>
rateLimiters[priority] = NewRequestRateLimiterAdapter(
42
>
NewDynamicRateLimiter(
43
>
rateBurstFn,
44
>
defaultRefreshInterval,
45
>
),
46
>
)
47
>
}
48
}
50
}
51