File tree Expand file tree Collapse file tree 4 files changed +26
-12
lines changed
lib/datadog/core/telemetry
sig/datadog/core/telemetry
spec/datadog/core/telemetry Expand file tree Collapse file tree 4 files changed +26
-12
lines changed Original file line number Diff line number Diff line change @@ -354,9 +354,11 @@ def initialize(message:, level:)
354
354
355
355
def payload
356
356
{
357
- message : @message ,
358
- level : @level ,
359
- # More optional fields to be added here...
357
+ logs : [ {
358
+ message : @message ,
359
+ level : @level ,
360
+ # More optional fields to be added here...
361
+ } ]
360
362
}
361
363
end
362
364
end
Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ module Datadog
75
75
76
76
def initialize : (message: String, level: Symbol) -> void
77
77
78
- def payload : () -> { message: String, level: String }
78
+ def payload : () -> { logs: [{ message: String, level: String }] }
79
79
end
80
80
81
81
class Distributions < GenerateMetrics
Original file line number Diff line number Diff line change @@ -218,26 +218,38 @@ def contain_configuration(*array)
218
218
event = Datadog ::Core ::Telemetry ::Event ::Log . new ( message : 'Hi' , level : :error )
219
219
expect ( event . type ) . to eq ( 'logs' )
220
220
expect ( event . payload ) . to eq (
221
- message : 'Hi' ,
222
- level : 'ERROR'
221
+ {
222
+ logs : [
223
+ message : 'Hi' ,
224
+ level : 'ERROR'
225
+ ]
226
+ }
223
227
)
224
228
end
225
229
226
230
it do
227
231
event = Datadog ::Core ::Telemetry ::Event ::Log . new ( message : 'Hi' , level : :debug )
228
232
expect ( event . type ) . to eq ( 'logs' )
229
233
expect ( event . payload ) . to eq (
230
- message : 'Hi' ,
231
- level : 'DEBUG'
234
+ {
235
+ logs : [
236
+ message : 'Hi' ,
237
+ level : 'DEBUG'
238
+ ]
239
+ }
232
240
)
233
241
end
234
242
235
243
it do
236
244
event = Datadog ::Core ::Telemetry ::Event ::Log . new ( message : 'Hi' , level : :warn )
237
245
expect ( event . type ) . to eq ( 'logs' )
238
246
expect ( event . payload ) . to eq (
239
- message : 'Hi' ,
240
- level : 'WARN'
247
+ {
248
+ logs : [
249
+ message : 'Hi' ,
250
+ level : 'WARN'
251
+ ]
252
+ }
241
253
)
242
254
end
243
255
Original file line number Diff line number Diff line change 10
10
telemetry = instance_double ( Datadog ::Core ::Telemetry ::Component )
11
11
allow ( Datadog . send ( :components ) ) . to receive ( :telemetry ) . and_return ( telemetry )
12
12
expect ( telemetry ) . to receive ( :log! ) . with ( instance_of ( Datadog ::Core ::Telemetry ::Event ::Log ) ) do |event |
13
- expect ( event . payload ) . to include ( message : 'RuntimeError' , level : 'ERROR' )
13
+ expect ( event . payload ) . to include ( logs : [ { message : 'RuntimeError' , level : 'ERROR' } ] )
14
14
end
15
15
16
16
begin
26
26
telemetry = instance_double ( Datadog ::Core ::Telemetry ::Component )
27
27
allow ( Datadog . send ( :components ) ) . to receive ( :telemetry ) . and_return ( telemetry )
28
28
expect ( telemetry ) . to receive ( :log! ) . with ( instance_of ( Datadog ::Core ::Telemetry ::Event ::Log ) ) do |event |
29
- expect ( event . payload ) . to include ( message : /#<Class:/ , level : 'ERROR' )
29
+ expect ( event . payload ) . to include ( logs : [ { message : /#<Class:/ , level : 'ERROR' } ] )
30
30
end
31
31
32
32
customer_exception = Class . new ( StandardError )
You can’t perform that action at this time.
0 commit comments