Merge branch 'master' into monitoring/ecs_final_es

elastic · Apr 22, 2021 · 7166642 · 7166642
2 parents f2df4ad + fc45de9
commit 7166642
Show file tree

Hide file tree

Showing 320 changed files with 6,383 additions and 3,003 deletions.
diff --git a/docs/developer/getting-started/monorepo-packages.asciidoc b/docs/developer/getting-started/monorepo-packages.asciidoc
@@ -68,4 +68,5 @@ yarn kbn watch-bazel
 - @kbn/std
 - @kbn/tinymath
 - @kbn/utility-types
+- @kbn/utils
 
diff --git a/...ressions/public/kibana-plugin-plugins-expressions-public.execution.interpret.md b/...ressions/public/kibana-plugin-plugins-expressions-public.execution.interpret.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-interpret<T>(ast: ExpressionAstNode, input: T): Promise<unknown>;
+interpret<T>(ast: ExpressionAstNode, input: T): Observable<unknown>;
 ```
 
 ## Parameters
@@ -19,5 +19,5 @@ interpret<T>(ast: ExpressionAstNode, input: T): Promise<unknown>;
 
 <b>Returns:</b>
 
-`Promise<unknown>`
+`Observable<unknown>`
 
diff --git a/...ssions/public/kibana-plugin-plugins-expressions-public.execution.invokechain.md b/...ssions/public/kibana-plugin-plugins-expressions-public.execution.invokechain.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-invokeChain(chainArr: ExpressionAstFunction[], input: unknown): Promise<any>;
+invokeChain(chainArr: ExpressionAstFunction[], input: unknown): Observable<any>;
 ```
 
 ## Parameters
@@ -19,5 +19,5 @@ invokeChain(chainArr: ExpressionAstFunction[], input: unknown): Promise<any>;
 
 <b>Returns:</b>
 
-`Promise<any>`
+`Observable<any>`
 
diff --git a/...ons/public/kibana-plugin-plugins-expressions-public.execution.invokefunction.md b/...ons/public/kibana-plugin-plugins-expressions-public.execution.invokefunction.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-invokeFunction(fn: ExpressionFunction, input: unknown, args: Record<string, unknown>): Promise<any>;
+invokeFunction(fn: ExpressionFunction, input: unknown, args: Record<string, unknown>): Observable<any>;
 ```
 
 ## Parameters
@@ -20,5 +20,5 @@ invokeFunction(fn: ExpressionFunction, input: unknown, args: Record<string, unkn
 
 <b>Returns:</b>
 
-`Promise<any>`
+`Observable<any>`
 
diff --git a/...lugins/expressions/public/kibana-plugin-plugins-expressions-public.execution.md b/...lugins/expressions/public/kibana-plugin-plugins-expressions-public.execution.md
@@ -26,7 +26,7 @@ export declare class Execution<Input = unknown, Output = unknown, InspectorAdapt
 |  [expression](./kibana-plugin-plugins-expressions-public.execution.expression.md) |  | <code>string</code> |  |
 |  [input](./kibana-plugin-plugins-expressions-public.execution.input.md) |  | <code>Input</code> | Initial input of the execution.<!-- -->N.B. It is initialized to <code>null</code> rather than <code>undefined</code> for legacy reasons, because in legacy interpreter it was set to <code>null</code> by default. |
 |  [inspectorAdapters](./kibana-plugin-plugins-expressions-public.execution.inspectoradapters.md) |  | <code>InspectorAdapters</code> |  |
-|  [result](./kibana-plugin-plugins-expressions-public.execution.result.md) |  | <code>Promise&lt;Output &#124; ExpressionValueError&gt;</code> |  |
+|  [result](./kibana-plugin-plugins-expressions-public.execution.result.md) |  | <code>Observable&lt;Output &#124; ExpressionValueError&gt;</code> | Future that tracks result or error of this execution. |
 |  [state](./kibana-plugin-plugins-expressions-public.execution.state.md) |  | <code>ExecutionContainer&lt;Output &#124; ExpressionValueError&gt;</code> | Dynamic state of the execution. |
 
 ## Methods

diff --git a/...ssions/public/kibana-plugin-plugins-expressions-public.execution.resolveargs.md b/...ssions/public/kibana-plugin-plugins-expressions-public.execution.resolveargs.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-resolveArgs(fnDef: ExpressionFunction, input: unknown, argAsts: any): Promise<any>;
+resolveArgs(fnDef: ExpressionFunction, input: unknown, argAsts: any): Observable<any>;
 ```
 
 ## Parameters
