Contents

# frozen_string_literal: true

require_relative '../worker'
require_relative '../workers/polling'

module Datadog
  module Core
    module Telemetry
      # Periodically (every DEFAULT_INTERVAL_SECONDS) sends a heartbeat event to the telemetry API.
      class Heartbeat < Core::Worker
        include Core::Workers::Polling

        DEFAULT_INTERVAL_SECONDS = 60

        def initialize(enabled: true, interval: DEFAULT_INTERVAL_SECONDS, &block)
          # Workers::Polling settings
          self.enabled = enabled
          # Workers::IntervalLoop settings
          self.loop_base_interval = interval
          self.fork_policy = Core::Workers::Async::Thread::FORK_POLICY_STOP
          super(&block)
          start
        end

        def loop_wait_before_first_iteration?
          true
        end

        private

        def start
          perform
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
ddtrace-1.12.1	lib/datadog/core/telemetry/heartbeat.rb
ddtrace-1.12.0	lib/datadog/core/telemetry/heartbeat.rb
ddtrace-1.11.1	lib/datadog/core/telemetry/heartbeat.rb
ddtrace-1.11.0	lib/datadog/core/telemetry/heartbeat.rb
ddtrace-1.11.0.beta1	lib/datadog/core/telemetry/heartbeat.rb