:param interface: 接口名，例如：com.qianmi.pc.es.api.EsProductQueryProvider :param version: 接口的版本号，例如：1.0.0，默认为1.0.0 :param dubbo_version: dubbo的版本号，默认为2.4.10 :param zk_register: zookeeper注册中心管理端，参见类：ZkRegister :param host: 远程主机地址，用于绕过zookeeper进行直连，例如：172.21.4.98:20
(self, interface, version='1.0.0', dubbo_version='2.4.10', zk_register=None, host=None)
| 22 | """ |
| 23 | |
| 24 | def __init__(self, interface, version='1.0.0', dubbo_version='2.4.10', zk_register=None, host=None): |
| 25 | """ |
| 26 | :param interface: 接口名，例如：com.qianmi.pc.es.api.EsProductQueryProvider |
| 27 | :param version: 接口的版本号，例如：1.0.0，默认为1.0.0 |
| 28 | :param dubbo_version: dubbo的版本号，默认为2.4.10 |
| 29 | :param zk_register: zookeeper注册中心管理端，参见类：ZkRegister |
| 30 | :param host: 远程主机地址，用于绕过zookeeper进行直连，例如：172.21.4.98:20882 |
| 31 | """ |
| 32 | if not zk_register and not host: |
| 33 | raise RegisterException('zk_register和host至少需要填入一个') |
| 34 | |
| 35 | logger.debug('Created client, interface={}, version={}'.format(interface, version)) |
| 36 | |
| 37 | self.__interface = interface |
| 38 | self.__version = version |
| 39 | self.__dubbo_version = dubbo_version |
| 40 | |
| 41 | self.__zk_register = zk_register |
| 42 | self.__host = host |
| 43 | |
| 44 | def call(self, method, args=(), timeout=None): |
| 45 | """ |
nothing calls this directly
no test coverage detected