@@ -20,5 +20,5 @@ resolveArgs(fnDef: ExpressionFunction, input: unknown, argAsts: any): Promise<an
 
 <b>Returns:</b>
 
-`Promise<any>`
+`Observable<any>`
 
diff --git a/...expressions/public/kibana-plugin-plugins-expressions-public.execution.result.md b/...expressions/public/kibana-plugin-plugins-expressions-public.execution.result.md
@@ -4,8 +4,10 @@
 
 ## Execution.result property
 
+Future that tracks result or error of this execution.
+
 <b>Signature:</b>
 
 ```typescript
-get result(): Promise<Output | ExpressionValueError>;
+readonly result: Observable<Output | ExpressionValueError>;
 ```
diff --git a/.../expressions/public/kibana-plugin-plugins-expressions-public.execution.start.md b/.../expressions/public/kibana-plugin-plugins-expressions-public.execution.start.md
@@ -11,7 +11,7 @@ N.B. `input` is initialized to `null` rather than `undefined` for legacy reasons
 <b>Signature:</b>
 
 ```typescript
-start(input?: Input): void;
+start(input?: Input): Observable<Output | ExpressionValueError>;
 ```
 
 ## Parameters
@@ -22,5 +22,5 @@ start(input?: Input): void;
 
 <b>Returns:</b>
 
-`void`
+`Observable<Output | ExpressionValueError>`
 
diff --git a/...ins/expressions/public/kibana-plugin-plugins-expressions-public.executor.run.md b/...ins/expressions/public/kibana-plugin-plugins-expressions-public.executor.run.md
@@ -9,7 +9,7 @@ Execute expression and return result.
 <b>Signature:</b>
 
 ```typescript
-run<Input, Output>(ast: string | ExpressionAstExpression, input: Input, params?: ExpressionExecutionParams): Promise<Output>;
+run<Input, Output>(ast: string | ExpressionAstExpression, input: Input, params?: ExpressionExecutionParams): Observable<Output | ExpressionValueError>;
 ```
 
 ## Parameters
