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

Class TelemetryReporter

java.lang.Object

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

public class TelemetryReporter
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected CommandExecutor	commandExecutor
protected TelemetryDataImpl	data
static long	DEFAULT_INIT_REPORT_DELAY_SECONDS	Report after 5 minutes the first time so that we get an initial ping quickly.
static long	EXTENDED_INIT_REPORT_DELAY_SECONDS	Report after 3 hours for the first time so that other modules (e.g.
protected org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>>	httpConnector
protected static final TelemetryLogger	LOG
protected MetricsRegistry	metricsRegistry
protected long	reportingIntervalInSeconds
protected String	telemetryEndpoint
protected TelemetryRegistry	telemetryRegistry
protected int	telemetryRequestRetries
protected int	telemetryRequestTimeout
protected TelemetrySendingTask	telemetrySendingTask
protected Timer	timer

Constructor Summary

Constructors

Constructor	Description
TelemetryReporter(CommandExecutor commandExecutor, String telemetryEndpoint, int telemetryRequestRetries, long telemetryReportingPeriod, 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
org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>>	getHttpConnector()
long	getInitialReportingDelaySeconds()
long	getReportingIntervalInSeconds()
String	getTelemetryEndpoint()
TelemetrySendingTask	getTelemetrySendingTask()
protected void	initTelemetrySendingTask()
boolean	isScheduled()
void	reportNow()
void	reschedule()
void	setTelemetrySendingTask(TelemetrySendingTask telemetrySendingTask)
void	start()
void	stop()
void	stop(boolean report)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final TelemetryLogger LOG

reportingIntervalInSeconds

protected long reportingIntervalInSeconds

DEFAULT_INIT_REPORT_DELAY_SECONDS

public static long DEFAULT_INIT_REPORT_DELAY_SECONDS

Report after 5 minutes the first time so that we get an initial ping quickly. 5 minutes delay so that other modules (e.g. those collecting the app server name) can contribute their data.

EXTENDED_INIT_REPORT_DELAY_SECONDS

public static long EXTENDED_INIT_REPORT_DELAY_SECONDS

Report after 3 hours for the first time so that other modules (e.g. those collecting the app server name) can contribute their data and test cases which accidentally enable reporting are very unlikely to send data.

telemetrySendingTask

protected TelemetrySendingTask telemetrySendingTask

timer

protected Timer timer

commandExecutor

protected CommandExecutor commandExecutor

telemetryEndpoint

protected String telemetryEndpoint

telemetryRequestRetries

protected int telemetryRequestRetries

data

protected TelemetryDataImpl data

httpConnector

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

telemetryRegistry

protected TelemetryRegistry telemetryRegistry

metricsRegistry

protected MetricsRegistry metricsRegistry

telemetryRequestTimeout

protected int telemetryRequestTimeout

Constructor Details

TelemetryReporter

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

Method Details

initTelemetrySendingTask

protected void initTelemetrySendingTask()

start

public void start()

reschedule

public void reschedule()

stop

public void stop()

stop

public void stop(boolean report)

reportNow

public void reportNow()

isScheduled

public boolean isScheduled()

getReportingIntervalInSeconds

public long getReportingIntervalInSeconds()

getTelemetrySendingTask

public TelemetrySendingTask getTelemetrySendingTask()

setTelemetrySendingTask

public void setTelemetrySendingTask(TelemetrySendingTask telemetrySendingTask)

getTelemetryEndpoint

public String getTelemetryEndpoint()

getHttpConnector

public org.camunda.connect.spi.Connector<? extends org.camunda.connect.spi.ConnectorRequest<?>> getHttpConnector()

getInitialReportingDelaySeconds

public long getInitialReportingDelaySeconds()