class EventQL::Client
Public Class Methods
new(opts = {})
click to toggle source
# File lib/eventql_client.rb, line 5 def initialize(opts = {}) @opts = opts end
Public Instance Methods
get_auth_token()
click to toggle source
# File lib/eventql_client.rb, line 46 def get_auth_token return @opts[:auth_token] end
get_database()
click to toggle source
# File lib/eventql_client.rb, line 42 def get_database return @opts[:database] end
get_host()
click to toggle source
# File lib/eventql_client.rb, line 34 def get_host return @opts[:host] end
get_port()
click to toggle source
# File lib/eventql_client.rb, line 38 def get_port return @opts[:port] end
has_auth_token?()
click to toggle source
# File lib/eventql_client.rb, line 50 def has_auth_token? return !@opts[:auth_token].nil? end
insert!(data, opts = {})
click to toggle source
# File lib/eventql_client.rb, line 13 def insert!(data, opts = {}) request = Net::HTTP::Post.new("/api/v1/tables/insert") request.add_field("Content-Type", "application/json") if has_auth_token? request.add_field("Authorization", "Token #{get_auth_token}") end request.body = data.to_json puts request.body http = Net::HTTP.new(get_host, get_port) response = http.request(request) if response.code.to_i == 201 return true else raise "HTTP ERROR (#{response.code}): #{response.body[0..128]}" end end
query(query_str, opts = {})
click to toggle source
# File lib/eventql_client.rb, line 9 def query(query_str, opts = {}) EventQL::Query.new(self, query_str, opts) end