Class: Lumberjack::Beats::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/lumberjack/beats/client.rb

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ Client

Returns a new instance of Client.



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/lumberjack/beats/client.rb', line 10

def initialize(opts={})
  @opts = {
    :port => 0,
    :addresses => [],
    :ssl_certificate => nil,
    :ssl_certificate_key => nil,
    :ssl_certificate_authorities => nil,
    :ssl => true,
    :json => false,
  }.merge(opts)

  @opts[:addresses] = Array(@opts[:addresses])
  raise "Must set a port." if @opts[:port] == 0
  raise "Must set atleast one address" if @opts[:addresses].empty? == 0

  if @opts[:ssl]
    if @opts[:ssl_certificate_authorities].nil? && (@opts[:ssl_certificate].nil? || @opts[:ssl_certificate_key].nil?)
      raise "Must set a ssl certificate or path"
    end
  end

  @socket = connect
end

Instance Method Details

#host ⇒ Object 



53
54
55
 
# File 'lib/lumberjack/beats/client.rb', line 53

def host
  @socket.host
end

#write(elements, opts = {}) ⇒ Object 



48
49
50
 
# File 'lib/lumberjack/beats/client.rb', line 48

def write(elements, opts={})
  @socket.write_sync(elements, opts)
end