module Octopus::Migrator::ClassMethods

Public Instance Methods

down_with_octopus(migrations_paths, target_version = nil, &block) click to toggle source
# File lib/octopus/migration.rb, line 174
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.to_s == Octopus.master_shard.to_s

  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) click to toggle source
# File lib/octopus/migration.rb, line 157
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
rollback_with_octopus(migrations_paths, steps = 1) click to toggle source
# File lib/octopus/migration.rb, line 191
def rollback_with_octopus(migrations_paths, steps = 1)
  return rollback_without_octopus(migrations_paths, steps) unless connection.is_a?(Octopus::Proxy)

  connection.send_queries_to_multiple_shards(connection.shard_names) do
    rollback_without_octopus(migrations_paths, steps)
  end
end
run_with_octopus(direction, migrations_paths, target_version) click to toggle source
# File lib/octopus/migration.rb, line 183
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) click to toggle source
# File lib/octopus/migration.rb, line 165
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.to_s == Octopus.master_shard.to_s

  connection.send_queries_to_multiple_shards(connection.shard_names) do
    up_without_octopus(migrations_paths, target_version, &block)
  end
end

Private Instance Methods

connection() click to toggle source
# File lib/octopus/migration.rb, line 201
def connection
  ActiveRecord::Base.connection
end