Class HealthSummaryService

java.lang.Object

com.flowable.platform.service.health.HealthSummaryService

public class HealthSummaryService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<HealthAdvisor>	advisors
protected final CoreAppManagementService	appManagementService
protected final org.flowable.cmmn.api.CmmnHistoryService	cmmnHistoryService
protected final org.flowable.engine.HistoryService	historyService
protected final org.flowable.engine.ManagementService	managementService
protected final PlatformEngineConfiguration	platformEngineConfiguration
protected final CoreReportingService	reportingService
protected final FlowableSystemInformationService	systemInformationService

Constructor Summary

Constructors

Constructor	Description
HealthSummaryService(FlowableSystemInformationService systemInformationService, CoreReportingService reportingService, PlatformEngineConfiguration platformEngineConfiguration, CoreAppManagementService appManagementService, org.flowable.engine.HistoryService historyService, org.flowable.cmmn.api.CmmnHistoryService cmmnHistoryService, org.flowable.engine.ManagementService managementService)
HealthSummaryService(FlowableSystemInformationService systemInformationService, CoreReportingService reportingService, PlatformEngineConfiguration platformEngineConfiguration, CoreAppManagementService appManagementService, org.flowable.engine.HistoryService historyService, org.flowable.cmmn.api.CmmnHistoryService cmmnHistoryService, org.flowable.engine.ManagementService managementService, List<HealthAdvisor> advisors)

Method Summary

Modifier and Type	Method	Description
protected List<HealthAdviceItem>	computeAdvice(HealthSummaryResponse response, List<SystemInformation> systemInfo, String tenantId)
protected ExecutorMetrics	computeExecutorMetrics()	Computes executor metrics using ES (primary) with DB fallback, consistent with computeMetrics(Date, Date, String).
protected ExecutorMetrics	computeExecutorMetricsFromDb(Instant to, Instant from10m, Instant from1h)
protected void	computeJobMetricsFromDb(HealthSummaryResponse.HealthSummaryMetrics metrics, Date from, Date to, String tenantId)
protected HealthSummaryResponse.HealthSummaryMetrics	computeMetrics(Date from, Date to, String tenantId)
protected Map<String, HealthSummaryResponse.NodeJobThroughput>	computeNodeJobThroughput(int minutesAgo, String tenantId)
protected Map<String, HealthSummaryResponse.NodeJobThroughput>	computeNodeJobThroughputFromEs(int minutesAgo, Date from, Date to, String tenantId)	Computes per-node job throughput from ES.
protected List<SlowJobIncidentCount>	computeSlowJobIncidentCounts(int minutesAgo, String tenantId)
protected Map<String, Map<String, ExecutorNodeSnapshot>>	dbLatestExecutorSnapshotsByNode(Instant from, Instant to)
protected ExecutorMetrics	fetchExecutorMetricsFromEs(Instant to, Instant from10m, Instant from1h)
HealthSummaryResponse	getHealthSummary(int minutesAgo, Integer comparisonMinutesAgo, String tenantId)
protected boolean	isElasticSearchMetricsAvailable()	Returns true if Micrometer metrics are being exported to Elasticsearch, meaning ES-backed metric reports can be used.
protected Map<String, Map<String, HealthSummaryResponse.NodeExecutorMetrics>>	mergeNodeExecutorMetrics(Map<String, Map<String, ExecutorNodeSnapshot>> currentSnapshots, Map<String, Map<String,Integer>> threadByNode10m, Map<String, Map<String,Integer>> threadByNode1h, Map<String, Map<String,Integer>> queueByNode10m, Map<String, Map<String,Integer>> queueByNode1h)
protected tools.jackson.databind.JsonNode	runRawReport(String reportId, Instant from, Instant to)
protected tools.jackson.databind.JsonNode	runRawReport(String reportId, Instant from, Instant to, String tenantId)
protected void	scaleStartedCountsToWindow(HealthSummaryResponse.HealthSummaryMetrics metrics, double factor)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

systemInformationService

protected final FlowableSystemInformationService systemInformationService

reportingService

protected final CoreReportingService reportingService

platformEngineConfiguration

protected final PlatformEngineConfiguration platformEngineConfiguration

appManagementService

protected final CoreAppManagementService appManagementService

historyService

protected final org.flowable.engine.HistoryService historyService

cmmnHistoryService

protected final org.flowable.cmmn.api.CmmnHistoryService cmmnHistoryService

