tracer

Documentation

Index

• func ExtractSpanContextFromMessageHeaders(ctx context.Context, h *bertytypes.MessageHeaders) context.Context
• func From(ctx context.Context) trace.Tracer
• func InitTracer(flag, service string) func()
• func InjectSpanContextToMessageHeaders(ctx context.Context, h *bertytypes.MessageHeaders)
• func New(name string) trace.Tracer
• func NewJaegerProvider(host, service string) (trace.Provider, func(), error)
• func NewStdoutProvider() (trace.Provider, error)
• func NewTestingProvider(t *testing.T, name string) trace.Provider
• func Propagators() propagation.Propagators
• func SetGlobalTraceProvider(tp trace.Provider)
• func SpanFromMessageHeaders(ctx context.Context, h *bertytypes.MessageHeaders, name string, ...) (context.Context, trace.Span)
• type Cleanup
  • func ConfigureProvider(cfg *Config) (pt trace.Provider, cl Cleanup, err error)
• type Config
• type ExporterType
• type RuntimeProvider
  • func NewRuntimeProvider(root trace.Provider) *RuntimeProvider
  • func (rp *RuntimeProvider) Tracer(name string) trace.Tracer
• type RuntimeTracer
  • func (rt *RuntimeTracer) Start(ctx context.Context, spanName string, opts ...trace.StartOption) (context.Context, trace.Span)
  • func (rt *RuntimeTracer) WithSpan(ctx context.Context, spanName string, fn func(ctx context.Context) error, ...) error

Functions

func ExtractSpanContextFromMessageHeaders

func ExtractSpanContextFromMessageHeaders(ctx context.Context, h *bertytypes.MessageHeaders) context.Context

func From

func From(ctx context.Context) trace.Tracer

func InitTracer

func InitTracer(flag, service string) func()

func InjectSpanContextToMessageHeaders

func InjectSpanContextToMessageHeaders(ctx context.Context, h *bertytypes.MessageHeaders)

func New

func New(name string) trace.Tracer

func NewJaegerProvider

func NewJaegerProvider(host, service string) (trace.Provider, func(), error)

func NewStdoutProvider

func NewStdoutProvider() (trace.Provider, error)

func NewTestingProvider

func NewTestingProvider(t *testing.T, name string) trace.Provider

func Propagators

func Propagators() propagation.Propagators

func SetGlobalTraceProvider

func SetGlobalTraceProvider(tp trace.Provider)

func SpanFromMessageHeaders

func SpanFromMessageHeaders(ctx context.Context, h *bertytypes.MessageHeaders, name string, attrs ...kv.KeyValue) (context.Context, trace.Span)

Types

type Cleanup

type Cleanup func()

func ConfigureProvider

func ConfigureProvider(cfg *Config) (pt trace.Provider, cl Cleanup, err error)

type Config

type Config struct {
	ExporterType    ExporterType
	ServiceName     string
	RuntimeProvider bool

	// Jaeger config
	JaegerHost string
}

type ExporterType

type ExporterType int

const (
	ExporterTypeNone ExporterType = iota
	ExporterTypeStdout
	ExporterTypeJaeger
)

type RuntimeProvider

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

func NewRuntimeProvider

func NewRuntimeProvider(root trace.Provider) *RuntimeProvider

func (*RuntimeProvider) Tracer

func (rp *RuntimeProvider) Tracer(name string) trace.Tracer

type RuntimeTracer

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

func (*RuntimeTracer) Start

func (rt *RuntimeTracer) Start(ctx context.Context, spanName string, opts ...trace.StartOption) (context.Context, trace.Span)

Start identical to original start span, but automatically add runtime information to the span

func (*RuntimeTracer) WithSpan

func (rt *RuntimeTracer) WithSpan(ctx context.Context, spanName string, fn func(ctx context.Context) error, opts ...trace.StartOption) error

WithSpan is identical to original start span, but automatically add runtime information to the span