module Octopus::ReplicationTracking::BaseMethods::ModuleMethods

Define Module methods

Public Instance Methods

replication_position(shard) click to toggle source
# File lib/octopus/replication_tracking/base_methods.rb, line 11
def replication_position(shard)
  conn = ActiveRecord::Base.connection

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

  using(shard) { conn.replication_position }
end