@@ -208,13 +208,19 @@ mod tests {
208
208
use opentelemetry:: trace:: TracerProvider as _;
209
209
use opentelemetry:: trace:: { TraceContextExt , TraceFlags , Tracer } ;
210
210
use opentelemetry:: { logs:: AnyValue , Key } ;
211
- use opentelemetry_sdk:: logs:: LoggerProvider ;
211
+ use opentelemetry_sdk:: logs:: { LogRecord , LoggerProvider } ;
212
212
use opentelemetry_sdk:: testing:: logs:: InMemoryLogsExporter ;
213
213
use opentelemetry_sdk:: trace;
214
214
use opentelemetry_sdk:: trace:: { Sampler , TracerProvider } ;
215
215
use tracing:: error;
216
216
use tracing_subscriber:: layer:: SubscriberExt ;
217
217
218
+ pub fn attributes_contains ( log_record : & LogRecord , key : & Key , value : & AnyValue ) -> bool {
219
+ log_record
220
+ . attributes_iter ( )
221
+ . any ( |( k, v) | k == key && v == value)
222
+ }
223
+
218
224
// cargo test --features=testing
219
225
#[ test]
220
226
fn tracing_appender_standalone ( ) {
@@ -256,23 +262,30 @@ mod tests {
256
262
assert_eq ! ( log. record. attributes_len( ) , 3 ) ;
257
263
#[ cfg( feature = "experimental_metadata_attributes" ) ]
258
264
assert_eq ! ( log. record. attributes_len( ) , 8 ) ;
259
- assert ! ( log
260
- . record
261
- . attributes_contains( & Key :: new( "event_id" ) , & AnyValue :: Int ( 20 ) ) ) ;
262
- assert ! ( log
263
- . record
264
- . attributes_contains( & Key :: new( "user_name" ) , & AnyValue :: String ( "otel" . into( ) ) ) ) ;
265
- assert ! ( log. record. attributes_contains(
265
+ assert ! ( attributes_contains(
266
+ & log. record,
267
+ & Key :: new( "event_id" ) ,
268
+ & AnyValue :: Int ( 20 )
269
+ ) ) ;
270
+ assert ! ( attributes_contains(
271
+ & log. record,
272
+ & Key :: new( "user_name" ) ,
273
+ & AnyValue :: String ( "otel" . into( ) )
274
+ ) ) ;
275
+ assert ! ( attributes_contains(
276
+ & log. record,
266
277
& Key :: new( "user_email" ) ,
267
278
& AnyValue :: String ( "otel@opentelemetry.io" . into( ) )
268
279
) ) ;
269
280
#[ cfg( feature = "experimental_metadata_attributes" ) ]
270
281
{
271
- assert ! ( log. record. attributes_contains(
282
+ assert ! ( attributes_contains(
283
+ & log. record,
272
284
& Key :: new( "code.filename" ) ,
273
285
& AnyValue :: String ( "layer.rs" . into( ) )
274
286
) ) ;
275
- assert ! ( log. record. attributes_contains(
287
+ assert ! ( attributes_contains(
288
+ & log. record,
276
289
& Key :: new( "code.namespace" ) ,
277
290
& AnyValue :: String ( "opentelemetry_appender_tracing::layer::tests" . into( ) )
278
291
) ) ;
@@ -361,23 +374,30 @@ mod tests {
361
374
assert_eq ! ( log. record. attributes_len( ) , 3 ) ;
362
375
#[ cfg( feature = "experimental_metadata_attributes" ) ]
363
376
assert_eq ! ( log. record. attributes_len( ) , 8 ) ;
364
- assert ! ( log
365
- . record
366
- . attributes_contains( & Key :: new( "event_id" ) , & AnyValue :: Int ( 20 . into( ) ) ) ) ;
367
- assert ! ( log
368
- . record
369
- . attributes_contains( & Key :: new( "user_name" ) , & AnyValue :: String ( "otel" . into( ) ) ) ) ;
370
- assert ! ( log. record. attributes_contains(
377
+ assert ! ( attributes_contains(
378
+ & log. record,
379
+ & Key :: new( "event_id" ) ,
380
+ & AnyValue :: Int ( 20 . into( ) )
381
+ ) ) ;
382
+ assert ! ( attributes_contains(
383
+ & log. record,
384
+ & Key :: new( "user_name" ) ,
385
+ & AnyValue :: String ( "otel" . into( ) )
386
+ ) ) ;
387
+ assert ! ( attributes_contains(
388
+ & log. record,
371
389
& Key :: new( "user_email" ) ,
372
390
& AnyValue :: String ( "otel@opentelemetry.io" . into( ) )
373
391
) ) ;
374
392
#[ cfg( feature = "experimental_metadata_attributes" ) ]
375
393
{
376
- assert ! ( log. record. attributes_contains(
394
+ assert ! ( attributes_contains(
395
+ & log. record,
377
396
& Key :: new( "code.filename" ) ,
378
397
& AnyValue :: String ( "layer.rs" . into( ) )
379
398
) ) ;
380
- assert ! ( log. record. attributes_contains(
399
+ assert ! ( attributes_contains(
400
+ & log. record,
381
401
& Key :: new( "code.namespace" ) ,
382
402
& AnyValue :: String ( "opentelemetry_appender_tracing::layer::tests" . into( ) )
383
403
) ) ;
@@ -437,11 +457,13 @@ mod tests {
437
457
438
458
#[ cfg( feature = "experimental_metadata_attributes" ) ]
439
459
{
440
- assert ! ( log. record. attributes_contains(
460
+ assert ! ( attributes_contains(
461
+ & log. record,
441
462
& Key :: new( "code.filename" ) ,
442
463
& AnyValue :: String ( "layer.rs" . into( ) )
443
464
) ) ;
444
- assert ! ( log. record. attributes_contains(
465
+ assert ! ( attributes_contains(
466
+ & log. record,
445
467
& Key :: new( "code.namespace" ) ,
446
468
& AnyValue :: String ( "opentelemetry_appender_tracing::layer::tests" . into( ) )
447
469
) ) ;
@@ -532,11 +554,13 @@ mod tests {
532
554
533
555
#[ cfg( feature = "experimental_metadata_attributes" ) ]
534
556
{
535
- assert ! ( log. record. attributes_contains(
557
+ assert ! ( attributes_contains(
558
+ & log. record,
536
559
& Key :: new( "code.filename" ) ,
537
560
& AnyValue :: String ( "layer.rs" . into( ) )
538
561
) ) ;
539
- assert ! ( log. record. attributes_contains(
562
+ assert ! ( attributes_contains(
563
+ & log. record,
540
564
& Key :: new( "code.namespace" ) ,
541
565
& AnyValue :: String ( "opentelemetry_appender_tracing::layer::tests" . into( ) )
542
566
) ) ;
0 commit comments