从zk中根据interface获取到providers信息 :param path: :param interface: :return:
(self, path, interface)
| 143 | return self._routing_with_wight(interface) |
| 144 | |
| 145 | def _get_providers_from_zk(self, path, interface): |
| 146 | """ |
| 147 | 从zk中根据interface获取到providers信息 |
| 148 | :param path: |
| 149 | :param interface: |
| 150 | :return: |
| 151 | """ |
| 152 | providers = self.zk.get_children(path, watch=self._watch_children) |
| 153 | providers = filter(lambda provider: provider['scheme'] == 'dubbo', map(parse_url, providers)) |
| 154 | if not providers: |
| 155 | raise RegisterException('no providers for interface {}'.format(interface)) |
| 156 | self._register_consumer(providers) |
| 157 | self.hosts[interface] = map(lambda provider: provider['host'], providers) |
| 158 | |
| 159 | def _get_configurators_from_zk(self, interface): |
| 160 | """ |
no test coverage detected