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
|
// Copyright 2020 New Relic Corporation. All rights reserved.
// SPDX-License-Identifier: Apache-2.0
package nrredis_test
import (
"context"
"fmt"
redis "github.com/go-redis/redis/v7"
nrredis "github.com/newrelic/go-agent/v3/integrations/nrredis-v7"
newrelic "github.com/newrelic/go-agent/v3/newrelic"
)
func getTransaction() *newrelic.Transaction { return nil }
func Example_client() {
opts := &redis.Options{Addr: "localhost:6379"}
client := redis.NewClient(opts)
//
// Step 1: Add a nrredis.NewHook() to your redis client.
//
client.AddHook(nrredis.NewHook(opts))
//
// Step 2: Ensure that all client calls contain a context with includes
// the transaction.
//
txn := getTransaction()
ctx := newrelic.NewContext(context.Background(), txn)
pong, err := client.WithContext(ctx).Ping().Result()
fmt.Println(pong, err)
}
func Example_clusterClient() {
client := redis.NewClusterClient(&redis.ClusterOptions{
Addrs: []string{":7000", ":7001", ":7002", ":7003", ":7004", ":7005"},
})
//
// Step 1: Add a nrredis.NewHook() to your redis cluster client.
//
client.AddHook(nrredis.NewHook(nil))
//
// Step 2: Ensure that all client calls contain a context with includes
// the transaction.
//
txn := getTransaction()
ctx := newrelic.NewContext(context.Background(), txn)
pong, err := client.WithContext(ctx).Ping().Result()
fmt.Println(pong, err)
}
|
