concurrentRuleEvalController holds a weighted semaphore which controls the concurrent evaluation of rules.
| 540 | |
| 541 | // concurrentRuleEvalController holds a weighted semaphore which controls the concurrent evaluation of rules. |
| 542 | type concurrentRuleEvalController struct { |
| 543 | sema *semaphore.Weighted |
| 544 | } |
| 545 | |
| 546 | func newRuleConcurrencyController(maxConcurrency int64) RuleConcurrencyController { |
| 547 | return &concurrentRuleEvalController{ |
nothing calls this directly
no outgoing calls
no test coverage detected