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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TelemetrySendingTask.CalculateMetricsCommand
protected class	TelemetrySendingTask.SendInitialMsgCmd

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected long	calculateMetricCount(ManagementService managementService, Date startReportTime, Date currentTime, String metricName)
protected Map<String,Metric>	calculateMetrics()
protected long	calculateUniqueUserCount(CommandContext commandContext, HistoryLevel historyLevel, Date currentTime)
protected void	clearDynamicData()
protected Map<String,Command>	fetchAndResetCommandCounts()
protected boolean	isSuccessStatusCode(int statusCode)
protected boolean	isTelemetryEnabled()
protected void	performDataSend(Boolean isInitialMessage, Runnable runnable)
protected Date	previousDay(Date date)
protected Internals	resolveDynamicData()
protected void	restoreDynamicData(Internals internals)
void	run()
protected void	sendData(Data dataToSend, boolean isInitialMessage)
protected void	sendInitialMessage()
protected void	sendInitialMessage(CommandContext commandContext)
protected void	updateStaticData()
protected void	updateTelemetryFlag(boolean enabled)
protected Boolean	validateData(Data 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 Detail

LOG

protected static final TelemetryLogger LOG

METRICS_TO_REPORT

protected static final Set<String> METRICS_TO_REPORT

TELEMETRY_INIT_MESSAGE_SENT_NAME

protected static final String TELEMETRY_INIT_MESSAGE_SENT_NAME

See Also:

Constant Field Values

UUID4_PATTERN

protected static final String UUID4_PATTERN

See Also:

Constant Field Values

commandExecutor

protected CommandExecutor commandExecutor

telemetryEndpoint

protected String telemetryEndpoint

staticData

protected Data 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

sendInitialMessage

protected boolean sendInitialMessage

Constructor Detail

TelemetrySendingTask

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

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in class TimerTask

sendInitialMessage

protected void sendInitialMessage()

sendInitialMessage

protected void sendInitialMessage(CommandContext commandContext)

updateStaticData

protected void updateStaticData()

isTelemetryEnabled

protected boolean isTelemetryEnabled()

sendData

protected void sendData(Data dataToSend,
                        boolean isInitialMessage)

isSuccessStatusCode

protected boolean isSuccessStatusCode(int statusCode)

Returns:

true if status code is 2xx

clearDynamicData

protected void clearDynamicData()

restoreDynamicData

protected void restoreDynamicData(Internals internals)

resolveDynamicData

protected Internals resolveDynamicData()

fetchAndResetCommandCounts

protected Map<String,Command> fetchAndResetCommandCounts()

calculateMetrics

protected Map<String,Metric> calculateMetrics()

calculateMetricCount

protected long calculateMetricCount(ManagementService managementService,
                                    Date startReportTime,
                                    Date currentTime,
                                    String metricName)

calculateUniqueUserCount

protected long calculateUniqueUserCount(CommandContext commandContext,
                                        HistoryLevel historyLevel,
                                        Date currentTime)

previousDay

protected Date previousDay(Date date)

updateTelemetryFlag

protected void updateTelemetryFlag(boolean enabled)

performDataSend

protected void performDataSend(Boolean isInitialMessage,
                               Runnable runnable)

validateData

protected Boolean validateData(Data dataToSend)