Module: Tako::ActiveRecordExt::ShardedMethods

Defined in:
lib/tako/active_record_ext/sharded_methods.rb

Instance Method Summary collapse

Instance Method Details

#sharded_methods(*method_names) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
15
16
 
# File 'lib/tako/active_record_ext/sharded_methods.rb', line 4

def sharded_methods(*method_names)
  method_names.each do |method_name|
    define_method(:"#{method_name}_with_tako") do |*params, &block|
      if current_shard
        ::Tako.shard(current_shard) { send(:"#{method_name}_without_tako",*params, &block) }
      else
        send(:"#{method_name}_without_tako",*params, &block)
      end
    end
    send(:alias_method, :"#{method_name}_without_tako", method_name)
    send(:alias_method, method_name, :"#{method_name}_with_tako")
  end
end