File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change @@ -1482,7 +1482,6 @@ class ZooKeeper(object):
1482
1482
# Constants used by the REST API:
1483
1483
LIVE_NODES_ZKNODE = "/live_nodes"
1484
1484
ALIASES = "/aliases.json"
1485
- CLUSTER_STATE = "/clusterstate.json"
1486
1485
COLLECTION_STATUS = "/collections"
1487
1486
COLLECTION_STATE = "/collections/%s/state.json"
1488
1487
SHARDS = "shards"
@@ -1526,14 +1525,6 @@ def connectionListener(state):
1526
1525
1527
1526
self .zk .add_listener (connectionListener )
1528
1527
1529
- @self .zk .DataWatch (ZooKeeper .CLUSTER_STATE )
1530
- def watchClusterState (data , * args , ** kwargs ):
1531
- if not data :
1532
- LOG .warning ("No cluster state available: no collections defined?" )
1533
- else :
1534
- self .collections = json .loads (data .decode ("utf-8" ))
1535
- LOG .info ("Updated collections: %s" , self .collections )
1536
-
1537
1528
@self .zk .ChildrenWatch (ZooKeeper .LIVE_NODES_ZKNODE )
1538
1529
def watchLiveNodes (children ):
1539
1530
self .liveNodes = children
You can’t perform that action at this time.
0 commit comments