managementService

protected final org.flowable.engine.ManagementService managementService

advisors

protected final List<HealthAdvisor> advisors

Constructor Details

HealthSummaryService

public HealthSummaryService(FlowableSystemInformationService systemInformationService,
 CoreReportingService reportingService,
 PlatformEngineConfiguration platformEngineConfiguration,
 CoreAppManagementService appManagementService,
 org.flowable.engine.HistoryService historyService,
 org.flowable.cmmn.api.CmmnHistoryService cmmnHistoryService,
 org.flowable.engine.ManagementService managementService)

HealthSummaryService

public HealthSummaryService(FlowableSystemInformationService systemInformationService,
 CoreReportingService reportingService,
 PlatformEngineConfiguration platformEngineConfiguration,
 CoreAppManagementService appManagementService,
 org.flowable.engine.HistoryService historyService,
 org.flowable.cmmn.api.CmmnHistoryService cmmnHistoryService,
 org.flowable.engine.ManagementService managementService,
 List<HealthAdvisor> advisors)

Method Details

getHealthSummary

public HealthSummaryResponse getHealthSummary(int minutesAgo,
 Integer comparisonMinutesAgo,
 String tenantId)

computeAdvice

protected List<HealthAdviceItem> computeAdvice(HealthSummaryResponse response,
 List<SystemInformation> systemInfo,
 String tenantId)

computeMetrics

protected HealthSummaryResponse.HealthSummaryMetrics computeMetrics(Date from,
 Date to,
 String tenantId)

scaleStartedCountsToWindow

protected void scaleStartedCountsToWindow(HealthSummaryResponse.HealthSummaryMetrics metrics,
 double factor)

isElasticSearchMetricsAvailable

protected boolean isElasticSearchMetricsAvailable()

Returns true if Micrometer metrics are being exported to Elasticsearch, meaning ES-backed metric reports can be used.

computeExecutorMetrics

protected ExecutorMetrics computeExecutorMetrics()

Computes executor metrics using ES (primary) with DB fallback, consistent with computeMetrics(Date, Date, String).

fetchExecutorMetricsFromEs

protected ExecutorMetrics fetchExecutorMetricsFromEs(Instant to,
 Instant from10m,
 Instant from1h)

runRawReport

protected tools.jackson.databind.JsonNode runRawReport(String reportId,
 Instant from,
 Instant to)

runRawReport

protected tools.jackson.databind.JsonNode runRawReport(String reportId,
 Instant from,
 Instant to,
 String tenantId)

computeExecutorMetricsFromDb

protected ExecutorMetrics computeExecutorMetricsFromDb(Instant to,
 Instant from10m,
 Instant from1h)

dbLatestExecutorSnapshotsByNode

protected Map<String, Map<String, ExecutorNodeSnapshot>> dbLatestExecutorSnapshotsByNode(Instant from,
 Instant to)

mergeNodeExecutorMetrics

protected Map<String, Map<String, HealthSummaryResponse.NodeExecutorMetrics>> mergeNodeExecutorMetrics(Map<String, Map<String, ExecutorNodeSnapshot>> currentSnapshots,
 Map<String, Map<String,Integer>> threadByNode10m,
 Map<String, Map<String,Integer>> threadByNode1h,
 Map<String, Map<String,Integer>> queueByNode10m,
 Map<String, Map<String,Integer>> queueByNode1h)

computeJobMetricsFromDb

protected void computeJobMetricsFromDb(HealthSummaryResponse.HealthSummaryMetrics metrics,
 Date from,
 Date to,
 String tenantId)

computeSlowJobIncidentCounts

protected List<SlowJobIncidentCount> computeSlowJobIncidentCounts(int minutesAgo,
 String tenantId)

computeNodeJobThroughput

protected Map<String, HealthSummaryResponse.NodeJobThroughput> computeNodeJobThroughput(int minutesAgo,
 String tenantId)

computeNodeJobThroughputFromEs

protected Map<String, HealthSummaryResponse.NodeJobThroughput> computeNodeJobThroughputFromEs(int minutesAgo,
 Date from,
 Date to,
 String tenantId)

Computes per-node job throughput from ES. Counts come from the job-metrics-summary-by-node report (counters); avg execution duration comes from the job-execution-time-avg-by-node report (weighted_avg over the flowable_job_execution Timer's mean, weighted by sample count). Returns null when the counts report did not yield any data (so the caller can fall back to DB).