module ActiveRecord::Sharding::DatabaseTasks::TasksForMultipleClusters

Public Instance Methods

invoke_task(name, cluster_name) click to toggle source
# File lib/active_record/sharding/database_tasks.rb, line 86
def invoke_task(name, cluster_name)
  task_name = "active_record:sharding:#{name}"
  to_rake_task(task_name).invoke cluster_name.to_s
  to_rake_task(task_name).reenable
end
invoke_task_for_all_clusters(task_name) click to toggle source
# File lib/active_record/sharding/database_tasks.rb, line 80
def invoke_task_for_all_clusters(task_name)
  cluster_names.each do |cluster_name|
    invoke_task task_name, cluster_name
  end
end
invoke_task_for_all_sequencers(task_name) click to toggle source
# File lib/active_record/sharding/database_tasks.rb, line 92
def invoke_task_for_all_sequencers(task_name)
  sequencer_names.each do |sequencer_name|
    invoke_task_for_sequencer task_name, sequencer_name
  end
end
invoke_task_for_sequencer(name, sequencer_name) click to toggle source
# File lib/active_record/sharding/database_tasks.rb, line 98
def invoke_task_for_sequencer(name, sequencer_name)
  task_name = "active_record:sharding:sequencer:#{name}"
  to_rake_task(task_name).invoke sequencer_name.to_s
  to_rake_task(task_name).reenable
end