mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
a4f2aaf076
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description Fix data returned by GenerateProfiles() to be compliant with the specification. <!-- Issue number if applicable --> #### Link to tracking issue Fixes # <!--Describe what testing was performed and which tests were added.--> #### Testing <!--Describe the documentation added.--> #### Documentation <!--Please delete paragraphs that you did not use before submitting.--> --------- Signed-off-by: Florian Lehner <[email protected]> Co-authored-by: Alex Boten <[email protected]>
92 lines
2.9 KiB
Go
92 lines
2.9 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package testdata // import "go.opentelemetry.io/collector/pdata/testdata"
|
|
|
|
import (
|
|
"time"
|
|
|
|
"go.opentelemetry.io/collector/pdata/pcommon"
|
|
"go.opentelemetry.io/collector/pdata/pprofile"
|
|
)
|
|
|
|
var profileStartTimestamp = pcommon.NewTimestampFromTime(time.Date(2020, 2, 11, 20, 26, 12, 321, time.UTC))
|
|
|
|
// GenerateProfiles generates dummy profiling data for tests
|
|
func GenerateProfiles(profilesCount int) pprofile.Profiles {
|
|
td := pprofile.NewProfiles()
|
|
|
|
dic := td.Dictionary()
|
|
// By convention, the first element is empty
|
|
dic.StringTable().Append("")
|
|
dic.StringTable().Append("key")
|
|
|
|
// By convention, the first element is empty
|
|
dic.AttributeTable().AppendEmpty()
|
|
attr := dic.AttributeTable().AppendEmpty()
|
|
attr.SetKeyStrindex(1)
|
|
attr.Value().SetStr("value-1")
|
|
attr2 := dic.AttributeTable().AppendEmpty()
|
|
attr2.SetKeyStrindex(1)
|
|
attr2.Value().SetStr("value-2")
|
|
|
|
// By convention, the first element is empty in all dictionary tables
|
|
dic.MappingTable().AppendEmpty()
|
|
dic.LocationTable().AppendEmpty()
|
|
dic.FunctionTable().AppendEmpty()
|
|
dic.LinkTable().AppendEmpty()
|
|
dic.StackTable().AppendEmpty()
|
|
|
|
initResource(td.ResourceProfiles().AppendEmpty().Resource())
|
|
ss := td.ResourceProfiles().At(0).ScopeProfiles().AppendEmpty().Profiles()
|
|
|
|
ss.EnsureCapacity(profilesCount)
|
|
for i := range profilesCount {
|
|
switch i % 2 {
|
|
case 0:
|
|
fillProfileOne(dic, ss.AppendEmpty())
|
|
case 1:
|
|
fillProfileTwo(dic, ss.AppendEmpty())
|
|
}
|
|
}
|
|
|
|
return td
|
|
}
|
|
|
|
func fillProfileOne(dic pprofile.ProfilesDictionary, profile pprofile.Profile) {
|
|
profile.SetProfileID([16]byte{0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F, 0x10})
|
|
profile.SetTime(profileStartTimestamp)
|
|
profile.SetDurationNano(uint64(time.Second.Nanoseconds()))
|
|
profile.SetDroppedAttributesCount(1)
|
|
|
|
loc := pprofile.NewLocation()
|
|
loc.SetAddress(1)
|
|
locID, _ := pprofile.SetLocation(dic.LocationTable(), loc)
|
|
stack := pprofile.NewStack()
|
|
stack.LocationIndices().Append(locID)
|
|
stackID, _ := pprofile.SetStack(dic.StackTable(), stack)
|
|
|
|
sample := profile.Samples().AppendEmpty()
|
|
sample.SetStackIndex(stackID)
|
|
sample.Values().Append(4)
|
|
sample.AttributeIndices().Append(1)
|
|
}
|
|
|
|
func fillProfileTwo(dic pprofile.ProfilesDictionary, profile pprofile.Profile) {
|
|
profile.SetProfileID([16]byte{0x02, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F, 0x10})
|
|
profile.SetTime(profileStartTimestamp)
|
|
profile.SetDurationNano(uint64(time.Second.Nanoseconds()))
|
|
|
|
loc := pprofile.NewLocation()
|
|
loc.SetAddress(2)
|
|
locID, _ := pprofile.SetLocation(dic.LocationTable(), loc)
|
|
stack := pprofile.NewStack()
|
|
stack.LocationIndices().Append(locID)
|
|
stackID, _ := pprofile.SetStack(dic.StackTable(), stack)
|
|
|
|
sample := profile.Samples().AppendEmpty()
|
|
sample.SetStackIndex(stackID)
|
|
sample.Values().Append(9)
|
|
sample.AttributeIndices().Append(2)
|
|
}
|