Lines Matching refs:cluster
118 if !(@r.cluster("info").split("\r\n").index("cluster_known_nodes:1")) ||
127 nodes = @r.cluster("nodes").split("\n")
164 @r.cluster("info").split("\n").each{|e|
196 @r.cluster("replicate",@info[:replicate])
212 @r.cluster("addslots",*new)
271 @r.cluster("nodes").each_line{|l|
430 nodes << n if n.r.cluster("getkeysinslot",slot,1).length > 0
463 node.r.cluster("addslots",slot)
474 nodes[0].r.cluster("addslots",slot)
487 target.r.cluster('addslots',slot)
488 target.r.cluster('setslot',slot,'stable')
494 src.r.cluster('setslot',slot,'importing',target.info[:name])
496 src.r.cluster('setslot',slot,'stable')
521 numkeys = n.r.cluster("countkeysinslot",slot)
549 elsif n.r.cluster("countkeysinslot",slot) > 0 && n != owner
571 owner.r.cluster("setslot",slot,"stable")
572 owner.r.cluster("addslots",slot)
576 owner.r.cluster("bumpepoch")
596 n.r.cluster('delslots',slot)
597 n.r.cluster('setslot',slot,'importing',owner.info[:name])
601 owner.r.cluster('bumpepoch')
618 node.r.cluster("setslot",slot,"stable")
624 migrating[0].r.cluster("getkeysinslot",slot,10).length == 0
625 migrating[0].r.cluster("setslot",slot,"stable")
795 n.r.cluster("set-config-epoch",config_epoch)
811 n.r.cluster("meet",first[:host],first[:port])
930 target.r.cluster("setslot",slot,"importing",source.info[:name])
931 source.r.cluster("setslot",slot,"migrating",target.info[:name])
935 keys = source.r.cluster("getkeysinslot",slot,o[:pipeline])
958 n.r.cluster("setslot",slot,"node",target.info[:name])
1343 new.r.cluster("meet",first[:host],first[:port])
1350 new.r.cluster("replicate",master.info[:name])
1383 n.r.cluster("replicate",master.info[:name])
1385 n.r.cluster("forget",argv[1])