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 |