trace

package

v0.0.0-...-8964234 Latest Latest Go to latest Published: Jun 20, 2022 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/g-airport/go-infra

Links

Open Source Insights

README ¶

Embed Trace

config

import "github.com/uber/jaeger-client-go/config"

cfg := config.Configuration{
		Sampler: &config.SamplerConfig{
			Type:                    jaeger.SamplerTypeConst,
			Param:                   1,
			SamplingRefreshInterval: time.Second,
		},
		Reporter: &config.ReporterConfig{
			LogSpans:            true,
			LocalAgentHostPort:  "127.0.0.1:5775",
			BufferFlushInterval: time.Second,
		},
	}

init

    InitByConfig(serviceName, cfg)

trace

    span, ctx := opentracing.StartSpanFromContext(context.Background(), "name")
    span.Finish()

Documentation ¶

Index ¶

func ClientWrapper() client.CallWrapper
func ExtractSpanContextFromContext(ctx context.Context, tracer opentracing.Tracer) (opentracing.SpanContext, error)
func ExtractSpanContextFromMQHeader(header amqp.Table, tracer opentracing.Tracer) (opentracing.SpanContext, error)
func ExtractSpanFromContext(ctx context.Context, tracer opentracing.Tracer, operationName string) opentracing.Span
func ExtractSpanFromMQHeader(header amqp.Table, tracer opentracing.Tracer, name string) (sp opentracing.Span)
func GRPCServerWrapper()
func Init(serviceName string) (io.Closer, error)
func InitByConfig(serviceName string, cfg jCfg.Configuration) (io.Closer, error)
func InjectSpanContextToContext(ctx context.Context, tracer opentracing.Tracer, ...) (context.Context, error)
func InjectSpanContextToMQHeader(header amqp.Table, tracer opentracing.Tracer, ...) error
func InjectSpanToContext(ctx context.Context, span opentracing.Span) (context.Context, error)
func InjectSpanToMQHeader(header amqp.Table, span opentracing.Span) error
func ServerWrapper() server.HandlerWrapper
type MQTextMapCarrier
- func (c MQTextMapCarrier) ForeachKey(handler func(key, val string) error) error
- func (c MQTextMapCarrier) Set(key, val string)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ClientWrapper ¶

func ClientWrapper() client.CallWrapper

func ExtractSpanContextFromContext ¶

func ExtractSpanContextFromContext(ctx context.Context, tracer opentracing.Tracer) (opentracing.SpanContext, error)

func ExtractSpanContextFromMQHeader ¶

func ExtractSpanContextFromMQHeader(header amqp.Table, tracer opentracing.Tracer) (opentracing.SpanContext, error)

func ExtractSpanFromContext ¶

func ExtractSpanFromContext(ctx context.Context, tracer opentracing.Tracer, operationName string) opentracing.Span

func ExtractSpanFromMQHeader ¶

func ExtractSpanFromMQHeader(header amqp.Table, tracer opentracing.Tracer, name string) (sp opentracing.Span)

func GRPCServerWrapper ¶

func GRPCServerWrapper()

func Init ¶

func Init(serviceName string) (io.Closer, error)

this method will initial global tracer if no call global tracer default no-op tracer init config from key:value

func InitByConfig ¶

func InitByConfig(serviceName string, cfg jCfg.Configuration) (io.Closer, error)

func InjectSpanContextToContext ¶

func InjectSpanContextToContext(ctx context.Context, tracer opentracing.Tracer, spanContext opentracing.SpanContext) (context.Context, error)

func InjectSpanContextToMQHeader ¶

func InjectSpanContextToMQHeader(header amqp.Table, tracer opentracing.Tracer, spanContext opentracing.SpanContext) error

func InjectSpanToContext ¶

func InjectSpanToContext(ctx context.Context, span opentracing.Span) (context.Context, error)

func InjectSpanToMQHeader ¶

func InjectSpanToMQHeader(header amqp.Table, span opentracing.Span) error

func ServerWrapper ¶

func ServerWrapper() server.HandlerWrapper

Types ¶

type MQTextMapCarrier ¶

type MQTextMapCarrier amqp.Table

func (MQTextMapCarrier) ForeachKey ¶

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

func (MQTextMapCarrier) Set ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL