Class AsyncExecutorMetricsReportRunner

java.lang.Object

com.flowable.platform.service.reports.AsyncExecutorMetricsReportRunner

All Implemented Interfaces:

ReportRunner, Ordered

public class AsyncExecutorMetricsReportRunner
extends Object
implements ReportRunner, Ordered

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ORDER
protected final PlatformEngineConfiguration	platformEngineConfiguration
protected static final String	REPORT_TYPE_JOB_AVG_DURATION
protected static final String	REPORT_TYPE_JOB_DEADLETTER_COUNT
protected static final String	REPORT_TYPE_JOB_DEADLETTER_RATE
protected static final String	REPORT_TYPE_JOB_EXECUTED_COUNT
protected static final String	REPORT_TYPE_JOB_EXECUTED_RATE
protected static final String	REPORT_TYPE_JOB_FAILED_COUNT
protected static final String	REPORT_TYPE_JOB_FAILED_RATE
protected static final String	REPORT_TYPE_JOB_MAX_DURATION
protected static final String	REPORT_TYPE_TASK_EXECUTOR_ACTIVE_THREADS
protected static final String	REPORT_TYPE_TASK_EXECUTOR_QUEUE_REMAINING
protected static final String	REPORT_TYPE_TASK_EXECUTOR_QUEUE_USAGE
protected static final String	REPORT_TYPE_TASK_EXECUTOR_QUEUED
protected static final String	REPORT_TYPE_TASK_EXECUTOR_THREAD_USAGE

Fields inherited from interface Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
AsyncExecutorMetricsReportRunner(PlatformEngineConfiguration platformEngineConfiguration)

Method Summary

Modifier and Type	Method	Description
boolean	canRun(ReportRequest reportRequest, ReportConfiguration report)
protected Map<String,String>	getJobMetricGroupByForBucket(List<JobMetric> metrics, String reportType)
int	getOrder()
protected Map<String,String>	getTaskExecutorGroupByForBucket(List<TaskExecutorMetric> metrics, String reportType)
protected boolean	isJobMetricReportType(String reportType)
ReportResult	run(ReportRequest reportRequest, ReportConfiguration report)
protected ReportResult	runJobMetricReport(ReportRequest reportRequest, String reportType)
protected ReportResult	runTaskExecutorMetricReport(ReportRequest reportRequest, String reportType)

Methods inherited from class Object

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

Field Details

ORDER

public static final int ORDER

See Also:

• Constant Field Values

REPORT_TYPE_TASK_EXECUTOR_ACTIVE_THREADS

protected static final String REPORT_TYPE_TASK_EXECUTOR_ACTIVE_THREADS

See Also:

• Constant Field Values

REPORT_TYPE_TASK_EXECUTOR_QUEUED

protected static final String REPORT_TYPE_TASK_EXECUTOR_QUEUED

See Also:

• Constant Field Values

REPORT_TYPE_TASK_EXECUTOR_QUEUE_REMAINING

protected static final String REPORT_TYPE_TASK_EXECUTOR_QUEUE_REMAINING

See Also:

• Constant Field Values

REPORT_TYPE_TASK_EXECUTOR_QUEUE_USAGE

protected static final String REPORT_TYPE_TASK_EXECUTOR_QUEUE_USAGE

See Also:

• Constant Field Values

REPORT_TYPE_TASK_EXECUTOR_THREAD_USAGE

protected static final String REPORT_TYPE_TASK_EXECUTOR_THREAD_USAGE

See Also:

• Constant Field Values

REPORT_TYPE_JOB_EXECUTED_RATE

protected static final String REPORT_TYPE_JOB_EXECUTED_RATE

See Also:

• Constant Field Values

REPORT_TYPE_JOB_FAILED_RATE

protected static final String REPORT_TYPE_JOB_FAILED_RATE

See Also:

• Constant Field Values

REPORT_TYPE_JOB_DEADLETTER_RATE

protected static final String REPORT_TYPE_JOB_DEADLETTER_RATE

See Also:

• Constant Field Values

REPORT_TYPE_JOB_EXECUTED_COUNT

protected static final String REPORT_TYPE_JOB_EXECUTED_COUNT

See Also:

• Constant Field Values

REPORT_TYPE_JOB_FAILED_COUNT

protected static final String REPORT_TYPE_JOB_FAILED_COUNT

See Also:

• Constant Field Values

REPORT_TYPE_JOB_DEADLETTER_COUNT

protected static final String REPORT_TYPE_JOB_DEADLETTER_COUNT

See Also:

• Constant Field Values

REPORT_TYPE_JOB_AVG_DURATION

protected static final String REPORT_TYPE_JOB_AVG_DURATION

See Also:

• Constant Field Values

REPORT_TYPE_JOB_MAX_DURATION

protected static final String REPORT_TYPE_JOB_MAX_DURATION

See Also:

• Constant Field Values

platformEngineConfiguration

protected final PlatformEngineConfiguration platformEngineConfiguration

Constructor Details

AsyncExecutorMetricsReportRunner

public AsyncExecutorMetricsReportRunner(PlatformEngineConfiguration platformEngineConfiguration)

Method Details

run

public ReportResult run(ReportRequest reportRequest,
 ReportConfiguration report)

Specified by:

run in interface ReportRunner

runTaskExecutorMetricReport

protected ReportResult runTaskExecutorMetricReport(ReportRequest reportRequest,
 String reportType)

runJobMetricReport

protected ReportResult runJobMetricReport(ReportRequest reportRequest,
 String reportType)

getTaskExecutorGroupByForBucket

protected Map<String,String> getTaskExecutorGroupByForBucket(List<TaskExecutorMetric> metrics,
 String reportType)

getJobMetricGroupByForBucket

protected Map<String,String> getJobMetricGroupByForBucket(List<JobMetric> metrics,
 String reportType)

isJobMetricReportType

protected boolean isJobMetricReportType(String reportType)

canRun

public boolean canRun(ReportRequest reportRequest,
 ReportConfiguration report)

Specified by:

canRun in interface ReportRunner

getOrder

public int getOrder()

Specified by:

getOrder in interface Ordered