class PgConduit::Connections
Attributes
dest_pool[R]
src_pool[R]
Public Class Methods
init_pool(params)
click to toggle source
# File lib/pg_conduit/connections.rb, line 7 def self.init_pool(params) ConnectionPool.new { PG::Connection.open(params) } end
new(source, destination)
click to toggle source
# File lib/pg_conduit/connections.rb, line 11 def initialize(source, destination) @src_pool = self.class.init_pool source @dest_pool = self.class.init_pool destination end
Public Instance Methods
with_destination() { |conn| ... }
click to toggle source
# File lib/pg_conduit/connections.rb, line 20 def with_destination @dest_pool.with { |conn| yield conn } end
with_source() { |conn| ... }
click to toggle source
# File lib/pg_conduit/connections.rb, line 16 def with_source @src_pool.with { |conn| yield conn } end