habsi/elasticsearch-js
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v7.0.0-rc1 support 🚀 (#792)

Browse Source 
Support for Elasticsearch `v7.0.0-rc1`
This commit is contained in:
Tomas Della Vedova
2019-03-28 08:32:24 +01:00
committed by GitHub
parent c7675708de
commit 1f6c68df9c
264 changed files with 733 additions and 3156 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
.ci/test-matrix.yml
View File

@ -1,6 +1,6 @@
---
ELASTICSEARCH_VERSION:
- 7.0.0-beta1
- 7.0.0-rc1
NODE_JS_VERSION:
- 11

2
.travis.yml
View File

@ -11,7 +11,7 @@ node_js:
env:
global:
- ELASTICSEARCH_VERSION=7.0.0-beta1
- ELASTICSEARCH_VERSION=7.0.0-rc1
- QUIET=true
before_install:

9
api/api/bulk.js
View File

@ -79,15 +79,6 @@ function buildBulk (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
bulk(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['body'] == null) {
const err = new ConfigurationError('Missing required parameter: body')

9
api/api/cat.aliases.js
View File

@ -71,15 +71,6 @@ function buildCatAliases (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catAliases(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.allocation.js
View File

@ -73,15 +73,6 @@ function buildCatAllocation (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catAllocation(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.count.js
View File

@ -71,15 +71,6 @@ function buildCatCount (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catCount(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.fielddata.js
View File

@ -75,15 +75,6 @@ function buildCatFielddata (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catFielddata(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.health.js
View File

@ -72,15 +72,6 @@ function buildCatHealth (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catHealth(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.help.js
View File

@ -59,15 +59,6 @@ function buildCatHelp (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catHelp(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.indices.js
View File

@ -77,15 +77,6 @@ function buildCatIndices (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catIndices(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.master.js
View File

@ -70,15 +70,6 @@ function buildCatMaster (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catMaster(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.nodeattrs.js
View File

@ -70,15 +70,6 @@ function buildCatNodeattrs (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catNodeattrs(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.nodes.js
View File

@ -73,15 +73,6 @@ function buildCatNodes (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catNodes(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.pending_tasks.js
View File

@ -70,15 +70,6 @@ function buildCatPendingTasks (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catPendingTasks(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.plugins.js
View File

@ -70,15 +70,6 @@ function buildCatPlugins (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catPlugins(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.recovery.js
View File

@ -71,15 +71,6 @@ function buildCatRecovery (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catRecovery(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.repositories.js
View File

@ -70,15 +70,6 @@ function buildCatRepositories (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catRepositories(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.segments.js
View File

@ -68,15 +68,6 @@ function buildCatSegments (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catSegments(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.shards.js
View File

@ -73,15 +73,6 @@ function buildCatShards (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catShards(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.snapshots.js
View File

@ -72,15 +72,6 @@ function buildCatSnapshots (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catSnapshots(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.tasks.js
View File

@ -75,15 +75,6 @@ function buildCatTasks (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catTasks(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.templates.js
View File

@ -71,15 +71,6 @@ function buildCatTemplates (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catTemplates(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cat.thread_pool.js
View File

@ -73,15 +73,6 @@ function buildCatThreadPool (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
catThreadPool(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/ccr.delete_auto_follow_pattern.js
View File

@ -51,15 +51,6 @@ function buildCcrDeleteAutoFollowPattern (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrDeleteAutoFollowPattern(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['name'] == null) {
const err = new ConfigurationError('Missing required parameter: name')

9
api/api/ccr.follow.js
View File

@ -53,15 +53,6 @@ function buildCcrFollow (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrFollow(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/ccr.follow_info.js
View File

@ -51,15 +51,6 @@ function buildCcrFollowInfo (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrFollowInfo(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

11
api/api/ccr.follow_stats.js
View File

@ -51,13 +51,10 @@ function buildCcrFollowStats (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrFollowStats(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')
return handleError(err, callback)
}
// validate headers object

31
api/api/xpack.migration.upgrade.js → api/api/ccr.forget_follower.js
View File

@ -22,25 +22,25 @@
/* eslint camelcase: 0 */
/* eslint no-unused-vars: 0 */
function buildXpackMigrationUpgrade (opts) {
function buildCcrForgetFollower (opts) {
// eslint-disable-next-line no-unused-vars
const { makeRequest, ConfigurationError, handleError } = opts
/**
* Perform a [xpack.migration.upgrade](https://www.elastic.co/guide/en/elasticsearch/reference/current/migration-api-upgrade.html) request
* Perform a [ccr.forget_follower](http://www.elastic.co/guide/en/elasticsearch/reference/current) request
*
* @param {string} index - The name of the index
* @param {boolean} wait_for_completion - Should the request block until the upgrade operation is completed
* @param {string} index - the name of the leader index for which specified follower retention leases should be removed
* @param {object} body - the name and UUID of the follower index, the name of the cluster containing the follower index, and the alias from the perspective of that cluster for the remote cluster containing the leader index
*/
const acceptedQuerystring = [
'wait_for_completion'
]
const snakeCase = {
waitForCompletion: 'wait_for_completion'
}
return function xpackMigrationUpgrade (params, options, callback) {
return function ccrForgetFollower (params, options, callback) {
options = options || {}
if (typeof options === 'function') {
callback = options
@ -52,20 +52,15 @@ function buildXpackMigrationUpgrade (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
xpackMigrationUpgrade(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')
return handleError(err, callback)
}
if (params['body'] == null) {
const err = new ConfigurationError('Missing required parameter: body')
return handleError(err, callback)
}
// validate headers object
if (options.headers != null && typeof options.headers !== 'object') {
@ -88,7 +83,7 @@ function buildXpackMigrationUpgrade (opts) {
var path = ''
path = '/' + '_migration' + '/' + 'upgrade' + '/' + encodeURIComponent(index)
path = '/' + encodeURIComponent(index) + '/' + '_ccr' + '/' + 'forget_follower'
// build request object
const request = {
@ -129,4 +124,4 @@ function buildXpackMigrationUpgrade (opts) {
}
}
module.exports = buildXpackMigrationUpgrade
module.exports = buildCcrForgetFollower

9
api/api/ccr.get_auto_follow_pattern.js
View File

@ -51,15 +51,6 @@ function buildCcrGetAutoFollowPattern (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrGetAutoFollowPattern(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/ccr.pause_follow.js
View File

@ -51,15 +51,6 @@ function buildCcrPauseFollow (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrPauseFollow(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/ccr.put_auto_follow_pattern.js
View File

@ -52,15 +52,6 @@ function buildCcrPutAutoFollowPattern (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrPutAutoFollowPattern(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['name'] == null) {
const err = new ConfigurationError('Missing required parameter: name')

9
api/api/ccr.resume_follow.js
View File

@ -52,15 +52,6 @@ function buildCcrResumeFollow (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrResumeFollow(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/ccr.stats.js
View File

@ -50,15 +50,6 @@ function buildCcrStats (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrStats(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/ccr.unfollow.js
View File

@ -51,15 +51,6 @@ function buildCcrUnfollow (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ccrUnfollow(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/clear_scroll.js
View File

@ -57,15 +57,6 @@ function buildClearScroll (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clearScroll(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/cluster.allocation_explain.js
View File

@ -62,15 +62,6 @@ function buildClusterAllocationExplain (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterAllocationExplain(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/cluster.get_settings.js
View File

@ -66,15 +66,6 @@ function buildClusterGetSettings (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterGetSettings(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cluster.health.js
View File

@ -83,15 +83,6 @@ function buildClusterHealth (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterHealth(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cluster.pending_tasks.js
View File

@ -60,15 +60,6 @@ function buildClusterPendingTasks (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterPendingTasks(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cluster.put_settings.js
View File

@ -64,15 +64,6 @@ function buildClusterPutSettings (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterPutSettings(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['body'] == null) {
const err = new ConfigurationError('Missing required parameter: body')

9
api/api/cluster.remote_info.js
View File

@ -55,15 +55,6 @@ function buildClusterRemoteInfo (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterRemoteInfo(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cluster.reroute.js
View File

@ -71,15 +71,6 @@ function buildClusterReroute (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterReroute(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/cluster.state.js
View File

@ -80,15 +80,6 @@ function buildClusterState (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterState(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/cluster.stats.js
View File

@ -61,15 +61,6 @@ function buildClusterStats (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
clusterStats(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/count.js
View File

@ -94,15 +94,6 @@ function buildCount (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
count(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required url components
if (params['type'] != null && (params['index'] == null)) {
const err = new ConfigurationError('Missing required parameter of the url: index')

9
api/api/create.js
View File

@ -77,15 +77,6 @@ function buildCreate (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
create(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/delete.js
View File

@ -80,15 +80,6 @@ function buildDelete (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
_delete(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/delete_by_query.js
View File

@ -137,15 +137,6 @@ function buildDeleteByQuery (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
deleteByQuery(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/delete_by_query_rethrottle.js
View File

@ -59,15 +59,6 @@ function buildDeleteByQueryRethrottle (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
deleteByQueryRethrottle(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['task_id'] == null && params['taskId'] == null) {
const err = new ConfigurationError('Missing required parameter: task_id or taskId')

9
api/api/delete_script.js
View File

@ -61,15 +61,6 @@ function buildDeleteScript (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
deleteScript(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/exists.js
View File

@ -84,15 +84,6 @@ function buildExists (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
exists(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/exists_source.js
View File

@ -81,15 +81,6 @@ function buildExistsSource (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
existsSource(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/explain.js
View File

@ -90,15 +90,6 @@ function buildExplain (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
explain(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/field_caps.js
View File

@ -67,15 +67,6 @@ function buildFieldCaps (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
fieldCaps(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/get.js
View File

@ -90,15 +90,6 @@ function buildGet (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
get(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/get_script.js
View File

@ -59,15 +59,6 @@ function buildGetScript (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
getScript(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

9
api/api/get_source.js
View File

@ -81,15 +81,6 @@ function buildGetSource (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
getSource(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['id'] == null) {
const err = new ConfigurationError('Missing required parameter: id')

17
api/api/xpack.graph.explore.js → api/api/graph.explore.js
View File

@ -22,11 +22,11 @@
/* eslint camelcase: 0 */
/* eslint no-unused-vars: 0 */
function buildXpackGraphExplore (opts) {
function buildGraphExplore (opts) {
// eslint-disable-next-line no-unused-vars
const { makeRequest, ConfigurationError, handleError } = opts
/**
* Perform a [xpack.graph.explore](https://www.elastic.co/guide/en/elasticsearch/reference/current/graph-explore-api.html) request
* Perform a [graph.explore](https://www.elastic.co/guide/en/elasticsearch/reference/current/graph-explore-api.html) request
*
* @param {list} index - A comma-separated list of index names to search; use `_all` or empty string to perform the operation on all indices
* @param {list} type - A comma-separated list of document types to search; leave empty to perform the operation on all types
@ -44,7 +44,7 @@ function buildXpackGraphExplore (opts) {
}
return function xpackGraphExplore (params, options, callback) {
return function graphExplore (params, options, callback) {
options = options || {}
if (typeof options === 'function') {
callback = options
@ -56,15 +56,6 @@ function buildXpackGraphExplore (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
xpackGraphExplore(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required url components
if (params['type'] != null && (params['index'] == null)) {
const err = new ConfigurationError('Missing required parameter of the url: index')
@ -137,4 +128,4 @@ function buildXpackGraphExplore (opts) {
}
}
module.exports = buildXpackGraphExplore
module.exports = buildGraphExplore

9
api/api/ilm.delete_lifecycle.js
View File

@ -51,15 +51,6 @@ function buildIlmDeleteLifecycle (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmDeleteLifecycle(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

12
api/api/ilm.explain_lifecycle.js
View File

@ -29,11 +29,10 @@ function buildIlmExplainLifecycle (opts) {
* Perform a [ilm.explain_lifecycle](https://www.elastic.co/guide/en/elasticsearch/reference/current/ilm-explain-lifecycle.html) request
*
* @param {string} index - The name of the index to explain
* @param {boolean} human - Return data such as dates in a human readable format
*/
const acceptedQuerystring = [
'human'
]
const snakeCase = {
@ -52,15 +51,6 @@ function buildIlmExplainLifecycle (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmExplainLifecycle(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/ilm.get_lifecycle.js
View File

@ -51,15 +51,6 @@ function buildIlmGetLifecycle (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmGetLifecycle(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/ilm.get_status.js
View File

@ -50,15 +50,6 @@ function buildIlmGetStatus (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmGetStatus(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/ilm.move_to_step.js
View File

@ -52,15 +52,6 @@ function buildIlmMoveToStep (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmMoveToStep(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/ilm.put_lifecycle.js
View File

@ -52,15 +52,6 @@ function buildIlmPutLifecycle (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmPutLifecycle(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/ilm.remove_policy.js
View File

@ -51,15 +51,6 @@ function buildIlmRemovePolicy (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmRemovePolicy(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/ilm.retry.js
View File

@ -51,15 +51,6 @@ function buildIlmRetry (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmRetry(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/ilm.start.js
View File

@ -50,15 +50,6 @@ function buildIlmStart (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmStart(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/ilm.stop.js
View File

@ -50,15 +50,6 @@ function buildIlmStop (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
ilmStop(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/index.js
View File

@ -86,15 +86,6 @@ function buildIndex (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
_index(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.analyze.js
View File

@ -59,15 +59,6 @@ function buildIndicesAnalyze (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesAnalyze(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// 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}`)

9
api/api/indices.clear_cache.js
View File

@ -75,15 +75,6 @@ function buildIndicesClearCache (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesClearCache(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.close.js
View File

@ -70,15 +70,6 @@ function buildIndicesClose (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesClose(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.create.js
View File

@ -68,15 +68,6 @@ function buildIndicesCreate (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesCreate(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.delete.js
View File

@ -70,15 +70,6 @@ function buildIndicesDelete (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesDelete(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.delete_alias.js
View File

@ -62,15 +62,6 @@ function buildIndicesDeleteAlias (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesDeleteAlias(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.delete_template.js
View File

@ -61,15 +61,6 @@ function buildIndicesDeleteTemplate (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesDeleteTemplate(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['name'] == null) {
const err = new ConfigurationError('Missing required parameter: name')

9
api/api/indices.exists.js
View File

@ -73,15 +73,6 @@ function buildIndicesExists (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesExists(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.exists_alias.js
View File

@ -68,15 +68,6 @@ function buildIndicesExistsAlias (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesExistsAlias(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['name'] == null) {
const err = new ConfigurationError('Missing required parameter: name')

9
api/api/indices.exists_template.js
View File

@ -64,15 +64,6 @@ function buildIndicesExistsTemplate (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesExistsTemplate(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['name'] == null) {
const err = new ConfigurationError('Missing required parameter: name')

9
api/api/indices.exists_type.js
View File

@ -68,15 +68,6 @@ function buildIndicesExistsType (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesExistsType(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.flush.js
View File

@ -70,15 +70,6 @@ function buildIndicesFlush (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesFlush(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.flush_synced.js
View File

@ -65,15 +65,6 @@ function buildIndicesFlushSynced (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesFlushSynced(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.forcemerge.js
View File

@ -73,15 +73,6 @@ function buildIndicesForcemerge (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesForcemerge(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.freeze.js
View File

@ -66,15 +66,6 @@ function buildIndicesFreeze (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesFreeze(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.get.js
View File

@ -79,15 +79,6 @@ function buildIndicesGet (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesGet(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.get_alias.js
View File

@ -68,15 +68,6 @@ function buildIndicesGetAlias (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesGetAlias(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.get_field_mapping.js
View File

@ -75,15 +75,6 @@ function buildIndicesGetFieldMapping (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesGetFieldMapping(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['fields'] == null) {
const err = new ConfigurationError('Missing required parameter: fields')

9
api/api/indices.get_mapping.js
View File

@ -74,15 +74,6 @@ function buildIndicesGetMapping (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesGetMapping(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.get_settings.js
View File

@ -77,15 +77,6 @@ function buildIndicesGetSettings (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesGetSettings(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.get_template.js
View File

@ -67,15 +67,6 @@ function buildIndicesGetTemplate (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesGetTemplate(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.get_upgrade.js
View File

@ -65,15 +65,6 @@ function buildIndicesGetUpgrade (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesGetUpgrade(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.open.js
View File

@ -73,15 +73,6 @@ function buildIndicesOpen (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesOpen(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.put_alias.js
View File

@ -63,15 +63,6 @@ function buildIndicesPutAlias (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesPutAlias(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['index'] == null) {
const err = new ConfigurationError('Missing required parameter: index')

9
api/api/indices.put_mapping.js
View File

@ -75,15 +75,6 @@ function buildIndicesPutMapping (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesPutMapping(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['body'] == null) {
const err = new ConfigurationError('Missing required parameter: body')

9
api/api/indices.put_settings.js
View File

@ -77,15 +77,6 @@ function buildIndicesPutSettings (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesPutSettings(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['body'] == null) {
const err = new ConfigurationError('Missing required parameter: body')

9
api/api/indices.put_template.js
View File

@ -72,15 +72,6 @@ function buildIndicesPutTemplate (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesPutTemplate(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['name'] == null) {
const err = new ConfigurationError('Missing required parameter: name')

9
api/api/indices.recovery.js
View File

@ -61,15 +61,6 @@ function buildIndicesRecovery (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesRecovery(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.refresh.js
View File

@ -65,15 +65,6 @@ function buildIndicesRefresh (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesRefresh(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

9
api/api/indices.rollover.js
View File

@ -72,15 +72,6 @@ function buildIndicesRollover (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesRollover(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params['alias'] == null) {
const err = new ConfigurationError('Missing required parameter: alias')

9
api/api/indices.segments.js
View File

@ -67,15 +67,6 @@ function buildIndicesSegments (opts) {
options = {}
}
// promises support
if (callback == null) {
return new Promise((resolve, reject) => {
indicesSegments(params, options, (err, body) => {
err ? reject(err) : resolve(body)
})
})
}
// check required parameters
if (params.body != null) {
const err = new ConfigurationError('This API does not require a body')

Some files were not shown because too many files have changed in this diff Show More