class Redis::DistRedis

def keys_by_node(*keyz)
  keyz.flatten.inject({}) do |kbn, k|
    node = node_for_key(k)
    next if kbn[node] && kbn[node].include?(k)
    kbn[node] ||= []
    kbn[node] << k
    kbn
  end
end