tracer

Documentation

Index

• Constants
• Variables
• func Closer() (errs []error)
• func ConfigFromViper(v *viper.Viper) (c *config.Configuration, err error)
• func DoAfter(span opentracing.Span, resp *http.Response, err error)
• func DoBefore(ctx context.Context, req *http.Request, operationName string) (span opentracing.Span, newCtx context.Context, err error)
• func ExtractSpanFromGinContext(c *gin.Context) (span opentracing.Span, err error)
• func ExtractSpanFromHeader(req *http.Request, operationName string) (span opentracing.Span)
• func GinContextConvert(ctx context.Context, c *gin.Context) (newCtx context.Context, err error)
• func GinHandler() gin.HandlerFunc
• func Init(v *viper.Viper)
• func InjectSpanToGinContext(c *gin.Context, span opentracing.Span)
• func InjectSpanToHeader(req *http.Request, span opentracing.Span) (err error)
• func NewRedisHook(config RedisHookConfig) redis.Hook
• func NewTracerDB(ctx context.Context, db *gorm.DB) *gorm.DB
• func NewTracerRedisClient(ctx context.Context, cli *redis.Client) *redis.Client
• func NewTracerRedisClusterClient(ctx context.Context, cli *redis.ClusterClient) *redis.ClusterClient
• func NewTracerRedisSentinelClient(ctx context.Context, cli *redis.SentinelClient) *redis.SentinelClient
• func RegisterDB(db *gorm.DB)
• type RedisHookConfig

Constants

const (
	//DBTraceContextKey opentracing在db中保存context的Key
	DBTraceContextKey = "trace.db.context"
	//DBTraceSpanKey opentracing在db中保存span的Key
	DBTraceSpanKey = "trace.db.span"
)

const (
	//TraceGinSpanKey opentracing在gin中保存span的Key
	TraceGinSpanKey = "tracer.span"
)

Variables

var DBStatement = string(ext.DBStatement)

DBStatement opentracing ext.DBStatement

var (
	//Enable 是否启用Opentracing
	Enable bool
)

Functions

func Closer

func Closer() (errs []error)

Closer .

func ConfigFromViper

func ConfigFromViper(v *viper.Viper) (c *config.Configuration, err error)

ConfigFromViper 从viper中获取配置信息

func DoAfter

func DoAfter(span opentracing.Span, resp *http.Response, err error)

DoAfter http 请求之后

func DoBefore

func DoBefore(ctx context.Context, req *http.Request, operationName string) (span opentracing.Span, newCtx context.Context, err error)

DoBefore http 请求之前

func ExtractSpanFromGinContext

func ExtractSpanFromGinContext(c *gin.Context) (span opentracing.Span, err error)

ExtractSpanFromGinContext 从ginContext提取span信息

func ExtractSpanFromHeader

func ExtractSpanFromHeader(req *http.Request, operationName string) (span opentracing.Span)

ExtractSpanFromHeader 从http请求头中获取链路跟踪信息 主要是给自己暴露的API请求过滤器中使用

func GinContextConvert

func GinContextConvert(ctx context.Context, c *gin.Context) (newCtx context.Context, err error)

GinContextConvert ginContext转换成ctx

func GinHandler

func GinHandler() gin.HandlerFunc

GinHandler .

func Init

func Init(v *viper.Viper)

Init 启用链路跟踪

func InjectSpanToGinContext

func InjectSpanToGinContext(c *gin.Context, span opentracing.Span)

InjectSpanToGinContext 将span写入ginContext

func InjectSpanToHeader

func InjectSpanToHeader(req *http.Request, span opentracing.Span) (err error)

InjectSpanToHeader 将Span信息注入到Header中

func NewRedisHook

func NewRedisHook(config RedisHookConfig) redis.Hook

NewRedisHook .

func NewTracerDB

func NewTracerDB(ctx context.Context, db *gorm.DB) *gorm.DB

NewTracerDB 获取新的带有span的DB

func NewTracerRedisClient

func NewTracerRedisClient(ctx context.Context, cli *redis.Client) *redis.Client

NewTracerRedisClient .

func NewTracerRedisClusterClient

func NewTracerRedisClusterClient(ctx context.Context, cli *redis.ClusterClient) *redis.ClusterClient

NewTracerRedisClusterClient .

func NewTracerRedisSentinelClient

func NewTracerRedisSentinelClient(ctx context.Context, cli *redis.SentinelClient) *redis.SentinelClient

NewTracerRedisSentinelClient .

func RegisterDB

func RegisterDB(db *gorm.DB)

RegisterDB .

Types

type RedisHookConfig

type RedisHookConfig struct {
	Name string
}

RedisHookConfig .