// Licensed to Elasticsearch B.V under one or more agreements.
// Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
// See the LICENSE file in the project root for more information
///
import { ConnectionOptions as TlsConnectionOptions } from 'tls';
import Transport, {
ApiError,
ApiResponse,
RequestEvent,
TransportRequestParams,
TransportRequestOptions,
nodeFilterFn,
nodeSelectorFn,
generateRequestIdFn,
TransportRequestCallback,
TransportRequestPromise,
RequestBody,
RequestNDBody
} from './lib/Transport';
import { URL } from 'url';
import Connection, { AgentOptions, agentFn } from './lib/Connection';
import {
ConnectionPool,
BaseConnectionPool,
CloudConnectionPool,
ResurrectEvent,
BasicAuth,
ApiKeyAuth
} from './lib/pool';
import Serializer from './lib/Serializer';
import Helpers from './lib/Helpers';
import * as RequestParams from './api/requestParams';
import * as errors from './lib/errors';
declare type callbackFn = (err: ApiError, result: ApiResponse) => void;
// Extend API
interface ClientExtendsCallbackOptions {
ConfigurationError: errors.ConfigurationError,
makeRequest(params: TransportRequestParams, options?: TransportRequestOptions): Promise | void;
result: {
body: null,
statusCode: null,
headers: null,
warnings: null
}
}
declare type extendsCallback = (options: ClientExtendsCallbackOptions) => any;
// /Extend API
interface NodeOptions {
url: URL;
id?: string;
agent?: AgentOptions;
ssl?: TlsConnectionOptions;
headers?: Record;
roles?: {
master: boolean;
data: boolean;
ingest: boolean;
ml: boolean;
}
}
interface ClientOptions {
node?: string | string[] | NodeOptions | NodeOptions[];
nodes?: string | string[] | NodeOptions | NodeOptions[];
Connection?: typeof Connection;
ConnectionPool?: typeof ConnectionPool;
Transport?: typeof Transport;
Serializer?: typeof Serializer;
maxRetries?: number;
requestTimeout?: number;
pingTimeout?: number;
sniffInterval?: number | boolean;
sniffOnStart?: boolean;
sniffEndpoint?: string;
sniffOnConnectionFault?: boolean;
resurrectStrategy?: 'ping' | 'optimistic' | 'none';
suggestCompression?: boolean;
compression?: 'gzip';
ssl?: TlsConnectionOptions;
agent?: AgentOptions | agentFn;
nodeFilter?: nodeFilterFn;
nodeSelector?: nodeSelectorFn | string;
headers?: Record;
opaqueIdPrefix?: string;
generateRequestId?: generateRequestIdFn;
name?: string | symbol;
auth?: BasicAuth | ApiKeyAuth;
cloud?: {
id: string;
// TODO: remove username and password here in 8
username?: string;
password?: string;
}
}
declare class Client {
constructor(opts?: ClientOptions);
connectionPool: ConnectionPool;
transport: Transport;
serializer: Serializer;
extend(method: string, fn: extendsCallback): void
extend(method: string, opts: { force: boolean }, fn: extendsCallback): void;
helpers: Helpers;
child(opts?: ClientOptions): Client;
close(): Promise;
close(callback: Function): void;
close(callback?: Function): Promise | void;
emit(event: string | symbol, ...args: any[]): boolean;
on(event: 'request', listener: (err: ApiError, meta: RequestEvent) => void): this;
on(event: 'response', listener: (err: ApiError, meta: RequestEvent) => void): this;
on(event: 'sniff', listener: (err: ApiError, meta: RequestEvent) => void): this;
on(event: 'resurrect', listener: (err: null, meta: ResurrectEvent) => void): this;
once(event: 'request', listener: (err: ApiError, meta: RequestEvent) => void): this;
once(event: 'response', listener: (err: ApiError, meta: RequestEvent) => void): this;
once(event: 'sniff', listener: (err: ApiError, meta: RequestEvent) => void): this;
once(event: 'resurrect', listener: (err: null, meta: ResurrectEvent) => void): this;
off(event: string | symbol, listener: (...args: any[]) => void): this;
/* GENERATED */
async_search: {
delete, TContext = unknown>(params?: RequestParams.AsyncSearchDelete, options?: TransportRequestOptions): TransportRequestPromise>
delete, TContext = unknown>(callback: callbackFn): TransportRequestCallback
delete, TContext = unknown>(params: RequestParams.AsyncSearchDelete, callback: callbackFn): TransportRequestCallback
delete, TContext = unknown>(params: RequestParams.AsyncSearchDelete, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
get, TContext = unknown>(params?: RequestParams.AsyncSearchGet, options?: TransportRequestOptions): TransportRequestPromise>
get, TContext = unknown>(callback: callbackFn): TransportRequestCallback
get, TContext = unknown>(params: RequestParams.AsyncSearchGet, callback: callbackFn): TransportRequestCallback
get, TContext = unknown>(params: RequestParams.AsyncSearchGet, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(params?: RequestParams.AsyncSearchSubmit, options?: TransportRequestOptions): TransportRequestPromise>
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(callback: callbackFn): TransportRequestCallback
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AsyncSearchSubmit, callback: callbackFn): TransportRequestCallback
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AsyncSearchSubmit, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
}
asyncSearch: {
delete, TContext = unknown>(params?: RequestParams.AsyncSearchDelete, options?: TransportRequestOptions): TransportRequestPromise>
delete, TContext = unknown>(callback: callbackFn): TransportRequestCallback
delete, TContext = unknown>(params: RequestParams.AsyncSearchDelete, callback: callbackFn): TransportRequestCallback
delete, TContext = unknown>(params: RequestParams.AsyncSearchDelete, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
get, TContext = unknown>(params?: RequestParams.AsyncSearchGet, options?: TransportRequestOptions): TransportRequestPromise>
get, TContext = unknown>(callback: callbackFn): TransportRequestCallback
get, TContext = unknown>(params: RequestParams.AsyncSearchGet, callback: callbackFn): TransportRequestCallback
get, TContext = unknown>(params: RequestParams.AsyncSearchGet, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(params?: RequestParams.AsyncSearchSubmit, options?: TransportRequestOptions): TransportRequestPromise>
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(callback: callbackFn): TransportRequestCallback
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AsyncSearchSubmit, callback: callbackFn): TransportRequestCallback
submit, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AsyncSearchSubmit, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
}
autoscaling: {
delete_autoscaling_policy, TContext = unknown>(params?: RequestParams.AutoscalingDeleteAutoscalingPolicy, options?: TransportRequestOptions): TransportRequestPromise>
delete_autoscaling_policy, TContext = unknown>(callback: callbackFn): TransportRequestCallback
delete_autoscaling_policy, TContext = unknown>(params: RequestParams.AutoscalingDeleteAutoscalingPolicy, callback: callbackFn): TransportRequestCallback
delete_autoscaling_policy, TContext = unknown>(params: RequestParams.AutoscalingDeleteAutoscalingPolicy, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
deleteAutoscalingPolicy, TContext = unknown>(params?: RequestParams.AutoscalingDeleteAutoscalingPolicy, options?: TransportRequestOptions): TransportRequestPromise>
deleteAutoscalingPolicy, TContext = unknown>(callback: callbackFn): TransportRequestCallback
deleteAutoscalingPolicy, TContext = unknown>(params: RequestParams.AutoscalingDeleteAutoscalingPolicy, callback: callbackFn): TransportRequestCallback
deleteAutoscalingPolicy, TContext = unknown>(params: RequestParams.AutoscalingDeleteAutoscalingPolicy, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
get_autoscaling_decision, TContext = unknown>(params?: RequestParams.AutoscalingGetAutoscalingDecision, options?: TransportRequestOptions): TransportRequestPromise>
get_autoscaling_decision, TContext = unknown>(callback: callbackFn): TransportRequestCallback
get_autoscaling_decision, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingDecision, callback: callbackFn): TransportRequestCallback
get_autoscaling_decision, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingDecision, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
getAutoscalingDecision, TContext = unknown>(params?: RequestParams.AutoscalingGetAutoscalingDecision, options?: TransportRequestOptions): TransportRequestPromise>
getAutoscalingDecision, TContext = unknown>(callback: callbackFn): TransportRequestCallback
getAutoscalingDecision, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingDecision, callback: callbackFn): TransportRequestCallback
getAutoscalingDecision, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingDecision, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
get_autoscaling_policy, TContext = unknown>(params?: RequestParams.AutoscalingGetAutoscalingPolicy, options?: TransportRequestOptions): TransportRequestPromise>
get_autoscaling_policy, TContext = unknown>(callback: callbackFn): TransportRequestCallback
get_autoscaling_policy, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingPolicy, callback: callbackFn): TransportRequestCallback
get_autoscaling_policy, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingPolicy, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
getAutoscalingPolicy, TContext = unknown>(params?: RequestParams.AutoscalingGetAutoscalingPolicy, options?: TransportRequestOptions): TransportRequestPromise>
getAutoscalingPolicy, TContext = unknown>(callback: callbackFn): TransportRequestCallback
getAutoscalingPolicy, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingPolicy, callback: callbackFn): TransportRequestCallback
getAutoscalingPolicy, TContext = unknown>(params: RequestParams.AutoscalingGetAutoscalingPolicy, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
put_autoscaling_policy, TRequestBody extends RequestBody = Record, TContext = unknown>(params?: RequestParams.AutoscalingPutAutoscalingPolicy, options?: TransportRequestOptions): TransportRequestPromise>
put_autoscaling_policy, TRequestBody extends RequestBody = Record, TContext = unknown>(callback: callbackFn): TransportRequestCallback
put_autoscaling_policy, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AutoscalingPutAutoscalingPolicy, callback: callbackFn): TransportRequestCallback
put_autoscaling_policy, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AutoscalingPutAutoscalingPolicy, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
putAutoscalingPolicy, TRequestBody extends RequestBody = Record, TContext = unknown>(params?: RequestParams.AutoscalingPutAutoscalingPolicy, options?: TransportRequestOptions): TransportRequestPromise>
putAutoscalingPolicy, TRequestBody extends RequestBody = Record, TContext = unknown>(callback: callbackFn): TransportRequestCallback
putAutoscalingPolicy, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AutoscalingPutAutoscalingPolicy, callback: callbackFn): TransportRequestCallback
putAutoscalingPolicy, TRequestBody extends RequestBody = Record, TContext = unknown>(params: RequestParams.AutoscalingPutAutoscalingPolicy, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
}
bulk, TRequestBody extends RequestNDBody = Record[], TContext = unknown>(params?: RequestParams.Bulk, options?: TransportRequestOptions): TransportRequestPromise>
bulk, TRequestBody extends RequestNDBody = Record[], TContext = unknown>(callback: callbackFn): TransportRequestCallback
bulk, TRequestBody extends RequestNDBody = Record[], TContext = unknown>(params: RequestParams.Bulk, callback: callbackFn): TransportRequestCallback
bulk, TRequestBody extends RequestNDBody = Record[], TContext = unknown>(params: RequestParams.Bulk, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
cat: {
aliases, TContext = unknown>(params?: RequestParams.CatAliases, options?: TransportRequestOptions): TransportRequestPromise>
aliases, TContext = unknown>(callback: callbackFn): TransportRequestCallback
aliases, TContext = unknown>(params: RequestParams.CatAliases, callback: callbackFn): TransportRequestCallback
aliases, TContext = unknown>(params: RequestParams.CatAliases, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
allocation, TContext = unknown>(params?: RequestParams.CatAllocation, options?: TransportRequestOptions): TransportRequestPromise>
allocation, TContext = unknown>(callback: callbackFn): TransportRequestCallback
allocation, TContext = unknown>(params: RequestParams.CatAllocation, callback: callbackFn): TransportRequestCallback
allocation, TContext = unknown>(params: RequestParams.CatAllocation, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
count, TContext = unknown>(params?: RequestParams.CatCount, options?: TransportRequestOptions): TransportRequestPromise>
count, TContext = unknown>(callback: callbackFn): TransportRequestCallback
count, TContext = unknown>(params: RequestParams.CatCount, callback: callbackFn): TransportRequestCallback
count, TContext = unknown>(params: RequestParams.CatCount, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
fielddata, TContext = unknown>(params?: RequestParams.CatFielddata, options?: TransportRequestOptions): TransportRequestPromise>
fielddata, TContext = unknown>(callback: callbackFn): TransportRequestCallback
fielddata, TContext = unknown>(params: RequestParams.CatFielddata, callback: callbackFn): TransportRequestCallback
fielddata, TContext = unknown>(params: RequestParams.CatFielddata, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
health, TContext = unknown>(params?: RequestParams.CatHealth, options?: TransportRequestOptions): TransportRequestPromise>
health, TContext = unknown>(callback: callbackFn): TransportRequestCallback
health, TContext = unknown>(params: RequestParams.CatHealth, callback: callbackFn): TransportRequestCallback
health, TContext = unknown>(params: RequestParams.CatHealth, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
help, TContext = unknown>(params?: RequestParams.CatHelp, options?: TransportRequestOptions): TransportRequestPromise>
help, TContext = unknown>(callback: callbackFn): TransportRequestCallback
help, TContext = unknown>(params: RequestParams.CatHelp, callback: callbackFn): TransportRequestCallback
help, TContext = unknown>(params: RequestParams.CatHelp, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
indices, TContext = unknown>(params?: RequestParams.CatIndices, options?: TransportRequestOptions): TransportRequestPromise>
indices, TContext = unknown>(callback: callbackFn): TransportRequestCallback
indices, TContext = unknown>(params: RequestParams.CatIndices, callback: callbackFn): TransportRequestCallback
indices, TContext = unknown>(params: RequestParams.CatIndices, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
master, TContext = unknown>(params?: RequestParams.CatMaster, options?: TransportRequestOptions): TransportRequestPromise>
master, TContext = unknown>(callback: callbackFn): TransportRequestCallback
master, TContext = unknown>(params: RequestParams.CatMaster, callback: callbackFn): TransportRequestCallback
master, TContext = unknown>(params: RequestParams.CatMaster, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
ml_data_frame_analytics, TContext = unknown>(params?: RequestParams.CatMlDataFrameAnalytics, options?: TransportRequestOptions): TransportRequestPromise>
ml_data_frame_analytics, TContext = unknown>(callback: callbackFn): TransportRequestCallback
ml_data_frame_analytics, TContext = unknown>(params: RequestParams.CatMlDataFrameAnalytics, callback: callbackFn): TransportRequestCallback
ml_data_frame_analytics, TContext = unknown>(params: RequestParams.CatMlDataFrameAnalytics, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
mlDataFrameAnalytics, TContext = unknown>(params?: RequestParams.CatMlDataFrameAnalytics, options?: TransportRequestOptions): TransportRequestPromise>
mlDataFrameAnalytics, TContext = unknown>(callback: callbackFn): TransportRequestCallback
mlDataFrameAnalytics, TContext = unknown>(params: RequestParams.CatMlDataFrameAnalytics, callback: callbackFn): TransportRequestCallback
mlDataFrameAnalytics, TContext = unknown>(params: RequestParams.CatMlDataFrameAnalytics, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
ml_datafeeds, TContext = unknown>(params?: RequestParams.CatMlDatafeeds, options?: TransportRequestOptions): TransportRequestPromise>
ml_datafeeds, TContext = unknown>(callback: callbackFn): TransportRequestCallback
ml_datafeeds, TContext = unknown>(params: RequestParams.CatMlDatafeeds, callback: callbackFn): TransportRequestCallback
ml_datafeeds, TContext = unknown>(params: RequestParams.CatMlDatafeeds, options: TransportRequestOptions, callback: callbackFn): TransportRequestCallback
mlDatafeeds, TContext = unknown>(params?: RequestParams.CatMlDatafeeds, options?: TransportRequestOptions): TransportRequestPromise>
mlDatafeeds, TContext = unknown>(callback: callbackFn): TransportRequestCallback
mlDatafeeds