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