kjaeger

Documentation

Index

• func HTTPServerTracing(tracer opentracing.Tracer) gin.HandlerFunc
• func New(opts ...*Option) (opentracing.Tracer, io.Closer, error)
• func NewHook(tracer opentracing.Tracer) redis.Hook
• func RestyTracingAfter() func(*resty.Client, *resty.Response) error
• func RestyTracingBefore(tracer opentracing.Tracer) func(*resty.Client, *resty.Request) error
• type Option
  • func ConfigOption(key string) (option *Option, err error)
  • func NewOption() *Option
  • func SetBufferFlushInterval(l string) *Option
  • func SetLocalAgentHostPort(l string) *Option
  • func SetLogger(l baselogger.JaegerLogger) *Option
  • func SetPanicOnError(l string) *Option
  • func SetReporterLogSpans(l bool) *Option
  • func SetSampleParam(l float64) *Option
  • func SetSampleType(l string) *Option
  • func SetServiceName(s string) *Option
  • func SetTag(l ...opentracing.Tag) *Option
  • func SetTraceBaggageHeaderPrefix(l string) *Option
  • func SetTraceContextHeaderName(l string) *Option
  • func (c *Option) MergeOption(opts ...*Option) *Option
  • func (c *Option) SetBufferFlushInterval(l string) *Option
  • func (c *Option) SetLocalAgentHostPort(l string) *Option
  • func (c *Option) SetLogger(l baselogger.JaegerLogger) *Option
  • func (c *Option) SetPanicOnError(l string) *Option
  • func (c *Option) SetReporterLogSpans(l bool) *Option
  • func (c *Option) SetSampleParam(l float64) *Option
  • func (c *Option) SetSampleType(l string) *Option
  • func (c *Option) SetServiceName(s string) *Option
  • func (c *Option) SetTag(l ...opentracing.Tag) *Option
  • func (c *Option) SetTraceBaggageHeaderPrefix(l string) *Option
  • func (c *Option) SetTraceContextHeaderName(l string) *Option
• type RedisTracingHook
  • func (hook RedisTracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (hook RedisTracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (hook RedisTracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (hook RedisTracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

Functions

func HTTPServerTracing

func HTTPServerTracing(tracer opentracing.Tracer) gin.HandlerFunc

func New

func New(opts ...*Option) (opentracing.Tracer, io.Closer, error)

func NewHook

func NewHook(tracer opentracing.Tracer) redis.Hook

NewHook creates a new go-redis hook instance and that will collect spans using the provided tracer.

func RestyTracingAfter

func RestyTracingAfter() func(*resty.Client, *resty.Response) error

func RestyTracingBefore

func RestyTracingBefore(tracer opentracing.Tracer) func(*resty.Client, *resty.Request) error

Types

type Option

type Option struct {
	Logger                   baselogger.JaegerLogger
	ServiceName              string
	SampleType               string
	LocalAgentHostPort       string
	TraceBaggageHeaderPrefix string
	TraceContextHeaderName   string
	BufferFlushInterval      string

	SampleParam      float64
	EnableRPCMetrics bool
	ReporterLogSpans bool
	// contains filtered or unexported fields
}

Config HTTP config

func ConfigOption

func ConfigOption(key string) (option *Option, err error)

RawConfig ...

func NewOption

func NewOption() *Option

func SetBufferFlushInterval

func SetBufferFlushInterval(l string) *Option

func SetLocalAgentHostPort

func SetLocalAgentHostPort(l string) *Option

func SetLogger

func SetLogger(l baselogger.JaegerLogger) *Option

func SetPanicOnError

func SetPanicOnError(l string) *Option

func SetReporterLogSpans

func SetReporterLogSpans(l bool) *Option

func SetSampleParam

func SetSampleParam(l float64) *Option

func SetSampleType

func SetSampleType(l string) *Option

func SetServiceName

func SetServiceName(s string) *Option

func SetTag

func SetTag(l ...opentracing.Tag) *Option

func SetTraceBaggageHeaderPrefix

func SetTraceBaggageHeaderPrefix(l string) *Option

func SetTraceContextHeaderName

func SetTraceContextHeaderName(l string) *Option

func (*Option) MergeOption

func (c *Option) MergeOption(opts ...*Option) *Option

func (*Option) SetBufferFlushInterval

func (c *Option) SetBufferFlushInterval(l string) *Option

func (*Option) SetLocalAgentHostPort

func (c *Option) SetLocalAgentHostPort(l string) *Option

func (*Option) SetLogger

func (c *Option) SetLogger(l baselogger.JaegerLogger) *Option

func (*Option) SetPanicOnError

func (c *Option) SetPanicOnError(l string) *Option

func (*Option) SetReporterLogSpans

func (c *Option) SetReporterLogSpans(l bool) *Option

func (*Option) SetSampleParam

func (c *Option) SetSampleParam(l float64) *Option

func (*Option) SetSampleType

func (c *Option) SetSampleType(l string) *Option

func (*Option) SetServiceName

func (c *Option) SetServiceName(s string) *Option

func (*Option) SetTag

func (c *Option) SetTag(l ...opentracing.Tag) *Option

func (*Option) SetTraceBaggageHeaderPrefix

func (c *Option) SetTraceBaggageHeaderPrefix(l string) *Option

func (*Option) SetTraceContextHeaderName

func (c *Option) SetTraceContextHeaderName(l string) *Option

type RedisTracingHook

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

func (RedisTracingHook) AfterProcess

func (hook RedisTracingHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (RedisTracingHook) AfterProcessPipeline

func (hook RedisTracingHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (RedisTracingHook) BeforeProcess

func (hook RedisTracingHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (RedisTracingHook) BeforeProcessPipeline

func (hook RedisTracingHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)