@@ -7,10 +7,10 @@ import (
77)
88
99func Example_instrumentation () {
10- cl := redis .NewClient (& redis.Options {
10+ redisdb := redis .NewClient (& redis.Options {
1111 Addr : ":6379" ,
1212 })
13- cl .WrapProcess (func (old func (cmd redis.Cmder ) error ) func (cmd redis.Cmder ) error {
13+ redisdb .WrapProcess (func (old func (cmd redis.Cmder ) error ) func (cmd redis.Cmder ) error {
1414 return func (cmd redis.Cmder ) error {
1515 fmt .Printf ("starting processing: <%s>\n " , cmd )
1616 err := old (cmd )
@@ -19,17 +19,17 @@ func Example_instrumentation() {
1919 }
2020 })
2121
22- cl .Ping ()
22+ redisdb .Ping ()
2323 // Output: starting processing: <ping: >
2424 // finished processing: <ping: PONG>
2525}
2626
2727func ExamplePipeline_instrumentation () {
28- client := redis .NewClient (& redis.Options {
28+ redisdb := redis .NewClient (& redis.Options {
2929 Addr : ":6379" ,
3030 })
3131
32- client .WrapProcessPipeline (func (old func ([]redis.Cmder ) error ) func ([]redis.Cmder ) error {
32+ redisdb .WrapProcessPipeline (func (old func ([]redis.Cmder ) error ) func ([]redis.Cmder ) error {
3333 return func (cmds []redis.Cmder ) error {
3434 fmt .Printf ("pipeline starting processing: %v\n " , cmds )
3535 err := old (cmds )
@@ -38,7 +38,7 @@ func ExamplePipeline_instrumentation() {
3838 }
3939 })
4040
41- client .Pipelined (func (pipe redis.Pipeliner ) error {
41+ redisdb .Pipelined (func (pipe redis.Pipeliner ) error {
4242 pipe .Ping ()
4343 pipe .Ping ()
4444 return nil
0 commit comments