-
Notifications
You must be signed in to change notification settings - Fork 3
/
schema_otel.go
31 lines (28 loc) · 991 Bytes
/
schema_otel.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
package logstorage
import (
"go.opentelemetry.io/collector/pdata/pcommon"
"go.opentelemetry.io/collector/pdata/plog"
"github.com/go-faster/oteldb/internal/otelstorage"
)
// NewRecordFromOTEL creates new Record.
func NewRecordFromOTEL(
res pcommon.Resource,
scope pcommon.InstrumentationScope,
record plog.LogRecord,
) Record {
return Record{
ObservedTimestamp: record.ObservedTimestamp(),
Timestamp: record.Timestamp(),
TraceID: otelstorage.TraceID(record.TraceID()),
SpanID: otelstorage.SpanID(record.SpanID()),
Flags: record.Flags(),
SeverityText: record.SeverityText(),
SeverityNumber: record.SeverityNumber(),
Body: record.Body().AsString(),
Attrs: otelstorage.Attrs(record.Attributes()),
ResourceAttrs: otelstorage.Attrs(res.Attributes()),
ScopeName: scope.Name(),
ScopeVersion: scope.Version(),
ScopeAttrs: otelstorage.Attrs(scope.Attributes()),
}
}