Class: PgConduit::Connections

Inherits:
Object
  • Object
show all
Defined in:
lib/pg_conduit/connections.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(source, destination) ⇒ Connections

Returns a new instance of Connections.



11
12
13
14
 
# 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

Instance Attribute Details

#dest_pool ⇒ Object (readonly)

Returns the value of attribute dest_pool.



5
6
7
 
# File 'lib/pg_conduit/connections.rb', line 5

def dest_pool
  @dest_pool
end

#src_pool ⇒ Object (readonly)

Returns the value of attribute src_pool.



5
6
7
 
# File 'lib/pg_conduit/connections.rb', line 5

def src_pool
  @src_pool
end

Class Method Details

.init_pool(params) ⇒ Object 



7
8
9
 
# File 'lib/pg_conduit/connections.rb', line 7

def self.init_pool(params)
  ConnectionPool.new { PG::Connection.open(params) }
end

Instance Method Details

#with_destination ⇒ Object 



20
21
22
 
# File 'lib/pg_conduit/connections.rb', line 20

def with_destination
  @dest_pool.with { |conn| yield conn }
end

#with_source ⇒ Object 



16
17
18
 
# File 'lib/pg_conduit/connections.rb', line 16

def with_source
  @src_pool.with { |conn| yield conn }
end