Class: Pgai::Port::Manager

Inherits:
Object
  • Object
show all
Defined in:
lib/pgai/port/manager.rb

Instance Method Summary collapse

Constructor Details

#initialize(logger: Pgai::Commander.instance.logger) ⇒ Manager

Returns a new instance of Manager.



6
7
8
9
 
# File 'lib/pgai/port/manager.rb', line 6

def initialize(logger: Pgai::Commander.instance.logger)
  @logger = logger
  @executor = Concurrent::IndirectImmediateExecutor.new
end

Instance Method Details

#forward(local_port, host, port) ⇒ Object 



11
12
13
14
15
16
 
# File 'lib/pgai/port/manager.rb', line 11

def forward(local_port, host, port)
  forwarder = start(local_port, host, port)
  yield
ensure
  forwarder&.stop
end

#start(local_port, host, port) ⇒ Object 



18
19
20
21
22
 
# File 'lib/pgai/port/manager.rb', line 18

def start(local_port, host, port)
  fw = Port::Forwarder.new(local_port, host, port, logger: @logger)
  @executor.post(fw, &:start)
  fw
end