mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Dmitry AnoshinandGitHub
3ef58fda95
Alternative to https://github.com/open-telemetry/opentelemetry-collector/pull/13176 that doesn't involve custom encoder but exposes new public module `pdata/xpdata/request` The actual change set is pretty small. Most of the code is generated protobuf
32 lines
856 B
Go
32 lines
856 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package request // import "go.opentelemetry.io/collector/pdata/xpdata/request"
|
|
|
|
import (
|
|
"encoding/binary"
|
|
"errors"
|
|
)
|
|
|
|
const (
|
|
// field 1 << 3, wire type 5 (fixed32)
|
|
protoTag1TypeByte = 0x0D
|
|
|
|
// version of the request payload format set in the `format_version` field
|
|
requestFormatVersion = uint32(1)
|
|
)
|
|
|
|
var ErrInvalidFormat = errors.New("invalid request payload format")
|
|
|
|
// isRequestPayloadV1 returns true if the given payload represents one of the wrappers around standard OpenTelemetry
|
|
// data types defined in internal/request.go and has the version set to 1.
|
|
func isRequestPayloadV1(data []byte) bool {
|
|
if len(data) < 5 {
|
|
return false
|
|
}
|
|
if data[0] != protoTag1TypeByte {
|
|
return false
|
|
}
|
|
return binary.LittleEndian.Uint32(data[1:5]) == requestFormatVersion
|
|
}
|