class Rom::Dynamo::GlobalIndexDataset

Dataset queried via a Global Secondary Index Paginate through keys from Global Index and call BatchGetItem for keys from each page

Public Instance Methods

each(&block) click to toggle source
# File lib/rom/dynamo/relation.rb, line 166
def each(&block)
  if @query[:limit]
    each_item(start_query, &block)
  else
    result = start_query(limit: 100)
    result.each_page { |p| each_item(p, &block) }
  end
end

Private Instance Methods

each_item(result, &block) click to toggle source
# File lib/rom/dynamo/relation.rb, line 175
        def each_item(result, &block)
  keys = result[:items].map { |h| hash_to_key(h) }
  batch_get_each_item(keys, &block)
end