instaredis

README

Instana instrumentation for go-redis

This module contains instrumentation code for Redis clients written with go-redis.

Installation

To add the module to your go.mod file run the following command in your project directory:

$ go get github.com/instana/go-sensor/instrumentation/instaredis

Usage

instaredis offers function wrappers for redis.NewClient(), redis.NewFailoverClient(), redis.NewClusterClient() and redis.NewFailoverClusterClient() that instrument an instance of redis.Client or redis.ClusterClient by adding hooks to the redis client. These hooks then use the provided instana.Collector to trace Redis calls made with this client instance:

rdb := redis.NewClient(&redis.Options{
	Addr: "localhost:6382",
})

instaredis.WrapClient(rdb, collector)

See the instaredis package documentation for detailed examples.

Documentation

Overview

Example

package main

import (
	"context"
	"time"

	"github.com/go-redis/redis/v8"
	instana "github.com/instana/go-sensor"
	"github.com/instana/go-sensor/instrumentation/instaredis"
)

func main() {

	// Initialize Instana collector
	c := instana.InitCollector(&instana.Options{
		Service: "redis-client",
	})
	defer instana.ShutdownCollector()

	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	rdb := redis.NewClient(&redis.Options{
		Addr: "localhost:6382",
	})

	// Use instaredis.WrapClient() after the Redis client instance is created in order to instrument the client.
	// The same instaredis.WrapClient() can be used when creating a Redis client with redis.NewFailoverClient.
	// When creating an instance of Redis to communicate with a cluster, instaredis.WrapClusterClient() should be used
	// instead. These cases apply when a client is being created via redis.NewClusterClient() or
	// redis.NewFailoverClusterClient()
	instaredis.WrapClient(rdb, c)

	// Use the API normally.
	rdb.Do(ctx, "incr", "counter")
	rdb.Get(ctx, "counter").Bytes()

	pipe := rdb.Pipeline()
	pipe.Set(ctx, "name", "Instana", time.Minute)
	pipe.Incr(ctx, "some_counter")
	pipe.Exec(ctx)

	txPipe := rdb.TxPipeline()
	txPipe.Set(ctx, "email", "info@instana.com", time.Minute)
	txPipe.Incr(ctx, "some_counter")
	txPipe.Exec(ctx)
}

Index

• Constants
• type InstanaRedisClient
  • func WrapClient(client InstanaRedisClient, sensor instana.TracerLogger) InstanaRedisClient
• type InstanaRedisClusterClient
  • func WrapClusterClient(clusterClient InstanaRedisClusterClient, sensor instana.TracerLogger) InstanaRedisClusterClient

Examples

• Package

Constants

const Version = "1.50.0"

Version is the instrumentation module semantic version

Types

type InstanaRedisClient

type InstanaRedisClient interface {
	AddHook(hook redis.Hook)
	Options() *redis.Options
}

func WrapClient

func WrapClient(client InstanaRedisClient, sensor instana.TracerLogger) InstanaRedisClient

WrapClient wraps the Redis client instance in order to add the instrumentation

type InstanaRedisClusterClient

type InstanaRedisClusterClient interface {
	AddHook(hook redis.Hook)
	Options() *redis.ClusterOptions
}

func WrapClusterClient

func WrapClusterClient(clusterClient InstanaRedisClusterClient, sensor instana.TracerLogger) InstanaRedisClusterClient

WrapClusterClient wraps the Redis client instance in order to add the instrumentation