Package org.camunda.bpm.engine.impl.telemetry.reporter

Class TelemetrySendingTask

java.lang.Object

java.util.TimerTask

org.camunda.bpm.engine.impl.telemetry.reporter.TelemetrySendingTask

All Implemented Interfaces:

Runnable

public class TelemetrySendingTask
extends TimerTask

Field Summary

Fields

Modifier and Type	Field	Description
protected CommandExecutor	commandExecutor
protected org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>>	httpConnector
protected static final TelemetryLogger	LOG
protected static final Set<String>	METRICS_TO_REPORT
protected MetricsRegistry	metricsRegistry
protected TelemetryDataImpl	staticData
protected String	telemetryEndpoint
protected TelemetryRegistry	telemetryRegistry
protected int	telemetryRequestRetries
protected int	telemetryRequestTimeout
protected static final String	UUID4_PATTERN

Constructor Summary

Constructors

Constructor	Description
TelemetrySendingTask(CommandExecutor commandExecutor, String telemetryEndpoint, int telemetryRequestRetries, TelemetryDataImpl data, org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> httpConnector, TelemetryRegistry telemetryRegistry, MetricsRegistry metricsRegistry, int telemetryRequestTimeout)

Method Summary

Modifier and Type	Method	Description
protected Map<String,Metric>	calculateMetrics(boolean reset, boolean addLegacyNames)
protected Map<String,Command>	fetchAndResetCommandCounts(boolean reset)
protected boolean	isSuccessStatusCode(int statusCode)
protected boolean	isTelemetryEnabled()
protected void	performDataSend(Runnable runnable)
protected InternalsImpl	resolveDynamicData(boolean reset, boolean addLegacyNames)
protected void	restoreDynamicData(InternalsImpl internals)
void	run()
protected void	sendData(TelemetryDataImpl dataToSend)
TelemetryDataImpl	updateAndSendData(boolean sendData, boolean addLegacyNames)
void	updateDataCollectionStartDate()
protected void	updateStaticData()
protected Boolean	validateData(TelemetryDataImpl dataToSend)

Methods inherited from class java.util.TimerTask

cancel, scheduledExecutionTime

Methods inherited from class java.lang.Object

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

Field Details

METRICS_TO_REPORT

protected static final Set<String> METRICS_TO_REPORT

LOG

protected static final TelemetryLogger LOG

UUID4_PATTERN

protected static final String UUID4_PATTERN

See Also:

• Constant Field Values

commandExecutor

protected CommandExecutor commandExecutor

telemetryEndpoint

protected String telemetryEndpoint

staticData

protected TelemetryDataImpl staticData

httpConnector

protected org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> httpConnector

telemetryRequestRetries

protected int telemetryRequestRetries

telemetryRegistry

protected TelemetryRegistry telemetryRegistry

metricsRegistry

protected MetricsRegistry metricsRegistry

telemetryRequestTimeout

protected int telemetryRequestTimeout

Constructor Details

TelemetrySendingTask

public TelemetrySendingTask(CommandExecutor commandExecutor,
 String telemetryEndpoint,
 int telemetryRequestRetries,
 TelemetryDataImpl data,
 org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> httpConnector,
 TelemetryRegistry telemetryRegistry,
 MetricsRegistry metricsRegistry,
 int telemetryRequestTimeout)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class TimerTask

updateAndSendData

public TelemetryDataImpl updateAndSendData(boolean sendData,
 boolean addLegacyNames)

updateStaticData

protected void updateStaticData()

updateDataCollectionStartDate

public void updateDataCollectionStartDate()

isTelemetryEnabled

protected boolean isTelemetryEnabled()

sendData

protected void sendData(TelemetryDataImpl dataToSend)

isSuccessStatusCode

protected boolean isSuccessStatusCode(int statusCode)

Returns:

true if status code is 2xx

restoreDynamicData

protected void restoreDynamicData(InternalsImpl internals)

resolveDynamicData

protected InternalsImpl resolveDynamicData(boolean reset,
 boolean addLegacyNames)

fetchAndResetCommandCounts

protected Map<String,Command> fetchAndResetCommandCounts(boolean reset)

calculateMetrics

protected Map<String,Metric> calculateMetrics(boolean reset,
 boolean addLegacyNames)

performDataSend

protected void performDataSend(Runnable runnable)

validateData

protected Boolean validateData(TelemetryDataImpl dataToSend)