Class TelemetrySendingTask

  • All Implemented Interfaces:
    java.lang.Runnable

    public class TelemetrySendingTask
    extends java.util.TimerTask
    • Field Detail

      • METRICS_TO_REPORT

        protected static final java.util.Set<java.lang.String> METRICS_TO_REPORT
      • telemetryEndpoint

        protected java.lang.String telemetryEndpoint
      • httpConnector

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

        protected int telemetryRequestRetries
      • telemetryRequestTimeout

        protected int telemetryRequestTimeout
    • Constructor Detail

      • TelemetrySendingTask

        public TelemetrySendingTask​(CommandExecutor commandExecutor,
                                    java.lang.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 Detail

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
        Specified by:
        run in class java.util.TimerTask
      • updateAndSendData

        public TelemetryDataImpl updateAndSendData​(boolean sendData,
                                                   boolean addLegacyNames)
      • updateStaticData

        protected void updateStaticData()
      • isTelemetryEnabled

        protected boolean isTelemetryEnabled()
      • 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 java.util.Map<java.lang.String,​Command> fetchAndResetCommandCounts​(boolean reset)
      • calculateMetrics

        protected java.util.Map<java.lang.String,​Metric> calculateMetrics​(boolean reset,
                                                                                boolean addLegacyNames)
      • performDataSend

        protected void performDataSend​(java.lang.Runnable runnable)
      • validateData

        protected java.lang.Boolean validateData​(TelemetryDataImpl dataToSend)