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
124 125 126 127 128 129 130 131 |
# File 'lib/octopus/migration.rb', line 124 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
107 108 109 110 111 112 113 |
# File 'lib/octopus/migration.rb', line 107 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
133 134 135 136 137 138 139 |
# File 'lib/octopus/migration.rb', line 133 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
115 116 117 118 119 120 121 122 |
# File 'lib/octopus/migration.rb', line 115 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 |