/* * Licensed to Elasticsearch B.V. under one or more contributor * license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright * ownership. Elasticsearch B.V. licenses this file to you under * the Apache License, Version 2.0 (the "License"); you may * not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. */ 'use strict' /* eslint camelcase: 0 */ /* eslint no-unused-vars: 0 */ function buildCatMaster (opts) { // eslint-disable-next-line no-unused-vars const { makeRequest, ConfigurationError, handleError } = opts /** * Perform a [cat.master](https://www.elastic.co/guide/en/elasticsearch/reference/5.x/cat-master.html) request * * @param {string} format - a short version of the Accept header, e.g. json, yaml * @param {boolean} local - Return local information, do not retrieve the state from master node (default: false) * @param {time} master_timeout - Explicit operation timeout for connection to master node * @param {list} h - Comma-separated list of column names to display * @param {boolean} help - Return help information * @param {list} s - Comma-separated list of column names or column aliases to sort by * @param {boolean} v - Verbose mode. Display column headers */ const acceptedQuerystring = [ 'format', 'local', 'master_timeout', 'h', 'help', 's', 'v', 'pretty', 'human', 'error_trace', 'source', 'filter_path' ] const snakeCase = { masterTimeout: 'master_timeout', errorTrace: 'error_trace', filterPath: 'filter_path' } return function catMaster (params, options, callback) { options = options || {} if (typeof options === 'function') { callback = options options = {} } if (typeof params === 'function' || params == null) { callback = params params = {} options = {} } // check required parameters if (params.body != null) { const err = new ConfigurationError('This API does not require a body') return handleError(err, callback) } // validate headers object if (options.headers != null && typeof options.headers !== 'object') { const err = new ConfigurationError(`Headers should be an object, instead got: ${typeof options.headers}`) return handleError(err, callback) } var warnings = null var { method, body } = params var querystring = semicopy(params, ['method', 'body']) if (method == null) { method = 'GET' } var ignore = options.ignore || null if (typeof ignore === 'number') { ignore = [ignore] } var path = '' path = '/' + '_cat' + '/' + 'master' // build request object const request = { method, path, body: null, querystring } const requestOptions = { ignore, requestTimeout: options.requestTimeout || null, maxRetries: options.maxRetries || null, asStream: options.asStream || false, headers: options.headers || null, querystring: options.querystring || null, compression: options.compression || false, warnings } return makeRequest(request, requestOptions, callback) function semicopy (obj, exclude) { var target = {} var keys = Object.keys(obj) for (var i = 0, len = keys.length; i < len; i++) { var key = keys[i] if (exclude.indexOf(key) === -1) { target[snakeCase[key] || key] = obj[key] if (acceptedQuerystring.indexOf(snakeCase[key] || key) === -1) { warnings = warnings || [] warnings.push('Client - Unknown parameter: "' + key + '", sending it as query parameter') } } } return target } } } module.exports = buildCatMaster