@elastic/elasticsearch-canary
Advanced tools
Comparing version 8.0.0-canary.1 to 8.0.0-canary.2
@@ -26,4 +26,4 @@ /* | ||
const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
const acceptedQuerystring = ['format', 'local', 'h', 'help', 's', 'v', 'expand_wildcards', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'bytes', 'master_timeout', 'fields', 'time', 'ts', 'health', 'pri', 'include_unloaded_segments', 'full_id', 'active_only', 'detailed', 'index', 'ignore_unavailable', 'node_id', 'actions', 'parent_task', 'allow_no_match', 'allow_no_datafeeds', 'allow_no_jobs', 'from', 'size'] | ||
const snakeCase = { expandWildcards: 'expand_wildcards', errorTrace: 'error_trace', filterPath: 'filter_path', masterTimeout: 'master_timeout', includeUnloadedSegments: 'include_unloaded_segments', fullId: 'full_id', activeOnly: 'active_only', ignoreUnavailable: 'ignore_unavailable', nodeId: 'node_id', parentTask: 'parent_task', allowNoMatch: 'allow_no_match', allowNoDatafeeds: 'allow_no_datafeeds', allowNoJobs: 'allow_no_jobs' } | ||
const acceptedQuerystring = ['format', 'local', 'h', 'help', 's', 'v', 'expand_wildcards', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'bytes', 'master_timeout', 'fields', 'time', 'ts', 'health', 'pri', 'include_unloaded_segments', 'full_id', 'include_bootstrap', 'active_only', 'detailed', 'index', 'ignore_unavailable', 'nodes', 'actions', 'parent_task_id', 'allow_no_match', 'allow_no_datafeeds', 'allow_no_jobs', 'from', 'size'] | ||
const snakeCase = { expandWildcards: 'expand_wildcards', errorTrace: 'error_trace', filterPath: 'filter_path', masterTimeout: 'master_timeout', includeUnloadedSegments: 'include_unloaded_segments', fullId: 'full_id', includeBootstrap: 'include_bootstrap', activeOnly: 'active_only', ignoreUnavailable: 'ignore_unavailable', parentTaskId: 'parent_task_id', allowNoMatch: 'allow_no_match', allowNoDatafeeds: 'allow_no_datafeeds', allowNoJobs: 'allow_no_jobs' } | ||
@@ -30,0 +30,0 @@ function CatApi (transport, ConfigurationError) { |
@@ -88,2 +88,29 @@ /* | ||
EqlApi.prototype.getStatus = function eqlGetStatusApi (params, options, callback) { | ||
;[params, options, callback] = normalizeArguments(params, options, callback) | ||
// check required parameters | ||
if (params['id'] == null) { | ||
const err = new this[kConfigurationError]('Missing required parameter: id') | ||
return handleError(err, callback) | ||
} | ||
var { method, body, id, ...querystring } = params | ||
querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
var path = '' | ||
if (method == null) method = 'GET' | ||
path = '/' + '_eql' + '/' + 'search' + '/' + 'status' + '/' + encodeURIComponent(id) | ||
// build request object | ||
const request = { | ||
method, | ||
path, | ||
body: null, | ||
querystring | ||
} | ||
return this.transport.request(request, options, callback) | ||
} | ||
EqlApi.prototype.search = function eqlSearchApi (params, options, callback) { | ||
@@ -120,2 +147,6 @@ ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
Object.defineProperties(EqlApi.prototype, { | ||
get_status: { get () { return this.getStatus } } | ||
}) | ||
module.exports = EqlApi |
@@ -179,2 +179,6 @@ /* | ||
} | ||
if (params['rollup_index'] == null && params['rollupIndex'] == null) { | ||
const err = new this[kConfigurationError]('Missing required parameter: rollup_index or rollupIndex') | ||
return handleError(err, callback) | ||
} | ||
if (params['body'] == null) { | ||
@@ -185,3 +189,9 @@ const err = new this[kConfigurationError]('Missing required parameter: body') | ||
var { method, body, index, ...querystring } = params | ||
// check required url components | ||
if ((params['rollup_index'] != null || params['rollupIndex'] != null) && (params['index'] == null)) { | ||
const err = new this[kConfigurationError]('Missing required parameter of the url: index') | ||
return handleError(err, callback) | ||
} | ||
var { method, body, index, rollupIndex, rollup_index, ...querystring } = params | ||
querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
@@ -191,3 +201,3 @@ | ||
if (method == null) method = 'POST' | ||
path = '/' + encodeURIComponent(index) + '/' + '_rollup' | ||
path = '/' + encodeURIComponent(index) + '/' + '_rollup' + '/' + encodeURIComponent(rollup_index || rollupIndex) | ||
@@ -194,0 +204,0 @@ // build request object |
@@ -26,4 +26,4 @@ /* | ||
const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
const acceptedQuerystring = ['analyzer', 'analyze_wildcard', 'ccs_minimize_roundtrips', 'default_operator', 'df', 'explain', 'stored_fields', 'docvalue_fields', 'from', 'ignore_unavailable', 'ignore_throttled', 'allow_no_indices', 'expand_wildcards', 'lenient', 'preference', 'q', 'routing', 'scroll', 'search_type', 'size', 'sort', '_source', '_source_excludes', '_source_exclude', '_source_includes', '_source_include', 'terminate_after', 'stats', 'suggest_field', 'suggest_mode', 'suggest_size', 'suggest_text', 'timeout', 'track_scores', 'track_total_hits', 'allow_partial_search_results', 'typed_keys', 'version', 'seq_no_primary_term', 'request_cache', 'batched_reduce_size', 'max_concurrent_shard_requests', 'pre_filter_shard_size', 'rest_total_hits_as_int', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
const snakeCase = { analyzeWildcard: 'analyze_wildcard', ccsMinimizeRoundtrips: 'ccs_minimize_roundtrips', defaultOperator: 'default_operator', storedFields: 'stored_fields', docvalueFields: 'docvalue_fields', ignoreUnavailable: 'ignore_unavailable', ignoreThrottled: 'ignore_throttled', allowNoIndices: 'allow_no_indices', expandWildcards: 'expand_wildcards', searchType: 'search_type', _sourceExcludes: '_source_excludes', _sourceExclude: '_source_exclude', _sourceIncludes: '_source_includes', _sourceInclude: '_source_include', terminateAfter: 'terminate_after', suggestField: 'suggest_field', suggestMode: 'suggest_mode', suggestSize: 'suggest_size', suggestText: 'suggest_text', trackScores: 'track_scores', trackTotalHits: 'track_total_hits', allowPartialSearchResults: 'allow_partial_search_results', typedKeys: 'typed_keys', seqNoPrimaryTerm: 'seq_no_primary_term', requestCache: 'request_cache', batchedReduceSize: 'batched_reduce_size', maxConcurrentShardRequests: 'max_concurrent_shard_requests', preFilterShardSize: 'pre_filter_shard_size', restTotalHitsAsInt: 'rest_total_hits_as_int', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
const acceptedQuerystring = ['analyzer', 'analyze_wildcard', 'ccs_minimize_roundtrips', 'default_operator', 'df', 'explain', 'stored_fields', 'docvalue_fields', 'from', 'ignore_unavailable', 'ignore_throttled', 'allow_no_indices', 'expand_wildcards', 'lenient', 'preference', 'q', 'routing', 'scroll', 'search_type', 'size', 'sort', '_source', '_source_excludes', '_source_exclude', '_source_includes', '_source_include', 'terminate_after', 'stats', 'suggest_field', 'suggest_mode', 'suggest_size', 'suggest_text', 'timeout', 'track_scores', 'track_total_hits', 'allow_partial_search_results', 'typed_keys', 'version', 'seq_no_primary_term', 'request_cache', 'batched_reduce_size', 'max_concurrent_shard_requests', 'pre_filter_shard_size', 'rest_total_hits_as_int', 'min_compatible_shard_node', 'pretty', 'human', 'error_trace', 'source', 'filter_path'] | ||
const snakeCase = { analyzeWildcard: 'analyze_wildcard', ccsMinimizeRoundtrips: 'ccs_minimize_roundtrips', defaultOperator: 'default_operator', storedFields: 'stored_fields', docvalueFields: 'docvalue_fields', ignoreUnavailable: 'ignore_unavailable', ignoreThrottled: 'ignore_throttled', allowNoIndices: 'allow_no_indices', expandWildcards: 'expand_wildcards', searchType: 'search_type', _sourceExcludes: '_source_excludes', _sourceExclude: '_source_exclude', _sourceIncludes: '_source_includes', _sourceInclude: '_source_include', terminateAfter: 'terminate_after', suggestField: 'suggest_field', suggestMode: 'suggest_mode', suggestSize: 'suggest_size', suggestText: 'suggest_text', trackScores: 'track_scores', trackTotalHits: 'track_total_hits', allowPartialSearchResults: 'allow_partial_search_results', typedKeys: 'typed_keys', seqNoPrimaryTerm: 'seq_no_primary_term', requestCache: 'request_cache', batchedReduceSize: 'batched_reduce_size', maxConcurrentShardRequests: 'max_concurrent_shard_requests', preFilterShardSize: 'pre_filter_shard_size', restTotalHitsAsInt: 'rest_total_hits_as_int', minCompatibleShardNode: 'min_compatible_shard_node', errorTrace: 'error_trace', filterPath: 'filter_path' } | ||
@@ -30,0 +30,0 @@ function searchApi (params, options, callback) { |
@@ -26,3 +26,3 @@ /* | ||
const { handleError, snakeCaseKeys, normalizeArguments, kConfigurationError } = require('../utils') | ||
const acceptedQuerystring = ['ignore_unavailable', 'allow_no_indices', 'expand_wildcards', 'index', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'master_timeout', 'wait_for_completion'] | ||
const acceptedQuerystring = ['ignore_unavailable', 'allow_no_indices', 'expand_wildcards', 'index', 'pretty', 'human', 'error_trace', 'source', 'filter_path', 'master_timeout', 'wait_for_completion', 'storage', 'level'] | ||
const snakeCase = { ignoreUnavailable: 'ignore_unavailable', allowNoIndices: 'allow_no_indices', expandWildcards: 'expand_wildcards', errorTrace: 'error_trace', filterPath: 'filter_path', masterTimeout: 'master_timeout', waitForCompletion: 'wait_for_completion' } | ||
@@ -29,0 +29,0 @@ |
@@ -278,2 +278,23 @@ /* | ||
SnapshotApi.prototype.getFeatures = function snapshotGetFeaturesApi (params, options, callback) { | ||
;[params, options, callback] = normalizeArguments(params, options, callback) | ||
var { method, body, ...querystring } = params | ||
querystring = snakeCaseKeys(acceptedQuerystring, snakeCase, querystring) | ||
var path = '' | ||
if (method == null) method = 'GET' | ||
path = '/' + '_snapshottable_features' | ||
// build request object | ||
const request = { | ||
method, | ||
path, | ||
body: null, | ||
querystring | ||
} | ||
return this.transport.request(request, options, callback) | ||
} | ||
SnapshotApi.prototype.getRepository = function snapshotGetRepositoryApi (params, options, callback) { | ||
@@ -408,2 +429,3 @@ ;[params, options, callback] = normalizeArguments(params, options, callback) | ||
delete_repository: { get () { return this.deleteRepository } }, | ||
get_features: { get () { return this.getFeatures } }, | ||
get_repository: { get () { return this.getRepository } }, | ||
@@ -410,0 +432,0 @@ verify_repository: { get () { return this.verifyRepository } } |
@@ -77,2 +77,3 @@ /* | ||
const LicenseApi = require('./api/license') | ||
const LogstashApi = require('./api/logstash') | ||
const MigrationApi = require('./api/migration') | ||
@@ -88,2 +89,3 @@ const MlApi = require('./api/ml') | ||
const SslApi = require('./api/ssl') | ||
const TextStructureApi = require('./api/text_structure') | ||
const TransformApi = require('./api/transform') | ||
@@ -110,2 +112,3 @@ const WatcherApi = require('./api/watcher') | ||
const kLicense = Symbol('License') | ||
const kLogstash = Symbol('Logstash') | ||
const kMigration = Symbol('Migration') | ||
@@ -120,2 +123,3 @@ const kMl = Symbol('Ml') | ||
const kSsl = Symbol('Ssl') | ||
const kTextStructure = Symbol('TextStructure') | ||
const kTransform = Symbol('Transform') | ||
@@ -143,2 +147,3 @@ const kWatcher = Symbol('Watcher') | ||
this[kLicense] = null | ||
this[kLogstash] = null | ||
this[kMigration] = null | ||
@@ -153,2 +158,3 @@ this[kMl] = null | ||
this[kSsl] = null | ||
this[kTextStructure] = null | ||
this[kTransform] = null | ||
@@ -352,2 +358,10 @@ this[kWatcher] = null | ||
}, | ||
logstash: { | ||
get () { | ||
if (this[kLogstash] === null) { | ||
this[kLogstash] = new LogstashApi(this.transport, this[kConfigurationError]) | ||
} | ||
return this[kLogstash] | ||
} | ||
}, | ||
migration: { | ||
@@ -427,2 +441,11 @@ get () { | ||
}, | ||
textStructure: { | ||
get () { | ||
if (this[kTextStructure] === null) { | ||
this[kTextStructure] = new TextStructureApi(this.transport, this[kConfigurationError]) | ||
} | ||
return this[kTextStructure] | ||
} | ||
}, | ||
text_structure: { get () { return this.textStructure } }, | ||
transform: { | ||
@@ -429,0 +452,0 @@ get () { |
@@ -300,2 +300,3 @@ /* | ||
help?: boolean; | ||
include_bootstrap?: boolean; | ||
s?: string | string[]; | ||
@@ -364,6 +365,6 @@ v?: boolean; | ||
format?: string; | ||
node_id?: string | string[]; | ||
nodes?: string | string[]; | ||
actions?: string | string[]; | ||
detailed?: boolean; | ||
parent_task?: number; | ||
parent_task_id?: string; | ||
h?: string | string[]; | ||
@@ -730,2 +731,6 @@ help?: boolean; | ||
export interface EqlGetStatus extends Generic { | ||
id: string; | ||
} | ||
export interface EqlSearch<T = RequestBody> extends Generic { | ||
@@ -1404,2 +1409,15 @@ index: string; | ||
export interface LogstashDeletePipeline extends Generic { | ||
id: string; | ||
} | ||
export interface LogstashGetPipeline extends Generic { | ||
id: string; | ||
} | ||
export interface LogstashPutPipeline<T = RequestBody> extends Generic { | ||
id: string; | ||
body: T; | ||
} | ||
export interface Mget<T = RequestBody> extends Generic { | ||
@@ -1504,20 +1522,2 @@ index?: string; | ||
export interface MlFindFileStructure<T = RequestNDBody> extends Generic { | ||
lines_to_sample?: number; | ||
line_merge_size_limit?: number; | ||
timeout?: string; | ||
charset?: string; | ||
format?: 'ndjson' | 'xml' | 'delimited' | 'semi_structured_text'; | ||
has_header_row?: boolean; | ||
column_names?: string | string[]; | ||
delimiter?: string; | ||
quote?: string; | ||
should_trim_fields?: boolean; | ||
grok_pattern?: string; | ||
timestamp_field?: string; | ||
timestamp_format?: string; | ||
explain?: boolean; | ||
body: T; | ||
} | ||
export interface MlFlushJob<T = RequestBody> extends Generic { | ||
@@ -2012,2 +2012,3 @@ job_id: string; | ||
index: string; | ||
rollup_index: string; | ||
body: T; | ||
@@ -2091,2 +2092,3 @@ } | ||
rest_total_hits_as_int?: boolean; | ||
min_compatible_shard_node?: string; | ||
body?: T; | ||
@@ -2135,2 +2137,3 @@ } | ||
wait_for_completion?: boolean; | ||
storage?: string; | ||
body: T; | ||
@@ -2141,2 +2144,3 @@ } | ||
index?: string | string[]; | ||
level?: 'cluster' | 'indices' | 'shards'; | ||
} | ||
@@ -2364,2 +2368,6 @@ | ||
export interface SnapshotGetFeatures extends Generic { | ||
master_timeout?: string; | ||
} | ||
export interface SnapshotGetRepository extends Generic { | ||
@@ -2449,2 +2457,20 @@ repository?: string | string[]; | ||
export interface TextStructureFindStructure<T = RequestBody> extends Generic { | ||
lines_to_sample?: number; | ||
line_merge_size_limit?: number; | ||
timeout?: string; | ||
charset?: string; | ||
format?: 'ndjson' | 'xml' | 'delimited' | 'semi_structured_text'; | ||
has_header_row?: boolean; | ||
column_names?: string | string[]; | ||
delimiter?: string; | ||
quote?: string; | ||
should_trim_fields?: boolean; | ||
grok_pattern?: string; | ||
timestamp_field?: string; | ||
timestamp_format?: string; | ||
explain?: boolean; | ||
body: T; | ||
} | ||
export interface TransformDeleteTransform extends Generic { | ||
@@ -2451,0 +2477,0 @@ transform_id: string; |
@@ -36,3 +36,8 @@ /* | ||
const { prepareHeaders } = Connection.internals | ||
const clientVersion = require('./package.json').version | ||
let clientVersion = require('./package.json').version | ||
/* istanbul ignore next */ | ||
if (clientVersion.includes('-')) { | ||
// clean prerelease | ||
clientVersion = clientVersion.slice(0, clientVersion.indexOf('-')) + 'p' | ||
} | ||
const nodeVersion = process.versions.node | ||
@@ -39,0 +44,0 @@ |
@@ -14,4 +14,4 @@ { | ||
"homepage": "http://www.elastic.co/guide/en/elasticsearch/client/javascript-api/current/index.html", | ||
"version": "8.0.0-canary.1", | ||
"versionCanary": "8.0.0-canary.1", | ||
"version": "8.0.0-canary.2", | ||
"versionCanary": "8.0.0-canary.2", | ||
"keywords": [ | ||
@@ -107,3 +107,3 @@ "elasticsearch", | ||
}, | ||
"commitHash": "a91c55b1" | ||
"commitHash": "79658b17" | ||
} |
@@ -74,3 +74,3 @@ <img align="right" width="auto" height="auto" src="https://www.elastic.co/static-res/images/elastic-logo-200.png"> | ||
WARNING: There is no official support for the browser environment. It exposes your Elasticsearch instance to everyone, which could lead to security issues. | ||
We recommend that you write a lightweight proxy that uses this client instead. | ||
We recommend that you write a lightweight proxy that uses this client instead, you can see a proxy example [here](./docs/examples/proxy). | ||
@@ -77,0 +77,0 @@ ## Documentation |
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
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
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
1233385
97
19313