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 Data |
staticData |
protected String |
telemetryEndpoint |
protected TelemetryRegistry |
telemetryRegistry |
protected int |
telemetryRequestRetries |
protected int |
telemetryRequestTimeout |
protected static String |
UUID4_PATTERN |
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) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,Metric> |
calculateMetrics() |
protected void |
clearDynamicData() |
protected Map<String,Command> |
fetchAndResetCommandCounts() |
protected boolean |
isSuccessStatusCode(int statusCode) |
protected boolean |
isTelemetryEnabled() |
protected void |
performDataSend(Runnable runnable) |
protected Internals |
resolveDynamicData() |
protected void |
restoreDynamicData(Internals internals) |
void |
run() |
protected void |
sendData(Data dataToSend) |
protected void |
updateStaticData() |
protected void |
updateTelemetryFlag(boolean enabled) |
protected Boolean |
validateData(Data dataToSend) |
cancel, scheduledExecutionTime
protected static final TelemetryLogger LOG
protected static final String UUID4_PATTERN
protected CommandExecutor commandExecutor
protected String telemetryEndpoint
protected Data staticData
protected org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> httpConnector
protected int telemetryRequestRetries
protected TelemetryRegistry telemetryRegistry
protected MetricsRegistry metricsRegistry
protected int telemetryRequestTimeout
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)
protected void updateStaticData()
protected boolean isTelemetryEnabled()
protected void sendData(Data dataToSend)
protected boolean isSuccessStatusCode(int statusCode)
protected void clearDynamicData()
protected void restoreDynamicData(Internals internals)
protected Internals resolveDynamicData()
protected void updateTelemetryFlag(boolean enabled)
protected void performDataSend(Runnable runnable)
Copyright © 2022. All rights reserved.