Contents

module Octopus::Migration  
  def using(*args, &block)
    if args.size == 1
      self.connection().block = true
      self.connection().current_shard = args.first
    else
      self.connection().current_shard = args        
    end
    
    yield if block_given?

    return self
  end

  def using_group(*args)
    if args.size == 1
      self.connection().block = true
      self.connection().current_group = args.first
    else
      self.connection().current_group = args
    end

    return self
  end
end


ActiveRecord::Migration.extend(Octopus::Migration)

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
ar-octopus-0.0.16	lib/octopus/migration.rb
ar-octopus-0.0.15	lib/octopus/migration.rb
ar-octopus-0.0.14	lib/octopus/migration.rb
ar-octopus-0.0.13	lib/octopus/migration.rb
ar-octopus-0.0.12	lib/octopus/migration.rb
ar-octopus-0.0.11	lib/octopus/migration.rb
ar-octopus-0.0.10	lib/octopus/migration.rb
ar-octopus-0.0.9	lib/octopus/migration.rb