Class: FnordMetric::Acceptor

Inherits:
Object
  • Object
show all
Defined in:
lib/fnordmetric/acceptors/acceptor.rb

Instance Method Summary collapse

Constructor Details

#initialize(opts) ⇒ Acceptor

Returns a new instance of Acceptor.



3
4
5
6
7
 
# File 'lib/fnordmetric/acceptors/acceptor.rb', line 3

def initialize(opts)
  @opts = opts

  FnordMetric.register(self)
end

Instance Method Details

#initialized ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/fnordmetric/acceptors/acceptor.rb', line 9

def initialized   
  inbound_class = if @opts[:protocol] == :udp 
    FnordMetric::UDPAcceptor
  else
    FnordMetric::TCPAcceptor
  end

  @opts[:listen] = [
    @opts[:host] || "0.0.0.0",
    @opts[:port] || 2323
  ]

  begin
    inbound_stream = inbound_class.start(@opts)
    FnordMetric.log "listening on #{@opts[:protocol]}://#{@opts[:listen][0..1].join(":")}"
  #rescue
  #  FnordMetric.log "cant start #{inbound_class.name}. port in use?"
  end
end