Module: Ocular::DSL::Graphite

Included in:
RunContext, Event::DefinitionProxy
Defined in:
lib/ocular/dsl/graphite.rb

Instance Method Summary collapse

Instance Method Details

#graphite(target, options = {}) ⇒ Object

add_help “graphite”, “what?”



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
 
# File 'lib/ocular/dsl/graphite.rb', line 11

def graphite(target, options = {})
    datasources = ::Ocular::Settings::get(:datasources)
    if !datasources or !datasources[:graphite]
        raise "No graphite client settings"
    end
    settings = datasources[:graphite]

    uri = URI.parse(settings[:url])
    http = Net::HTTP.new(uri.host, uri.port)
    http.use_ssl = uri.instance_of?(URI::HTTPS)

    if !options[:from]
        options[:from] = "-1min"
    end

    if options[:format]
        options.delete(:format)
    end

    query = "/render?target=#{CGI.escape(target)}&format=json"
    options.each do |k, v|
        query += "&#{k}=#{CGI.escape(v)}"
    end

    request = Net::HTTP::Get.new(query)
    response = http.request(request)
    if !response
        raise "error, no response from post request"
    end
    if response.code.to_i != 200
        raise "Invalid response from graphite for query #{query}. Response code: #{response.code}, response body: #{response.body}"
    end

    begin
        return JSON.parse(response.body)
    rescue
        return nil
    end
end

#graphite_get_latests(target, options = {}) ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/ocular/dsl/graphite.rb', line 51

def graphite_get_latests(target, options = {})
    values = {}
    response = graphite(target, options)
    response.each do |reply|
        # Discard null replies
        # sort in descending order
        # pick latests datapoint
        # from that pick the value
        if reply and reply["datapoints"] and reply["datapoints"].length > 0
            values[reply["target"]] = reply["datapoints"].select {|x| x and x[0] }.sort {|a,b| b[1] <=> a[1]}.first[0]
        end
    end

    return values
end