Commit f29d1fb0 authored by Salvatore Sanfilippo's avatar Salvatore Sanfilippo
Browse files

assert_empty in redis-trib

parent 8c4c5090
...@@ -43,6 +43,14 @@ class ClusterNode ...@@ -43,6 +43,14 @@ class ClusterNode
end end
end end
def assert_empty
if !(@r.cluster("info").split("\r\n").index("cluster_known_nodes:1")) ||
(@r.info['db0'])
puts "Error: Node #{self} is not empty. Either the node already knows other nodes (check with nodes-info) or contains some key in database 0."
exit 1
end
end
def r def r
@r @r
end end
...@@ -63,7 +71,7 @@ class RedisTrib ...@@ -63,7 +71,7 @@ class RedisTrib
node = ClusterNode.new(n) node = ClusterNode.new(n)
node.connect node.connect
node.assert_cluster node.assert_cluster
# node.assert_empty node.assert_empty
} }
end end
end end
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment