github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 09:48:58 -04:00
Code Issues Projects Releases Packages Wiki Activity

[Status service] reuse plugin status observables (#126334)

Browse source
This commit is contained in:
Pierre Gayvallet 2022-02-24 21:41:58 +01:00 • committed by GitHub
parent febb41c3e6
commit c914e94841
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 47 additions and 26 deletions
Download patch file Download diff file Expand all files Collapse all files

73
src/core/server/status/plugins_status.ts
View file

@ -30,6 +30,13 @@ interface Deps {
export class PluginsStatusService {
private readonly pluginStatuses = new Map<PluginName, Observable<ServiceStatus>>();
private readonly derivedStatuses = new Map<PluginName, Observable<ServiceStatus>>();
private readonly dependenciesStatuses = new Map<
PluginName,
Observable<Record<PluginName, ServiceStatus>>
>();
private allPluginsStatuses?: Observable<Record<PluginName, ServiceStatus>>;
private readonly update$ = new BehaviorSubject(true);
private readonly defaultInheritedStatus$: Observable<ServiceStatus>;
private newRegistrationsAllowed = true;
@ -59,7 +66,10 @@ export class PluginsStatusService {
}
public getAll$(): Observable<Record<PluginName, ServiceStatus>> {
return this.getPluginStatuses$([...this.deps.pluginDependencies.keys()]);
if (!this.allPluginsStatuses) {
this.allPluginsStatuses = this.getPluginStatuses$([...this.deps.pluginDependencies.keys()]);
}
return this.allPluginsStatuses;
}
public getDependenciesStatus$(plugin: PluginName): Observable<Record<PluginName, ServiceStatus>> {
@ -67,35 +77,46 @@ export class PluginsStatusService {
if (!dependencies) {
throw new Error(`Unknown plugin: ${plugin}`);
}
return this.getPluginStatuses$(dependencies).pipe(
// Prevent many emissions at once from dependency status resolution from making this too noisy
debounceTime(25)
);
if (!this.dependenciesStatuses.has(plugin)) {
this.dependenciesStatuses.set(
plugin,
this.getPluginStatuses$(dependencies).pipe(
// Prevent many emissions at once from dependency status resolution from making this too noisy
debounceTime(25)
)
);
}
return this.dependenciesStatuses.get(plugin)!;
}
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.
if (this.anyCustomStatuses(plugin)) {
return combineLatest([this.deps.core$, this.getDependenciesStatus$(plugin)]).pipe(
map(([coreStatus, pluginStatuses]) => {
return getSummaryStatus(
[...Object.entries(coreStatus), ...Object.entries(pluginStatuses)],
{
allAvailableSummary: `All dependencies are available`,
}
if (!this.derivedStatuses.has(plugin)) {
this.derivedStatuses.set(
plugin,
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.
if (this.anyCustomStatuses(plugin)) {
return combineLatest([this.deps.core$, this.getDependenciesStatus$(plugin)]).pipe(
map(([coreStatus, pluginStatuses]) => {
return getSummaryStatus(
[...Object.entries(coreStatus), ...Object.entries(pluginStatuses)],
{
allAvailableSummary: `All dependencies are available`,
}
);
})
);
})
);
} else {
return this.defaultInheritedStatus$;
}
})
);
} else {
return this.defaultInheritedStatus$;
}
})
)
);
}
return this.derivedStatuses.get(plugin)!;
}
private getPluginStatuses$(plugins: PluginName[]): Observable<Record<PluginName, ServiceStatus>> {