redis

To start tracing Redis, simply create a new client using the library and continue using as you normally would.

package main

import (
	"context"

	redistrace "github.com/DataDog/dd-trace-go/contrib/go-redis/redis.v8/v2"

	"github.com/DataDog/dd-trace-go/v2/ddtrace/ext"
	"github.com/DataDog/dd-trace-go/v2/ddtrace/tracer"

	"github.com/go-redis/redis/v8"
)

func main() {
	tracer.Start()
	defer tracer.Stop()

	ctx := context.Background()
	// create a new Client
	opts := &redis.Options{Addr: "127.0.0.1", Password: "", DB: 0}
	c := redistrace.NewClient(opts)

	// any action emits a span
	c.Set(ctx, "test_key", "test_value", 0)

	// optionally, create a new root span
	root, ctx := tracer.StartSpanFromContext(context.Background(), "parent.request",
		tracer.SpanType(ext.SpanTypeRedis),
		tracer.ServiceName("web"),
		tracer.ResourceName("/home"),
	)

	// commit further commands, which will inherit from the parent in the context.
	c.Set(ctx, "food", "cheese", 0)
	root.Finish()
}

Output:

You can also trace Redis Pipelines. Simply use as usual and the traces will be automatically picked up by the underlying implementation.

package main

import (
	"context"
	"time"

	redistrace "github.com/DataDog/dd-trace-go/contrib/go-redis/redis.v8/v2"

	"github.com/DataDog/dd-trace-go/v2/ddtrace/tracer"

	"github.com/go-redis/redis/v8"
)

func main() {
	tracer.Start()
	defer tracer.Stop()

	ctx := context.Background()
	// create a client
	opts := &redis.Options{Addr: "127.0.0.1", Password: "", DB: 0}
	c := redistrace.NewClient(opts, redistrace.WithService("my-redis-service"))

	// open the pipeline
	pipe := c.Pipeline()

	// submit some commands
	pipe.Incr(ctx, "pipeline_counter")
	pipe.Expire(ctx, "pipeline_counter", time.Hour)

	// execute with trace
	pipe.Exec(ctx)
}

Output:

You can create a traced ClusterClient using WrapClient

package main

import (
	"context"

	redistrace "github.com/DataDog/dd-trace-go/contrib/go-redis/redis.v8/v2"

	"github.com/DataDog/dd-trace-go/v2/ddtrace/tracer"

	"github.com/go-redis/redis/v8"
)

func main() {
	tracer.Start()
	defer tracer.Stop()

	c := redis.NewClusterClient(&redis.ClusterOptions{})
	redistrace.WrapClient(c)

	//Do something, passing in any relevant context
	c.Incr(context.TODO(), "my_counter")
}

Output: