@elastic/elasticsearch-canary
Advanced tools
Comparing version 8.0.0-canary.25 to 8.0.0-canary.26
@@ -13,3 +13,9 @@ import { Transport, TransportRequestOptions, TransportRequestOptionsWithMeta, TransportRequestOptionsWithOutMeta, TransportResult } from '@elastic/transport'; | ||
globalCheckpoints(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>; | ||
msearch(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>; | ||
msearch(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>; | ||
msearch(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>; | ||
search(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>; | ||
search(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>; | ||
search(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>; | ||
} | ||
export {}; |
@@ -48,4 +48,46 @@ "use strict"; | ||
} | ||
async msearch(params, options) { | ||
const acceptedPath = ['index']; | ||
const querystring = {}; | ||
const body = undefined; | ||
params = params !== null && params !== void 0 ? params : {}; | ||
for (const key in params) { | ||
if (acceptedPath.includes(key)) { | ||
continue; | ||
} | ||
else if (key !== 'body') { | ||
querystring[key] = params[key]; | ||
} | ||
} | ||
let method = ''; | ||
let path = ''; | ||
if (params.index != null) { | ||
method = body != null ? 'POST' : 'GET'; | ||
path = `/${encodeURIComponent(params.index.toString())}/_fleet/_msearch`; | ||
} | ||
else { | ||
method = body != null ? 'POST' : 'GET'; | ||
path = '/_fleet/_msearch'; | ||
} | ||
return await this.transport.request({ path, method, querystring, bulkBody: body }, options); | ||
} | ||
async search(params, options) { | ||
const acceptedPath = ['index']; | ||
const querystring = {}; | ||
const body = undefined; | ||
params = params !== null && params !== void 0 ? params : {}; | ||
for (const key in params) { | ||
if (acceptedPath.includes(key)) { | ||
continue; | ||
} | ||
else if (key !== 'body') { | ||
querystring[key] = params[key]; | ||
} | ||
} | ||
const method = body != null ? 'POST' : 'GET'; | ||
const path = `/${encodeURIComponent(params.index.toString())}/_fleet/_search`; | ||
return await this.transport.request({ path, method, querystring, body }, options); | ||
} | ||
} | ||
exports.default = Fleet; | ||
//# sourceMappingURL=fleet.js.map |
@@ -103,2 +103,5 @@ import { Transport, TransportRequestOptions, TransportRequestOptionsWithMeta, TransportRequestOptionsWithOutMeta, TransportResult } from '@elastic/transport'; | ||
migrateToDataStream(this: That, params: T.IndicesMigrateToDataStreamRequest | TB.IndicesMigrateToDataStreamRequest, options?: TransportRequestOptions): Promise<T.IndicesMigrateToDataStreamResponse>; | ||
modifyDataStream(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithOutMeta): Promise<T.TODO>; | ||
modifyDataStream(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.TODO, unknown>>; | ||
modifyDataStream(this: That, params?: T.TODO | TB.TODO, options?: TransportRequestOptions): Promise<T.TODO>; | ||
open(this: That, params: T.IndicesOpenRequest | TB.IndicesOpenRequest, options?: TransportRequestOptionsWithOutMeta): Promise<T.IndicesOpenResponse>; | ||
@@ -105,0 +108,0 @@ open(this: That, params: T.IndicesOpenRequest | TB.IndicesOpenRequest, options?: TransportRequestOptionsWithMeta): Promise<TransportResult<T.IndicesOpenResponse, unknown>>; |
@@ -721,2 +721,19 @@ "use strict"; | ||
} | ||
async modifyDataStream(params, options) { | ||
const acceptedPath = []; | ||
const querystring = {}; | ||
const body = undefined; | ||
params = params !== null && params !== void 0 ? params : {}; | ||
for (const key in params) { | ||
if (acceptedPath.includes(key)) { | ||
continue; | ||
} | ||
else if (key !== 'body') { | ||
querystring[key] = params[key]; | ||
} | ||
} | ||
const method = 'POST'; | ||
const path = '/_data_stream/_modify'; | ||
return await this.transport.request({ path, method, querystring, body }, options); | ||
} | ||
async open(params, options) { | ||
@@ -723,0 +740,0 @@ const acceptedPath = ['index']; |
@@ -35,2 +35,3 @@ import AsyncSearchApi from './api/async_search'; | ||
import IngestApi from './api/ingest'; | ||
import knnSearchApi from './api/knn_search'; | ||
import LicenseApi from './api/license'; | ||
@@ -113,2 +114,3 @@ import LogstashApi from './api/logstash'; | ||
ingest: IngestApi; | ||
knnSearch: typeof knnSearchApi; | ||
license: LicenseApi; | ||
@@ -115,0 +117,0 @@ logstash: LogstashApi; |
@@ -64,2 +64,3 @@ "use strict"; | ||
const ingest_1 = (0, tslib_1.__importDefault)(require("./api/ingest")); | ||
const knn_search_1 = (0, tslib_1.__importDefault)(require("./api/knn_search")); | ||
const license_1 = (0, tslib_1.__importDefault)(require("./api/license")); | ||
@@ -396,2 +397,3 @@ const logstash_1 = (0, tslib_1.__importDefault)(require("./api/logstash")); | ||
API.prototype.info = info_1.default; | ||
API.prototype.knnSearch = knn_search_1.default; | ||
API.prototype.mget = mget_1.default; | ||
@@ -398,0 +400,0 @@ API.prototype.msearch = msearch_1.default; |
@@ -10,3 +10,3 @@ /// <reference types="node" /> | ||
import API from './api'; | ||
interface NodeOptions { | ||
export interface NodeOptions { | ||
url: URL; | ||
@@ -71,2 +71,1 @@ id?: string; | ||
} | ||
export {}; |
{ | ||
"name": "@elastic/elasticsearch-canary", | ||
"version": "8.0.0-canary.25", | ||
"versionCanary": "8.0.0-canary.25", | ||
"version": "8.0.0-canary.26", | ||
"versionCanary": "8.0.0-canary.26", | ||
"description": "The official Elasticsearch client for Node.js", | ||
@@ -93,3 +93,3 @@ "main": "index.js", | ||
}, | ||
"commitHash": "dc74a804" | ||
"commitHash": "1e1ac6a2" | ||
} |
@@ -18,3 +18,3 @@ { | ||
"forceConsistentCasingInFileNames": true, | ||
"skipLibCheck": true, | ||
"skipLibCheck": false, | ||
"esModuleInterop": true, | ||
@@ -21,0 +21,0 @@ "isolatedModules": true, |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
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
2102219
258
42591