import { Logger } from 'src/core/server' ; import { Observable } from 'rxjs' ; import { TaskManagerConfig } from '../config' ; import { MonitoringStats , createAggregators , createMonitoringStatsStream , } from './monitoring_stats_stream' ; import { TaskStore } from '../task_store' ; import { TaskPollingLifecycle } from '../polling_lifecycle' ; import { ManagedConfiguration } from '../lib/create_managed_configuration' ; import { EphemeralTaskLifecycle } from '../ephemeral_task_lifecycle' ; export type { MonitoringStats , RawMonitoringStats } from './monitoring_stats_stream' ; export { HealthStatus , summarizeMonitoringStats , createAggregators , createMonitoringStatsStream , } from './monitoring_stats_stream' ; export function createMonitoringStats ( taskPollingLifecycle , ephemeralTaskLifecycle , taskStore , elasticsearchAndSOAvailability$ , config , managedConfig , logger ) { return createMonitoringStatsStream ( createAggregators ( taskPollingLifecycle , ephemeralTaskLifecycle , taskStore , elasticsearchAndSOAvailability$ , config , managedConfig , logger ) , config ) ; }