Sha256: 02e7367f3f17d801e2b51367527c69b558c0bb9c72789ba5de3ec011ec93a6ec
Contents?: true
Size: 1.65 KB
Versions: 5
Compression:
Stored size: 1.65 KB
Contents
module Elasticsearch
module XPack
module API
module Monitoring
module Actions
# Insert monitoring data in bulk
#
# @option arguments [String] :type Default document type for items which don't provide one
# @option arguments [Hash] :body The operation definition and data (action-data pairs), separated by newlines (*Required*)
# @option arguments [String] :system_id Identifier of the monitored system
# @option arguments [String] :system_api_version API version of the monitored system
# @option arguments [String] :system_version Version of the monitored system
#
# @see http://www.elastic.co/guide/en/monitoring/current/appendix-api-bulk.html
#
def bulk(arguments={})
raise ArgumentError, "Required argument 'body' missing" unless arguments[:body]
valid_params = [
:system_id,
:system_api_version,
:system_version,
:interval ]
arguments = arguments.clone
type = arguments.delete(:type)
body = arguments.delete(:body)
method = Elasticsearch::API::HTTP_POST
path = Elasticsearch::API::Utils.__pathify '_xpack/monitoring', type, '_bulk'
params = Elasticsearch::API::Utils.__validate_and_extract_params arguments, valid_params
if body.is_a? Array
payload = Elasticsearch::API::Utils.__bulkify(body)
else
payload = body
end
perform_request(method, path, params, payload).body
end
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems