Class: Chronos::Application::CaptureTelemetry

Inherits:
Object
  • Object
show all
Defined in:
lib/chronos/application/capture_telemetry.rb

Overview

Coordinates bounded non-exception telemetry capture.

Examples:

capture.call("query", {"duration_ms" => 3.2})

Instance Method Summary collapse

Constructor Details

#initialize(config, delivery_pipeline, logger = nil, options = {}) ⇒ CaptureTelemetry

Returns a new instance of CaptureTelemetry.



16
17
18
19
20
21
22
23
 
# File 'lib/chronos/application/capture_telemetry.rb', line 16

def initialize(config, delivery_pipeline, logger = nil, options = {})
  @config = config
  @delivery_pipeline = delivery_pipeline
  @logger = logger || Internal::SafeLogger.new(config.logger)
  @serializer = options[:serializer] || Core::TelemetrySerializer.new(
    config, nil, :max_payload_size => proc { @delivery_pipeline.max_payload_size }
  )
end

Instance Method Details

#call(event_type, payload = {}, context = {}) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
 
# File 'lib/chronos/application/capture_telemetry.rb', line 25

def call(event_type, payload = {}, context = {})
  return false unless @config.enabled_for_environment?
  return false unless @delivery_pipeline.capture_allowed?(event_type)

  event = Core::TelemetryEvent.new(event_type, payload, context)
  @delivery_pipeline.enqueue(@serializer.call(event))
rescue StandardError => error
  @logger.warn("Chronos telemetry capture failed: #{error.class}")
  false
end