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 Config
• type HTTPTracer
  • func (t *HTTPTracer) Begin(ectx echo.Context)
  • func (t *HTTPTracer) End(ectx echo.Context)
• type LimitTracer
  • func (t *LimitTracer) Begin(ectx echo.Context)
  • func (t *LimitTracer) 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 Tracer
  • func New() *Tracer
  • func (t *Tracer) Close()
  • func (t *Tracer) Init(cfg interface{}) error
  • func (t *Tracer) Run()

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 Config

type Config struct {
	Endpoint      string  // jaeger 地址
	Probabilistic float64 // 采样率
	Name          string  // tracer name
}

Config 链路追踪配置

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 LimitTracer

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

LimitTracer token request limit

func (*LimitTracer) Begin

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

Begin 开始捕捉

func (*LimitTracer) End

func (t *LimitTracer) 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 Tracer

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

func New

func New() *Tracer

func (*Tracer) Close

func (t *Tracer) Close()

func (*Tracer) Init

func (t *Tracer) Init(cfg interface{}) error

func (*Tracer) Run

func (t *Tracer) Run()