mirror of
https://gitee.com/milvus-io/milvus.git
synced 2026-01-07 11:21:52 +08:00
remove dummy code
This commit is contained in:
parent
dd38d54d64
commit
7d1590c691
@ -152,59 +152,3 @@ class ConnectionMgr:
|
||||
if url is None:
|
||||
return self.on_nonexisted_meta(name)
|
||||
return self.on_unregister_meta(name, url)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
class Conn:
|
||||
def __init__(self, state):
|
||||
self.state = state
|
||||
|
||||
def connect(self, uri):
|
||||
return self.state
|
||||
|
||||
def connected(self):
|
||||
return self.state
|
||||
|
||||
fail_conn = Conn(False)
|
||||
success_conn = Conn(True)
|
||||
|
||||
class Retry:
|
||||
def __init__(self):
|
||||
self.times = 0
|
||||
|
||||
def __call__(self, conn):
|
||||
self.times += 1
|
||||
print('Retrying {}'.format(self.times))
|
||||
|
||||
|
||||
retry_obj = Retry()
|
||||
c = Connection('client', uri='', on_retry_func=retry_obj)
|
||||
|
||||
def f():
|
||||
print('ffffffff')
|
||||
|
||||
# c.conn = fail_conn
|
||||
# m = c.connect(func=f)
|
||||
# m()
|
||||
|
||||
c.conn = success_conn
|
||||
m = c.connect(func=f)
|
||||
m()
|
||||
|
||||
mgr = ConnectionMgr()
|
||||
mgr.register('pod1', '111')
|
||||
mgr.register('pod2', '222')
|
||||
mgr.register('pod2', '222')
|
||||
mgr.register('pod2', 'tcp://127.0.0.1:19530')
|
||||
|
||||
pod3 = mgr.conn('pod3')
|
||||
print(pod3)
|
||||
|
||||
pod2 = mgr.conn('pod2')
|
||||
print(pod2)
|
||||
print(pod2.connected)
|
||||
|
||||
mgr.unregister('pod1')
|
||||
|
||||
logger.info(mgr.metas)
|
||||
logger.info(mgr.conns)
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user