Method iteration

ring/client/pool.go:117–123

(_ context.Context)

}

func (p *Pool) iteration(_ context.Context) error {
	p.removeStaleClients()
	if p.cfg.HealthCheckEnabled {
		p.cleanUnhealthy()
	}
	return nil
}

func (p *Pool) fromCache(addr string) (*poolMember, bool) {
	p.RLock()