opentracing_helper

Documentation

Index

• Variables
• func GetHTTPClient(srv IsTracedGetter) *http.Client
• func GetSpanFromRequest(r *http.Request, name string) opentracing.Span
• func InjectSpanToRequest(span opentracing.Span, r *http.Request)
• func Middleware(srv interface{}, name string, options ...nethttp.MWOption) http.HandlerFunc
• func NewRequester(srv IsTracedGetter) func(...nethttp.ClientOption) ...
• func NewTracer(name string, args ...interface{}) (opentracing.Tracer, io.Closer, error)
• type ComponentNameGetter
• type IsTracedGetter
• type JaegerTracerFactory
  • func (jtf *JaegerTracerFactory) New(args ...interface{}) (opentracing.Tracer, io.Closer, error)
• type TracerFactory
• type TracerOption

Variables

var (
	ErrInvalidTracerDriver = errors.New("invalid tracer driver")
)

Functions

func GetHTTPClient

func GetHTTPClient(srv IsTracedGetter) *http.Client

func GetSpanFromRequest

func GetSpanFromRequest(r *http.Request, name string) opentracing.Span

func InjectSpanToRequest

func InjectSpanToRequest(span opentracing.Span, r *http.Request)

func Middleware

func Middleware(srv interface{}, name string, options ...nethttp.MWOption) http.HandlerFunc

func NewRequester

func NewRequester(srv IsTracedGetter) func(...nethttp.ClientOption) func(context.Context, string, string, io.Reader) (*http.Request, *nethttp.Tracer, error)

func NewTracer

func NewTracer(name string, args ...interface{}) (opentracing.Tracer, io.Closer, error)

Types

type ComponentNameGetter

type ComponentNameGetter interface {
	ComponentName() string
}

type IsTracedGetter

type IsTracedGetter interface {
	IsTraced(*http.Request) bool
}

type JaegerTracerFactory

type JaegerTracerFactory struct{}

func (*JaegerTracerFactory) New

func (jtf *JaegerTracerFactory) New(args ...interface{}) (opentracing.Tracer, io.Closer, error)

type TracerFactory

type TracerFactory interface {
	New(args ...interface{}) (opentracing.Tracer, io.Closer, error)
}

type TracerOption

type TracerOption struct {
	*viper.Viper
}