1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
// Copyright 2020 New Relic Corporation. All rights reserved.
// SPDX-License-Identifier: Apache-2.0
package newrelic
import (
"bytes"
"time"
)
// https://source.datanerd.us/agents/agent-specs/blob/master/Span-Events.md
type spanCategory string
const (
spanCategoryHTTP spanCategory = "http"
spanCategoryDatastore = "datastore"
// spanCategoryGeneric is a generic span category.
spanCategoryGeneric = "generic"
)
// spanEvent represents a span event, necessary to support Distributed Tracing.
type spanEvent struct {
TraceID string
GUID string
ParentID string
TransactionID string
Sampled bool
Priority priority
Timestamp time.Time
Duration time.Duration
Name string
TxnName string
Category spanCategory
Component string
Kind string
IsEntrypoint bool
TrustedParentID string
TracingVendors string
AgentAttributes spanAttributeMap
UserAttributes spanAttributeMap
}
// WriteJSON prepares JSON in the format expected by the collector.
func (e *spanEvent) WriteJSON(buf *bytes.Buffer) {
w := jsonFieldsWriter{buf: buf}
buf.WriteByte('[')
buf.WriteByte('{')
w.stringField("type", "Span")
w.stringField("traceId", e.TraceID)
w.stringField("guid", e.GUID)
if "" != e.ParentID {
w.stringField("parentId", e.ParentID)
}
w.stringField("transactionId", e.TransactionID)
w.boolField("sampled", e.Sampled)
w.writerField("priority", e.Priority)
w.intField("timestamp", timeToIntMillis(e.Timestamp))
w.floatField("duration", e.Duration.Seconds())
w.stringField("name", e.Name)
w.stringField("category", string(e.Category))
if e.IsEntrypoint {
w.boolField("nr.entryPoint", true)
}
if e.Component != "" {
w.stringField("component", e.Component)
}
if e.Kind != "" {
w.stringField("span.kind", e.Kind)
}
if "" != e.TrustedParentID {
w.stringField("trustedParentId", e.TrustedParentID)
}
if "" != e.TracingVendors {
w.stringField("tracingVendors", e.TracingVendors)
}
if "" != e.TxnName {
w.stringField("transaction.name", e.TxnName)
}
buf.WriteByte('}')
buf.WriteByte(',')
buf.WriteByte('{')
writeAttrs(buf, e.UserAttributes)
buf.WriteByte('}')
buf.WriteByte(',')
buf.WriteByte('{')
writeAttrs(buf, e.AgentAttributes)
buf.WriteByte('}')
buf.WriteByte(']')
}
func writeAttrs(buf *bytes.Buffer, attrs spanAttributeMap) {
w := jsonFieldsWriter{buf: buf}
for key, val := range attrs {
w.writerField(key, val)
}
}
// MarshalJSON is used for testing.
func (e *spanEvent) MarshalJSON() ([]byte, error) {
buf := bytes.NewBuffer(make([]byte, 0, 256))
e.WriteJSON(buf)
return buf.Bytes(), nil
}
type spanEvents struct {
*analyticsEvents
}
func newSpanEvents(max int) *spanEvents {
return &spanEvents{
analyticsEvents: newAnalyticsEvents(max),
}
}
func (events *spanEvents) addEventPopulated(e *spanEvent) {
events.analyticsEvents.addEvent(analyticsEvent{priority: e.Priority, jsonWriter: e})
}
// MergeSpanEvents merges the span events from a transaction into the
// harvest's span events. This should only be called if the transaction was
// sampled and span events are enabled.
func (events *spanEvents) MergeSpanEvents(evts []*spanEvent) {
for _, evt := range evts {
events.addEventPopulated(evt)
}
}
func (events *spanEvents) MergeIntoHarvest(h *harvest) {
h.SpanEvents.mergeFailed(events.analyticsEvents)
}
func (events *spanEvents) Data(agentRunID string, harvestStart time.Time) ([]byte, error) {
return events.CollectorJSON(agentRunID)
}
func (events *spanEvents) EndpointMethod() string {
return cmdSpanEvents
}
|
