Sha256: 01f5ff7939b74e68030e7b96d34de1a3315069b2ebfc0a534af5fb89016d31ea
Contents?: true
Size: 852 Bytes
Versions: 6
Compression:
Stored size: 852 Bytes
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
def initialize(heartbeat_interval_seconds:, enabled: true, &block)
# Workers::Polling settings
self.enabled = enabled
# Workers::IntervalLoop settings
self.loop_base_interval = heartbeat_interval_seconds
self.fork_policy = Core::Workers::Async::Thread::FORK_POLICY_STOP
super(&block)
start
end
def loop_wait_before_first_iteration?; end
private
def start
perform
end
end
end
end
end
Version data entries
6 entries across 6 versions & 2 rubygems