@@ -508,7 +508,7 @@ impl BatchLogProcessor {
508
508
let mut logs = Vec :: with_capacity ( config. max_export_batch_size ) ;
509
509
let current_batch_size = current_batch_size_for_thread;
510
510
511
- // This method gets upto `max_export_batch_size` amount of logs from the channel and exports them.
511
+ // This method gets up to `max_export_batch_size` amount of logs from the channel and exports them.
512
512
// It returns the result of the export operation.
513
513
// It expects the logs vec to be empty when it's called.
514
514
#[ inline]
@@ -871,16 +871,18 @@ impl BatchConfigBuilder {
871
871
#[ cfg( all( test, feature = "testing" , feature = "logs" ) ) ]
872
872
mod tests {
873
873
use super :: {
874
- BatchLogProcessor , OTEL_BLRP_EXPORT_TIMEOUT , OTEL_BLRP_MAX_EXPORT_BATCH_SIZE ,
875
- OTEL_BLRP_MAX_QUEUE_SIZE , OTEL_BLRP_SCHEDULE_DELAY ,
874
+ BatchLogProcessor , OTEL_BLRP_MAX_EXPORT_BATCH_SIZE , OTEL_BLRP_MAX_QUEUE_SIZE ,
875
+ OTEL_BLRP_SCHEDULE_DELAY ,
876
876
} ;
877
+ #[ cfg( feature = "experimental_logs_batch_log_processor_with_async_runtime" ) ]
878
+ use super :: { OTEL_BLRP_EXPORT_TIMEOUT , OTEL_BLRP_EXPORT_TIMEOUT_DEFAULT } ;
877
879
use crate :: logs:: LogResult ;
878
880
use crate :: logs:: { LogBatch , LogExporter , SdkLogRecord } ;
879
881
use crate :: {
880
882
logs:: {
881
883
log_processor:: {
882
- OTEL_BLRP_EXPORT_TIMEOUT_DEFAULT , OTEL_BLRP_MAX_EXPORT_BATCH_SIZE_DEFAULT ,
883
- OTEL_BLRP_MAX_QUEUE_SIZE_DEFAULT , OTEL_BLRP_SCHEDULE_DELAY_DEFAULT ,
884
+ OTEL_BLRP_MAX_EXPORT_BATCH_SIZE_DEFAULT , OTEL_BLRP_MAX_QUEUE_SIZE_DEFAULT ,
885
+ OTEL_BLRP_SCHEDULE_DELAY_DEFAULT ,
884
886
} ,
885
887
BatchConfig , BatchConfigBuilder , InMemoryLogExporter , InMemoryLogExporterBuilder ,
886
888
LogProcessor , SdkLoggerProvider , SimpleLogProcessor ,
@@ -933,7 +935,9 @@ mod tests {
933
935
fn test_default_const_values ( ) {
934
936
assert_eq ! ( OTEL_BLRP_SCHEDULE_DELAY , "OTEL_BLRP_SCHEDULE_DELAY" ) ;
935
937
assert_eq ! ( OTEL_BLRP_SCHEDULE_DELAY_DEFAULT , 1_000 ) ;
938
+ #[ cfg( feature = "experimental_logs_batch_log_processor_with_async_runtime" ) ]
936
939
assert_eq ! ( OTEL_BLRP_EXPORT_TIMEOUT , "OTEL_BLRP_EXPORT_TIMEOUT" ) ;
940
+ #[ cfg( feature = "experimental_logs_batch_log_processor_with_async_runtime" ) ]
937
941
assert_eq ! ( OTEL_BLRP_EXPORT_TIMEOUT_DEFAULT , 30_000 ) ;
938
942
assert_eq ! ( OTEL_BLRP_MAX_QUEUE_SIZE , "OTEL_BLRP_MAX_QUEUE_SIZE" ) ;
939
943
assert_eq ! ( OTEL_BLRP_MAX_QUEUE_SIZE_DEFAULT , 2_048 ) ;
@@ -949,6 +953,7 @@ mod tests {
949
953
// The following environment variables are expected to be unset so that their default values are used.
950
954
let env_vars = vec ! [
951
955
OTEL_BLRP_SCHEDULE_DELAY ,
956
+ #[ cfg( feature = "experimental_logs_batch_log_processor_with_async_runtime" ) ]
952
957
OTEL_BLRP_EXPORT_TIMEOUT ,
953
958
OTEL_BLRP_MAX_QUEUE_SIZE ,
954
959
OTEL_BLRP_MAX_EXPORT_BATCH_SIZE ,
@@ -976,6 +981,7 @@ mod tests {
976
981
fn test_batch_config_configurable_by_env_vars ( ) {
977
982
let env_vars = vec ! [
978
983
( OTEL_BLRP_SCHEDULE_DELAY , Some ( "2000" ) ) ,
984
+ #[ cfg( feature = "experimental_logs_batch_log_processor_with_async_runtime" ) ]
979
985
( OTEL_BLRP_EXPORT_TIMEOUT , Some ( "60000" ) ) ,
980
986
( OTEL_BLRP_MAX_QUEUE_SIZE , Some ( "4096" ) ) ,
981
987
( OTEL_BLRP_MAX_EXPORT_BATCH_SIZE , Some ( "1024" ) ) ,
@@ -1035,6 +1041,7 @@ mod tests {
1035
1041
let mut env_vars = vec ! [
1036
1042
( OTEL_BLRP_MAX_EXPORT_BATCH_SIZE , Some ( "500" ) ) ,
1037
1043
( OTEL_BLRP_SCHEDULE_DELAY , Some ( "I am not number" ) ) ,
1044
+ #[ cfg( feature = "experimental_logs_batch_log_processor_with_async_runtime" ) ]
1038
1045
( OTEL_BLRP_EXPORT_TIMEOUT , Some ( "2046" ) ) ,
1039
1046
] ;
1040
1047
temp_env:: with_vars ( env_vars. clone ( ) , || {
0 commit comments