Add debounce to the status observers to reduce unnecessary CPU loops (e…

…lastic#108952) (elastic#108998)

Co-authored-by: Alejandro Fernández Haro <[email protected]>

src/core/server/status/plugins_status.test.ts

@@ -247,7 +247,6 @@ describe('PluginStatusService', () => {
       subscription.unsubscribe();
 
       expect(statusUpdates).toEqual([
-        { a: { level: ServiceStatusLevels.available, summary: 'All dependencies are available' } },
         { a: { level: ServiceStatusLevels.degraded, summary: 'a degraded' } },
         { a: { level: ServiceStatusLevels.unavailable, summary: 'a unavailable' } },
         { a: { level: ServiceStatusLevels.available, summary: 'a available' } },
@@ -274,7 +273,6 @@ describe('PluginStatusService', () => {
       subscription.unsubscribe();
 
       expect(statusUpdates).toEqual([
-        { a: { level: ServiceStatusLevels.available, summary: 'All dependencies are available' } },
         { a: { level: ServiceStatusLevels.degraded, summary: 'a degraded' } },
         { a: { level: ServiceStatusLevels.unavailable, summary: 'a unavailable' } },
         { a: { level: ServiceStatusLevels.available, summary: 'a available' } },
@@ -357,6 +355,35 @@ describe('PluginStatusService', () => {
       }).toThrowError();
     });
 
+    it('debounces plugins custom status registration', async () => {
+      const service = new PluginsStatusService({
+        core$: coreAllAvailable$,
+        pluginDependencies,
+      });
+      const available: ServiceStatus = {
+        level: ServiceStatusLevels.available,
+        summary: 'a available',
+      };
+
+      const statusUpdates: Array<Record<string, ServiceStatus>> = [];
+      const subscription = service
+        .getDependenciesStatus$('b')
+        .subscribe((status) => statusUpdates.push(status));
+
+      const pluginA$ = new BehaviorSubject(available);
+      service.set('a', pluginA$);
+
+      expect(statusUpdates).toStrictEqual([]);
+
+      const delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));
+
+      // Waiting for the debounce timeout should cut a new update
+      await delay(25);
+      subscription.unsubscribe();
+
+      expect(statusUpdates).toStrictEqual([{ a: available }]);
+    });
+
     it('debounces events in quick succession', async () => {
       const service = new PluginsStatusService({
         core$: coreAllAvailable$,

src/core/server/status/plugins_status.ts

@@ -76,6 +76,7 @@ export class PluginsStatusService {
 
   public getDerivedStatus$(plugin: PluginName): Observable<ServiceStatus> {
     return this.update$.pipe(
+      debounceTime(25), // Avoid calling the plugin's custom status logic for every plugin that depends on it.
       switchMap(() => {
         // Only go up the dependency tree if any of this plugin's dependencies have a custom status
         // Helps eliminate memory overhead of creating thousands of Observables unnecessarily.