tracing

Documentation

Index

• func GetSpanId(ctx context.Context) string
• func GetString(ctx context.Context, key string) string
• func GetTraceId(ctx context.Context) string
• func GetValue(ctx context.Context, key string) interface{}
• func InitJaeger(serviceName, endpoint string) (flush func(), err error)
• func NewAPISpan(r *ghttp.Request, spanName string) (context.Context, *gtrace.Span)
• func NewRPCClient(address string) (error, *gRPCClient)
• func NewRPCServer(address string) (error, *gRPCServer)
• func NewSpan(ctx context.Context, spanName string) (context.Context, *gtrace.Span)
• func Request(ctx context.Context, url string) string
• func Set(ctx context.Context, key string, value interface{}) context.Context

Functions

func GetSpanId

func GetSpanId(ctx context.Context) string

func GetString

func GetString(ctx context.Context, key string) string

GetString 从链路中获取指定key的字符串值

func GetTraceId

func GetTraceId(ctx context.Context) string

获取链路跟踪ID

func GetValue

func GetValue(ctx context.Context, key string) interface{}

func InitJaeger

func InitJaeger(serviceName, endpoint string) (flush func(), err error)

InitJaeger 初始化jaeger并将其注册到全局TracerProvider。 输出参数“flush”用于等待上载导出的跟踪范围， 如果您的程序正在结束，并且您不想丢失最近的跨距，则此选项非常有用

func NewAPISpan

func NewAPISpan(r *ghttp.Request, spanName string) (context.Context, *gtrace.Span)

NewSpan HTTP

func NewRPCClient

func NewRPCClient(address string) (error, *gRPCClient)

NewRPCClient 建立rpc连接

func NewRPCServer

func NewRPCServer(address string) (error, *gRPCServer)

NewServer 启动一个grpc服务

func NewSpan

func NewSpan(ctx context.Context, spanName string) (context.Context, *gtrace.Span)

NewSpan 第一个span获取方式context.Background()

func Request

func Request(ctx context.Context, url string) string

Request HTTP Client 向服务端发送请求

func Set

func Set(ctx context.Context, key string, value interface{}) context.Context

Set 链路设置键值