tracer

Documentation

Index

• Variables
• func ClientInterceptor(tracer opentracing.Tracer) grpc.UnaryClientInterceptor
• func GetGRPCServerTracer() grpc.ServerOption
• func NewSlowReporter(sender jaeger.Transport, metrics *jaeger.Metrics, probabilistic float64) jaeger.Reporter
• type HTTPTracer
  • func (t *HTTPTracer) Begin(ectx echo.Context)
  • func (t *HTTPTracer) End(ectx echo.Context)
• type MDReaderWriter
  • func (c MDReaderWriter) ForeachKey(handler func(key, val string) error) error
  • func (c MDReaderWriter) Set(key, val string)
• type Option
  • func WithProbabilistic(probabilistic float64) Option
  • func WithSlowRequest(ms int) Option
  • func WithSlowSpan(ms int) Option
• type RedisTracer
  • func (r *RedisTracer) Begin(ctx context.Context)
  • func (r *RedisTracer) End()
• type TraceKey
• type Tracer
  • func New(name string, jaegerAddress string, opts ...Option) *Tracer
  • func (t *Tracer) Init() error

Variables

var (

	// ErrConfigConvert 配置转换失败
	ErrConfigConvert = errors.New("Convert linker config")
)

Functions

func ClientInterceptor

func ClientInterceptor(tracer opentracing.Tracer) grpc.UnaryClientInterceptor

ClientInterceptor rpc拦截器

func GetGRPCServerTracer

func GetGRPCServerTracer() grpc.ServerOption

GetGRPCServerTracer 获取GRPC Server拦截器

func NewSlowReporter

func NewSlowReporter(sender jaeger.Transport, metrics *jaeger.Metrics, probabilistic float64) jaeger.Reporter

NewSlowReporter creates a new reporter that sends spans out of process by means of Sender.

Types

type HTTPTracer

type HTTPTracer struct {
	// contains filtered or unexported fields
}

HTTPTracer http request tracer

func (*HTTPTracer) Begin

func (t *HTTPTracer) Begin(ectx echo.Context)

Begin 开始捕捉

func (*HTTPTracer) End

func (t *HTTPTracer) End(ectx echo.Context)

End 结束捕捉

type MDReaderWriter

type MDReaderWriter struct {
	metadata.MD
}

MDReaderWriter metadata 读写

func (MDReaderWriter) ForeachKey

func (c MDReaderWriter) ForeachKey(handler func(key, val string) error) error

ForeachKey 为了 opentracing.TextMapReader ，参考 opentracing 代码

func (MDReaderWriter) Set

func (c MDReaderWriter) Set(key, val string)

Set 为了 opentracing.TextMapWriter，参考 opentracing 代码

type Option

type Option func(*Tracer)

Option config wraps

func WithProbabilistic

func WithProbabilistic(probabilistic float64) Option

WithProbabilistic 采样率 0 ~ 1

func WithSlowRequest

func WithSlowRequest(ms int) Option

WithSlowRequest 单次请求阀值（超过会有慢日志

func WithSlowSpan

func WithSlowSpan(ms int) Option

WithSlowSpan 单次调用阀值（超过会有慢日志

type RedisTracer

type RedisTracer struct {
	Cmd string
	// contains filtered or unexported fields
}

RedisTracer redis tracer

func (*RedisTracer) Begin

func (r *RedisTracer) Begin(ctx context.Context)

Begin 开始监听

func (*RedisTracer) End

func (r *RedisTracer) End()

End 结束监听

type TraceKey

type TraceKey int

TraceKey 主键类型

const (
	// RequestKey 请求的键值
	RequestKey TraceKey = 1000 + iota
)

type Tracer

type Tracer struct {
	// contains filtered or unexported fields
}

Tracer tracer struct

func New

func New(name string, jaegerAddress string, opts ...Option) *Tracer

New n

func (*Tracer) Init

func (t *Tracer) Init() error

Init 初始化