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
47 lines
1.2 KiB
Go
47 lines
1.2 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package ptrace // import "go.opentelemetry.io/collector/pdata/ptrace"
|
|
|
|
import (
|
|
"go.opentelemetry.io/collector/pdata/internal"
|
|
)
|
|
|
|
var _ MarshalSizer = (*ProtoMarshaler)(nil)
|
|
|
|
type ProtoMarshaler struct{}
|
|
|
|
func (e *ProtoMarshaler) MarshalTraces(td Traces) ([]byte, error) {
|
|
size := internal.SizeProtoOrigExportTraceServiceRequest(td.getOrig())
|
|
buf := make([]byte, size)
|
|
_ = internal.MarshalProtoOrigExportTraceServiceRequest(td.getOrig(), buf)
|
|
return buf, nil
|
|
}
|
|
|
|
func (e *ProtoMarshaler) TracesSize(td Traces) int {
|
|
return internal.SizeProtoOrigExportTraceServiceRequest(td.getOrig())
|
|
}
|
|
|
|
func (e *ProtoMarshaler) ResourceSpansSize(td ResourceSpans) int {
|
|
return internal.SizeProtoOrigResourceSpans(td.orig)
|
|
}
|
|
|
|
func (e *ProtoMarshaler) ScopeSpansSize(td ScopeSpans) int {
|
|
return internal.SizeProtoOrigScopeSpans(td.orig)
|
|
}
|
|
|
|
func (e *ProtoMarshaler) SpanSize(td Span) int {
|
|
return internal.SizeProtoOrigSpan(td.orig)
|
|
}
|
|
|
|
type ProtoUnmarshaler struct{}
|
|
|
|
func (d *ProtoUnmarshaler) UnmarshalTraces(buf []byte) (Traces, error) {
|
|
td := NewTraces()
|
|
err := internal.UnmarshalProtoOrigExportTraceServiceRequest(td.getOrig(), buf)
|
|
if err != nil {
|
|
return Traces{}, err
|
|
}
|
|
return td, nil
|
|
}
|