maxmustermann/kibana
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[alerting] disable status reporting for now (#116717)

Browse source 
Co-authored-by: spalger <spalger@users.noreply.github.com>
This commit is contained in:
Spencer 2021-10-29 12:48:03 -05:00 committed by GitHub
parent 29ac5583b7
commit 05cfe434f0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 31 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

57
x-pack/plugins/alerting/server/plugin.ts
View file

@ -6,10 +6,9 @@
*/
import type { PublicMethodsOf } from '@kbn/utility-types';
import { first, map, share } from 'rxjs/operators';
import { first } from 'rxjs/operators';
import { BehaviorSubject } from 'rxjs';
import { UsageCollectionSetup } from 'src/plugins/usage_collection/server';
import { combineLatest } from 'rxjs';
import { SecurityPluginSetup, SecurityPluginStart } from '../../security/server';
import {
EncryptedSavedObjectsPluginSetup,
@ -61,11 +60,7 @@ import {
initializeApiKeyInvalidator,
scheduleApiKeyInvalidatorTask,
} from './invalidate_pending_api_keys/task';
import {
getHealthStatusStream,
scheduleAlertingHealthCheck,
initializeAlertingHealth,
} from './health';
import { scheduleAlertingHealthCheck, initializeAlertingHealth } from './health';
import { AlertsConfig } from './config';
import { getHealth } from './health/get_health';
import { AlertingAuthorizationClientFactory } from './alerting_authorization_client_factory';
@ -236,33 +231,33 @@ export class AlertingPlugin {
);
const serviceStatus$ = new BehaviorSubject<ServiceStatus>({
level: ServiceStatusLevels.degraded,
summary: 'Alerting is initializing',
level: ServiceStatusLevels.available,
summary: 'Alerting is (probably) ready',
});
core.status.set(serviceStatus$);
core.getStartServices().then(async ([coreStart, startPlugins]) => {
combineLatest([
core.status.derivedStatus$,
getHealthStatusStream(
startPlugins.taskManager,
this.logger,
coreStart.savedObjects,
this.config
),
])
.pipe(
map(([derivedStatus, healthStatus]) => {
if (healthStatus.level > derivedStatus.level) {
return healthStatus as ServiceStatus;
} else {
return derivedStatus;
}
}),
share()
)
.subscribe(serviceStatus$);
});
// core.getStartServices().then(async ([coreStart, startPlugins]) => {
// combineLatest([
// core.status.derivedStatus$,
// getHealthStatusStream(
// startPlugins.taskManager,
// this.logger,
// coreStart.savedObjects,
// this.config
// ),
// ])
// .pipe(
// map(([derivedStatus, healthStatus]) => {
// if (healthStatus.level > derivedStatus.level) {
// return healthStatus as ServiceStatus;
// } else {
// return derivedStatus;
// }
// }),
// share()
// )
// .subscribe(serviceStatus$);
// });
initializeAlertingHealth(this.logger, plugins.taskManager, core.getStartServices());