Module: Octopus::Migrator::ClassMethods
- Defined in:
- lib/octopus/migration.rb
Instance Method Summary collapse
- #down_with_octopus(migrations_paths, target_version = nil, &block) ⇒ Object
- #migrate_with_octopus(migrations_paths, target_version = nil, &block) ⇒ Object
- #run_with_octopus(direction, migrations_paths, target_version) ⇒ Object
- #up_with_octopus(migrations_paths, target_version = nil, &block) ⇒ Object
Instance Method Details
#down_with_octopus(migrations_paths, target_version = nil, &block) ⇒ Object
114 115 116 117 118 119 120 121 |
# File 'lib/octopus/migration.rb', line 114 def down_with_octopus(migrations_paths, target_version = nil, &block) return down_without_octopus(migrations_paths, target_version, &block) unless connection.is_a?(Octopus::Proxy) return down_without_octopus(migrations_paths, target_version, &block) unless connection.current_shard == :master connection.send_queries_to_multiple_shards(connection.shard_names) do down_without_octopus(migrations_paths, target_version, &block) end end |
#migrate_with_octopus(migrations_paths, target_version = nil, &block) ⇒ Object
97 98 99 100 101 102 103 |
# File 'lib/octopus/migration.rb', line 97 def migrate_with_octopus(migrations_paths, target_version = nil, &block) return migrate_without_octopus(migrations_paths, target_version, &block) unless connection.is_a?(Octopus::Proxy) connection.send_queries_to_multiple_shards(connection.shard_names) do migrate_without_octopus(migrations_paths, target_version, &block) end end |
#run_with_octopus(direction, migrations_paths, target_version) ⇒ Object
123 124 125 126 127 128 129 |
# File 'lib/octopus/migration.rb', line 123 def run_with_octopus(direction, migrations_paths, target_version) return run_without_octopus(direction, migrations_paths, target_version) unless connection.is_a?(Octopus::Proxy) connection.send_queries_to_multiple_shards(connection.shard_names) do run_without_octopus(direction, migrations_paths, target_version) end end |
#up_with_octopus(migrations_paths, target_version = nil, &block) ⇒ Object
105 106 107 108 109 110 111 112 |
# File 'lib/octopus/migration.rb', line 105 def up_with_octopus(migrations_paths, target_version = nil, &block) return up_without_octopus(migrations_paths, target_version, &block) unless connection.is_a?(Octopus::Proxy) return up_without_octopus(migrations_paths, target_version, &block) unless connection.current_shard == :master connection.send_queries_to_multiple_shards(connection.shard_names) do up_without_octopus(migrations_paths, target_version, &block) end end |