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