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