Class FlowableAsyncExecutorMeterRegistry

java.lang.Object

io.micrometer.core.instrument.MeterRegistry

io.micrometer.core.instrument.push.PushMeterRegistry

io.micrometer.core.instrument.step.StepMeterRegistry

com.flowable.platform.service.metrics.FlowableAsyncExecutorMeterRegistry

public class FlowableAsyncExecutorMeterRegistry
extends io.micrometer.core.instrument.step.StepMeterRegistry

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	FlowableAsyncExecutorMeterRegistry.JobMetricEntry
protected static class	FlowableAsyncExecutorMeterRegistry.TaskExecutorMetricEntry

Nested classes/interfaces inherited from class io.micrometer.core.instrument.MeterRegistry

io.micrometer.core.instrument.MeterRegistry.Config, io.micrometer.core.instrument.MeterRegistry.More

Field Summary

Fields

Modifier and Type	Field	Description
protected final FlowableAsyncExecutorMeterConfig	config
protected ScheduledExecutorService	flushScheduler
protected List<FlowableAsyncExecutorMeterRegistry.JobMetricEntry>	jobMetricEntries
protected final org.slf4j.Logger	logger
protected final Object	metricsLock
protected PlatformEngineConfiguration	platformEngineConfiguration
protected final ObjectProvider<PlatformEngineConfiguration>	platformEngineConfigurationProvider
protected List<FlowableAsyncExecutorMeterRegistry.TaskExecutorMetricEntry>	taskExecutorMetricEntries

Fields inherited from class io.micrometer.core.instrument.MeterRegistry

clock

Constructor Summary

Constructors

Constructor	Description
FlowableAsyncExecutorMeterRegistry(FlowableAsyncExecutorMeterConfig config, ObjectProvider<PlatformEngineConfiguration> platformEngineConfigurationObjectProvider)
FlowableAsyncExecutorMeterRegistry(FlowableAsyncExecutorMeterConfig config, ObjectProvider<PlatformEngineConfiguration> platformEngineConfigurationObjectProvider, io.micrometer.core.instrument.Clock clock)

Method Summary

Modifier and Type	Method	Description
void	close()
protected FlowableAsyncExecutorMeterRegistry.JobMetricEntry	createJobMetricEntry(String jobType, String tenantId, String node, Instant timestamp)
protected io.micrometer.core.instrument.distribution.DistributionStatisticConfig	defaultHistogramConfig()
protected String	determineNodeTag(List<io.micrometer.core.instrument.Meter> meters)
protected void	flushToDB()
protected TimeUnit	getBaseTimeUnit()
protected PlatformEngineConfiguration	getPlatformEngineConfiguration()
protected void	publish()
protected String	resolveJobMetricType(String meterName)
void	start(ThreadFactory threadFactory)

Methods inherited from class io.micrometer.core.instrument.step.StepMeterRegistry

newCounter, newDistributionSummary, newFunctionCounter, newFunctionTimer, newGauge, newLongTaskTimer, newMeter, newTimer, stop

Methods inherited from class io.micrometer.core.instrument.push.PushMeterRegistry

getLastScheduledPublishStartTime, isPublishing, start, startMessage, waitForInProgressScheduledPublish

Methods inherited from class io.micrometer.core.instrument.MeterRegistry

clear, config, counter, counter, counter, find, forEachMeter, gauge, gauge, gauge, gauge, gaugeCollectionSize, gaugeMapSize, get, getConventionName, getConventionTags, getMeters, isClosed, meterRegistrationFailed, more, newLongTaskTimer, newTimeGauge, remove, remove, removeByPreFilterId, summary, summary, timer, timer, timer

Methods inherited from class Object

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

Field Details

logger

protected final org.slf4j.Logger logger

config

protected final FlowableAsyncExecutorMeterConfig config

platformEngineConfigurationProvider

protected final ObjectProvider<PlatformEngineConfiguration> platformEngineConfigurationProvider

platformEngineConfiguration

protected volatile PlatformEngineConfiguration platformEngineConfiguration

metricsLock

protected final Object metricsLock

flushScheduler

protected ScheduledExecutorService flushScheduler

taskExecutorMetricEntries

protected List<FlowableAsyncExecutorMeterRegistry.TaskExecutorMetricEntry> taskExecutorMetricEntries

jobMetricEntries

protected List<FlowableAsyncExecutorMeterRegistry.JobMetricEntry> jobMetricEntries

Constructor Details

FlowableAsyncExecutorMeterRegistry

public FlowableAsyncExecutorMeterRegistry(FlowableAsyncExecutorMeterConfig config,
 ObjectProvider<PlatformEngineConfiguration> platformEngineConfigurationObjectProvider)

FlowableAsyncExecutorMeterRegistry

public FlowableAsyncExecutorMeterRegistry(FlowableAsyncExecutorMeterConfig config,
 ObjectProvider<PlatformEngineConfiguration> platformEngineConfigurationObjectProvider,
 io.micrometer.core.instrument.Clock clock)

Method Details

publish

protected void publish()

Specified by:

publish in class io.micrometer.core.instrument.push.PushMeterRegistry

flushToDB

protected void flushToDB()

defaultHistogramConfig

protected io.micrometer.core.instrument.distribution.DistributionStatisticConfig defaultHistogramConfig()

Overrides:

defaultHistogramConfig in class io.micrometer.core.instrument.step.StepMeterRegistry

getBaseTimeUnit

protected TimeUnit getBaseTimeUnit()

Specified by:

getBaseTimeUnit in class io.micrometer.core.instrument.MeterRegistry

start

public void start(ThreadFactory threadFactory)

Overrides:

start in class io.micrometer.core.instrument.step.StepMeterRegistry

close

public void close()

Overrides:

close in class io.micrometer.core.instrument.step.StepMeterRegistry

resolveJobMetricType

protected String resolveJobMetricType(String meterName)

createJobMetricEntry

protected FlowableAsyncExecutorMeterRegistry.JobMetricEntry createJobMetricEntry(String jobType,
 String tenantId,
 String node,
 Instant timestamp)

determineNodeTag

protected String determineNodeTag(List<io.micrometer.core.instrument.Meter> meters)

getPlatformEngineConfiguration

protected PlatformEngineConfiguration getPlatformEngineConfiguration()