Skip to content

Commit 8597c40

Browse files
committed
Implement debug flag for telemetry
1 parent 03eefec commit 8597c40

File tree

5 files changed

+16
-6
lines changed

5 files changed

+16
-6
lines changed

lib/datadog/core/configuration/settings.rb

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -946,6 +946,16 @@ def initialize(*_)
946946
# @default `nil`.
947947
# @return [String,nil]
948948
option :service
949+
950+
# For internal use only.
951+
# Enables telemetry debugging through the Datadog platform.
952+
#
953+
# @default `false`.
954+
# @return [Boolean]
955+
option :debug do |o|
956+
o.type :bool
957+
o.default false
958+
end
949959
end
950960

951961
settings :crashtracking do

lib/datadog/core/telemetry/emitter.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,9 +22,9 @@ def initialize(transport, logger: Datadog.logger)
2222
end
2323

2424
# Retrieves and emits a TelemetryRequest object based on the request type specified
25-
def request(event)
25+
def request(event, debug: false)
2626
seq_id = self.class.sequence.next
27-
payload = Request.build_payload(event, seq_id)
27+
payload = Request.build_payload(event, seq_id, debug: debug)
2828
res = @transport.send_telemetry(request_type: event.type, payload: payload)
2929
logger.debug { "Telemetry sent for event `#{event.type}` (response code: #{res.code})" }
3030
res

lib/datadog/core/telemetry/request.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,11 @@ module Request
1111
class << self
1212
using Core::Utils::Hash::Refinement
1313

14-
def build_payload(event, seq_id, api_version: 'v2')
14+
def build_payload(event, seq_id, api_version: 'v2', debug: false)
1515
hash = {
1616
api_version: api_version,
1717
application: application,
18-
debug: false,
18+
debug: debug,
1919
host: host,
2020
payload: event.payload,
2121
request_type: event.type,

sig/datadog/core/telemetry/emitter.rbs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ module Datadog
99

1010
extend Core::Utils::Forking
1111
def initialize: (untyped transport, ?logger: Core::Logger) -> void
12-
def request: (Datadog::Core::Telemetry::Event::Base event) -> (Datadog::Core::Transport::HTTP::Adapters::Net::Response | Datadog::Core::Transport::InternalErrorResponse)
12+
def request: (Datadog::Core::Telemetry::Event::Base event, ?debug: bool) -> (Datadog::Core::Transport::HTTP::Adapters::Net::Response | Datadog::Core::Transport::InternalErrorResponse)
1313
def self.sequence: () -> Datadog::Core::Utils::Sequence
1414
end
1515
end

sig/datadog/core/telemetry/request.rbs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ module Datadog
22
module Core
33
module Telemetry
44
module Request
5-
def self.build_payload: (Event::Base event, int seq_id) -> ::Hash[Symbol, untyped]
5+
def self.build_payload: (Event::Base event, int seq_id, ?debug: bool) -> ::Hash[Symbol, untyped]
66

77
private
88

0 commit comments

Comments
 (0)