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
|
// Copyright 2020 New Relic Corporation. All rights reserved.
// SPDX-License-Identifier: Apache-2.0
// Package integrationsupport exists to expose functionality to integration
// packages without adding noise to the public API.
package integrationsupport
import (
"github.com/newrelic/go-agent/v3/internal"
newrelic "github.com/newrelic/go-agent/v3/newrelic"
)
// AddAgentAttribute allows instrumentation packages to add agent attributes.
func AddAgentAttribute(txn *newrelic.Transaction, id string, stringVal string, otherVal interface{}) {
if nil == txn {
return
}
if aa, ok := txn.Private.(internal.AddAgentAttributer); ok {
aa.AddAgentAttribute(id, stringVal, otherVal)
}
}
// AddAgentSpanAttribute allows instrumentation packages to add span attributes.
func AddAgentSpanAttribute(txn *newrelic.Transaction, key string, val string) {
if nil == txn {
return
}
internal.AddAgentSpanAttribute(txn.Private, key, val)
}
// This code below is used for testing and is based on the similar code in internal_test.go in
// the newrelic package. That code is not exported, though, and we frequently need something similar
// for integration packages, so it is copied here.
const (
testLicenseKey = "0123456789012345678901234567890123456789"
SampleAppName = "my app"
)
// ExpectApp combines Application and Expect, for use in validating data in test apps
type ExpectApp struct {
internal.Expect
*newrelic.Application
}
// ConfigFullTraces enables distributed tracing and sets transaction
// trace and transaction trace segment thresholds to zero for full traces.
func ConfigFullTraces(cfg *newrelic.Config) {
cfg.DistributedTracer.Enabled = true
cfg.TransactionTracer.Segments.Threshold = 0
cfg.TransactionTracer.Threshold.IsApdexFailing = false
cfg.TransactionTracer.Threshold.Duration = 0
}
// NewTestApp creates an ExpectApp with the given ConnectReply function and Config function
func NewTestApp(replyfn func(*internal.ConnectReply), cfgFn ...newrelic.ConfigOption) ExpectApp {
cfgFn = append(cfgFn,
func(cfg *newrelic.Config) {
// Prevent spawning app goroutines in tests.
if !cfg.ServerlessMode.Enabled {
cfg.Enabled = false
}
},
newrelic.ConfigAppName(SampleAppName),
newrelic.ConfigLicense(testLicenseKey),
)
app, err := newrelic.NewApplication(cfgFn...)
if nil != err {
panic(err)
}
internal.HarvestTesting(app.Private, replyfn)
return ExpectApp{
Expect: app.Private.(internal.Expect),
Application: app,
}
}
// NewBasicTestApp creates an ExpectApp with the standard testing connect reply function and config
func NewBasicTestApp() ExpectApp {
return NewTestApp(nil, BasicConfigFn)
}
// BasicConfigFn is a default config function to be used when no special settings are needed for a test app
var BasicConfigFn = func(cfg *newrelic.Config) {
cfg.Enabled = false
}
// DTEnabledCfgFn is a reusable Config function that sets Distributed Tracing to enabled
var DTEnabledCfgFn = func(cfg *newrelic.Config) {
cfg.Enabled = false
cfg.DistributedTracer.Enabled = true
}
// SampleEverythingReplyFn is a reusable ConnectReply function that samples everything
var SampleEverythingReplyFn = func(reply *internal.ConnectReply) {
reply.SetSampleEverything()
}
|
