class Latias::Influxdb::ActionBucket::Base

base

Attributes

bucket[R]
client[R]
org[R]
precision[R]
query[R]
token[R]
url[R]
use_ssl[R]
verify_mode[R]

Public Instance Methods

call() click to toggle source
# File lib/latias/influxdb/action_bucket/base.rb, line 18
def call
  all_query = "from(bucket: \"#{use_value('bucket')}\") #{@query}"
  @query = ''
  @client.create_query_api.query(query: all_query, org: use_value('org'))
end
client_connection() click to toggle source
# File lib/latias/influxdb/action_bucket/base.rb, line 24
def client_connection
  @query = ''
  @client = InfluxDB2::Client.new(use_value('url'), use_value('token'),
                                  use_ssl: use_value('use_ssl'),
                                  verify_mode: use_value('verify_mode'),
                                  precision: InfluxDB2::WritePrecision::NANOSECOND)
  self
end
execute(query) click to toggle source
# File lib/latias/influxdb/action_bucket/base.rb, line 14
def execute(query)
  @query = query
end

Private Instance Methods

get_binding(param) click to toggle source
# File lib/latias/influxdb/action_bucket/base.rb, line 44
def get_binding(param)
  binding
end
new_command() click to toggle source
# File lib/latias/influxdb/action_bucket/base.rb, line 40
def new_command
  '|> '
end
use_value(key) click to toggle source
# File lib/latias/influxdb/action_bucket/base.rb, line 35
def use_value(key)
  b = get_binding("self")
  b.eval("@#{key}") || Latias::Influxdb.configuration.send(key)
end