Class: Opower::TimeSeries::TSClient::PipelineWrapper

Inherits:
Object
  • Object
show all
Defined in:
lib/time_series/ts_client.rb

Overview

Wraps pipelined requests and creates their individual HTTP requests against OpenTSDB

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(config, queries) ⇒ PipelineWrapper

Initializes the pipeline wrapper and sets up the Excon requests based on the queries.

Parameters:

  • config (Hash) —

    the client configuration

  • queries (Array) —

    the Array of Query objects to execute



161
162
163
164
165
 
# File 'lib/time_series/ts_client.rb', line 161

def initialize(config, queries)
  @config = config
  @queries = queries
  @requests = @queries.map { |query| { method: :get, path: 'api/query', query: query.request } }
end

Instance Attribute Details

#requests ⇒ Object (readonly)

Returns the value of attribute requests.



155
156
157
 
# File 'lib/time_series/ts_client.rb', line 155

def requests
  @requests
end