Commit e23e4ce 1 parent bacad23 commit e23e4ce Copy full SHA for e23e4ce
File tree 1 file changed +0
-9
lines changed
1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change @@ -1530,7 +1530,6 @@ class ZooKeeper(object):
1530
1530
# Constants used by the REST API:
1531
1531
LIVE_NODES_ZKNODE = "/live_nodes"
1532
1532
ALIASES = "/aliases.json"
1533
- CLUSTER_STATE = "/clusterstate.json"
1534
1533
COLLECTION_STATUS = "/collections"
1535
1534
COLLECTION_STATE = "/collections/%s/state.json"
1536
1535
SHARDS = "shards"
@@ -1574,14 +1573,6 @@ def connectionListener(state):
1574
1573
1575
1574
self .zk .add_listener (connectionListener )
1576
1575
1577
- @self .zk .DataWatch (ZooKeeper .CLUSTER_STATE )
1578
- def watchClusterState (data , * args , ** kwargs ):
1579
- if not data :
1580
- LOG .warning ("No cluster state available: no collections defined?" )
1581
- else :
1582
- self .collections = json .loads (data .decode ("utf-8" ))
1583
- LOG .info ("Updated collections: %s" , self .collections )
1584
-
1585
1576
@self .zk .ChildrenWatch (ZooKeeper .LIVE_NODES_ZKNODE )
1586
1577
def watchLiveNodes (children ):
1587
1578
self .liveNodes = children
You can’t perform that action at this time.
0 commit comments