Pool holds a cache of grpc_health_v1 clients.
| 42 | |
| 43 | // Pool holds a cache of grpc_health_v1 clients. |
| 44 | type Pool struct { |
| 45 | services.Service |
| 46 | |
| 47 | cfg PoolConfig |
| 48 | discovery PoolServiceDiscovery |
| 49 | factory PoolFactory |
| 50 | logger log.Logger |
| 51 | clientName string |
| 52 | |
| 53 | sync.RWMutex |
| 54 | clients map[string]PoolClient |
| 55 | |
| 56 | clientsMetric prometheus.Gauge |
| 57 | } |
| 58 | |
| 59 | // NewPool creates a new Pool. |
| 60 | func NewPool(clientName string, cfg PoolConfig, discovery PoolServiceDiscovery, factory PoolFactory, clientsMetric prometheus.Gauge, logger log.Logger) *Pool { |
nothing calls this directly
no outgoing calls
no test coverage detected