DefaultEndpointer implements an Endpointer interface. When created with NewEndpointer function, it automatically registers as a subscriber to events from the Instances and maintains a list of active Endpoints.
| 67 | // as a subscriber to events from the Instances and maintains a list |
| 68 | // of active Endpoints. |
| 69 | type DefaultEndpointer struct { |
| 70 | cache *endpointCache |
| 71 | instancer Instancer |
| 72 | ch chan Event |
| 73 | } |
| 74 | |
| 75 | func (de *DefaultEndpointer) receive() { |
| 76 | for event := range de.ch { |
nothing calls this directly
no outgoing calls
no test coverage detected