|
27 | 27 | #include "opentelemetry/nostd/utility.h"
|
28 | 28 | #include "opentelemetry/sdk/instrumentationscope/instrumentation_scope.h"
|
29 | 29 | #include "opentelemetry/sdk/logs/exporter.h"
|
| 30 | +#include "opentelemetry/sdk/logs/log_record_data.h" |
30 | 31 | #include "opentelemetry/sdk/logs/logger_provider.h"
|
31 | 32 | #include "opentelemetry/sdk/logs/processor.h"
|
32 | 33 | #include "opentelemetry/sdk/logs/provider.h"
|
33 |
| -#include "opentelemetry/sdk/logs/read_write_log_record.h" |
34 | 34 | #include "opentelemetry/sdk/logs/readable_log_record.h"
|
35 | 35 | #include "opentelemetry/sdk/logs/recordable.h"
|
36 | 36 | #include "opentelemetry/sdk/logs/simple_log_record_processor.h"
|
@@ -82,7 +82,7 @@ TEST(OStreamLogRecordExporter, Shutdown)
|
82 | 82 |
|
83 | 83 | // After processor/exporter is shutdown, no logs should be sent to stream
|
84 | 84 | auto record = exporter->MakeRecordable();
|
85 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get())->SetBody("Log record not empty"); |
| 85 | + static_cast<sdklogs::LogRecordData *>(record.get())->SetBody("Log record not empty"); |
86 | 86 | exporter->Export(nostd::span<std::unique_ptr<sdklogs::Recordable>>(&record, 1));
|
87 | 87 |
|
88 | 88 | // Restore original stringstream buffer
|
@@ -171,12 +171,12 @@ TEST(OStreamLogRecordExporter, SimpleLogToCout)
|
171 | 171 | // Create a log record and manually timestamp, severity, name, message
|
172 | 172 | common::SystemTimestamp now(std::chrono::system_clock::now());
|
173 | 173 |
|
174 |
| - auto record = std::unique_ptr<sdklogs::Recordable>(new sdklogs::ReadWriteLogRecord()); |
175 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get())->SetTimestamp(now); |
176 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get())->SetObservedTimestamp(now); |
177 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get()) |
| 174 | + auto record = std::unique_ptr<sdklogs::Recordable>(new sdklogs::LogRecordData()); |
| 175 | + static_cast<sdklogs::LogRecordData *>(record.get())->SetTimestamp(now); |
| 176 | + static_cast<sdklogs::LogRecordData *>(record.get())->SetObservedTimestamp(now); |
| 177 | + static_cast<sdklogs::LogRecordData *>(record.get()) |
178 | 178 | ->SetSeverity(logs_api::Severity::kTrace); // kTrace has enum value of 1
|
179 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get())->SetBody("Message"); |
| 179 | + static_cast<sdklogs::LogRecordData *>(record.get())->SetBody("Message"); |
180 | 180 |
|
181 | 181 | opentelemetry::sdk::instrumentationscope::InstrumentationScope instrumentation_scope =
|
182 | 182 | GetTestInstrumentationScope();
|
@@ -248,10 +248,10 @@ TEST(OStreamLogRecordExporter, LogWithStringAttributesToCerr)
|
248 | 248 |
|
249 | 249 | // Set resources for this log record only of type <string, string>
|
250 | 250 | auto resource = opentelemetry::sdk::resource::Resource::Create({{"key1", "val1"}});
|
251 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get())->SetResource(resource); |
| 251 | + static_cast<sdklogs::LogRecordData *>(record.get())->SetResource(resource); |
252 | 252 |
|
253 | 253 | // Set attributes to this log record of type <string, AttributeValue>
|
254 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get())->SetAttribute("a", true); |
| 254 | + static_cast<sdklogs::LogRecordData *>(record.get())->SetAttribute("a", true); |
255 | 255 |
|
256 | 256 | opentelemetry::sdk::instrumentationscope::InstrumentationScope instrumentation_scope =
|
257 | 257 | GetTestInstrumentationScope();
|
@@ -326,12 +326,12 @@ TEST(OStreamLogRecordExporter, LogWithVariantTypesToClog)
|
326 | 326 | nostd::span<int> data1{array1.data(), array1.size()};
|
327 | 327 |
|
328 | 328 | auto resource = opentelemetry::sdk::resource::Resource::Create({{"res1", data1}});
|
329 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get())->SetResource(resource); |
| 329 | + static_cast<sdklogs::LogRecordData *>(record.get())->SetResource(resource); |
330 | 330 |
|
331 | 331 | // Set resources for this log record of bool types as the value
|
332 | 332 | // e.g. key/value is a par of type <string, array of bools>
|
333 | 333 | std::array<bool, 3> array = {false, true, false};
|
334 |
| - static_cast<sdklogs::ReadWriteLogRecord *>(record.get()) |
| 334 | + static_cast<sdklogs::LogRecordData *>(record.get()) |
335 | 335 | ->SetAttribute("attr1", nostd::span<bool>{array.data(), array.size()});
|
336 | 336 |
|
337 | 337 | opentelemetry::sdk::instrumentationscope::InstrumentationScope instrumentation_scope =
|
|
0 commit comments