@@ -533,7 +533,7 @@ mod tests {
533
533
} ;
534
534
use crate :: export:: logs:: { LogBatch , LogExporter } ;
535
535
use crate :: logs:: LogRecord ;
536
- use crate :: testing:: logs:: InMemoryLogsExporterBuilder ;
536
+ use crate :: testing:: logs:: InMemoryLogExporterBuilder ;
537
537
use crate :: {
538
538
logs:: {
539
539
log_processor:: {
@@ -543,7 +543,7 @@ mod tests {
543
543
BatchConfig , BatchConfigBuilder , LogProcessor , LoggerProvider , SimpleLogProcessor ,
544
544
} ,
545
545
runtime,
546
- testing:: logs:: InMemoryLogsExporter ,
546
+ testing:: logs:: InMemoryLogExporter ,
547
547
Resource ,
548
548
} ;
549
549
use async_trait:: async_trait;
@@ -690,7 +690,7 @@ mod tests {
690
690
] ;
691
691
temp_env:: with_vars ( env_vars. clone ( ) , || {
692
692
let builder =
693
- BatchLogProcessor :: builder ( InMemoryLogsExporter :: default ( ) , runtime:: Tokio ) ;
693
+ BatchLogProcessor :: builder ( InMemoryLogExporter :: default ( ) , runtime:: Tokio ) ;
694
694
695
695
assert_eq ! ( builder. config. max_export_batch_size, 500 ) ;
696
696
assert_eq ! (
@@ -711,7 +711,7 @@ mod tests {
711
711
712
712
temp_env:: with_vars ( env_vars, || {
713
713
let builder =
714
- BatchLogProcessor :: builder ( InMemoryLogsExporter :: default ( ) , runtime:: Tokio ) ;
714
+ BatchLogProcessor :: builder ( InMemoryLogExporter :: default ( ) , runtime:: Tokio ) ;
715
715
assert_eq ! ( builder. config. max_export_batch_size, 120 ) ;
716
716
assert_eq ! ( builder. config. max_queue_size, 120 ) ;
717
717
} ) ;
@@ -726,7 +726,7 @@ mod tests {
726
726
. with_max_queue_size ( 4 )
727
727
. build ( ) ;
728
728
729
- let builder = BatchLogProcessor :: builder ( InMemoryLogsExporter :: default ( ) , runtime:: Tokio )
729
+ let builder = BatchLogProcessor :: builder ( InMemoryLogExporter :: default ( ) , runtime:: Tokio )
730
730
. with_batch_config ( expected) ;
731
731
732
732
let actual = & builder. config ;
@@ -784,7 +784,7 @@ mod tests {
784
784
async fn test_batch_shutdown ( ) {
785
785
// assert we will receive an error
786
786
// setup
787
- let exporter = InMemoryLogsExporterBuilder :: default ( )
787
+ let exporter = InMemoryLogExporterBuilder :: default ( )
788
788
. keep_records_on_shutdown ( )
789
789
. build ( ) ;
790
790
let processor = BatchLogProcessor :: new (
@@ -806,7 +806,7 @@ mod tests {
806
806
807
807
#[ test]
808
808
fn test_simple_shutdown ( ) {
809
- let exporter = InMemoryLogsExporterBuilder :: default ( )
809
+ let exporter = InMemoryLogExporterBuilder :: default ( )
810
810
. keep_records_on_shutdown ( )
811
811
. build ( ) ;
812
812
let processor = SimpleLogProcessor :: new ( Box :: new ( exporter. clone ( ) ) ) ;
@@ -831,7 +831,7 @@ mod tests {
831
831
#[ tokio:: test( flavor = "current_thread" ) ]
832
832
#[ ignore = "See issue https://github.com/open-telemetry/opentelemetry-rust/issues/1968" ]
833
833
async fn test_batch_log_processor_shutdown_with_async_runtime_current_flavor_multi_thread ( ) {
834
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
834
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
835
835
let processor = BatchLogProcessor :: new (
836
836
Box :: new ( exporter. clone ( ) ) ,
837
837
BatchConfig :: default ( ) ,
@@ -846,7 +846,7 @@ mod tests {
846
846
847
847
#[ tokio:: test( flavor = "current_thread" ) ]
848
848
async fn test_batch_log_processor_shutdown_with_async_runtime_current_flavor_current_thread ( ) {
849
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
849
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
850
850
let processor = BatchLogProcessor :: new (
851
851
Box :: new ( exporter. clone ( ) ) ,
852
852
BatchConfig :: default ( ) ,
@@ -858,7 +858,7 @@ mod tests {
858
858
859
859
#[ tokio:: test( flavor = "multi_thread" ) ]
860
860
async fn test_batch_log_processor_shutdown_with_async_runtime_multi_flavor_multi_thread ( ) {
861
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
861
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
862
862
let processor = BatchLogProcessor :: new (
863
863
Box :: new ( exporter. clone ( ) ) ,
864
864
BatchConfig :: default ( ) ,
@@ -870,7 +870,7 @@ mod tests {
870
870
871
871
#[ tokio:: test( flavor = "multi_thread" ) ]
872
872
async fn test_batch_log_processor_shutdown_with_async_runtime_multi_flavor_current_thread ( ) {
873
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
873
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
874
874
let processor = BatchLogProcessor :: new (
875
875
Box :: new ( exporter. clone ( ) ) ,
876
876
BatchConfig :: default ( ) ,
@@ -989,7 +989,7 @@ mod tests {
989
989
990
990
#[ test]
991
991
fn test_simple_processor_sync_exporter_without_runtime ( ) {
992
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
992
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
993
993
let processor = SimpleLogProcessor :: new ( Box :: new ( exporter. clone ( ) ) ) ;
994
994
995
995
let mut record: LogRecord = Default :: default ( ) ;
@@ -1002,7 +1002,7 @@ mod tests {
1002
1002
1003
1003
#[ tokio:: test( flavor = "multi_thread" , worker_threads = 1 ) ]
1004
1004
async fn test_simple_processor_sync_exporter_with_runtime ( ) {
1005
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
1005
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
1006
1006
let processor = SimpleLogProcessor :: new ( Box :: new ( exporter. clone ( ) ) ) ;
1007
1007
1008
1008
let mut record: LogRecord = Default :: default ( ) ;
@@ -1015,7 +1015,7 @@ mod tests {
1015
1015
1016
1016
#[ tokio:: test( flavor = "multi_thread" ) ]
1017
1017
async fn test_simple_processor_sync_exporter_with_multi_thread_runtime ( ) {
1018
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
1018
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
1019
1019
let processor = Arc :: new ( SimpleLogProcessor :: new ( Box :: new ( exporter. clone ( ) ) ) ) ;
1020
1020
1021
1021
let mut handles = vec ! [ ] ;
@@ -1038,7 +1038,7 @@ mod tests {
1038
1038
1039
1039
#[ tokio:: test( flavor = "current_thread" ) ]
1040
1040
async fn test_simple_processor_sync_exporter_with_current_thread_runtime ( ) {
1041
- let exporter = InMemoryLogsExporterBuilder :: default ( ) . build ( ) ;
1041
+ let exporter = InMemoryLogExporterBuilder :: default ( ) . build ( ) ;
1042
1042
let processor = SimpleLogProcessor :: new ( Box :: new ( exporter. clone ( ) ) ) ;
1043
1043
1044
1044
let mut record: LogRecord = Default :: default ( ) ;
0 commit comments