Module: ActiveRecord::Sharding::DatabaseTasks::TasksForMultipleClusters

Included in:
ActiveRecord::Sharding::DatabaseTasks
Defined in:
lib/active_record/sharding/database_tasks.rb

Instance Method Summary collapse

Instance Method Details

#invoke_task(name, cluster_name) ⇒ Object 



86
87
88
89
90
 
# 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) ⇒ Object 



80
81
82
83
84
 
# 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) ⇒ Object 



92
93
94
95
96
 
# 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) ⇒ Object 



98
99
100
101
102
 
# 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