Module: Octopus::Migration::ClassMethods
- Defined in:
- lib/octopus/migration.rb
Instance Method Summary collapse
Instance Method Details
#shards ⇒ Object
40 41 42 43 44 45 46 47 48 49 50 51 52 53 |
# File 'lib/octopus/migration.rb', line 40 def shards shards = Set.new if groups = current_group Array.wrap(groups).each do |group| group_shards = connection.shards_for_group(group) shards.merge(group_shards) if group_shards end elsif shard = current_shard shards.merge(Array.wrap(shard)) end shards.to_a.presence || [:master] end |