| 37 | } |
| 38 | |
| 39 | type roundRobinLoadBalancer struct { |
| 40 | hosts atomic.Value |
| 41 | index uint32 |
| 42 | mu *sync.Mutex |
| 43 | } |
| 44 | |
| 45 | func (l *roundRobinLoadBalancer) OnEvent(event Event) { |
| 46 | l.mu.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected