Sha256: 63e8efaa6a1cc4d5345e9ec62f2459ca27cdb7bc2322d30a4a4c22b329501fb9

Contents?: true

Size: 519 Bytes

Versions: 2

Compression:

Stored size: 519 Bytes

Contents

module Octopus
  module ReplicationTracking
    # Extension of Octopus
    module BaseMethods
      def self.extended(base)
        base.extend(ModuleMethods)
      end

      # Define Module methods
      module ModuleMethods
        def replication_position(shard)
          conn = ActiveRecord::Base.connection

          return unless conn.is_a?(Octopus::Proxy)

          using(shard) { conn.replication_position }
        end
      end
    end
  end
end

Octopus.extend(Octopus::ReplicationTracking::BaseMethods)

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
ar-octopus-replication-tracking-0.1.5 lib/octopus/replication_tracking/base_methods.rb
ar-octopus-replication-tracking-0.1.3 lib/octopus/replication_tracking/base_methods.rb