fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-17 16:10:50 +00:00
Code Issues Projects Releases Wiki Activity

initial node loading info code for redis-trib

Browse Source
This commit is contained in:
antirez 2011-09-28 19:08:35 +02:00
parent 1ef8b0a96d
commit d3f7fbfc09
1 changed files with 37 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/redis-trib.rb
View File

@ -22,6 +22,8 @@ class ClusterNode
@port = s[1]
@slots = {}
@dirty = false
@info = nil
@friends = []
end
def to_s
@ -29,6 +31,7 @@ class ClusterNode
end
def connect(o={})
return if @r
xputs "Connecting to node #{self}: "
begin
@r = Redis.new(:host => @host, :port => @port)
@ -58,6 +61,39 @@ class ClusterNode
end
end
def load_info(o={})
self.connect
nodes = @r.cluster("nodes").split("\n")
nodes.each{|n|
# name addr flags role ping_sent ping_recv link_status slots
name,addr,flags,role,ping_sent,ping_recv,link_status,slots = n.split(" ")
info = {
:name => name,
:addr => addr,
:flags => flags.split(","),
:role => role,
:ping_sent => ping_sent.to_i,
:ping_recv => ping_recv.to_i,
:link_status => link_status
}
if info[:flags].index("myself")
@info = info
@slots = {}
slots.split(",").each{|s|
if s.index("-")
start,stop = s.split("-")
self.add_slots((start.to_i)..(stop.to_i))
else
self.add_slots((s.to_i)..(s.to_i))
end
}
@dirty = false
elsif o[:getfriends]
@friends << info
end
}
end
def add_slots(slots)
slots.each{|s|
@slots[s] = :new
@ -205,6 +241,7 @@ class RedisTrib
node = ClusterNode.new(ARGV[1])
node.connect(:abort => true)
node.assert_cluster
node.load_info
add_node(node)
check_cluster
end