Lines Matching refs:keys

226         slots = @info[:slots].keys.sort
366         keys = 0
372                 keys += n.r.dbsize
375         xputs "[OK] #{keys} keys in #{masters} masters."
376         keys_per_slot = sprintf("%.2f",keys/16384.0)
408 …         "[WARNING] Node #{n} has slots in migrating state (#{n.info[:migrating].keys.join(",")})."
409                 open_slots += n.info[:migrating].keys
413 …         "[WARNING] Node #{n} has slots in importing state (#{n.info[:importing].keys.join(",")})."
414                 open_slots += n.info[:importing].keys
436         not_covered = (0...ClusterHashSlots).to_a - covered_slots.keys
458             xputs none.keys.join(",")
470             puts single.keys.join(",")
481             xputs multi.keys.join(",")
894             s.slots.keys.sort[(0...n)].each{|slot|
935             keys = source.r.cluster("getkeysinslot",slot,o[:pipeline])
936             break if keys.length == 0
938 …  source.r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:keys,*keys])
942 …r.client.call(["migrate",target.info[:host],target.info[:port],"",0,@timeout,:replace,:keys,*keys])
949             print "."*keys.length if o[:dots]
1469             cursor,keys = source.scan(cursor, :count => 1000)
1471             keys.each{|k|