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
|
// Copyright 2020 New Relic Corporation. All rights reserved.
// SPDX-License-Identifier: Apache-2.0
// Package nrnats instruments https://github.com/nats-io/nats.go.
//
// This package can be used to simplify instrumenting NATS publishers and subscribers. Currently due to the nature of
// the NATS framework we are limited to two integration points: `StartPublishSegment` for publishers, and `SubWrapper`
// for subscribers.
//
// NATS publishers
//
// To generate an external segment for any method that publishes or responds to a NATS message, use the
// `StartPublishSegment` method. The resulting segment will also need to be ended. Example:
//
// nc, _ := nats.Connect(nats.DefaultURL)
// txn := currentTransaction() // current newrelic.Transaction
// subject := "testing.subject"
// seg := nrnats.StartPublishSegment(txn, nc, subject)
// err := nc.Publish(subject, []byte("Hello World"))
// if nil != err {
// panic(err)
// }
// seg.End()
//
// Or:
//
// nc, _ := nats.Connect(nats.DefaultURL)
// txn := currentTransaction() // current newrelic.Transaction
// subject := "testing.subject"
// defer nrnats.StartPublishSegment(txn, nc, subject).End()
// nc.Publish(subject, []byte("Hello World"))
//
//
// StartPublishSegment can be used with a NATS Streamming Connection as well
// (https://github.com/nats-io/stan.go). Use the `NatsConn()` method on the
// `stan.Conn` interface (https://godoc.org/github.com/nats-io/stan#Conn) to
// access the `nats.Conn` object.
//
// sc, _ := stan.Connect(clusterID, clientID)
// txn := currentTransaction()
// subject := "testing.subject"
// defer nrnats.StartPublishSegment(txn, sc.NatsConn(), subject).End()
// sc.Publish(subject, []byte("Hello World"))
//
// NATS subscribers
//
// The `nrnats.SubWrapper` function can be used to wrap the function for `nats.Subscribe`
// (https://godoc.org/github.com/nats-io/go-nats#Conn.Subscribe or
// https://godoc.org/github.com/nats-io/go-nats#EncodedConn.Subscribe)
// and `nats.QueueSubscribe` (https://godoc.org/github.com/nats-io/go-nats#Conn.QueueSubscribe or
// https://godoc.org/github.com/nats-io/go-nats#EncodedConn.QueueSubscribe)
// If the `newrelic.Application` parameter is non-nil, it will create a `newrelic.Transaction` and end the transaction
// when the passed function is complete. Example:
//
// nc, _ := nats.Connect(nats.DefaultURL)
// app := createNRApp() // newrelic.Application
// subject := "testing.subject"
// nc.Subscribe(subject, nrnats.SubWrapper(app, myMessageHandler))
//
// Full Publisher/Subscriber example:
// https://github.com/newrelic/go-agent/blob/master/v3/integrations/nrnats/examples/main.go
package nrnats
import "github.com/newrelic/go-agent/v3/internal"
func init() { internal.TrackUsage("integration", "framework", "nats") }
|
