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