Skip to content

Commit e546331

Browse files
committed
few more
1 parent e7ad747 commit e546331

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

opentelemetry-sdk/src/logs/log_processor_with_async_runtime.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -555,7 +555,7 @@ mod tests {
555555
let processor =
556556
BatchLogProcessor::new(exporter.clone(), BatchConfig::default(), runtime::Tokio);
557557

558-
let mut record = LogRecord::new();
558+
let mut record = SdkLogRecord::new();
559559
let instrumentation = InstrumentationScope::default();
560560

561561
processor.emit(&mut record, &instrumentation);
@@ -624,11 +624,11 @@ mod tests {
624624

625625
#[derive(Debug)]
626626
struct FirstProcessor {
627-
pub(crate) logs: Arc<Mutex<Vec<(LogRecord, InstrumentationScope)>>>,
627+
pub(crate) logs: Arc<Mutex<Vec<(SdkLogRecord, InstrumentationScope)>>>,
628628
}
629629

630630
impl LogProcessor for FirstProcessor {
631-
fn emit(&self, record: &mut LogRecord, instrumentation: &InstrumentationScope) {
631+
fn emit(&self, record: &mut SdkLogRecord, instrumentation: &InstrumentationScope) {
632632
// add attribute
633633
record.add_attribute(
634634
Key::from_static_str("processed_by"),
@@ -654,11 +654,11 @@ mod tests {
654654

655655
#[derive(Debug)]
656656
struct SecondProcessor {
657-
pub(crate) logs: Arc<Mutex<Vec<(LogRecord, InstrumentationScope)>>>,
657+
pub(crate) logs: Arc<Mutex<Vec<(SdkLogRecord, InstrumentationScope)>>>,
658658
}
659659

660660
impl LogProcessor for SecondProcessor {
661-
fn emit(&self, record: &mut LogRecord, instrumentation: &InstrumentationScope) {
661+
fn emit(&self, record: &mut SdkLogRecord, instrumentation: &InstrumentationScope) {
662662
assert!(record.attributes_contains(
663663
&Key::from_static_str("processed_by"),
664664
&AnyValue::String("FirstProcessor".into())
@@ -817,7 +817,7 @@ mod tests {
817817
let processor =
818818
BatchLogProcessor::new(exporter.clone(), BatchConfig::default(), runtime::Tokio);
819819

820-
let mut record = LogRecord::new();
820+
let mut record = SdkLogRecord::new();
821821
let instrumentation = InstrumentationScope::default();
822822

823823
processor.emit(&mut record, &instrumentation);

0 commit comments

Comments
 (0)