Class: Prometheus::ApiClient::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/prometheus/api_client/client.rb

Overview

Client contains the implementation for a Prometheus compatible api_client.

Defined Under Namespace

Classes: RequestError

Constant Summary collapse

DEFAULT_ARGS =

Default paramters for creating default client

{
  url: 'http://localhost:9090',
  path: '/api/v1/',
  credentials: {},
  options: {
    open_timeout: 2,
    timeout: 5,
  },
}.freeze

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Client

Create a Prometheus API client:

A default client is created if options is omitted.

Parameters:

  • options (Hash) (defaults to: {})

Options Hash (options):

  • :url (String) —

    server base URL.

  • :credentials (Hash) —

    Authentication credentials.

  • :options (Hash) —

    Options used to define connection.

  • :params (Hash) —

    URI query unencoded key/value pairs.

  • :headers (Hash) —

    Unencoded HTTP header key/value pairs.

  • :request (Hash) —

    Request options.

  • :ssl (Hash) —

    SSL options.

  • :proxy (Hash) —

    Proxy options.



37
38
39
40
41
42
43
 
# File 'lib/prometheus/api_client/client.rb', line 37

def initialize(options = {})
  options = DEFAULT_ARGS.merge(options)

  @client = Faraday.new(
    faraday_options(options),
  )
end

Instance Method Details

#faraday_headers(credentials) ⇒ Object

Helper function to evalueate the low level headers option



126
127
128
129
130
131
132
 
# File 'lib/prometheus/api_client/client.rb', line 126

def faraday_headers(credentials)
  return unless credentials[:token]

  {
    Authorization: 'Bearer ' + credentials[:token].to_s,
  }
end

#faraday_options(options) ⇒ Object

Helper function to create the args for the low level client



135
136
137
138
139
140
141
142
143
144
145
146
 
# File 'lib/prometheus/api_client/client.rb', line 135

def faraday_options(options)
  {
    url: options[:url] + options[:path],
    proxy: faraday_proxy(options[:options]),
    ssl: faraday_verify_ssl(options[:options]),
    headers: faraday_headers(options[:credentials]),
    request: {
      open_timeout: options[:options][:open_timeout],
      timeout: options[:options][:timeout],
    },
  }
end

#faraday_proxy(options) ⇒ Object

Helper function to evalueate the low level proxy option



111
112
113
 
# File 'lib/prometheus/api_client/client.rb', line 111

def faraday_proxy(options)
  options[:http_proxy_uri] if options[:http_proxy_uri]
end

#faraday_verify_ssl(options) ⇒ Object

Helper function to evalueate the low level ssl option



116
117
118
119
120
121
122
123
 
# File 'lib/prometheus/api_client/client.rb', line 116

def faraday_verify_ssl(options)
  return unless options[:verify_ssl]

  {
    verify: options[:verify_ssl] != OpenSSL::SSL::VERIFY_NONE,
    cert_store: options[:ssl_cert_store],
  }
end

#get(command, options) ⇒ Object

Issues a get request to the low level client.



96
97
98
 
# File 'lib/prometheus/api_client/client.rb', line 96

def get(command, options)
  @client.get(command, options)
end

#label(label, options = {}) ⇒ Object

Returns a list of label values for a provided label name:

No options used.

Parameters:

  • label (String) —

    Label name

  • options (Hash) (defaults to: {}) 


91
92
93
 
# File 'lib/prometheus/api_client/client.rb', line 91

def label(label, options = {})
  run_command("label/#{label}/values", options)
end

#query(options) ⇒ Object

Evaluates an instant query at a single point in time:

The current server time is used if the time parameter is omitted.

Parameters:

  • options (Hash)

Options Hash (options):

  • :query (String) —

    Prometheus expression query string.

  • :time (String) —

    <rfc3339 | unix_timestamp> Evaluation timestamp. Optional.

  • :timeout (String) —

    Evaluation timeout. Optional. Defaults to and is capped by the value of the -query.timeout flag.



55
56
57
 
# File 'lib/prometheus/api_client/client.rb', line 55

def query(options)
  run_command('query', options)
end

#query_range(options) ⇒ Object

Evaluates an expression query over a range of time:

The current server time is used if the time parameter is omitted.

Parameters:

  • options (Hash)

Options Hash (options):

  • :query (String) —

    Prometheus expression query string.

  • :start (String) —

    <rfc3339 | unix_timestamp> Start timestamp.

  • :end (String) —

    <rfc3339 | unix_timestamp> End timestamp.

  • :step (String) —

    <duration> Query resolution step width.

  • :timeout (String) —

    Evaluation timeout. Optional. Defaults to and is capped by the value of the -query.timeout flag.



71
72
73
 
# File 'lib/prometheus/api_client/client.rb', line 71

def query_range(options)
  run_command('query_range', options)
end

#run_command(command, options) ⇒ Object

Issues a get request to the low level client, and evalueate the response JSON.



102
103
104
105
106
107
108
 
# File 'lib/prometheus/api_client/client.rb', line 102

def run_command(command, options)
  response = get(command, options)

  JSON.parse(response.body)['data']
rescue
  raise RequestError, 'Bad response from server'
end

#targets(options = {}) ⇒ Object

Returns an overview of the current state of the Prometheus target discovery:

No options used.

Parameters:

  • options (Hash) (defaults to: {}) 


81
82
83
 
# File 'lib/prometheus/api_client/client.rb', line 81

def targets(options = {})
  run_command('targets', options)
end