class ATSD::MessagesService
Public Instance Methods
insert(messages)
click to toggle source
Insert messages.
@param [Array<Message, Hash>, Message
, Hash] messages @return [self] @raise [APIError]
# File lib/atsd/services/messages_service.rb, line 26 def insert(messages) messages = Utils.ensure_array(messages).map do |s| s = Message.new(s) if s.is_a? Hash s.to_request_hash end @client.messages_insert messages self end
query(entity, options = {})
click to toggle source
Create query builder for messages.
@param [String, Entity] entity @param [Hash] options other query parameters @return [MessagesQuery]
# File lib/atsd/services/messages_service.rb, line 13 def query(entity, options = {}) query = MessagesQuery.new @client entity = entity.name if entity.is_a? Entity options.merge! entity: entity options.each { |option, value| query[option] = value } query end
stats_query(options)
click to toggle source
Retrieve message counters for the specified filters as series.
@param [Hash] options parameters @return [self] @raise [APIError]
# File lib/atsd/services/messages_service.rb, line 40 def stats_query(options) options[:metric] = 'message-count' options = Utils.ensure_array(options).map do |s| s = Message.new(s) if s.is_a? Hash s.to_request_hash end result = @client.messages_stat_query(options) result.map { |json| Series.new json } end