Class: Sbmt::KafkaConsumer::Probes::Host

Inherits:
Object
  • Object
show all
Defined in:
lib/sbmt/kafka_consumer/probes/host.rb

Class Method Summary collapse

Class Method Details

.run_async ⇒ Object 



11
12
13
14
15
16
17
18
 
# File 'lib/sbmt/kafka_consumer/probes/host.rb', line 11

def run_async
  config = Sbmt::KafkaConsumer::Config.new
  if config.probes[:port] == config.metrics[:port]
    start_on_single_port(config)
  else
    start_on_different_ports(config)
  end
end

.webrick ⇒ Object 



20
21
22
23
24
 
# File 'lib/sbmt/kafka_consumer/probes/host.rb', line 20

def webrick
  return ::Rack::Handler::WEBrick if Gem::Version.new(::Rack.release) < Gem::Version.new("3")

  ::Rackup::Handler::WEBrick
end