otgoredis

README

opentracing-go-redis

OpenTracing instrumentation for go-redis.

This instrumentation bases on internal tracing of go-redis.

Install

go get -u github.com/lyb0307/opentracing-go-redis

Usage

Example:

package main

import (
"github.com/go-redis/redis/v8"
"github.com/lyb0307/otgoredis"
)

func main() {
    tracer := ... // init your tracer

    rdb := redis.NewClient(&redis.Options{
        Addr: "localhost:6379",
        DB: 0,
    })
    
    rdb.AddHook(otgoredis.NewHookWithTracer(tracer))
}

License

MIT

Documentation

Index

• func AppendArg(b []byte, v interface{}) []byte
• func Bytes(s string) []byte
• func String(b []byte) string
• type OpenTracingHook
  • func NewHook() *OpenTracingHook
  • func NewHookWithTracer(tracker opentracing.Tracer) *OpenTracingHook
  • func (h *OpenTracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (h *OpenTracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (h *OpenTracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (h *OpenTracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

Functions

func AppendArg

func AppendArg(b []byte, v interface{}) []byte

func Bytes

func Bytes(s string) []byte

Bytes converts string to byte slice.

func String

func String(b []byte) string

String converts byte slice to string.

Types

type OpenTracingHook

type OpenTracingHook struct {
	Tracker opentracing.Tracer
}

func NewHook

func NewHook() *OpenTracingHook

func NewHookWithTracer

func NewHookWithTracer(tracker opentracing.Tracer) *OpenTracingHook

func (*OpenTracingHook) AfterProcess

func (h *OpenTracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*OpenTracingHook) AfterProcessPipeline

func (h *OpenTracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*OpenTracingHook) BeforeProcess

func (h *OpenTracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (*OpenTracingHook) BeforeProcessPipeline

func (h *OpenTracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)