Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add PID as an attribute in each sample #212

Open
wants to merge 10 commits into
base: main
Choose a base branch
from
Open

Add PID as an attribute in each sample #212

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
3b846d6
Add PID as an attribute in each sample
bhavnajindal Oct 28, 2024
eab2981
use traceAndMetaKey to store PID
bhavnajindal Oct 29, 2024
12b35c1
Addition to testcase for pid as an attribute in sample
bhavnajindal Nov 1, 2024
5cd8eb0
update addProfileAttributes to support intValue
bhavnajindal Nov 4, 2024
2a1d950
update testcase with pid as int64
bhavnajindal Nov 4, 2024
5cb3920
use type assertion instead of reflect package
bhavnajindal Nov 4, 2024
92013aa
use generics to support IntValue in attributes
bhavnajindal Nov 5, 2024
80def22
fix for golangcli-lint. remove unnecessary converion
bhavnajindal Nov 5, 2024
8254178
Add error log and support empty values in attribute
bhavnajindal Nov 5, 2024
9f1e466
Fix error msg length
bhavnajindal Nov 5, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions reporter/otlp_reporter.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,7 @@ type traceEvents struct {
mappingEnds []libpf.Address
mappingFileOffsets []uint64
timestamps []uint64 // in nanoseconds
pid uint64
florianl marked this conversation as resolved.
Show resolved Hide resolved
}

// attrKeyValue is a helper to populate Profile.attribute_table.
Expand Down Expand Up @@ -185,6 +186,7 @@ func (r *OTLPReporter) ReportTraceEvent(trace *libpf.Trace, meta *TraceEventMeta
mappingEnds: trace.MappingEnd,
mappingFileOffsets: trace.MappingFileOffsets,
timestamps: []uint64{uint64(meta.Timestamp)},
pid: uint64(meta.PID),
}
}

Expand Down Expand Up @@ -652,6 +654,7 @@ func (r *OTLPReporter) getProfile() (profile *profiles.Profile, startTS, endTS u
{key: string(semconv.ContainerIDKey), value: traceKey.containerID},
{key: string(semconv.ThreadNameKey), value: traceKey.comm},
{key: string(semconv.ServiceNameKey), value: traceKey.apmServiceName},
{key: string(semconv.ProcessPIDKey), value: strconv.FormatUint(traceInfo.pid, 10)},
}, attributeMap)
sample.LocationsLength = uint64(len(traceInfo.frameTypes))
locationIndex += sample.LocationsLength
Expand Down