We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4ccf57c commit a24cbd3Copy full SHA for a24cbd3
src/opentelemetry/convert.rs
@@ -139,6 +139,8 @@ impl From<ResourceLog> for Event {
139
rl.log_record.dropped_attributes_count,
140
);
141
142
+ le.insert(log_schema().source_type_key(), Bytes::from("opentelemetry"));
143
+
144
le.into()
145
}
146
src/sources/opentelemetry/tests.rs
@@ -116,6 +116,7 @@ async fn receive_grpc_logs() {
116
("dropped_attributes_count", 3.into()),
117
("timestamp", Utc.timestamp_nanos(1).into()),
118
("observed_timestamp", Utc.timestamp_nanos(2).into()),
119
+ ("source_type", "opentelemetry".into()),
120
]);
121
let expect_event = Event::from(LogEvent::from(expect_vec));
122
assert_eq!(actual_event, expect_event);
0 commit comments