Class: OpenTSDB::Client

Inherits:
Object
  • Object
show all
Includes:
Logging
Defined in:
lib/opentsdb/client.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Logging

included, #logger

Constructor Details

#initialize(options = {}) ⇒ Client

Returns a new instance of Client.



10
11
12
13
14
15
16
17
18
 
# File 'lib/opentsdb/client.rb', line 10

def initialize(options = {})
  begin
    hostname = options[:hostname] || 'localhost'
    port = options[:port] || 4242
    @connection = TCPSocket.new(hostname, port)
  rescue
    raise "Unable to connect or invalid connection data"
  end
end

Instance Attribute Details

#connection ⇒ Object (readonly)

Returns the value of attribute connection.



8
9
10
 
# File 'lib/opentsdb/client.rb', line 8

def connection
  @connection
end

Instance Method Details

#build_command(input) ⇒ Object 



28
29
30
31
32
33
34
 
# File 'lib/opentsdb/client.rb', line 28

def build_command(input) 
  if input.kind_of?(Array)
    input.collect { |unit| to_command(unit) }.join("\n")
  else
    to_command(input)
  end.chomp
end

#put(options = {}) ⇒ Object 



36
37
38
 
# File 'lib/opentsdb/client.rb', line 36

def put(options = {})
  @connection.puts(build_command(options))
end

#to_command(options) ⇒ Object 



20
21
22
23
24
25
26
 
# File 'lib/opentsdb/client.rb', line 20

def to_command( options )
  timestamp = options[:timestamp].to_i
  metric_name = options[:metric]
  value = options[:value].to_f
  tags = options[:tags].map{|k,v| "#{k}=#{v}"}.join(" ")
  "put #{metric_name} #{timestamp} #{value} #{tags}"
end