@@ -22,5 +22,5 @@ run<Input, Output>(ast: string | ExpressionAstExpression, input: Input, params?:
 
 <b>Returns:</b>
 
-`Promise<Output>`
+`Observable<Output | ExpressionValueError>`
 
diff --git a/...ugins/expressions/public/kibana-plugin-plugins-expressions-public.typestring.md b/...ugins/expressions/public/kibana-plugin-plugins-expressions-public.typestring.md
@@ -11,5 +11,5 @@ If the type extends a Promise, we still need to return the string representation
 <b>Signature:</b>
 
 ```typescript
-export declare type TypeString<T> = KnownTypeToString<UnwrapPromiseOrReturn<T>>;
+export declare type TypeString<T> = KnownTypeToString<T extends ObservableLike<any> ? UnwrapObservable<T> : UnwrapPromiseOrReturn<T>>;
 ```
diff --git a/...ressions/server/kibana-plugin-plugins-expressions-server.execution.interpret.md b/...ressions/server/kibana-plugin-plugins-expressions-server.execution.interpret.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-interpret<T>(ast: ExpressionAstNode, input: T): Promise<unknown>;
+interpret<T>(ast: ExpressionAstNode, input: T): Observable<unknown>;
 ```
 
 ## Parameters
@@ -19,5 +19,5 @@ interpret<T>(ast: ExpressionAstNode, input: T): Promise<unknown>;
 
 <b>Returns:</b>
 
-`Promise<unknown>`
+`Observable<unknown>`
 
diff --git a/...ssions/server/kibana-plugin-plugins-expressions-server.execution.invokechain.md b/...ssions/server/kibana-plugin-plugins-expressions-server.execution.invokechain.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-invokeChain(chainArr: ExpressionAstFunction[], input: unknown): Promise<any>;
+invokeChain(chainArr: ExpressionAstFunction[], input: unknown): Observable<any>;
 ```
 
 ## Parameters
@@ -19,5 +19,5 @@ invokeChain(chainArr: ExpressionAstFunction[], input: unknown): Promise<any>;
 
 <b>Returns:</b>
 
-`Promise<any>`
+`Observable<any>`
 
diff --git a/...ons/server/kibana-plugin-plugins-expressions-server.execution.invokefunction.md b/...ons/server/kibana-plugin-plugins-expressions-server.execution.invokefunction.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-invokeFunction(fn: ExpressionFunction, input: unknown, args: Record<string, unknown>): Promise<any>;
+invokeFunction(fn: ExpressionFunction, input: unknown, args: Record<string, unknown>): Observable<any>;
 ```
 
 ## Parameters
@@ -20,5 +20,5 @@ invokeFunction(fn: ExpressionFunction, input: unknown, args: Record<string, unkn
 
 <b>Returns:</b>
 
-`Promise<any>`
+`Observable<any>`
 
diff --git a/...lugins/expressions/server/kibana-plugin-plugins-expressions-server.execution.md b/...lugins/expressions/server/kibana-plugin-plugins-expressions-server.execution.md
@@ -26,7 +26,7 @@ export declare class Execution<Input = unknown, Output = unknown, InspectorAdapt
 |  [expression](./kibana-plugin-plugins-expressions-server.execution.expression.md) |  | <code>string</code> |  |
 |  [input](./kibana-plugin-plugins-expressions-server.execution.input.md) |  | <code>Input</code> | Initial input of the execution.<!-- -->N.B. It is initialized to <code>null</code> rather than <code>undefined</code> for legacy reasons, because in legacy interpreter it was set to <code>null</code> by default. |
 |  [inspectorAdapters](./kibana-plugin-plugins-expressions-server.execution.inspectoradapters.md) |  | <code>InspectorAdapters</code> |  |
-|  [result](./kibana-plugin-plugins-expressions-server.execution.result.md) |  | <code>Promise&lt;Output &#124; ExpressionValueError&gt;</code> |  |
+|  [result](./kibana-plugin-plugins-expressions-server.execution.result.md) |  | <code>Observable&lt;Output &#124; ExpressionValueError&gt;</code> | Future that tracks result or error of this execution. |
 |  [state](./kibana-plugin-plugins-expressions-server.execution.state.md) |  | <code>ExecutionContainer&lt;Output &#124; ExpressionValueError&gt;</code> | Dynamic state of the execution. |
 
 ## Methods

diff --git a/...ssions/server/kibana-plugin-plugins-expressions-server.execution.resolveargs.md b/...ssions/server/kibana-plugin-plugins-expressions-server.execution.resolveargs.md
@@ -7,7 +7,7 @@
 <b>Signature:</b>
 
 ```typescript
-resolveArgs(fnDef: ExpressionFunction, input: unknown, argAsts: any): Promise<any>;
+resolveArgs(fnDef: ExpressionFunction, input: unknown, argAsts: any): Observable<any>;
 ```
 
 ## Parameters
@@ -20,5 +20,5 @@ resolveArgs(fnDef: ExpressionFunction, input: unknown, argAsts: any): Promise<an
 
 <b>Returns:</b>
 
-`Promise<any>`
+`Observable<any>`
 
diff --git a/...expressions/server/kibana-plugin-plugins-expressions-server.execution.result.md b/...expressions/server/kibana-plugin-plugins-expressions-server.execution.result.md
@@ -4,8 +4,10 @@
 
 ## Execution.result property
 
+Future that tracks result or error of this execution.
+
 <b>Signature:</b>
 
 ```typescript
-get result(): Promise<Output | ExpressionValueError>;
+readonly result: Observable<Output | ExpressionValueError>;
 ```
diff --git a/.../expressions/server/kibana-plugin-plugins-expressions-server.execution.start.md b/.../expressions/server/kibana-plugin-plugins-expressions-server.execution.start.md
@@ -11,7 +11,7 @@ N.B. `input` is initialized to `null` rather than `undefined` for legacy reasons
 <b>Signature:</b>
 
 ```typescript
-start(input?: Input): void;
+start(input?: Input): Observable<Output | ExpressionValueError>;
 ```
 
 ## Parameters
@@ -22,5 +22,5 @@ start(input?: Input): void;
 
 <b>Returns:</b>
 
-`void`
+`Observable<Output | ExpressionValueError>`
 
diff --git a/...ins/expressions/server/kibana-plugin-plugins-expressions-server.executor.run.md b/...ins/expressions/server/kibana-plugin-plugins-expressions-server.executor.run.md
@@ -9,7 +9,7 @@ Execute expression and return result.
 <b>Signature:</b>
 
 ```typescript
-run<Input, Output>(ast: string | ExpressionAstExpression, input: Input, params?: ExpressionExecutionParams): Promise<Output>;
+run<Input, Output>(ast: string | ExpressionAstExpression, input: Input, params?: ExpressionExecutionParams): Observable<Output | ExpressionValueError>;
 ```
 
 ## Parameters
@@ -22,5 +22,5 @@ run<Input, Output>(ast: string | ExpressionAstExpression, input: Input, params?:
 
 <b>Returns:</b>
 
-`Promise<Output>`
+`Observable<Output | ExpressionValueError>`
 
diff --git a/...ugins/expressions/server/kibana-plugin-plugins-expressions-server.typestring.md b/...ugins/expressions/server/kibana-plugin-plugins-expressions-server.typestring.md
@@ -11,5 +11,5 @@ If the type extends a Promise, we still need to return the string representation
 <b>Signature:</b>
 
 ```typescript
-export declare type TypeString<T> = KnownTypeToString<UnwrapPromiseOrReturn<T>>;
+export declare type TypeString<T> = KnownTypeToString<T extends ObservableLike<any> ? UnwrapObservable<T> : UnwrapPromiseOrReturn<T>>;
 ```
diff --git a/package.json b/package.json
@@ -141,7 +141,7 @@
     "@kbn/ui-framework": "link:packages/kbn-ui-framework",
     "@kbn/ui-shared-deps": "link:packages/kbn-ui-shared-deps",
     "@kbn/utility-types": "link:bazel-bin/packages/kbn-utility-types/npm_module",
-    "@kbn/utils": "link:packages/kbn-utils",
+    "@kbn/utils": "link:bazel-bin/packages/kbn-utils/npm_module",
     "@loaders.gl/core": "^2.3.1",
     "@loaders.gl/json": "^2.3.1",
     "@mapbox/geojson-rewind": "^0.5.0",
@@ -300,6 +300,7 @@
     "p-retry": "^4.2.0",
     "papaparse": "^5.2.0",
     "pdfmake": "^0.1.65",
+    "peggy": "^1.0.0",
     "pegjs": "0.10.0",
     "pluralize": "3.1.0",
     "pngjs": "^3.4.0",

diff --git a/packages/BUILD.bazel b/packages/BUILD.bazel
@@ -10,5 +10,6 @@ filegroup(
       "//packages/kbn-std:build",
       "//packages/kbn-tinymath:build",
       "//packages/kbn-utility-types:build",
+      "//packages/kbn-utils:build",
   ],
 )
diff --git a/packages/kbn-apm-config-loader/package.json b/packages/kbn-apm-config-loader/package.json
@@ -11,7 +11,6 @@
     "kbn:watch": "yarn build --watch"
   },
   "dependencies": {
-    "@elastic/safer-lodash-set": "link:../elastic-safer-lodash-set",
-    "@kbn/utils": "link:../kbn-utils"
+    "@elastic/safer-lodash-set": "link:../elastic-safer-lodash-set"
   }
 }
diff --git a/packages/kbn-cli-dev-mode/package.json b/packages/kbn-cli-dev-mode/package.json
@@ -18,7 +18,6 @@
     "@kbn/logging": "link:../kbn-logging",
     "@kbn/server-http-tools": "link:../kbn-server-http-tools",
     "@kbn/optimizer": "link:../kbn-optimizer",
-    "@kbn/dev-utils": "link:../kbn-dev-utils",
-    "@kbn/utils": "link:../kbn-utils"
+    "@kbn/dev-utils": "link:../kbn-dev-utils"
   }
 }
diff --git a/packages/kbn-config-schema/BUILD.bazel b/packages/kbn-config-schema/BUILD.bazel
@@ -63,15 +63,14 @@ ts_project(
 
 js_library(
   name = PKG_BASE_NAME,
-  srcs = [],
+  srcs = NPM_MODULE_EXTRA_FILES,
   deps = [":tsc"] + DEPS,
   package_name = PKG_REQUIRE_NAME,
   visibility = ["//visibility:public"],
 )
 
 pkg_npm(
   name = "npm_module",
-  srcs = NPM_MODULE_EXTRA_FILES,
   deps = [
     ":%s" % PKG_BASE_NAME,
   ]

diff --git a/packages/kbn-dev-utils/package.json b/packages/kbn-dev-utils/package.json
@@ -13,9 +13,6 @@
   "kibana": {
     "devOnly": true
   },
-  "dependencies": {
-    "@kbn/utils": "link:../kbn-utils"
-  },
   "devDependencies": {
     "@kbn/expect": "link:../kbn-expect"
   }

diff --git a/packages/kbn-docs-utils/package.json b/packages/kbn-docs-utils/package.json
@@ -13,7 +13,6 @@
     "kbn:watch": "../../node_modules/.bin/tsc --watch"
   },
   "dependencies": {
-    "@kbn/utils": "link:../kbn-utils",
     "@kbn/config": "link:../kbn-config",
     "@kbn/dev-utils": "link:../kbn-dev-utils"
   }

diff --git a/packages/kbn-es-archiver/package.json b/packages/kbn-es-archiver/package.json
@@ -14,7 +14,6 @@
   },
   "dependencies": {
     "@kbn/dev-utils": "link:../kbn-dev-utils",
-    "@kbn/test": "link:../kbn-test",
-    "@kbn/utils": "link:../kbn-utils"
+    "@kbn/test": "link:../kbn-test"
   }
 }
diff --git a/packages/kbn-es/src/cluster.js b/packages/kbn-es/src/cluster.js
@@ -272,7 +272,7 @@ exports.Cluster = class Cluster {
     // especially because we currently run many instances of ES on the same machine during CI
     options.esEnvVars.ES_JAVA_OPTS =
       (options.esEnvVars.ES_JAVA_OPTS ? `${options.esEnvVars.ES_JAVA_OPTS} ` : '') +
-      '-Xms1g -Xmx1g';
+      '-Xms2g -Xmx2g';
 
     this._process = execa(ES_BIN, args, {
       cwd: installPath,

diff --git a/packages/kbn-legacy-logging/package.json b/packages/kbn-legacy-logging/package.json
@@ -9,8 +9,5 @@
     "build": "tsc",
     "kbn:bootstrap": "yarn build",
     "kbn:watch": "yarn build --watch"
-  },
-  "dependencies": {
-    "@kbn/utils": "link:../kbn-utils"
   }
 }
diff --git a/packages/kbn-pm/package.json b/packages/kbn-pm/package.json
@@ -14,8 +14,5 @@
   },
   "devDependencies": {
     "@kbn/dev-utils": "link:../kbn-dev-utils"
-  },
-  "dependencies": {
-    "@kbn/utils": "link:../kbn-utils"
   }
 }
diff --git a/packages/kbn-test/package.json b/packages/kbn-test/package.json
@@ -20,7 +20,6 @@
   },
   "devDependencies": {
     "@kbn/dev-utils": "link:../kbn-dev-utils",
-    "@kbn/expect": "link:../kbn-expect",
-    "@kbn/utils": "link:../kbn-utils"
+    "@kbn/expect": "link:../kbn-expect"
   }
 }
diff --git a/packages/kbn-test/src/jest/integration_tests/junit_reporter.test.ts b/packages/kbn-test/src/jest/integration_tests/junit_reporter.test.ts
@@ -30,8 +30,13 @@ it(
   'produces a valid junit report for failures',
   async () => {
     const result = await execa(
-      './node_modules/.bin/jest',
-      ['--config', 'packages/kbn-test/src/jest/integration_tests/__fixtures__/jest.config.js'],
+      'node',
+      [
+        '--preserve-symlinks',
+        './node_modules/.bin/jest',
+        '--config',
+        'packages/kbn-test/src/jest/integration_tests/__fixtures__/jest.config.js',
+      ],
       {
         cwd: REPO_ROOT,
         env: {