Module: ActiveRecord::Turntable::Migration::ShardDefinition

Defined in:
lib/active_record/turntable/migration.rb

Instance Method Summary collapse

Instance Method Details

#clusters(*cluster_names) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/active_record/turntable/migration.rb', line 15

def clusters(*cluster_names)
  config = ActiveRecord::Base.turntable_config
  (self.target_shards ||= []).concat(
    if cluster_names.first == :all
      config['clusters'].map do |name, cluster_conf|
        cluster_conf["shards"].map {|shard| shard["connection"]}
      end
    else
      cluster_names.map do |cluster_name|
        config['clusters'][cluster_name]["shards"].map do |shard|
          shard["connection"]
        end
      end.flatten
    end
  )
end

#shards(*connection_names) ⇒ Object 



32
33
34
 
# File 'lib/active_record/turntable/migration.rb', line 32

def shards(*connection_names)
  (self.target_shards ||= []).concat connection_names
end