Contents

module Octopus::CollectionProxy
  def self.included(base)
    base.send(:include, Octopus::ShardTracking::Dynamic)
    base.sharded_methods :any?, :build, :count, :create, :create!, :concat, :delete, :delete_all,
                         :destroy, :destroy_all, :empty?, :find, :first, :include?, :last, :length,
                         :many?, :pluck, :replace, :select, :size, :sum, :to_a, :uniq
  end

  def current_shard
    @association.owner.current_shard
  end
end

ActiveRecord::Associations::CollectionProxy.send(:include, Octopus::CollectionProxy)

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ar-octopus-0.8.2	lib/octopus/collection_proxy.rb