(ctx context.Context)
| 75 | } |
| 76 | |
| 77 | func (p *Pool) iteration(ctx context.Context) error { |
| 78 | p.removeStaleClients() |
| 79 | if p.cfg.HealthCheckEnabled { |
| 80 | p.cleanUnhealthy() |
| 81 | } |
| 82 | return nil |
| 83 | } |
| 84 | |
| 85 | func (p *Pool) fromCache(addr string) (PoolClient, bool) { |
| 86 | p.RLock() |
nothing calls this directly
no test coverage detected