Sha256: 274d7f37294dea93286d36504974a5178584f4b841bbad8ef76af6a8fb9d8931
Contents?: true
Size: 795 Bytes
Versions: 34
Compression:
Stored size: 795 Bytes
Contents
module Groonga
module Sharding
class LogicalShardListCommand < Command
register("logical_shard_list",
[
"logical_table",
])
def run_body(input)
enumerator = LogicalEnumerator.new("logical_shard_list",
input,
:require_shard_key => false)
shard_names = enumerator.collect do |current_shard, shard_range|
current_shard.table_name
end
writer.array("shards", shard_names.size) do
shard_names.each do |shard_name|
writer.map("shard", 1) do
writer.write("name")
writer.write(shard_name)
end
end
end
end
end
end
end
Version data entries
34 entries across 34 versions & 1 rubygems