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