Sha256: 7ff2e96168711c96adc15c3e93c8ad0d4195ec90d18a245969de8abfa6e82ddd
Contents?: true
Size: 1.85 KB
Versions: 3
Compression:
Stored size: 1.85 KB
Contents
# Licensed to Elasticsearch B.V under one or more agreements. # Elasticsearch B.V licenses this file to you under the Apache 2.0 License. # See the LICENSE file in the project root for more information 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
3 entries across 3 versions & 1 rubygems