Sha256: 25a99b47c0bc594083285711ae3ab79dee22a7b4a98a5043c8a5dd1e9356a0af
Contents?: true
Size: 1.85 KB
Versions: 2
Compression:
Stored size: 1.85 KB
Contents
# Copyright (c) 2022 Contrast Security, Inc. See https://www.contrastsecurity.com/enduser-terms-0317a for more details. # frozen_string_literal: true require 'contrast/agent/worker_thread' require 'contrast/agent/reporting/report' require 'contrast/agent/inventory/dependency_usage_analysis' require 'contrast/agent/reporting/reporting_events/poll' module Contrast module Agent module ReportingWorkers # The ReporterHeartbeat will make sure that the process remains marked alive by TeamServer and that we # periodically reach out to get the latest settings for this application. It also sends out those # messages which do not need to be associated directly with a request, # such as Server Activity and Library Observation. class ReporterHeartbeat < WorkerThread # TeamServer will mark an application offline after 5 minutes. Sending this every one should be more than enough # to satisfy our goals. REFRESH_INTERVAL_SEC = 60 def start_thread! return if running? @_thread = Contrast::Agent::Thread.new do logger.info('[Heartbeat] Starting thread.') loop do polling_events.each do |event| Contrast::Agent.reporter&.send_event(event) end clean_properties sleep(REFRESH_INTERVAL_SEC) end end end private def poll_message @_poll_message ||= Contrast::Agent::Reporting::Poll.new end # Those events which should be sent periodically, rather than on event or request. # # @return [Array<Contrast::Agent::Reporting::ReportingEvent>] def polling_events [Contrast::Agent::Inventory::DependencyUsageAnalysis.instance.generate_library_usage, poll_message].compact end end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
contrast-agent-6.11.0 | lib/contrast/agent/reporting/reporting_workers/reporter_heartbeat.rb |
contrast-agent-6.10.0 | lib/contrast/agent/reporting/reporting_workers/reporter_heartbeat.rb |