module Octopus::ShardTracking::Attribute
Attributes
current_shard[RW]
Public Class Methods
included(base)
click to toggle source
# File lib/octopus/shard_tracking/attribute.rb, line 7 def self.included(base) base.send(:include, Octopus::ShardTracking) end
Public Instance Methods
set_current_shard()
click to toggle source
# File lib/octopus/shard_tracking/attribute.rb, line 13 def set_current_shard return unless Octopus.enabled? if ActiveRecord::Base.connection_proxy.block self.current_shard = ActiveRecord::Base.connection_proxy.current_shard end end