Package com.flowable.platform.service.incident

Class FlowableIncidentReportingMeterRegistry

java.lang.Object

io.micrometer.core.instrument.MeterRegistry

io.micrometer.core.instrument.push.PushMeterRegistry

io.micrometer.core.instrument.step.StepMeterRegistry

com.flowable.platform.service.incident.FlowableIncidentReportingMeterRegistry

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

Author:

Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	FlowableIncidentReportingMeterRegistry.IncidentEntry

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 AppEngineConfiguration	appEngineConfiguration
protected final ObjectProvider<AppEngineConfiguration>	appEngineConfigurationProvider
protected final FlowableIncidentMeterConfig	config
protected ScheduledExecutorService	gaugePollingService
protected final org.slf4j.Logger	logger

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

clock

Constructor Summary

Constructors

Constructor	Description
FlowableIncidentReportingMeterRegistry(FlowableIncidentMeterConfig config, ObjectProvider<AppEngineConfiguration> appEngineConfigurationProvider)
FlowableIncidentReportingMeterRegistry(FlowableIncidentMeterConfig config, ObjectProvider<AppEngineConfiguration> appEngineConfigurationProvider, io.micrometer.core.instrument.Clock clock)

Method Summary

Modifier and Type	Method	Description
protected Map<String,Object>	createExtraInfo(io.micrometer.core.instrument.Meter.Id id, String tagToIgnore)
protected Map<String,Object>	createExtraInfo(io.micrometer.core.instrument.Meter.Id id, String tagToIgnore, Function<String,String> tagMapper)
protected FlowableIncidentReportingMeterRegistry.IncidentEntry	createIncidentEntry(io.micrometer.core.instrument.DistributionSummary timer, double threshold, double value)
protected FlowableIncidentReportingMeterRegistry.IncidentEntry	createIncidentEntry(io.micrometer.core.instrument.Timer timer, double threshold, double value)
protected io.micrometer.core.instrument.distribution.DistributionStatisticConfig	defaultHistogramConfig()
protected AppEngineConfiguration	getAppEngineConfiguration()
protected TimeUnit	getBaseTimeUnit()
protected double	getThreshold(io.micrometer.core.instrument.DistributionSummary distributionSummary)
protected double	getThreshold(io.micrometer.core.instrument.Timer timer)
protected double	getValue(io.micrometer.core.instrument.DistributionSummary distributionSummary)
protected void	pollGauges()
protected void	pollGaugesSafely()
protected void	publish()
void	start(ThreadFactory threadFactory)

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

close, 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, find, forEachMeter, gauge, gauge, gauge, gauge, gaugeCollectionSize, gaugeMapSize, get, getConventionName, getConventionTags, getMeters, isClosed, meterRegistrationFailed, more, newLongTaskTimer, newTimeGauge, remove, remove, removeByPreFilterId, summary, summary, timer, timer

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.slf4j.Logger logger

config

protected final FlowableIncidentMeterConfig config

appEngineConfigurationProvider

protected final ObjectProvider<AppEngineConfiguration> appEngineConfigurationProvider

appEngineConfiguration

protected AppEngineConfiguration appEngineConfiguration

gaugePollingService

protected ScheduledExecutorService gaugePollingService

Constructor Details

FlowableIncidentReportingMeterRegistry

public FlowableIncidentReportingMeterRegistry(FlowableIncidentMeterConfig config,
 ObjectProvider<AppEngineConfiguration> appEngineConfigurationProvider)

FlowableIncidentReportingMeterRegistry

public FlowableIncidentReportingMeterRegistry(FlowableIncidentMeterConfig config,
 ObjectProvider<AppEngineConfiguration> appEngineConfigurationProvider,
 io.micrometer.core.instrument.Clock clock)

Method Details

pollGaugesSafely

protected void pollGaugesSafely()

pollGauges

protected void pollGauges()

publish

protected void publish()

Specified by:

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

getThreshold

protected double getThreshold(io.micrometer.core.instrument.Timer timer)

getValue

protected double getValue(io.micrometer.core.instrument.DistributionSummary distributionSummary)

getThreshold

protected double getThreshold(io.micrometer.core.instrument.DistributionSummary distributionSummary)

createIncidentEntry

protected FlowableIncidentReportingMeterRegistry.IncidentEntry createIncidentEntry(io.micrometer.core.instrument.Timer timer,
 double threshold,
 double value)

createIncidentEntry

protected FlowableIncidentReportingMeterRegistry.IncidentEntry createIncidentEntry(io.micrometer.core.instrument.DistributionSummary timer,
 double threshold,
 double value)

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

getAppEngineConfiguration

protected AppEngineConfiguration getAppEngineConfiguration()

createExtraInfo

protected Map<String,Object> createExtraInfo(io.micrometer.core.instrument.Meter.Id id,
 String tagToIgnore)

createExtraInfo

protected Map<String,Object> createExtraInfo(io.micrometer.core.instrument.Meter.Id id,
 String tagToIgnore,
 Function<String,String> tagMapper)