mirror of
https://github.com/hanzoai/traces.git
synced 2026-11-03 04:05:45 +00:00
MarioandGitHub
e0354d1bed
* Update Prometheus to v0.307.2 * Update otel collector * Update OTel collector
49 lines
1.3 KiB
Go
49 lines
1.3 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package plog // import "go.opentelemetry.io/collector/pdata/plog"
|
|
|
|
import (
|
|
"go.opentelemetry.io/collector/pdata/internal"
|
|
)
|
|
|
|
var _ MarshalSizer = (*ProtoMarshaler)(nil)
|
|
|
|
type ProtoMarshaler struct{}
|
|
|
|
func (e *ProtoMarshaler) MarshalLogs(ld Logs) ([]byte, error) {
|
|
size := internal.SizeProtoOrigExportLogsServiceRequest(ld.getOrig())
|
|
buf := make([]byte, size)
|
|
_ = internal.MarshalProtoOrigExportLogsServiceRequest(ld.getOrig(), buf)
|
|
return buf, nil
|
|
}
|
|
|
|
func (e *ProtoMarshaler) LogsSize(ld Logs) int {
|
|
return internal.SizeProtoOrigExportLogsServiceRequest(ld.getOrig())
|
|
}
|
|
|
|
func (e *ProtoMarshaler) ResourceLogsSize(ld ResourceLogs) int {
|
|
return internal.SizeProtoOrigResourceLogs(ld.orig)
|
|
}
|
|
|
|
func (e *ProtoMarshaler) ScopeLogsSize(ld ScopeLogs) int {
|
|
return internal.SizeProtoOrigScopeLogs(ld.orig)
|
|
}
|
|
|
|
func (e *ProtoMarshaler) LogRecordSize(ld LogRecord) int {
|
|
return internal.SizeProtoOrigLogRecord(ld.orig)
|
|
}
|
|
|
|
var _ Unmarshaler = (*ProtoUnmarshaler)(nil)
|
|
|
|
type ProtoUnmarshaler struct{}
|
|
|
|
func (d *ProtoUnmarshaler) UnmarshalLogs(buf []byte) (Logs, error) {
|
|
ld := NewLogs()
|
|
err := internal.UnmarshalProtoOrigExportLogsServiceRequest(ld.getOrig(), buf)
|
|
if err != nil {
|
|
return Logs{}, err
|
|
}
|
|
return ld, nil
|
|
}
|