[Alerting] Add telemetry to task manager health API to determine what…

… users are accessing it (#119349)
elastic · Nov 24, 2021 · 6eae6b8 · 6eae6b8
1 parent 90bebce
commit 6eae6b8
Show file tree

Hide file tree

Showing 5 changed files with 293 additions and 51 deletions.
diff --git a/x-pack/plugins/security/server/authorization/privileges/privileges.test.ts b/x-pack/plugins/security/server/authorization/privileges/privileges.test.ts
@@ -276,6 +276,7 @@ describe('features', () => {
           actions.version,
           ...(expectDecryptedTelemetry ? [actions.api.get('decryptedTelemetry')] : []),
           ...(expectGetFeatures ? [actions.api.get('features')] : []),
+          ...(expectGetFeatures ? [actions.api.get('taskManager')] : []),
           ...(expectManageSpaces
             ? [
                 actions.space.manage,
@@ -492,6 +493,7 @@ describe('features', () => {
           actions.version,
           ...(expectDecryptedTelemetry ? [actions.api.get('decryptedTelemetry')] : []),
           ...(expectGetFeatures ? [actions.api.get('features')] : []),
+          ...(expectGetFeatures ? [actions.api.get('taskManager')] : []),
           ...(expectManageSpaces
             ? [
                 actions.space.manage,
@@ -558,6 +560,7 @@ describe('features', () => {
           actions.version,
           ...(expectDecryptedTelemetry ? [actions.api.get('decryptedTelemetry')] : []),
           ...(expectGetFeatures ? [actions.api.get('features')] : []),
+          ...(expectGetFeatures ? [actions.api.get('taskManager')] : []),
           ...(expectManageSpaces
             ? [
                 actions.space.manage,
@@ -625,6 +628,7 @@ describe('features', () => {
           actions.version,
           ...(expectDecryptedTelemetry ? [actions.api.get('decryptedTelemetry')] : []),
           ...(expectGetFeatures ? [actions.api.get('features')] : []),
+          ...(expectGetFeatures ? [actions.api.get('taskManager')] : []),
           ...(expectManageSpaces
             ? [
                 actions.space.manage,
@@ -893,6 +897,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),
@@ -1059,6 +1064,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),
@@ -1292,6 +1298,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),
@@ -1431,6 +1438,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),
@@ -1613,6 +1621,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),
@@ -1749,6 +1758,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),
@@ -1980,6 +1990,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),
@@ -2245,6 +2256,7 @@ describe('subFeatures', () => {
         actions.version,
         actions.api.get('decryptedTelemetry'),
         actions.api.get('features'),
+        actions.api.get('taskManager'),
         actions.space.manage,
         actions.ui.get('spaces', 'manage'),
         actions.ui.get('management', 'kibana', 'spaces'),

diff --git a/x-pack/plugins/security/server/authorization/privileges/privileges.ts b/x-pack/plugins/security/server/authorization/privileges/privileges.ts
@@ -106,6 +106,7 @@ export function privilegesFactory(
             actions.version,
             actions.api.get('decryptedTelemetry'),
             actions.api.get('features'),
+            actions.api.get('taskManager'),
             actions.space.manage,
             actions.ui.get('spaces', 'manage'),
             actions.ui.get('management', 'kibana', 'spaces'),

diff --git a/x-pack/plugins/task_manager/server/plugin.ts b/x-pack/plugins/task_manager/server/plugin.ts
@@ -66,12 +66,14 @@ export class TaskManagerPlugin
   private middleware: Middleware = createInitialMiddleware();
   private elasticsearchAndSOAvailability$?: Observable<boolean>;
   private monitoringStats$ = new Subject<MonitoringStats>();
+  private readonly kibanaVersion: PluginInitializerContext['env']['packageInfo']['version'];
 
   constructor(private readonly initContext: PluginInitializerContext) {
     this.initContext = initContext;
     this.logger = initContext.logger.get();
     this.config = initContext.config.get<TaskManagerConfig>();
     this.definitions = new TaskTypeDictionary(this.logger);
+    this.kibanaVersion = initContext.env.packageInfo.version;
   }
 
   public setup(
@@ -92,15 +94,26 @@ export class TaskManagerPlugin
       this.logger.info(`TaskManager is identified by the Kibana UUID: ${this.taskManagerId}`);
     }
 
+    const startServicesPromise = core.getStartServices().then(([coreServices]) => ({
+      elasticsearch: coreServices.elasticsearch,
+    }));
+
+    const usageCounter = plugins.usageCollection?.createUsageCounter(`taskManager`);
+
     // Routes
     const router = core.http.createRouter();
-    const { serviceStatus$, monitoredHealth$ } = healthRoute(
+    const { serviceStatus$, monitoredHealth$ } = healthRoute({
       router,
-      this.monitoringStats$,
-      this.logger,
-      this.taskManagerId,
-      this.config!
-    );
+      monitoringStats$: this.monitoringStats$,
+      logger: this.logger,
+      taskManagerId: this.taskManagerId,
+      config: this.config!,
+      usageCounter,
+      kibanaVersion: this.kibanaVersion,
+      kibanaIndexName: core.savedObjects.getKibanaIndex(),
+      getClusterClient: () =>
+        startServicesPromise.then(({ elasticsearch }) => elasticsearch.client),
+    });
 
     core.status.derivedStatus$.subscribe((status) =>
       this.logger.debug(`status core.status.derivedStatus now set to ${status.level}`)