Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
@elastic/elasticsearch
Advanced tools
@elastic/elasticsearch - npm Package Compare versions
Comparing version 7.15.0 to 7.16.0
@@ -26,4 +26,4 @@ /* | ||
| const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
| const acceptedQuerystring = ['analyzer', 'analyze_wildcard', 'default_operator', 'df', 'from', 'ignore_unavailable', 'allow_no_indices', 'conflicts', 'expand_wildcards', 'lenient', 'preference', 'q', 'routing', 'scroll', 'search_type', 'search_timeout', 'size', 'max_docs', 'sort', '_source', '_source_excludes', '_source_exclude', '_source_includes', '_source_include', 'terminate_after', 'stats', 'version', 'request_cache', 'refresh', 'timeout', 'wait_for_active_shards', 'scroll_size', 'wait_for_completion', 'requests_per_second', 'slices', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
| const snakeCase = { analyzeWildcard: 'analyze_wildcard', defaultOperator: 'default_operator', ignoreUnavailable: 'ignore_unavailable', allowNoIndices: 'allow_no_indices', expandWildcards: 'expand_wildcards', searchType: 'search_type', searchTimeout: 'search_timeout', maxDocs: 'max_docs', _sourceExcludes: '_source_excludes', _sourceExclude: '_source_exclude', _sourceIncludes: '_source_includes', _sourceInclude: '_source_include', terminateAfter: 'terminate_after', requestCache: 'request_cache', waitForActiveShards: 'wait_for_active_shards', scrollSize: 'scroll_size', waitForCompletion: 'wait_for_completion', requestsPerSecond: 'requests_per_second', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
| const acceptedQuerystring = ['analyzer', 'analyze_wildcard', 'default_operator', 'df', 'from', 'ignore_unavailable', 'allow_no_indices', 'conflicts', 'expand_wildcards', 'lenient', 'preference', 'q', 'routing', 'scroll', 'search_type', 'search_timeout', 'size', 'max_docs', 'sort', 'terminate_after', 'stats', 'version', 'request_cache', 'refresh', 'timeout', 'wait_for_active_shards', 'scroll_size', 'wait_for_completion', 'requests_per_second', 'slices', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
| const snakeCase = { analyzeWildcard: 'analyze_wildcard', defaultOperator: 'default_operator', ignoreUnavailable: 'ignore_unavailable', allowNoIndices: 'allow_no_indices', expandWildcards: 'expand_wildcards', searchType: 'search_type', searchTimeout: 'search_timeout', maxDocs: 'max_docs', terminateAfter: 'terminate_after', requestCache: 'request_cache', waitForActiveShards: 'wait_for_active_shards', scrollSize: 'scroll_size', waitForCompletion: 'wait_for_completion', requestsPerSecond: 'requests_per_second', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
@@ -30,0 +30,0 @@ function deleteByQueryApi (params, options, callback) { |
@@ -26,4 +26,4 @@ /* | ||
| const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
| const acceptedQuerystring = ['wait_for_advance', 'wait_for_index', 'checkpoints', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
| const snakeCase = { waitForAdvance: 'wait_for_advance', waitForIndex: 'wait_for_index', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
| const acceptedQuerystring = ['wait_for_advance', 'wait_for_index', 'checkpoints', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'wait_for_checkpoints', 'wait_for_checkpoints_timeout', 'allow_partial_search_results'] | ||
| const snakeCase = { waitForAdvance: 'wait_for_advance', waitForIndex: 'wait_for_index', errorTrace: 'error_trace', filterPath: 'filter_path', waitForCheckpoints: 'wait_for_checkpoints', waitForCheckpointsTimeout: 'wait_for_checkpoints_timeout', allowPartialSearchResults: 'allow_partial_search_results' } | ||
@@ -62,2 +62,61 @@ function FleetApi (transport, ConfigurationError) { | ||
| FleetApi.prototype.msearch = function fleetMsearchApi (params, options, callback) { | ||
| ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
| // check required parameters | ||
| if (params.body == null) { | ||
| const err = new this[kConfigurationError]('Missing required parameter: body') | ||
| return handleError(err, callback) | ||
| } | ||
| let { method, body, index, ...querystring } = params | ||
| querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
| let path = '' | ||
| if ((index) != null) { | ||
| if (method == null) method = body == null ? 'GET' : 'POST' | ||
| path = '/' + encodeURIComponent(index) + '/' + '_fleet' + '/' + '_fleet_msearch' | ||
| } else { | ||
| if (method == null) method = body == null ? 'GET' : 'POST' | ||
| path = '/' + '_fleet' + '/' + '_fleet_msearch' | ||
| } | ||
| // build request object | ||
| const request = { | ||
| method, | ||
| path, | ||
| bulkBody: body, | ||
| querystring | ||
| } | ||
| return this.transport.request(request, options, callback) | ||
| } | ||
| FleetApi.prototype.search = function fleetSearchApi (params, options, callback) { | ||
| ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
| // check required parameters | ||
| if (params.index == null) { | ||
| const err = new this[kConfigurationError]('Missing required parameter: index') | ||
| return handleError(err, callback) | ||
| } | ||
| let { method, body, index, ...querystring } = params | ||
| querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
| let path = '' | ||
| if (method == null) method = body == null ? 'GET' : 'POST' | ||
| path = '/' + encodeURIComponent(index) + '/' + '_fleet' + '/' + '_fleet_search' | ||
| // build request object | ||
| const request = { | ||
| method, | ||
| path, | ||
| body: body || '', | ||
| querystring | ||
| } | ||
| return this.transport.request(request, options, callback) | ||
| } | ||
| Object.defineProperties(FleetApi.prototype, { | ||
@@ -64,0 +123,0 @@ global_checkpoints: { get () { return this.globalCheckpoints } } |
@@ -1008,2 +1008,29 @@ /* | ||
| IndicesApi.prototype.modifyDataStream = function indicesModifyDataStreamApi (params, options, callback) { | ||
| ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
| // check required parameters | ||
| if (params.body == null) { | ||
| const err = new this[kConfigurationError]('Missing required parameter: body') | ||
| return handleError(err, callback) | ||
| } | ||
| let { method, body, ...querystring } = params | ||
| querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
| let path = '' | ||
| if (method == null) method = 'POST' | ||
| path = '/' + '_data_stream' + '/' + '_modify' | ||
| // build request object | ||
| const request = { | ||
| method, | ||
| path, | ||
| body: body || '', | ||
| querystring | ||
| } | ||
| return this.transport.request(request, options, callback) | ||
| } | ||
| IndicesApi.prototype.open = function indicesOpenApi (params, options, callback) { | ||
@@ -1739,2 +1766,3 @@ ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
| migrate_to_data_stream: { get () { return this.migrateToDataStream } }, | ||
| modify_data_stream: { get () { return this.modifyDataStream } }, | ||
| promote_data_stream: { get () { return this.promoteDataStream } }, | ||
@@ -1741,0 +1769,0 @@ put_alias: { get () { return this.putAlias } }, |
@@ -26,4 +26,4 @@ /* | ||
| const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
| const acceptedQuerystring = ['master_timeout', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'summary', 'verbose'] | ||
| const snakeCase = { masterTimeout: 'master_timeout', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
| const acceptedQuerystring = ['master_timeout', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'summary', 'if_version', 'verbose'] | ||
| const snakeCase = { masterTimeout: 'master_timeout', errorTrace: 'error_trace', filterPath: 'filter_path', ifVersion: 'if_version' } | ||
@@ -30,0 +30,0 @@ function IngestApi (transport, ConfigurationError) { |
@@ -60,2 +60,49 @@ /* | ||
| MigrationApi.prototype.getFeatureUpgradeStatus = function migrationGetFeatureUpgradeStatusApi (params, options, callback) { | ||
| ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
| let { method, body, ...querystring } = params | ||
| querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
| let path = '' | ||
| if (method == null) method = 'GET' | ||
| path = '/' + '_migration' + '/' + 'system_features' | ||
| // build request object | ||
| const request = { | ||
| method, | ||
| path, | ||
| body: null, | ||
| querystring | ||
| } | ||
| return this.transport.request(request, options, callback) | ||
| } | ||
| MigrationApi.prototype.postFeatureUpgrade = function migrationPostFeatureUpgradeApi (params, options, callback) { | ||
| ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
| let { method, body, ...querystring } = params | ||
| querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
| let path = '' | ||
| if (method == null) method = 'POST' | ||
| path = '/' + '_migration' + '/' + 'system_features' | ||
| // build request object | ||
| const request = { | ||
| method, | ||
| path, | ||
| body: body || '', | ||
| querystring | ||
| } | ||
| return this.transport.request(request, options, callback) | ||
| } | ||
| Object.defineProperties(MigrationApi.prototype, { | ||
| get_feature_upgrade_status: { get () { return this.getFeatureUpgradeStatus } }, | ||
| post_feature_upgrade: { get () { return this.postFeatureUpgrade } } | ||
| }) | ||
| module.exports = MigrationApi |
@@ -26,3 +26,3 @@ /* | ||
| const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
| const acceptedQuerystring = ['pretty', 'human', 'error_trace', 'source', 'filter_path', 'interval', 'snapshots', 'threads', 'ignore_idle_threads', 'type', 'timeout', 'flat_settings', 'completion_fields', 'fielddata_fields', 'fields', 'groups', 'level', 'types', 'include_segment_file_sizes', 'include_unloaded_segments'] | ||
| const acceptedQuerystring = ['pretty', 'human', 'error_trace', 'source', 'filter_path', 'interval', 'snapshots', 'threads', 'ignore_idle_threads', 'type', 'sort', 'timeout', 'flat_settings', 'completion_fields', 'fielddata_fields', 'fields', 'groups', 'level', 'types', 'include_segment_file_sizes', 'include_unloaded_segments'] | ||
| const snakeCase = { errorTrace: 'error_trace', filterPath: 'filter_path', ignoreIdleThreads: 'ignore_idle_threads', flatSettings: 'flat_settings', completionFields: 'completion_fields', fielddataFields: 'fielddata_fields', includeSegmentFileSizes: 'include_segment_file_sizes', includeUnloadedSegments: 'include_unloaded_segments' } | ||
@@ -29,0 +29,0 @@ |
@@ -37,2 +37,6 @@ /* | ||
| } | ||
| if (params.keep_alive == null && params.keepAlive == null) { | ||
| const err = new this[kConfigurationError]('Missing required parameter: keep_alive or keepAlive') | ||
| return handleError(err, callback) | ||
| } | ||
@@ -39,0 +43,0 @@ let { method, body, index, ...querystring } = params |
@@ -26,4 +26,4 @@ /* | ||
| const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
| const acceptedQuerystring = ['exact_bounds', 'extent', 'grid_precision', 'grid_type', 'size', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
| const snakeCase = { exactBounds: 'exact_bounds', gridPrecision: 'grid_precision', gridType: 'grid_type', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
| const acceptedQuerystring = ['exact_bounds', 'extent', 'grid_precision', 'grid_type', 'size', 'track_total_hits', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
| const snakeCase = { exactBounds: 'exact_bounds', gridPrecision: 'grid_precision', gridType: 'grid_type', trackTotalHits: 'track_total_hits', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
@@ -30,0 +30,0 @@ function searchMvtApi (params, options, callback) { |
@@ -26,4 +26,4 @@ /* | ||
| const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
| const acceptedQuerystring = ['force', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'from', 'size', 'allow_no_match', 'exclude_generated', 'defer_validation', 'timeout', 'wait_for_completion', 'wait_for_checkpoint'] | ||
| const snakeCase = { errorTrace: 'error_trace', filterPath: 'filter_path', allowNoMatch: 'allow_no_match', excludeGenerated: 'exclude_generated', deferValidation: 'defer_validation', waitForCompletion: 'wait_for_completion', waitForCheckpoint: 'wait_for_checkpoint' } | ||
| const acceptedQuerystring = ['force', 'timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'from', 'size', 'allow_no_match', 'exclude_generated', 'defer_validation', 'wait_for_completion', 'wait_for_checkpoint', 'dry_run'] | ||
| const snakeCase = { errorTrace: 'error_trace', filterPath: 'filter_path', allowNoMatch: 'allow_no_match', excludeGenerated: 'exclude_generated', deferValidation: 'defer_validation', waitForCompletion: 'wait_for_completion', waitForCheckpoint: 'wait_for_checkpoint', dryRun: 'dry_run' } | ||
@@ -118,14 +118,13 @@ function TransformApi (transport, ConfigurationError) { | ||
| // check required parameters | ||
| if (params.body == null) { | ||
| const err = new this[kConfigurationError]('Missing required parameter: body') | ||
| return handleError(err, callback) | ||
| } | ||
| let { method, body, ...querystring } = params | ||
| let { method, body, transformId, transform_id, ...querystring } = params | ||
| querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
| let path = '' | ||
| if (method == null) method = 'POST' | ||
| path = '/' + '_transform' + '/' + '_preview' | ||
| if ((transform_id || transformId) != null) { | ||
| if (method == null) method = body == null ? 'GET' : 'POST' | ||
| path = '/' + '_transform' + '/' + encodeURIComponent(transform_id || transformId) + '/' + '_preview' | ||
| } else { | ||
| if (method == null) method = body == null ? 'GET' : 'POST' | ||
| path = '/' + '_transform' + '/' + '_preview' | ||
| } | ||
@@ -259,2 +258,23 @@ // build request object | ||
| TransformApi.prototype.upgradeTransforms = function transformUpgradeTransformsApi (params, options, callback) { | ||
| ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
| let { method, body, ...querystring } = params | ||
| querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
| let path = '' | ||
| if (method == null) method = 'POST' | ||
| path = '/' + '_transform' + '/' + '_upgrade' | ||
| // build request object | ||
| const request = { | ||
| method, | ||
| path, | ||
| body: body || '', | ||
| querystring | ||
| } | ||
| return this.transport.request(request, options, callback) | ||
| } | ||
| Object.defineProperties(TransformApi.prototype, { | ||
@@ -268,5 +288,6 @@ delete_transform: { get () { return this.deleteTransform } }, | ||
| stop_transform: { get () { return this.stopTransform } }, | ||
| update_transform: { get () { return this.updateTransform } } | ||
| update_transform: { get () { return this.updateTransform } }, | ||
| upgrade_transforms: { get () { return this.upgradeTransforms } } | ||
| }) | ||
| module.exports = TransformApi |
@@ -26,4 +26,4 @@ /* | ||
| const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
| const acceptedQuerystring = ['analyzer', 'analyze_wildcard', 'default_operator', 'df', 'from', 'ignore_unavailable', 'allow_no_indices', 'conflicts', 'expand_wildcards', 'lenient', 'pipeline', 'preference', 'q', 'routing', 'scroll', 'search_type', 'search_timeout', 'size', 'max_docs', 'sort', '_source', '_source_excludes', '_source_exclude', '_source_includes', '_source_include', 'terminate_after', 'stats', 'version', 'version_type', 'request_cache', 'refresh', 'timeout', 'wait_for_active_shards', 'scroll_size', 'wait_for_completion', 'requests_per_second', 'slices', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
| const snakeCase = { analyzeWildcard: 'analyze_wildcard', defaultOperator: 'default_operator', ignoreUnavailable: 'ignore_unavailable', allowNoIndices: 'allow_no_indices', expandWildcards: 'expand_wildcards', searchType: 'search_type', searchTimeout: 'search_timeout', maxDocs: 'max_docs', _sourceExcludes: '_source_excludes', _sourceExclude: '_source_exclude', _sourceIncludes: '_source_includes', _sourceInclude: '_source_include', terminateAfter: 'terminate_after', versionType: 'version_type', requestCache: 'request_cache', waitForActiveShards: 'wait_for_active_shards', scrollSize: 'scroll_size', waitForCompletion: 'wait_for_completion', requestsPerSecond: 'requests_per_second', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
| const acceptedQuerystring = ['analyzer', 'analyze_wildcard', 'default_operator', 'df', 'from', 'ignore_unavailable', 'allow_no_indices', 'conflicts', 'expand_wildcards', 'lenient', 'pipeline', 'preference', 'q', 'routing', 'scroll', 'search_type', 'search_timeout', 'size', 'max_docs', 'sort', 'terminate_after', 'stats', 'version', 'version_type', 'request_cache', 'refresh', 'timeout', 'wait_for_active_shards', 'scroll_size', 'wait_for_completion', 'requests_per_second', 'slices', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
| const snakeCase = { analyzeWildcard: 'analyze_wildcard', defaultOperator: 'default_operator', ignoreUnavailable: 'ignore_unavailable', allowNoIndices: 'allow_no_indices', expandWildcards: 'expand_wildcards', searchType: 'search_type', searchTimeout: 'search_timeout', maxDocs: 'max_docs', terminateAfter: 'terminate_after', versionType: 'version_type', requestCache: 'request_cache', waitForActiveShards: 'wait_for_active_shards', scrollSize: 'scroll_size', waitForCompletion: 'wait_for_completion', requestsPerSecond: 'requests_per_second', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
@@ -30,0 +30,0 @@ function updateByQueryApi (params, options, callback) { |
17
index.js
@@ -24,2 +24,3 @@ /* | ||
| const { URL } = require('url') | ||
| const buffer = require('buffer') | ||
| const debug = require('debug')('elasticsearch') | ||
@@ -118,5 +119,15 @@ const Transport = require('./lib/Transport') | ||
| enableMetaHeader: true, | ||
| disablePrototypePoisoningProtection: false | ||
| disablePrototypePoisoningProtection: false, | ||
| maxResponseSize: null, | ||
| maxCompressedResponseSize: null | ||
| }, opts) | ||
| if (options.maxResponseSize !== null && options.maxResponseSize > buffer.constants.MAX_STRING_LENGTH) { | ||
| throw new ConfigurationError(`The maxResponseSize cannot be bigger than ${buffer.constants.MAX_STRING_LENGTH}`) | ||
| } | ||
| if (options.maxCompressedResponseSize !== null && options.maxCompressedResponseSize > buffer.constants.MAX_LENGTH) { | ||
| throw new ConfigurationError(`The maxCompressedResponseSize cannot be bigger than ${buffer.constants.MAX_LENGTH}`) | ||
| } | ||
| if (options.caFingerprint !== null && isHttpConnection(opts.node || opts.nodes)) { | ||
@@ -183,3 +194,5 @@ throw new ConfigurationError('You can\'t configure the caFingerprint with a http connection') | ||
| opaqueIdPrefix: options.opaqueIdPrefix, | ||
| context: options.context | ||
| context: options.context, | ||
| maxResponseSize: options.maxResponseSize, | ||
| maxCompressedResponseSize: options.maxCompressedResponseSize | ||
| }) | ||
@@ -186,0 +199,0 @@ |
@@ -116,3 +116,10 @@ /* | ||
| this._openRequests-- | ||
| callback(new ConnectionError(err.message), null) | ||
| let message = err.message | ||
| if (err.code === 'ECONNRESET') { | ||
| /* istanbul ignore next */ | ||
| const socket = request.socket || {} | ||
| /* istanbul ignore next */ | ||
| message += ` - Local: ${socket.localAddress || 'unknown'}:${socket.localPort || 'unknown'}, Remote: ${socket.remoteAddress || 'unknown'}:${socket.remotePort || 'unknown'}` | ||
| } | ||
| callback(new ConnectionError(message), null) | ||
| } | ||
@@ -119,0 +126,0 @@ |
@@ -64,2 +64,4 @@ /* | ||
| opaqueIdPrefix?: string; | ||
| maxResponseSize?: number; | ||
| maxCompressedResponseSize?: number; | ||
| } | ||
@@ -117,2 +119,4 @@ | ||
| opaqueId?: string; | ||
| maxResponseSize?: number; | ||
| maxCompressedResponseSize?: number; | ||
| } | ||
@@ -119,0 +123,0 @@ |
@@ -46,2 +46,4 @@ /* | ||
| const kEventEmitter = Symbol('event emitter') | ||
| const kMaxResponseSize = Symbol('max response size') | ||
| const kMaxCompressedResponseSize = Symbol('max compressed response size') | ||
@@ -76,2 +78,4 @@ class Transport { | ||
| this[kEventEmitter] = new EventEmitter() | ||
| this[kMaxResponseSize] = opts.maxResponseSize || MAX_STRING_LENGTH | ||
| this[kMaxCompressedResponseSize] = opts.maxCompressedResponseSize || MAX_BUFFER_LENGTH | ||
@@ -167,9 +171,15 @@ this.nodeFilter = opts.nodeFilter || defaultNodeFilter | ||
| const compression = options.compression !== undefined ? options.compression : this.compression | ||
| const maxResponseSize = options.maxResponseSize || this[kMaxResponseSize] | ||
| const maxCompressedResponseSize = options.maxCompressedResponseSize || this[kMaxCompressedResponseSize] | ||
| let request = { abort: noop } | ||
| const transportReturn = { | ||
| then (onFulfilled, onRejected) { | ||
| return p.then(onFulfilled, onRejected) | ||
| if (p != null) { | ||
| return p.then(onFulfilled, onRejected) | ||
| } | ||
| }, | ||
| catch (onRejected) { | ||
| return p.catch(onRejected) | ||
| if (p != null) { | ||
| return p.catch(onRejected) | ||
| } | ||
| }, | ||
@@ -183,3 +193,5 @@ abort () { | ||
| finally (onFinally) { | ||
| return p.finally(onFinally) | ||
| if (p != null) { | ||
| return p.finally(onFinally) | ||
| } | ||
| } | ||
@@ -251,11 +263,11 @@ } | ||
| const contentLength = Number(result.headers['content-length']) | ||
| if (isCompressed && contentLength > MAX_BUFFER_LENGTH) { | ||
| if (isCompressed && contentLength > maxCompressedResponseSize) { | ||
| response.destroy() | ||
| return onConnectionError( | ||
| new RequestAbortedError(`The content length (${contentLength}) is bigger than the maximum allowed buffer (${MAX_BUFFER_LENGTH})`, result) | ||
| new RequestAbortedError(`The content length (${contentLength}) is bigger than the maximum allowed buffer (${maxCompressedResponseSize})`, result) | ||
| ) | ||
| } else if (contentLength > MAX_STRING_LENGTH) { | ||
| } else if (contentLength > maxResponseSize) { | ||
| response.destroy() | ||
| return onConnectionError( | ||
| new RequestAbortedError(`The content length (${contentLength}) is bigger than the maximum allowed string (${MAX_STRING_LENGTH})`, result) | ||
| new RequestAbortedError(`The content length (${contentLength}) is bigger than the maximum allowed string (${maxResponseSize})`, result) | ||
| ) | ||
@@ -262,0 +274,0 @@ } |
@@ -11,7 +11,7 @@ { | ||
| }, | ||
| "./": "./" | ||
| "./*": "./*.js" | ||
| }, | ||
| "homepage": "http://www.elastic.co/guide/en/elasticsearch/client/javascript-api/current/index.html", | ||
| "version": "7.15.0", | ||
| "versionCanary": "7.15.0-canary.3", | ||
| "version": "7.16.0", | ||
| "versionCanary": "7.16.0-canary.7", | ||
| "keywords": [ | ||
@@ -18,0 +18,0 @@ "elasticsearch", |
@@ -31,3 +31,3 @@ <img align="right" width="auto" height="auto" src="https://www.elastic.co/static-res/images/elastic-logo-200.png"> | ||
| NOTE: The minimum supported version of Node.js is `v10`. | ||
| NOTE: The minimum supported version of Node.js is `v12`. | ||
@@ -53,9 +53,9 @@ The client versioning follows the Elastc Stack versioning, this means that | ||
| | --------------- |------------------| ---------------------- | | ||
| | `8.x` | `December 2019` | `7.11` (early 2021) | | ||
| | `10.x` | `Apri 2021` | `7.12` (mid 2021) | | ||
| | `8.x` | `December 2019` | `7.11` (early 2021) | | ||
| | `10.x` | `April 2021` | `7.12` (mid 2021) | | ||
| ### Compatibility | ||
| Language clients are forward compatible; meaning that clients support communicating with greater minor versions of Elasticsearch. | ||
| Elastic language clients are also backwards compatible with lesser supported minor Elasticsearch versions. | ||
| Language clients are forward compatible; meaning that clients support communicating with greater or equal minor versions of Elasticsearch. | ||
| Elasticsearch language clients are only backwards compatible with default distributions and without guarantees made. | ||
@@ -62,0 +62,0 @@ | Elasticsearch Version | Client Version | |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
- increased by2.2%
1958492
- Lines of code
- increased by1.93%
36460
No dependency changes