newEndpointCache returns a new, empty endpointCache.
(factory Factory, logger log.Logger, options endpointerOptions)
| 32 | |
| 33 | // newEndpointCache returns a new, empty endpointCache. |
| 34 | func newEndpointCache(factory Factory, logger log.Logger, options endpointerOptions) *endpointCache { |
| 35 | return &endpointCache{ |
| 36 | options: options, |
| 37 | factory: factory, |
| 38 | cache: map[string]endpointCloser{}, |
| 39 | logger: logger, |
| 40 | timeNow: time.Now, |
| 41 | } |
| 42 | } |
| 43 | |
| 44 | // Update should be invoked by clients with a complete set of current instance |
| 45 | // strings whenever that set changes. The cache manufactures new endpoints via |
no outgoing calls
searching dependent graphs…