| 24 | } |
| 25 | |
| 26 | type flowLimiter struct { |
| 27 | limiterLock sync.Mutex |
| 28 | activeFlowsCounter uint64 |
| 29 | maxActiveFlows uint64 |
| 30 | unlimited bool |
| 31 | } |
| 32 | |
| 33 | func NewLimiter(maxActiveFlows uint64) Limiter { |
| 34 | flowLimiter := &flowLimiter{ |
nothing calls this directly
no outgoing calls
no test coverage detected