Module: KairosDB::Query::Core

Included in:
Client
Defined in:
lib/kairosdb/query/core.rb

Constant Summary collapse

KAIROSDB_DELETE_PATH = 
'/api/v1/metric'
KAIROSDB_QUERY_PATH = 
'/api/v1/datapoints/query'
KAIROSDB_WRITE_PATH = 
'/api/v1/datapoints'

Instance Method Summary collapse

Instance Method Details

#query(opts = {}) ⇒ Object

Parameters:

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


11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/kairosdb/query/core.rb', line 11

def query(opts = {})
  url = full_path(KAIROSDB_QUERY_PATH)
  metrics = fetch_metrics(post(url, opts))

  if block_given?
    metrics.each do |metric|
      yield metric['name'], metric['tags'], metric['values']
    end
  else
    metrics
  end
end

#write_data(data) ⇒ Object

Parameters:

  • opts (Hash) 


28
29
30
 
# File 'lib/kairosdb/query/core.rb', line 28

def write_data(data)
  writer.write(data)
end