caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 00:28:26 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

redis-trib: added cluster_error method to add errors.

Browse Source
This commit is contained in:
antirez 2013-03-22 12:59:18 +01:00
parent d7eae8d8d7
commit 813d7cbdd1
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/redis-trib.rb
View File

@ -250,6 +250,11 @@ class RedisTrib
@nodes << node @nodes << node
end end
def cluster_error(msg)
@errors << msg
puts msg
end
def get_node_by_name(name) def get_node_by_name(name)
@nodes.each{|n| @nodes.each{|n|
return n if n.info[:name] == name.downcase return n if n.info[:name] == name.downcase
@ -281,9 +286,8 @@ class RedisTrib
if slots.length == ClusterHashSlots if slots.length == ClusterHashSlots
puts "[OK] All #{ClusterHashSlots} slots covered." puts "[OK] All #{ClusterHashSlots} slots covered."
else else
@errors << cluster_error \
"[ERR] Not all #{ClusterHashSlots} slots are covered by nodes." "[ERR] Not all #{ClusterHashSlots} slots are covered by nodes."
puts @errors[-1]
fix_slots_coverage if @fix fix_slots_coverage if @fix
end end
end end
@ -293,10 +297,12 @@ class RedisTrib
open_slots = [] open_slots = []
@nodes.each{|n| @nodes.each{|n|
if n.info[:migrating].size > 0 if n.info[:migrating].size > 0
puts "[WARNING] Node #{n} has slots in migrating state." cluster_error \
"[WARNING] Node #{n} has slots in migrating state."
open_slots += n.info[:migrating].keys open_slots += n.info[:migrating].keys
elsif n.info[:importing].size > 0 elsif n.info[:importing].size > 0
puts "[WARNING] Node #{n} has slots in importing state." cluster_error \
"[WARNING] Node #{n} has slots in importing state."
open_slots += n.info[:importing].keys open_slots += n.info[:importing].keys
end end
} }
@ -566,7 +572,7 @@ class RedisTrib
load_cluster_info_from_node(ARGV[1]) load_cluster_info_from_node(ARGV[1])
check_cluster check_cluster
if @errors.length != 0 if @errors.length != 0
puts "Please fix your cluster problems before resharding." puts "\n--- Please fix your cluster problems before resharding ---"
exit 1 exit 1
end end
numslots = 0 numslots = 0