tracing

README

在glog使用traceId

func InitLog() error {
    err := glog.InitLog(
        config.SetFileName2Logger(name),
        func (cfg *config.Config) {
            cfg.TradeIDFunc = func (entry *message.Entry) string {
                return GetTraceIdFromCache(entry.RoutineId)
            },      
        },
    )
    if err != nil {
        log.Errorf("err: %v", err)
        return err
    }
}

Documentation

Index

• Variables
• func GetTraceIdFromCache(key int64) string
• func InitTracer(url string, serviceName string) error
• func NewCacheTraceId() *traceIdCache
• func SetClientSpan(ctx context.Context, span trace.Span, m interface{})
• func SetServerSpan(ctx context.Context, span trace.Span, m interface{})
• func SpanID(ctx context.Context) string
• func TraceID(ctx context.Context) string
• type ClientHandler
  • func (c *ClientHandler) HandleConn(_ context.Context, _ stats.ConnStats)
  • func (c *ClientHandler) HandleRPC(ctx context.Context, rs stats.RPCStats)
  • func (c *ClientHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context
  • func (c *ClientHandler) TagRPC(ctx context.Context, _ *stats.RPCTagInfo) context.Context
• type Metadata
  • func (b Metadata) Extract(parent context.Context, carrier propagation.TextMapCarrier) context.Context
  • func (b Metadata) Fields() []string
  • func (b Metadata) Inject(ctx context.Context, carrier propagation.TextMapCarrier)
• type Option
  • func WithPropagator(propagator propagation.TextMapPropagator) Option
  • func WithTracerName(tracerName string) Option
  • func WithTracerProvider(provider trace.TracerProvider) Option
• type Tracer
  • func NewTracer(kind trace.SpanKind, opts ...Option) *Tracer
  • func (t *Tracer) End(_ context.Context, span trace.Span, m interface{}, err error)
  • func (t *Tracer) Start(ctx context.Context, operation string, carrier propagation.TextMapCarrier) (context.Context, trace.Span)

Variables

var CacheTraceId *traceIdCache

Functions

func GetTraceIdFromCache

func GetTraceIdFromCache(key int64) string

func InitTracer

func InitTracer(url string, serviceName string) error

InitTracer 设置全局trace

func NewCacheTraceId

func NewCacheTraceId() *traceIdCache

func SetClientSpan

func SetClientSpan(ctx context.Context, span trace.Span, m interface{})

func SetServerSpan

func SetServerSpan(ctx context.Context, span trace.Span, m interface{})

func SpanID

func SpanID(ctx context.Context) string

SpanID returns a span_id valuer.

func TraceID

func TraceID(ctx context.Context) string

TraceID returns a trace_id valuer.

Types

type ClientHandler

type ClientHandler struct{}

ClientHandler is tracing ClientHandler

func (*ClientHandler) HandleConn

func (c *ClientHandler) HandleConn(_ context.Context, _ stats.ConnStats)

HandleConn exists to satisfy gRPC stats.Handler.

func (*ClientHandler) HandleRPC

func (c *ClientHandler) HandleRPC(ctx context.Context, rs stats.RPCStats)

HandleRPC implements per-RPC tracing and stats instrumentation.

func (*ClientHandler) TagConn

func (c *ClientHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context

TagConn exists to satisfy gRPC stats.Handler.

func (*ClientHandler) TagRPC

func (c *ClientHandler) TagRPC(ctx context.Context, _ *stats.RPCTagInfo) context.Context

TagRPC implements per-RPC context management.

type Metadata

type Metadata struct{}

Metadata is tracing metadata propagator

func (Metadata) Extract

func (b Metadata) Extract(parent context.Context, carrier propagation.TextMapCarrier) context.Context

Extract returns a copy of parent with the metadata from the carrier added.

func (Metadata) Fields

func (b Metadata) Fields() []string

Fields returns the keys who's values are set with Inject.

func (Metadata) Inject

func (b Metadata) Inject(ctx context.Context, carrier propagation.TextMapCarrier)

Inject sets metadata key-values from ctx into the carrier.

type Option

type Option func(*options)

Option is tracing option.

func WithPropagator

func WithPropagator(propagator propagation.TextMapPropagator) Option

WithPropagator with tracer propagator.

func WithTracerName

func WithTracerName(tracerName string) Option

WithTracerName with tracer name

func WithTracerProvider

func WithTracerProvider(provider trace.TracerProvider) Option

WithTracerProvider with tracer provider. By default, it uses the global provider that is set by otel.SetTracerProvider(provider).

type Tracer

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

Tracer is otel span tracer

func NewTracer

func NewTracer(kind trace.SpanKind, opts ...Option) *Tracer

NewTracer create tracer instance

func (*Tracer) End

func (t *Tracer) End(_ context.Context, span trace.Span, m interface{}, err error)

End finish tracing span

func (*Tracer) Start

func (t *Tracer) Start(ctx context.Context, operation string, carrier propagation.TextMapCarrier) (context.Context, trace.Span)

Start start tracing span